fix: save creator

Author: rakibansary

src/common/CoreOperations.ts

@@ -25,7 +25,7 @@ import {
   UpdateType,
   Value as PartiQLValue,
 } from "../dal/models/nosql/parti_ql";
-import { StatusBuilder } from "@grpc/grpc-js";
+import { Metadata, StatusBuilder } from "@grpc/grpc-js";
 import { Status } from "@grpc/grpc-js/build/src/constants";
 
 export type ValueType =
@@ -150,7 +150,12 @@ abstract class CoreOperations<
     };
   }
 
-  protected async create(entity: I & T): Promise<T> {
+  protected async create(entity: I & T, metadata?: Metadata): Promise<T> {
+    let handle = null;
+    if (metadata?.get("handle") != null) {
+      handle = metadata?.get("handle")?.toString();
+    }
+
     const queryRequest: QueryRequest = {
       kind: {
         $case: "query",
@@ -159,7 +164,11 @@ abstract class CoreOperations<
             $case: "insert",
             insert: {
               table: this.entityName,
-              attributes: entity,
+              attributes: {
+                ...entity,
+                createdBy: handle != null ? handle : undefined,
+                updatedBy: handle != null ? handle : undefined,
+              },
             },
           },
         },

src/domain/Challenge.ts

@@ -61,7 +61,7 @@ import { ScanCriteria } from "../models/common/common";
 import constants from "../util/constants";
 import legacyMapper from "../util/LegacyMapper";
 import { CreateResult, Operator } from "@topcoder-framework/lib-common";
-import { StatusBuilder } from "@grpc/grpc-js";
+import { Metadata, StatusBuilder } from "@grpc/grpc-js";
 import { Status } from "@grpc/grpc-js/build/src/constants";
 import ChallengeScheduler from "../util/ChallengeScheduler";
 
@@ -151,7 +151,10 @@ class ChallengeDomain extends CoreOperations<Challenge, CreateChallengeInput> {
     return Challenge.fromJSON(item);
   }
 
-  public async create(input: CreateChallengeInput): Promise<Challenge> {
+  public async create(
+    input: CreateChallengeInput,
+    metadata: Metadata | undefined
+  ): Promise<Challenge> {
     input.name = xss(input.name);
 
     if (Array.isArray(input.discussions)) {
@@ -196,7 +199,7 @@ class ChallengeDomain extends CoreOperations<Challenge, CreateChallengeInput> {
         // prettier-ignore
         const legacyChallengeCreateInput = LegacyCreateChallengeInput.fromPartial(legacyMapper.mapChallengeDraftUpdateInput(input));
         // prettier-ignore
-        const legacyChallengeCreateResponse = await legacyChallengeDomain.create(legacyChallengeCreateInput);
+        const legacyChallengeCreateResponse = await legacyChallengeDomain.create(legacyChallengeCreateInput, metadata);
         if (legacyChallengeCreateResponse.kind?.$case === "integerId") {
           legacyChallengeId = legacyChallengeCreateResponse.kind.integerId;
         }
@@ -240,7 +243,7 @@ class ChallengeDomain extends CoreOperations<Challenge, CreateChallengeInput> {
         }) ?? [],
     };
 
-    return super.create(challenge);
+    return super.create(challenge, metadata);
   }
 
   async syncChallengePhases(

src/service/ChallengeService.ts

@@ -33,8 +33,8 @@ class ChallengeServerImpl implements ChallengeServer {
     call: ServerUnaryCall<CreateChallengeInput, Challenge>,
     callback: sendUnaryData<Challenge>
   ): Promise<void> => {
-    const { request: createChallengeInput } = call;
-    Domain.create(createChallengeInput)
+    const { request: createChallengeInput, metadata } = call;
+    Domain.create(createChallengeInput, metadata)
       .then((challenge) => callback(null, challenge))
       .catch((error) => callback(error, null));
   };