:tada: first commit

.gitignore

+node_modules

README.md

+# Final Countdown
+
+Bree job running with a small htmx gui

jobs/heartbeat.js

+const path = require('path')
+const jobDef = {
+    timeout: false,
+    interval: '10s'
+}
+
+/**
+ * Actual job instructions
+ */
+const jobRun = () => {
+    console.log('beep')
+    return 'boop'
+}
+jobRun()
+
+module.exports = { jobName: path.basename(__filename, '.js'), ...jobDef }

jobs/index.js

+const defs = [
+    require("./setup"),
+    require("./heartbeat")
+]
+
+class Job {
+    constructor({ jobName, timeout, interval }) {
+        this.name = jobName
+        this.timeout = timeout
+        this.interval = interval
+    }
+}
+
+class JobFactory {
+    constructor() {
+        this.jobs = []
+        this.addJobsFromDefs({ defs })
+    }
+    /**
+     * Force using of Job objects for validating
+     */
+    createJob({ jobName, timeout, interval }) {
+        return new Job({ jobName, timeout, interval })
+    }
+    /**
+     * Only store the job if it is
+     * a valid Job instance
+     */
+    addJobFromDef(jobDef) {
+        const job = this.createJob(jobDef)
+        if (job) {
+            this.jobs.push(job)
+        }
+    }
+    /**
+     * Take in job definitions from accompanying
+     * job files. Job files must include and
+     * execute a jobRun()
+     */
+    addJobsFromDefs({ defs }) {
+        defs.forEach(def => this.addJobFromDef(def))
+    }
+}
+
+const jobFactory = new JobFactory()
+module.exports = jobFactory

jobs/setup.js

+const path = require('path')
+const jobDef = {
+    timeout: '1s',
+}
+
+/**
+ * Actual job instructions
+ */
+const jobRun = () => {
+    console.log('---')
+    console.log('bree started...')
+    console.log('---')
+}
+jobRun()
+
+module.exports = { jobName: path.basename(__filename, '.js'), ...jobDef }

lib/index.js

+const Vision = require('@hapi/vision')
+const Pug = require('pug')
+
+const { all } = require('../plugins')
+
+/**
+ * A Hapi server instance
+ * @typedef {Object} Server
+ */
+
+/**
+ * A plugin for Hapi
+ * @typedef {Object} Plugin
+ */
+exports.plugin = {
+    name: 'main-app-plugin',
+
+    /**
+     * Main Hapi plugin that grabs all our
+     * other plugins to create the API app
+     * @param {Server} server
+     * @param {Object} options
+     */
+    register: async (server, options) => {
+        // My custom plugins
+        for(let plug of all) await server.register(plug, plug.opts)
+
+        await server.register(Vision)
+        server.views({
+            engines: { pug: Pug },
+            relativeTo: __dirname ,
+            path: 'templates'
+        })
+    },
+}

lib/templates/index/index.pug

+extends ../layouts/_layout.pug
+
+block header
+    h1 #{title}
+
+block content
+    section.container
+        p #{message}
+        button(hx-post="/client/clicked" hx-swap="outerHTML") click
+
+block footer
+    p footie

lib/templates/index/partials/on_click.pug

+button(hx-post="/client/clicked" hx-swap="outerHTML") #{msg}
+p #{h}
+ul
+  each job in jobs
+    li
+        p name: 
+            span= job.name
+        p timout: 
+            span= job.timeout ? job.timeout : 'false'
+        p interval: 
+            span= job.interval ? job.interval : 'false'

lib/templates/layouts/_layout.pug

+doctype html
+html(lang='en')
+    head
+        title Client test
+        script(src="https://unpkg.com/htmx.org@1.8.0" integrity="sha384-cZuAZ+ZbwkNRnrKi05G/fjBX+azI9DNOkNYysZ0I/X5ZFgsmMiBXgDZof30F5ofc" crossorigin="anonymous")
+
+    body
+        header
+            block header
+        main
+            block content
+        footer
+            block footer

manifest.js

+const Confidence = require('@hapipal/confidence')
+
+/** Glue manifest as a confidence store */
+module.exports = new Confidence.Store({
+    server: {
+        host: 'localhost',
+        port: {
+            $filter: 'NODE_ENV',
+            $default: {
+                $param: 'API_PORT',
+                $coerce: 'number',
+                $default: 3001,
+            },
+            test: { $value: undefined }, // Let the server find an open port
+        },
+        debug: {
+            $filter: 'NODE_ENV',
+            $default: {
+                log: ['error', 'start'],
+                request: ['error'],
+            },
+            production: {
+                request: ['implementation'],
+            },
+        },
+    },
+    register: {
+        plugins: [
+            /** Main app */
+            {
+                plugin: './lib',
+                options: {},
+            },
+        ],
+    },
+})

package.json

