Add networkId logic to superfluid subgraphs

src/adapters/superFluid/superFluidAdapter.ts

@@ -1,19 +1,33 @@
 import axios from 'axios';
 import { logger } from '../../utils/logger';
-import { isProduction } from '../../utils/utils';
 import {
   FlowUpdatedEvent,
   SuperFluidAdapterInterface,
 } from './superFluidAdapterInterface';
+import { NETWORK_IDS } from '../../provider';
 
-const superFluidGraphqlUrl =
+const superFluidGraphqlPolygonUrl =
   'https://subgraph-endpoints.superfluid.dev/optimism-mainnet/protocol-v1';
-const superFluidGraphqlStagingUrl =
+const superFluidGraphqlPolygonStagingUrl =
   'https://optimism-sepolia.subgraph.x.superfluid.dev';
+const superFluidGraphBaseUrl =
+  'https://subgraph-endpoints.superfluid.dev/base-mainnet/protocol-v1';
 
-const subgraphUrl = isProduction
-  ? superFluidGraphqlUrl
-  : superFluidGraphqlStagingUrl;
+const subgraphUrlMap = {
+  [NETWORK_IDS.OPTIMISTIC]: superFluidGraphqlPolygonUrl,
+  [NETWORK_IDS.OPTIMISM_SEPOLIA]: superFluidGraphqlPolygonStagingUrl,
+  [NETWORK_IDS.BASE_MAINNET]: superFluidGraphBaseUrl,
+  [NETWORK_IDS.BASE_SEPOLIA]: superFluidGraphBaseUrl,
+};
+
+// Function to retrieve the subgraph URL for a given network ID
+const getSubgraphUrl = (networkId: number) => {
+  const url = subgraphUrlMap[networkId];
+  if (!url) {
+    throw new Error(`No subgraph URL found for network ID: ${networkId}`);
+  }
+  return url;
+};
 
 // Define your GraphQL query as a string and prepare your variables
 const accountQuery = `
@@ -169,8 +183,9 @@
     */
 
   // Optimism works
-  async accountBalance(accountId: string) {
+  async accountBalance(accountId: string, networkId: number) {
     try {
+      const subgraphUrl = getSubgraphUrl(networkId);
       const response = await axios.post(subgraphUrl, {
         query: accountQuery,
         variables: {
@@ -189,12 +204,16 @@
     sender: string;
     flowRate: string;
     transactionHash: string;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined> {
     try {
+      const subgraphUrl = getSubgraphUrl(params.networkId);
+      const { networkId, ...whereParams } = params;
+
       const response = await axios.post(subgraphUrl, {
         query: getFlowsQuery,
         variables: {
-          where: params,
+          where: whereParams,
           orderBy: 'timestamp',
           orderDirection: 'asc',
         },
@@ -213,14 +232,19 @@
     sender: string;
     flowRate: string;
     timestamp_gt: number;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined> {
     try {
+      const subgraphUrl = getSubgraphUrl(params.networkId);
+
       logger.debug('getFlowByReceiverSenderFlowRate has been called', params);
 
+      const { networkId, ...whereParams } = params;
+
       const response = await axios.post(subgraphUrl, {
         query: getFlowsQuery,
         variables: {
-          where: params,
+          where: whereParams,
           orderBy: 'timestamp',
           orderDirection: 'asc',
         },

src/adapters/superFluid/superFluidAdapterInterface.ts

@@ -20,17 +20,19 @@ export interface SuperFluidAdapterInterface {
     currency: string;
     recurringDonationTxHash: string;
   }): Promise<any>;
-  accountBalance(accountId: string): Promise<any>;
+  accountBalance(accountId: string, networkId: number): Promise<any>;
   getFlowByTxHash(params: {
     receiver: string;
     sender: string;
     flowRate: string;
     transactionHash: string;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined>;
   getFlowByReceiverSenderFlowRate(params: {
     receiver: string;
     sender: string;
     flowRate: string;
     timestamp_gt: number;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined>;
 }

src/adapters/superFluid/superFluidMockAdapter.ts

@@ -85,6 +85,7 @@ export class SuperFluidMockAdapter implements SuperFluidAdapterInterface {
     sender: string;
     flowRate: string;
     timestamp_gt: number;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined> {
     return Promise.resolve(undefined);
   }
@@ -94,6 +95,7 @@ export class SuperFluidMockAdapter implements SuperFluidAdapterInterface {
     sender: string;
     flowRate: string;
     transactionHash: string;
+    networkId: number;
   }): Promise<FlowUpdatedEvent | undefined> {
     const { receiver, sender, flowRate, transactionHash } = params;
     return Promise.resolve({

src/services/chains/evm/draftRecurringDonationService.ts

@@ -47,6 +47,7 @@ export async function matchDraftRecurringDonations(
         timestamp_gt: convertTimeStampToSeconds(
           draftRecurringDonation.createdAt.getTime(),
         ),
+        networkId: draftRecurringDonation.networkId,
       };
       const flow =
         await superFluidAdapter.getFlowByReceiverSenderFlowRate(getFlowParams);

src/services/cronJobs/checkUserSuperTokenBalancesQueue.ts

@@ -108,6 +108,7 @@ export const validateDonorSuperTokenBalance = async (
 
   const accountBalances = await superFluidAdapter.accountBalance(
     user.walletAddress!,
+    recurringDonation.networkId,
   );
 
   logger.debug(

src/services/recurringDonationService.ts

@@ -393,6 +393,7 @@ export const updateRecurringDonationStatusWithNetwork = async (params: {
       flowRate: recurringDonation.flowRate,
       sender: recurringDonation?.donor?.walletAddress?.toLowerCase() as string,
       transactionHash: recurringDonation.txHash,
+      networkId: recurringDonation.networkId,
     });
     if (!txData) {
       throw new Error(

test/graphqlQueries.ts

@@ -2072,6 +2072,24 @@ export const removeSocialProfileMutation = `
           }
         `;
 
+export const recurringDonationEligibleProjectsQuery = `
+  query (
+    networkId: Int
+    page: Int
+    limit: Int
+  ) {
+    recurringDonationEligibleProjects {
+      id
+      slug
+      title
+      anchorContracts {
+        address
+        networkId
+      }
+    }
+  }
+`;
+
 export const getAllowedCountries = `
     query {
         getAllowedCountries {