add cluster matching sync timestamp and logs (#1913)

* add cluster matching sync timestamp and logs

* add nullability to clustermathicng syncAT

migration/1737544105947-addClusterMatchingSyncAtTimestamp.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner, TableColumn } from 'typeorm';
+
+export class addClusterMatchingSyncAtTimestamp1737544105947
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    const table = await queryRunner.getTable('qf_round');
+    const columnExists = table?.findColumnByName('clusterMatchingSyncAt');
+
+    if (!columnExists) {
+      await queryRunner.addColumn(
+        'qf_round',
+        new TableColumn({
+          name: 'clusterMatchingSyncAt',
+          type: 'timestamp',
+          isNullable: true,
+        }),
+      );
+    }
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.dropColumn('qf_round', 'clusterMatchingSyncAt');
+  }
+}

src/entities/qfRound.ts

@@ -126,6 +126,10 @@ export class QfRound extends BaseEntity {
   @Column({ default: false })
   isDataAnalysisDone: boolean;
 
+  @Field(_type => Date, { nullable: true })
+  @Column({ nullable: true })
+  clusterMatchingSyncAt?: Date;
+
   @UpdateDateColumn()
   updatedAt: Date;
 

src/services/cronJobs/syncEstimatedClusterMatchingJob.ts

@@ -56,6 +56,10 @@ export const fetchAndUpdateClusterEstimatedMatching = async () => {
       activeQfRound.id,
       matchingData,
     );
+
+    // Update latest job ran succesfully
+    activeQfRound.clusterMatchingSyncAt = new Date();
+    await activeQfRound.save();
   } catch (e) {
     logger.error('fetchAndUpdateClusterEstimatedMatching error', e);
   } finally {

src/workers/cocm/estimatedClusterMatchingWorker.ts

@@ -14,12 +14,20 @@ export type EstimatedClusterMatchingWorker =
 
 const worker: EstimatedClusterMatchingWorker = {
   async fetchEstimatedClusterMatching(matchingDataInput: any) {
-    return await getClusterMatchingAdapter().fetchEstimatedClusterMatchings(
-      matchingDataInput,
+    logger.debug('fetchEstimatedClusterMatching() has been called');
+    const matchingData =
+      await getClusterMatchingAdapter().fetchEstimatedClusterMatchings(
+        matchingDataInput,
+      );
+    logger.debug(
+      'fetchEstimatedClusterMatching() has worked with params',
+      String(matchingData),
     );
+    return matchingData;
   },
 
   async updateEstimatedClusterMatching(qfRoundId: number, matchingData: any) {
+    logger.debug('updateEstimatedClusterMatching() has been called');
     try {
       const params: any[] = [];
       const values = matchingData