WiP

Author: ignaciodob

packages/orb-sync-lib/src/database/postgres.ts

@@ -72,11 +72,8 @@ export class PostgresClient {
       ;`;
   };
 
-  async select<T>(sqlQuery: string, params?: Record<string, unknown>): Promise<T[]> {
-    const prepared = sql(sqlQuery, { useNullForMissing: true })(params || {});
-    const result = await this.pool.query(prepared.text, prepared.values);
-
-    return result.rows;
+  async query(text: string, params?: string[]): Promise<QueryResult> {
+    return this.pool.query(text, params);
   }
 
   /**

packages/orb-sync-lib/src/sync/invoices.ts

@@ -10,9 +10,11 @@ export async function syncInvoices(postgresClient: PostgresClient, invoices: Inv
   const invoiceIds = invoices.map((invoice) => invoice.id);
 
   // Fetch existing invoices from the database
-  const existingInvoices = (await postgresClient.select(
-    `SELECT id, last_synced_at FROM ${TABLE} WHERE id IN (${invoiceIds.join(',')})`
-  )) as { id: string; last_synced_at: string }[];
+  const existingInvoices = (
+    await postgresClient.query(
+      `SELECT id, last_synced_at FROM ${TABLE} WHERE id IN (${invoiceIds.join(',')})`
+    )
+  ).rows as { id: string; last_synced_at: string }[];
 
   // Filter out invoices that have been synced since the sync timestamp
   const invoicesToUpsert = invoices.filter((invoice) => {