Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

Commit f41df8c

Browse files
veshuveshu
committed
fix for #36 
1 parent 365e926 commit f41df8c

File tree

2 files changed

+60
-46
lines changed

2 files changed

+60
-46
lines changed

‎services/GithubService.js

Lines changed: 47 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,19 @@ const copilotUserSchema = Joi.object().keys({
2222
topcoderUsername: Joi.string()
2323
}).required();
2424

25+
/**
26+
* parse the repository name and repoFullName owner
27+
* @param {String} fullName the full repository name
28+
* @returns {Object} the parsed data
29+
* @private
30+
*/
31+
function _parseRepoUrl(fullName) {
32+
const results = fullName.split('/');
33+
const repo = results[results.length - 1];
34+
const owner = _(results).slice(0, results.length - 1).join('/');
35+
return {owner, repo};
36+
}
37+
2538
/**
2639
* authenticate the github using access token
2740
* @param {String} accessToken the access token of copilot
@@ -79,14 +92,14 @@ async function _getUsernameById(github, id) {
7992
/**
8093
* updates the title of github issue
8194
* @param {Object} copilot the copilot
82-
* @param {string} repo the repository
95+
* @param {string} repoFullName the repository
8396
* @param {Number} number the issue number
8497
* @param {string} title new title
8598
*/
86-
async function updateIssue(copilot, repo, number, title) {
87-
Joi.attempt({copilot, repo, number, title}, updateIssue.schema);
99+
async function updateIssue(copilot, repoFullName, number, title) {
100+
Joi.attempt({copilot, repoFullName, number, title}, updateIssue.schema);
88101
const github = await _authenticate(copilot.accessToken);
89-
const owner = await _getUsernameById(github, copilot.userProviderId);
102+
const {owner, repo} = _parseRepoUrl(repoFullName);
90103
try {
91104
await github.issues.edit({owner, repo, number, title});
92105
} catch (err) {
@@ -97,22 +110,22 @@ async function updateIssue(copilot, repo, number, title) {
97110

98111
updateIssue.schema = {
99112
copilot: copilotUserSchema,
100-
repo: Joi.string().required(),
113+
repoFullName: Joi.string().required(),
101114
number: Joi.number().required(),
102115
title: Joi.string().required()
103116
};
104117

105118
/**
106119
* Assigns the issue to user
107120
* @param {Object} copilot the copilot
108-
* @param {string} repo the repository
121+
* @param {string} repoFullName the repository
109122
* @param {Number} number the issue number
110123
* @param {string} user the user login of assignee
111124
*/
112-
async function assignUser(copilot, repo, number, user) {
113-
Joi.attempt({copilot, repo, number, user}, assignUser.schema);
125+
async function assignUser(copilot, repoFullName, number, user) {
126+
Joi.attempt({copilot, repoFullName, number, user}, assignUser.schema);
114127
const github = await _authenticate(copilot.accessToken);
115-
const owner = await _getUsernameById(github, copilot.userProviderId);
128+
const {owner, repo} = _parseRepoUrl(repoFullName);
116129
try {
117130
const issue = await github.issues.get({owner, repo, number});
118131

@@ -129,23 +142,23 @@ async function assignUser(copilot, repo, number, user) {
129142

130143
assignUser.schema = {
131144
copilot: copilotUserSchema,
132-
repo: Joi.string().required(),
145+
repoFullName: Joi.string().required(),
133146
number: Joi.number().required(),
134147
user: Joi.string().required()
135148
};
136149

137150
/**
138151
* Removes an assignee from the issue
139152
* @param {Object} copilot the copilot
140-
* @param {string} repo the repository
153+
* @param {string} repoFullName the repository
141154
* @param {Number} number the issue number
142155
* @param {string} user the user login of assignee
143156
*/
144-
async function removeAssign(copilot, repo, number, user) {
145-
Joi.attempt({copilot, repo, number, user}, removeAssign.schema);
157+
async function removeAssign(copilot, repoFullName, number, user) {
158+
Joi.attempt({copilot, repoFullName, number, user}, removeAssign.schema);
146159

147160
const github = await _authenticate(copilot.accessToken);
148-
const owner = await _getUsernameById(github, copilot.userProviderId);
161+
const {owner, repo} = _parseRepoUrl(repoFullName);
149162
await _removeAssignees(github, owner, repo, number, [user]);
150163
logger.debug(`Github user ${user} is unassigned from issue number ${number}`);
151164
}
@@ -155,15 +168,15 @@ removeAssign.schema = assignUser.schema;
155168
/**
156169
* creates the comments on github issue
157170
* @param {Object} copilot the copilot
158-
* @param {string} repo the repository
171+
* @param {string} repoFullName the repository
159172
* @param {Number} number the issue number
160173
* @param {string} body the comment body text
161174
*/
162-
async function createComment(copilot, repo, number, body) {
163-
Joi.attempt({copilot, repo, number, body}, createComment.schema);
175+
async function createComment(copilot, repoFullName, number, body) {
176+
Joi.attempt({copilot, repoFullName, number, body}, createComment.schema);
164177

165178
const github = await _authenticate(copilot.accessToken);
166-
const owner = await _getUsernameById(github, copilot.userProviderId);
179+
const {owner, repo} = _parseRepoUrl(repoFullName);
167180
try {
168181
await github.issues.createComment({owner, repo, number, body});
169182
} catch (err) {
@@ -174,7 +187,7 @@ async function createComment(copilot, repo, number, body) {
174187

175188
createComment.schema = {
176189
copilot: copilotUserSchema,
177-
repo: Joi.string().required(),
190+
repoFullName: Joi.string().required(),
178191
number: Joi.number().required(),
179192
body: Joi.string().required()
180193
};
@@ -218,14 +231,14 @@ getUserIdByLogin.schema = {
218231
/**
219232
* updates the github issue as paid and fix accepted
220233
* @param {Object} copilot the copilot
221-
* @param {string} repo the repository
234+
* @param {string} repoFullName the repository
222235
* @param {Number} number the issue number
223236
* @param {Number} challengeId the challenge id
224237
*/
225-
async function markIssueAsPaid(copilot, repo, number, challengeId) {
226-
Joi.attempt({copilot, repo, number, challengeId}, markIssueAsPaid.schema);
238+
async function markIssueAsPaid(copilot, repoFullName, number, challengeId) {
239+
Joi.attempt({copilot, repoFullName, number, challengeId}, markIssueAsPaid.schema);
227240
const github = await _authenticate(copilot.accessToken);
228-
const owner = await _getUsernameById(github, copilot.userProviderId);
241+
const {owner, repo} = _parseRepoUrl(repoFullName);
229242
const labels = [config.PAID_ISSUE_LABEL, config.FIX_ACCEPTED_ISSUE_LABEL];
230243
try {
231244
await github.issues.edit({owner, repo, number, labels});
@@ -239,22 +252,22 @@ async function markIssueAsPaid(copilot, repo, number, challengeId) {
239252

240253
markIssueAsPaid.schema = {
241254
copilot: copilotUserSchema,
242-
repo: Joi.string().required(),
255+
repoFullName: Joi.string().required(),
243256
number: Joi.number().required(),
244257
challengeId: Joi.number().positive().required()
245258
};
246259

247260
/**
248261
* change the state of github issue
249262
* @param {Object} copilot the copilot
250-
* @param {string} repo the repository
263+
* @param {string} repoFullName the repository
251264
* @param {Number} number the issue number
252265
* @param {string} state new state
253266
*/
254-
async function changeState(copilot, repo, number, state) {
255-
Joi.attempt({copilot, repo, number, state}, changeState.schema);
267+
async function changeState(copilot, repoFullName, number, state) {
268+
Joi.attempt({copilot, repoFullName, number, state}, changeState.schema);
256269
const github = await _authenticate(copilot.accessToken);
257-
const owner = await _getUsernameById(github, copilot.userProviderId);
270+
const {owner, repo} = _parseRepoUrl(repoFullName);
258271
try {
259272
await github.issues.edit({owner, repo, number, state});
260273
} catch (err) {
@@ -265,22 +278,22 @@ async function changeState(copilot, repo, number, state) {
265278

266279
changeState.schema = {
267280
copilot: copilotUserSchema,
268-
repo: Joi.string().required(),
281+
repoFullName: Joi.string().required(),
269282
number: Joi.number().required(),
270283
state: Joi.string().required()
271284
};
272285

273286
/**
274287
* updates the github issue with new labels
275288
* @param {Object} copilot the copilot
276-
* @param {string} repo the repository
289+
* @param {string} repoFullName the repository
277290
* @param {Number} number the issue number
278291
* @param {Number} labels the challenge id
279292
*/
280-
async function addLabels(copilot, repo, number, labels) {
281-
Joi.attempt({copilot, repo, number, labels}, addLabels.schema);
293+
async function addLabels(copilot, repoFullName, number, labels) {
294+
Joi.attempt({copilot, repoFullName, number, labels}, addLabels.schema);
282295
const github = await _authenticate(copilot.accessToken);
283-
const owner = await _getUsernameById(github, copilot.userProviderId);
296+
const {owner, repo} = _parseRepoUrl(repoFullName);
284297
try {
285298
await github.issues.edit({owner, repo, number, labels});
286299
} catch (err) {
@@ -291,7 +304,7 @@ async function addLabels(copilot, repo, number, labels) {
291304

292305
addLabels.schema = {
293306
copilot: copilotUserSchema,
294-
repo: Joi.string().required(),
307+
repoFullName: Joi.string().required(),
295308
number: Joi.number().required(),
296309
labels: Joi.array().items(Joi.string()).required()
297310
};

‎services/IssueService.js

Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ async function handleEventGracefully(event, issue, err) {
6565
// reschedule event
6666
if (event.retryCount <= config.RETRY_COUNT) {
6767
logger.debug('Scheduling event for next retry');
68-
const newEvent = { ...event };
68+
const newEvent = {...event};
6969
newEvent.retryCount += 1;
7070
delete newEvent.copilot;
7171
setTimeout(async () => {
@@ -82,7 +82,7 @@ async function handleEventGracefully(event, issue, err) {
8282
}
8383
// notify error in git host
8484
if (event.provider === 'github') {
85-
await gitHubService.createComment(event.copilot, event.data.repository.name, issue.number, comment);
85+
await gitHubService.createComment(event.copilot, event.data.repository.full_name, issue.number, comment);
8686
} else {
8787
await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
8888
}
@@ -93,7 +93,7 @@ async function handleEventGracefully(event, issue, err) {
9393
// ensure label is ready for review
9494
const readyForReviewLabels = [config.READY_FOR_REVIEW_ISSUE_LABEL];
9595
if (event.provider === 'github') {
96-
await gitHubService.addLabels(event.copilot, event.data.repository.name, issue.number, readyForReviewLabels);
96+
await gitHubService.addLabels(event.copilot, event.data.repository.full_name, issue.number, readyForReviewLabels);
9797
} else {
9898
await gitlabService.addLabels(event.copilot, event.data.repository.id, issue.number, readyForReviewLabels);
9999
}
@@ -105,6 +105,7 @@ async function handleEventGracefully(event, issue, err) {
105105

106106
/**
107107
* check if challenge is exists for given issue in db/topcoder
108+
* @param {Object} event the event
108109
* @param {Object} issue the issue
109110
* @returns {Object} the found db issue if exists
110111
* @private
@@ -177,7 +178,7 @@ async function assignUserAsRegistrant(topcoderUserId, challengeId) {
177178
*/
178179
async function reOpenIssue(event, issue) {
179180
if (event.provider === 'github') {
180-
await gitHubService.changeState(event.copilot, event.data.repository.name, issue.number, 'open');
181+
await gitHubService.changeState(event.copilot, event.data.repository.full_name, issue.number, 'open');
181182
} else {
182183
await gitlabService.changeState(event.copilot, event.data.repository.id, issue.number, 'reopen');
183184
}
@@ -202,9 +203,9 @@ async function rollbackAssignee(event, assigneeUserId, issue, reOpen = false) {
202203
// comment on the git ticket for the user to self-sign up with the Topcoder x Self-Service tool
203204
const comment = `@${assigneeUsername}, please sign-up with Topcoder X tool`;
204205
if (event.provider === 'github') {
205-
await gitHubService.createComment(event.copilot, event.data.repository.name, issue.number, comment);
206+
await gitHubService.createComment(event.copilot, event.data.repository.full_name, issue.number, comment);
206207
// un-assign the user from the ticket
207-
await gitHubService.removeAssign(event.copilot, event.data.repository.name, issue.number, assigneeUsername);
208+
await gitHubService.removeAssign(event.copilot, event.data.repository.full_name, issue.number, assigneeUsername);
208209
} else {
209210
await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
210211
// un-assign the user from the ticket
@@ -285,7 +286,7 @@ async function handleIssueAssignment(event, issue) {
285286
const contestUrl = getUrlForChallengeId(dbIssue.challengeId);
286287
const comment = `Contest ${contestUrl} has been updated - it has been assigned to ${userMapping.topcoderUsername}.`;
287288
if (event.provider === 'github') {
288-
await gitHubService.createComment(event.copilot, event.data.repository.name, issue.number, comment);
289+
await gitHubService.createComment(event.copilot, event.data.repository.full_name, issue.number, comment);
289290
} else {
290291
await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
291292
}
@@ -314,15 +315,15 @@ async function handleIssueComment(event, issue) {
314315
logger.debug(`updating issue: ${event.data.repository.name}/${issue.number}`);
315316

316317
if (event.provider === 'github') {
317-
await gitHubService.updateIssue(event.copilot, event.data.repository.name, issue.number, newTitle);
318+
await gitHubService.updateIssue(event.copilot, event.data.repository.full_name, issue.number, newTitle);
318319
} else {
319320
await gitlabService.updateIssue(event.copilot, event.data.repository.id, issue.number, newTitle);
320321
}
321322

322323
// assign user
323324
logger.debug(`assigning user, ${parsedComment.assignedUser} to issue: ${event.data.repository.name}/${issue.number}`);
324325
if (event.provider === 'github') {
325-
await gitHubService.assignUser(event.copilot, event.data.repository.name, issue.number, parsedComment.assignedUser);
326+
await gitHubService.assignUser(event.copilot, event.data.repository.full_name, issue.number, parsedComment.assignedUser);
326327
} else {
327328
const userId = await gitlabService.getUserIdByLogin(event.copilot, parsedComment.assignedUser);
328329
await gitlabService.assignUser(event.copilot, event.data.repository.id, issue.number, userId);
@@ -370,7 +371,7 @@ async function handleIssueUpdate(event, issue) {
370371
const contestUrl = getUrlForChallengeId(dbIssue.challengeId);
371372
const comment = `Contest ${contestUrl} has been updated - the new changes has been updated for this ticket.`;
372373
if (event.provider === 'github') {
373-
await gitHubService.createComment(event.copilot, event.data.repository.name, issue.number, comment);
374+
await gitHubService.createComment(event.copilot, event.data.repository.full_name, issue.number, comment);
374375
} else {
375376
await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
376377
}
@@ -461,7 +462,7 @@ async function handleIssueClose(event, issue) {
461462
try {
462463
logger.debug('update issue as paid');
463464
if (event.provider === 'github') {
464-
await gitHubService.markIssueAsPaid(event.copilot, event.data.repository.name, issue.number, dbIssue.challengeId);
465+
await gitHubService.markIssueAsPaid(event.copilot, event.data.repository.full_name, issue.number, dbIssue.challengeId);
465466
} else {
466467
await gitlabService.markIssueAsPaid(event.copilot, event.data.repository.id, issue.number, dbIssue.challengeId);
467468
}
@@ -520,7 +521,7 @@ async function handleIssueCreate(event, issue) {
520521
const contestUrl = getUrlForChallengeId(issue.challengeId);
521522
const comment = `Contest ${contestUrl} has been created for this ticket.`;
522523
if (event.provider === 'github') {
523-
await gitHubService.createComment(event.copilot, event.data.repository.name, issue.number, comment);
524+
await gitHubService.createComment(event.copilot, event.data.repository.full_name, issue.number, comment);
524525
} else {
525526
await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
526527
}

0 commit comments

Comments
 (0)