Commit 49232fc7 by Adi Amir

make cisco.getParkingSpots working again

parent 27d263d1
......@@ -10,6 +10,7 @@ sourceCompatibility = 1.8
repositories {
mavenLocal()
maven { url "http://mandubian-mvn.googlecode.com/svn/trunk/mandubian-mvn/repository" }
maven { url "https://mvnrepository.com/artifact/org.eclipse.jetty.websocket/websocket-client" }
maven { url "http://172.16.1.132:8081/repository/internal" }
}
......@@ -25,6 +26,7 @@ dependencies {
compile group: 'javax.websocket', name: 'javax.websocket-api', version: '1.1'
compile 'com.neovisionaries:nv-websocket-client:1.30'
compile 'org.java-websocket:Java-WebSocket:1.3.0'
compile group: 'org.eclipse.jetty.websocket', name: 'websocket-client', version: '9.4.0.M1'
///json-patch start
compile 'com.google.guava:guava:1.18.0'
compile 'com.github.fge:json-patch:1.9'
......
......@@ -40,8 +40,8 @@ public class CiscoManager {
// consts
public static String CISCO = "cisco";
public static String CISCO_DOMAIN = "10.10.20.6";
public static String API_URI = "/apigw/devnetlabapi/cdp/v1/";
public static String API_TOKEN_URI = "/apigw/devnetlabtokenapi/";
public static String API_URI = "/cdp/v1/";
public static String API_TOKEN_URI = "/cdp/v1/";
//tools
private static PercentEscaper pes = new PercentEscaper("-_.!~*\'()@:$,;/?:", false);
......@@ -302,7 +302,7 @@ public class CiscoManager {
request.setPort(80);
request.setMethod(SimpleHttpRequest.Method.GET);
// path
String path = API_URI + "accounts/username";
String path = API_URI + "accounts";
request.setPath(path);
// query string
String queryString = "loginName=" + loginInfo.username;
......
package testWebSocket.JettyWebSocket;
//import com.google.gdata.model.atompub.Draft;
//import io.undertow.websockets.client.WebSocketClient;
//import org.java_websocket.drafts.Draft_10;
//import org.java_websocket.handshake.ServerHandshake;
//import org.java_websocket.client.WebSocketClient;
import org.eclipse.jetty.websocket.api.StatusCode;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.junit.Test;
import java.net.URI;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import org.eclipse.jetty.util.ssl.SslContextFactory;
import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
import org.eclipse.jetty.websocket.client.WebSocketClient;
import org.eclipse.jetty.websocket.api.WebSocketListener;
/**
* Created by eli on 10/27/16.
*/
public class TestJettyWebSocket {
@WebSocket(maxTextMessageSize = 64 * 1024)
public class SimpleEchoSocket
{
private final CountDownLatch closeLatch;
@SuppressWarnings("unused")
private Session session;
public SimpleEchoSocket()
{
this.closeLatch = new CountDownLatch(1);
}
public boolean awaitClose(int duration, TimeUnit unit) throws InterruptedException
{
return this.closeLatch.await(duration,unit);
}
@OnWebSocketClose
public void onClose(int statusCode, String reason)
{
System.out.printf("Connection closed: %d - %s%n",statusCode,reason);
this.session = null;
this.closeLatch.countDown(); // trigger latch
}
@OnWebSocketConnect
public void onConnect(Session session)
{
System.out.printf("Got connect: %s%n",session);
this.session = session;
try
{
Future<Void> fut;
fut = session.getRemote().sendStringByFuture("Hello");
fut.get(2,TimeUnit.SECONDS); // wait for send to complete.
fut = session.getRemote().sendStringByFuture("Thanks for the conversation.");
fut.get(2,TimeUnit.SECONDS); // wait for send to complete.
//session.close(StatusCode.NORMAL,"I'm done");
}
catch (Throwable t)
{
t.printStackTrace();
}
}
@OnWebSocketMessage
public void onMessage(String msg)
{
System.out.printf("Got msg: %s%n",msg);
}
}
@Test
public void testJettyWebSocket() {
try {
WebSocketClient client = new WebSocketClient(new SslContextFactory());
client.start();
//URI echoUri = new URI("wss://ic-websocket-server.run.aws-usw02-pr.ice.predix.io/events");
URI echoUri = new URI("wss://ie-websocket-server-prod.run.aws-usw02-pr.ice.predix.io/consume?routing-key=c9af2c65-c25e-4087-8b8a-122c8243e5f1&service-name=ie-traffic");
// wss://${env.domain_eventurl}?routing-key=c9af2c65-c25e-4087-8b8a-122c8243e5f1&service-name=ie-traffic
ClientUpgradeRequest request = new ClientUpgradeRequest();
request.setHeader("Authorization",
"Bearer eyJhbGciOiJSUzI1NiIsImtpZCI6ImxlZ2FjeS10b2tlbi1rZXkiLCJ0eXAiOiJKV1QifQ.eyJqdGkiOiJjNWM3Yzc4Y2Q1YmQ0NDk0YmJiYWUxNmNjN2I4ZDg0MiIsInN1YiI6ImlwZ2FsbGVyeSIsInNjb3BlIjpbInVhYS5yZXNvdXJjZSIsImllLWN1cnJlbnQuU0RTSU0tSUUtUFVCTElDLVNBRkVUWS5JRS1QVUJMSUMtU0FGRVRZLkxJTUlURUQuREVWRUxPUCIsImllLWN1cnJlbnQuU0RTSU0tSUUtRU5WSVJPTk1FTlRBTC5JRS1FTlZJUk9OTUVOVEFMLkxJTUlURUQuREVWRUxPUCIsImllLWN1cnJlbnQuU0RTSU0tSUUtVFJBRkZJQy5JRS1UUkFGRklDLkxJTUlURUQuREVWRUxPUCIsImllLWN1cnJlbnQuU0RTSU0tSUUtUEFSS0lORy5JRS1QQVJLSU5HLkxJTUlURUQuREVWRUxPUCIsImllLWN1cnJlbnQuU0RTSU0tSUUtUEVERVNUUklBTi5JRS1QRURFU1RSSUFOLkxJTUlURUQuREVWRUxPUCJdLCJjbGllbnRfaWQiOiJpcGdhbGxlcnkiLCJjaWQiOiJpcGdhbGxlcnkiLCJhenAiOiJpcGdhbGxlcnkiLCJncmFudF90eXBlIjoiY2xpZW50X2NyZWRlbnRpYWxzIiwicmV2X3NpZyI6IjdjYzhlZTU3IiwiaWF0IjoxNTAyOTY4MjQ5LCJleHAiOjE1MDM1NzMwNDksImlzcyI6Imh0dHBzOi8vODkwNDA3ZDctZTYxNy00ZDcwLTk4NWYtMDE3OTJkNjkzMzg3LnByZWRpeC11YWEucnVuLmF3cy11c3cwMi1wci5pY2UucHJlZGl4LmlvL29hdXRoL3Rva2VuIiwiemlkIjoiODkwNDA3ZDctZTYxNy00ZDcwLTk4NWYtMDE3OTJkNjkzMzg3IiwiYXVkIjpbImllLWN1cnJlbnQuU0RTSU0tSUUtVFJBRkZJQy5JRS1UUkFGRklDLkxJTUlURUQiLCJpZS1jdXJyZW50LlNEU0lNLUlFLVBBUktJTkcuSUUtUEFSS0lORy5MSU1JVEVEIiwiaWUtY3VycmVudC5TRFNJTS1JRS1QVUJMSUMtU0FGRVRZLklFLVBVQkxJQy1TQUZFVFkuTElNSVRFRCIsInVhYSIsImlwZ2FsbGVyeSIsImllLWN1cnJlbnQuU0RTSU0tSUUtRU5WSVJPTk1FTlRBTC5JRS1FTlZJUk9OTUVOVEFMLkxJTUlURUQiLCJpZS1jdXJyZW50LlNEU0lNLUlFLVBFREVTVFJJQU4uSUUtUEVERVNUUklBTi5MSU1JVEVEIl19.IEKhIglF8Mc9PwfDiMH-rEtk6HVcfKs7LfdOhf7lMMTC-mG0hAe2mPcLMinhh7ZLhZEwer9hcwMIZG4XdnrirWYLXTzCTSCzpKdHyTKm84mDEqRh30zKFkfNwaJ7I1Yi5EVWRd0ZbF9sLJN4uT2C0U0eHbFVHrYTtz9KGq2_-8HpI3p8fRojZvfVDDANGzS0R7j3Qmj1gNEXn81PEjbWqiPCTjgAsWkzjIzrTFJKTSYCaqwYMq0JWS7TgAb-n4FygMDptyNf-8rI5Nstyky_WDL5TJYVO-PlRereXepEnSZ1iOSBBI22gET6KC_th_ipmkmCmwJKdLcRk4GLDe3Oig");
request.setHeader("Predix-Zone-Id", "SDSIM-IE-PARKING");
SimpleEchoSocket socket = new SimpleEchoSocket();
Future<Session> fut = client.connect(socket, echoUri, request);
System.out.printf("Connecting to : %s%n",echoUri);
fut.get().getRemote()
.sendString("{\"bbox\":\"32.715675:-117.161230,32.708498:-117.151681\",\"eventTypes\":[\"PKIN\"]}");
socket.awaitClose(10,TimeUnit.SECONDS);
} catch (Exception e) {
System.out.println("error: " + e.toString());
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment