Omit platforms from delegation queries

Author: mmahdigh

src/flow/flow.controller.ts

@@ -490,22 +490,19 @@ export class FlowController {
     const twitterUsername = twitterRes ? twitterRes.username : null;
 
     const uniqueFarcasterCollectionDelegators = fid
-      ? await this.flowService.getCollectionDelegators(`${fid}`, 'FARCASTER')
+      ? await this.flowService.getCollectionDelegators(`${fid}`)
       : [];
 
     const uniqueTwitterCollectionDelegators = twitterUsername
-      ? await this.flowService.getCollectionDelegators(
-          twitterUsername,
-          'TWITTER',
-        )
+      ? await this.flowService.getCollectionDelegators(twitterUsername)
       : [];
 
     const uniqueFarcasterBudgetDelegators = fid
-      ? await this.flowService.getBudgetDelegators(`${fid}`, 'FARCASTER')
+      ? await this.flowService.getBudgetDelegators(`${fid}`)
       : [];
 
     const uniqueTwitterBudgetDelegators = twitterUsername
-      ? await this.flowService.getBudgetDelegators(twitterUsername, 'TWITTER')
+      ? await this.flowService.getBudgetDelegators(twitterUsername)
       : [];
 
     // const fid = (res.metadata as FarcasterMetadata).fid;
@@ -529,8 +526,6 @@ export class FlowController {
       ].map((el) => el.id),
     ).size;
 
-    console.log('res2', res2);
-
     const uniqueBudgetDelegatorsSize = new Set(
       [
         ...uniqueFarcasterBudgetDelegators,
@@ -560,14 +555,12 @@ export class FlowController {
                   ? []
                   : await this.flowService.getCollectionDelegators(
                       `${fid}`,
-                      'FARCASTER',
                       el.collectionId,
                     )),
                 ...(!twitterUsername
                   ? []
                   : await this.flowService.getCollectionDelegators(
                       twitterUsername,
-                      'TWITTER',
                       el.collectionId,
                     )),
               ],
@@ -580,15 +573,11 @@ export class FlowController {
               delegators: [
                 ...(!fid
                   ? []
-                  : await this.flowService.getBudgetDelegators(
-                      `${fid}`,
-                      'FARCASTER',
-                    )),
+                  : await this.flowService.getBudgetDelegators(`${fid}`)),
                 ...(!twitterUsername
                   ? []
                   : await this.flowService.getBudgetDelegators(
                       twitterUsername,
-                      'TWITTER',
                     )),
               ],
             };

src/flow/flow.service.ts

@@ -541,7 +541,6 @@ export class FlowService {
    */
   getCollectionDelegators = async (
     socialId: string,
-    platform?: DelegationPlatform,
     collectionId?: number,
   ): Promise<User[]> => {
     // Store users who have delegated to our target
@@ -553,8 +552,22 @@ export class FlowService {
     // Use BFS to traverse the delegation graph backward
     let currentBatch: string[] = [socialId];
 
+    // let iteration = 1;
+
+    // console.log('--------------------------------');
+
     while (currentBatch.length > 0) {
       // Find all direct delegations to users in the current batch
+
+      // console.log(
+      //   'iteration',
+      //   iteration++,
+      //   'current batch',
+      //   currentBatch,
+      //   'metadata',
+      //   { collectionId },
+      // );
+
       const directDelegations =
         await this.prismaService.collectionDelegation.findMany({
           where: {
@@ -563,7 +576,6 @@ export class FlowService {
               mode: 'insensitive',
             },
             collectionId,
-            platform,
           },
           include: {
             user: true,
@@ -583,6 +595,8 @@ export class FlowService {
           // For each delegator, get their social ID to find who delegated to them
         }
       }
+
+      // console.log('Direct delegations', directDelegations);
       const delegatorSocialIds = await this.convertUserIdsToSocials(
         directDelegations.map((el) => el.userId),
       );
@@ -591,6 +605,8 @@ export class FlowService {
       currentBatch = nextBatch;
     }
 
+    // console.log('--------------------------------');
+
     return delegators;
   };
 
@@ -599,10 +615,7 @@ export class FlowService {
    * @param socialId The Twitter or Farcaster ID of the user receiving delegations
    * @returns Array of User objects who have delegated to the target
    */
-  getBudgetDelegators = async (
-    socialId: string,
-    platform?: DelegationPlatform,
-  ): Promise<User[]> => {
+  getBudgetDelegators = async (socialId: string): Promise<User[]> => {
     // Store users who have delegated to our target
     const delegators: User[] = [];
 
@@ -621,7 +634,6 @@ export class FlowService {
               in: currentBatch,
               mode: 'insensitive',
             },
-            platform,
           },
           include: {
             user: true,