:recycle: probably too big of an update | pubnub chat | sse notifications | planetscale connection script | added some env vars

backend/.env.sample

 API_PORT=3001
 APP_SECRET=mysecret
 
+USE_LOCAL_DB=true
+
 DB_ROOT_PASSWORD=root
 DB_USER=root
 DB_NAME=test
 DB_HOST=localhost
-DB_TYPE=mysql
+DB_TYPE=mysql
+DB_PORT=3306
+
+PSCALE_DB_BRANCH=main
+PSCALE_DB_NAME=planet-scale-db

backend/knexfile.js

 require('dotenv').config()
 
+const local = {
+    host: process.env.DB_HOST,
+    user: process.env.DB_USER,
+    password: process.env.DB_ROOT_PASSWORD,
+    database: process.env.DB_NAME,
+    port: process.env.DB_PORT
+}
+const pscale = {
+    host: process.env.PSCALE_DB_HOST ? process.env.PSCALE_DB_HOST : '127.0.0.1',
+    user: process.env.PSCALE_DB_USER ? process.env.PSCALE_DB_USER : 'root',
+    password: process.env.PSCALE_DB_PASSWORD ? process.env.PSCALE_DB_PASSWORD : '', 
+    database: process.env.PSCALE_DB_NAME,
+    port: process.env.PSCALE_DB_PORT ? process.env.PSCALE_DB_PORT : 3306
+}
+
+const connectionSettings = process.env.USE_LOCAL_DB == true ? local : pscale
+
 module.exports = {
     development: {
         client: process.env.DB_TYPE,
-        connection: {
-            host: process.env.DB_HOST,
-            user: process.env.DB_USER,
-            password: process.env.DB_ROOT_PASSWORD,
-            database: process.env.DB_NAME,
-            port: 3307
-        },
+        connection: connectionSettings,
         pool: {
             min: 2,
             max: 10

backend/lib/plugins/notification.js

-const Stream = require('stream')
-const PassThrough = Stream.PassThrough
-const Transform = Stream.Transform
 const NotificationRoute = require('../routes/notification')
-
-const stringifyEvent = function (event) {
-    let str = ''
-    const endl = '\r\n'
-    for (const i in event) {
-        let val = event[i]
-        if (val instanceof Buffer) { val = val.toString() }
-        if (typeof val === 'object') { val = JSON.stringify(val) }
-        str += i + ': ' + val + endl
-    }
-    str += endl
-    return str
-}
-
-class Transformer extends Transform {
-    constructor(options, objectMode) {
-        super({ objectMode })
-        options = options || {}
-        this.counter = 1
-        this.event = options.event || null
-        this.generateId = options.generateId ? options.generateId : () => {
-            return this.counter++
-        }
-    }
-    _transform (chunk, encoding, callback) {
-        const event = {
-            id: this.generateId(chunk),
-            data: chunk
-        }
-        if (this.event) { event.event = this.event }
-        this.push(stringifyEvent(event))
-        callback()
-    }
-    _flush(callback) {
-        this.push(stringifyEvent({ event: 'end', data: '' }))
-        callback()
-    }
-} 
-
-const writeEvent = function (event, stream) {
-    if (event) {
-        stream.write(stringifyEvent(event))
-    } else {
-        // closing time
-        stream.write(stringifyEvent({ event: 'end', data: '' }))
-        stream.end()
-    }
-}
-
-const onEvent = (event, h, streamOptions) => {
-    // We only support ObjectMode streams
-    if (!event._readableState.objectMode) return
-
-    const through = new Transformer(streamOptions, true)
-    const active = new PassThrough()
-    through.pipe(active)
-    event.pipe(through)
-    console.log(event)
-    return h.response(active)
-        .header('content-type', 'text/event-stream')
-        .header('content-encoding', 'identity')
-}
+const { onEvent } = require('../services/notification')
 
 module.exports = {
     name: 'notification-plugin',

backend/lib/services/notification.js

+/** Heavily lifted from: https://github.com/mtharrison/susie/blob/master/lib/index.js */
+
+const Stream = require('stream')
+const PassThrough = Stream.PassThrough
+const Transform = Stream.Transform
+
+const ENDER = { event: 'end', data: '' }
+
+/**
+ * Stringify a stream
+ * ?: I don't really get what this is doing
+ * @param {Stream} event
+ * @returns {string}
+ */
+const stringifyEvent = function (event) {
+    let str = ''
+    const endl = '\r\n'
+    for (const i in event) {
+        let val = event[i]
+        if (val instanceof Buffer) { val = val.toString() }
+        if (typeof val === 'object') { val = JSON.stringify(val) }
+        str += i + ': ' + val + endl
+    }
+    str += endl
+    return str
+}
+
+/**
+ * Transform extension
+ * ?: I don't really get what this is doing
+ * @param {object} options
+ * @param {object} objectMode 
+ */
+class Transformer extends Transform {
+    constructor(options, objectMode) {
+        super({ objectMode })
+        options = options || {}
+        this.counter = 1
+        this.event = options.event || null
+        this.generateId = options.generateId ? options.generateId : () => {
+            return this.counter++
+        }
+    }
+    _transform (chunk, encoding, callback) {
+        const event = {
+            id: this.generateId(chunk),
+            data: chunk
+        }
+        if (this.event) { event.event = this.event }
+        this.push(stringifyEvent(event))
+        callback()
+    }
+    _flush(callback) {
+        this.push(stringifyEvent(ENDER))
+        callback()
+    }
+} 
+
+/**
+ * Take an event stream and write content to another stream
+ * ?: Save this for future extension
+ * @param {Stream} event stream input
+ * @param {Stream} stream to write to
+ */
+const writeEvent = function (event, stream) {
+    if (event) {
+        stream.write(stringifyEvent(event))
+    } else {
+        // closing time
+        stream.write(stringifyEvent(ENDER))
+        stream.end()
+    }
+}
+
+/**
+ * Callback to decorate server toolkit (h)
+ * !: Currently we only support ObjectMode streams
+ * ?: I don't really get what this is doing
+ * @param {Stream} event stream input
+ * @param {Toolkit} h hapi common response toolkit
+ * @param {object} streamOptions
+ */
+const onEvent = (event, h, streamOptions) => {
+    // const state = h.request.plugins.notifications = h.request.plugins.notifications || {}
+    let active
+    if (event instanceof Stream.Readable) {
+        if (event._readableState.objectMode) {
+            const through = new Transformer(streamOptions, true)
+            active = new PassThrough()
+            through.pipe(active)
+            event.pipe(through)
+        }
+        // else {
+        //     stream = new Transformer(streamOptions, false)
+        //     event.pipe(stream)
+        // }
+        return h.response(active)
+            .header('content-type', 'text/event-stream')
+            .header('content-encoding', 'identity')
+    }
+    // Uncomment to do stream state stuff
+    // handle a first object arg
+    // if (!state.stream) {
+    //     active = new PassThrough()
+    //     state.stream = active
+    //     state.mode = 'object'
+    //     const response = h.response(active)
+    //         .header('content-type', 'text/event-stream')
+    //         .header('content-encoding', 'identity')
+    //     writeEvent(event, active)
+    //     return response
+    // }
+    // already have an object stream flowing, just write next event
+    // active = state.stream
+    // internals.writeEvent(event, active)
+}
+
+module.exports = { onEvent }

backend/package.json

   "main": "index.js",
   "scripts": {
     "start": "nodemon server",
-    "migrate": "knex migjrate:latest",
+    "connect": "USE_LOCAL_DB=false pscale connect $(grep '^PSCALE_DB_NAME' .env | cut -d '=' -f2) $(grep '^PSCALE_DB_BRANCH' .env | cut -d '=' -f2)",
+    "migrate": "knex migrate:latest",
     "unmigrate": "knex migrate:down",
     "reseed": "knex migrate:rollback --all && knex migrate:latest && knex seed:run",
     "generate": "node ./db/data-generator/index.js",

frontend/.env.sample

+VITE_PUBNUB_PUBLISH_KEY=pub-a-123467890-123467890
+VITE_PUBNUB_SUBSCRIBE_KEY=sub-a-123467890-123467890
+VITE_UUID_SECRET=00000000-0000-1111-0000-000000000000

frontend/package-lock.json

             "resolved": "https://registry.npmjs.org/@babel/parser/-/parser-7.16.4.tgz",
             "integrity": "sha512-6V0qdPUaiVHH3RtZeLIsc+6pDhbYzHR8ogA8w+f+Wc77DuXto19g2QUwveINoS34Uw+W8/hQDGJCx+i4n7xcng=="
         },
+        "@babel/runtime": {
+            "version": "7.17.2",
+            "resolved": "https://registry.npmjs.org/@babel/runtime/-/runtime-7.17.2.tgz",
+            "integrity": "sha512-hzeyJyMA1YGdJTuWU0e/j4wKXrU4OMFvY2MSlaI9B7VQb0r5cxTE3EAIS2Q7Tn2RIcDkRvTA/v2JsAEhxe99uw==",
+            "requires": {
+                "regenerator-runtime": "^0.13.4"
+            }
+        },
         "@babel/types": {
             "version": "7.16.0",
             "resolved": "https://registry.npmjs.org/@babel/types/-/types-7.16.0.tgz",
             "resolved": "https://registry.npmjs.org/@sideway/pinpoint/-/pinpoint-2.0.0.tgz",
             "integrity": "sha512-RNiOoTPkptFtSVzQevY/yWtZwf/RxyVnPy/OcA9HBM3MlGDnBEYL5B41H0MTn0Uec8Hi+2qUtTfG2WWZBmMejQ=="
         },
+        "@tootallnate/once": {
+            "version": "1.1.2",
+            "resolved": "https://registry.npmjs.org/@tootallnate/once/-/once-1.1.2.tgz",
+            "integrity": "sha512-RbzJvlNzmRq5c3O09UipeuXno4tA1FE6ikOjxZK0tuxVv3412l64l5t1W5pj4+rJq9vpkm/kwiR07aZXnsKPxw=="
+        },
+        "@tsconfig/node12": {
+            "version": "1.0.9",
+            "resolved": "https://registry.npmjs.org/@tsconfig/node12/-/node12-1.0.9.tgz",
+            "integrity": "sha512-/yBMcem+fbvhSREH+s14YJi18sp7J9jpuhYByADT2rypfajMZZN4WQ6zBGgBKp53NKmqI36wFYDb3yaMPurITw=="
+        },
         "@types/istanbul-lib-coverage": {
             "version": "2.0.3",
             "resolved": "https://registry.npmjs.org/@types/istanbul-lib-coverage/-/istanbul-lib-coverage-2.0.3.tgz",
             "integrity": "sha512-rq9s+JNhf0IChjtDXxllJ7g41oZk5SlXtp0LHwyA5cejwn7vKmKp4pPri6YEePv2PU65sAsegbXtIinmDFDXgQ==",
             "dev": true
         },
+        "acorn-walk": {
+            "version": "8.2.0",
+            "resolved": "https://registry.npmjs.org/acorn-walk/-/acorn-walk-8.2.0.tgz",
+            "integrity": "sha512-k+iyHEuPgSw6SbuDpGQM+06HQUa04DZ3o+F6CSzXMvvI5KMvnaEqXe+YVe555R9nn6GPt404fos4wcgpw12SDA=="
+        },
+        "agent-base": {
+            "version": "6.0.2",
+            "resolved": "https://registry.npmjs.org/agent-base/-/agent-base-6.0.2.tgz",
+            "integrity": "sha512-RZNwNclF7+MS/8bDg70amg32dyeZGZxiDuQmZxKLAlQjr3jGyLx+4Kkk58UO7D2QdgFIQCovuSuZESne6RG6XQ==",
+            "requires": {
+                "debug": "4"
+            }
+        },
+        "agentkeepalive": {
+            "version": "3.5.2",
+            "resolved": "https://registry.npmjs.org/agentkeepalive/-/agentkeepalive-3.5.2.tgz",
+            "integrity": "sha512-e0L/HNe6qkQ7H19kTlRRqUibEAwDK5AFk6y3PtMsuut2VAH6+Q4xZml1tNDJD7kSAyqmbG/K08K5WEJYtUrSlQ==",
+            "requires": {
+                "humanize-ms": "^1.2.1"
+            }
+        },
         "ajv": {
             "version": "6.12.6",
             "resolved": "https://registry.npmjs.org/ajv/-/ajv-6.12.6.tgz",
             "integrity": "sha512-TaTivMB6pYI1kXwrFlEhLeGfOqoDNdTxjCdwRfFFkEA30Eu+k48W34nlok2EYWJfFFzqaEmichdNM7th6M5HNw==",
             "dev": true
         },
+        "ast-types": {
+            "version": "0.13.4",
+            "resolved": "https://registry.npmjs.org/ast-types/-/ast-types-0.13.4.tgz",
+            "integrity": "sha512-x1FCFnFifvYDDzTaLII71vG5uvDwgtmDTEVWAxrgeiR8VjMONcCXJx7E+USjDtHlwFmt9MysbqgF9b9Vjr6w+w==",
+            "requires": {
+                "tslib": "^2.0.1"
+            }
+        },
         "async-validator": {
             "version": "4.0.7",
             "resolved": "https://registry.npmjs.org/async-validator/-/async-validator-4.0.7.tgz",
             "integrity": "sha512-Pj2IR7u8hmUEDOwB++su6baaRi+QvsgajuFB9j95foM1N2gy5HM4z60hfusIO0fBPG5uLAEl6yCJr1jNSVugEQ==",
             "dev": true
         },
+        "asynckit": {
+            "version": "0.4.0",
+            "resolved": "https://registry.npmjs.org/asynckit/-/asynckit-0.4.0.tgz",
+            "integrity": "sha1-x57Zf380y48robyXkLzDZkdLS3k="
+        },
         "autoprefixer": {
             "version": "10.2.5",
             "resolved": "https://registry.npmjs.org/autoprefixer/-/autoprefixer-10.2.5.tgz",
             "integrity": "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw==",
             "dev": true
         },
+        "base64-js": {
+            "version": "1.5.1",
+            "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz",
+            "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA=="
+        },
         "big.js": {
             "version": "5.2.2",
             "resolved": "https://registry.npmjs.org/big.js/-/big.js-5.2.2.tgz",
                 "picocolors": "^1.0.0"
             }
         },
+        "buffer": {
+            "version": "6.0.3",
+            "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+            "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+            "requires": {
+                "base64-js": "^1.3.1",
+                "ieee754": "^1.2.1"
+            }
+        },
         "bytes": {
             "version": "3.1.1",
             "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.1.tgz",
-            "integrity": "sha512-dWe4nWO/ruEOY7HkUJ5gFt1DCFV9zPRoJr8pV0/ASQermOZjtq8jMjOprC0Kd10GLN+l7xaUPvxzJFWtxGu8Fg==",
-            "dev": true
+            "integrity": "sha512-dWe4nWO/ruEOY7HkUJ5gFt1DCFV9zPRoJr8pV0/ASQermOZjtq8jMjOprC0Kd10GLN+l7xaUPvxzJFWtxGu8Fg=="
         },
         "call-bind": {
             "version": "1.0.2",
             "integrity": "sha512-YhF/hG6nqBEllymSIjLtR2iWDDnChvhnVJqp+vloyt2tEHFG1yBR+ac2B/rOw0qOK0m0lEXU2dv4E/sMk5P9Kg==",
             "dev": true
         },
+        "cbor-js": {
+            "version": "0.1.0",
+            "resolved": "https://registry.npmjs.org/cbor-js/-/cbor-js-0.1.0.tgz",
+            "integrity": "sha1-yAzmEg84fo+qdDcN/aIdlluPx/k="
+        },
+        "cbor-sync": {
+            "version": "1.0.4",
+            "resolved": "https://registry.npmjs.org/cbor-sync/-/cbor-sync-1.0.4.tgz",
+            "integrity": "sha512-GWlXN4wiz0vdWWXBU71Dvc1q3aBo0HytqwAZnXF1wOwjqNnDWA1vZ1gDMFLlqohak31VQzmhiYfiCX5QSSfagA=="
+        },
         "chalk": {
             "version": "2.4.2",
             "resolved": "https://registry.npmjs.org/chalk/-/chalk-2.4.2.tgz",
             "integrity": "sha512-MKGMzyfeuutC/ZJ1cba9NqcNpfeqMUcYmyF1ZFY6/Cn7CNSAKx6a+s48sqLqyAiZuaP2TcqMhoo+dlwFnVxT9w==",
             "dev": true
         },
+        "combined-stream": {
+            "version": "1.0.8",
+            "resolved": "https://registry.npmjs.org/combined-stream/-/combined-stream-1.0.8.tgz",
+            "integrity": "sha512-FQN4MRfuJeHf7cBbBMJFXhKSDq+2kAArBlmRBvcvFE5BB1HZKXtSFASDhdlz9zOYwxh8lDdnvmMOe/+5cdoEdg==",
+            "requires": {
+                "delayed-stream": "~1.0.0"
+            }
+        },
+        "component-emitter": {
+            "version": "1.3.0",
+            "resolved": "https://registry.npmjs.org/component-emitter/-/component-emitter-1.3.0.tgz",
+            "integrity": "sha512-Rd3se6QB+sO1TwqZjscQrurpEPIfO0/yYnSin6Q/rD3mOutHvUrCAhJub3r90uNb+SESBuE0QYoB90YdfatsRg=="
+        },
         "concat-map": {
             "version": "0.0.1",
             "resolved": "https://registry.npmjs.org/concat-map/-/concat-map-0.0.1.tgz",
             "integrity": "sha512-hIP3EEPs8tB9AT1L+NUqtwOAps4mk2Zob89MWXMHjHWg9milF/j4osnnQLXBCBFBk/tvIG/tUc9mOUJiPBhPXA==",
             "dev": true
         },
+        "cookiejar": {
+            "version": "2.1.3",
+            "resolved": "https://registry.npmjs.org/cookiejar/-/cookiejar-2.1.3.tgz",
+            "integrity": "sha512-JxbCBUdrfr6AQjOXrxoTvAMJO4HBTUIlBzslcJPAz+/KT8yk53fXun51u+RenNYvad/+Vc2DIz5o9UxlCDymFQ=="
+        },
+        "core-util-is": {
+            "version": "1.0.3",
+            "resolved": "https://registry.npmjs.org/core-util-is/-/core-util-is-1.0.3.tgz",
+            "integrity": "sha512-ZQBvi1DcpJ4GDqanjucZ2Hj3wEO5pZDS89BWbkcrvdxksJorwUDDZamX9ldFkp9aw2lmBDLgkObEA4DWNJ9FYQ=="
+        },
         "cross-spawn": {
             "version": "7.0.3",
             "resolved": "https://registry.npmjs.org/cross-spawn/-/cross-spawn-7.0.3.tgz",
             "resolved": "https://registry.npmjs.org/csstype/-/csstype-2.6.17.tgz",
             "integrity": "sha512-u1wmTI1jJGzCJzWndZo8mk4wnPTZd1eOIYTYvuEyOQGfmDl3TrabCCfKnOC86FZwW/9djqTl933UF/cS425i9A=="
         },
+        "data-uri-to-buffer": {
+            "version": "3.0.1",
+            "resolved": "https://registry.npmjs.org/data-uri-to-buffer/-/data-uri-to-buffer-3.0.1.tgz",
+            "integrity": "sha512-WboRycPNsVw3B3TL559F7kuBUM4d8CgMEvk6xEJlOp7OBPjt6G7z8WMWlD2rOFZLk6OYfFIUGsCOWzcQH9K2og=="
+        },
         "date-fns": {
             "version": "2.26.0",
             "resolved": "https://registry.npmjs.org/date-fns/-/date-fns-2.26.0.tgz",
             "version": "4.3.2",
             "resolved": "https://registry.npmjs.org/debug/-/debug-4.3.2.tgz",
             "integrity": "sha512-mOp8wKcvj7XxC78zLgw/ZA+6TSgkoE2C/ienthhRD298T7UNwAg9diBpLRxC0mOezLl4B0xV7M0cCO6P/O0Xhw==",
-            "dev": true,
             "requires": {
                 "ms": "2.1.2"
             }
         "deep-is": {
             "version": "0.1.4",
             "resolved": "https://registry.npmjs.org/deep-is/-/deep-is-0.1.4.tgz",
-            "integrity": "sha512-oIPzksmTg4/MriiaYGO+okXDT7ztn/w3Eptv/+gSIdMdKsJo0u4CfYNFJPy+4SKMuCqGw2wxnA+URMg3t8a/bQ==",
-            "dev": true
+            "integrity": "sha512-oIPzksmTg4/MriiaYGO+okXDT7ztn/w3Eptv/+gSIdMdKsJo0u4CfYNFJPy+4SKMuCqGw2wxnA+URMg3t8a/bQ=="
+        },
+        "degenerator": {
+            "version": "3.0.2",
+            "resolved": "https://registry.npmjs.org/degenerator/-/degenerator-3.0.2.tgz",
+            "integrity": "sha512-c0mef3SNQo56t6urUU6tdQAs+ThoD0o9B9MJ8HEt7NQcGEILCRFqQb7ZbP9JAv+QF1Ky5plydhMR/IrqWDm+TQ==",
+            "requires": {
+                "ast-types": "^0.13.2",
+                "escodegen": "^1.8.1",
+                "esprima": "^4.0.0",
+                "vm2": "^3.9.8"
+            }
+        },
+        "delayed-stream": {
+            "version": "1.0.0",
+            "resolved": "https://registry.npmjs.org/delayed-stream/-/delayed-stream-1.0.0.tgz",
+            "integrity": "sha1-3zrhmayt+31ECqrgsp4icrJOxhk="
         },
         "depd": {
             "version": "1.1.2",
             "resolved": "https://registry.npmjs.org/depd/-/depd-1.1.2.tgz",
-            "integrity": "sha1-m81S4UwJd2PnSbJ0xDRu0uVgtak=",
-            "dev": true
+            "integrity": "sha1-m81S4UwJd2PnSbJ0xDRu0uVgtak="
         },
         "diff-sequences": {
             "version": "26.6.2",
             "integrity": "sha1-G2HAViGQqN/2rjuyzwIAyhMLhtQ=",
             "dev": true
         },
+        "escodegen": {
+            "version": "1.14.3",
+            "resolved": "https://registry.npmjs.org/escodegen/-/escodegen-1.14.3.tgz",
+            "integrity": "sha512-qFcX0XJkdg+PB3xjZZG/wKSuT1PnQWx57+TVSjIMmILd2yC/6ByYElPwJnslDsuWuSAp4AwJGumarAAmJch5Kw==",
+            "requires": {
+                "esprima": "^4.0.1",
+                "estraverse": "^4.2.0",
+                "esutils": "^2.0.2",
+                "optionator": "^0.8.1",
+                "source-map": "~0.6.1"
+            },
+            "dependencies": {
+                "levn": {
+                    "version": "0.3.0",
+                    "resolved": "https://registry.npmjs.org/levn/-/levn-0.3.0.tgz",
+                    "integrity": "sha1-OwmSTt+fCDwEkP3UwLxEIeBHZO4=",
+                    "requires": {
+                        "prelude-ls": "~1.1.2",
+                        "type-check": "~0.3.2"
+                    }
+                },
+                "optionator": {
+                    "version": "0.8.3",
+                    "resolved": "https://registry.npmjs.org/optionator/-/optionator-0.8.3.tgz",
+                    "integrity": "sha512-+IW9pACdk3XWmmTXG8m3upGUJst5XRGzxMRjXzAuJ1XnIFNvfhjjIuYkDvysnPQ7qzqVzLt78BCruntqRhWQbA==",
+                    "requires": {
+                        "deep-is": "~0.1.3",
+                        "fast-levenshtein": "~2.0.6",
+                        "levn": "~0.3.0",
+                        "prelude-ls": "~1.1.2",
+                        "type-check": "~0.3.2",
+                        "word-wrap": "~1.2.3"
+                    }
+                },
+                "prelude-ls": {
+                    "version": "1.1.2",
+                    "resolved": "https://registry.npmjs.org/prelude-ls/-/prelude-ls-1.1.2.tgz",
+                    "integrity": "sha1-IZMqVJ9eUv/ZqCf1cOBL5iqX2lQ="
+                },
+                "type-check": {
+                    "version": "0.3.2",
+                    "resolved": "https://registry.npmjs.org/type-check/-/type-check-0.3.2.tgz",
+                    "integrity": "sha1-WITKtRLPHTVeP7eE8wgEsrUg23I=",
+                    "requires": {
+                        "prelude-ls": "~1.1.2"
+                    }
+                }
+            }
+        },
         "eslint": {
             "version": "8.3.0",
             "resolved": "https://registry.npmjs.org/eslint/-/eslint-8.3.0.tgz",
                 }
             }
         },
+        "esprima": {
+            "version": "4.0.1",
+            "resolved": "https://registry.npmjs.org/esprima/-/esprima-4.0.1.tgz",
+            "integrity": "sha512-eGuFFw7Upda+g4p+QHvnW0RyTX/SVeJBDM/gCtMARO0cLuT2HcEKnTPvhjV6aGeqrCB/sbNop0Kszm0jsaWU4A=="
+        },
         "esquery": {
             "version": "1.4.0",
             "resolved": "https://registry.npmjs.org/esquery/-/esquery-1.4.0.tgz",
         "estraverse": {
             "version": "4.3.0",
             "resolved": "https://registry.npmjs.org/estraverse/-/estraverse-4.3.0.tgz",
-            "integrity": "sha512-39nnKffWz8xN1BU/2c79n9nB9HDzo0niYUqx6xyqUnyoAnQyyWpOTdZEeiCch8BBu515t4wp9ZmgVfVhn9EBpw==",
-            "dev": true
+            "integrity": "sha512-39nnKffWz8xN1BU/2c79n9nB9HDzo0niYUqx6xyqUnyoAnQyyWpOTdZEeiCch8BBu515t4wp9ZmgVfVhn9EBpw=="
         },
         "estree-walker": {
             "version": "2.0.2",
         "esutils": {
             "version": "2.0.3",
             "resolved": "https://registry.npmjs.org/esutils/-/esutils-2.0.3.tgz",
-            "integrity": "sha512-kVscqXk4OCp68SZ0dkgEKVi6/8ij300KBWTJq32P/dYeWTSwK41WyTxalN1eRmA5Z9UU/LX9D7FWSmV9SAYx6g==",
-            "dev": true
+            "integrity": "sha512-kVscqXk4OCp68SZ0dkgEKVi6/8ij300KBWTJq32P/dYeWTSwK41WyTxalN1eRmA5Z9UU/LX9D7FWSmV9SAYx6g=="
         },
         "evtd": {
             "version": "0.2.3",
         "fast-levenshtein": {
             "version": "2.0.6",
             "resolved": "https://registry.npmjs.org/fast-levenshtein/-/fast-levenshtein-2.0.6.tgz",
-            "integrity": "sha1-PYpcZog6FqMMqGQ+hR8Zuqd5eRc=",
-            "dev": true
+            "integrity": "sha1-PYpcZog6FqMMqGQ+hR8Zuqd5eRc="
+        },
+        "fast-safe-stringify": {
+            "version": "2.1.1",
+            "resolved": "https://registry.npmjs.org/fast-safe-stringify/-/fast-safe-stringify-2.1.1.tgz",
+            "integrity": "sha512-W+KJc2dmILlPplD/H4K9l9LcAHAfPtP6BY84uVLXQ6Evcz9Lcg33Y2z1IVblT6xdY54PXYVHEv+0Wpq8Io6zkA=="
         },
         "fastq": {
             "version": "1.13.0",
                 "flat-cache": "^3.0.4"
             }
         },
+        "file-uri-to-path": {
+            "version": "2.0.0",
+            "resolved": "https://registry.npmjs.org/file-uri-to-path/-/file-uri-to-path-2.0.0.tgz",
+            "integrity": "sha512-hjPFI8oE/2iQPVe4gbrJ73Pp+Xfub2+WI2LlXDbsaJBwT5wuMh35WNWVYYTpnz895shtwfyutMFLFywpQAFdLg=="
+        },
         "fill-range": {
             "version": "7.0.1",
             "resolved": "https://registry.npmjs.org/fill-range/-/fill-range-7.0.1.tgz",
             "integrity": "sha512-dVsPA/UwQ8+2uoFe5GHtiBMu48dWLTdsuEd7CKGlZlD78r1TTWBvDuFaFGKCo/ZfEr95Uk56vZoX86OsHkUeIg==",
             "dev": true
         },
+        "form-data": {
+            "version": "3.0.1",
+            "resolved": "https://registry.npmjs.org/form-data/-/form-data-3.0.1.tgz",
+            "integrity": "sha512-RHkBKtLWUVwd7SqRIvCZMEvAMoGUp0XU+seQiZejj0COz3RI3hWP4sCv3gZWWLjJTd7rGwcsF5eKZGii0r/hbg==",
+            "requires": {
+                "asynckit": "^0.4.0",
+                "combined-stream": "^1.0.8",
+                "mime-types": "^2.1.12"
+            }
+        },
+        "formidable": {
+            "version": "1.2.6",
+            "resolved": "https://registry.npmjs.org/formidable/-/formidable-1.2.6.tgz",
+            "integrity": "sha512-KcpbcpuLNOwrEjnbpMC0gS+X8ciDoZE1kkqzat4a8vrprf+s9pKNQ/QIwWfbfs4ltgmFl3MD177SNTkve3BwGQ=="
+        },
         "fraction.js": {
             "version": "4.0.13",
             "resolved": "https://registry.npmjs.org/fraction.js/-/fraction.js-4.0.13.tgz",
             "integrity": "sha512-E1fz2Xs9ltlUp+qbiyx9wmt2n9dRzPsS11Jtdb8D2o+cC7wr9xkkKsVKJuBX0ST+LVS+LhLO+SbLJNtfWcJvXA==",
             "dev": true
         },
+        "fs-extra": {
+            "version": "8.1.0",
+            "resolved": "https://registry.npmjs.org/fs-extra/-/fs-extra-8.1.0.tgz",
+            "integrity": "sha512-yhlQgA6mnOJUKOsRUFsgJdQCvkKhcz8tlZG5HBQfReYZy46OwLcY+Zia0mtdHsOo9y/hP+CxMN0TU9QxoOtG4g==",
+            "requires": {
+                "graceful-fs": "^4.2.0",
+                "jsonfile": "^4.0.0",
+                "universalify": "^0.1.0"
+            }
+        },
         "fs.realpath": {
             "version": "1.0.0",
             "resolved": "https://registry.npmjs.org/fs.realpath/-/fs.realpath-1.0.0.tgz",
             "dev": true,
             "optional": true
         },
+        "ftp": {
+            "version": "0.3.10",
+            "resolved": "https://registry.npmjs.org/ftp/-/ftp-0.3.10.tgz",
+            "integrity": "sha1-kZfYYa2BQvPmPVqDv+TFn3MwiF0=",
+            "requires": {
+                "readable-stream": "1.1.x",
+                "xregexp": "2.0.0"
+            },
+            "dependencies": {
+                "readable-stream": {
+                    "version": "1.1.14",
+                    "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-1.1.14.tgz",
+                    "integrity": "sha1-fPTFTvZI44EwhMY23SB54WbAgdk=",
+                    "requires": {
+                        "core-util-is": "~1.0.0",
+                        "inherits": "~2.0.1",
+                        "isarray": "0.0.1",
+                        "string_decoder": "~0.10.x"
+                    }
+                },
+                "string_decoder": {
+                    "version": "0.10.31",
+                    "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-0.10.31.tgz",
+                    "integrity": "sha1-YuIDvEF2bGwoyfyEMB2rHFMQ+pQ="
+                }
+            }
+        },
         "function-bind": {
             "version": "1.1.1",
             "resolved": "https://registry.npmjs.org/function-bind/-/function-bind-1.1.1.tgz",
                 "has-symbols": "^1.0.1"
             }
         },
+        "get-uri": {
+            "version": "3.0.2",
+            "resolved": "https://registry.npmjs.org/get-uri/-/get-uri-3.0.2.tgz",
+            "integrity": "sha512-+5s0SJbGoyiJTZZ2JTpFPLMPSch72KEqGOTvQsBqg0RBWvwhWUSYZFAtz3TPW0GXJuLBJPts1E241iHg+VRfhg==",
+            "requires": {
+                "@tootallnate/once": "1",
+                "data-uri-to-buffer": "3",
+                "debug": "4",
+                "file-uri-to-path": "2",
+                "fs-extra": "^8.1.0",
+                "ftp": "^0.3.10"
+            }
+        },
         "glob": {
             "version": "7.2.0",
             "resolved": "https://registry.npmjs.org/glob/-/glob-7.2.0.tgz",
                 "is-glob": "^4.0.3"
             }
         },
+        "graceful-fs": {
+            "version": "4.2.9",
+            "resolved": "https://registry.npmjs.org/graceful-fs/-/graceful-fs-4.2.9.tgz",
+            "integrity": "sha512-NtNxqUcXgpW2iMrfqSfR73Glt39K+BLwWsPs94yR63v45T0Wbej7eRmL5cWfwEgqXnmjQp3zaJTshdRW/qC2ZQ=="
+        },
         "has": {
             "version": "1.0.3",
             "resolved": "https://registry.npmjs.org/has/-/has-1.0.3.tgz",
             "version": "1.8.1",
             "resolved": "https://registry.npmjs.org/http-errors/-/http-errors-1.8.1.tgz",
             "integrity": "sha512-Kpk9Sm7NmI+RHhnj6OIWDI1d6fIoFAtFt9RLaTMRlg/8w49juAStsrBgp0Dp4OdxdVbRIeKhtCUvoi/RuAhO4g==",
-            "dev": true,
             "requires": {
                 "depd": "~1.1.2",
                 "inherits": "2.0.4",
                 "toidentifier": "1.0.1"
             }
         },
+        "http-proxy-agent": {
+            "version": "4.0.1",
+            "resolved": "https://registry.npmjs.org/http-proxy-agent/-/http-proxy-agent-4.0.1.tgz",
+            "integrity": "sha512-k0zdNgqWTGA6aeIRVpvfVob4fL52dTfaehylg0Y4UvSySvOq/Y+BOyPrgpUrA7HylqvU8vIZGsRuXmspskV0Tg==",
+            "requires": {
+                "@tootallnate/once": "1",
+                "agent-base": "6",
+                "debug": "4"
+            }
+        },
+        "https-proxy-agent": {
+            "version": "5.0.0",
+            "resolved": "https://registry.npmjs.org/https-proxy-agent/-/https-proxy-agent-5.0.0.tgz",
+            "integrity": "sha512-EkYm5BcKUGiduxzSt3Eppko+PiNWNEpa4ySk9vTC6wDsQJW9rHSa+UhGNJoRYp7bz6Ht1eaRIa6QaJqO5rCFbA==",
+            "requires": {
+                "agent-base": "6",
+                "debug": "4"
+            }
+        },
+        "humanize-ms": {
+            "version": "1.2.1",
+            "resolved": "https://registry.npmjs.org/humanize-ms/-/humanize-ms-1.2.1.tgz",
+            "integrity": "sha1-xG4xWaKT9riW2ikxbYtv6Lt5u+0=",
+            "requires": {
+                "ms": "^2.0.0"
+            }
+        },
         "iconv-lite": {
             "version": "0.4.24",
             "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz",
             "integrity": "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==",
-            "dev": true,
             "requires": {
                 "safer-buffer": ">= 2.1.2 < 3"
             }
             "integrity": "sha512-soFhflCVWLfRNOPU3iv5Z9VUdT44xFRbzjLsEzSr5AQmgqPMTHdU3PMT1Cf1ssx8fLNJDA1juftYl+PUcv3MqA==",
             "dev": true
         },
+        "ieee754": {
+            "version": "1.2.1",
+            "resolved": "https://registry.npmjs.org/ieee754/-/ieee754-1.2.1.tgz",
+            "integrity": "sha512-dcyqhDvX1C46lXZcVqCpK+FtMRQVdIMN6/Df5js2zouUsqG7I6sFxitIC+7KYK29KdXOLHdu9zL4sFnoVQnqaA=="
+        },
         "ignore": {
             "version": "4.0.6",
             "resolved": "https://registry.npmjs.org/ignore/-/ignore-4.0.6.tgz",
         "inherits": {
             "version": "2.0.4",
             "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
-            "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==",
-            "dev": true
+            "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
+        },
+        "ip": {
+            "version": "1.1.5",
+            "resolved": "https://registry.npmjs.org/ip/-/ip-1.1.5.tgz",
+            "integrity": "sha1-vd7XARQpCCjAoDnnLvJfWq7ENUo="
         },
         "is-core-module": {
             "version": "2.3.0",
                 "has-tostringtag": "^1.0.0"
             }
         },
+        "isarray": {
+            "version": "0.0.1",
+            "resolved": "https://registry.npmjs.org/isarray/-/isarray-0.0.1.tgz",
+            "integrity": "sha1-ihis/Kmo9Bd+Cav8YDiTmwXR7t8="
+        },
         "isexe": {
             "version": "2.0.0",
             "resolved": "https://registry.npmjs.org/isexe/-/isexe-2.0.0.tgz",
                 "minimist": "^1.2.0"
             }
         },
+        "jsonfile": {
+            "version": "4.0.0",
+            "resolved": "https://registry.npmjs.org/jsonfile/-/jsonfile-4.0.0.tgz",
+            "integrity": "sha1-h3Gq4HmbZAdrdmQPygWPnBDjPss=",
+            "requires": {
+                "graceful-fs": "^4.1.6"
+            }
+        },
         "jstransformer": {
             "version": "1.0.0",
             "resolved": "https://registry.npmjs.org/jstransformer/-/jstransformer-1.0.0.tgz",
                 "type-check": "~0.4.0"
             }
         },
