rename

Author: arcoraven

src/db/contractSubscriptions/createContractSubscription.ts

@@ -4,27 +4,27 @@ interface CreateContractSubscriptionParams {
   chainId: number;
   contractAddress: string;
   webhookId?: number;
-  parseEventLogs: boolean;
-  filterEventLogs: string[];
-  parseTransactionReceipts: boolean;
+  processEventLogs: boolean;
+  filterEvents: string[];
+  processTransactionReceipts: boolean;
 }
 
 export const createContractSubscription = async ({
   chainId,
   contractAddress,
   webhookId,
-  parseEventLogs,
-  filterEventLogs,
-  parseTransactionReceipts,
+  processEventLogs,
+  filterEvents,
+  processTransactionReceipts,
 }: CreateContractSubscriptionParams) => {
   return prisma.contractSubscriptions.create({
     data: {
       chainId,
       contractAddress,
       webhookId,
-      parseEventLogs,
-      filterEventLogs,
-      parseTransactionReceipts,
+      processEventLogs,
+      filterEvents,
+      processTransactionReceipts,
     },
     include: {
       webhook: true,

src/server/routes/contract/subscriptions/addContractSubscription.ts

@@ -29,18 +29,18 @@ const bodySchema = Type.Object({
       examples: ["https://example.com/webhook"],
     }),
   ),
-  parseEventLogs: Type.Optional(
+  processEventLogs: Type.Optional(
     Type.Boolean({
       description: "If true, parse event logs for this contract.",
     }),
   ),
-  filterEventLogs: Type.Optional(
+  filterEvents: Type.Optional(
     Type.Array(Type.String(), {
       description:
         "A case-sensitive list of event log names to parse. If empty, parse all event logs.",
     }),
   ),
-  parseTransactionReceipts: Type.Optional(
+  processTransactionReceipts: Type.Optional(
     Type.Boolean({
       description: "If true, parse transaction receipts for this contract.",
     }),
@@ -83,16 +83,16 @@ export async function addContractSubscription(fastify: FastifyInstance) {
         chain,
         contractAddress,
         webhookUrl,
-        parseEventLogs = true,
-        filterEventLogs = [],
-        parseTransactionReceipts = true,
+        processEventLogs = true,
+        filterEvents = [],
+        processTransactionReceipts = true,
       } = request.body;
 
       const chainId = await getChainIdFromChain(chain);
       const standardizedContractAddress = contractAddress.toLowerCase();
 
       // Must parse logs or receipts.
-      if (!parseEventLogs && !parseTransactionReceipts) {
+      if (!processEventLogs && !processTransactionReceipts) {
         throw createCustomError(
           "Contract Subscriptions must parse event logs and/or receipts.",
           StatusCodes.BAD_REQUEST,
@@ -137,9 +137,9 @@ export async function addContractSubscription(fastify: FastifyInstance) {
         chainId,
         contractAddress: standardizedContractAddress,
         webhookId,
-        parseEventLogs,
-        filterEventLogs,
-        parseTransactionReceipts,
+        processEventLogs,
+        filterEvents,
+        processTransactionReceipts,
       });
 
       reply.status(StatusCodes.OK).send({

src/server/schemas/contractSubscription.ts

@@ -7,9 +7,9 @@ export const contractSubscriptionSchema = Type.Object({
   chainId: Type.Number(),
   contractAddress: Type.String(),
   webhook: Type.Optional(WebhookSchema),
-  parseEventLogs: Type.Boolean(),
-  filterEventLogs: Type.Array(Type.String()),
-  parseTransactionReceipts: Type.Boolean(),
+  processEventLogs: Type.Boolean(),
+  filterEvents: Type.Array(Type.String()),
+  processTransactionReceipts: Type.Boolean(),
   createdAt: Type.Unsafe<Date>({
     type: "string",
     format: "date",
@@ -25,8 +25,8 @@ export const toContractSubscriptionSchema = (
   webhook: contractSubscription.webhook
     ? toWebhookSchema(contractSubscription.webhook)
     : undefined,
-  parseEventLogs: contractSubscription.parseEventLogs,
-  filterEventLogs: contractSubscription.filterEventLogs,
-  parseTransactionReceipts: contractSubscription.parseTransactionReceipts,
+  processEventLogs: contractSubscription.processEventLogs,
+  filterEvents: contractSubscription.filterEvents,
+  processTransactionReceipts: contractSubscription.processTransactionReceipts,
   createdAt: contractSubscription.createdAt,
 });

src/worker/tasks/chainIndexer.ts

@@ -68,11 +68,11 @@ export const createChainIndexerTask = async (args: {
             events: string[];
             functions: string[];
           }[] = contractSubscriptions
-            .filter((c) => c.parseEventLogs)
+            .filter((c) => c.processEventLogs)
             .map((c) => ({
               address: c.contractAddress,
-              events: c.filterEventNames,
-              functions: c.filterFunctionNames,
+              events: c.filterEvents,
+              functions: [],
             }));
           if (eventLogFilters.length > 0) {
             await enqueueProcessEventLogs({
@@ -86,7 +86,7 @@ export const createChainIndexerTask = async (args: {
           // Identify contract addresses to parse transaction receipts, if any.
           const transactionReceiptFilters: { address: string }[] =
             contractSubscriptions
-              .filter((cs) => cs.parseTransactionReceipts)
+              .filter((cs) => cs.processTransactionReceipts)
               .map((cs) => ({
                 address: cs.contractAddress.toLowerCase(),
               }));