import { Hono } from 'hono'
import { upgradeWebSocket } from 'hono/cloudflare-workers'
const app = new Hono()
const obj = { data: 5 };

//i'm periodically changing the data in obj
function startTimer() {
    return setInterval(() => {
        obj.data = Math.random();
    }, 1000);
}

const wsApp = app.get(
    '/ws',
    upgradeWebSocket((c) => {
        let timer: NodeJS.Timeout;
        return {
            onOpen: (event, ws) => {
                console.log('connected');
                ws.send(JSON.stringify(obj));
                timer = startTimer();
            },
            onClose: (event, ws) => {
                //if no clients are connected stop the timer
                // if ( ws.clients.size === 0) {
                //     clearInterval(timer);
                // }
            }
        }
    })
)

export type WebSocketApp = typeof wsApp;

import { Hono } from 'hono'
import { upgradeWebSocket } from 'hono/cloudflare-workers'
const app = new Hono()
const obj = { data: 5 };

//i'm periodically changing the data in obj
function startTimer() {
    return setInterval(() => {
        obj.data = Math.random();
    }, 1000);
}

const wsApp = app.get(
    '/ws',
    upgradeWebSocket((c) => {
        let timer: NodeJS.Timeout;
        return {
            onOpen: (event, ws) => {
                console.log('connected');
                ws.send(JSON.stringify(obj));
                timer = startTimer();
            },
            onClose: (event, ws) => {
                //if no clients are connected stop the timer
                // if ( ws.clients.size === 0) {
                //     clearInterval(timer);
                // }
            }
        }
    })
)

export type WebSocketApp = typeof wsApp;