Compare commits

...

6 Commits

Author SHA1 Message Date
Lynn Shi
fa77d3896d WIFI-4732 add equipmentId in error msg 2021-10-20 16:12:40 -04:00
Lynn Shi
55c4671211 Wifi 4732 update based on review comments 2021-10-20 15:31:46 -04:00
Lynn Shi
a540274210 WIFI-4732 Minor update 2021-10-19 23:48:38 -04:00
Lynn Shi
56f43d8e7f WIFI-4732 add null check 2021-10-19 22:41:34 -04:00
Lynn Shi
607c1c815e WIFI-4732 EquipmentPortalController reset defaults channels for equipment country change 2021-10-19 22:32:43 -04:00
Rahul Sharma
f750d0cad2 Merge pull request #164 from Telecominfraproject/wifi-4417_2
Adding method to retrieve profile based on ModelType
2021-10-17 22:18:43 -04:00
6 changed files with 727 additions and 157 deletions

View File

@@ -1,6 +1,8 @@
package com.telecominfraproject.wlan.equipment.models;
import java.util.EnumMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
@@ -48,6 +50,38 @@ public class ElementRadioConfiguration extends BaseJsonModel
private Boolean deauthAttackDetection;
private Set<ChannelPowerLevel> allowedChannelsPowerLevels = new HashSet<>();
public final static int DEFAULT_CHANNEL_NUMBER_2DOT4GHZ = 6;
public final static int DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ = 11;
public final static int DEFAULT_CHANNEL_NUMBER_5GHZ = 36;
public final static int DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ = 44;
public final static int DEFAULT_CHANNEL_NUMBER_5GHZL = 36;
public final static int DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZL = 44;
public final static int DEFAULT_CHANNEL_NUMBER_5GHZU = 149;
public final static int DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZU = 157;
private static final Map<RadioType, Integer> defaultChannelNumberMap = new EnumMap<>(RadioType.class);
private static final Map<RadioType, Integer> defaultBackupChannelNumberMap = new EnumMap<>(RadioType.class);
static {
defaultChannelNumberMap.put(RadioType.is2dot4GHz, DEFAULT_CHANNEL_NUMBER_2DOT4GHZ);
defaultChannelNumberMap.put(RadioType.is5GHz, DEFAULT_CHANNEL_NUMBER_5GHZ);
defaultChannelNumberMap.put(RadioType.is5GHzL, DEFAULT_CHANNEL_NUMBER_5GHZL);
defaultChannelNumberMap.put(RadioType.is5GHzU, DEFAULT_CHANNEL_NUMBER_5GHZU);
defaultBackupChannelNumberMap.put(RadioType.is2dot4GHz, DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ);
defaultBackupChannelNumberMap.put(RadioType.is5GHz, DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ);
defaultBackupChannelNumberMap.put(RadioType.is5GHzL, DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZL);
defaultBackupChannelNumberMap.put(RadioType.is5GHzU, DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZU);
}
public static Integer getDefaultChannelNumber(RadioType radioType) {
return defaultChannelNumberMap.get(radioType);
}
public static Integer getDefaultBackupChannelNumber(RadioType radioType) {
return defaultBackupChannelNumberMap.get(radioType);
}
/**
* Static creator
@@ -60,19 +94,8 @@ public class ElementRadioConfiguration extends BaseJsonModel
returnValue.setRadioType(radioType);
if (radioType == RadioType.is5GHz) {
returnValue.setChannelNumber(36);
returnValue.setBackupChannelNumber(44);
} else if (radioType == RadioType.is5GHzL) {
returnValue.setChannelNumber(36);
returnValue.setBackupChannelNumber(44);
} else if (radioType == RadioType.is5GHzU) {
returnValue.setChannelNumber(149);
returnValue.setBackupChannelNumber(157);
} else {
returnValue.setChannelNumber(6);
returnValue.setBackupChannelNumber(11);
}
returnValue.setChannelNumber(getDefaultChannelNumber(radioType));
returnValue.setBackupChannelNumber(getDefaultBackupChannelNumber(radioType));
return returnValue;
}

View File

@@ -36,11 +36,9 @@ import com.telecominfraproject.wlan.core.model.pagination.PaginationContext;
import com.telecominfraproject.wlan.core.model.pagination.PaginationResponse;
import com.telecominfraproject.wlan.core.model.pagination.SortOrder;
import com.telecominfraproject.wlan.core.model.pair.PairLongLong;
import com.telecominfraproject.wlan.datastore.exceptions.DsDataValidationException;
import com.telecominfraproject.wlan.equipment.models.AntennaType;
import com.telecominfraproject.wlan.equipment.models.ApElementConfiguration;
import com.telecominfraproject.wlan.equipment.models.CellSizeAttributes;
import com.telecominfraproject.wlan.equipment.models.ChannelPowerLevel;
import com.telecominfraproject.wlan.equipment.models.CustomerEquipmentCounts;
import com.telecominfraproject.wlan.equipment.models.ElementRadioConfiguration;
import com.telecominfraproject.wlan.equipment.models.Equipment;
@@ -623,94 +621,6 @@ public class EquipmentServiceRemoteTest extends BaseRemoteTest {
}
@Test
public void testEquipmentUpdateChannelNumValidation() {
//Create new Equipment - success
Equipment equipment = new Equipment();
equipment.setName("testName-"+getNextEquipmentId());
equipment.setInventoryId("test-inv-"+getNextEquipmentId());
equipment.setEquipmentType(EquipmentType.AP);
equipment.setDetails(ApElementConfiguration.createWithDefaults());
ElementRadioConfiguration element2dot4RadioConfig = ((ApElementConfiguration)equipment.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
element2dot4RadioConfig.setAllowedChannelsPowerLevels(new HashSet<>());
for (int i = 1; i <= 11; i++) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element2dot4RadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
Equipment ret = remoteInterface.create(equipment);
assertNotNull(ret);
ret = remoteInterface.get(ret.getId());
assertEqualEquipments(equipment, ret);
ElementRadioConfiguration retElement2dot4RadioConfig = ((ApElementConfiguration)ret.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
assertEquals(retElement2dot4RadioConfig.getChannelNumber().intValue(), 6);
//Update success
retElement2dot4RadioConfig.setChannelNumber(1);
retElement2dot4RadioConfig.setManualChannelNumber(2);
retElement2dot4RadioConfig.setBackupChannelNumber(3);
retElement2dot4RadioConfig.setManualBackupChannelNumber(4);
Equipment updatedEquipment = remoteInterface.update(ret);
Equipment retUpdate = remoteInterface.get(ret.getId());
assertEqualEquipments(retUpdate, updatedEquipment);
ElementRadioConfiguration ret2Element2dot4RadioConfig = ((ApElementConfiguration)retUpdate.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
assertEquals(retElement2dot4RadioConfig.getChannelNumber().intValue(), 1);
assertEquals(retElement2dot4RadioConfig.getManualChannelNumber().intValue(), 2);
assertEquals(retElement2dot4RadioConfig.getBackupChannelNumber().intValue(), 3);
assertEquals(retElement2dot4RadioConfig.getManualBackupChannelNumber().intValue(), 4);
//Update failure
ret2Element2dot4RadioConfig.setChannelNumber(12);
try {
remoteInterface.update(retUpdate);
fail("EquipmentService update channelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setChannelNumber(6);
ret2Element2dot4RadioConfig.setManualChannelNumber(13);
try {
remoteInterface.update(retUpdate);
fail("EquipmentService update manualChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setManualChannelNumber(7);
ret2Element2dot4RadioConfig.setBackupChannelNumber(14);
try {
remoteInterface.update(retUpdate);
fail("EquipmentService update backupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setBackupChannelNumber(8);
ret2Element2dot4RadioConfig.setManualBackupChannelNumber(15);
try {
remoteInterface.update(retUpdate);
fail("EquipmentService update manualBackupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
//Tolerate null now
ret2Element2dot4RadioConfig.setManualBackupChannelNumber(null);
remoteInterface.update(retUpdate);
}
@Test
public void testGetPaginatedEquipmentIds()
{
@@ -869,7 +779,6 @@ public class EquipmentServiceRemoteTest extends BaseRemoteTest {
// Clean up after test
createdSet.forEach( c-> remoteInterface.delete(c));
}
@Test

View File

@@ -1,12 +1,10 @@
package com.telecominfraproject.wlan.equipment.controller;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -34,7 +32,6 @@ import com.telecominfraproject.wlan.datastore.exceptions.DsDataValidationExcepti
import com.telecominfraproject.wlan.equipment.datastore.EquipmentDatastore;
import com.telecominfraproject.wlan.equipment.models.ApElementConfiguration;
import com.telecominfraproject.wlan.equipment.models.CellSizeAttributes;
import com.telecominfraproject.wlan.equipment.models.ChannelPowerLevel;
import com.telecominfraproject.wlan.equipment.models.CustomerEquipmentCounts;
import com.telecominfraproject.wlan.equipment.models.ElementRadioConfiguration;
import com.telecominfraproject.wlan.equipment.models.Equipment;
@@ -263,14 +260,12 @@ public class EquipmentController {
throw new DsDataValidationException("Equipment contains unsupported value");
}
validateChannelNum(equipment);
Equipment existingEquipment = equipmentDatastore.getOrNull(equipment.getId());
ApElementConfiguration existingApElementConfig = null;
if (existingEquipment != null && existingEquipment.getDetails() instanceof ApElementConfiguration) {
existingApElementConfig = (ApElementConfiguration) existingEquipment.getDetails();
}
Equipment ret = equipmentDatastore.update(equipment);
ApElementConfiguration updatedApElementConfig = null;
if (ret != null && ret.getDetails() instanceof ApElementConfiguration) {
@@ -299,39 +294,6 @@ public class EquipmentController {
return ret;
}
private void validateChannelNum(Equipment equipment) {
if (equipment.getDetails() instanceof ApElementConfiguration) {
ApElementConfiguration apElementConfiguration = (ApElementConfiguration) equipment.getDetails();
if (apElementConfiguration.getRadioMap() != null) {
for (RadioType radioType : apElementConfiguration.getRadioMap().keySet()) {
ElementRadioConfiguration elementRadioConfig = apElementConfiguration.getRadioMap().get(radioType);
Integer channelNum = elementRadioConfig.getChannelNumber();
Integer manualChannelNum = elementRadioConfig.getManualChannelNumber();
Integer backupChannelNum = elementRadioConfig.getBackupChannelNumber();
Integer manualBackupChannelNum = elementRadioConfig.getManualBackupChannelNumber();
List<Integer> allowedChannels = elementRadioConfig.getAllowedChannelsPowerLevels().stream().map(ChannelPowerLevel::getChannelNumber).collect(Collectors.toList());
if (allowedChannels != null && !allowedChannels.isEmpty()) {
checkAllowedChannels(channelNum, "channelNumber", allowedChannels);
checkAllowedChannels(backupChannelNum, "backupChannelNumber", allowedChannels);
checkAllowedChannels(manualChannelNum, "manualChannelNumber", allowedChannels);
checkAllowedChannels(manualBackupChannelNum, "manualBackupChannelNumber", allowedChannels);
}
}
}
}
}
private void checkAllowedChannels(Integer channelNum, String channelType, List<Integer> allowedChannels) {
if (channelNum != null && !allowedChannels.contains(channelNum)) {
LOG.error("Failed to update Equipment. The {} ({}) is out of the allowed channels range {}",
channelType, channelNum, allowedChannels);
throw new DsDataValidationException("Equipment contains disallowed " + channelType);
}
}
/**
* Updates Equipment Channels
*
@@ -574,25 +536,13 @@ public class EquipmentController {
Set<Long> equipmentIds = new HashSet<>();
request.getItems().forEach(item -> equipmentIds.add(item.getEquipmentId()));
//validate equipment before the bulk update
List<Equipment> equipmentBeforeUpdate = equipmentDatastore.get(equipmentIds);
Map<Long, Equipment> eqMap = new HashMap<>();
equipmentBeforeUpdate.forEach(eq -> eqMap.put(eq.getId(), eq));
request.getItems().forEach(item -> {
Equipment eq = eqMap.get(item.getEquipmentId());
if(item.applyToEquipment(eq)) {
validateChannelNum(eq);
}
});
equipmentDatastore.updateRrmBulk(request);
//send events after the bulk update
List<Equipment> equipmentAfterUpdate = equipmentDatastore.get(equipmentIds);
List<SystemEvent> events = new ArrayList<>();
equipmentAfterUpdate.forEach(eq -> events.add(new EquipmentChangedEvent(eq)));
equipmentAfterUpdate.forEach(eq -> events.add(new EquipmentApImpactingChangedEvent(eq)));
publishEvents(events);
return new GenericResponse(true, "");

View File

@@ -161,6 +161,42 @@
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>location-service-local</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>location-datastore-inmemory</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>alarm-service-local</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>alarm-datastore-inmemory</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>status-service-local</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
<dependency>
<artifactId>status-datastore-inmemory</artifactId>
<groupId>com.telecominfraproject.wlan</groupId>
<version>1.2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
</dependencies>
</project>

View File

@@ -6,7 +6,9 @@ import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -27,8 +29,10 @@ import com.telecominfraproject.wlan.core.model.pagination.PaginationContext;
import com.telecominfraproject.wlan.core.model.pagination.PaginationResponse;
import com.telecominfraproject.wlan.core.model.pair.PairLongLong;
import com.telecominfraproject.wlan.datastore.exceptions.DsConcurrentModificationException;
import com.telecominfraproject.wlan.datastore.exceptions.DsDataValidationException;
import com.telecominfraproject.wlan.equipment.EquipmentServiceInterface;
import com.telecominfraproject.wlan.equipment.models.ApElementConfiguration;
import com.telecominfraproject.wlan.equipment.models.ChannelPowerLevel;
import com.telecominfraproject.wlan.equipment.models.ElementRadioConfiguration;
import com.telecominfraproject.wlan.equipment.models.Equipment;
import com.telecominfraproject.wlan.equipment.models.EquipmentCellSizeAttributesUpdateRequest;
@@ -36,7 +40,9 @@ import com.telecominfraproject.wlan.equipment.models.EquipmentChannelsUpdateRequ
import com.telecominfraproject.wlan.equipment.models.EquipmentDetails;
import com.telecominfraproject.wlan.equipment.models.RadioConfiguration;
import com.telecominfraproject.wlan.equipment.models.bulkupdate.rrm.EquipmentRrmBulkUpdateRequest;
import com.telecominfraproject.wlan.location.service.LocationServiceInterface;
import com.telecominfraproject.wlan.profile.ProfileServiceInterface;
import com.telecominfraproject.wlan.location.models.Location;
import com.telecominfraproject.wlan.status.StatusServiceInterface;
/**
@@ -48,6 +54,9 @@ import com.telecominfraproject.wlan.status.StatusServiceInterface;
public class EquipmentPortalController {
private static final Logger LOG = LoggerFactory.getLogger(EquipmentPortalController.class);
public static enum CHANNEL_NUMBER_TYPE {channelNumber, backupChannelNumber, manualChannelNumber,
manualBackupChannelNumber};
@Value("${tip.wlan.portal.equipment.numRetryUpdate:10}")
private int numRetryUpdate;
@@ -71,6 +80,9 @@ public class EquipmentPortalController {
@Autowired
private ProfileServiceInterface profileServiceInterface;
@Autowired
private LocationServiceInterface locationServiceInterface;
@RequestMapping(value = "/equipment", method = RequestMethod.GET)
public Equipment getEquipment(@RequestParam long equipmentId) {
@@ -86,14 +98,25 @@ public class EquipmentPortalController {
LOG.debug("Updating equipment {}", equipment.getId());
Equipment ret = null;
Equipment existing = equipmentServiceInterface.getOrNull(equipment.getId());
for(int i=0; i<numRetryUpdate; i++) {
try {
if (equipment != null && existing != null && equipment.getLocationId() != existing.getLocationId()) {
Location location = locationServiceInterface.get(equipment.getLocationId());
Location existingLocation = locationServiceInterface.get(existing.getLocationId());
if (!Objects.equals(Location.getCountryCode(location), Location.getCountryCode(existingLocation))) {
updateEquipmentWithDefaultChannels(equipment);
}
}
validateChannelNum(equipment);
ret = equipmentServiceInterface.update(equipment);
break;
} catch (DsConcurrentModificationException e) {
LOG.debug("Equipment was concurrently updated, retrying: {}", e.getMessage());
Equipment existing = equipmentServiceInterface.getOrNull(equipment.getId());
existing = equipmentServiceInterface.getOrNull(equipment.getId());
equipment.setLastModifiedTimestamp(existing.getLastModifiedTimestamp());
}
}
@@ -105,9 +128,115 @@ public class EquipmentPortalController {
return ret;
}
private void updateEquipmentWithDefaultChannels(Equipment equipment) {
if (equipment.getDetails() instanceof ApElementConfiguration) {
ApElementConfiguration apElementConfiguration = (ApElementConfiguration) equipment.getDetails();
if (apElementConfiguration.getRadioMap() != null) {
for (RadioType radioType : apElementConfiguration.getRadioMap().keySet()) {
ElementRadioConfiguration elementRadioConfig = apElementConfiguration.getRadioMap().get(radioType);
elementRadioConfig.setChannelNumber(ElementRadioConfiguration.getDefaultChannelNumber(radioType));
elementRadioConfig.setBackupChannelNumber(ElementRadioConfiguration.getDefaultBackupChannelNumber(radioType));
elementRadioConfig.setManualChannelNumber(ElementRadioConfiguration.getDefaultChannelNumber(radioType));
elementRadioConfig.setManualBackupChannelNumber(ElementRadioConfiguration.getDefaultBackupChannelNumber(radioType));
}
}
}
}
private void validateChannelNum(Equipment equipment) {
if (equipment != null && equipment.getDetails() instanceof ApElementConfiguration) {
ApElementConfiguration apElementConfiguration = (ApElementConfiguration) equipment.getDetails();
if (apElementConfiguration.getRadioMap() != null) {
for (RadioType radioType : apElementConfiguration.getRadioMap().keySet()) {
ElementRadioConfiguration elementRadioConfig = apElementConfiguration.getRadioMap().get(radioType);
List<Integer> allowedChannels = elementRadioConfig.getAllowedChannelsPowerLevels().stream().map(
ChannelPowerLevel::getChannelNumber).collect(Collectors.toList());
if (allowedChannels != null && !allowedChannels.isEmpty()) {
for (CHANNEL_NUMBER_TYPE channelType : CHANNEL_NUMBER_TYPE.values()) {
checkAllowedChannels(equipment.getId(), elementRadioConfig, channelType, allowedChannels, radioType);
}
}
}
}
}
}
private Integer getChannelNumber( ElementRadioConfiguration elementRadioConfig, CHANNEL_NUMBER_TYPE channelType) {
Integer channelNum = null;
switch (channelType) {
case channelNumber: {
channelNum = elementRadioConfig.getChannelNumber();
break;
}
case backupChannelNumber: {
channelNum = elementRadioConfig.getBackupChannelNumber();
break;
}
case manualChannelNumber: {
channelNum = elementRadioConfig.getManualChannelNumber();
break;
}
case manualBackupChannelNumber: {
channelNum = elementRadioConfig.getManualBackupChannelNumber();
break;
}
}
return channelNum;
}
private void checkAllowedChannels(long equipmentId, ElementRadioConfiguration elementRadioConfig, CHANNEL_NUMBER_TYPE channelType,
List<Integer> allowedChannels, RadioType radioType) {
Integer channelNum = getChannelNumber(elementRadioConfig, channelType);
checkAllowedChannels(equipmentId, channelNum, channelType, allowedChannels, radioType);
}
private void checkAllowedChannels(long equipmentId, Integer channelNum, CHANNEL_NUMBER_TYPE channelType,
List<Integer> allowedChannels, RadioType radioType) {
if (channelNum != null && !allowedChannels.contains(channelNum)) {
LOG.error("Failed to update Equipment {}. The {} ({}) is out of the allowed channels range {} for radioType {}",
equipmentId, channelType, channelNum, allowedChannels, radioType);
throw new DsDataValidationException("Failed to update Equipment. The " + channelType + "(" + channelNum +
") is out of the allowed channels range " + allowedChannels + " for radioType " +
RadioType.getRadioDisplayString(radioType));
}
}
@RequestMapping(value = "/equipment/channel", method = RequestMethod.PUT)
public Equipment updateEquipmentChannels(@RequestBody EquipmentChannelsUpdateRequest request) {
LOG.debug("updateEquipmentChannels {}", request);
Map<RadioType, Integer> primaryChannels = request.getPrimaryChannels();
Map<RadioType, Integer> backupChannels = request.getBackupChannels();
long equipmentId = request.getEquipmentId();
Equipment existing = equipmentServiceInterface.getOrNull(equipmentId);
if (existing != null && existing.getDetails() instanceof ApElementConfiguration) {
ApElementConfiguration apElementConfiguration = (ApElementConfiguration) existing.getDetails();
if (apElementConfiguration.getRadioMap() != null) {
for (RadioType radioType : apElementConfiguration.getRadioMap().keySet()) {
ElementRadioConfiguration elementRadioConfig = apElementConfiguration.getRadioMap().get(radioType);
List<Integer> allowedChannels = elementRadioConfig.getAllowedChannelsPowerLevels().stream().map(
ChannelPowerLevel::getChannelNumber).collect(Collectors.toList());
if (allowedChannels != null && !allowedChannels.isEmpty()) {
if (primaryChannels != null && primaryChannels.get(radioType) != null) {
checkAllowedChannels(equipmentId, primaryChannels.get(radioType), CHANNEL_NUMBER_TYPE.channelNumber, allowedChannels, radioType);
}
if (backupChannels != null && backupChannels.get(radioType) != null) {
checkAllowedChannels(equipmentId, backupChannels.get(radioType), CHANNEL_NUMBER_TYPE.backupChannelNumber, allowedChannels, radioType);
}
}
}
}
}
return equipmentServiceInterface.updateChannels(request);
}
@@ -302,6 +431,20 @@ public class EquipmentPortalController {
@RequestMapping(value = "/equipment/rrmBulk", method=RequestMethod.PUT)
public GenericResponse updateRrmBulk(@RequestBody EquipmentRrmBulkUpdateRequest request) {
LOG.debug("updateRrmBulk {}", request);
//validate equipment before the bulk update
Set<Long> equipmentIds = new HashSet<>();
request.getItems().forEach(item -> equipmentIds.add(item.getEquipmentId()));
List<Equipment> equipmentBeforeUpdate = equipmentServiceInterface.get(equipmentIds);
Map<Long, Equipment> eqMap = new HashMap<>();
equipmentBeforeUpdate.forEach(eq -> eqMap.put(eq.getId(), eq));
request.getItems().forEach(item -> {
Equipment eq = eqMap.get(item.getEquipmentId());
if(item.applyToEquipment(eq)) {
validateChannelNum(eq);
}
});
equipmentServiceInterface.updateRrmBulk(request);
return new GenericResponse(true, "");
}

View File

@@ -0,0 +1,509 @@
package com.telecominfraproject.wlan.portal.controller.equipment;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
import java.util.EnumMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.atomic.AtomicLong;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
import org.springframework.context.annotation.Import;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import com.telecominfraproject.wlan.alarm.AlarmServiceLocal;
import com.telecominfraproject.wlan.alarm.controller.AlarmController;
import com.telecominfraproject.wlan.alarm.datastore.inmemory.AlarmDatastoreInMemory;
import com.telecominfraproject.wlan.cloudeventdispatcher.CloudEventDispatcherEmpty;
import com.telecominfraproject.wlan.core.model.entity.CountryCode;
import com.telecominfraproject.wlan.core.model.equipment.EquipmentType;
import com.telecominfraproject.wlan.core.model.equipment.RadioType;
import com.telecominfraproject.wlan.datastore.exceptions.DsDataValidationException;
import com.telecominfraproject.wlan.equipment.EquipmentServiceLocal;
import com.telecominfraproject.wlan.equipment.controller.EquipmentController;
import com.telecominfraproject.wlan.equipment.datastore.inmemory.EquipmentDatastoreInMemory;
import com.telecominfraproject.wlan.equipment.models.ApElementConfiguration;
import com.telecominfraproject.wlan.equipment.models.ChannelPowerLevel;
import com.telecominfraproject.wlan.equipment.models.ElementRadioConfiguration;
import com.telecominfraproject.wlan.equipment.models.Equipment;
import com.telecominfraproject.wlan.equipment.models.EquipmentChannelsUpdateRequest;
import com.telecominfraproject.wlan.equipment.models.RadioConfiguration;
import com.telecominfraproject.wlan.location.datastore.LocationDatastore;
import com.telecominfraproject.wlan.location.datastore.inmemory.LocationDatastoreInMemory;
import com.telecominfraproject.wlan.location.models.Location;
import com.telecominfraproject.wlan.location.models.LocationDetails;
import com.telecominfraproject.wlan.location.models.LocationType;
import com.telecominfraproject.wlan.location.service.LocationServiceController;
import com.telecominfraproject.wlan.location.service.LocationServiceLocal;
import com.telecominfraproject.wlan.profile.ProfileServiceLocal;
import com.telecominfraproject.wlan.profile.controller.ProfileController;
import com.telecominfraproject.wlan.profile.datastore.inmemory.ProfileDatastoreInMemory;
import com.telecominfraproject.wlan.profile.models.ProfileByCustomerRequestFactory;
import com.telecominfraproject.wlan.status.StatusServiceLocal;
import com.telecominfraproject.wlan.status.controller.StatusController;
import com.telecominfraproject.wlan.status.datastore.inmemory.StatusDatastoreInMemory;
@RunWith(SpringRunner.class)
@ActiveProfiles(profiles = {
"integration_test",
}) //NOTE: these profiles will be ADDED to the list of active profiles
@SpringBootTest(webEnvironment = WebEnvironment.NONE, classes = EquipmentPortalControllerTest.class)
@Import(value = {
EquipmentServiceLocal.class,
EquipmentController.class,
EquipmentDatastoreInMemory.class,
EquipmentPortalController.class,
LocationServiceLocal.class,
LocationServiceController.class,
LocationDatastoreInMemory.class,
CloudEventDispatcherEmpty.class,
AlarmServiceLocal.class,
AlarmController.class,
AlarmDatastoreInMemory.class,
ProfileServiceLocal.class,
ProfileDatastoreInMemory.class,
ProfileController.class,
ProfileByCustomerRequestFactory.class,
StatusServiceLocal.class,
StatusDatastoreInMemory.class,
StatusController.class
})
public class EquipmentPortalControllerTest {
private static AtomicLong locationIncrementer = new AtomicLong(1);
private static AtomicLong equipmentIncrementer = new AtomicLong(1);
private static Set<Long> locationIds = new HashSet<Long>();
private static Set<Long> equipmentIds = new HashSet<Long>();
@Autowired private EquipmentPortalController equipmentPortalController;
@Autowired private LocationDatastore locationDatastore;
@BeforeEach
public void setup()
{
locationIds.clear();
equipmentIds.clear();
}
protected Location createLocation(int customerId, LocationType locationType, CountryCode countryCode) {
Location location = new Location();
location.setCustomerId(customerId);
// Setup location details with default CmapLocationActivityDetails
LocationDetails details = LocationDetails.createWithDefaults();
details.setCountryCode(countryCode);
location.setDetails(details);
location.setName("Location-UT" + locationIncrementer.getAndIncrement());
location.setLocationType(locationType);
Location created = locationDatastore.create(location);
assertNotNull(created);
return created;
}
@Test
public void testEquipmentUpdateChannelNumValidation() {
Location location = createLocation(2, LocationType.SITE, CountryCode.US);
//Create new Equipment - success
Equipment equipment = new Equipment();
equipment.setName("testName-"+ equipmentIncrementer.getAndIncrement());
equipment.setInventoryId("test-inv-"+equipmentIncrementer.getAndIncrement());
equipment.setEquipmentType(EquipmentType.AP);
equipment.setLocationId(location.getId());
equipment.setDetails(ApElementConfiguration.createWithDefaults());
ElementRadioConfiguration element2dot4RadioConfig = ((ApElementConfiguration)equipment.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
element2dot4RadioConfig.setAllowedChannelsPowerLevels(new HashSet<>());
for (int i = 1; i <= 11; i++) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element2dot4RadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
Equipment ret = equipmentPortalController.createEquipment(equipment);
assertNotNull(ret);
long equipmentId = ret.getId();
ret = equipmentPortalController.getEquipment(equipmentId);
assertEqualEquipments(equipment, ret);
ElementRadioConfiguration retElement2dot4RadioConfig = ((ApElementConfiguration)ret.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_2DOT4GHZ, retElement2dot4RadioConfig.getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ, retElement2dot4RadioConfig.getBackupChannelNumber().intValue());
//Update success
retElement2dot4RadioConfig.setChannelNumber(1);
retElement2dot4RadioConfig.setManualChannelNumber(2);
retElement2dot4RadioConfig.setBackupChannelNumber(3);
retElement2dot4RadioConfig.setManualBackupChannelNumber(4);
Equipment updatedEquipment = equipmentPortalController.updateEquipment(ret);
Equipment retUpdate = equipmentPortalController.getEquipment(ret.getId());
assertEqualEquipments(retUpdate, updatedEquipment);
ElementRadioConfiguration ret2Element2dot4RadioConfig = ((ApElementConfiguration)retUpdate.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
assertEquals(1, ret2Element2dot4RadioConfig.getChannelNumber().intValue());
assertEquals(2, ret2Element2dot4RadioConfig.getManualChannelNumber().intValue());
assertEquals(3, ret2Element2dot4RadioConfig.getBackupChannelNumber().intValue());
assertEquals(4, ret2Element2dot4RadioConfig.getManualBackupChannelNumber().intValue());
//Update failure
ret2Element2dot4RadioConfig.setChannelNumber(12);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update channelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setChannelNumber(6);
ret2Element2dot4RadioConfig.setManualChannelNumber(13);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update manualChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setManualChannelNumber(7);
ret2Element2dot4RadioConfig.setBackupChannelNumber(14);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update backupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element2dot4RadioConfig.setBackupChannelNumber(8);
ret2Element2dot4RadioConfig.setManualBackupChannelNumber(15);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update manualBackupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
//Tolerate null now
ret2Element2dot4RadioConfig.setManualBackupChannelNumber(null);
equipmentPortalController.updateEquipment(retUpdate);
// Clean up after test
equipmentPortalController.deleteEquipment(equipmentId);
locationDatastore.delete(location.getId());
}
@Test
public void testEquipmentUpdateChannelNumValidationWithCorrection() {
Location location1 = createLocation(2, LocationType.SITE, CountryCode.US);
Location location2 = createLocation(2, LocationType.BUILDING, CountryCode.SA);
//Create new Equipment - success
Equipment equipment = new Equipment();
equipment.setName("testName-"+equipmentIncrementer.getAndIncrement());
equipment.setInventoryId("test-inv-"+equipmentIncrementer.getAndIncrement());
equipment.setEquipmentType(EquipmentType.AP);
equipment.setLocationId(location1.getId());
ApElementConfiguration apConfig = ApElementConfiguration.createWithDefaults();
if (apConfig.getElementRadioConfiguration(RadioType.is5GHz) == null) {
Map<RadioType, ElementRadioConfiguration> radioMapInit = apConfig.getRadioMap();
Map<RadioType, RadioConfiguration> advRadioMapInit = apConfig.getAdvancedRadioMap();
radioMapInit.put(RadioType.is5GHz, ElementRadioConfiguration.createWithDefaults(RadioType.is5GHz));
apConfig.setRadioMap(radioMapInit);
advRadioMapInit.put(RadioType.is5GHz, RadioConfiguration.createWithDefaults(RadioType.is5GHz));
apConfig.setAdvancedRadioMap(advRadioMapInit);
}
equipment.setDetails(apConfig);
ElementRadioConfiguration element5GRadioConfig = ((ApElementConfiguration)equipment.getDetails()).getRadioMap().get(RadioType.is5GHz);
element5GRadioConfig.setAllowedChannelsPowerLevels(new HashSet<>());
for (int i = 36; i <= 64; i=i+4) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element5GRadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
for (int i = 149; i <= 161; i=i+4) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element5GRadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
Equipment ret = equipmentPortalController.createEquipment(equipment);
assertNotNull(ret);
long equipmentId = ret.getId();
ret = equipmentPortalController.getEquipment(equipmentId);
assertEqualEquipments(equipment, ret);
ElementRadioConfiguration retElement5GRadioConfig = ((ApElementConfiguration)ret.getDetails()).getRadioMap().get(RadioType.is5GHz);
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, retElement5GRadioConfig.getChannelNumber().intValue());
assertEquals( ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, retElement5GRadioConfig.getBackupChannelNumber().intValue());
//Update success
retElement5GRadioConfig.setChannelNumber(149);
retElement5GRadioConfig.setManualChannelNumber(52);
retElement5GRadioConfig.setBackupChannelNumber(157);
retElement5GRadioConfig.setManualBackupChannelNumber(60);
Equipment updatedEquipment = equipmentPortalController.updateEquipment(ret);
Equipment retUpdate = equipmentPortalController.getEquipment(ret.getId());
assertEqualEquipments(retUpdate, updatedEquipment);
ElementRadioConfiguration ret2Element5GRadioConfig = ((ApElementConfiguration)retUpdate.getDetails()).getRadioMap().get(RadioType.is5GHz);
assertEquals(149, ret2Element5GRadioConfig.getChannelNumber().intValue());
assertEquals(52, ret2Element5GRadioConfig.getManualChannelNumber().intValue());
assertEquals(157, ret2Element5GRadioConfig.getBackupChannelNumber().intValue());
assertEquals(60, ret2Element5GRadioConfig.getManualBackupChannelNumber().intValue());
//Update failure
ret2Element5GRadioConfig.setChannelNumber(165);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update channelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element5GRadioConfig.setChannelNumber(157);
ret2Element5GRadioConfig.setManualChannelNumber(165);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update manualChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element5GRadioConfig.setManualChannelNumber(44);
ret2Element5GRadioConfig.setBackupChannelNumber(14);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update backupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element5GRadioConfig.setBackupChannelNumber(36);
ret2Element5GRadioConfig.setManualBackupChannelNumber(15);
try {
equipmentPortalController.updateEquipment(retUpdate);
fail("EquipmentService update manualBackupChannelNumber failed");
} catch (DsDataValidationException e) {
// pass
}
ret2Element5GRadioConfig.setManualBackupChannelNumber(52);
equipmentPortalController.updateEquipment(retUpdate);
Equipment ret2Update = equipmentPortalController.getEquipment(ret.getId());
ElementRadioConfiguration ret3Element5GRadioConfig = ((ApElementConfiguration)ret2Update.getDetails()).getRadioMap().get(RadioType.is5GHz);
assertEquals(157, ret3Element5GRadioConfig.getChannelNumber().intValue());
assertEquals(44, ret3Element5GRadioConfig.getManualChannelNumber().intValue());
assertEquals(36, ret3Element5GRadioConfig.getBackupChannelNumber().intValue());
assertEquals(52, ret3Element5GRadioConfig.getManualBackupChannelNumber().intValue());
// CHANGE Country Code
ret2Update.setLocationId(location2.getId());
Equipment ret3Update = equipmentPortalController.updateEquipment(ret2Update);
ElementRadioConfiguration ret4Element5GRadioConfig = ((ApElementConfiguration) ret3Update.getDetails())
.getRadioMap().get(RadioType.is5GHz);
// These are auto-corrected values
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, ret4Element5GRadioConfig.getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, ret4Element5GRadioConfig.getManualChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, ret4Element5GRadioConfig.getBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, ret4Element5GRadioConfig.getManualBackupChannelNumber().intValue());
for (int i = 149; i <= 161; i = i + 4) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
ret4Element5GRadioConfig.getAllowedChannelsPowerLevels().remove(cpl);
}
Equipment ret5Update = equipmentPortalController.updateEquipment(ret3Update);
ElementRadioConfiguration ret5Element5GRadioConfig = ((ApElementConfiguration) ret5Update.getDetails())
.getRadioMap().get(RadioType.is5GHz);
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, ret5Element5GRadioConfig.getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, ret5Element5GRadioConfig.getManualChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, ret5Element5GRadioConfig.getBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, ret5Element5GRadioConfig.getManualBackupChannelNumber().intValue());
// Clean up after test
equipmentPortalController.deleteEquipment(equipmentId);
locationDatastore.delete(location1.getId());
locationDatastore.delete(location2.getId());
}
@Test
public void testChannelsUpdateChannelNumValidation() {
Location location = createLocation(2, LocationType.SITE, CountryCode.US);
//Create test Equipment
Equipment equipment = new Equipment();
equipment.setName("test_ChannelsUpdate");
equipment.setLocationId(location.getId());
equipment.setEquipmentType(EquipmentType.AP);
equipment.setInventoryId("inv-" + equipment.getName());
ApElementConfiguration apConfig = ApElementConfiguration.createWithDefaults();
equipment.setDetails(apConfig);
if (apConfig.getElementRadioConfiguration(RadioType.is5GHz) == null) {
Map<RadioType, ElementRadioConfiguration> radioMap = apConfig.getRadioMap();
radioMap.put(RadioType.is5GHz, ElementRadioConfiguration.createWithDefaults(RadioType.is5GHz));
apConfig.setRadioMap(radioMap);
}
ElementRadioConfiguration element2dot4RadioConfig = ((ApElementConfiguration)equipment.getDetails()).getRadioMap().get(RadioType.is2dot4GHz);
element2dot4RadioConfig.setAllowedChannelsPowerLevels(new HashSet<>());
for (int i = 1; i <= 11; i++) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element2dot4RadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
ElementRadioConfiguration element5GRadioConfig = ((ApElementConfiguration)equipment.getDetails()).getRadioMap().get(RadioType.is5GHz);
element5GRadioConfig.setAllowedChannelsPowerLevels(new HashSet<>());
for (int i = 36; i <= 64; i=i+4) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element5GRadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
for (int i = 149; i <= 161; i=i+4) {
ChannelPowerLevel cpl = new ChannelPowerLevel();
cpl.setChannelNumber(i);
cpl.setChannelWidth(20);
cpl.setDfs(false);
cpl.setPowerLevel(30);
element5GRadioConfig.getAllowedChannelsPowerLevels().add(cpl);
}
Equipment equipmentCreated = equipmentPortalController.createEquipment(equipment);
long equipmentId = equipmentCreated.getId();
Equipment equipmentGet = equipmentPortalController.getEquipment(equipmentId);
assertNotNull(equipmentGet);
ApElementConfiguration apElementConfiguration = (ApElementConfiguration)equipmentGet.getDetails();
assertNotNull(apElementConfiguration);
Map<RadioType, ElementRadioConfiguration> radioMap = apElementConfiguration.getRadioMap();
assertNotNull(radioMap);
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getManualChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getManualBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getManualChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getManualBackupChannelNumber().intValue());
Map<RadioType, Integer> primaryChannels = new EnumMap<>(RadioType.class);
Map<RadioType, Integer> backupChannels = new EnumMap<>(RadioType.class);
Map<RadioType, Boolean> autoChannelSelections = new EnumMap<>(RadioType.class);
primaryChannels.put(RadioType.is2dot4GHz, 1);
primaryChannels.put(RadioType.is5GHz, 52);
backupChannels.put(RadioType.is2dot4GHz, 6);
backupChannels.put(RadioType.is5GHz, 149);
autoChannelSelections.put(RadioType.is2dot4GHz, false);
autoChannelSelections.put(RadioType.is5GHz, false);
EquipmentChannelsUpdateRequest channelsUpdateRequest = new EquipmentChannelsUpdateRequest();
channelsUpdateRequest.setEquipmentId(equipmentId);
channelsUpdateRequest.setPrimaryChannels(primaryChannels);
channelsUpdateRequest.setBackupChannels(backupChannels);
channelsUpdateRequest.setAutoChannelSelections(autoChannelSelections);
Equipment equipmentUpdate1 = equipmentPortalController.updateEquipmentChannels(channelsUpdateRequest);
Equipment equipmentGetUpdate1 = equipmentPortalController.getEquipment(equipmentId);
assertEqualEquipments(equipmentGetUpdate1, equipmentUpdate1);
apElementConfiguration = (ApElementConfiguration)equipmentGetUpdate1.getDetails();
assertNotNull(apElementConfiguration);
radioMap = apElementConfiguration.getRadioMap();
assertNotNull(radioMap);
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_2DOT4GHZ, radioMap.get(RadioType.is2dot4GHz).getBackupChannelNumber().intValue());
assertEquals(1, radioMap.get(RadioType.is2dot4GHz).getManualChannelNumber().intValue());
assertEquals(6, radioMap.get(RadioType.is2dot4GHz).getManualBackupChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getChannelNumber().intValue());
assertEquals(ElementRadioConfiguration.DEFAULT_BACKUP_CHANNEL_NUMBER_5GHZ, radioMap.get(RadioType.is5GHz).getBackupChannelNumber().intValue());
assertEquals(52, radioMap.get(RadioType.is5GHz).getManualChannelNumber().intValue());
assertEquals(149, radioMap.get(RadioType.is5GHz).getManualBackupChannelNumber().intValue());
primaryChannels.clear();
primaryChannels.put(RadioType.is2dot4GHz, 30);
primaryChannels.put(RadioType.is5GHz, 200);
backupChannels.clear();
backupChannels.put(RadioType.is2dot4GHz, 20);
backupChannels.put(RadioType.is5GHz, 300);
channelsUpdateRequest = new EquipmentChannelsUpdateRequest();
channelsUpdateRequest.setEquipmentId(equipmentId);
channelsUpdateRequest.setPrimaryChannels(primaryChannels);
channelsUpdateRequest.setBackupChannels(backupChannels);
channelsUpdateRequest.setAutoChannelSelections(autoChannelSelections);
try {
Equipment equipmentUpdate2 = equipmentPortalController.updateEquipmentChannels(channelsUpdateRequest);
} catch (DsDataValidationException e) {
// pass
}
// Clean up after test
equipmentPortalController.deleteEquipment(equipmentId);
locationDatastore.delete(location.getId());
}
private void assertEqualEquipments(
Equipment expected,
Equipment actual) {
assertEquals(expected.getName(), actual.getName());
//TODO: add more fields to check here
}
}