From d241c5bdf19a382efe137638573d67b751f64300 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Francisco=20L=C3=B3pez?= Date: Thu, 22 May 2025 12:55:51 +0200 Subject: [PATCH] Refactor job creation to move webhook entity creation from fund to setup --- .../server/src/modules/job/job.service.ts | 26 +++++++++---------- 1 file changed, 12 insertions(+), 14 deletions(-) diff --git a/packages/apps/job-launcher/server/src/modules/job/job.service.ts b/packages/apps/job-launcher/server/src/modules/job/job.service.ts index 8b3085f130..d34a6a07c5 100644 --- a/packages/apps/job-launcher/server/src/modules/job/job.service.ts +++ b/packages/apps/job-launcher/server/src/modules/job/job.service.ts @@ -376,6 +376,17 @@ export class JobService { jobEntity.status = JobStatus.LAUNCHED; await this.jobRepository.updateOne(jobEntity); + const oracleType = this.getOracleType(jobEntity.requestType); + const webhookEntity = new WebhookEntity(); + Object.assign(webhookEntity, { + escrowAddress: jobEntity.escrowAddress, + chainId: jobEntity.chainId, + eventType: EventType.ESCROW_CREATED, + oracleType: oracleType, + hasSignature: oracleType !== OracleType.HCAPTCHA ? true : false, + }); + await this.webhookRepository.createUnique(webhookEntity); + return jobEntity; } @@ -397,20 +408,7 @@ export class JobService { }); jobEntity.status = JobStatus.FUNDED; - await this.jobRepository.updateOne(jobEntity); - - const oracleType = this.getOracleType(jobEntity.requestType); - const webhookEntity = new WebhookEntity(); - Object.assign(webhookEntity, { - escrowAddress: jobEntity.escrowAddress, - chainId: jobEntity.chainId, - eventType: EventType.ESCROW_CREATED, - oracleType: oracleType, - hasSignature: oracleType !== OracleType.HCAPTCHA ? true : false, - }); - await this.webhookRepository.createUnique(webhookEntity); - - return jobEntity; + return this.jobRepository.updateOne(jobEntity); } public async requestToCancelJobById(