TDL-19802: Add new streams talk_phone_numbers and ticket_metrics_event

tap_zendesk/schemas/talk_phone_numbers.json

@@ -0,0 +1,207 @@
+{
+  "type": [
+    "null",
+    "object"
+  ],
+  "properties": {
+    "capabilities": {
+      "type": [
+        "null",
+        "object"
+      ],
+      "properties": {
+        "sms": {
+          "type": [
+            "null",
+            "boolean"
+          ]
+        },
+        "mms": {
+          "type": [
+            "null",
+            "boolean"
+          ]
+        },
+        "voice": {
+          "type": [
+            "null",
+            "boolean"
+          ]
+        }
+      }
+    },
+    "categorised_greetings": {
+      "properties": { },
+      "type": [
+        "null",
+        "object"
+      ]
+    },
+    "categorised_greetings_with_sub_settings": {
+      "properties": { },
+      "type": [
+        "null",
+        "object"
+      ]
+    },
+    "country_code": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "created_at": {
+      "type": [
+        "null",
+        "string"
+      ],
+      "format": "date-time"
+    },
+    "default_greeting_ids": {
+      "type": ["null", "array"],
+      "items": {
+        "type": [
+          "null",
+          "string"
+        ]
+      }
+    },
+    "default_group_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "display_number": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "external": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "greeting_ids": {
+      "type": ["null", "array"],
+      "items": {
+        "type": [
+          "null",
+          "integer"
+        ]
+      }
+    },
+    "group_ids": {
+      "type": ["null", "array"],
+      "items": {
+        "type": [
+          "null",
+          "integer"
+        ]
+      }
+    },
+    "id": {
+      "type": [
+        "integer"
+      ]
+    },
+     "ivr_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "line_type": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "location": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "name": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "nickname": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "number": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "outbound_enabled": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "priority": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "recorded": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "schedule_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "sms_enabled": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "sms_group_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "token": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "toll_free": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "transcription": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    },
+    "voice_enabled": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    }
+  }
+}

tap_zendesk/schemas/ticket_metric_events.json

@@ -0,0 +1,115 @@
+{
+  "type": [
+    "null",
+    "object"
+  ],
+  "properties": {
+    "id": {
+      "type": [
+        "integer"
+      ]
+    },
+    "instance_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "metric": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "ticket_id": {
+      "type": [
+        "null",
+        "integer"
+      ]
+    },
+    "time": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "type": {
+      "type": [
+        "null",
+        "string"
+      ]
+    },
+    "sla": {
+      "type": [
+        "null",
+        "object"
+      ],
+      "properties": {
+        "target": {
+          "type": [
+            "null",
+            "integer"
+          ]
+        },
+        "business_hours": {
+          "type": [
+            "null",
+            "boolean"
+          ]
+        },
+        "policy": {
+          "type": [
+            "null",
+            "object"
+          ],
+          "properties": {
+            "id": {
+              "type": [
+                "null",
+                "integer"
+              ]
+            },
+            "title": {
+              "type": [
+                "null",
+                "string"
+              ]
+            },
+            "description": {
+              "type": [
+                "null",
+                "string"
+              ]
+            }
+          }
+        }
+      }
+    },
+    "status": {
+      "type": [
+        "null",
+        "object"
+      ],
+      "properties": {
+        "calendar": {
+          "type": [
+            "null",
+            "integer"
+          ]
+        },
+        "business": {
+          "type": [
+            "null",
+            "integer"
+          ]
+        }
+      }
+    },
+    "deleted": {
+      "type": [
+        "null",
+        "boolean"
+      ]
+    }
+  }
+}

tap_zendesk/streams.py

@@ -406,6 +406,34 @@ def check_access(self):
             #Skip 404 ZendeskNotFoundError error as goal is just to check whether TicketComments have read permission or not
             pass
 
+class TicketMetricEvents(Stream):
+    name = "ticket_metric_events"
+    replication_method = "INCREMENTAL"
+    replication_key = "time"
+    count = 0
+
+    def sync(self, state):
+        bookmark = self.get_bookmark(state)
+        start = bookmark - datetime.timedelta(seconds=1)
+
+        epoch_start = int(start.strftime('%s'))
+        parsed_start = singer.strftime(start, "%Y-%m-%dT%H:%M:%SZ")
+        ticket_metric_events = self.client.tickets.metrics_incremental(start_time=epoch_start)
+        for event in ticket_metric_events:
+            self.count += 1
+            if bookmark < utils.strptime_with_tz(event.time):
+                self.update_bookmark(state, event.time)
+            if parsed_start <= event.time:
+                yield (self.stream, event)
+
+    def check_access(self):
+        try:
+            epoch_start = int(utils.now().strftime('%s'))
+            self.client.tickets.metrics_incremental(start_time=epoch_start)
+        except http.ZendeskNotFoundError:
+            #Skip 404 ZendeskNotFoundError error as goal is just to check whether TicketComments have read permission or not
+            pass
+
 class TicketComments(Stream):
     name = "ticket_comments"
     replication_method = "INCREMENTAL"
@@ -440,6 +468,21 @@ def check_access(self):
             #Skip 404 ZendeskNotFoundError error as goal is to just check to whether TicketComments have read permission or not
             pass
 
+class TalkPhoneNumbers(Stream):
+    name = 'talk_phone_numbers'
+    replication_method = "FULL_TABLE"
+
+    def sync(self, state): # pylint: disable=unused-argument
+        for phone_number in self.client.talk.phone_numbers():
+            yield (self.stream, phone_number)
+
+    def check_access(self):
+        try:
+            self.client.talk.phone_numbers()
+        except http.ZendeskNotFoundError:
+            #Skip 404 ZendeskNotFoundError error as goal is to just check to whether TicketComments have read permission or not
+            pass
+
 class SatisfactionRatings(CursorBasedStream):
     name = "satisfaction_ratings"
     replication_method = "INCREMENTAL"
@@ -608,5 +651,7 @@ def check_access(self):
     "satisfaction_ratings": SatisfactionRatings,
     "tags": Tags,
     "ticket_metrics": TicketMetrics,
+    "ticket_metric_events": TicketMetricEvents,
     "sla_policies": SLAPolicies,
+    "talk_phone_numbers": TalkPhoneNumbers,
 }