+        "lil-uuid": {
+            "version": "0.1.1",
+            "resolved": "https://registry.npmjs.org/lil-uuid/-/lil-uuid-0.1.1.tgz",
+            "integrity": "sha1-+e3PI/AOQr9D8PhD2Y2LU/M0HxY="
+        },
         "loader-utils": {
             "version": "1.4.0",
             "resolved": "https://registry.npmjs.org/loader-utils/-/loader-utils-1.4.0.tgz",
             "version": "5.1.1",
             "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-5.1.1.tgz",
             "integrity": "sha512-KpNARQA3Iwv+jTA0utUVVbrh+Jlrr1Fv0e56GGzAFOXN7dk/FviaDW8LHmK52DlcH4WP2n6gI8vN1aesBFgo9w==",
-            "dev": true,
             "requires": {
                 "yallist": "^3.0.2"
             }
             "integrity": "sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg==",
             "dev": true
         },
+        "methods": {
+            "version": "1.1.2",
+            "resolved": "https://registry.npmjs.org/methods/-/methods-1.1.2.tgz",
+            "integrity": "sha1-VSmk1nZUE07cxSZmVoNbD4Ua/O4="
+        },
         "micromatch": {
             "version": "4.0.4",
             "resolved": "https://registry.npmjs.org/micromatch/-/micromatch-4.0.4.tgz",
                 "picomatch": "^2.2.3"
             }
         },
