cloud/routes/include/websocket.js

import { Elysia } from 'elysia'
import Meteostanice from '../../utils/meteostanice'
import warningCheck from '../../utils/warningCheck'

export default (langName, lang) => new Elysia({ prefix: "/ws" })
  .ws("/sendData/:key", {
    open({ data: { params: { key } } }) {
        const meteostanica = Meteostanice.getWebsocket(key)

        if (!meteostanica) {
            return lang.websocket.errors.invalidKey({ key })
        }

        return lang.websocket.keepalive()
    },

    async message({ data: { params: { key } } }, message) {
        if (message === lang.websocket.keepalive()) {
            return lang.websocket.keepalive()
        }

        const meteostanica = Meteostanice.getWebsocket(key)

        if (!meteostanica) {
            return lang.websocket.errors.invalidKey({ key })
        }

        const {
            indoorTemp,
            indoorPressure,
            indoorHumidity,
            outdoorConnected,
            outdoorTemp,
            outdoorPressure,
            outdoorHumidity,
            timestamp
        } = message

        if (
            !indoorTemp?.length ||
            !indoorPressure?.length ||
            !indoorHumidity?.length ||
            !outdoorConnected?.toString()?.length ||
            !outdoorTemp?.length ||
            !outdoorPressure?.length ||
            !outdoorHumidity?.length
        ) {
            return lang.websocket.errors.missingFields()
        }
        
        Meteostanice.postData(
            meteostanica.id,
            indoorTemp,
            indoorPressure,
            indoorHumidity,
            outdoorConnected,
            outdoorTemp,
            outdoorPressure,
            outdoorHumidity,
            timestamp
        )

        await warningCheck(langName, lang, meteostanica)

        return lang.websocket.dataSaved({ meteostanica })
    }
  })