[AMSDK-11201] - Differentiate XDM vs standard shared state via eventName (adobe#593)

Author: PravinPK

AEPCore/Sources/eventhub/EventHub.swift

@@ -180,7 +180,7 @@ final class EventHub {
             }
 
             sharedState.set(version: version, data: data)
-            self.dispatch(event: self.createSharedStateEvent(extensionName: extensionName))
+            self.dispatch(event: self.createSharedStateEvent(extensionName: extensionName, sharedStatetype: sharedStateType))
             Log.debug(label: self.LOG_TAG, "\(sharedStateType.rawValue.capitalized) shared state created for \(extensionName) with version \(version) and data: \n\(PrettyDictionary.prettify(data))")
         }
     }
@@ -284,7 +284,7 @@ final class EventHub {
 
         let version = sharedState.resolve(version: 0).value == nil ? 0 : eventNumberCounter.incrementAndGet()
         sharedState.set(version: version, data: data)
-        dispatch(event: createSharedStateEvent(extensionName: EventHubConstants.NAME))
+        dispatch(event: createSharedStateEvent(extensionName: EventHubConstants.NAME, sharedStatetype: .standard))
         Log.debug(label: LOG_TAG, "Shared state created for \(EventHubConstants.NAME) with version \(version) and data: \n\(PrettyDictionary.prettify(data))")
     }
 
@@ -328,14 +328,15 @@ final class EventHub {
         guard let pendingVersion = version, let container = registeredExtensions.first(where: { $1.sharedStateName.caseInsensitiveCompare(extensionName) == .orderedSame })?.value else { return }
         guard let sharedState = container.sharedState(for: sharedStateType) else { return }
         sharedState.updatePending(version: pendingVersion, data: data)
-        dispatch(event: createSharedStateEvent(extensionName: container.sharedStateName))
+        dispatch(event: createSharedStateEvent(extensionName: container.sharedStateName, sharedStatetype: sharedStateType))
     }
 
     /// Creates a template `Event` for `SharedState` of the provided `extensionName`
     /// - Parameter extensionName: A `String` containing the name of the extension
     /// - Returns: An empty `SharedState` `Event` for the provided `extensionName`
-    private func createSharedStateEvent(extensionName: String) -> Event {
-        return Event(name: EventHubConstants.STATE_CHANGE, type: EventType.hub, source: EventSource.sharedState,
+    private func createSharedStateEvent(extensionName: String, sharedStatetype: SharedStateType) -> Event {
+        let eventName = sharedStatetype == .standard ? EventHubConstants.STATE_CHANGE : EventHubConstants.XDM_STATE_CHANGE
+        return Event(name: eventName, type: EventType.hub, source: EventSource.sharedState,
                      data: [EventHubConstants.EventDataKeys.Configuration.EVENT_STATE_OWNER: extensionName])
     }
 

AEPCore/Sources/eventhub/EventHubConstants.swift

@@ -13,7 +13,8 @@ import Foundation
 
 /// Constant values used throughout `EventHub`
 enum EventHubConstants {
-    static let STATE_CHANGE = "STATE_CHANGE_EVENT"
+    static let STATE_CHANGE = "Shared state change"
+    static let XDM_STATE_CHANGE = "Shared state change (XDM)"
     static let NAME = "com.adobe.module.eventhub"
     static let FRIENDLY_NAME = "EventHub"
     static let VERSION_NUMBER = "3.1.0"

AEPCore/Tests/EventHubTests/EventHubTests.swift

@@ -1027,8 +1027,8 @@ class EventHubTests: XCTestCase {
 
         let event = Event(name: "test", type: EventType.acquisition, source: EventSource.requestContent, data: nil)
         eventHub.getExtensionContainer(MockExtension.self)?.registerListener(type: EventType.hub, source: EventSource.sharedState) { event in
-            XCTAssertEqual(event.name, EventHubConstants.STATE_CHANGE)
             if event.data?[EventHubConstants.EventDataKeys.Configuration.EVENT_STATE_OWNER] as! String == EventHubTests.MOCK_EXTENSION_NAME {
+                XCTAssertEqual(event.name, EventHubConstants.STATE_CHANGE)
                 expectation.fulfill()
             }
         }
@@ -1052,8 +1052,8 @@ class EventHubTests: XCTestCase {
 
         let event = Event(name: "test", type: EventType.acquisition, source: EventSource.requestContent, data: nil)
         eventHub.getExtensionContainer(MockExtension.self)?.registerListener(type: EventType.hub, source: EventSource.sharedState) { event in
-            XCTAssertEqual(event.name, EventHubConstants.STATE_CHANGE)
             if event.data?[EventHubConstants.EventDataKeys.Configuration.EVENT_STATE_OWNER] as! String == EventHubTests.MOCK_EXTENSION_NAME {
+                XCTAssertEqual(event.name, EventHubConstants.XDM_STATE_CHANGE)
                 expectation.fulfill()
             }
         }

AEPCore/Tests/FunctionalTests/EventHubContractTests.swift

@@ -124,7 +124,7 @@ class EventHubContractTest: XCTestCase {
         let sharedStateEventExpectation = XCTestExpectation(description: "Event Hub shared stated event is received")
         ContractExtensionOne.eventReceivedClosure = { event in
             switch event.name{
-            case "STATE_CHANGE_EVENT":
+            case "Shared state change":
                 sharedStateEventExpectation.fulfill()
             default:
                 XCTAssertFalse(true)
@@ -156,7 +156,7 @@ class EventHubContractTest: XCTestCase {
                 firstEventExpectation.fulfill()
             case "second":
                 secondEventExpectation.fulfill()
-            case "STATE_CHANGE_EVENT":
+            case "Shared state change":
                 sharedStateEventExpectation.fulfill()
             default:
                 XCTAssertFalse(true)