Fixed logs endpoint typing for scope

Matatika · Mar 23, 2022 · 3dafc2d · 3dafc2d
1 parent 2370969
commit 3dafc2d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/tap_auth0/schemas/log.py b/tap_auth0/schemas/log.py
@@ -1,4 +1,5 @@
 from singer_sdk.typing import (
+    ArrayType,
     BooleanType,
     DateTimeType,
     ObjectType,
@@ -47,7 +48,7 @@ class LogObject(CustomObject):
         Property("user_id", StringType),
         Property("user_name", StringType),
         Property("audience", StringType),
-        Property("scope", StringType),
+        Property("scope", ArrayType(StringType)),
         Property("strategy", StringType),
         Property("strategy_type", StringType),
         Property("log_id", StringType),

diff --git a/tap_auth0/streams.py b/tap_auth0/streams.py
@@ -169,3 +169,10 @@ def validate_response(self, response: requests.Response) -> None:
 
     def parse_response(self, response: requests.Response) -> Iterable[dict]:
         return [] if self.log_expired else super().parse_response(response)
+
+    def post_process(self, row: dict, context: Optional[dict] = None) -> Optional[dict]:
+        row = super().post_process(row, context)
+        scope = row.get("scope")
+        if isinstance(scope, str):
+            row.update({ "scope": scope.split() })
+        return row