+        "mime": {
+            "version": "2.6.0",
+            "resolved": "https://registry.npmjs.org/mime/-/mime-2.6.0.tgz",
+            "integrity": "sha512-USPkMeET31rOMiarsBNIHZKLGgvKc/LrjofAnBlOttf5ajRvqiRA8QsenbcooctK6d6Ts6aqZXBA+XbkKthiQg=="
+        },
         "mime-db": {
             "version": "1.51.0",
             "resolved": "https://registry.npmjs.org/mime-db/-/mime-db-1.51.0.tgz",
-            "integrity": "sha512-5y8A56jg7XVQx2mbv1lu49NR4dokRnhZYTtL+KGfaa27uq4pSTXkwQkFJl4pkRMyNFz/EtYDSkiiEHx3F7UN6g==",
-            "dev": true
+            "integrity": "sha512-5y8A56jg7XVQx2mbv1lu49NR4dokRnhZYTtL+KGfaa27uq4pSTXkwQkFJl4pkRMyNFz/EtYDSkiiEHx3F7UN6g=="
         },
         "mime-types": {
             "version": "2.1.34",
             "resolved": "https://registry.npmjs.org/mime-types/-/mime-types-2.1.34.tgz",
             "integrity": "sha512-6cP692WwGIs9XXdOO4++N+7qjqv0rqxxVvJ3VHPh/Sc9mVZcQP+ZGhkKiTvWMQRr2tbHkJP/Yn7Y0npb3ZBs4A==",
-            "dev": true,
             "requires": {
                 "mime-db": "1.51.0"
             }
         "ms": {
             "version": "2.1.2",
             "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.2.tgz",
-            "integrity": "sha512-sGkPx+VjMtmA6MX27oA4FBFELFCZZ4S4XqeGOXCv68tT+jb3vk/RyaKWP0PTKyWtmLSM0b+adUTEvbs1PEaH2w==",
-            "dev": true
+            "integrity": "sha512-sGkPx+VjMtmA6MX27oA4FBFELFCZZ4S4XqeGOXCv68tT+jb3vk/RyaKWP0PTKyWtmLSM0b+adUTEvbs1PEaH2w=="
         },
         "naive-ui": {
             "version": "2.20.3",
             "integrity": "sha1-Sr6/7tdUHywnrPspvbvRXI1bpPc=",
             "dev": true
         },
+        "netmask": {
+            "version": "2.0.2",
+            "resolved": "https://registry.npmjs.org/netmask/-/netmask-2.0.2.tgz",
+            "integrity": "sha512-dBpDMdxv9Irdq66304OLfEmQ9tbNRFnFTuZiLo+bD+r332bBmMJ8GBLXklIXXgxd3+v9+KUnZaUR5PJMa75Gsg=="
+        },
         "node-releases": {
             "version": "2.0.1",
             "resolved": "https://registry.npmjs.org/node-releases/-/node-releases-2.0.1.tgz",
                 "word-wrap": "^1.2.3"
             }
         },
