feat(3322-tigerbeetle): bump tb from 0.15.4 to 0.16.29 (#3323)

* feat(3322): bump tb from 0.15.4 to 0.16.29 * feat(3322): fix issue related to post vs void. * feat(3322): formatting. * feat(3322): remove comment.
interledger · Mar 5, 2025 · 286f146 · 286f146
1 parent cef0726
commit 286f146
Show file tree

Hide file tree

Showing 8 changed files with 66 additions and 58 deletions.
diff --git a/infrastructure/helm/tigerbeetle/values.yaml b/infrastructure/helm/tigerbeetle/values.yaml
@@ -26,7 +26,7 @@ statefulset:
     repository: ghcr.io/tigerbeetle/tigerbeetle
     pullPolicy: IfNotPresent
     # Overrides the image tag whose default is the chart appVersion.
-    tag: "0.15.4"
+    tag: "0.16.29"
 
   proxyImage:
     repository: nginx

diff --git a/localenv/tigerbeetle/docker-compose.yml b/localenv/tigerbeetle/docker-compose.yml
@@ -1,6 +1,6 @@
 services:
   tigerbeetle:
-    image: ghcr.io/tigerbeetle/tigerbeetle:0.15.4
+    image: ghcr.io/tigerbeetle/tigerbeetle:0.16.29
     privileged: true
     volumes:
       - tigerbeetle-data:/var/lib/tigerbeetle

diff --git a/packages/backend/package.json b/packages/backend/package.json
@@ -96,7 +96,7 @@
     "pg": "^8.11.3",
     "pino": "^8.19.0",
     "raw-body": "^2.5.2",
-    "tigerbeetle-node": "0.15.4",
+    "tigerbeetle-node": "0.16.29",
     "token-introspection": "workspace:*",
     "uuid": "^9.0.1"
   }

diff --git a/packages/backend/src/accounting/tigerbeetle/service.test.ts b/packages/backend/src/accounting/tigerbeetle/service.test.ts
@@ -472,7 +472,7 @@ describe('TigerBeetle Accounting Service', (): void => {
           } else {
             await expect(
               accountingService.getBalance(sourceAccount.asset.id)
-            ).resolves.toEqual(BigInt(0))
+            ).resolves.toEqual(0n)
 
             await expect(
               accountingService.getBalance(destinationAccount.asset.id)
@@ -481,7 +481,7 @@ describe('TigerBeetle Accounting Service', (): void => {
 
           await expect(
             accountingService.getBalance(destinationAccount.id)
-          ).resolves.toEqual(BigInt(0))
+          ).resolves.toEqual(0n)
 
           if (post) {
             await expect(trxOrError.post()).resolves.toBeUndefined()

diff --git a/packages/backend/src/accounting/tigerbeetle/transfers.ts b/packages/backend/src/accounting/tigerbeetle/transfers.ts
@@ -20,6 +20,9 @@ type TransfersError = {
 
 export type TransferUserData128 = string | number | bigint
 
+const TB_AMOUNT_MAX = BigInt(2n ** 128n - 1n)
+const TB_AMOUNT_MIN = 0n
+
 interface TransferOptions {
   transferRef?: TransferUserData128
   code?: TigerBeetleTransferCode
@@ -103,9 +106,15 @@ export async function createTransfers(
       if (transfer.postId) {
         tbTransfer.flags |= TransferFlags.post_pending_transfer
         tbTransfer.pending_id = toTigerBeetleId(transfer.postId)
+        // We only support setting the posting transfer amount to match the pending transfer:
+        // https://docs.tigerbeetle.com/reference/transfer/#amount
+        tbTransfer.amount = TB_AMOUNT_MAX
       } else if (transfer.voidId) {
         tbTransfer.flags |= TransferFlags.void_pending_transfer
         tbTransfer.pending_id = toTigerBeetleId(transfer.voidId)
+        // We only support setting the void transfer amount to match the pending transfer:
+        // https://docs.tigerbeetle.com/reference/transfer/#amount
+        tbTransfer.amount = TB_AMOUNT_MIN
       }
     }
 
@@ -178,7 +187,11 @@ export async function getAccountTransfers(
     timestamp_min: 0n,
     timestamp_max: 0n,
     limit,
-    flags: AccountFilterFlags.credits | AccountFilterFlags.debits
+    flags: AccountFilterFlags.credits | AccountFilterFlags.debits,
+    code: 0, //disabled
+    user_data_32: 0, //disabled
+    user_data_64: 0n, //disabled
+    user_data_128: 0n //disabled
   }
   const tbAccountTransfers: TbTransfer[] =
     await deps.tigerBeetle.getAccountTransfers(filter)

diff --git a/packages/backend/src/tests/tigerbeetle.ts b/packages/backend/src/tests/tigerbeetle.ts
@@ -15,7 +15,7 @@ export async function startTigerBeetleContainer(clusterId?: number): Promise<{
   const tigerBeetleClusterId = clusterId || Config.tigerBeetleClusterId
   const { name: tigerBeetleDir } = tmp.dirSync({ unsafeCleanup: true })
   const tigerBeetleFile = `cluster_${tigerBeetleClusterId}_replica_0_test.tigerbeetle`
-  const tigerBeetleContainerVersion = 'ghcr.io/tigerbeetle/tigerbeetle:0.15.4'
+  const tigerBeetleContainerVersion = 'ghcr.io/tigerbeetle/tigerbeetle:0.16.29'
 
   const tbContFormat = await new GenericContainer(tigerBeetleContainerVersion)
     .withExposedPorts(TIGERBEETLE_PORT)

diff --git a/packages/documentation/src/content/docs/integration/deployment/docker-compose.mdx b/packages/documentation/src/content/docs/integration/deployment/docker-compose.mdx
@@ -189,7 +189,7 @@ services:
       - '3005:3005'
 
   tigerbeetle:
-    image: ghcr.io/tigerbeetle/tigerbeetle:0.15.4
+    image: ghcr.io/tigerbeetle/tigerbeetle:0.16.29
     privileged: true
     volumes:
       - tigerbeetle-data:/var/lib/tigerbeetle