🐛 Handle stats for every affiliation campaigns

packages/ponder/src/campaign/campaignCreation.ts

@@ -5,7 +5,10 @@ import {
     interactionCampaignAbi,
     referralCampaignAbi,
 } from "../../abis/campaignAbis";
-import { emptyCampaignStats } from "../interactions/stats";
+import {
+    affiliationCampaignTypes,
+    emptyCampaignStats,
+} from "../interactions/stats";
 import { bytesToString } from "../utils/format";
 
 /**
@@ -20,12 +23,6 @@ ponder.on("CampaignsFactory:CampaignCreated", async ({ event, context }) => {
     });
 });
 
-const affiliationCampaignTypes = [
-    "frak.campaign.affiliation-fixed",
-    "frak.campaign.affiliation-range",
-    "frak.campaign.referral",
-];
-
 /**
  * Upsert a fresh campaign in the db
  * @param address

packages/ponder/src/interactions/stats.ts

@@ -4,7 +4,7 @@ import {
     campaignTable,
     productInteractionContractTable,
 } from "ponder:schema";
-import { and, desc, eq } from "ponder";
+import { and, desc, eq, inArray } from "ponder";
 import type { Address } from "viem";
 import { interactionCampaignAbi } from "../../abis/campaignAbis";
 
@@ -25,6 +25,15 @@ export const emptyCampaignStats = {
     rewardCount: 0n,
 };
 
+/**
+ * All the type of campaigns that are affiliation related
+ */
+export const affiliationCampaignTypes = [
+    "frak.campaign.affiliation-fixed",
+    "frak.campaign.affiliation-range",
+    "frak.campaign.referral",
+];
+
 export type StatsIncrementsParams = Partial<
     Omit<typeof affiliationCampaignStatsTable.$inferSelect, "campaignId">
 >;
@@ -106,7 +115,7 @@ async function increaseCampaignsStats({
         .where(
             and(
                 eq(campaignTable.productId, interactionContract.productId),
-                eq(campaignTable.type, "frak.campaign.referral"),
+                inArray(campaignTable.type, affiliationCampaignTypes),
                 eq(campaignTable.attached, true)
             )
         );