+        "pac-proxy-agent": {
+            "version": "5.0.0",
+            "resolved": "https://registry.npmjs.org/pac-proxy-agent/-/pac-proxy-agent-5.0.0.tgz",
+            "integrity": "sha512-CcFG3ZtnxO8McDigozwE3AqAw15zDvGH+OjXO4kzf7IkEKkQ4gxQ+3sdF50WmhQ4P/bVusXcqNE2S3XrNURwzQ==",
+            "requires": {
+                "@tootallnate/once": "1",
+                "agent-base": "6",
+                "debug": "4",
+                "get-uri": "3",
+                "http-proxy-agent": "^4.0.1",
+                "https-proxy-agent": "5",
+                "pac-resolver": "^5.0.0",
+                "raw-body": "^2.2.0",
+                "socks-proxy-agent": "5"
+            }
+        },
+        "pac-resolver": {
+            "version": "5.0.0",
+            "resolved": "https://registry.npmjs.org/pac-resolver/-/pac-resolver-5.0.0.tgz",
+            "integrity": "sha512-H+/A6KitiHNNW+bxBKREk2MCGSxljfqRX76NjummWEYIat7ldVXRU3dhRIE3iXZ0nvGBk6smv3nntxKkzRL8NA==",
+            "requires": {
+                "degenerator": "^3.0.1",
+                "ip": "^1.1.5",
+                "netmask": "^2.0.1"
+            }
+        },
         "parent-module": {
             "version": "1.0.1",
             "resolved": "https://registry.npmjs.org/parent-module/-/parent-module-1.0.1.tgz",
                 "asap": "~2.0.3"
             }
         },
