diff --git a/.github/workflows/test.yaml b/.github/workflows/test.yaml index 237d73b9..c03f2526 100644 --- a/.github/workflows/test.yaml +++ b/.github/workflows/test.yaml @@ -32,15 +32,15 @@ jobs: steps: - name: Checkout Code - uses: actions/checkout@v3 + uses: actions/checkout@v4 - name: Install PNPM - uses: pnpm/action-setup@v3 + uses: pnpm/action-setup@v4 with: - version: 8 + version: 9 - name: Use Node.js - uses: actions/setup-node@v3 + uses: actions/setup-node@v4 with: node-version: "21" cache: "pnpm" diff --git a/test/services/transaction.test.ts b/test/services/transaction.test.ts index 2995a949..6dcc4423 100644 --- a/test/services/transaction.test.ts +++ b/test/services/transaction.test.ts @@ -124,11 +124,14 @@ describe('transactionProcessor', () => { }, }; - transactionProcessor.enqueueTransaction(transactionRequest); - const count = await transactionProcessor['queue'].getJobCounts(); - const job = await transactionProcessor['queue'].getJob(transactionRequest.txid); - expect(count.delayed).toBe(1); - expect(job?.delay).toBe(cradle.env.TRANSACTION_QUEUE_JOB_DELAY); + await transactionProcessor.enqueueTransaction(transactionRequest); + const jobs = await transactionProcessor['queue'].getJobs('delayed'); + const jobFromApi = await transactionProcessor['queue'].getJob(transactionRequest.txid); + const jobFromList = jobs.find((row) => row.id === transactionRequest.txid); + + expect(jobFromApi).toBeDefined(); + expect(jobFromApi!.id).toStrictEqual(jobFromList?.id); + expect(jobFromApi!.delay).toBe(cradle.env.TRANSACTION_QUEUE_JOB_DELAY); }); test('retryMissingTransactions: should be retry transaction job when missing', async () => {