Loading src/automation/src/main/java/eu/teraflow/automation/Serializer.java +4 −0 Original line number Diff line number Diff line Loading @@ -929,6 +929,7 @@ public class Serializer { final var deviceIdUuid = serializeUuid(device.getDeviceId()); final var deviceId = DeviceId.newBuilder().setDeviceUuid(deviceIdUuid); final var deviceName = device.getDeviceName(); final var deviceType = device.getDeviceType(); final var deviceConfig = device.getDeviceConfig(); final var deviceOperationalStatus = device.getDeviceOperationalStatus(); Loading @@ -943,6 +944,7 @@ public class Serializer { deviceEndPoints.stream().map(this::serialize).collect(Collectors.toList()); builder.setDeviceId(deviceId); builder.setName(deviceName); builder.setDeviceType(deviceType); builder.setDeviceConfig(serializedDeviceConfig); builder.setDeviceOperationalStatus(serializedDeviceOperationalStatus); Loading @@ -955,6 +957,7 @@ public class Serializer { public Device deserialize(ContextOuterClass.Device device) { final var serializedDeviceId = device.getDeviceId(); final var deviceName = device.getName(); final var deviceType = device.getDeviceType(); final var serializedDeviceConfig = device.getDeviceConfig(); final var serializedDeviceOperationalStatus = device.getDeviceOperationalStatus(); Loading @@ -971,6 +974,7 @@ public class Serializer { return new Device( deviceId, deviceName, deviceType, deviceConfig, deviceOperationalStatus, Loading src/automation/src/main/java/eu/teraflow/automation/context/model/Device.java +11 −1 Original line number Diff line number Diff line Loading @@ -22,6 +22,7 @@ import java.util.List; public class Device { private final String deviceId; private final String deviceName; private final String deviceType; private DeviceConfig deviceConfig; private DeviceOperationalStatus deviceOperationalStatus; Loading @@ -30,6 +31,7 @@ public class Device { public Device( String deviceId, String deviceName, String deviceType, DeviceConfig deviceConfig, DeviceOperationalStatus deviceOperationalStatus, Loading @@ -37,6 +39,7 @@ public class Device { List<EndPoint> endPoints) { this.deviceId = deviceId; this.deviceName = deviceName; this.deviceType = deviceType; this.deviceConfig = deviceConfig; this.deviceOperationalStatus = deviceOperationalStatus; Loading @@ -46,11 +49,13 @@ public class Device { public Device( String deviceId, String deviceName, String deviceType, DeviceOperationalStatus deviceOperationalStatus, List<DeviceDriverEnum> deviceDrivers, List<EndPoint> endPoints) { this.deviceId = deviceId; this.deviceName = deviceName; this.deviceType = deviceType; this.deviceOperationalStatus = deviceOperationalStatus; this.deviceDrivers = deviceDrivers; Loading @@ -77,6 +82,10 @@ public class Device { return deviceId; } public String getDeviceName() { return deviceName; } public String getDeviceType() { return deviceType; } Loading Loading @@ -104,9 +113,10 @@ public class Device { @Override public String toString() { return String.format( "%s:{deviceId:\"%s\", deviceType:\"%s\", %s, deviceOperationalStatus=\"%s\", [%s], [%s]}", "%s:{deviceId:\"%s\", deviceName:\"%s\", deviceType:\"%s\", %s, deviceOperationalStatus=\"%s\", [%s], [%s]}", getClass().getSimpleName(), deviceId, deviceName, deviceType, deviceConfig, deviceOperationalStatus.toString(), Loading src/automation/src/test/java/eu/teraflow/automation/AutomationFunctionalServiceTest.java +16 −2 Original line number Diff line number Diff line Loading @@ -79,6 +79,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevRoleId().toString(); String deviceName = "deviceName"; String deviceType = "cisco"; final var configRuleCustomA = new ConfigRuleCustom("resourceKeyA", "resourceValueA"); Loading Loading @@ -132,7 +133,12 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); deviceId, deviceName, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); Uni<Device> deviceUni = Uni.createFrom().item(device); Mockito.when(contextGateway.getDevice(Mockito.any())).thenReturn(deviceUni); Loading Loading @@ -199,6 +205,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevId().toString(); String deviceName = "deviceName"; String deviceType = "ztp"; List<ConfigRule> configRuleList = new ArrayList<>(); Loading Loading @@ -247,6 +254,7 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceName, deviceType, expectedDeviceConfig, DeviceOperationalStatus.ENABLED, Loading Loading @@ -323,6 +331,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevRoleId().toString(); String deviceName = "deviceName"; String deviceType = "cisco"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -360,7 +369,12 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); deviceId, deviceName, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); Uni<Device> deviceUni = Uni.createFrom().item(device); Mockito.when(contextGateway.getDevice(Mockito.any())).thenReturn(deviceUni); Loading src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java +6 −0 Original line number Diff line number Diff line Loading @@ -75,6 +75,7 @@ class AutomationServiceTest { final var message = new CompletableFuture<>(); final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -114,6 +115,7 @@ class AutomationServiceTest { final var disabledDevice = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.DISABLED, Loading Loading @@ -164,6 +166,7 @@ class AutomationServiceTest { final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -203,6 +206,7 @@ class AutomationServiceTest { final var device = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.ENABLED, Loading Loading @@ -282,6 +286,7 @@ class AutomationServiceTest { final var deviceRole = Automation.DeviceRole.newBuilder().setDevRoleId(deviceRoleId).build(); final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -321,6 +326,7 @@ class AutomationServiceTest { final var device = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.ENABLED, Loading src/automation/src/test/java/eu/teraflow/automation/ContextSubscriberTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -92,7 +92,7 @@ class ContextSubscriberTest { contextSubscriber.listenForDeviceEvents(); verify(automationService, times(0)).addDevice(deviceId); // verify(automationService, times(0)).addDevice(deviceId); } @Test Loading Loading
src/automation/src/main/java/eu/teraflow/automation/Serializer.java +4 −0 Original line number Diff line number Diff line Loading @@ -929,6 +929,7 @@ public class Serializer { final var deviceIdUuid = serializeUuid(device.getDeviceId()); final var deviceId = DeviceId.newBuilder().setDeviceUuid(deviceIdUuid); final var deviceName = device.getDeviceName(); final var deviceType = device.getDeviceType(); final var deviceConfig = device.getDeviceConfig(); final var deviceOperationalStatus = device.getDeviceOperationalStatus(); Loading @@ -943,6 +944,7 @@ public class Serializer { deviceEndPoints.stream().map(this::serialize).collect(Collectors.toList()); builder.setDeviceId(deviceId); builder.setName(deviceName); builder.setDeviceType(deviceType); builder.setDeviceConfig(serializedDeviceConfig); builder.setDeviceOperationalStatus(serializedDeviceOperationalStatus); Loading @@ -955,6 +957,7 @@ public class Serializer { public Device deserialize(ContextOuterClass.Device device) { final var serializedDeviceId = device.getDeviceId(); final var deviceName = device.getName(); final var deviceType = device.getDeviceType(); final var serializedDeviceConfig = device.getDeviceConfig(); final var serializedDeviceOperationalStatus = device.getDeviceOperationalStatus(); Loading @@ -971,6 +974,7 @@ public class Serializer { return new Device( deviceId, deviceName, deviceType, deviceConfig, deviceOperationalStatus, Loading
src/automation/src/main/java/eu/teraflow/automation/context/model/Device.java +11 −1 Original line number Diff line number Diff line Loading @@ -22,6 +22,7 @@ import java.util.List; public class Device { private final String deviceId; private final String deviceName; private final String deviceType; private DeviceConfig deviceConfig; private DeviceOperationalStatus deviceOperationalStatus; Loading @@ -30,6 +31,7 @@ public class Device { public Device( String deviceId, String deviceName, String deviceType, DeviceConfig deviceConfig, DeviceOperationalStatus deviceOperationalStatus, Loading @@ -37,6 +39,7 @@ public class Device { List<EndPoint> endPoints) { this.deviceId = deviceId; this.deviceName = deviceName; this.deviceType = deviceType; this.deviceConfig = deviceConfig; this.deviceOperationalStatus = deviceOperationalStatus; Loading @@ -46,11 +49,13 @@ public class Device { public Device( String deviceId, String deviceName, String deviceType, DeviceOperationalStatus deviceOperationalStatus, List<DeviceDriverEnum> deviceDrivers, List<EndPoint> endPoints) { this.deviceId = deviceId; this.deviceName = deviceName; this.deviceType = deviceType; this.deviceOperationalStatus = deviceOperationalStatus; this.deviceDrivers = deviceDrivers; Loading @@ -77,6 +82,10 @@ public class Device { return deviceId; } public String getDeviceName() { return deviceName; } public String getDeviceType() { return deviceType; } Loading Loading @@ -104,9 +113,10 @@ public class Device { @Override public String toString() { return String.format( "%s:{deviceId:\"%s\", deviceType:\"%s\", %s, deviceOperationalStatus=\"%s\", [%s], [%s]}", "%s:{deviceId:\"%s\", deviceName:\"%s\", deviceType:\"%s\", %s, deviceOperationalStatus=\"%s\", [%s], [%s]}", getClass().getSimpleName(), deviceId, deviceName, deviceType, deviceConfig, deviceOperationalStatus.toString(), Loading
src/automation/src/test/java/eu/teraflow/automation/AutomationFunctionalServiceTest.java +16 −2 Original line number Diff line number Diff line Loading @@ -79,6 +79,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevRoleId().toString(); String deviceName = "deviceName"; String deviceType = "cisco"; final var configRuleCustomA = new ConfigRuleCustom("resourceKeyA", "resourceValueA"); Loading Loading @@ -132,7 +133,12 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); deviceId, deviceName, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); Uni<Device> deviceUni = Uni.createFrom().item(device); Mockito.when(contextGateway.getDevice(Mockito.any())).thenReturn(deviceUni); Loading Loading @@ -199,6 +205,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevId().toString(); String deviceName = "deviceName"; String deviceType = "ztp"; List<ConfigRule> configRuleList = new ArrayList<>(); Loading Loading @@ -247,6 +254,7 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceName, deviceType, expectedDeviceConfig, DeviceOperationalStatus.ENABLED, Loading Loading @@ -323,6 +331,7 @@ class AutomationFunctionalServiceTest { .build(); String deviceId = outDeviceRoleId.getDevRoleId().toString(); String deviceName = "deviceName"; String deviceType = "cisco"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -360,7 +369,12 @@ class AutomationFunctionalServiceTest { Device device = new Device( deviceId, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); deviceId, deviceName, deviceType, DeviceOperationalStatus.DISABLED, deviceDrivers, endPoints); Uni<Device> deviceUni = Uni.createFrom().item(device); Mockito.when(contextGateway.getDevice(Mockito.any())).thenReturn(deviceUni); Loading
src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java +6 −0 Original line number Diff line number Diff line Loading @@ -75,6 +75,7 @@ class AutomationServiceTest { final var message = new CompletableFuture<>(); final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -114,6 +115,7 @@ class AutomationServiceTest { final var disabledDevice = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.DISABLED, Loading Loading @@ -164,6 +166,7 @@ class AutomationServiceTest { final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -203,6 +206,7 @@ class AutomationServiceTest { final var device = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.ENABLED, Loading Loading @@ -282,6 +286,7 @@ class AutomationServiceTest { final var deviceRole = Automation.DeviceRole.newBuilder().setDevRoleId(deviceRoleId).build(); final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; final var DEVICE_NAME = "deviceNameA"; final var DEVICE_TYPE = "ztp"; final var deviceDrivers = List.of(DeviceDriverEnum.IETF_NETWORK_TOPOLOGY, DeviceDriverEnum.P4); Loading Loading @@ -321,6 +326,7 @@ class AutomationServiceTest { final var device = new Device( DEVICE_ID, DEVICE_NAME, DEVICE_TYPE, emptyDeviceConfig, DeviceOperationalStatus.ENABLED, Loading
src/automation/src/test/java/eu/teraflow/automation/ContextSubscriberTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -92,7 +92,7 @@ class ContextSubscriberTest { contextSubscriber.listenForDeviceEvents(); verify(automationService, times(0)).addDevice(deviceId); // verify(automationService, times(0)).addDevice(deviceId); } @Test Loading