Release Oct 2024 - decentralized verification

migration-old-backup/1724061402220-RenameIsProjectVerifiedToIsGivbackEligibleInDonation.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class RenameIsProjectVerifiedToIsGivbackEligibleInDonation1637168932306
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            ALTER TABLE donation
+            RENAME COLUMN "isProjectVerified" TO "isProjectGivbackEligible";
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            ALTER TABLE donation
+            RENAME COLUMN "isProjectGivbackEligible" TO "isProjectVerified";
+        `);
+  }
+}

migration/1646295724658-createTokensTable.ts

@@ -10,6 +10,7 @@ export class createTokensTable1646295724658 implements MigrationInterface {
           name text COLLATE pg_catalog."default" NOT NULL,
           symbol text COLLATE pg_catalog."default" NOT NULL,
           address text COLLATE pg_catalog."default" NOT NULL,
+          "isQR" BOOLEAN DEFAULT FALSE NOT NUL,
           "networkId" integer NOT NULL,
           decimals integer NOT NULL,
           "order" integer,

migration/1696918830123-add_octant_donations_to_db.ts

@@ -68,7 +68,7 @@ const transactions: Partial<Donation>[] = [
     transactionId:
       '0x30954cb441cb7b2184e6cd1afc6acbd1318f86a68b669f6bfb2786dd459e2d6c',
     currency: 'ETH',
-    isProjectVerified: true,
+    isProjectGivbackEligible: true,
     isTokenEligibleForGivback: true,
     amount: 5,
     valueUsd: 9_458.4,

migration/1716367359560-add_base_chain_tokens.ts

@@ -6,6 +6,10 @@ import { NETWORK_IDS } from '../src/provider';
 
 export class AddBaseChainTokens1716367359560 implements MigrationInterface {
   public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE token ADD COLUMN IF NOT EXISTS "isQR" BOOLEAN DEFAULT FALSE NOT NULL`,
+    );
+
     const environment = config.get('ENVIRONMENT') as string;
 
     const networkId =

migration/1724060343213-AddIsGivbackEligibleColumnToProject.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner, TableColumn } from 'typeorm';
+
+export class AddIsGivbackEligibleColumnToProject1637168932304
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    // Add the new column
+    await queryRunner.addColumn(
+      'project',
+      new TableColumn({
+        name: 'isGivbackEligible',
+        type: 'boolean',
+        isNullable: false,
+        default: false,
+      }),
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    // Drop the isGivbackEligible column
+    await queryRunner.dropColumn('project', 'isGivbackEligible');
+  }
+}

migration/1724060408379-UpdateIsGivbackEligibleForVerifiedProjects.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class UpdateIsGivbackEligibleForVerifiedProjects1637168932305
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    // Update isGivbackEligible to true for verified projects
+    await queryRunner.query(`
+            UPDATE project
+            SET "isGivbackEligible" = true
+            WHERE "verified" = true;
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    // Revert the update (optional)
+    await queryRunner.query(`
+            UPDATE project
+            SET "isGivbackEligible" = false
+            WHERE "verified" = true;
+        `);
+  }
+}

migration/1724223781248-ProjectInstantPowerViewV3.ts

@@ -0,0 +1,66 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ProjectInstantPowerViewV31724223781248
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+          DROP MATERIALIZED VIEW IF EXISTS public.project_instant_power_view;
+          CREATE MATERIALIZED VIEW IF NOT EXISTS public.project_instant_power_view AS
+          SELECT
+            innerview."projectId",
+            ROUND(CAST(innerview."totalPower" as NUMERIC), 2) as "totalPower",
+            rank() OVER (
+              ORDER BY
+                innerview."totalPower" DESC
+            ) AS "powerRank"
+          FROM
+            (
+              SELECT
+                project.id AS "projectId",
+                CASE
+                  WHEN (project.verified = true OR project."isGivbackEligible" = true) AND project."statusId" = 5 THEN COALESCE(sum(pp."boostedPower"), 0 :: double precision)
+                  ELSE 0 :: double precision
+                END AS "totalPower"
+              FROM
+                project
+                LEFT JOIN (
+                  SELECT
+                    "powerBoosting"."projectId",
+                    sum("instantPowerBalance".balance * "powerBoosting".percentage :: double precision / 100 :: double precision) AS "boostedPower",
+                    now() AS "updateTime"
+                  FROM
+                    instant_power_balance "instantPowerBalance"
+                    JOIN power_boosting "powerBoosting" ON "powerBoosting"."userId" = "instantPowerBalance"."userId"
+                  GROUP BY
+                    "powerBoosting"."projectId"
+                ) pp ON pp."projectId" = project.id
+              GROUP BY
+                project.id
+            ) innerview
+          ORDER BY
+            innerview."totalPower" DESC WITH DATA;
+        `);
+
+    await queryRunner.query(`
+          CREATE UNIQUE INDEX idx_project_instant_power_view_unique ON public.project_instant_power_view ("projectId");
+        `);
+
+    await queryRunner.query(`
+          CREATE INDEX project_instant_power_view_project_id ON public.project_instant_power_view USING hash ("projectId") TABLESPACE pg_default;
+        `);
+
+    await queryRunner.query(`
+          CREATE INDEX project_instant_power_view_total_power ON public.project_instant_power_view USING btree ("totalPower" DESC) TABLESPACE pg_default;
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+          DROP MATERIALIZED VIEW IF EXISTS public.project_instant_power_view;
+          DROP INDEX IF EXISTS public.idx_project_instant_power_view_unique;
+          DROP INDEX IF EXISTS public.project_instant_power_view_project_id;
+          DROP INDEX IF EXISTS public.project_instant_power_view_total_power;
+        `);
+  }
+}

