# Logs dir in all projects
**/logs/*
**/debug-logs/*
+sdnr/northbound/ranSlice/provider/derby.log
# Added for Intellij IDEA IDE
**/.idea/*
<scope>provided</scope>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-actor_2.13</artifactId>
- <scope>provided</scope>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-cluster_2.13</artifactId>
+ <groupId>com.typesafe</groupId>
+ <artifactId>config</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<artifactId>jaxb-api</artifactId>
<scope>provided</scope>
</dependency>
- <dependency>
- <groupId>javax.activation</groupId>
- <artifactId>activation</artifactId>
- <scope>provided</scope>
- </dependency>
<dependency>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-runtime</artifactId>
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Guicutthrough;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Inventory;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.NetworkElementDeviceType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev161109.NetconfCallhomeServer;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev161109.netconf.callhome.server.AllowedDevices;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev161109.netconf.callhome.server.allowed.devices.Device;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev201015.NetconfCallhomeServer;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev201015.netconf.callhome.server.AllowedDevices;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconf.callhome.server.rev201015.netconf.callhome.server.allowed.devices.Device;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
package org.onap.ccsdk.features.sdnr.wt.devicemanager.oran.test;
import java.util.Map;
+import org.eclipse.jdt.annotation.NonNull;
import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
import org.opendaylight.yang.gen.v1.urn.o.ran.fm._1._0.rev190204.AlarmNotif;
return new DateAndTime("2021-03-23T18:19:42.326144Z");
}
+ @Override
+ public @NonNull Map<Class<? extends Augmentation<AlarmNotif>>, Augmentation<AlarmNotif>> augmentations() {
+ return null;
+ }
+
+ @Override
+ public Boolean getIsCleared() {
+ return null;
+ }
+
}
*/
package org.onap.ccsdk.features.sdnr.wt.devicemanager.oran.test;
+import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import java.math.BigDecimal;
import org.eclipse.jdt.annotation.Nullable;
String dateTimeString = "2020-02-05T12:30:45.283Z";
String name = "Slot-0";
+ NetconfNode testNetconfNode = mock(NetconfNode.class);
+ when(testNetconfNode.getHost()).thenReturn(new Host(new IpAddress(new Ipv4Address("10.10.10.10"))));
+
when(netconfAccessor.getNodeId()).thenReturn(new NodeId("nSky"));
- when(netconfAccessor.getNetconfNode()).thenReturn(new TestNetconfNode());
+ when(netconfAccessor.getNetconfNode()).thenReturn(testNetconfNode);
when(vesCollectorService.getConfig()).thenReturn(vesCfgService);
when(vesCfgService.getReportingEntityName()).thenReturn("SDN-R");
Component testComponent = ComponentHelper.get(name, dateTimeString);
mapper.mapPNFRegistrationFields();
}
- public class TestNetconfNode implements NetconfNode {
-
- @Override
- public @Nullable Credentials getCredentials() {
- return null;
- }
-
- @Override
- public @Nullable Host getHost() {
- return new Host(new IpAddress(new Ipv4Address("10.10.10.10")));
- }
-
- @Override
- public @Nullable PortNumber getPort() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Boolean isTcpOnly() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Protocol getProtocol() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Boolean isSchemaless() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable YangModuleCapabilities getYangModuleCapabilities() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable NonModuleCapabilities getNonModuleCapabilities() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Boolean isReconnectOnChangedSchema() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint32 getConnectionTimeoutMillis() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint32 getDefaultRequestTimeoutMillis() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint32 getMaxConnectionAttempts() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint16 getBetweenAttemptsTimeoutMillis() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable BigDecimal getSleepFactor() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint32 getKeepaliveDelay() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint16 getConcurrentRpcLimit() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable Uint16 getActorResponseWaitTime() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable OdlHelloMessageCapabilities getOdlHelloMessageCapabilities() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable ConnectionStatus getConnectionStatus() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable ClusteredConnectionStatus getClusteredConnectionStatus() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable String getConnectedMessage() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable AvailableCapabilities getAvailableCapabilities() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable UnavailableCapabilities getUnavailableCapabilities() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable PassThrough getPassThrough() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable String getSchemaCacheDirectory() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable YangLibrary getYangLibrary() {
- // TODO Auto-generated method stub
- return null;
- }
-
- @Override
- public @Nullable IgnoreMissingSchemaSources getIgnoreMissingSchemaSources() {
- // TODO Auto-generated method stub
- return null;
- }
-
- }
-
}
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev170324.air._interface.historical.performances.g.HistoricalPerformanceDataList> airHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev170324.air._interface.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period15Min)
.setPerformanceData(performanceData).build());
AirInterfaceHistoricalPerformances airHistoricalPerformanceData =
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev170324.ethernet.container.historical.performances.g.HistoricalPerformanceDataList> ethHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev170324.ethernet.container.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period24Hours)
.setPerformanceData(ethPerformanceData).build());
EthernetContainerHistoricalPerformances ethContainerHistoricalPerformanceData =
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev180907.air._interface.historical.performances.g.HistoricalPerformanceDataList> airHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev180907.air._interface.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period15Min)
.setPerformanceData(performanceData).build());
AirInterfaceHistoricalPerformances airHistoricalPerformanceData =
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev180907.ethernet.container.historical.performances.g.HistoricalPerformanceDataList> ethHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev180907.ethernet.container.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period24Hours)
.setPerformanceData(ethPerformanceData).build());
EthernetContainerHistoricalPerformances ethContainerHistoricalPerformanceData =
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.historical.performances.g.HistoricalPerformanceDataList> airHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period15Min)
.setPerformanceData(performanceData).build());
AirInterfaceHistoricalPerformances airHistoricalPerformanceData =
List<org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.ethernet.container.historical.performances.g.HistoricalPerformanceDataList> ethHistPMList =
Arrays.asList(
new org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.ethernet.container.historical.performances.g.HistoricalPerformanceDataListBuilder()
+ .setHistoryDataId("123")
.setGranularityPeriod(GranularityPeriodType.Period24Hours)
.setPerformanceData(ethPerformanceData).build());
EthernetContainerHistoricalPerformances ethContainerHistoricalPerformanceData =
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ptp.dataset.rev170208.port.ds.entry.PortIdentityBuilder;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-
+import org.opendaylight.yangtools.yang.common.Uint16;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
when(netconfAccessor.getDataBroker()).thenReturn(dataBroker);
PortIdentity portIdentity = new PortIdentityBuilder().setPortNumber(10).build();
- List<PortDsList> portDsList = Arrays.asList(new PortDsListBuilder().setPortIdentity(portIdentity).build());
- InstanceList instanceList = new InstanceListBuilder().setPortDsList(portDsList).build();
+ List<PortDsList> portDsList =
+ Arrays.asList(new PortDsListBuilder().setPortNumber(10).setPortIdentity(portIdentity).build());
+ InstanceList instanceList =
+ new InstanceListBuilder().setInstanceNumber(Uint16.valueOf(1)).setPortDsList(portDsList).build();
InstanceIdentifier<InstanceList> PTPINSTANCES_IID =
InstanceIdentifier.builder(InstanceList.class, new InstanceListKey(1)).build();
when(netconfAccessor.getTransactionUtils().readData(netconfAccessor.getDataBroker(),
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import org.eclipse.jdt.annotation.NonNull;
import org.junit.Before;
import org.junit.Test;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.openroadm.impl.PmDataBuilderOpenRoadm;
import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev191129.Validity;
import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev191129.ResourceTypeEnum;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Pmdata15mEntity;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.units.rev200413.Celsius;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.units.rev200413.PerformanceMeasurementUnitId;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
+import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.PathArgument;
import org.opendaylight.yangtools.yang.common.Uint16;
import org.opendaylight.yangtools.yang.common.Uint64;
private Map<HistoricalPmKey, HistoricalPm> historicalPMCollection = new HashMap<HistoricalPmKey, HistoricalPm>();
private Map<HistoricalPmEntryKey, HistoricalPmEntry> historicalPmEntryCollection =
new HashMap<HistoricalPmEntryKey, HistoricalPmEntry>();
-
-
+ private PathArgument pa =new PathArgument() {
+ @Override
+ public int compareTo(PathArgument o) {
+ return 0;
+ }
+ @Override
+ public @NonNull Class<? extends DataObject> getType() {
+ return Pmdata15mEntity.class;
+ }
+ };
// public methods
@Before
when(historicalPm.getMeasurement()).thenReturn(measurementData);
historicalPMCollection.put(historicalPmBuilder.key(), historicalPmBuilder.build());
- historicalPmEntryBuiler.setPmResourceTypeExtension("dshjdekjdewkk")
+ historicalPmEntryBuiler.setPmResourceInstance(InstanceIdentifier.create(Arrays.asList(pa)))
+ .setPmResourceTypeExtension("dshjdekjdewkk")
.setPmResourceType(ResourceTypeEnum.CircuitPack).setHistoricalPm(historicalPMCollection);
historicalPmEntryCollection.put(historicalPmEntryBuiler.key(), historicalPmEntryBuiler.build());
when(historicalPm.getMeasurement()).thenReturn(measurementData);
historicalPMCollection.put(historicalPmBuilder.key(), historicalPmBuilder.build());
- historicalPmEntryBuiler.setPmResourceTypeExtension("dshjdekjdewkk")
+ historicalPmEntryBuiler.setPmResourceInstance(InstanceIdentifier.create(Arrays.asList(pa)))
+ .setPmResourceTypeExtension("dshjdekjdewkk")
.setPmResourceType(ResourceTypeEnum.Device).setHistoricalPm(historicalPMCollection);
historicalPmEntryCollection.put(historicalPmEntryBuiler.key(), historicalPmEntryBuiler.build());
import org.opendaylight.yangtools.yang.common.QName;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
+import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
/**
* Interface handling netconf connection.
*
* @param <T> specific child class of DOMNotificationListener
* @param listener listener to be called
- * @param types as list of SchemaPath
+ * @param types as list of Absolute
* @return handler to manager registration
*/
<T extends DOMNotificationListener> @NonNull ListenerRegistration<DOMNotificationListener> doRegisterNotificationListener(
- @NonNull T listener, Collection<SchemaPath> types);
+ @NonNull T listener, Collection<Absolute> types);
/**
* Register netconf notification listener for related mountpoint
* @See <a href="https://tools.ietf.org/html/rfc5277">https://tools.ietf.org/html/rfc5277</a>
* @param <T>
* @param listener to be registers
- * @param types as array of SchemaPath
+ * @param types as array of Absolute
* @return Object to close and access
*/
<T extends DOMNotificationListener> @NonNull ListenerRegistration<DOMNotificationListener> doRegisterNotificationListener(
- @NonNull T listener, SchemaPath[] types);
+ @NonNull T listener, Absolute[] types);
/**
* Register netconf notification listener for related mountpoint
</dependency>
<!-- akka -->
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-actor_2.13</artifactId>
- <scope>provided</scope>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-cluster_2.13</artifactId>
+ <groupId>com.typesafe</groupId>
+ <artifactId>config</artifactId>
<scope>provided</scope>
</dependency>
<!-- wt -->
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
+import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOG = LoggerFactory.getLogger(NetconfDomAccessorImpl.class);
private static final QName CREATE_SUBSCRIPTION = QName.create(CreateSubscriptionInput.QNAME, "create-subscription");
- private static final SchemaPath RPC_PATH_CREATE_SUBSCRIPTION =
- NetconfMessageTransformUtil.toPath(CREATE_SUBSCRIPTION);
private static final YangInstanceIdentifier STREAMS_PATH =
YangInstanceIdentifier.builder().node(Netconf.QNAME).node(Streams.QNAME).build();
@Override
public @NonNull <T extends DOMNotificationListener> ListenerRegistration<DOMNotificationListener> doRegisterNotificationListener(
- @NonNull T listener, Collection<SchemaPath> types) {
+ @NonNull T listener, Collection<Absolute> types) {
LOG.info("Begin register listener for Mountpoint {}", mountpoint.getIdentifier().toString());
final ListenerRegistration<DOMNotificationListener> ranListenerRegistration =
@Override
public @NonNull <T extends DOMNotificationListener> ListenerRegistration<DOMNotificationListener> doRegisterNotificationListener(
- @NonNull T listener, SchemaPath[] types) {
+ @NonNull T listener, Absolute[] types) {
return doRegisterNotificationListener(listener, Arrays.asList(types));
}
@Override
public @NonNull <T extends DOMNotificationListener> ListenerRegistration<DOMNotificationListener> doRegisterNotificationListener(
@NonNull T listener, QName[] types) {
- List<SchemaPath> schemaPathList = Arrays.stream(types).map(qname -> NetconfMessageTransformUtil.toPath(qname)).collect(toList());
+ List<Absolute> schemaPathList = Arrays.stream(types).map(qname -> Absolute.of(qname)).collect(toList());
return doRegisterNotificationListener(listener, schemaPathList);
}
@Override
public ListenableFuture<? extends DOMRpcResult> invokeCreateSubscription(CreateSubscriptionInput input) {
final ContainerNode nnInput = serializer.toNormalizedNodeRpcData(input);
- return rpcService.invokeRpc(RPC_PATH_CREATE_SUBSCRIPTION, nnInput);
+ return rpcService.invokeRpc(CREATE_SUBSCRIPTION, nnInput);
}
@Override
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
+import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
public class TestNetconfAccessorImpl extends Mockito {
DOMMountPoint domMountPoint = mock(DOMMountPoint.class);
when(domNotificationService.registerNotificationListener(any(DOMNotificationListener.class),
- ArgumentMatchers.<Collection<SchemaPath>>any()))
+ ArgumentMatchers.<Collection<Absolute>>any()))
.thenReturn(new ListenerRegistration<DOMNotificationListener>() {
@Override
public @NonNull DOMNotificationListener getInstance() {
NetconfDomAccessorImpl netconfDomAccessor =
new NetconfDomAccessorImpl(netconfAccessor, domDataBroker, domMountPoint, domContext);
- Collection<SchemaPath> types = Arrays.asList(SchemaPath.create(false, NetworkTopology.QNAME));
+ Collection<Absolute> types = Arrays.asList(Absolute.of(NetworkTopology.QNAME));
DOMNotificationListener listener = (notification) -> System.out.println("Notification: " + notification);
ListenerRegistration<DOMNotificationListener> res =
netconfDomAccessor.doRegisterNotificationListener(listener, types);
//Capture parameters and assert them
ArgumentCaptor<DOMNotificationListener> captor1 = ArgumentCaptor.forClass(DOMNotificationListener.class);
@SuppressWarnings("unchecked")
- ArgumentCaptor<Collection<SchemaPath>> captor2 = ArgumentCaptor.forClass(Collection.class);
+ ArgumentCaptor<Collection<Absolute>> captor2 = ArgumentCaptor.forClass(Collection.class);
verify(domNotificationService).registerNotificationListener(captor1.capture(), captor2.capture());
assertEquals("Listener", listener, captor1.getValue());
import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.rpc.NetconfnodeStateServiceRpcApiImpl;
import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.example.ExampleConfig;
import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.example.TestNetconfHelper;
-import org.opendaylight.binding.runtime.spi.BindingRuntimeHelpers;
+import org.opendaylight.mdsal.binding.runtime.spi.BindingRuntimeHelpers;
import org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.binding.api.DataObjectModification;
+++ /dev/null
-module websocketmanager {
-
- yang-version 1;
- namespace "urn:opendaylight:params:xml:ns:yang:websocketmanager";
- prefix websocketmanager;
-
- import ietf-yang-types {
- prefix yang;
- }
- organization
- "highstreet technologies GmbH";
- contact
- "Web: <https://highstreet-technologies.com>
- ONAP: <https://wiki.onap.org/display/DW/SDN-R+Websocketmanager+Upgrade>";
-
- description
- "Websocketmanager Api Module
-
- Copyright 2021 highstreet technologies GmbH Intellectual Property.
- All rights reserved.
-
- Licensed under the Apache License, Version 2.0 (the 'License');
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an 'AS IS' BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.";
-
- revision 2021-03-22 {
- description
- "Initial revision";
- }
-
- notification items-dropped-notification {
- uses items-dropped-notification-g;
- description "none";
- }
- grouping items-dropped-notification-g {
- leaf amount {
- type uint32;
- default 0;
- description "Counts of notifications that were dropped.";
- }
- description "To be sent when notifications were dropped in fact of a set ratio limit.";
- }
-}
<artifactId>json</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-actor_2.13</artifactId>
- <scope>provided</scope>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-cluster_2.13</artifactId>
+ <groupId>com.typesafe</groupId>
+ <artifactId>config</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * ONAP : ccsdk features
- * ================================================================================
- * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
- * All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- *
- */
-package org.onap.ccsdk.features.sdnr.wt.websocketmanager2.test;
-
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import org.junit.Test;
-import org.onap.ccsdk.features.sdnr.wt.websocketmanager.model.data.NotificationOutput;
-import org.onap.ccsdk.features.sdnr.wt.yang.mapper.YangToolsMapper;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ObjectCreationNotification;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ObjectCreationNotificationBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class TestSerializer {
-
- private static final Logger LOG = LoggerFactory.getLogger(TestSerializer.class);
- private static final YangToolsMapper mapper = new YangToolsMapper();
- private static final String TIMESTAMP = "2020-04-01T10:20:40.0Z";
- private static final String NODEID = "node1";
-
- @Test
- public void test1() {
- ObjectCreationNotification notification = new ObjectCreationNotificationBuilder().setCounter(Integer.valueOf(5)).build();
- NotificationOutput output = new NotificationOutput(notification, NODEID, ObjectCreationNotification.QNAME,DateAndTime.getDefaultInstance(TIMESTAMP));
- String sOutput=null;
- try {
- sOutput = mapper.writeValueAsString(output);
- LOG.debug(sOutput);
- } catch (JsonProcessingException e) {
- e.printStackTrace();
- fail(e.getMessage());
- }
- assertNotNull(sOutput);
- assertTrue(sOutput.contains("\"type\""));
- }
-}
+++ /dev/null
-/*
- * ============LICENSE_START========================================================================
- * ONAP : ccsdk feature sdnr wt
- * =================================================================================================
- * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
- * =================================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
- * in compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
- * or implied. See the License for the specific language governing permissions and limitations under
- * the License.
- * ============LICENSE_END==========================================================================
- */
-package org.onap.ccsdk.features.sdnr.wt.websocketmanager2.test;
-
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import java.util.Arrays;
-import java.util.List;
-import org.junit.Test;
-import org.onap.ccsdk.features.sdnr.wt.websocketmanager.model.data.ReducedSchemaInfo;
-import org.onap.ccsdk.features.sdnr.wt.websocketmanager.model.data.SchemaInfo;
-import org.onap.ccsdk.features.sdnr.wt.websocketmanager.model.data.Scope;
-import org.onap.ccsdk.features.sdnr.wt.websocketmanager.utils.UserScopes;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ObjectCreationNotification;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ProblemNotification;
-import org.opendaylight.yangtools.yang.common.QName;
-
-public class UserScopeTest {
-
- private static final String SCOPE1 = "problem-notification";
- private static final String SCOPE2 = "scope2";
- private static final String SCOPE3 = "scope3";
- private static final String SCOPE4 = "scope4";
-
- @Test
- public void test() {
- UserScopes scopes1 = new UserScopes();
- List<String> json1 = Arrays.asList(SCOPE1, SCOPE2, SCOPE3);
- scopes1.setScopes(Arrays.asList(buildScope(null, ProblemNotification.QNAME)));
-
- assertTrue(scopes1.hasScope(new ReducedSchemaInfo(ProblemNotification.QNAME)));
- assertFalse(scopes1.hasScope("RoadmA", new ReducedSchemaInfo(ObjectCreationNotification.QNAME)));
-
- assertTrue(scopes1.hasScope("RoadmA", new ReducedSchemaInfo(ProblemNotification.QNAME)));
-
- }
-
-
- private static final Scope buildScope(String nodeId, QName qname) {
- Scope scope = new Scope();
- scope.setNodeId(nodeId);
- scope.setSchema(new SchemaInfo(qname));
- return scope;
- }
-
-}
Code Review / ccsdk / features.git / commitdiff