Skip to content

Commit 2574b1e

Browse files
authored
fix: handle filters missing from CS job data (#580)
1 parent 1034949 commit 2574b1e

File tree

2 files changed

+12
-4
lines changed

2 files changed

+12
-4
lines changed

src/worker/tasks/processEventLogsWorker.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,12 @@ import { logWorkerEvents } from "../queues/queues";
3030
import { enqueueWebhook } from "../queues/sendWebhookQueue";
3131

3232
const handler: Processor<any, void, string> = async (job: Job<string>) => {
33-
const { chainId, filters, fromBlock, toBlock } =
34-
superjson.parse<EnqueueProcessEventLogsData>(job.data);
33+
const {
34+
chainId,
35+
filters = [],
36+
fromBlock,
37+
toBlock,
38+
} = superjson.parse<EnqueueProcessEventLogsData>(job.data);
3539

3640
const logs = await getLogs({
3741
chainId,

src/worker/tasks/processTransactionReceiptsWorker.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,12 @@ import { getContractId } from "../utils/contractId";
2828
import { getWebhooksByContractAddresses } from "./processEventLogsWorker";
2929

3030
const handler: Processor<any, void, string> = async (job: Job<string>) => {
31-
const { chainId, filters, fromBlock, toBlock } =
32-
superjson.parse<EnqueueProcessTransactionReceiptsData>(job.data);
31+
const {
32+
chainId,
33+
filters = [],
34+
fromBlock,
35+
toBlock,
36+
} = superjson.parse<EnqueueProcessTransactionReceiptsData>(job.data);
3337

3438
const receipts = await getFormattedTransactionReceipts({
3539
chainId,

0 commit comments

Comments
 (0)