migration/1725260193333-projectGivbackRankView.ts

@@ -0,0 +1,66 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ProjectGivbackRankViewV31725260193333
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `
+                    DROP
+                      MATERIALIZED VIEW IF EXISTS public.project_givback_rank_view;
+                    CREATE MATERIALIZED VIEW IF NOT EXISTS public.project_givback_rank_view AS
+                    SELECT
+                      innerview."projectId",
+                      ROUND(CAST(innerview."totalPower" as NUMERIC), 2) as "totalPower",
+                      rank() OVER (
+                        ORDER BY
+                          innerview."totalPower" DESC
+                      ) AS "powerRank",
+                      "powerRound".round
+                    FROM
+                      (
+                        SELECT
+                          project.id AS "projectId",
+                          CASE project."isGivbackEligible" and project."statusId" = 5 WHEN false THEN 0 :: double precision ELSE COALESCE(
+                            sum(pp."boostedPower"),
+                            0 :: double precision
+                          ) END AS "totalPower"
+                        FROM
+                          project project
+                          LEFT JOIN (
+                            SELECT
+                              "powerRound".round,
+                              "powerBoostingSnapshot"."projectId",
+                              "powerBoostingSnapshot"."userId",
+                              avg(
+                                "powerBalanceSnapshot".balance * "powerBoostingSnapshot".percentage :: double precision / 100 :: double precision
+                              ) AS "boostedPower",
+                              now() AS "updateTime"
+                            FROM
+                              power_round "powerRound"
+                              JOIN power_snapshot "powerSnapshot" ON "powerSnapshot"."roundNumber" = "powerRound".round
+                              JOIN power_balance_snapshot "powerBalanceSnapshot" ON "powerBalanceSnapshot"."powerSnapshotId" = "powerSnapshot".id
+                              JOIN power_boosting_snapshot "powerBoostingSnapshot" ON "powerBoostingSnapshot"."powerSnapshotId" = "powerSnapshot".id
+                              AND "powerBoostingSnapshot"."userId" = "powerBalanceSnapshot"."userId"
+                            GROUP BY
+                              "powerRound".round,
+                              "powerBoostingSnapshot"."projectId",
+                              "powerBoostingSnapshot"."userId"
+                          ) pp ON pp."projectId" = project.id
+                        GROUP BY
+                          project.id
+                      ) innerview,
+                      power_round "powerRound"
+                    ORDER BY
+                      innerview."totalPower" DESC WITH DATA;
+                    CREATE UNIQUE INDEX project_givback_rank_view_project_id_round_unique ON public.project_givback_rank_view ("projectId", "round");
+                    CREATE INDEX project_givback_rank_view_project_id ON public.project_givback_rank_view USING hash ("projectId") TABLESPACE pg_default;
+                    CREATE INDEX project_givback_rank_view_total_power ON public.project_givback_rank_view USING btree ("totalPower" DESC) TABLESPACE pg_default;
+                `,
+    );
+  }
+
+  public async down(_queryRunner: QueryRunner): Promise<void> {
+    //
+  }
+}

migration/1726069430594-add_endaoment_project_banners.ts

