fix: set bi-directional relationship on credentials and transaction

Author: will-break-it

packages/projection-typeorm/src/operators/storeTransactions.ts

@@ -1,5 +1,5 @@
 import { ChainSyncEventType } from '@cardano-sdk/core';
-import { TransactionEntity } from '../entity';
+import { CredentialEntity, TransactionEntity } from '../entity';
 import { WithTxCredentials } from './storeCredentials';
 import { typeormOperator } from './util';
 import { WithBlock } from '@cardano-sdk/projection';
@@ -17,14 +17,25 @@ export const storeTransactions = typeormOperator<WithTxCredentials>(async (evt)
   // produced txs will be automatically deleted via block cascade
   if (txs.length === 0 || eventType !== ChainSyncEventType.RollForward) return;
 
-  const transactionEntities = txs.map(
-    (tx): TransactionEntity => ({
+  const credentialEntities = new Set<CredentialEntity>();
+  const transactionEntities = new Array<TransactionEntity>();
+  for (const tx of txs) {
+    const credentials = credentialsByTx[tx.id] || [];
+    const txEntity: TransactionEntity = {
       block: header,
       cbor: tx.cbor,
-      credentials: credentialsByTx[tx.id] || [],
+      credentials,
       txId: tx.id
-    })
-  );
+    };
+    transactionEntities.push(txEntity);
+    credentials.forEach((credential) => {
+      if (!credential.transactions) {
+        credential.transactions = [];
+      }
+      credential.transactions.push(txEntity);
+      credentialEntities.add(credential); // Collect credentials to be re-saved
+    });
+  }
 
   await queryRunner.manager
     .createQueryBuilder()
@@ -33,4 +44,7 @@ export const storeTransactions = typeormOperator<WithTxCredentials>(async (evt)
     .values(transactionEntities)
     .orIgnore()
     .execute();
+    
+  // Re-save credential entities to ensure relationships are persisted
+  await queryRunner.manager.save(Array.from(credentialEntities));
 });