@@ -49,10 +49,10 @@ public class BigSwitchVnsApi {
4949 private static final Logger s_logger = Logger .getLogger (BigSwitchVnsApi .class );
5050 private final static String _protocol = "http" ;
5151 private final static String _nsBaseUri = "/networkService/v1.1" ;
52- private final static String _controllerBaseUri = "/wm/core" ;
5352 private final static String CONTENT_TYPE = "Content-Type" ;
53+ private final static String ACCEPT = "Accept" ;
5454 private final static String CONTENT_JSON = "application/json" ;
55- private final static String HTTP_HEADER_INSTANCE_ID = "HTTP_INSTANCE_ID " ;
55+ private final static String HTTP_HEADER_INSTANCE_ID = "INSTANCE_ID " ;
5656 private final static String CLOUDSTACK_INSTANCE_ID = "org.apache.cloudstack" ;
5757 private final static MultiThreadedHttpConnectionManager s_httpClientManager =
5858 new MultiThreadedHttpConnectionManager ();
@@ -114,55 +114,56 @@ protected void login() throws BigSwitchVnsApiException {
114114 return ;
115115 }
116116
117- public void createNetwork (Network network )
117+ public void createNetwork (NetworkData network )
118118 throws BigSwitchVnsApiException {
119- String uri = _nsBaseUri + "/tenant /" + network .getTenant_id () + "/network " ;
120- executeCreateObject (network , new TypeToken <Network >(){}.getType (),
119+ String uri = _nsBaseUri + "/tenants /" + network .getNetwork (). getTenant_id () + "/networks " ;
120+ executeCreateObject (network , new TypeToken <NetworkData >(){}.getType (),
121121 uri , Collections .<String ,String >emptyMap ());
122122 }
123123
124124 public void deleteNetwork (String tenantId , String networkId ) throws BigSwitchVnsApiException {
125- String uri = _nsBaseUri + "/tenant /" + tenantId + "/networks/" + networkId ;
125+ String uri = _nsBaseUri + "/tenants /" + tenantId + "/networks/" + networkId ;
126126 executeDeleteObject (uri );
127127 }
128128
129- public void createPort (String networkUuid , Port port )
129+ public void createPort (String networkUuid , PortData port )
130130 throws BigSwitchVnsApiException {
131- String uri = _nsBaseUri + "/tenant /" + port .getTenant_id () + "/networks/" + networkUuid + "/ports" ;
132- executeCreateObject (port , new TypeToken <Port >(){}.getType (),
131+ String uri = _nsBaseUri + "/tenants /" + port . getPort () .getTenant_id () + "/networks/" + networkUuid + "/ports" ;
132+ executeCreateObject (port , new TypeToken <PortData >(){}.getType (),
133133 uri , Collections .<String ,String >emptyMap ());
134134 }
135135
136- public void modifyPort (String networkId , Port port )
136+ public void modifyPort (String networkId , PortData port )
137137 throws BigSwitchVnsApiException {
138- String uri = _nsBaseUri + "/tenant /" + port .getTenant_id () + "/networks/" + networkId + "/ports" ;
138+ String uri = _nsBaseUri + "/tenants /" + port . getPort () .getTenant_id () + "/networks/" + networkId + "/ports" ;
139139 executeUpdateObject (port , uri , Collections .<String ,String >emptyMap ());
140140 }
141141
142142 public void deletePort (String tenantId , String networkId , String portId )
143143 throws BigSwitchVnsApiException {
144- String uri = _nsBaseUri + "/tenant /" + tenantId + "/networks/" + networkId + "/ports/" + portId ;
144+ String uri = _nsBaseUri + "/tenants /" + tenantId + "/networks/" + networkId + "/ports/" + portId ;
145145 executeDeleteObject (uri );
146146 }
147147
148148 public void modifyPortAttachment (String tenantId ,
149149 String networkId ,
150150 String portId ,
151- Attachment attachment ) throws BigSwitchVnsApiException {
152- String uri = _nsBaseUri + "/tenant /" + tenantId + "/networks/" + networkId + "/ports/" + portId + "/attachment" ;
151+ AttachmentData attachment ) throws BigSwitchVnsApiException {
152+ String uri = _nsBaseUri + "/tenants /" + tenantId + "/networks/" + networkId + "/ports/" + portId + "/attachment" ;
153153 executeUpdateObject (attachment , uri , Collections .<String ,String >emptyMap ());
154154 }
155155
156156 public void deletePortAttachment (String tenantId , String networkId , String portId )
157157 throws BigSwitchVnsApiException {
158- String uri = _nsBaseUri + "/tenant /" + tenantId + "/networks/" + networkId + "/ports/" + portId + "/attachment" ;
158+ String uri = _nsBaseUri + "/tenants /" + tenantId + "/networks/" + networkId + "/ports/" + portId + "/attachment" ;
159159 executeDeleteObject (uri );
160160 }
161161
162162 public ControlClusterStatus getControlClusterStatus () throws BigSwitchVnsApiException {
163- String uri = _controllerBaseUri + "/health/json " ;
163+ String uri = _nsBaseUri + "/health" ;
164164 ControlClusterStatus ccs = executeRetrieveObject (new TypeToken <ControlClusterStatus >(){}.getType (),
165165 uri , 80 , null );
166+ ccs .setStatus (true );
166167
167168 return ccs ;
168169 }
@@ -177,6 +178,7 @@ protected <T> void executeUpdateObject(T newObject, String uri, Map<String,Strin
177178
178179 PutMethod pm = (PutMethod ) createMethod ("put" , uri , 80 );
179180 pm .setRequestHeader (CONTENT_TYPE , CONTENT_JSON );
181+ pm .setRequestHeader (ACCEPT , CONTENT_JSON );
180182 pm .setRequestHeader (HTTP_HEADER_INSTANCE_ID , CLOUDSTACK_INSTANCE_ID );
181183 try {
182184 pm .setRequestEntity (new StringRequestEntity (
@@ -207,6 +209,7 @@ protected <T> void executeCreateObject(T newObject, Type returnObjectType, Strin
207209
208210 PostMethod pm = (PostMethod ) createMethod ("post" , uri , 80 );
209211 pm .setRequestHeader (CONTENT_TYPE , CONTENT_JSON );
212+ pm .setRequestHeader (ACCEPT , CONTENT_JSON );
210213 pm .setRequestHeader (HTTP_HEADER_INSTANCE_ID , CLOUDSTACK_INSTANCE_ID );
211214 try {
212215 pm .setRequestEntity (new StringRequestEntity (
@@ -235,6 +238,7 @@ protected void executeDeleteObject(String uri) throws BigSwitchVnsApiException {
235238
236239 DeleteMethod dm = (DeleteMethod ) createMethod ("delete" , uri , 80 );
237240 dm .setRequestHeader (CONTENT_TYPE , CONTENT_JSON );
241+ dm .setRequestHeader (ACCEPT , CONTENT_JSON );
238242 dm .setRequestHeader (HTTP_HEADER_INSTANCE_ID , CLOUDSTACK_INSTANCE_ID );
239243
240244 executeMethod (dm );
@@ -257,6 +261,7 @@ protected <T> T executeRetrieveObject(Type returnObjectType, String uri, int por
257261
258262 GetMethod gm = (GetMethod ) createMethod ("get" , uri , port );
259263 gm .setRequestHeader (CONTENT_TYPE , CONTENT_JSON );
264+ gm .setRequestHeader (ACCEPT , CONTENT_JSON );
260265 gm .setRequestHeader (HTTP_HEADER_INSTANCE_ID , CLOUDSTACK_INSTANCE_ID );
261266
262267 if (parameters != null && !parameters .isEmpty ()) {
@@ -327,4 +332,4 @@ private String responseToErrorMessage(HttpMethodBase method) {
327332 return method .getStatusText ();
328333 }
329334
330- }
335+ }
0 commit comments