Merge pull request #1 from FlowFuse/first-tests

First tests

Author: hardillb

.eslintrc

@@ -9,7 +9,7 @@
     "extends": [
         "standard"
     ],
-    "plugins": [ "eslint-plugin-html", "no-only-tests" ],
+    "plugins": [ "no-only-tests" ],
     "parserOptions": {
          "ecmaVersion": 13
     },

.github/workflows/tests.yml

@@ -0,0 +1,27 @@
+name: Tests
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    
+jobs:
+  unit:
+    name: Unit tests
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/setup-node@v4
+      - name: Install Dependencies
+        run: npm ci
+      - name: Lint
+        run: npm run lint
+      - name: Unit tests
+        run: npm run test
+        
+        

index.js

@@ -1,3 +1,29 @@
 const express = require('express')
-const mqtt = require('mqtt')
+const bodyParser = require('body-parser')
+const { API } = require('./lib/api.js')
+const { healthz } = require('./lib/health.js')
 
+const port = 3500
+
+const app = express()
+app.use(bodyParser.json({}))
+
+app.get('/healthz', healthz)
+
+const options = {
+    forgeURL: process.env.FORGE_URL,
+    team: process.env.FORGE_TEAM_ID,
+    broker: process.env.FORGE_BROKER_ID,
+    token: process.env.FORGE_TEAM_TOKEN
+}
+
+const api = new API(app, options)
+
+process.on('SIGTERM', async () => {
+    await api.stop()
+    process.exit(0)
+})
+
+app.listen(port, () => {
+    console.log(`listening on port ${port}`)
+})

lib/agent.js

@@ -0,0 +1,71 @@
+const got = require('got')
+const mqtt = require('mqtt')
+
+class Agent {
+    constructor (options) {
+        this.options = options
+        this.topics = {}
+    }
+
+    async connect () {
+        const agent = this
+        this.connected = false
+
+        try {
+            this.creds = await got.get(`${this.options.forgeURL}/api/v1/team/${this.options.team}/broker/${this.options.broker}/creds`, {
+                headers: {
+                    Authorization: `Bearer ${this.options.token}`
+                }
+            }).json()
+
+            this.client = mqtt.connect(`${this.creds.protocol}//${this.creds.hostname}:${this.creds.port}`, this.creds)
+            this.client.on('connect', function () {
+                agent.connected = true
+                // console.log('connected')
+                agent.client.subscribe('#')
+            })
+            this.client.on('reconnect', function () {
+                console.log('reconnecting')
+            })
+            this.client.on('close', function () {
+                // console.log('closed')
+            })
+            this.client.on('disconnect', function () {})
+            this.client.on('error', function (error) {
+                console.log('error', error)
+            })
+            this.client.on('message', function (topic) {
+                // console.log(topic)
+                agent.topics[topic] = Date.now()
+            })
+        } catch (err) {
+            console.log(err)
+            throw err
+        }
+    }
+
+    async start () {
+        if (this.client) {
+            await this.stop()
+        }
+        await this.connect()
+    }
+
+    async stop () {
+        if (this.client) {
+            this.client.end()
+        }
+        this.connected = false
+    }
+
+    state () {
+        return {
+            connected: this.connected,
+            topics: this.topics
+        }
+    }
+}
+
+module.exports = {
+    Agent
+}

lib/api.js

@@ -0,0 +1,14 @@
+class API {
+    constructor (app, options) {
+        app.get('/', (request, reply) => {
+        })
+    }
+
+    async stop () {
+
+    }
+}
+
+module.exports = {
+    API
+}

lib/health.js

@@ -0,0 +1,7 @@
+const healthz = async function (request, response) {
+    response.send({})
+}
+
+module.exports = {
+    healthz
+}