Merge branch 'develop'

Author: James Cori

config/default.js

@@ -78,6 +78,8 @@ module.exports = {
 
   COPILOT_PAYMENT_TYPE: process.env.COPILOT_PAYMENT_TYPE || 'copilot',
 
+  COPILOT_ROLE_ID: process.env.COPILOT_ROLE_ID || 'cfe12b3f-2a24-4639-9d8b-ec86726f76bd',
+
   // V5 Term UUID
   SYNC_V5_TERM_UUID: process.env.SYNC_V5_TERM_UUID || '317cd8f9-d66c-4f2a-8774-63c612d99cd4',
   SYNC_V5_WRITE_ENABLED: process.env.SYNC_V5_WRITE_ENABLED === 'true' || false

src/constants.js

@@ -45,10 +45,20 @@ const challengeStatuses = {
   CancelledZeroRegistrations: 'Cancelled - Zero Registrations'
 }
 
+const supportedMetadata = {
+  allowStockArt: 52,
+  drPoints: 30,
+  submissionViewable: 53,
+  submissionLimit: 51,
+  codeRepo: 85,
+  environment: 84
+}
+
 module.exports = {
   prizeSetTypes,
   EVENT_ORIGINATOR,
   EVENT_MIME_TYPE,
   createChallengeStatusesMap,
-  challengeStatuses
+  challengeStatuses,
+  supportedMetadata
 }

src/services/ProcessorService.js

@@ -14,6 +14,7 @@ const groupService = require('./groupsService')
 const termsService = require('./termsService')
 const copilotPaymentService = require('./copilotPaymentService')
 const timelineService = require('./timelineService')
+const metadataService = require('./metadataService')
 
 /**
  * Get group information by V5 UUID
@@ -107,16 +108,27 @@ async function associateChallengeTerms (v5Terms, legacyChallengeId, createdBy, u
 
 /**
  * Set the copilot payment on legacy
+ * @param {String} challengeId the V5 challenge ID
  * @param {Number|String} legacyChallengeId the legacy challenge ID
  * @param {Array} prizeSets the prizeSets array
  * @param {String} createdBy the created by handle
  * @param {String} updatedBy the updated by handle
+ * @param {String} m2mToken the m2m token
  */
-async function setCopilotPayment (legacyChallengeId, prizeSets = [], createdBy, updatedBy) {
+async function setCopilotPayment (challengeId, legacyChallengeId, prizeSets = [], createdBy, updatedBy, m2mToken) {
   try {
     const copilotPayment = _.get(_.find(prizeSets, p => p.type === config.COPILOT_PAYMENT_TYPE), 'prizes[0].value', null)
-    logger.debug(`Setting Copilot Payment: ${copilotPayment} for legacyId ${legacyChallengeId}`)
-    await copilotPaymentService.setCopilotPayment(legacyChallengeId, copilotPayment, createdBy, updatedBy)
+    if (copilotPayment) {
+      logger.debug('Fetching challenge copilot...')
+      const res = await helper.getRequest(`${config.V5_RESOURCES_API_URL}?challengeId=${challengeId}&roleId=${config.COPILOT_ROLE_ID}`, m2mToken)
+      const [copilotResource] = res.body
+      if (!copilotResource) {
+        logger.warn(`Copilot does not exist for challenge ${challengeId} (legacy: ${legacyChallengeId})`)
+        return
+      }
+      logger.debug(`Setting Copilot Payment: ${copilotPayment} for legacyId ${legacyChallengeId} for copilot ${copilotResource.memberId}`)
+      await copilotPaymentService.setCopilotPayment(legacyChallengeId, copilotPayment, createdBy, updatedBy)
+    }
   } catch (e) {
     logger.error('Failed to set the copilot payment!')
     logger.debug(e)
@@ -325,6 +337,21 @@ async function parsePayload (payload, m2mToken, isCreated = true, informixGroupI
       data.groupsToBeDeleted = _.map(informixGroupIds, g => _.toString(g))
     }
 
+    if (payload.metadata && payload.metadata.length > 0) {
+      const fileTypes = _.find(payload.metadata, meta => meta.name === 'fileTypes')
+      if (fileTypes) {
+        if (_.isArray(fileTypes.value)) {
+          data.fileTypes = fileTypes.value
+        } else {
+          try {
+            data.fileTypes = JSON.parse(fileTypes.value)
+          } catch (e) {
+            data.fileTypes = []
+          }
+        }
+      }
+    }
+
     return data
   } catch (err) {
     // Debugging
@@ -385,7 +412,7 @@ async function processCreate (message) {
     await helper.forceV4ESFeeder(newChallenge.body.result.content.id)
     await associateChallengeGroups(saveDraftContestDTO.groupsToBeAdded, saveDraftContestDTO.groupsToBeDeleted, newChallenge.body.result.content.id)
     // await associateChallengeTerms(saveDraftContestDTO.termsToBeAdded, saveDraftContestDTO.termsToBeRemoved, newChallenge.body.result.content.id)
-    await setCopilotPayment(newChallenge.body.result.content.id, _.get(message, 'payload.prizeSets'), _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy'))
+    await setCopilotPayment(challengeUuid, newChallenge.body.result.content.id, _.get(message, 'payload.prizeSets'), _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy'), m2mToken)
     await helper.patchRequest(`${config.V5_CHALLENGE_API_URL}/${challengeUuid}`, {
       legacy: {
         ...message.payload.legacy,
@@ -466,7 +493,7 @@ async function processUpdate (message) {
     return
   } else if (!message.payload.legacyId) {
     logger.debug('Legacy ID does not exist. Will create...')
-    return processCreate(message)
+    await processCreate(message)
   }
   const m2mToken = await helper.getM2MToken()
 
@@ -506,12 +533,45 @@ async function processUpdate (message) {
   const saveDraftContestDTO = await parsePayload(message.payload, m2mToken, false, v4GroupIds)
   // logger.debug('Parsed Payload', saveDraftContestDTO)
   try {
-    await helper.putRequest(`${config.V4_CHALLENGE_API_URL}/${message.payload.legacyId}`, { param: _.omit(saveDraftContestDTO, ['groupsToBeAdded', 'groupsToBeDeleted']) }, m2mToken)
+    try {
+      if (challenge) {
+        await helper.putRequest(`${config.V4_CHALLENGE_API_URL}/${message.payload.legacyId}`, { param: _.omit(saveDraftContestDTO, ['groupsToBeAdded', 'groupsToBeDeleted']) }, m2mToken)
+      }
+    } catch (e) {
+      logger.warn('Failed to update the challenge via the V4 API')
+      logger.error(e)
+    }
     await associateChallengeGroups(saveDraftContestDTO.groupsToBeAdded, saveDraftContestDTO.groupsToBeDeleted, message.payload.legacyId)
-    await associateChallengeTerms(message.payload.terms, message.payload.legacyId, _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy'))
-    await setCopilotPayment(message.payload.legacyId, _.get(message, 'payload.prizeSets'), _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy'))
-
-    if (message.payload.status) {
+    await associateChallengeTerms(message.payload.terms, message.payload.legacyId, _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy') || _.get(message, 'payload.createdBy'))
+    await setCopilotPayment(message.payload.id, message.payload.legacyId, _.get(message, 'payload.prizeSets'), _.get(message, 'payload.createdBy'), _.get(message, 'payload.updatedBy') || _.get(message, 'payload.createdBy'), m2mToken)
+
+    // Update metadata in IFX
+    if (message.payload.metadata && message.payload.metadata.length > 0) {
+      for (const metadataKey of _.keys(constants.supportedMetadata)) {
+        const entry = _.find(message.payload.metadata, meta => meta.name === metadataKey)
+        if (entry) {
+          if (metadataKey === 'submissionLimit') {
+            // data here is JSON stringified
+            try {
+              const parsedEntryValue = JSON.parse(entry.value)
+              if (parsedEntryValue.limit) {
+                entry.value = parsedEntryValue.count
+              } else {
+                entry.value = null
+              }
+            } catch (e) {
+              entry.value = null
+            }
+          }
+          try {
+            await metadataService.createOrUpdateMetadata(message.payload.legacyId, constants.supportedMetadata[metadataKey], entry.value, _.get(message, 'payload.updatedBy') || _.get(message, 'payload.createdBy'))
+          } catch (e) {
+            logger.warn(`Failed to set ${metadataKey} (${constants.supportedMetadata[metadataKey]})`)
+          }
+        }
+      }
+    }
+    if (message.payload.status && challenge) {
       // logger.info(`The status has changed from ${challenge.currentStatus} to ${message.payload.status}`)
       if (message.payload.status === constants.challengeStatuses.Active && challenge.currentStatus !== constants.challengeStatuses.Active) {
         logger.info('Activating challenge...')
@@ -532,7 +592,11 @@ async function processUpdate (message) {
         }
       }
     }
-    await helper.forceV4ESFeeder(message.payload.legacyId)
+    try {
+      await helper.forceV4ESFeeder(message.payload.legacyId)
+    } catch (e) {
+      logger.warn('Failed to call V4 ES Feeder')
+    }
   } catch (e) {
     logger.error('processUpdate Catch', e)
     throw e

src/services/copilotPaymentService.js

@@ -5,6 +5,7 @@ const helper = require('../common/helper')
 
 const COPILOT_PAYMENT_PROJECT_INFO_ID = 49
 const COPILOT_PAYMENT_RESOURCE_INFO_ID = 7
+const COPILOT_PAYMENT_TYPE_ID = 15
 const COPILOT_RESOURCE_ROLE_ID = 14
 
 const QUERY_GET_COPILOT_RESOURCE_FOR_CHALLENGE = `SELECT limit 1 resource_id as resourceid FROM resource WHERE project_id = %d AND resource_role_id = ${COPILOT_RESOURCE_ROLE_ID}`
@@ -32,6 +33,10 @@ const QUERY_DELETE_COPILOT_PAYMENT = `DELETE FROM project_info WHERE project_inf
 const QUERY_UPDATE_COPILOT_RESOURCE_PAYMENT = `UPDATE resource_info SET value = ?, modify_user = ?, modify_date = CURRENT WHERE resource_id = ? AND resource_info_type_id = ${COPILOT_PAYMENT_RESOURCE_INFO_ID}`
 // const QUERY_DELETE_COPILOT_RESOURCE_PAYMENT = `DELETE FROM resource_info WHERE resource_id = ? AND resource_info_type_id = ${COPILOT_PAYMENT_RESOURCE_INFO_ID}`
 
+const QUERY_SELECT_PAYMENT_TYPE = `SELECT value FROM resource_info WHERE resource_info_type_id = ${COPILOT_PAYMENT_TYPE_ID} AND resource_id = %d`
+const QUERY_INSERT_PAYMENT_TYPE = `INSERT INTO resource_info (resource_id, resource_info_type_id, value, create_user, create_date, modify_user, modify_date) VALUES (?, "${COPILOT_PAYMENT_TYPE_ID}", ?, ?, CURRENT, ?, CURRENT)`
+const QUERY_UPDATE_PAYMENT_TYPE = `UPDATE resource_info SET value = ?, modify_user = ?, modify_date = CURRENT WHERE resource_id = ? AND resource_info_type_id = ${COPILOT_PAYMENT_TYPE_ID}`
+
 /**
  * Prepare Informix statement
  * @param {Object} connection the Informix connection
@@ -58,6 +63,14 @@ async function setCopilotPayment (challengeLegacyId, amount, createdBy, updatedB
     const copilotResourceId = await getCopilotResourceId(connection, challengeLegacyId)
     const copilotPayment = await getCopilotPayment(connection, challengeLegacyId)
     if (amount != null && amount >= 0) {
+      // Make sure the payment type is set to manual
+      // TODO: Figure out why data is not saved in IFX even when there are no errors
+      // const paymentType = await getCopilotPaymentType(connection, copilotResourceId)
+      // if (!paymentType) {
+      //   await createCopilotPaymentType(connection, copilotResourceId, 'TRUE', updatedBy || createdBy)
+      // } else if (_.toLower(_.toString(paymentType.value)) !== 'true') {
+      //   await updateCopilotPaymentType(connection, copilotResourceId, 'TRUE', updatedBy || createdBy)
+      // }
       if (copilotPayment) {
         logger.debug(`Copilot payment exists, updating: ${challengeLegacyId}`)
         return updateCopilotPayment(connection, copilotResourceId, challengeLegacyId, amount, updatedBy)
@@ -78,6 +91,43 @@ async function setCopilotPayment (challengeLegacyId, amount, createdBy, updatedB
   }
 }
 
+/**
+ * Gets the copilot payment type for a legacyId
+ * @param {Object} connection the connection
+ * @param {Number} resourceId the resource ID
+ */
+async function getCopilotPaymentType (connection, resourceId) {
+  const result = await connection.queryAsync(util.format(QUERY_SELECT_PAYMENT_TYPE, resourceId))
+  logger.debug(`Result: ${JSON.stringify(result, null, 2)}`)
+  return _.get(result, '[0]', null)
+}
+
+/**
+ * Create the copilot payment type record
+ * @param {Object} connection the connection
+ * @param {Number} resourceId the resource ID
+ * @param {Boolean} value the value
+ * @param {String} createdBy the create user handle
+ */
+async function createCopilotPaymentType (connection, resourceId, value, createdBy) {
+  const query = await prepare(connection, QUERY_INSERT_PAYMENT_TYPE)
+  logger.debug(`Create Copilot Payment Type Values: ${[resourceId, value, createdBy, createdBy]}`)
+  await query.executeAsync([resourceId, value, createdBy, createdBy])
+}
+
+/**
+ * Update the copilot payment type record
+ * @param {Object} connection the connection
+ * @param {Number} resourceId the resource ID
+ * @param {Boolean} value the value
+ * @param {String} createdBy the create user handle
+ */
+async function updateCopilotPaymentType (connection, resourceId, value, createdBy) {
+  const query = await prepare(connection, QUERY_UPDATE_PAYMENT_TYPE)
+  logger.debug(`Update Copilot Payment Type Values: ${[value, createdBy, resourceId]}`)
+  await query.executeAsync([value, createdBy, resourceId])
+}
+
 /**
  * Gets the copilot payment for a legacyId
  * @param {Object} connection

src/services/metadataService.js

@@ -0,0 +1,89 @@
+/**
+ * Metadata Service
+ * Interacts with InformixDB
+ */
+const util = require('util')
+const logger = require('../common/logger')
+const helper = require('../common/helper')
+
+const QUERY_GET_ENTRY = 'SELECT value FROM project_info WHERE project_id = %d and project_info_type_id = %d'
+const QUERY_CREATE = 'INSERT INTO project_info (project_id, project_info_type_id, value, create_user, create_date, modify_user, modify_date) VALUES (?, ?, ?, ?, CURRENT, ?, CURRENT)'
+const QUERY_UPDATE = 'UPDATE project_info SET value = ?, modify_user = ?, modify_date = CURRENT WHERE project_info_type_id = ? AND project_id = ?'
+const QUERY_DELETE = 'DELETE FROM project_info WHERE project_id = ? and project_info_type_id = ?'
+
+/**
+ * Prepare Informix statement
+ * @param {Object} connection the Informix connection
+ * @param {String} sql the sql
+ * @return {Object} Informix statement
+ */
+async function prepare (connection, sql) {
+  // logger.debug(`Preparing SQL ${sql}`)
+  const stmt = await connection.prepareAsync(sql)
+  return Promise.promisifyAll(stmt)
+}
+
+/**
+ * Get project info entry entry
+ * @param {Number} challengeLegacyId the legacy challenge ID
+ * @param {Number} typeId the type ID
+ */
+async function getMetadataEntry (challengeLegacyId, typeId) {
+  // logger.debug(`Getting Groups for Challenge ${challengeLegacyId}`)
+  const connection = await helper.getInformixConnection()
+  let result = null
+  try {
+    result = await connection.queryAsync(util.format(QUERY_GET_ENTRY, challengeLegacyId, typeId))
+  } catch (e) {
+    logger.error(`Error in 'getMetadataEntry' ${e}`)
+    throw e
+  } finally {
+    await connection.closeAsync()
+  }
+  return result
+}
+
+/**
+ * Enable timeline notifications
+ * @param {Number} challengeLegacyId the legacy challenge ID
+ * @param {Number} typeId the type ID
+ * @param {Any} value the value
+ * @param {String} createdBy the created by
+ */
+async function createOrUpdateMetadata (challengeLegacyId, typeId, value, createdBy) {
+  const connection = await helper.getInformixConnection()
+  let result = null
+  try {
+    // await connection.beginTransactionAsync()
+    const [existing] = await getMetadataEntry(challengeLegacyId, typeId)
+    if (existing) {
+      if (value) {
+        logger.info(`Metadata ${typeId} exists. Will update`)
+        const query = await prepare(connection, QUERY_UPDATE)
+        result = await query.executeAsync([value, createdBy, typeId, challengeLegacyId])
+      } else {
+        logger.info(`Metadata ${typeId} exists. Will delete`)
+        const query = await prepare(connection, QUERY_DELETE)
+        result = await query.executeAsync([challengeLegacyId, typeId])
+      }
+    } else {
+      logger.info(`Metadata ${typeId} does not exist. Will create`)
+      const query = await prepare(connection, QUERY_CREATE)
+      result = await query.executeAsync([challengeLegacyId, typeId, value, createdBy, createdBy])
+    }
+    // await connection.commitTransactionAsync()
+    logger.info(`Metadata with typeId ${typeId} has been enabled for challenge ${challengeLegacyId}`)
+  } catch (e) {
+    logger.error(`Error in 'createOrUpdateMetadata' ${e}, rolling back transaction`)
+    await connection.rollbackTransactionAsync()
+    throw e
+  } finally {
+    await connection.closeAsync()
+  }
+  return result
+}
+
+module.exports = {
+  getMetadataEntry,
+  createOrUpdateMetadata
+}