+        "proxy-agent": {
+            "version": "5.0.0",
+            "resolved": "https://registry.npmjs.org/proxy-agent/-/proxy-agent-5.0.0.tgz",
+            "integrity": "sha512-gkH7BkvLVkSfX9Dk27W6TyNOWWZWRilRfk1XxGNWOYJ2TuedAv1yFpCaU9QSBmBe716XOTNpYNOzhysyw8xn7g==",
+            "requires": {
+                "agent-base": "^6.0.0",
+                "debug": "4",
+                "http-proxy-agent": "^4.0.0",
+                "https-proxy-agent": "^5.0.0",
+                "lru-cache": "^5.1.1",
+                "pac-proxy-agent": "^5.0.0",
+                "proxy-from-env": "^1.0.0",
+                "socks-proxy-agent": "^5.0.0"
+            }
+        },
+        "proxy-from-env": {
+            "version": "1.1.0",
+            "resolved": "https://registry.npmjs.org/proxy-from-env/-/proxy-from-env-1.1.0.tgz",
+            "integrity": "sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg=="
+        },
+        "pubnub": {
+            "version": "5.0.0",
+            "resolved": "https://registry.npmjs.org/pubnub/-/pubnub-5.0.0.tgz",
+            "integrity": "sha512-oia2VLlO7088nMfDKZbw4RWdbhgiO2YVOlEm26fvrfZL5/MZHwb/QPM+x3Xgyw4+lrGmdzotf3JGFsufqpjLaw==",
+            "requires": {
+                "@babel/runtime": "^7.10.5",
+                "@tsconfig/node12": "^1.0.9",
+                "agentkeepalive": "^3.5.2",
+                "buffer": "^6.0.3",
+                "cbor-js": "^0.1.0",
+                "cbor-sync": "^1.0.4",
+                "lil-uuid": "^0.1.1",
+                "superagent": "^6.1.0",
+                "superagent-proxy": "^3.0.0"
+            }
+        },
         "pug": {
             "version": "3.0.2",
             "resolved": "https://registry.npmjs.org/pug/-/pug-3.0.2.tgz",
         "qs": {
             "version": "6.9.6",
             "resolved": "https://registry.npmjs.org/qs/-/qs-6.9.6.tgz",
-            "integrity": "sha512-TIRk4aqYLNoJUbd+g2lEdz5kLWIuTMRagAXxl78Q0RiVjAOugHmeKNGdd3cwo/ktpf9aL9epCfFqWDEKysUlLQ==",
-            "dev": true
+            "integrity": "sha512-TIRk4aqYLNoJUbd+g2lEdz5kLWIuTMRagAXxl78Q0RiVjAOugHmeKNGdd3cwo/ktpf9aL9epCfFqWDEKysUlLQ=="
         },
         "queue-microtask": {
             "version": "1.2.3",
             "version": "2.4.2",
             "resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.4.2.tgz",
             "integrity": "sha512-RPMAFUJP19WIet/99ngh6Iv8fzAbqum4Li7AD6DtGaW2RpMB/11xDoalPiJMTbu6I3hkbMVkATvZrqb9EEqeeQ==",
-            "dev": true,
             "requires": {
                 "bytes": "3.1.1",
                 "http-errors": "1.8.1",
                 "pify": "^2.3.0"
             }
         },
+        "readable-stream": {
+            "version": "3.6.0",
+            "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.0.tgz",
+            "integrity": "sha512-BViHy7LKeTz4oNnkcLJ+lVSL6vpiFeX6/d3oSH8zCW7UxP2onchk+vTGB143xuFjHS3deTgkKoXXymXqymiIdA==",
+            "requires": {
+                "inherits": "^2.0.3",
+                "string_decoder": "^1.1.1",
+                "util-deprecate": "^1.0.1"
+            }
+        },
+        "regenerator-runtime": {
+            "version": "0.13.9",
+            "resolved": "https://registry.npmjs.org/regenerator-runtime/-/regenerator-runtime-0.13.9.tgz",
+            "integrity": "sha512-p3VT+cOEgxFsRRA9X4lkI1E+k2/CtnKtU4gcxyaCUreilL/vqI6CdZ3wxVUx3UOUg+gnUOQQcRI7BmSI656MYA=="
+        },
         "regexpp": {
             "version": "3.2.0",
             "resolved": "https://registry.npmjs.org/regexpp/-/regexpp-3.2.0.tgz",
                 "queue-microtask": "^1.2.2"
             }
         },
