:sparkles: tricky global context addition to use orm transactions

backend/lib/plugins/user.js

@@ -1,12 +1,16 @@
+const Objection = require('objection');
 const Schmervice = require('@hapipal/schmervice');
 const Schwifty = require('@hapipal/schwifty');
 const Jwt = require('@hapi/jwt');
 const JwtStrategy = require('../auth/strategies/jwt')
+
 const UserModel = require('../models/user');
 
 const UserCurrentRoute = require('../routes/user/current');
 const UserLoginRoute = require('../routes/user/login');
 
+const UserService = require('../services/user');
+
 module.exports = {
     name: 'user-plugin',
     version: '1.0.0',
@@ -20,16 +24,14 @@ module.exports = {
         server.auth.strategy('default_jwt', 'jwt', jwtOptions)
         server.auth.default('default_jwt')
 
+        // Bind to global context
+        // So we can use Objection transactions
+        server.bind({
+            transaction: (fn) => Objection.transaction(server.knex(), fn)
+        })
 
         await server.register(Schmervice)
-        server.registerService(
-            class MathService extends Schmervice.Service {
-                add(x, y) {
-                    this.server.log(['math-service'], 'Adding')
-                    return Number(x) + Number(y)
-                }
-            }
-        )
+        server.registerService(UserService)
 
         await server.route(UserCurrentRoute)
         await server.route(UserLoginRoute)

backend/lib/routes/user/login.js

@@ -18,10 +18,11 @@ const pluginConfig = {
 const validators = {
     post: {
         payload: Joi.object({
-            user: Joi.object().required().keys({
-                email: User.field('email').required(),
-                password: Joi.string().required()
-            })
+            user: Joi.object().keys({
+                email: User.field('email'),
+                password: Joi.string()
+            }),
+            error: Joi.string()
         })
     }
 }
@@ -29,35 +30,35 @@ const validators = {
 module.exports = {
     method: 'post',
     path: '/login',
-    handler: async (request, h) => {
+    handler: async function (request, h) {
         try {
-            const { user: { email, password } } = request.payload
-            const { mathService } = request.services()
-            console.log(mathService.add(10, 1))
             // const { userService, displayService } = request.services();
+            const { userService } = request.services()
+            const res = request.payload
+            console.log('---')
 
-            // const login = async (txn) => {
-
-            //     return await userService.login({ email, password }, txn);
-            // };
-
-            // const user = await h.context.transaction(login);
-            // const token = userService.createToken(user.id);
+            const login = async (txn) => {
+                return await userService.login({
+                    email: res.user.email,
+                    password: res.user.password
+                }, txn)
+            }
+            // Bound context from your plugin server declaration
+            const user = await h.context.transaction(login)
+            const token = userService.createToken(user.id)
 
             return {
                 ok: true,
                 handler: pluginConfig.handlerType,
-                data: {
-                    user: { email: '', password: '' }
-                },
-                // data: { user: displayService.user(user, token) }
+                data: { user: displayService.user(user, token) }
             }
         }
         catch(err) {
+            console.error(err)
             return {
                 ok: false,
                 handler: pluginConfig.handlerType,
-                data: { error: err },
+                data: { error: `${err}` },
             }
         }
     },

backend/lib/services/user.js

@@ -45,6 +45,8 @@ module.exports = class UserService extends Schmervice.Service {
     async login({ email, password }, txn) {
         const { User } = this.server.models()
 
+        console.log('user service attempting login...')
+
         const user = await User.query(txn).throwIfNotFound().first().where({
             email: User.raw('? collate nocase', email)
         })