keep lastSyncTimestamp and retentionPeriodDays separate

connectors/src/connectors/gong/temporal/activities.ts

@@ -99,7 +99,7 @@ export async function gongSyncTranscriptsActivity({
   let pageCursor = null;
   do {
     const { transcripts, nextPageCursor } = await gongClient.getTranscripts({
-      startTimestamp: configuration.lastSyncTimestamp,
+      startTimestamp: configuration.getSyncStartTimestamp(),
       pageCursor,
     });
     const callsMetadata = await getTranscriptsMetadata({

connectors/src/resources/gong_resources.ts

@@ -87,23 +87,37 @@ export class GongConfigurationResource extends BaseResource<GongConfigurationMod
 
   async resetLastSyncTimestamp(): Promise<void> {
     await this.update({
-      lastSyncTimestamp: this.retentionPeriodDays
-        ? Date.now() - this.retentionPeriodDays * 24 * 60 * 60 * 1000
-        : null,
+      lastSyncTimestamp: null,
     });
   }
 
   async setLastSyncTimestamp(timestamp: number): Promise<void> {
     await this.update({
-      // Can't set a timestamp older than what is enforced by the retention period.
-      lastSyncTimestamp: this.retentionPeriodDays
-        ? Math.max(
-            timestamp,
-            Date.now() - this.retentionPeriodDays * 24 * 60 * 60 * 1000
-          )
-        : timestamp,
+      lastSyncTimestamp: timestamp,
     });
   }
+
+  async setRetentionPeriodDays(
+    retentionPeriodDays: number | null
+  ): Promise<void> {
+    await this.update({
+      retentionPeriodDays,
+    });
+  }
+
+  // Returns the timestamp to start syncing from.
+  getSyncStartTimestamp() {
+    if (!this.retentionPeriodDays) {
+      return this.lastSyncTimestamp;
+    }
+    if (!this.lastSyncTimestamp) {
+      return Date.now() - this.retentionPeriodDays * 24 * 60 * 60 * 1000;
+    }
+    return Math.max(
+      this.lastSyncTimestamp,
+      Date.now() - this.retentionPeriodDays * 24 * 60 * 60 * 1000
+    );
+  }
 }
 
 export type GongUserBlob = Omit<