temp.js

'use strict'

const WebSocket = require('ws');
const mqtt = require('mqtt');
const sqlite = require('sqlite-async')
const wss = new WebSocket.Server({
    port: 7009,
    perMessageDeflate: {
      zlibDeflateOptions: {
        // See zlib defaults.
        chunkSize: 1024,
        memLevel: 7,
        level: 3
      },
      zlibInflateOptions: {
        chunkSize: 10 * 1024
      },
      // Other options settable:
      clientNoContextTakeover: true, // Defaults to negotiated value.
      serverNoContextTakeover: true, // Defaults to negotiated value.
      serverMaxWindowBits: 10, // Defaults to negotiated value.
      // Below options specified as default values.
      concurrencyLimit: 10, // Limits zlib concurrency for perf.
      threshold: 1024 // Size (in bytes) below which messages
      // should not be compressed.
    }
  }); 
module.exports = class Temp {
    constructor(dbName = ':memory:') {
		return (async() => {
			this.db = await sqlite.open(dbName)
			// we need this table to store the user accounts
			const sql = 'CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY AUTOINCREMENT, user TEXT, pass TEXT);'
			await this.db.run(sql)
			return this
		})()
    }
    async reading() {
        let data = '40c'
        const connection = new WebSocket('ws://localhost:7009')
         wss.on('connection', function connection(ws) {
             const client = mqtt.connect('mqtt.coventry.ac.uk', {
               host: 'mqtt.coventry.ac.uk', 
               protocol: 'mqtts',
               username: '302CEM',
               password: 'n3fXXFZrjw',
               port: 8883,  
             })
             client.on('connect', function () {
                 client.subscribe('302CEM/Team2/temp01', function (err) {
                 })
               })
               client.on('message', function (topic, message) {
                data = message.toString()
                //console.log(message.toString())
                console.log(data)
                 
            })
         });
         return data
     }


}