:sparkles: added matchqueue service and routes

backend/lib/models/matchqueue.js

@@ -0,0 +1,21 @@
+const Schwifty = require('@hapipal/schwifty')
+const Joi = require('joi')
+
+const Profile = require('./profile')
+// const User = require('./user')
+// const Membership = require('./membership')
+
+module.exports = class MatchQue extends Schwifty.Model {
+    static get tableName() {
+        return 'matchque'
+    }
+
+    static get joiSchema() {
+        return Joi.object({
+            match_id: Joi.number(),
+            profile_id: Joi.number().required(),
+            profile_id_2: Joi.number().required(),
+            deleted: Joi.boolean().required(),
+        })
+    }
+}

backend/lib/plugins/matchqueue.js

@@ -0,0 +1,30 @@
+const Objection = require('objection')
+const Schmervice = require('@hapipal/schmervice')
+const Schwifty = require('@hapipal/schwifty')
+
+const MatchQueService = require('../services/matchqueue')
+
+const MatchQueModel = require('../models/matchqueue')
+const MatchQueRoute = require('../routes/matchqueue/matchqueue')
+const MatchQueChooseRoute = require('../routes/matchqueue/choosematch')
+
+module.exports = {
+    name: 'matchqueue-plugin',
+    version: '1.0.0',
+    register: async (server, options) => {
+        await server.register(Schwifty)
+
+        await server.registerModel(MatchQueModel)
+
+        server.bind({
+            transaction: fn => Objection.transaction(server.knex(), fn),
+        })
+
+        await server.register(Schmervice)
+
+        server.registerService(MatchQueService)
+
+        await server.route(MatchQueRoute)
+        await server.route(MatchQueChooseRoute)
+    },
+}

backend/lib/routes/matchqueue/choosematch.js

@@ -0,0 +1,67 @@
+'use strict'
+
+const Joi = require('joi')
+
+const pluginConfig = {
+    handlerType: 'matchque',
+    docs: {
+        description: 'updates matchque',
+        notes: 'Updates MatchQue Table if User chooses to match with another or chooses to delete match',
+    },
+}
+
+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: true,
+
+    //     /** Validate the incoming payload (POST method) */
+
+    payload: Joi.object({
+        profile_id_2: Joi.number(),
+        reinsert: Joi.boolean(),
+    }),
+}
+
+module.exports = {
+    method: 'POST',
+    path: '/{profile_id}/choose',
+    options: {
+        ...pluginConfig.docs,
+        tags: ['api'],
+        /** Protect this route with authentication? */
+        auth: false,
+        handler: async function (request, h) {
+            const { profile_id } = request.params
+            const { profile_id_2, reinsert } = request.payload
+            const { matchQueService } = request.server.services()
+
+            return await matchQueService.markAsDeleted(
+                profile_id,
+                profile_id_2,
+                reinsert,
+            )
+        },
+        /** Validate based on validators object */
+        validate: {
+            ...validators,
+            failAction: 'log',
+        },
+
+        // couldn't get validate server response working...
+
+        /** Validate the server response */
+        // response: {
+        //     schema: Joi.object({
+        //         ok: Joi.bool(),
+        //         handler: Joi.string(),
+        //         data: Joi.object(),
+        //     }),
+        // },
+    },
+}

backend/lib/routes/matchqueue/matchqueue.js

@@ -0,0 +1,79 @@
+'use strict'
+
+const Joi = require('joi')
+
+const pluginConfig = {
+    handlerType: 'matchque',
+    docs: {
+        description: 'inserts scored matches',
+        notes: 'Waits for Scoring Service, and inserts any that does not exist in MatchQue Table',
+    },
+}
+
+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: true,
+
+    //     /** Validate the incoming payload (POST method) */
+
+    payload: Joi.object({
+        maxDistance: Joi.number().required(),
+        distanceUnit: Joi.string().required(),
+    }),
+}
+
+module.exports = {
+    method: 'POST',
+    path: '/{profile_id}/matches',
+    options: {
+        ...pluginConfig.docs,
+        tags: ['api'],
+        /** Protect this route with authentication? */
+        auth: false,
+        handler: async function (request, h) {
+            const { profile_id } = request.params
+            const { maxDistance, distanceUnit } = request.payload
+            const { matchQueService, profileService } =
+                request.server.services()
+            // get results back from profileServices.scoreProfilesFor(profile_id, maxDistance, distanceUnit)
+            const potentials = await profileService.scoreProfilesFor(
+                profile_id,
+                maxDistance,
+                distanceUnit,
+            )
+            let potentialProfileIds = potentials.map(
+                potential => potential.profile_id,
+            )
+            potentialProfileIds = [...new Set(potentialProfileIds)]
+
+            await matchQueService.insertScoredProfilesIntoMatchQue(
+                profile_id,
+                potentialProfileIds,
+            )
+
+            return matchQueService.getPotentials(profile_id)
+        },
+        /** Validate based on validators object */
+        validate: {
+            ...validators,
+            failAction: 'log',
+        },
+
+        // couldn't get validate server response working...
+
+        /** Validate the server response */
+        // response: {
+        //     schema: Joi.object({
+        //         ok: Joi.bool(),
+        //         handler: Joi.string(),
+        //         data: Joi.object(),
+        //     }),
+        // },
+    },
+}

backend/lib/services/matchqueue.js

@@ -0,0 +1,67 @@
+const Schmervice = require('@hapipal/schmervice')
+
+module.exports = class MatchQueService extends Schmervice.Service {
+    constructor(...args) {
+        super(...args)
+    }
+
+    async getPotentials(profileId) {
+        const { MatchQue } = this.server.models()
+        const allPotentials = await MatchQue.query()
+            .where('profile_id', profileId)
+            .andWhere('deleted', false)
+        return allPotentials
+    }
+    /**
+     * Saves Scored Profile Ids to MatchQue IN ORDER
+     * @param {number} profileId
+     * @param {array} potentialProfileIds
+     */
+    async insertScoredProfilesIntoMatchQue(profileId, potentialProfileIds) {
+        const { MatchQue } = this.server.models()
+
+        // returns an array of all matches for the profileId where the profile_id_2 already exists in the potentialProfileIds array
+        await MatchQue.query()
+            .patch({
+                deleted: true,
+            })
+            .where('profile_id', profileId)
+
+        for (let potentialProfileId of potentialProfileIds) {
+            await MatchQue.query().insert({
+                profile_id: profileId,
+                profile_id_2: potentialProfileId,
+                deleted: false,
+            })
+        }
+
+        return await this.getPotentials(profileId)
+    }
+    /**
+     * Set the rows deleted as true, does NOT DELETE from database
+     * @param {number} profileId
+     * @param {number} profileId2
+     * @param {boolean} reinsert
+     * @returns
+     */
+    async markAsDeleted(profileId, profileId2, reinsert) {
+        const { MatchQue } = this.server.models()
+        await MatchQue.query()
+            .patch({
+                deleted: true,
+            })
+            .where('profile_id', profileId)
+            .andWhere('profile_id_2', profileId2)
+            .first()
+
+        if (reinsert) {
+            await MatchQue.query().insert({
+                profile_id: profileId,
+                profile_id_2: profileId2,
+                deleted: false,
+            })
+        }
+
+        return await this.getPotentials(profileId)
+    }
+}