Merge pull request #1334 from Giveth/3752_add_unique_index_for_sybil_…

…table

Add unique index for sybil table

migration/1708256080054-add_unique_index_for_sybil_table.ts

@@ -0,0 +1,29 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddUniqueIndexForSybilTable1708256080054
+  implements MigrationInterface
+{
+  async up(queryRunner: QueryRunner): Promise<void> {
+    // Step 1: Identify and Resolve Duplicates
+    // Example strategy: Keep the first record and delete the rest
+    await queryRunner.query(`
+      DELETE FROM sybil
+      WHERE id NOT IN (
+        SELECT MIN(id)
+        FROM sybil
+        GROUP BY "userId", "qfRoundId"
+      );
+    `);
+
+    // Step 2: Create Unique Index
+    await queryRunner.query(`
+      CREATE UNIQUE INDEX "IDX_USERID_QFROUNDID" ON "sybil" ("userId", "qfRoundId");
+    `);
+  }
+
+  async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+      DROP INDEX "IDX_USERID_QFROUNDID";
+    `);
+  }
+}

src/entities/sybil.ts

@@ -6,12 +6,14 @@ import {
   ManyToOne,
   RelationId,
   BaseEntity,
+  Unique,
 } from 'typeorm';
 import { User } from './user';
 import { QfRound } from './qfRound';
 
 @ObjectType()
 @Entity()
+@Unique(['userId', 'qfRoundId'])
 export class Sybil extends BaseEntity {
   @Field(type => ID)
   @PrimaryGeneratedColumn()

src/entities/userPassportScore.ts

@@ -0,0 +1,49 @@
+import { Field, ID, ObjectType } from 'type-graphql';
+import {
+  PrimaryGeneratedColumn,
+  Column,
+  Entity,
+  ManyToOne,
+  RelationId,
+  BaseEntity,
+  UpdateDateColumn,
+  CreateDateColumn,
+} from 'typeorm';
+import { User } from './user';
+import { QfRound } from './qfRound';
+
+@ObjectType()
+@Entity()
+export class UserPassportScore extends BaseEntity {
+  @Field(type => ID)
+  @PrimaryGeneratedColumn()
+  readonly id: number;
+
+  @Field({ nullable: false })
+  @Column('number')
+  passportScore: number;
+
+  @Field(type => User)
+  @ManyToOne(type => User, { eager: true })
+  user: User;
+
+  @RelationId((userPassportScore: UserPassportScore) => userPassportScore.user)
+  @Column()
+  userId: number;
+
+  @Field(type => QfRound)
+  @ManyToOne(type => QfRound, { eager: true })
+  qfRound: QfRound;
+
+  @RelationId(
+    (userPassportScore: UserPassportScore) => userPassportScore.qfRound,
+  )
+  @Column()
+  qfRoundId: number;
+
+  @UpdateDateColumn()
+  updatedAt: Date;
+
+  @CreateDateColumn()
+  createdAt: Date;
+}

src/server/adminJs/tabs/sybilTab.ts

@@ -64,14 +64,16 @@ export const createSybil = async (
         throw new Error('No valid entries to insert');
       }
 
-      // Insert query
-      const query = `
-        INSERT INTO sybil ("confirmedSybil", "userId", "qfRoundId")
-        VALUES ${values};
-    `;
-
+      // Upsert query
+      const upsertQuery = `
+          INSERT INTO sybil ("confirmedSybil", "userId", "qfRoundId")
+          VALUES ${values}
+          ON CONFLICT ("userId", "qfRoundId") 
+          DO UPDATE SET 
+            "confirmedSybil" = EXCLUDED."confirmedSybil";
+     `;
       // Execute the query
-      await Sybil.query(query);
+      await Sybil.query(upsertQuery);
     } else {
       const sybil = new Sybil();
       sybil.confirmedSybil = true;