2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.netconf.test.tool;
11 import com.google.common.base.Optional;
12 import com.google.common.collect.Sets;
14 import java.util.Collections;
16 import org.opendaylight.controller.config.util.capability.Capability;
17 import org.opendaylight.netconf.api.monitoring.CapabilityListener;
18 import org.opendaylight.netconf.impl.SessionIdProvider;
19 import org.opendaylight.netconf.mapping.api.NetconfOperation;
20 import org.opendaylight.netconf.mapping.api.NetconfOperationService;
21 import org.opendaylight.netconf.mapping.api.NetconfOperationServiceFactory;
22 import org.opendaylight.netconf.test.tool.rpc.DataList;
23 import org.opendaylight.netconf.test.tool.rpc.SimulatedCommit;
24 import org.opendaylight.netconf.test.tool.rpc.SimulatedCreateSubscription;
25 import org.opendaylight.netconf.test.tool.rpc.SimulatedDiscardChanges;
26 import org.opendaylight.netconf.test.tool.rpc.SimulatedEditConfig;
27 import org.opendaylight.netconf.test.tool.rpc.SimulatedGet;
28 import org.opendaylight.netconf.test.tool.rpc.SimulatedGetConfig;
29 import org.opendaylight.netconf.test.tool.rpc.SimulatedLock;
30 import org.opendaylight.netconf.test.tool.rpc.SimulatedUnLock;
32 class SimulatedOperationProvider implements NetconfOperationServiceFactory {
33 private final Set<Capability> caps;
34 private final SimulatedOperationService simulatedOperationService;
36 SimulatedOperationProvider(final SessionIdProvider idProvider,
37 final Set<Capability> caps,
38 final Optional<File> notificationsFile,
39 final Optional<File> initialConfigXMLFile) {
41 simulatedOperationService = new SimulatedOperationService(
42 idProvider.getCurrentSessionId(), notificationsFile, initialConfigXMLFile);
46 public Set<Capability> getCapabilities() {
51 public AutoCloseable registerCapabilityListener(
52 final CapabilityListener listener) {
53 listener.onCapabilitiesChanged(caps, Collections.<Capability>emptySet());
54 return new AutoCloseable() {
56 public void close() throws Exception {
62 public NetconfOperationService createService(
63 final String netconfSessionIdForReporting) {
64 return simulatedOperationService;
67 static class SimulatedOperationService implements NetconfOperationService {
68 private final long currentSessionId;
69 private final Optional<File> notificationsFile;
70 private final Optional<File> initialConfigXMLFile;
72 SimulatedOperationService(final long currentSessionId, final Optional<File> notificationsFile,
73 final Optional<File> initialConfigXMLFile) {
74 this.currentSessionId = currentSessionId;
75 this.notificationsFile = notificationsFile;
76 this.initialConfigXMLFile = initialConfigXMLFile;
80 public Set<NetconfOperation> getNetconfOperations() {
81 final DataList storage = new DataList();
82 final SimulatedGet sGet = new SimulatedGet(String.valueOf(currentSessionId), storage);
83 final SimulatedEditConfig sEditConfig = new SimulatedEditConfig(String.valueOf(currentSessionId), storage);
84 final SimulatedGetConfig sGetConfig = new SimulatedGetConfig(
85 String.valueOf(currentSessionId), storage, initialConfigXMLFile);
86 final SimulatedCommit sCommit = new SimulatedCommit(String.valueOf(currentSessionId));
87 final SimulatedLock sLock = new SimulatedLock(String.valueOf(currentSessionId));
88 final SimulatedUnLock sUnlock = new SimulatedUnLock(String.valueOf(currentSessionId));
89 final SimulatedCreateSubscription sCreateSubs = new SimulatedCreateSubscription(
90 String.valueOf(currentSessionId), notificationsFile);
91 final SimulatedDiscardChanges sDiscardChanges = new SimulatedDiscardChanges(
92 String.valueOf(currentSessionId));
93 return Sets.newHashSet(
94 sGet, sGetConfig, sEditConfig, sCommit, sLock, sUnlock, sCreateSubs, sDiscardChanges);