*/
package org.opendaylight.yangtools.restconf.client;
-import static org.junit.Assert.assertNotNull;
-
+import com.google.common.util.concurrent.ListenableFuture;
import java.net.MalformedURLException;
-import java.net.URI;
+import java.net.URL;
+import java.util.Iterator;
+import java.util.Set;
import java.util.concurrent.ExecutionException;
-
import javassist.ClassPool;
-
-import org.junit.Test;
+import org.junit.Before;
import org.opendaylight.yangtools.restconf.client.api.RestconfClientContext;
import org.opendaylight.yangtools.restconf.client.api.UnsupportedProtocolException;
+import org.opendaylight.yangtools.restconf.client.api.data.ConfigurationDatastore;
import org.opendaylight.yangtools.restconf.client.api.data.OperationalDatastore;
+import org.opendaylight.yangtools.restconf.client.api.event.EventStreamInfo;
+import org.opendaylight.yangtools.restconf.client.api.event.ListenableEventStreamContext;
import org.opendaylight.yangtools.sal.binding.generator.impl.ModuleInfoBackedContext;
import org.opendaylight.yangtools.sal.binding.generator.impl.RuntimeGeneratedMappingServiceImpl;
+import org.opendaylight.yangtools.yang.binding.RpcService;
import org.opendaylight.yangtools.yang.binding.util.BindingReflections;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.fail;
public class RestconfClientImplTest {
private static final Logger logger = LoggerFactory.getLogger(RestconfClientImplTest.class);
private static final String restconfUrl = "http://localhost:8080";
+ //private static final String restconfUrl = "http://pce-guest35.cisco.com:9080";
public static final String JSON = "+json";
public static final String XML = "+xml";
private RestconfClientContext restconfClientContext;
+ private RuntimeGeneratedMappingServiceImpl mappingService;
-
-
- @Test
- public void testGetRpcServiceContext() throws ExecutionException, InterruptedException, MalformedURLException, UnsupportedProtocolException {
- URI uri = URI.create(restconfUrl);
- RestconfClientFactory factory = new RestconfClientFactory();
- RuntimeGeneratedMappingServiceImpl mappingService = new RuntimeGeneratedMappingServiceImpl();
+ @Before
+ public void setupRestconfClientContext() throws MalformedURLException, UnsupportedProtocolException {
+ mappingService = new RuntimeGeneratedMappingServiceImpl();
mappingService.setPool(new ClassPool());
mappingService.init();
- ModuleInfoBackedContext moduleInfo = ModuleInfoBackedContext.create();
+ final ModuleInfoBackedContext moduleInfo = ModuleInfoBackedContext.create();
moduleInfo.addModuleInfos(BindingReflections.loadModuleInfos());
-
mappingService.onGlobalContextUpdated(moduleInfo.tryToCreateSchemaContext().get());
+ this.restconfClientContext = new RestconfClientFactory().getRestconfClientContext(new URL(restconfUrl),mappingService, mappingService);
+ assertNotNull(this.restconfClientContext);
+ }
- restconfClientContext = factory.getRestconfClientContext(uri.toURL(), mappingService, mappingService);
- assertNotNull(restconfClientContext);
-
- OperationalDatastore datastore = restconfClientContext.getOperationalDatastore();
+// @Test
+ public void testGetAvailableEventStreams(){
+ ListenableFuture<Set<EventStreamInfo>> streamsFuture = restconfClientContext.getAvailableEventStreams();
+ while (!streamsFuture.isDone()){
+ //noop
+ }
+ if (streamsFuture.isDone()){
+ try {
+ Set<EventStreamInfo> streams = (Set<EventStreamInfo>) streamsFuture.get();
+ assertNotNull(streams);
+ } catch (InterruptedException e) {
+ fail(e.getMessage());
+ } catch (ExecutionException e) {
+ fail(e.getMessage());
+ }
+ }
+ }
+// @Test
+ public void testGetRpcServices(){
+ ListenableFuture<Set<Class<? extends RpcService>>> servicesFuture = restconfClientContext.getRpcServices();
+ while (!servicesFuture.isDone()){
+ //noop
+ }
+ if (servicesFuture.isDone()){
+ try {
+ Set<Class<? extends RpcService>> streams = (Set<Class<? extends RpcService>>) servicesFuture.get();
+ assertNotNull(streams);
+ } catch (InterruptedException e) {
+ fail(e.getMessage());
+ } catch (ExecutionException e) {
+ fail(e.getMessage());
+ }
+ }
+ }
- // Example use of client
-// ListenableFuture<Optional<Nodes>> result = datastore.readData(InstanceIdentifier.builder(Nodes.class).toInstance());
-// Optional<Nodes> optionalNodes = result.get();
-// Nodes node = optionalNodes.get();
-// assertNotNull(node);
+// @Test
+ public void getEventStreamContext() throws MalformedURLException, UnsupportedProtocolException, ExecutionException, InterruptedException {
+ ListenableFuture<Set<EventStreamInfo>> evtStreams = restconfClientContext.getAvailableEventStreams();
+ while (!evtStreams.isDone()){
+ //noop
+ }
+ Iterator<EventStreamInfo> it = evtStreams.get().iterator();
+ ListenableEventStreamContext evtStreamCtx = restconfClientContext.getEventStreamContext(it.next());
+ assertNotNull(evtStreamCtx);
+ }
+// @Test
+ public void testGetOperationalDatastore() throws ExecutionException, InterruptedException, MalformedURLException, UnsupportedProtocolException {
+ OperationalDatastore datastore = restconfClientContext.getOperationalDatastore();
+ assertNotNull(datastore);
}
+// @Test
+ public void testGetConfigurationDatastore() throws ExecutionException, InterruptedException, MalformedURLException, UnsupportedProtocolException {
+ ConfigurationDatastore datastore = restconfClientContext.getConfigurationDatastore();
+ assertNotNull(datastore);
+ }
+
}
Code Review / yangtools.git / commitdiff