Add Pagerduty source and destination

sources/pagerduty-source/acceptance-test-config.yml

@@ -1,25 +1,25 @@
 connector_image: pagerduty-source
 tests:
   spec:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
       spec_path: "test_files/spec.json"
   connection:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
       status: "succeed"
     - config_path: "test_files/invalid_config.json"
       status: "failed"
   discovery:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
   basic_read:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
       configured_catalog_path: "test_files/full_configured_catalog.json"
       expect_records:
         path: "test_files/expected_records.txt"
   full_refresh:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
       configured_catalog_path: "test_files/full_configured_catalog.json"
   incremental:
-    - config_path: "test_files/config.json"
+    - config_path: "secrets/config.json"
       configured_catalog_path: "test_files/incremental_configured_catalog.json"
       future_state_path: "test_files/abnormal_state.json"
       cursor_paths:

sources/pagerduty-source/src/streams/incidentLogEntries.ts

@@ -32,7 +32,7 @@ export class IncidentLogEntries extends AirbyteStreamBase {
   get cursorField(): string | string[] {
     return 'created_at';
   }
-  
+
   async *readRecords(
     syncMode: SyncMode,
     cursorField?: string[],
@@ -67,7 +67,7 @@ export class IncidentLogEntries extends AirbyteStreamBase {
     currentStreamState: IncidentLogEntryState,
     latestRecord: LogEntry
   ): IncidentLogEntryState {
-    const currentState = new Date(currentStreamState.lastSynced);
+    const currentState = new Date(currentStreamState.lastSynced ?? 0);
     const lastState = new Date(latestRecord.created_at);
     return {
       lastSynced:

sources/pagerduty-source/src/streams/incidents.ts

@@ -60,7 +60,7 @@ export class Incidents extends AirbyteStreamBase {
     currentStreamState: IncidentState,
     latestRecord: Incident
   ): IncidentState {
-    const currentState = new Date(currentStreamState.lastSynced);
+    const currentState = new Date(currentStreamState.lastSynced ?? 0);
     const lastState = new Date(latestRecord.created_at);
     return {
       lastSynced:

sources/pagerduty-source/test_files/abnormal_state.json

@@ -1,8 +1,8 @@
 {
   "incidents": {
-    "lastSynced": "2021-10-29T05:52:30Z"
+    "lastSynced": "2200-10-29T05:52:30Z"
   },
   "incident_log_entries": {
-    "lastSynced": "2021-10-29T05:52:30Z"
+    "lastSynced": "2200-10-29T05:52:30Z"
   }
 }