:construction: Started work on saving survey state by sending responses to db

backend/lib/plugins/profile.js

@@ -16,6 +16,7 @@ const MatchService = require('../services/match')
 
 const ProfileScoreRoute = require('../routes/profile/score')
 const ProfileUpdateRoute = require('../routes/profile/update')
+const ProfileInsertRoute = require('../routes/profile/insert')
 const ProfileRespondRoute = require('../routes/profile/respond')
 const ProfileMatchRoute = require('../routes/profile/match')
 const ProfileQueueRoute = require('../routes/profile/queue')
@@ -51,6 +52,7 @@ module.exports = {
         await server.route(ProfileScoreRoute)
         await server.route(ProfileRespondRoute)
         await server.route(ProfileUpdateRoute)
+        await server.route(ProfileInsertRoute)
         await server.route(ProfileMatchRoute)
         await server.route(ProfileQueueRoute)
         await server.route(ProfileGetRoute)

backend/lib/routes/profile/insert.js

@@ -0,0 +1,99 @@
+'use strict'
+
+const Joi = require('joi')
+const apiSchema = require('../../schemas/api')
+const errorSchema = require('../../schemas/errors')
+const surveyResponseSchema = require('../../schemas/responses')
+const params = require('../../schemas/params')
+
+const pluginConfig = {
+    handlerType: 'profile',
+    docs: {
+        description: 'Insert profile',
+        notes: 'Insert new profile responses',
+    },
+}
+
+const responseSchemas = {
+    response: surveyResponseSchema.list,
+    error: errorSchema.single,
+}
+
+const validators = {
+    /** Validate the header (cookie check) */
+    // headers: true,
+
+    /** Validate the route params (/active/{thing}) */
+    params: params.profileId,
+
+    /** Validate the route query (/active/{thing}?limit=10&offset=10) */
+    // query: true,
+    /** Validate the incoming payload (POST method) */
+    payload: responseSchemas.responses,
+}
+
+module.exports = {
+    method: 'POST',
+    path: '/{profile_id}/insert/{response_id?}',
+    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
+
+            /** Grab payload info */
+            const res = request.payload
+            console.log('res :=>', res)
+
+            try {
+                const allResponses = profileService.saveResponseForProfile(profileId, res)
+
+                if (!allResponses) {
+                    throw new RangeError('Response not inserted')
+                }
+
+                return h
+                    .response({
+                        ok: true,
+                        handler: pluginConfig.handlerType,
+                        data: allResponses,
+                    })
+                    .code(200)
+            } 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: {
+                200: apiSchema.single
+                    .append({
+                        data: responseSchemas.response,
+                    })
+                    .label('response_list_res'),
+                409: apiSchema.single
+                    .append({
+                        data: responseSchemas.error,
+                    })
+                    .label('error_single_res'),
+            },
+        },
+    },
+}

frontend/src/entities/survey/survey.js

@@ -43,6 +43,14 @@ class Survey extends _baseRecord {
         )
     }
 
