import fastify from 'fastify'
import { serverFactory, fastifyUws } from '@geut/fastify-uws'

const app = fastify({
  serverFactory
})

await app.register(fastifyUws)

app.websocketServer.on('open', ws => {
  console.log('OPEN')
})

app.websocketServer.on('close', ws => {
  console.log('CLOSE')
})

app
  .get('/', {
    ws: {
      topics: [
        'home/sensors/ligth',
        'home/sensors/temp'
      ]
    }
  },
  async (req, reply) => {
    if (!reply.ws) {
      return 'hello from http endpoint'
    }

    reply.subscribe('home/sensors/temp')
    reply.on('message', (message) => {
      reply.publish('home/sensors/temp', 'random message')
    })
    reply.send(JSON.stringify({ hello: 'world' }))
  })
  .listen({
    port: 3000
  }, (err) => {
    err && console.error(err)
  })