Sync customer id for accounting also (#261)

openintegrations · Feb 13, 2025 · dcb7506 · dcb7506
1 parent 8a8c94d
commit dcb7506
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/unified/unified-accounting/unifiedAccountingLink.ts b/unified/unified-accounting/unifiedAccountingLink.ts
@@ -18,6 +18,7 @@ export function unifiedAccountingLink(ctx: {
     id: Id['conn']
     connectorConfig: {connectorName: string}
     metadata?: unknown
+    customerId?: string | null
   }
 }): Link<AnyEntityPayload, PostgresInputPayload> {
   return Rx.mergeMap((op) => {
@@ -67,6 +68,9 @@ export function unifiedAccountingLink(ctx: {
         data: {
           ...mapped,
           connection_id: ctx.source.id, // Should this be the default somehow?
+          // Denormalize customer_id onto entities for now, though may be better
+          // to just sync connection also?
+          customer_id: ctx.source.customerId,
         },
         upsert: {
           key_columns: ['connection_id', 'id'],