misc context | cache fixes (#1641)

lolopinto · Sep 7, 2023 · 13e2c7b · 13e2c7b
1 parent df2d00c
commit 13e2c7b
Show file tree

Hide file tree

Showing 14 changed files with 289 additions and 256 deletions.
diff --git a/ts/src/action/operations.ts b/ts/src/action/operations.ts
@@ -516,7 +516,7 @@ export class EdgeOperation implements DataOperation {
   ): Promise<void> {
     const params = this.getDeleteRowParams(edgeData, edge, context);
     if (params.op === SQLStatementOperation.Delete) {
-      return deleteRows(q, params.options, params.clause);
+      return deleteRows(q, { ...params.options, context }, params.clause);
     } else {
       if (params.op !== SQLStatementOperation.Update) {
         throw new Error(`invalid operation ${params.op}`);
@@ -526,6 +526,7 @@ export class EdgeOperation implements DataOperation {
         whereClause: params.clause,
         fields: params.updateData!,
         fieldsToLog: params.updateData!,
+        context,
       });
     }
   }
@@ -538,7 +539,7 @@ export class EdgeOperation implements DataOperation {
   ): void {
     const params = this.getDeleteRowParams(edgeData, edge, context);
     if (params.op === SQLStatementOperation.Delete) {
-      return deleteRowsSync(q, params.options, params.clause);
+      return deleteRowsSync(q, { ...params.options, context }, params.clause);
     } else {
       if (params.op !== SQLStatementOperation.Update) {
         throw new Error(`invalid operation ${params.op}`);
@@ -547,6 +548,7 @@ export class EdgeOperation implements DataOperation {
         tableName: params.options.tableName,
         whereClause: params.clause,
         fields: params.updateData!,
+        context,
       });
     }
   }