+    hasMinResponsesToCreateProfile(responses) {
+        if (responses.name &&
+            responses.email &&
+            responses.seeking) {
+            return true
+        } else return false
+    }
+
     validateAnswer(payload) {
         const { question, input } = payload
 

frontend/src/services/survey.service.js

@@ -22,6 +22,23 @@ const fetchQuestions = async () => {
     return withResponses
 }
 
+const insertNewSurveyResponses = async (surveyResponses, profileId) => {
+    surveyResponses.forEach(responseKeyIdwithVal => {
+        const keyId = responseKeyIdwithVal.response_key_id
+        const val = responseKeyIdwithVal.val
+        // POST
+        // TODO: create this route on the backend
+        db.post(`/profile/${profileId}/insert/${keyId}`, [
+            {
+                profile_id: profileId,
+                reponse_key_id: keyId,
+                val: val,
+            }
+        ])
+    })
+}
+
+// similar to this
 const updateSurveyByProfileId = async (surveyResponses, profileId) => {
     surveyResponses.forEach(responseKeyIdwithVal => {
         const keyId = responseKeyIdwithVal.response_key_id
@@ -38,6 +55,7 @@ const updateSurveyByProfileId = async (surveyResponses, profileId) => {
     })
 }
 
+// and similar to this
 const scoreSurveyByProfileId = async (profileId, maxDistance = 99) => {
     const scoreSurvey = await db.get(
         `/profile/${profileId}/score?max_distance=${maxDistance}`,
@@ -51,6 +69,7 @@ const fetchResponsesByProfileId = async profileId => {
 
 export {
     fetchQuestions,
+    insertNewSurveyResponses,
     updateSurveyByProfileId,
     scoreSurveyByProfileId,
     fetchResponsesByProfileId,

frontend/src/utils/lang.js

@@ -19,17 +19,17 @@ const splash = {
 const allSteps = {
     usa: {
         name: 'name',
+        email: 'email',
+        seeking: 'seeking',
         aspect01: 'aspect-1',
         aspect02: 'aspect-2',
         aspect03: 'aspect-3',
         password: 'password',
         zipcode: 'zipcode',
-        seeking: 'seeking',
         urgency: 'urgency',
         aspect04: 'aspect-4',
         aspect05: 'aspect-5',
         aspect06: 'aspect-6',
-        email: 'email',
         presence: 'presence',
         duration: 'duration',
         pronouns: 'pronouns',

frontend/src/utils/survey.js

@@ -1,10 +1,11 @@
 import { Survey } from '../entities/index.js'
-import { fetchQuestions } from '../services/index.js'
+import { fetchQuestions, insertNewSurveyResponses } from '../services/index.js'
 import { splash, possible, surveyStages, allSteps } from './lang.js'
 
 class SurveyFactory {
     constructor() {
         this.questionsFromDb = []
+        this.responsesFromDb = []
     }
     _addResponses(responseKeys, responsesByCategory) {
         const existingResponses = {}
@@ -82,6 +83,15 @@ class SurveyFactory {
             console.error(err)
         }
     }
+    async addNewSurveyAnswers(responses, profileId) {
+        try {
+            this.responsesFromDb = await insertNewSurveyResponses(responses, profileId)
+            return this.responsesFromDb
+        }
+        catch (err) {
+            console.error(err)
+        }
+    }
     async createSurvey(roleTree) {
         if (!this.questionsFromDb.length) {
             const res = await this.getQuestions()

frontend/src/views/OnboardingView.vue

@@ -34,11 +34,14 @@ main.view--onboarding
 </template>
 
 <script>
+// import { currentProfile } from '@/services'
+// import { createProfileForUserId } from '../services/profile.service'
 import { surveyFactory } from '@/utils'
+import { signupUser, createProfileForUserId } from '@/services/'
 import stepViews from '@/components/onboarding'
 import SurveyCompleteView from './SurveyCompleteView.vue'
 
-// import savesurveybyprfileid - call it on submit
+// import savesurveybyprofileid - call it on submit
 // paginate to save every steps answers
 export default {
     name: 'OnboardingView',
@@ -49,12 +52,17 @@ export default {
     data: () => ({
         answered: {},
         aspectQuestions: [],
+        responses: [],
         currentStep: 0,
         survey: null,
+        currentProfileId: null,
         invalidResponse: false,
     }),
     async created() {
+        // uses createSurvey/getQuestions from from utils/survey.service.js 
+        // which calls in fetchQuestions from services/survey.service.js
         this.survey = await surveyFactory.createSurvey()
+        // TODO: create boolean value based off if a passed user_email is found in user db (i.e. login)
     },
     methods: {
         onSubmit() {
@@ -63,7 +71,7 @@ export default {
         goToStep(num) {
             this.currentStep = num
         },
-        updateAnswers(payload) {
+        async updateAnswers(payload) {
             // null payload is passed on splash page
             if (payload) {
                 this.invalidResponse = false
@@ -77,7 +85,28 @@ export default {
 
                 // once validated, don't log password in answered object
                 this.answered[k] = k === 'password' ? undefined : payload.input
-                console.log(`Updated answers: ${JSON.stringify(this.answered)}`)
+                console.log('this.answered :=>', this.answered)
+
+                // formats initial responses for response table
+                const response = {}
+                response.response_key_id = payload.question.response_key_id
+                response.val = payload.input
+                this.responses.push(response)
+
+                // save endpoint here
+                // start with utils/surve.js
+                if (this.currentProfileId) {
+                    surveyFactory.addNewSurveyAnswers(this.responses, this.currentProfileId)
+                }
+
+                // creates a user in db as long as name, email, and seeking are defined
+                if (!this.currentProfileId && this.survey.hasMinResponsesToCreateProfile(this.answered)) {
+                    const newUser = await signupUser(this.answered)
+                    const newUserId = newUser.user_id
+                    const newProfile = await createProfileForUserId(newUserId, this.responses)
+                    this.currentProfileId = newProfile.profile_id
+                }
+
                 if (k === 'aspects') return
             }
             if (this.currentStep > this.survey.steps.length) {