+        "safe-buffer": {
+            "version": "5.2.1",
+            "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
+            "integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ=="
+        },
         "safer-buffer": {
             "version": "2.1.2",
             "resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
-            "integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==",
-            "dev": true
+            "integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg=="
         },
         "seemly": {
             "version": "0.3.2",
         "setprototypeof": {
             "version": "1.2.0",
             "resolved": "https://registry.npmjs.org/setprototypeof/-/setprototypeof-1.2.0.tgz",
-            "integrity": "sha512-E5LDX7Wrp85Kil5bhZv46j8jOeboKq5JMmYM3gVGdGH8xFpPWXUMsNrlODCrkoxMEeNi/XZIwuRvY4XNwYMJpw==",
-            "dev": true
+            "integrity": "sha512-E5LDX7Wrp85Kil5bhZv46j8jOeboKq5JMmYM3gVGdGH8xFpPWXUMsNrlODCrkoxMEeNi/XZIwuRvY4XNwYMJpw=="
         },
         "shebang-command": {
             "version": "2.0.0",
             "integrity": "sha512-7++dFhtcx3353uBaq8DDR4NuxBetBzC7ZQOhmTQInHEd6bSrXdiEyzCvG07Z44UYdLShWUyXt5M/yhz8ekcb1A==",
             "dev": true
         },
+        "smart-buffer": {
+            "version": "4.2.0",
+            "resolved": "https://registry.npmjs.org/smart-buffer/-/smart-buffer-4.2.0.tgz",
+            "integrity": "sha512-94hK0Hh8rPqQl2xXc3HsaBoOXKV20MToPkcXvwbISWLEs+64sBq5kFgn2kJDHb1Pry9yrP0dxrCI9RRci7RXKg=="
+        },
+        "socks": {
+            "version": "2.6.2",
+            "resolved": "https://registry.npmjs.org/socks/-/socks-2.6.2.tgz",
+            "integrity": "sha512-zDZhHhZRY9PxRruRMR7kMhnf3I8hDs4S3f9RecfnGxvcBHQcKcIH/oUcEWffsfl1XxdYlA7nnlGbbTvPz9D8gA==",
+            "requires": {
+                "ip": "^1.1.5",
+                "smart-buffer": "^4.2.0"
+            }
+        },
+        "socks-proxy-agent": {
+            "version": "5.0.1",
+            "resolved": "https://registry.npmjs.org/socks-proxy-agent/-/socks-proxy-agent-5.0.1.tgz",
+            "integrity": "sha512-vZdmnjb9a2Tz6WEQVIurybSwElwPxMZaIc7PzqbJTrezcKNznv6giT7J7tZDZ1BojVaa1jvO/UiUdhDVB0ACoQ==",
+            "requires": {
+                "agent-base": "^6.0.2",
+                "debug": "4",
+                "socks": "^2.3.3"
+            }
+        },
         "source-map": {
             "version": "0.6.1",
             "resolved": "https://registry.npmjs.org/source-map/-/source-map-0.6.1.tgz",
         "statuses": {
             "version": "1.5.0",
             "resolved": "https://registry.npmjs.org/statuses/-/statuses-1.5.0.tgz",
-            "integrity": "sha1-Fhx9rBd2Wf2YEfQ3cfqZOBR4Yow=",
-            "dev": true
+            "integrity": "sha1-Fhx9rBd2Wf2YEfQ3cfqZOBR4Yow="
         },
         "string-hash": {
             "version": "1.1.3",
             "integrity": "sha1-6Kr8CsGFW0Zmkp7X3RJ1311sgRs=",
             "dev": true
         },
+        "string_decoder": {
+            "version": "1.3.0",
+            "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
+            "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
+            "requires": {
+                "safe-buffer": "~5.2.0"
+            }
+        },
         "strip-ansi": {
             "version": "3.0.1",
             "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-3.0.1.tgz",
                 "postcss": "^8.1.6"
             }
         },
+        "superagent": {
+            "version": "6.1.0",
+            "resolved": "https://registry.npmjs.org/superagent/-/superagent-6.1.0.tgz",
+            "integrity": "sha512-OUDHEssirmplo3F+1HWKUrUjvnQuA+nZI6i/JJBdXb5eq9IyEQwPyPpqND+SSsxf6TygpBEkUjISVRN4/VOpeg==",
+            "requires": {
+                "component-emitter": "^1.3.0",
+                "cookiejar": "^2.1.2",
+                "debug": "^4.1.1",
+                "fast-safe-stringify": "^2.0.7",
+                "form-data": "^3.0.0",
+                "formidable": "^1.2.2",
+                "methods": "^1.1.2",
+                "mime": "^2.4.6",
+                "qs": "^6.9.4",
+                "readable-stream": "^3.6.0",
+                "semver": "^7.3.2"
+            },
+            "dependencies": {
+                "lru-cache": {
+                    "version": "6.0.0",
+                    "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-6.0.0.tgz",
+                    "integrity": "sha512-Jo6dJ04CmSjuznwJSS3pUeWmd/H0ffTlkXXgwZi+eq1UCmqQwCh+eLsYOYCwY991i2Fah4h1BEMCx4qThGbsiA==",
+                    "requires": {
+                        "yallist": "^4.0.0"
+                    }
+                },
+                "semver": {
+                    "version": "7.3.5",
+                    "resolved": "https://registry.npmjs.org/semver/-/semver-7.3.5.tgz",
+                    "integrity": "sha512-PoeGJYh8HK4BTO/a9Tf6ZG3veo/A7ZVsYrSA6J8ny9nb3B1VrpkuN+z9OE5wfE5p6H4LchYZsegiQgbJD94ZFQ==",
+                    "requires": {
+                        "lru-cache": "^6.0.0"
+                    }
+                },
+                "yallist": {
+                    "version": "4.0.0",
+                    "resolved": "https://registry.npmjs.org/yallist/-/yallist-4.0.0.tgz",
+                    "integrity": "sha512-3wdGidZyq5PB084XLES5TpOSRA3wjXAlIWMhum2kRcv/41Sn2emQ0dycQW4uZXLejwKvg6EsvbdlVL+FYEct7A=="
+                }
+            }
+        },
+        "superagent-proxy": {
+            "version": "3.0.0",
+            "resolved": "https://registry.npmjs.org/superagent-proxy/-/superagent-proxy-3.0.0.tgz",
+            "integrity": "sha512-wAlRInOeDFyd9pyonrkJspdRAxdLrcsZ6aSnS+8+nu4x1aXbz6FWSTT9M6Ibze+eG60szlL7JA8wEIV7bPWuyQ==",
+            "requires": {
+                "debug": "^4.3.2",
+                "proxy-agent": "^5.0.0"
+            }
+        },
         "supports-color": {
             "version": "6.1.0",
             "resolved": "https://registry.npmjs.org/supports-color/-/supports-color-6.1.0.tgz",
         "toidentifier": {
             "version": "1.0.1",
             "resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz",
-            "integrity": "sha512-o5sSPKEkg/DIQNmH43V0/uerLrpzVedkUh8tGNvaeXpfpuwjKenlSox/2O/BTlZUtEe+JG7s5YhEz608PlAHRA==",
-            "dev": true
+            "integrity": "sha512-o5sSPKEkg/DIQNmH43V0/uerLrpzVedkUh8tGNvaeXpfpuwjKenlSox/2O/BTlZUtEe+JG7s5YhEz608PlAHRA=="
         },
         "token-stream": {
             "version": "1.0.0",
             "integrity": "sha512-wv9lBoPaeWsOgBSX09cpDi1HcO/A3aNfY+Qhvu8JnOSvVfSTmcXMKGrg9g8oTgWA8YLVqq+wt8p+eQvAhqKqlQ==",
             "dev": true
         },
+        "tslib": {
+            "version": "2.3.1",
+            "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.3.1.tgz",
+            "integrity": "sha512-77EbyPPpMz+FRFRuAFlWMtmgUWGe9UOG2Z25NqCwiIjRhOf5iKGuzSe5P2w1laq+FkRy4p+PCuVkJSGkzTEKVw=="
+        },
         "type-check": {
             "version": "0.4.0",
             "resolved": "https://registry.npmjs.org/type-check/-/type-check-0.4.0.tgz",
             "integrity": "sha1-sxxa6CVIRKOoKBVBzisEuGWnNP8=",
             "dev": true
         },
+        "universalify": {
+            "version": "0.1.2",
+            "resolved": "https://registry.npmjs.org/universalify/-/universalify-0.1.2.tgz",
+            "integrity": "sha512-rBJeI5CXAlmy1pV+617WB9J63U6XcazHHF2f2dbJix4XzpUF0RS3Zbj0FGIOCAva5P/d/GBOYaACQ1w+0azUkg=="
+        },
         "unpipe": {
             "version": "1.0.0",
             "resolved": "https://registry.npmjs.org/unpipe/-/unpipe-1.0.0.tgz",
-            "integrity": "sha1-sr9O6FFKrmFltIF4KdIbLvSZBOw=",
-            "dev": true
+            "integrity": "sha1-sr9O6FFKrmFltIF4KdIbLvSZBOw="
         },
         "uri-js": {
             "version": "4.4.1",
         "util-deprecate": {
             "version": "1.0.2",
             "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
-            "integrity": "sha1-RQ1Nyfpw3nMnYvvS1KKJgUGaDM8=",
-            "dev": true
+            "integrity": "sha1-RQ1Nyfpw3nMnYvvS1KKJgUGaDM8="
         },
         "v8-compile-cache": {
             "version": "2.3.0",
                 }
             }
         },
+        "vm2": {
+            "version": "3.9.8",
+            "resolved": "https://registry.npmjs.org/vm2/-/vm2-3.9.8.tgz",
+            "integrity": "sha512-/1PYg/BwdKzMPo8maOZ0heT7DLI0DAFTm7YQaz/Lim9oIaFZsJs3EdtalvXuBfZwczNwsYhju75NW4d6E+4q+w==",
+            "requires": {
+                "acorn": "^8.7.0",
+                "acorn-walk": "^8.2.0"
+            },
+            "dependencies": {
+                "acorn": {
+                    "version": "8.7.0",
+                    "resolved": "https://registry.npmjs.org/acorn/-/acorn-8.7.0.tgz",
+                    "integrity": "sha512-V/LGr1APy+PXIwKebEWrkZPwoeoF+w1jiOBUmuxuiUIaOHtob8Qc9BTrYo7VuI5fR8tqsy+buA2WFooR5olqvQ=="
+                }
+            }
+        },
         "void-elements": {
             "version": "3.1.0",
             "resolved": "https://registry.npmjs.org/void-elements/-/void-elements-3.1.0.tgz",
         "word-wrap": {
             "version": "1.2.3",
             "resolved": "https://registry.npmjs.org/word-wrap/-/word-wrap-1.2.3.tgz",
-            "integrity": "sha512-Hz/mrNwitNRh/HUAtM/VT/5VH+ygD6DV7mYKZAtHOrbs8U7lvPS6xf7EJKMF0uW1KJCl0H701g3ZGus+muE5vQ==",
-            "dev": true
+            "integrity": "sha512-Hz/mrNwitNRh/HUAtM/VT/5VH+ygD6DV7mYKZAtHOrbs8U7lvPS6xf7EJKMF0uW1KJCl0H701g3ZGus+muE5vQ=="
         },
         "wrappy": {
             "version": "1.0.2",
             "integrity": "sha1-tSQ9jz7BqjXxNkYFvA0QNuMKtp8=",
             "dev": true
         },
+        "xregexp": {
+            "version": "2.0.0",
+            "resolved": "https://registry.npmjs.org/xregexp/-/xregexp-2.0.0.tgz",
+            "integrity": "sha1-UqY+VsoLhKfzpfPWGHLxJq16WUM="
+        },
         "yallist": {
             "version": "3.1.1",
             "resolved": "https://registry.npmjs.org/yallist/-/yallist-3.1.1.tgz",
-            "integrity": "sha512-a4UGQaWPH59mOXUYnAG2ewncQS4i4F43Tv3JoAM+s2VDAmS9NsK8GpDMLrCHPksFT7h3K6TOoUNn2pb7RoXx4g==",
-            "dev": true
+            "integrity": "sha512-a4UGQaWPH59mOXUYnAG2ewncQS4i4F43Tv3JoAM+s2VDAmS9NsK8GpDMLrCHPksFT7h3K6TOoUNn2pb7RoXx4g=="
         }
     }
 }

