Add numOfRegistrants handling

Author: jmgasper

ReadMe.md

@@ -116,6 +116,7 @@ After that, please run
 ```bash
 export DATABASE_URL="postgresql://johndoe:mypassword@localhost:5532/resourceapi?schema=public&statement_timeout=60000"
 export MEMBER_DB_URL="postgresql://johndoe:mypassword@localhost:5632/memberdb"
+export CHALLENGE_DB_URL="postgresql://johndoe:mypassword@localhost:5732/challengedb"
 ```
 
 ### Create Tables

env.sh

@@ -29,3 +29,5 @@ export AUTH_SECRET=
 export DATABASE_URL="postgresql://johndoe:mypassword@localhost:5532/resourceapi?schema=public&statement_timeout=60000"
 
 export MEMBER_DB_URL="postgresql://johndoe:mypassword@localhost:5632/memberdb"
+
+export CHALLENGE_DB_URL="postgresql://johndoe:mypassword@localhost:5732/challengedb"

package.json

@@ -15,7 +15,8 @@
     "create-tables": "npx prisma migrate dev --schema=./prisma/schema.prisma",
     "prisma:generate:resource": "npx prisma generate --schema=./prisma/schema.prisma",
     "prisma:generate:member": "npx prisma generate --schema=./prisma/member-schema.prisma",
-    "prisma:generate": "npm run prisma:generate:resource && npm run prisma:generate:member",
+    "prisma:generate:challenge": "npx prisma generate --schema=./prisma/challenge-schema.prisma",
+    "prisma:generate": "npm run prisma:generate:resource && npm run prisma:generate:member && npm run prisma:generate:challenge",
     "drop-tables:test": "NODE_ENV=test npx prisma migrate reset",
     "clear-tables:test": "NODE_ENV=test node src/scripts/clear-tables.js",
     "create-tables:test": "NODE_ENV=test npx prisma migrate dev",

prisma/challenge-schema.prisma

@@ -0,0 +1,15 @@
+generator client {
+  provider = "prisma-client-js"
+  output   = "../node_modules/@prisma/client-challenge" // Relative path from this file to root node_modules
+}
+
+datasource db {
+  provider = "postgresql"
+  url      = env("CHALLENGE_DB_URL")
+}
+
+model Challenge {
+  id                String @id @default(uuid())
+  numOfRegistrants  Int    @default(0)
+}
+

src/common/helper.js

@@ -2,6 +2,7 @@
  * This file defines helper methods
  */
 const { PrismaClient } = require('@prisma/client-member')
+const { PrismaClient: ChallengePrismaClient } = require('@prisma/client-challenge')
 
 const _ = require('lodash')
 const config = require('config')
@@ -19,6 +20,7 @@ const busApiClient = busApi(_.pick(config, ['AUTH0_URL', 'AUTH0_AUDIENCE', 'TOKE
 
 const prisma = require('./prisma').getClient()
 const prismaMember = new PrismaClient()
+const prismaChallenge = new ChallengePrismaClient()
 
 /**
  * Check the error is custom error.
@@ -545,5 +547,7 @@ module.exports = {
   checkChallengeGroupAccess,
   checkAgreedTerms,
   postRequest,
-  advanceChallengePhase
+  advanceChallengePhase,
+  // Challenge DB client (exported for targeted updates)
+  prismaChallenge
 }

src/services/ResourceService.js

@@ -395,6 +395,17 @@ async function createResource (currentUser, resource) {
 
     logger.debug(`Created resource: ${JSON.stringify(ret)}`)
     await helper.postEvent(config.RESOURCE_CREATE_TOPIC, ret)
+    // Increment challenge registrants on submitter registration
+    if (resource.roleId === config.SUBMITTER_RESOURCE_ROLE_ID) {
+      try {
+        await helper.prismaChallenge.challenge.update({
+          where: { id: challengeId },
+          data: { numOfRegistrants: { increment: 1 } }
+        })
+      } catch (e) {
+        logger.warn(`Failed to increment numOfRegistrants for challenge ${challengeId}: ${e}`)
+      }
+    }
     if (!_.get(challenge, 'task.isTask', false) && resource.roleId === config.SUBMITTER_RESOURCE_ROLE_ID) {
       const forumUrl = _.get(challenge, 'discussions[0].url')
       let templateId = config.REGISTRATION_EMAIL.SENDGRID_TEMPLATE_ID
@@ -487,6 +498,17 @@ async function deleteResource (currentUser, resource) {
 
     logger.debug(`Deleted resource, posting to Bus API: ${JSON.stringify(ret)}`)
     await helper.postEvent(config.RESOURCE_DELETE_TOPIC, ret)
+    // Decrement challenge registrants on submitter unregistration
+    if (resource.roleId === config.SUBMITTER_RESOURCE_ROLE_ID) {
+      try {
+        await helper.prismaChallenge.challenge.update({
+          where: { id: challengeId },
+          data: { numOfRegistrants: { decrement: 1 } }
+        })
+      } catch (e) {
+        logger.warn(`Failed to decrement numOfRegistrants for challenge ${challengeId}: ${e}`)
+      }
+    }
     return ret
   } catch (err) {
     logger.error(`Delete Resource Error ${JSON.stringify(err)}`)