index.js

'use strict';

const Knex = require('knex')
const { Model } = require('objection')
const Hapi = require('hapi');
const secret = require('./config').secret

const knex = Knex(require('./knexfile').development);

Model.knex(knex)


const server = Hapi.server({
    port: 3000,
    host: 'localhost'
});


const validate = async (decoded, request, h) => {
    try {
        const client = request.redis.client;

        let res = await client.get(decoded.id);

        let session;
        if (res) {
            session = JSON.parse(res);
        }
        else {
            return { isValid: false }
        }
        if (session.valid === false || new Date().getTime() * 60 * 1000 <= session.exp) { // ensure that the token hasn't expired
            return { isValid: false }
        } else {
            session.exp = new Date().getTime()+30 *60*1000; // time + 30 minutes
            await client.set(decoded.id, JSON.stringify(session));
            return { isValid: true }
        }

    } catch (err) {
        throw Boom.badRequest(err)
    }
}



const init = async () => {
    await server.register(require('hapi-auth-jwt2'))
    await server.register(
        {
            plugin: require('hapi-redis2'),
            options: {
                settings: 'redis://localhost:6379',
                decorate:true
            }
        });

    server.auth.strategy('jwt', 'jwt', {
            key: secret,
            verifyOptions: { algorithms: ['HS256'] },
            validate: validate
        });

    server.route(require('./routes/todo_routes'))
    server.route(require('./routes/user_routes'))

    await server.start();
    console.log(`Server running at: ${server.info.uri}`);
};

process.on('unhandledRejection', (err) => {

    console.log(err);
    process.exit(1);
});

init();

module.exports = {
    server: server.listener
}