Merge branch 'staging' of github.com:Giveth/impact-graph into add_ste…

…llar_to_qf

Update Branch

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> {
+    //
+  }
+}

package.json

@@ -166,6 +166,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()),
+    });
   }
 }

src/entities/ProjectGivbackRankView.ts

@@ -0,0 +1,53 @@
+import {
+  OneToOne,
+  ViewColumn,
+  ViewEntity,
+  JoinColumn,
+  RelationId,
+  BaseEntity,
+  PrimaryColumn,
+  Column,
+  Index,
+} from 'typeorm';
+import { Field, Float, Int, ObjectType } from 'type-graphql';
+import { Project } from '../entities/project';
+import { ColumnNumericTransformer } from '../utils/entities';
+
+@ViewEntity('project_givback_rank_view', { synchronize: false })
+@Index('project_givback_rank_view_project_id_unique', ['projectId', 'round'], {
+  unique: true,
+})
+// It's similar to ProjectPowerView, but with a small difference that it uses a different view
+// That just includes project with isGivbackEligible = true
+@ObjectType()
+export class ProjectGivbackRankView extends BaseEntity {
+  @Field()
+  @ViewColumn()
+  @PrimaryColumn()
+  @RelationId(
+    (projectGivbackRankView: ProjectGivbackRankView) =>
+      projectGivbackRankView.project,
+  )
+  projectId: number;
+
+  @ViewColumn()
+  @Field(_type => Float)
+  @Column('numeric', {
+    scale: 2,
+    transformer: new ColumnNumericTransformer(),
+  })
+  totalPower: number;
+
+  @Field(_type => Project)
+  @OneToOne(_type => Project, project => project.projectPower)
+  @JoinColumn({ referencedColumnName: 'id' })
+  project: Project;
+
+  @ViewColumn()
+  @Field(_type => Int)
+  powerRank: number;
+
+  @ViewColumn()
+  @Field(_type => Int)
+  round: number;
+}

src/entities/donation.ts

@@ -77,7 +77,7 @@ export class Donation extends BaseEntity {
   @Field()
   @Column('boolean', { default: false })
   // https://github.com/Giveth/impact-graph/issues/407#issuecomment-1066892258
-  isProjectVerified: boolean;
+  isProjectGivbackEligible: boolean;
 
   @Field()
   @Column('text', { default: DONATION_STATUS.PENDING })

src/entities/entities.ts

@@ -51,6 +51,7 @@ import { ProjectActualMatchingView } from './ProjectActualMatchingView';
 import { ProjectSocialMedia } from './projectSocialMedia';
 import { DraftRecurringDonation } from './draftRecurringDonation';
 import { UserQfRoundModelScore } from './userQfRoundModelScore';
+import { ProjectGivbackRankView } from './ProjectGivbackRankView';
 
 export const getEntities = (): DataSourceOptions['entities'] => {
   return [
@@ -118,5 +119,7 @@ export const getEntities = (): DataSourceOptions['entities'] => {
     AnchorContractAddress,
     RecurringDonation,
     DraftRecurringDonation,
+
+    ProjectGivbackRankView,
   ];
 };

src/entities/project.ts

@@ -217,6 +217,7 @@ export class Project extends BaseEntity {
   @Field(_type => [Category], { nullable: true })
   @ManyToMany(_type => Category, category => category.projects, {
     nullable: true,
+    eager: true,
   })
   @JoinTable()
   categories: Category[];
@@ -408,6 +409,10 @@ export class Project extends BaseEntity {
   // @Column({ type: 'boolean', default: false })
   // tunnableQf?: boolean;
 
+  @Field(_type => Boolean, { nullable: true })
+  @Column({ type: 'boolean', default: false })
+  isGivbackEligible: boolean;
+
   @Field(_type => String)
   @Column({
     type: 'enum',