:sparkles: add endpoint to respond to UNANSWERED survey questions

backend/lib/plugins/profile.js

@@ -8,6 +8,7 @@ const ProfileService = require('../services/profile')
 
 const ProfileScoreRoute = require('../routes/profile/score')
 const ProfileUpdateRoute = require('../routes/profile/update')
+const ProfileRespondRoute = require('../routes/profile/respond')
 
 module.exports = {
     name: 'profile-plugin',
@@ -26,6 +27,7 @@ module.exports = {
         server.registerService(ProfileService)
 
         await server.route(ProfileScoreRoute)
+        await server.route(ProfileRespondRoute)
         await server.route(ProfileUpdateRoute)
     },
 }

backend/lib/routes/membership/active.js

@@ -18,7 +18,7 @@ const validators = {
     params: Joi.object({ profile_id: Joi.number() }),
 
     /** Validate the route query (/active/{thing}?limit=10&offset=10) */
-    // query: true,
+    query: Joi.object({ type: Joi.string().lowercase().min(6).max(11) }),
 
     /** Validate the incoming payload (POST method) */
     // payload: true,
@@ -43,9 +43,12 @@ module.exports = {
 
         handler: async function (request, h) {
             const { membershipService } = request.services()
+            const membershipType = request.query.type
+
             const profileId = request.params.profile_id
             const groupings = await membershipService.findGroupingsById(
                 profileId,
+                membershipType
             )
             try {
                 return {

backend/lib/routes/profile/respond.js

@@ -0,0 +1,109 @@
+'use strict'
+
+const Joi = require('joi')
+const profile = require('../../plugins/profile')
+
+const pluginConfig = {
+    handlerType: 'profile',
+    docs: {
+        description: 'Update profile',
+        notes: 'Update profile responses',
+    },
+}
+
+const responseSchemas = {
+    responses: Joi.array().items(
+        Joi.object({
+            response_id: Joi.number().required(),
+            profile_id: Joi.number().required(),
+            response_key_id: Joi.number().required(),
+            val: Joi.string().required(),
+        }),
+    ),
+    error: Joi.object({
+        error: Joi.string(),
+    }),
+}
+
+const validators = {
+    /** Validate the header (cookie check) */
+    // headers: true,
+
+    /** Validate the route params (/active/{thing}) */
+    params: Joi.object({ 
+        profile_id: Joi.number()
+    }),
+
+    /** Validate the route query (/active/{thing}?limit=10&offset=10) */
+    query: Joi.object({ 
+        response_key_id: Joi.number(),
+        val: Joi.string()
+    })
+    /** Validate the incoming payload (POST method) */
+    // payload: responseSchemas.responses,
+}
+
+module.exports = {
+    method: 'POST',
+    path: '/{profile_id}/respond',
+    options: {
+        ...pluginConfig.docs,
+        tags: ['api'],
+        /** Protect this route with authentication? */
+        auth: false,
+
+        handler: async function (request, h) {
+            const { profileService } = request.services()
+            
+            const profileId = request.params.profile_id
+            const responseToSave = {
+                profile_id: profileId,
+                response_key_id: request.query.response_key_id,
+                val: request.query.val
+            }
+            
+            try {
+                const allResponses = await profileService.saveResponseForProfile(profileId, responseToSave)
+                
+                // profileService.saveResponseForProfile() will return null if it exists
+                if(!allResponses){
+                    throw new RangeError('Response already exists')
+                }
+
+                return h.response({
+                    ok: true,
+                    handler: pluginConfig.handlerType,
+                    data: allResponses,
+                }).code(201)
+            } catch (err) {
+                return h.response({
+                    ok: false,
+                    handler: pluginConfig.handlerType,
+                    data: { error: `${err}` },
+                }).code(409)
+            }
+        },
+
+        /** Validate based on validators object */
+        validate: {
+            ...validators,
+            failAction: 'log',
+        },
+
+        /** Validate the server response */
+        response: {
+            status: {
+                201: Joi.object({
+                    ok: Joi.bool(),
+                    handler: Joi.string(),
+                    data: responseSchemas.responses,
+                }),
+                409: Joi.object({
+                    ok: Joi.bool(),
+                    handler: Joi.string(),
+                    data: responseSchemas.error,
+                }),
+            },
+        },
+    },
+}

backend/lib/routes/profile/update.js

@@ -19,6 +19,9 @@ const responseSchemas = {
             val: Joi.string().required(),
         }),
     ),
+    error: Joi.object({
+        error: Joi.string(),
+    }),
 }
 
 const validators = {
@@ -36,7 +39,7 @@ const validators = {
 
 module.exports = {
     method: 'PATCH',
-    path: '/{profile_id}/update',
+    path: '/{profile_id}/update/{response_id?}',
     options: {
         ...pluginConfig.docs,
         tags: ['api'],
@@ -47,6 +50,8 @@ module.exports = {
             const { profileService } = request.services()
             const profileId = request.params.profile_id
 
+            const responseId = request.params.response_id ? request.params.response_id : null
+            
             /** Grab payload info */
             const res = request.payload
 
@@ -75,11 +80,18 @@ module.exports = {
 
         /** Validate the server response */
         response: {
-            schema: Joi.object({
-                ok: Joi.bool(),
-                handler: Joi.string(),
-                data: responseSchemas.responses,
-            }),
+            status: {
+                201: Joi.object({
+                    ok: Joi.bool(),
+                    handler: Joi.string(),
+                    data: responseSchemas.responses,
+                }),
+                500: Joi.object({
+                    ok: Joi.bool(),
+                    handler: Joi.string(),
+                    data: responseSchemas.error,
+                }),
+            },
         },
     },
 }

backend/lib/routes/user/create-profile.js

@@ -85,7 +85,7 @@ module.exports = {
                         handler: pluginConfig.handlerType,
                         data: { error: `${err}` },
                     })
-                    .code(500)
+                    .code(409)
             }
         },
 
@@ -103,7 +103,7 @@ module.exports = {
                     handler: Joi.string(),
                     data: responseSchemas.response,
                 }),
-                500: Joi.object({
+                409: Joi.object({
                     ok: Joi.bool(),
                     handler: Joi.string(),
                     data: responseSchemas.error,

backend/lib/services/membership.js

@@ -10,13 +10,22 @@ module.exports = class MembershipService extends Schmervice.Service {
      * @param {number} profileId
      * @returns {Array} List of all grouping_ids for user
      */
-    async _getGroupIdsForProfileId(profileId) {
+    async _getGroupIdsForProfileId(profileId, type) {
         const { Membership } = this.server.models()
 
         /** Grab every Membership associated with this id */
-        const allMemberships = await Membership.query()
-            .where({ profile_id: profileId })
-            .where({ is_active: true })
+        let allMemberships
+        console.log()
+        if(type) {
+            allMemberships = await Membership.query()
+                .where({ profile_id: profileId })
+                .where({ membership_type: type })
+                .where({ is_active: true })
+        } else {
+            allMemberships = await Membership.query()
+                .where({ profile_id: profileId })
+                .where({ is_active: true })
+        }
         
         /** Copy a list of the just the Groupings */
         const groupingIdsToGrab = allMemberships.map(
@@ -57,10 +66,10 @@ module.exports = class MembershipService extends Schmervice.Service {
      * @param {number} profileId
      * @returns {Array}
      */
-    async findGroupingsById(profileId) {
+    async findGroupingsById(profileId, type) {
         const { Grouping } = this.server.models()
 
-        const dedupedGroupings = await this._getGroupIdsForProfileId(profileId)
+        const dedupedGroupings = await this._getGroupIdsForProfileId(profileId, type)
 
         /** Grab just the Groupings this id has a Membership for */
         return await Grouping.query()

backend/lib/services/profile.js

@@ -124,6 +124,25 @@ module.exports = class ProfileService extends Schmervice.Service {
         })
     }
 
+    /** Add response
+     * @param {Object} response to save
+     * @returns {null} updated responses
+     * @returns {Array} updated responses
+     */
+    async saveResponseForProfile(profileId, responseToSave) {
+        const { Response } = this.server.models()
+        let allResponses = await Response.query().where({
+            profile_id: profileId,
+        })
+        const matchingResponses = allResponses.filter(response => response.response_key_id == responseToSave.response_key_id)
+        
+        // ?:Maybe bad idea
+        if(matchingResponses.length > 0) { return null }
+
+        await await Response.query().insert(responseToSave)
+        return allResponses
+    }
+
     /**
      * Delete a profile
      * @param {number} userId