October release challenge 1

topcoder-archive/topcoder-platform-topcoder-x-ui#44
topcoder-archive/topcoder-platform-topcoder-x-ui#61 (Major requirement)
topcoder-archive/topcoder-platform-topcoder-x-ui#42 (Major requirement)
topcoder-archive/topcoder-platform-topcoder-x-ui#43
topcoder-archive/topcoder-platform-topcoder-x-ui#77 (Major requirement)
topcoder-archive/topcoder-platform-topcoder-x-ui#66

Author: jmgasper

README.md

@@ -217,6 +217,7 @@ When an issue is closed it will first check if issue has any assignee or not,
   - closes the challenge with winner as assignee
   - you can verify the challenge closed in OR (link will be commented in same issue in git host)
   - issue label will be updated from configured paid and fix accepted label name
+- if there is no fix_accepted label or prize is zero then the challenge will cancelled
 
 You can see following logs
 ```

config/default.js

@@ -89,4 +89,5 @@ module.exports = {
   TC_OR_DETAIL_LINK: process.env.TC_OR_DETAIL_LINK || 'https://software.topcoder-dev.com/review/actions/ViewProjectDetails?pid=',
   RETRY_COUNT: process.env.RETRY_COUNT || 3,
   RETRY_INTERVAL: process.env.RETRY_INTERVAL || 120000, // 2 minutes
+  CANCEL_CHALLENGE_INTERVAL: process.env.CANCEL_CHALLENGE_INTERVAL || 20 * 1000,
 };

configuration.md

@@ -31,6 +31,7 @@ The following config parameters are supported, they are defined in `config/defau
 |RETRY_COUNT| the number of times an event should be retried to process| 3|
 |RETRY_INTERVAL| the interval at which the event should be retried to process in milliseconds | 120000|
 |READY_FOR_REVIEW_ISSUE_LABEL| the label name for ready for review, should be one of the label configured in topcoder x ui|'tcx_ReadyForReview'|
+|CANCEL_CHALLENGE_INTERVAL| the time in millisecond after which the challenge will be closed| '24*60*60*1000'|
 
 KAFKA_OPTIONS should be object as described in https://github.com/oleksiyk/kafka#ssl
 For using with SSL, the options should be as

models/Issue.js

@@ -27,7 +27,8 @@ const schema = new mongoose.Schema({
   // From topcoder api
   challengeId: {type: Number, required: false, unique: true},
   projectId: {type: mongoose.Schema.Types.ObjectId, ref: 'Project'},
-  status: {type: String}
+  status: {type: String},
+  assignedAt: {type: Date, required: false}
 });
 
 // Issue number, provider, repositoryId must be unique

models/Project.js

@@ -17,8 +17,9 @@ const schema = new mongoose.Schema({
   rocketChatWebhook: {type: String, required: false},
   rocketChatChannelName: {type: String, required: false},
   archived: {type: String, required: true},
-  username: {type: String, required: true},
-  secretWebhookKey: {type: String, required: true}
+  owner: {type: String, required: true},
+  secretWebhookKey: {type: String, required: true},
+  copilot: {type: String, required: true}
 });
 
 schema.index({tcDirectId: 1});

services/CopilotPaymentService.js

