Fem 2293

Sources/OTT/Analytics/BaseOTTAnalyticsPlugin.swift

@@ -195,6 +195,10 @@ public class BaseOTTAnalyticsPlugin: BasePlugin, OTTAnalyticsPluginProtocol, App
     func reportConcurrencyEvent() {
         self.messageBus?.post(OttEvent.Concurrency())
     }
+
+    func reportBookmarkErrorEvent(code: String?, message: String?) {
+        self.messageBus?.post(OttEvent.BookmarkError(code: code, message: message))
+    }
 }
 
 /************************************************************/

Sources/OTT/Analytics/OTTEvent.swift

@@ -14,12 +14,13 @@ import PlayKit
 /// OTT Event
 public class OttEvent : PKEvent {
 
+    static let codeKey = "code"
+    static let messageKey = "message"
+
     class Concurrency : OttEvent {}
     /// represents the Concurrency event Type.
     /// Concurrency events fire when more then the allowed connections are exceeded.
-    public static let concurrency: OttEvent.Type = Concurrency.self
-
-    static let messageKey = "message"
+    public static let concurrency: OttEvent.Type = OttEvent.Concurrency.self
 
     class Report: OttEvent {
         convenience init(message: String) {
@@ -28,6 +29,14 @@ public class OttEvent : PKEvent {
     }
 
     @objc public static let report: OttEvent.Type = OttEvent.Report.self
+
+    class BookmarkError : OttEvent {
+        convenience init(code: String?, message: String?) {
+            self.init([OttEvent.codeKey: code ?? "", OttEvent.messageKey: message ?? ""])
+        }
+    }
+
+    @objc public static let bookmarkError: OttEvent.Type = OttEvent.BookmarkError.self
 }
 
 extension PKEvent {

Sources/OTT/Analytics/Phoenix/PhoenixAnalyticsPlugin.swift

@@ -77,9 +77,14 @@ public class PhoenixAnalyticsPlugin: BaseOTTAnalyticsPlugin {
                 PKLog.verbose("\(String(describing: response.data))")
                 guard let data = response.data as? [String: Any] else { return }
                 guard let result = data["result"] as? [String: Any] else { return }
-                guard let errorData = result["error"] as? [String: Any] else { return }
-                guard let errorCode = errorData["code"] as? Int, errorCode == 4001 else { return }
-                self.reportConcurrencyEvent()
+                guard let ottError = OTTError(json: result) else { return }
+
+                switch ottError.code {
+                case "4001":
+                    self.reportConcurrencyEvent()
+                default:
+                    self.reportBookmarkErrorEvent(code: ottError.code, message: ottError.message)
+                }
             }
         }
 

Sources/OTT/Model/OTTError.swift

@@ -15,16 +15,19 @@ class OTTError: OTTBaseObject {
 
     var message: String?
     var code: String?
+    var objectType: String?
 
     let errorKey = "error"
     let messageKey = "message"
     let codeKey = "code"
+    let objectTypeKey = "objectType"
 
     required init?(json: Any) {
 
         let jsonObj: JSON = JSON(json)
         let errorDict = jsonObj[errorKey]
         self.message = errorDict[messageKey].string
         self.code = errorDict[codeKey].string
+        self.objectType = errorDict[objectTypeKey].string
     }
 }