feat(sync-engine): add close() method to release database connections (#230)

Author: cescox

docs/typescript.md

@@ -139,3 +139,11 @@ await sync.syncBackfill({
 
 > **Note:**
 > For large Stripe accounts (more than 10,000 objects), it is recommended to write a script that loops through each day and sets the `created` date filters to the start and end of day. This avoids timeouts and memory issues when syncing large datasets.
+
+## Cleanup
+
+Call `close()` to release database connections when shutting down:
+
+```ts
+await sync.close()
+```

packages/sync-engine/src/database/postgres.ts

@@ -229,4 +229,8 @@ export class PostgresClient {
     })
     return cleansed
   }
+
+  async close(): Promise<void> {
+    await this.pool.end()
+  }
 }

packages/sync-engine/src/stripeSync.ts

@@ -1710,6 +1710,10 @@ export class StripeSync {
 
     return entities
   }
+
+  async close(): Promise<void> {
+    await this.postgresClient.close()
+  }
 }
 
 function chunkArray<T>(array: T[], chunkSize: number): T[][] {