+{
+  "name": "final-countdown",
+  "version": "1.0.0",
+  "description": "schedule all the things",
+  "main": "server.js",
+  "scripts": {
+    "dev": "node ./server.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "toj",
+  "license": "UNLICENSED",
+  "dependencies": {
+    "@hapi/glue": "^8.0.0",
+    "@hapi/hapi": "^20.2.2",
+    "@hapi/vision": "^7.0.0",
+    "@hapipal/confidence": "^6.0.2",
+    "@hapipal/schmervice": "^2.0.0",
+    "bree": "^9.1.1",
+    "exiting": "^6.1.0",
+    "htmx.org": "^1.8.0",
+    "joi": "^17.6.0",
+    "pug": "^3.0.2"
+  }
+}

plugins/client.js

+const Schmervice = require('@hapipal/schmervice')
+
+const all = require('../routes/client')
+// const UserService = require('./services/user')
+
+module.exports = {
+    name: 'client-plugin',
+    version: '1.0.0',
+    opts: {}, // No need to prefix the gui
+    register: async (server, options) => {
+
+        // Bind to global context
+        // So we can use Objection transactions
+        server.bind({
+            transaction: fn => ({ foo: 'bar' }),
+        })
+
+        await server.register(Schmervice)
+        // server.registerService(UserService)
+        for(let route of all) {
+            await server.route(route)
+        }
+    },
+}

plugins/index.js

+module.exports = {
+    all: [
+        require('../plugins/client'),
+        require('../plugins/scheduler')
+    ]
+}

plugins/scheduler.js

+const Schmervice = require('@hapipal/schmervice')
+
+// const UserCurrentRoute = require('./routes/user/current')
+const Timeline = require('../services/timeline.service')
+
+module.exports = {
+    name: 'scheduler-plugin',
+    version: '1.0.0',
+    opts: { 
+        routes: { prefix: '/scheduler' }
+    },
+    register: async (server, options) => {
+
+        // Bind to global context
+        // So we can use Objection transactions
+        server.bind({
+            transaction: fn => ({ foo: 'bar' }),
+        })
+
+        await server.register(Schmervice)
+        server.registerService(Timeline)
+        // await server.route(UserCurrentRoute)
+    },
+}

routes/client/client.clicked.js

+const template = 'index/partials/on_click'
+const action = 'client/clicked'
+
+const state = {
+    msg: 'wowow',
+    h: 'registered jobs'
+}
+
+const handler = (request, h) => {
+    const { timeline } = request.server.services()
+    const jobs = timeline.bree.config.jobs
+    return h.view(template, { ...state, jobs })
+}
+
+/**
+ * Corresponds with templates/index/partials/clicked.pug
+ */
+module.exports = {
+    method: 'POST',
+    path: `/${action}`,
+    options: { handler }
+}

routes/client/client.js

+const template = 'index/index'
+const action = 'client'
+
+const state = {
+    title: 'Custom Title',
+    message: 'hallo world'
+}
+
+/**
+ * Corresponds with templates/index/index.pug
+ */
+module.exports = {
+    method: 'GET',
+    path: `/${action}`,
+    options: {
+        handler: (request, h) => h.view(template, state)
+    }
+}

routes/client/index.js

+const client = require('./client')
+const clientClicked = require('./client.clicked')
+
+module.exports = [
+    client,
+    clientClicked
+]

server.js

+const Glue = require('@hapi/glue')
+const Exiting = require('exiting')
+const Manifest = require('./manifest')
+/**
+ * Our main app server
+ * @param {boolean} start
+ * @returns {Server}
+ */
+exports.deployment = async ({ start } = {}) => {
+    const manifest = Manifest.get('/', process.env)
+    const server = await Glue.compose(manifest, { relativeTo: __dirname })
+
+    if (start) {
+        await Exiting.createManager(server).start()
+        server.log(['start'], `Server started at ${server.info.uri}`)
+        return server
+    }
+
+    // await server.initialize()
+
+    // return server
+}
+
+if (require.main === module) {
+    exports.deployment({ start: true })
+
+    process.on('unhandledRejection', (err) => {
+        throw err
+    })
+}

services/timeline.service.js

+
+const Schmervice = require('@hapipal/schmervice')
+const Bree = require('bree')
+
+const all = require('../jobs')
+
+module.exports = class Timeline extends Schmervice.Service {
+    constructor(...args) {
+        super(...args)
+        this.bree = new Bree({ jobs: all.jobs })
+        this.bree.start()
+    }
+    async start(jobName) {
+        if (!jobName) {
+            await this.bree.start()
+        } else {
+            await this.bree.start(jobName)
+        }
+        return this.bree
+    }
+    stop(jobName) {
+        if (!jobName) {
+            this.bree.stop()
+        } else {
+            this.bree.stop(jobName)
+        }
+    }
+    async add(jobName) {
+        if (!jobName) return
+        await this.bree.add(jobName)
+    }
+    remove(jobName) {
+        if (!jobName) return
+        this.bree.remove(jobName)
+    }
+}