frontend/package.json

     },
     "dependencies": {
         "joi": "^17.4.0",
+        "pubnub": "^5.0.0",
         "vue": "^3.0.5",
         "vue-router": "^4.0.12"
     },

frontend/src/App.vue

 import * as sss from '@/sss/import.css'
 
 export default {
-    name: 'app',
+    name: 'app'
 }
 </script>
 

frontend/src/services/chat.service.js

+import PubNub from 'pubnub'
+
+/** 
+ * Provider method holder
+ * We always reference this object so
+ * we don't have to hardcode provider specific
+ * methods for doing chat things.
+ * 
+ * This gets overloaded later in the program
+ */
+const providerMethods = {
+    publish: () => console.error('no provider publish method set'),
+    subscribe: () => console.error('no provider subscribe method set'),
+    listen: () => console.error('no provider listen method set')
+}
+
+/** 
+ * Breaking out as much pubnub specific flavor
+ */
+const setupPubnub = async uuid => {
+    if(!uuid) return console.error('no pubnub uuid set')
+    
+    const pubnubClient = await new PubNub({
+        publishKey: import.meta.env.VITE_PUBNUB_PUBLISH_KEY,
+        subscribeKey: import.meta.env.VITE_PUBNUB_SUBSCRIBE_KEY,
+        uuid
+    })
+    // Pass pubnub specific methods to our placeholder obj
+    providerMethods['publish'] = pubnubClient.publish
+    providerMethods['subscribe'] = pubnubClient.subscribe
+    providerMethods['listen'] = pubnubClient.addListener
+
+    return pubnubClient
+}
+
+
+class ChatMessage {
+    constructor({ title, description }) {
+        this.title = title,
+        this.description = description
+    }
+}
+
+const testMessage = new ChatMessage({
+    title: "testing",
+    description: "hello world!",
+})
+const MAIN_CHANNEL = 'hello_world'
+
+class Chatter {
+    constructor() {
+        this.groupings = {}
+        this.provider = null
+        this.uuid = null
+
+        // Setup the main channel
+        this.subscriptions = [MAIN_CHANNEL]
+        
+        this.listeners = {
+            status: async e => {
+                if (e.category !== "PNConnectedCategory") return
+                await this._publish(this.subscriptions[0], testMessage)
+            },
+            message: this._onMessage,
+            presence: this._onPresence
+        }
+    }
+    async _onMessage(e) {
+        console.log(e.message.title)
+        console.log(e.message.description)
+    }
+    async _onPresence(e) {
+        return
+    }
+    async setup(uuid) {
+        this.uuid = uuid
+        this.provider = await setupPubnub(this.uuid)
+
+        this._listenFor({ listeners: this.listeners })
+        this._subscribe(this.subscriptions)
+    }
+    async _publish(channel, message) {
+        return await providerMethods['publish']({ channel, message })
+    }
+    _subscribe(channels) {
+        providerMethods['subscribe']({ channels })
+    }
+    _listenFor({ listeners }) {
+        providerMethods['listen'](listeners)
+    }
+}
+
+export { Chatter }