@@ -64,7 +64,7 @@ async function getExistingChallengeIdIfExists(event, dbPayment) {
   // check if there is existing active challenge associated with this project
   const existingPayments = await CopilotPayment.findOne({
     project: dbPayment.project,
-    username: event.data.copilot.handle,
+    username: event.project.copilot,
     closed: false,
     challengeId: {
       $gt: 0
@@ -135,7 +135,7 @@ async function _checkAndReSchedule(event, payment) {
   // get all unclosed payments for given project and user
   const existingPending = await CopilotPayment.find({
     project: payment.project,
-    username: event.data.copilot.handle,
+    username: event.project.copilot,
     closed: false,
     status: 'challenge_creation_pending'
   });
@@ -158,7 +158,7 @@ async function _checkAndReSchedule(event, payment) {
  * @private
  */
 async function handlePaymentAdd(event, payment) {
-  const copilot = event.data.copilot;
+  const copilot = {handle: event.project.copilot};
 
   payment = await getExistingChallengeIdIfExists(event, payment);
   if (!_.isNil(payment.challengeId)) {
@@ -232,7 +232,7 @@ async function handlePaymentAdd(event, payment) {
  * @private
  */
 async function handlePaymentUpdate(event, payment) {
-  const copilot = event.data.copilot;
+  const copilot = {handle: event.project.copilot};
   await _updateChallenge(copilot.handle, payment.project, payment.challengeId);
   logger.debug(`updated payment for challenge ${payment.challengeId} successful.`);
 }
@@ -245,7 +245,7 @@ async function handlePaymentUpdate(event, payment) {
  * @private
  */
 async function handlePaymentDelete(event, payment) {
-  const copilot = event.data.copilot;
+  const copilot = {handle: event.project.copilot};
   await _updateChallenge(copilot.handle, payment.project, payment.challengeId);
   logger.debug(`updated payment for challenge ${payment.challengeId} successful.`);
 }
@@ -255,11 +255,16 @@ async function handlePaymentDelete(event, payment) {
  * @param {Object} event the event
  */
 async function handlePaymentUpdates(event) {
-  const copilot = event.data.copilot;
+  const projectIds = await Project.find({
+    $or: [
+      {owner: event.copilot.handle},
+      {copilot: event.copilot.handle}
+    ]
+  }).select('_id');
 
   // get all unclosed payments for current user
   const dbPayments = await CopilotPayment.find({
-    username: copilot.handle,
+    project: {$in: projectIds},
     closed: false
   });
   if (dbPayments) {
@@ -269,7 +274,7 @@ async function handlePaymentUpdates(event) {
       const challengeId = challengeIds[i];
       const challengeDetail = await topcoderApiHelper.getChallengeById(challengeId);
       if (challengeDetail && challengeDetail.currentStatus === 'Completed') {
-        await CopilotPayment.updateMany({challengeId, username: copilot.handle, closed: false}, {closed: true});
+        await CopilotPayment.updateMany({challengeId, closed: false}, {closed: true});
       }
     }
     logger.debug('Success updating payments status.');
@@ -293,6 +298,9 @@ async function process(event) {
   if (_.isNil(payment.challengeId)) {
     delete payment.challengeId;
   }
+  if (payment.project) {
+    event.project = await Project.findById(payment.project);
+  }
   if (event.event === 'copilotPayment.add') {
     await handlePaymentAdd(event, payment);
   } else if (event.event === 'copilotPayment.update') {

services/IssueService.js

@@ -255,7 +255,8 @@ async function handleIssueAssignment(event, issue) {
       logger.debug(`Assigning user to challenge: ${userMapping.topcoderUsername}`);
       topcoderApiHelper.assignUserAsRegistrant(topcoderUserId, dbIssue.challengeId);
       dbIssue.set({
-        assignee: issue.assignee
+        assignee: issue.assignee,
+        assignedAt: new Date()
       });
       await dbIssue.save();
       // remove open for pickup and add assigned
@@ -381,6 +382,7 @@ async function handleIssueClose(event, issue) {
   try {
     dbIssue = await ensureChallengeExists(event, issue);
     if (!event.paymentSuccessful) {
+      let closeChallenge = false;
       // if issue is closed without Fix accepted label
       if (!_.includes(event.data.issue.labels, config.FIX_ACCEPTED_ISSUE_LABEL)) {
         logger.debug(`This issue ${issue.number} is closed without fix accepted label.`);
@@ -391,9 +393,13 @@ async function handleIssueClose(event, issue) {
         } else {
           await gitlabService.createComment(event.copilot, event.data.repository.id, issue.number, comment);
         }
-        return;
+        closeChallenge = true;
+      }
+      if (issue.prizes[0] === 0) {
+        closeChallenge = true;
       }
 
+
       // if issue is closed without assignee then do nothing
       if (!event.data.assignee.id) {
         logger.debug(`This issue ${issue.number} doesn't have assignee so ignoring this event.`);
@@ -453,7 +459,14 @@ async function handleIssueClose(event, issue) {
 
       // activate challenge
       await topcoderApiHelper.activateChallenge(dbIssue.challengeId);
-
+      if (closeChallenge) {
+        logger.debug(`The associated challenge ${dbIssue.challengeId} is scheduled for cancel`);
+        setTimeout(async () => {
+          await topcoderApiHelper.cancelPrivateContent(dbIssue.challengeId);
+          logger.debug(`The challenge ${dbIssue.challengeId} is deleted`);
+        }, config.CANCEL_CHALLENGE_INTERVAL); //eslint-disable-line
+        return;
+      }
       logger.debug(`close challenge with winner ${assigneeMember.topcoderUsername}(${winnerId})`);
       await topcoderApiHelper.closeChallenge(dbIssue.challengeId, winnerId);
       event.paymentSuccessful = true;
@@ -615,7 +628,8 @@ async function handleIssueUnAssignment(event, issue) {
     return;
   }
   dbIssue.set({
-    assignee: null
+    assignee: null,
+    assignedAt: null
   });
   await dbIssue.save();
 }

services/UserService.js

@@ -67,13 +67,13 @@ async function getRepositoryCopilot(provider, repoFullName) {
     repoUrl: fullRepoUrl
   });
 
-  if (!project || !project.username) {
+  if (!project || !project.owner || !project.copilot) {
     // throw this repo is not managed by Topcoder x tool
     throw new Error(`This repository '${repoFullName}' is not managed by Topcoder X tool.`);
   }
 
   const userMapping = await models.UserMapping.findOne({
-    topcoderUsername: project.username.toLowerCase()
+    topcoderUsername: project.copilot.toLowerCase()
   });
 
   if (!userMapping || (provider === 'github' && !userMapping.githubUserId) || (provider === 'gitlab' && !userMapping.gitlabUserId)) {