sprinklers3/server/state.ts

import logger from "@common/logger";
import * as mqtt from "@common/sprinklersRpc/mqtt";
import { Database } from "./Database";

export class ServerState {
    mqttClient: mqtt.MqttRpcClient;
    database: Database;

    constructor() {
        const mqttUrl = process.env.MQTT_URL;
        if (!mqttUrl) {
            throw new Error("Must specify a MQTT_URL to connect to");
        }
        this.mqttClient = new mqtt.MqttRpcClient(mqttUrl);
        this.database = new Database();
    }

    async start() {
        await this.database.connect();
        await this.database.createAll();
        logger.info("created database and tables");

        this.mqttClient.start();
    }
}