mirror of
				https://github.com/Telecominfraproject/wlan-cloud-opensync-controller.git
				synced 2025-11-03 20:17:53 +00:00 
			
		
		
		
	Compare commits
	
		
			1 Commits
		
	
	
		
			WIFI-3358
			...
			change_ses
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 
						 | 
					49d59dcd15 | 
@@ -1610,8 +1610,8 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
 | 
			
		||||
                clientSession.setMacAddress(clientInstance.getMacAddress());
 | 
			
		||||
                clientSession.setLocationId(ce.getLocationId());
 | 
			
		||||
                clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
                clientSession.getDetails().setSessionId(clientInstance.getMacAddress().getAddressAsLong());
 | 
			
		||||
                clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(clientInstance.getMacAddress().getAddressAsLong()));
 | 
			
		||||
                clientSession.getDetails().setSessionId(Long.toUnsignedString(clientInstance.getMacAddress().getAddressAsLong()));
 | 
			
		||||
                clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString(clientInstance.getMacAddress().getAddressAsLong())));
 | 
			
		||||
                clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
                clientSession.getDetails().setAssociationState(AssociationState._802_11_Associated);
 | 
			
		||||
                clientSession.getDetails().setAssocTimestamp(timestamp);
 | 
			
		||||
 
 | 
			
		||||
@@ -23,6 +23,7 @@ import org.springframework.beans.factory.annotation.Value;
 | 
			
		||||
import org.springframework.scheduling.annotation.Async;
 | 
			
		||||
import org.springframework.stereotype.Component;
 | 
			
		||||
 | 
			
		||||
import com.google.common.base.Objects;
 | 
			
		||||
import com.google.protobuf.ByteString;
 | 
			
		||||
import com.telecominfraproject.wlan.alarm.AlarmServiceInterface;
 | 
			
		||||
import com.telecominfraproject.wlan.alarm.models.Alarm;
 | 
			
		||||
@@ -338,20 +339,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        clientSession.getDetails().setRadioType(OvsdbToWlanCloudTypeMappingUtility.getRadioTypeFromOpensyncStatsRadioBandType(apClientEvent.getBand()));
 | 
			
		||||
        clientSession.getDetails().setSsid(apClientEvent.getSsid());
 | 
			
		||||
 | 
			
		||||
