Merge pull request #101 from intersystems-community/event-process

Event process
intersystems-community · Aug 9, 2023 · d6aa65c · d6aa65c
2 parents aa019eb + f98cd59
commit d6aa65c
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 3 deletions.
diff --git a/src/cls/ZPM/Analytics/AbstractEventProcessor.cls b/src/cls/ZPM/Analytics/AbstractEventProcessor.cls
@@ -0,0 +1,8 @@
+Class ZPM.Analytics.AbstractEventProcessor [ Abstract ]
+{
+
+ClassMethod Process(event) As %Status [ Abstract ]
+{
+}
+
+}
diff --git a/src/cls/ZPM/Analytics/Event.cls b/src/cls/ZPM/Analytics/Event.cls
@@ -3,7 +3,7 @@ Class ZPM.Analytics.Event Extends (%Persistent, %JSON.Adaptor)
 
 Parameter DSTIME = "AUTO";
 
-/// Server date and time, saving the data 
+/// Server date and time, saving the data
 Property TS As %PosixTime(%JSONINCLUDE = "none") [ SqlComputeCode = {set {*}=##class(%Library.PosixTime).CurrentTimeStamp()}, SqlComputed, SqlComputeOnChange = %%INSERT ];
 
 /// Event type: download, install, uninstall
@@ -48,8 +48,10 @@ ClassMethod SaveEvent(action As %String, ip As %String = "", json As %DynamicObj
         Set event.IP = ip
         Do event.%JSONImport(json)
         $$$ThrowOnError(event.%Save())
-        If ##class(%Dictionary.CompiledClass).%ExistsId("ZPM.Analytics.IP") {
-            Do ##class(ZPM.Analytics.IP).SetGeo(event, ip)
+        // get all ZPM.Analytics.AbstractEventProcessor subclasses
+        set rs = ##class(%Dictionary.ClassDefinitionQuery).SubclassOfFunc("ZPM.Analytics.AbstractEventProcessor")
+        while (rs.%Next()) {
+            do $classmethod(rs.%GetData(1), "Process", event)
         }
         $$$ThrowOnError(event.%Save())
         Return $$$OK