Release 2025-04-07

packages/apps/dashboard/client/package.json

@@ -16,7 +16,7 @@
     "@emotion/react": "^11.11.4",
     "@emotion/styled": "^11.11.5",
     "@human-protocol/sdk": "*",
-    "@mui/icons-material": "^6.4.6",
+    "@mui/icons-material": "^7.0.1",
     "@mui/material": "^5.15.18",
     "@mui/styled-engine-sc": "6.4.0",
     "@mui/x-data-grid": "^7.23.2",
@@ -53,7 +53,7 @@
     "sass": "^1.85.0",
     "stylelint-prettier": "^5.0.0",
     "typescript": "^5.6.3",
-    "vite": "^6.2.0",
+    "vite": "^6.2.4",
     "vite-plugin-svgr": "^4.2.0"
   }
 }

packages/apps/dashboard/server/package.json

@@ -36,7 +36,7 @@
   },
   "devDependencies": {
     "@nestjs/cli": "^10.3.2",
-    "@nestjs/schematics": "^10.1.3",
+    "@nestjs/schematics": "^11.0.2",
     "@nestjs/testing": "^10.4.6",
     "@types/express": "^4.17.13",
     "@types/jest": "29.5.1",

packages/apps/faucet/client/package.json

@@ -6,7 +6,7 @@
   "license": "MIT",
   "dependencies": {
     "@human-protocol/sdk": "*",
-    "@mui/icons-material": "^6.4.6",
+    "@mui/icons-material": "^7.0.1",
     "@mui/material": "^5.16.7",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
@@ -22,7 +22,7 @@
     "eslint-plugin-import": "^2.29.0",
     "eslint-plugin-react": "^7.34.3",
     "eslint-plugin-react-hooks": "^5.1.0",
-    "vite": "^6.2.0",
+    "vite": "^6.2.4",
     "vite-plugin-node-polyfills": "^0.22.0"
   },
   "scripts": {

packages/apps/fortune/exchange-oracle/client/package.json

@@ -50,7 +50,7 @@
     "eslint-plugin-react-hooks": "^5.1.0",
     "eslint-plugin-react-refresh": "^0.4.11",
     "typescript": "^5.6.3",
-    "vite": "^6.2.0"
+    "vite": "^6.2.4"
   },
   "lint-staged": {
     "*.{ts,tsx}": [

packages/apps/fortune/exchange-oracle/server/package.json

@@ -38,7 +38,7 @@
   "devDependencies": {
     "@golevelup/ts-jest": "^0.6.1",
     "@nestjs/cli": "^10.3.2",
-    "@nestjs/schematics": "^10.1.3",
+    "@nestjs/schematics": "^11.0.2",
     "@nestjs/testing": "^10.4.6",
     "@types/express": "^4.17.13",
     "@types/jest": "29.5.12",

packages/apps/fortune/exchange-oracle/server/src/common/constant/errors.ts

@@ -45,6 +45,7 @@ export enum ErrorAssignment {
 export enum ErrorJob {
   AlreadyExists = 'Job already exists',
   InvalidAddress = 'Invalid address',
+  InvalidStatus = 'Invalid job status',
   NotAssigned = 'User is not assigned to the job',
   SolutionAlreadySubmitted = 'User has already submitted a solution',
   JobCompleted = 'This job has already been completed',

packages/apps/fortune/exchange-oracle/server/src/common/enums/job.ts

@@ -1,5 +1,6 @@
 export enum JobStatus {
   ACTIVE = 'active',
+  PAUSED = 'paused',
   COMPLETED = 'completed',
   CANCELED = 'canceled',
 }

packages/apps/fortune/exchange-oracle/server/src/common/enums/webhook.ts

@@ -5,6 +5,8 @@ export enum EventType {
   ESCROW_FAILED = 'escrow_failed',
   SUBMISSION_REJECTED = 'submission_rejected',
   SUBMISSION_IN_REVIEW = 'submission_in_review',
+  ABUSE_DETECTED = 'abuse_detected',
+  ABUSE_DISMISSED = 'abuse_dismissed',
 }
 
 export enum WebhookStatus {

packages/apps/fortune/exchange-oracle/server/src/database/migrations/1743412274647-handleAbuse.ts

@@ -0,0 +1,83 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class HandleAbuse1743412274647 implements MigrationInterface {
+  name = 'HandleAbuse1743412274647';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            ALTER TYPE "hmt"."webhooks_event_type_enum"
+            RENAME TO "webhooks_event_type_enum_old"
+        `);
+    await queryRunner.query(`
+            CREATE TYPE "hmt"."webhooks_event_type_enum" AS ENUM(
+                'escrow_created',
+                'escrow_completed',
+                'escrow_canceled',
+                'escrow_failed',
+                'submission_rejected',
+                'submission_in_review',
+                'abuse_detected',
+                'abuse_dismissed'
+            )
+        `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."webhooks"
+            ALTER COLUMN "event_type" TYPE "hmt"."webhooks_event_type_enum" USING "event_type"::"text"::"hmt"."webhooks_event_type_enum"
+        `);
+    await queryRunner.query(`
+            DROP TYPE "hmt"."webhooks_event_type_enum_old"
+        `);
+    await queryRunner.query(`
+            ALTER TYPE "hmt"."jobs_status_enum"
+            RENAME TO "jobs_status_enum_old"
+        `);
+    await queryRunner.query(`
+            CREATE TYPE "hmt"."jobs_status_enum" AS ENUM('active', 'paused', 'completed', 'canceled')
+        `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."jobs"
+            ALTER COLUMN "status" TYPE "hmt"."jobs_status_enum" USING "status"::"text"::"hmt"."jobs_status_enum"
+        `);
+    await queryRunner.query(`
+            DROP TYPE "hmt"."jobs_status_enum_old"
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            CREATE TYPE "hmt"."jobs_status_enum_old" AS ENUM('active', 'completed', 'canceled')
+        `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."jobs"
+            ALTER COLUMN "status" TYPE "hmt"."jobs_status_enum_old" USING "status"::"text"::"hmt"."jobs_status_enum_old"
+        `);
+    await queryRunner.query(`
+            DROP TYPE "hmt"."jobs_status_enum"
+        `);
+    await queryRunner.query(`
+            ALTER TYPE "hmt"."jobs_status_enum_old"
+            RENAME TO "jobs_status_enum"
+        `);
+    await queryRunner.query(`
+            CREATE TYPE "hmt"."webhooks_event_type_enum_old" AS ENUM(
+                'escrow_created',
+                'escrow_completed',
+                'escrow_canceled',
+                'escrow_failed',
+                'submission_rejected',
+                'submission_in_review'
+            )
+        `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."webhooks"
+            ALTER COLUMN "event_type" TYPE "hmt"."webhooks_event_type_enum_old" USING "event_type"::"text"::"hmt"."webhooks_event_type_enum_old"
+        `);
+    await queryRunner.query(`
+            DROP TYPE "hmt"."webhooks_event_type_enum"
+        `);
+    await queryRunner.query(`
+            ALTER TYPE "hmt"."webhooks_event_type_enum_old"
+            RENAME TO "webhooks_event_type_enum"
+        `);
+  }
+}

packages/apps/fortune/exchange-oracle/server/src/modules/assignment/assignment.service.spec.ts

@@ -6,7 +6,7 @@ import {
   MOCK_MANIFEST_URL,
   MOCK_PRIVATE_KEY,
 } from '../../../test/constants';
-import { AssignmentStatus, JobType } from '../../common/enums/job';
+import { AssignmentStatus, JobStatus, JobType } from '../../common/enums/job';
 import { AssignmentRepository } from '../assignment/assignment.repository';
 import { AssignmentService } from '../assignment/assignment.service';
 import { ManifestDto } from '../job/job.dto';
@@ -18,7 +18,7 @@ import { Escrow__factory } from '@human-protocol/core/typechain-types';
 import { AssignmentSortField } from '../../common/enums/job';
 import { SortDirection } from '../../common/enums/collection';
 import { AssignmentEntity } from './assignment.entity';
-import { ErrorAssignment } from '../../common/constant/errors';
+import { ErrorAssignment, ErrorJob } from '../../common/constant/errors';
 import { BadRequestException } from '@nestjs/common';
 import { ServerConfigService } from '../../common/config/server-config.service';
 
@@ -117,6 +117,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')
@@ -140,6 +141,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         },
         workerAddress: workerAddress,
         status: AssignmentStatus.ACTIVE,
@@ -160,6 +162,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')
@@ -194,6 +197,7 @@ describe('AssignmentService', () => {
         assignmentService.createAssignment(createAssignmentDto, {
           address: workerAddress,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any),
       ).rejects.toThrow('Job not found');
     });
@@ -207,6 +211,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: differentReputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
 
       await expect(
@@ -217,13 +222,32 @@ describe('AssignmentService', () => {
       ).rejects.toThrow('Requested job is not in your reputation network');
     });
 
+    it('should fail if job is not active', async () => {
+      jest
+        .spyOn(jobRepository, 'findOneByChainIdAndEscrowAddress')
+        .mockResolvedValue({
+          id: 1,
+          manifestUrl: MOCK_MANIFEST_URL,
+          reputationNetwork: reputationNetwork,
+          status: JobStatus.PAUSED,
+        } as any);
+
+      await expect(
+        assignmentService.createAssignment(createAssignmentDto, {
+          address: workerAddress,
+          reputationNetwork: reputationNetwork,
+        } as any),
+      ).rejects.toThrow(ErrorJob.InvalidStatus);
+    });
+
     it('should fail if user already assigned', async () => {
       jest
         .spyOn(jobRepository, 'findOneByChainIdAndEscrowAddress')
         .mockResolvedValue({
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')
@@ -244,6 +268,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')
@@ -255,6 +280,7 @@ describe('AssignmentService', () => {
         assignmentService.createAssignment(createAssignmentDto, {
           address: workerAddress,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any),
       ).rejects.toThrow('Fully assigned job');
     });
@@ -267,6 +293,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')
@@ -291,6 +318,7 @@ describe('AssignmentService', () => {
           id: 1,
           manifestUrl: MOCK_MANIFEST_URL,
           reputationNetwork: reputationNetwork,
+          status: JobStatus.ACTIVE,
         } as any);
       jest
         .spyOn(assignmentRepository, 'findOneByJobIdAndWorker')

packages/apps/fortune/exchange-oracle/server/src/modules/assignment/assignment.service.ts

@@ -1,5 +1,5 @@
 import { BadRequestException, Injectable, Logger } from '@nestjs/common';
-import { AssignmentStatus, JobType } from '../../common/enums/job';
+import { AssignmentStatus, JobStatus, JobType } from '../../common/enums/job';
 import { JwtUser } from '../../common/types/jwt';
 import { JobRepository } from '../job/job.repository';
 import {
@@ -13,7 +13,7 @@ import { PageDto } from '../../common/pagination/pagination.dto';
 import { JobService } from '../job/job.service';
 import { Escrow__factory } from '@human-protocol/core/typechain-types';
 import { Web3Service } from '../web3/web3.service';
-import { ErrorAssignment } from '../../common/constant/errors';
+import { ErrorAssignment, ErrorJob } from '../../common/constant/errors';
 import { ServerConfigService } from '../../common/config/server-config.service';
 
 @Injectable()
@@ -40,6 +40,9 @@ export class AssignmentService {
     if (!jobEntity) {
       this.logger.log(ErrorAssignment.JobNotFound, AssignmentService.name);
       throw new BadRequestException(ErrorAssignment.JobNotFound);
+    } else if (jobEntity.status !== JobStatus.ACTIVE) {
+      this.logger.log(ErrorJob.InvalidStatus, AssignmentService.name);
+      throw new BadRequestException(ErrorJob.InvalidStatus);
     } else if (jobEntity.reputationNetwork !== jwtUser.reputationNetwork) {
       this.logger.log(
         ErrorAssignment.ReputationNetworkMismatch,

packages/apps/fortune/exchange-oracle/server/src/modules/job/job.service.spec.ts

@@ -450,6 +450,7 @@ describe('JobService', () => {
       job: {
         escrowAddress,
         chainId,
+        status: JobStatus.ACTIVE,
       },
     } as AssignmentEntity;
 
@@ -666,4 +667,54 @@ describe('JobService', () => {
       ).rejects.toThrow(`Solution not found in Escrow: ${escrowAddress}`);
     });
   });
+
+  describe('pauseJob', () => {
+    const webhook: WebhookDto = {
+      chainId,
+      escrowAddress,
+      eventType: EventType.ABUSE_DETECTED,
+    };
+
+    it('should create a new job in the database', async () => {
+      jest
+        .spyOn(jobRepository, 'findOneByChainIdAndEscrowAddress')
+        .mockResolvedValue({
+          chainId: chainId,
+          escrowAddress: escrowAddress,
+          status: JobStatus.ACTIVE,
+        } as JobEntity);
+      const result = await jobService.pauseJob(webhook);
+
+      expect(result).toEqual(undefined);
+      expect(jobRepository.updateOne).toHaveBeenCalledWith({
+        chainId: chainId,
+        escrowAddress: escrowAddress,
+        status: JobStatus.PAUSED,
+      });
+    });
+
+    it('should fail if job not exists', async () => {
+      jest
+        .spyOn(jobRepository, 'findOneByChainIdAndEscrowAddress')
+        .mockResolvedValue(null);
+
+      await expect(jobService.pauseJob(webhook)).rejects.toThrow(
+        ErrorJob.NotFound,
+      );
+    });
+
+    it('should fail if job is not in Active status', async () => {
+      jest
+        .spyOn(jobRepository, 'findOneByChainIdAndEscrowAddress')
+        .mockResolvedValue({
+          chainId: chainId,
+          escrowAddress: escrowAddress,
+          status: JobStatus.CANCELED,
+        } as JobEntity);
+
+      await expect(jobService.pauseJob(webhook)).rejects.toThrow(
+        ErrorJob.InvalidStatus,
+      );
+    });
+  });
 });