frontend/src/services/notification.service.js

+import { remote } from '../utils/db'
+
+class Toaster {
+    constructor(profileId) {
+        this.url = `${remote}/notification/${profileId}/subscribe`
+        this.source = null
+        this.source = new EventSource(this.url)
+        this.listenFor('end', message => this.source.close)
+    }
+    listenFor(event, callback) {
+        this.source.addEventListener(event, callback)
+    }
+}
+
+class StonkAlert extends Toaster {
+    constructor(profileId) {
+        super(profileId)
+
+        this.stonks = {}
+        this.listenFor('stonk', message => {
+            const parsed = JSON.parse(message.data)
+            this.stonks[parsed.name] = parsed
+            console.log('updated:', this.stonks)
+        })
+    }
+}
+
+export { Toaster, StonkAlert }

frontend/src/services/queue.service.js

     const queue = await db.get(
         `/profile/${profileId}/queue?include_profile=true`,
     )
-    return queue.map(profileData => {
+    
+    if(!queue?.length) {
+        console.error('could not retrieve match queue. Please take the survey and rescore.')
+    }
+
+    return queue ? queue.map(profileData => {
         return new Profile({ email: null, ...profileData })
-    })
+    }) : []
 }
 
 const updateQueueByProfileId = async (profileId, targetId, reinsert) => {

frontend/src/utils/db.js

         const header = { ...headerTemplate }
         header.method = 'GET'
         try {
-            console.log(`${remote}${endpoint}`)
+            // console.log(`${remote}${endpoint}`)
             let res = await fetch(`${remote}${endpoint}`, header)
             if (!res.ok) {
                 throw Error(res.statusText)
 }
 const db = new Connector()
 
-class Toaster {
-    constructor({ profileId }) {
-        this.url = `${remote}/notification/${profileId}/subscribe`
-        
-    }
-    connect() {
-        this.source = new EventSource(`${remote}/notification/${profileId}/subscribe`)
-        this.source.onmessage = e => {
-            console.log("Data", + e.data)
-        }
-        this.source.onerror = e => {
-            console.error("EventSource failed.", e)
-        }
-        this.source.addEventListener('end', e => {
-            this.close()
-        })
-    }
-}
-
-export { Connector, db, Toaster }
+export { Connector, db, remote }

frontend/src/views/home.vue

 import mainNav from '../components/MainNav.vue'
 import profileCardList from '../components/ProfileCardList.vue'
 import { fetchQueueByProfileId } from '../services'
-import { Toaster } from '../utils/db'
+import { StonkAlert } from '../services/notification.service'
+import { Chatter } from '../services/chat.service'
 
 import batch_10 from '../../../backend/db/generated/_batch_10.js.ref'
 import batch_20 from '../../../backend/db/generated/_batch_20.js.ref'
         mypid: null,
     }),
     mounted() {
+        this.setupChatter()
         this.setupToaster()
     },
     async created() {
     },
     methods: {
         setupToaster() {
-            const stocks = {}
-            const source = new EventSource(`http://localhost:3001/api/notification/${this.mypid}/subscribe`)
-            source.addEventListener('stonk', function (message) {
-                console.log('updated:', message)
-                const data = JSON.parse(message.data)
-                stocks[data.name] = data
-            })
-            source.addEventListener('end', function (message) {
-                this.close()
-            })
+            const t = new StonkAlert(this.mypid)
+        },
+        setupChatter() {
+            const c = new Chatter()
+            const testAccountUUID = import.meta.env.VITE_TEST_ACCOUNT_UUID
+            c.setup(testAccountUUID)
+            console.log('---')
+            console.log(c)
         },
         processQueue(queueList) {
             const formattedList = []