Skip to content

Commit c1f8bee

Browse files
committed
fix: assigning metadata
Signed-off-by: Rakib Ansary <rakibansary@gmail.com>
1 parent 5b1bc09 commit c1f8bee

File tree

3 files changed

+27
-21
lines changed

3 files changed

+27
-21
lines changed

package.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
"prettier": "^2.8.1"
4141
},
4242
"dependencies": {
43+
"@grpc/grpc-js": "^1.8.12",
4344
"@opensearch-project/opensearch": "^2.2.0",
4445
"@topcoder-framework/domain-challenge": "^0.7.3",
4546
"@topcoder-framework/lib-common": "^0.7.3",

src/services/ChallengeService.js

Lines changed: 25 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@ const phaseHelper = require("../common/phase-helper");
3030
const projectHelper = require("../common/project-helper");
3131
const challengeHelper = require("../common/challenge-helper");
3232

33+
const { Metadata: GrpcMetadata } = require("@grpc/grpc-js");
34+
3335
const esClient = helper.getESClient();
3436

3537
const { ChallengeDomain } = require("@topcoder-framework/domain-challenge");
@@ -1187,10 +1189,12 @@ async function createChallenge(currentUser, challenge, userToken) {
11871189
value: typeof m.value === "string" ? m.value : JSON.stringify(m.value),
11881190
}));
11891191

1190-
const ret = await challengeDomain.create(challenge, {
1191-
handle: currentUser.handle,
1192-
userId: currentUser.userId,
1193-
});
1192+
const grpcMetadata = new GrpcMetadata();
1193+
1194+
grpcMetadata.set("handle", currentUser.handle);
1195+
grpcMetadata.set("userId", currentUser.userId);
1196+
1197+
const ret = await challengeDomain.create(challenge, grpcMetadata);
11941198

11951199
ret.numOfSubmissions = 0;
11961200
ret.numOfRegistrants = 0;
@@ -1238,25 +1242,26 @@ async function createChallenge(currentUser, challenge, userToken) {
12381242
});
12391243

12401244
// Create in ES
1241-
await esClient.create({
1242-
index: config.get("ES.ES_INDEX"),
1243-
type: config.get("ES.OPENSEARCH") == "false" ? config.get("ES.ES_TYPE") : undefined,
1244-
refresh: config.get("ES.ES_REFRESH"),
1245-
id: ret.id,
1246-
body: ret,
1247-
});
1245+
// await esClient.create({
1246+
// index: config.get("ES.ES_INDEX"),
1247+
// type: config.get("ES.OPENSEARCH") == "false" ? config.get("ES.ES_TYPE") : undefined,
1248+
// refresh: config.get("ES.ES_REFRESH"),
1249+
// id: ret.id,
1250+
// body: ret,
1251+
// });
12481252

12491253
// If the challenge is self-service, add the creating user as the "client manager", *not* the manager
12501254
// This is necessary for proper handling of the vanilla embed on the self-service work item dashboard
1251-
if (challenge.legacy.selfService) {
1252-
if (currentUser.handle) {
1253-
await helper.createResource(ret.id, ret.createdBy, config.CLIENT_MANAGER_ROLE_ID);
1254-
}
1255-
} else {
1256-
if (currentUser.handle) {
1257-
await helper.createResource(ret.id, ret.createdBy, config.MANAGER_ROLE_ID);
1258-
}
1259-
}
1255+
1256+
// if (challenge.legacy.selfService) {
1257+
// if (currentUser.handle) {
1258+
// await helper.createResource(ret.id, ret.createdBy, config.CLIENT_MANAGER_ROLE_ID);
1259+
// }
1260+
// } else {
1261+
// if (currentUser.handle) {
1262+
// await helper.createResource(ret.id, ret.createdBy, config.MANAGER_ROLE_ID);
1263+
// }
1264+
// }
12601265

12611266
// post bus event
12621267
await helper.postBusEvent(constants.Topics.ChallengeCreated, ret);

yarn.lock

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@
125125
enabled "2.0.x"
126126
kuler "^2.0.0"
127127

128-
"@grpc/grpc-js@^1.8.0":
128+
"@grpc/grpc-js@^1.8.0", "@grpc/grpc-js@^1.8.12":
129129
version "1.8.12"
130130
resolved "https://registry.yarnpkg.com/@grpc/grpc-js/-/grpc-js-1.8.12.tgz#bc0120859e8b153db764b473cc019ddf6bb2b414"
131131
integrity sha512-MbUMvpVvakeKhdYux6gbSIPJaFMLNSY8jw4PqLI+FFztGrQRrYYAnHlR94+ncBQQewkpXQaW449m3tpH/B/ZnQ==

0 commit comments

Comments
 (0)