@@ -0,0 +1,86 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+import { endaomentProjects } from './data/importedEndaomentProjects';
+import { endaomentProjectCategoryMapping } from './data/endaomentProjectCategoryMapping';
+import { NETWORK_IDS } from '../src/provider';
+export class AddEndaomentProjectBanners1726069430594
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    const mainCategorySlugToBannerMapping = {
+      'environment-and-energy': 'environment-energy',
+      'health-and-wellness': 'health-wellness',
+      'art-and-culture': 'art-culture',
+      nature: 'nature',
+      community: 'community',
+      finance: 'finance',
+      education: 'education',
+      equality: 'equality',
+      other: '1',
+      'economic-and-infrastructure': 'economic-infrastructure',
+      ngo: 'non-profit',
+      technology: 'technology',
+    };
+    const subCategoryToCategory = await queryRunner.query(
+      'SELECT category.value, main_category.slug from category LEFT JOIN main_category on category."mainCategoryId" = main_category.id;',
+    );
+
+    const imageCategoryMapping = subCategoryToCategory.reduce(function (
+      categoryImageKeyPair,
+      category: { value: string; slug: string },
+    ) {
+      const bannerLink = mainCategorySlugToBannerMapping[category.slug] || '1';
+      categoryImageKeyPair[category.value] = bannerLink;
+      return categoryImageKeyPair;
+    }, {});
+
+    for (const project of endaomentProjects) {
+      const mainnetAddress = project.mainnetAddress;
+      const projectAddresses = await queryRunner.query(
+        `SELECT * FROM project_address WHERE LOWER(address) = $1 AND "networkId" = $2 LIMIT 1`,
+        [mainnetAddress!.toLowerCase(), NETWORK_IDS.MAIN_NET],
+      );
+
+      const projectAddress = await projectAddresses?.[0];
+
+      if (!projectAddress) {
+        // eslint-disable-next-line no-console
+        console.log(`Could not find project address for ${mainnetAddress}`);
+        continue;
+      }
+
+      // Insert the project-category relationship in a single query
+      const getCategoryNames = (nteeCode: string): string[] => {
+        const mapping = endaomentProjectCategoryMapping.find(
+          category => category.nteeCode === nteeCode,
+        );
+        return mapping
+          ? [
+              mapping.category1,
+              mapping.category2,
+              mapping.category3 || '',
+              mapping.category4 || '',
+            ].filter(Boolean)
+          : [];
+      };
+      if (!project.nteeCode) {
+        // eslint-disable-next-line no-console
+        console.log(`Could not find nteeCode for ${mainnetAddress}`);
+        continue;
+      }
+      const categoryNames = getCategoryNames(String(project.nteeCode));
+      const bannerImage = `/images/defaultProjectImages/${imageCategoryMapping[categoryNames[1]] || '1'}.png`;
+      await queryRunner.query(`UPDATE project SET image = $1 WHERE id = $2`, [
+        bannerImage,
+        projectAddress.projectId,
+      ]);
+      // eslint-disable-next-line no-console
+      console.log(
+        `Updated project ${projectAddress.projectId} with image ${bannerImage}`,
+      );
+    }
+  }
+
+  public async down(_queryRunner: QueryRunner): Promise<void> {
+    // No down migration
+  }
+}

package.json

@@ -135,6 +135,8 @@
     "test:qfRoundHistoryRepository": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/repositories/qfRoundHistoryRepository.test.ts",
     "test:qfRoundService": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/services/qfRoundService.test.ts",
     "test:project": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/entities/project.test.ts",
+    "test:projectsTab": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/server/adminJs/tabs/projectsTab.test.ts",
+    "test:syncUsersModelScore": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/services/cronJobs/syncUsersModelScore.test.ts",
     "test:notifyDonationsWithSegment": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/services/cronJobs/notifyDonationsWithSegment.test.ts",
     "test:checkProjectVerificationStatus": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/services/cronJobs/checkProjectVerificationStatus.test.ts",
     "test:statusReasonResolver": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/resolvers/statusReasonResolver.test.ts",
@@ -166,6 +168,7 @@
     "test:anchorContractAddressRepository": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/repositories/anchorContractAddressRepository.test.ts",
     "test:recurringDonationRepository": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/repositories/recurringDonationRepository.test.ts",
     "test:userPassportScoreRepository": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/repositories/userPassportScoreRepository.test.ts",
+    "test:projectGivbackRepository": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/repositories/projectGivbackViewRepository.test.ts",
     "test:recurringDonationService": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/services/recurringDonationService.test.ts",
     "test:dbCronRepository": "NODE_ENV=test mocha -t 90000 ./test/pre-test-scripts.ts  ./src/repositories/dbCronRepository.test.ts",
     "test:powerBoostingResolver": "NODE_ENV=test mocha ./test/pre-test-scripts.ts  ./src/resolvers/powerBoostingResolver.test.ts",

src/adapters/superFluid/superFluidMockAdapter.ts

@@ -2,6 +2,7 @@ import {
   FlowUpdatedEvent,
   SuperFluidAdapterInterface,
 } from './superFluidAdapterInterface';
+import { generateRandomString } from '../../utils/utils';
 
 export class SuperFluidMockAdapter implements SuperFluidAdapterInterface {
   async streamPeriods() {
@@ -88,12 +89,22 @@ export class SuperFluidMockAdapter implements SuperFluidAdapterInterface {
     return Promise.resolve(undefined);
   }
 
-  getFlowByTxHash(_params: {
+  getFlowByTxHash(params: {
     receiver: string;
     sender: string;
     flowRate: string;
     transactionHash: string;
   }): Promise<FlowUpdatedEvent | undefined> {
-    return Promise.resolve(undefined);
+    const { receiver, sender, flowRate, transactionHash } = params;
+    return Promise.resolve({
+      id: generateRandomString(20),
+      flowOperator: 'flowOperator',
+      flowRate,
+      transactionHash,
+      receiver,
+      sender,
+      token: '',
+      timestamp: String(new Date().getTime()),
+    });
   }
 }