@@ -462,20 +463,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        clientSession.getDetails().setRadioType(OvsdbToWlanCloudTypeMappingUtility.getRadioTypeFromOpensyncStatsRadioBandType(apClientEvent.getBand()));
 | 
			
		||||
        clientSession.getDetails().setSsid(apClientEvent.getSsid());
 | 
			
		||||
        if (apClientEvent.hasDevType()) {
 | 
			
		||||
@@ -541,20 +542,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        clientSession.getDetails().setRadioType(OvsdbToWlanCloudTypeMappingUtility.getRadioTypeFromOpensyncStatsRadioBandType(apClientEvent.getBand()));
 | 
			
		||||
        clientSession.getDetails().setSsid(apClientEvent.getSsid());
 | 
			
		||||
        if (apClientEvent.hasAuthStatus()) {
 | 
			
		||||
@@ -592,20 +593,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        clientSession.getDetails().setRadioType(OvsdbToWlanCloudTypeMappingUtility.getRadioTypeFromOpensyncStatsRadioBandType(apClientEvent.getBand()));
 | 
			
		||||
        clientSession.getDetails().setSsid(apClientEvent.getSsid());
 | 
			
		||||
        if (apClientEvent.hasStatus()) {
 | 
			
		||||
@@ -657,20 +658,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        clientSession.getDetails().setSsid(apClientEvent.getSsid());
 | 
			
		||||
 | 
			
		||||
        ClientFailureDetails clientFailureDetails = new ClientFailureDetails();
 | 
			
		||||
@@ -705,20 +706,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
 | 
			
		||||
        if (apClientEvent.hasFdataRxUpTsInUs()) {
 | 
			
		||||
            clientSession.getDetails().setFirstDataRcvdTimestamp(apClientEvent.getFdataRxUpTsInUs());
 | 
			
		||||
@@ -757,20 +758,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getCltMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        if (apClientEvent.hasCltId()) {
 | 
			
		||||
            clientSession.getDetails().setHostname(apClientEvent.getCltId());
 | 
			
		||||
        }
 | 
			
		||||
@@ -799,20 +800,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        if (apClientEvent.hasIpAddr()) {
 | 
			
		||||
            ByteString ipAddress = apClientEvent.getIpAddr();
 | 
			
		||||
            if (ipAddress != null) {
 | 
			
		||||
@@ -856,20 +857,20 @@ public class MqttStatsPublisher implements StatsPublisherInterface {
 | 
			
		||||
            clientSession.setMacAddress(MacAddress.valueOf(apClientEvent.getStaMac()));
 | 
			
		||||
            clientSession.setLocationId(locationId);
 | 
			
		||||
            clientSession.setDetails(new ClientSessionDetails());
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(apEventClientSession.getSessionId()));
 | 
			
		||||
            clientSession.getDetails().setDhcpDetails(new ClientDhcpDetails(Long.toUnsignedString( apEventClientSession.getSessionId())));
 | 
			
		||||
            clientSession.getDetails().setMetricDetails(new ClientSessionMetricDetails());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorEquipmentId() == null) {
 | 
			
		||||
            clientSession.getDetails().setPriorEquipmentId(clientSession.getEquipmentId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getPriorSessionId() == null) {
 | 
			
		||||
            if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId())
 | 
			
		||||
            if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId())))
 | 
			
		||||
                clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        if (clientSession.getDetails().getSessionId() != apEventClientSession.getSessionId()) {
 | 
			
		||||
        if (! Objects.equal( clientSession.getDetails().getSessionId(), Long.toUnsignedString( apEventClientSession.getSessionId()))) {
 | 
			
		||||
            clientSession.getDetails().setPriorSessionId(clientSession.getDetails().getSessionId());
 | 
			
		||||
        }
 | 
			
		||||
        clientSession.getDetails().setSessionId(apEventClientSession.getSessionId());
 | 
			
		||||
        clientSession.getDetails().setSessionId(Long.toUnsignedString( apEventClientSession.getSessionId()));
 | 
			
		||||
        if (apClientEvent.hasLastRcvUpTsInUs()) {
 | 
			
		||||
            clientSession.getDetails().setLastRxTimestamp(apClientEvent.getLastRcvUpTsInUs());
 | 
			
		||||
        }
 | 
			
		||||
 
 | 
			
		||||
@@ -190,7 +190,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        clientEvent.setRadioType(OvsdbToWlanCloudTypeMappingUtility
 | 
			
		||||
                .getRadioTypeFromOpensyncStatsRadioBandType(clientConnectEvent.getBand()));
 | 
			
		||||
        clientEvent.setSsid(clientConnectEvent.getSsid());
 | 
			
		||||
        clientEvent.setSessionId(clientConnectEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientConnectEvent.getSessionId()));
 | 
			
		||||
 | 
			
		||||
        if (clientConnectEvent.hasFbtUsed()) {
 | 
			
		||||
            clientEvent.setFbtUsed(clientConnectEvent.getFbtUsed());
 | 
			
		||||
@@ -278,7 +278,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientDisconnectEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientDisconnectEvent(
 | 
			
		||||
                clientDisconnectEvent.getTimestampMs());
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientDisconnectEvent.getStaMac()));
 | 
			
		||||
        clientEvent.setSessionId(clientDisconnectEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientDisconnectEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setRadioType(OvsdbToWlanCloudTypeMappingUtility
 | 
			
		||||
                .getRadioTypeFromOpensyncStatsRadioBandType(clientDisconnectEvent.getBand()));
 | 
			
		||||
        clientEvent.setSsid(clientDisconnectEvent.getSsid());
 | 
			
		||||
@@ -326,7 +326,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientAuthEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientAuthEvent(
 | 
			
		||||
                clientAuthEvent.getTimestampMs());
 | 
			
		||||
        clientEvent.setSessionId(clientAuthEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientAuthEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setSsid(clientAuthEvent.getSsid());
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientAuthEvent.getStaMac()));
 | 
			
		||||
        clientEvent.setRadioType(OvsdbToWlanCloudTypeMappingUtility
 | 
			
		||||
@@ -352,7 +352,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientAssocEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientAssocEvent(
 | 
			
		||||
                clientAssocEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientAssocEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientAssocEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setSsid(clientAssocEvent.getSsid());
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientAssocEvent.getStaMac()));
 | 
			
		||||
        clientEvent.setRadioType(OvsdbToWlanCloudTypeMappingUtility
 | 
			
		||||
@@ -403,7 +403,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientFailureEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientFailureEvent(
 | 
			
		||||
                clientFailureEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientFailureEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientFailureEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientFailureEvent.getStaMac()));
 | 
			
		||||
        clientEvent.setSsid(clientFailureEvent.getSsid());
 | 
			
		||||
 | 
			
		||||
@@ -430,7 +430,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientFirstDataEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientFirstDataEvent(
 | 
			
		||||
                clientFirstDataEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientFirstDataEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientFirstDataEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientFirstDataEvent.getStaMac()));
 | 
			
		||||
 | 
			
		||||
        if (clientFirstDataEvent.hasFdataTxUpTsInUs()) {
 | 
			
		||||
@@ -457,7 +457,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientIdEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientIdEvent(
 | 
			
		||||
                clientIdEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientIdEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientIdEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientIdEvent.getCltMac()));
 | 
			
		||||
        if (clientIdEvent.hasCltId()) {
 | 
			
		||||
            clientEvent.setUserId(clientIdEvent.getCltId());
 | 
			
		||||
@@ -478,7 +478,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientIpAddressEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientIpAddressEvent(
 | 
			
		||||
                clientIpEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientIpEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientIpEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientIpEvent.getStaMac()));
 | 
			
		||||
        if (clientIpEvent.hasIpAddr()) {
 | 
			
		||||
            try {
 | 
			
		||||
@@ -505,7 +505,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
        com.telecominfraproject.wlan.client.models.events.realtime.ClientTimeoutEvent clientEvent = new com.telecominfraproject.wlan.client.models.events.realtime.ClientTimeoutEvent(
 | 
			
		||||
                clientTimeoutEvent.getTimestampMs());
 | 
			
		||||
 | 
			
		||||
        clientEvent.setSessionId(clientTimeoutEvent.getSessionId());
 | 
			
		||||
        clientEvent.setSessionId(Long.toUnsignedString( clientTimeoutEvent.getSessionId()));
 | 
			
		||||
        clientEvent.setClientMacAddress(MacAddress.valueOf(clientTimeoutEvent.getStaMac()));
 | 
			
		||||
        if (clientTimeoutEvent.hasRCode()) {
 | 
			
		||||
            clientEvent.setTimeoutReason(clientTimeoutEvent.getRCode().equals(CTReasonType.CTR_IDLE_TOO_LONG)
 | 
			
		||||
@@ -861,7 +861,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            cloudSipCallReportEvent.setEventType(RealTimeEventType.SipCallReport);
 | 
			
		||||
 | 
			
		||||
            cloudSipCallReportEvent.setSipCallId(callReport.getWifiSessionId());
 | 
			
		||||
            cloudSipCallReportEvent.setAssociationId(callReport.getSessionId());
 | 
			
		||||
            cloudSipCallReportEvent.setAssociationId(Long.toUnsignedString( callReport.getSessionId()));
 | 
			
		||||
 | 
			
		||||
            if (callReport.hasReason()) {
 | 
			
		||||
                cloudSipCallReportEvent.setReportReason(getCallReportReason(callReport.getReason()));
 | 
			
		||||
@@ -927,11 +927,11 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apCallStart.hasSessionId()) {
 | 
			
		||||
                cloudSipCallStartEvent.setAssociationId(apCallStart.getSessionId());
 | 
			
		||||
                cloudSipCallStartEvent.setAssociationId(Long.toUnsignedString( apCallStart.getSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apCallStart.hasWifiSessionId()) {
 | 
			
		||||
                cloudSipCallStartEvent.setAssociationId(apCallStart.getWifiSessionId());
 | 
			
		||||
                cloudSipCallStartEvent.setAssociationId(Long.toUnsignedString( apCallStart.getWifiSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apCallStart.getCodecsCount() > 0) {
 | 
			
		||||
@@ -991,7 +991,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
 | 
			
		||||
            if (apCallStop.hasSessionId()) {
 | 
			
		||||
 | 
			
		||||
                cloudSipCallStopEvent.setAssociationId(apCallStop.getSessionId());
 | 
			
		||||
                cloudSipCallStopEvent.setAssociationId(Long.toUnsignedString(  apCallStop.getSessionId()));
 | 
			
		||||
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
@@ -1055,11 +1055,11 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoServer.hasSessionId()) {
 | 
			
		||||
                rtsStartEvent.setSessionId(apStreamVideoServer.getSessionId());
 | 
			
		||||
                rtsStartEvent.setSessionId(Long.toUnsignedString( apStreamVideoServer.getSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoServer.hasVideoSessionId()) {
 | 
			
		||||
                rtsStartEvent.setVideoSessionId(apStreamVideoServer.getVideoSessionId());
 | 
			
		||||
                rtsStartEvent.setVideoSessionId(Long.toUnsignedString(  apStreamVideoServer.getVideoSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            eventsList.add(rtsStartEvent);
 | 
			
		||||
@@ -1179,7 +1179,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoSessionStart.hasSessionId()) {
 | 
			
		||||
                rtsStartSessionEvent.setSessionId(apStreamVideoSessionStart.getSessionId());
 | 
			
		||||
                rtsStartSessionEvent.setSessionId(Long.toUnsignedString( apStreamVideoSessionStart.getSessionId()));
 | 
			
		||||
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
@@ -1190,7 +1190,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoSessionStart.hasVideoSessionId()) {
 | 
			
		||||
                rtsStartSessionEvent.setVideoSessionId(apStreamVideoSessionStart.getVideoSessionId());
 | 
			
		||||
                rtsStartSessionEvent.setVideoSessionId(Long.toUnsignedString( apStreamVideoSessionStart.getVideoSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
            eventsList.add(rtsStartSessionEvent);
 | 
			
		||||
        }
 | 
			
		||||
@@ -1220,7 +1220,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoStop.hasSessionId()) {
 | 
			
		||||
                rtsStopEvent.setSessionId(apStreamVideoStop.getSessionId());
 | 
			
		||||
                rtsStopEvent.setSessionId(Long.toUnsignedString( apStreamVideoStop.getSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoStop.hasStreamingVideoType()) {
 | 
			
		||||
@@ -1235,7 +1235,7 @@ public class RealtimeEventPublisher {
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (apStreamVideoStop.hasVideoSessionId()) {
 | 
			
		||||
                rtsStopEvent.setVideoSessionId(apStreamVideoStop.getVideoSessionId());
 | 
			
		||||
                rtsStopEvent.setVideoSessionId(Long.toUnsignedString(  apStreamVideoStop.getVideoSessionId()));
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            eventsList.add(rtsStopEvent);
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user