ws.go

package main

import (
	"encoding/json"
	"fmt"
	"log"
	"time"

	"github.com/lxzan/gws"
)

// react socket handler
type WebSocketHandler struct{}

func (h *WebSocketHandler) OnOpen(conn *gws.Conn) {
	log.Println("Connection opened")
}

func (h *WebSocketHandler) OnMessage(conn *gws.Conn, message *gws.Message) {
	log.Println("Received message:", string(message.Data.String()))

	err := conn.WriteMessage(gws.OpcodeText, []byte("Hello, World!"))
	if err != nil {
		log.Println("Write error:", err)
	}
}

func (h *WebSocketHandler) OnClose(conn *gws.Conn, err error) {
	log.Println("Connection closed:", err)
}

func (c *WebSocketHandler) OnPing(socket *gws.Conn, payload []byte) {
	_ = socket.SetDeadline(time.Now().Add(PingInterval + PingWait))
	_ = socket.WritePong(nil)
}

func (c *WebSocketHandler) OnPong(socket *gws.Conn, payload []byte) {}

const (
	PingInterval = 5 * time.Second
	PingWait     = 10 * time.Second
)

// got reciver socket handler
type LogReceiverSocketHandler struct{}

func (h *LogReceiverSocketHandler) OnOpen(conn *gws.Conn) {
	log.Println("Connection opened")
}

// I WANT MAX VALUE FOR sub.key1 OVER 1 MINUTE.
func (h *LogReceiverSocketHandler) OnMessage(conn *gws.Conn, message *gws.Message) {
	msg := make(map[string]interface{})
	err := json.Unmarshal(message.Data.Bytes(), &msg)

	_, ok := msg["sub"]
	if ok {
		sub, ok := msg["sub"].(map[string]interface{})
		if ok {
			fmt.Println("KEY1:", sub["key1"])
		}
	}

	err = conn.WriteMessage(gws.OpcodeText, []byte("Hello, World!"))
	if err != nil {
		log.Println("Write error:", err)
	}
}

func (h *LogReceiverSocketHandler) OnClose(conn *gws.Conn, err error) {
	log.Println("Connection closed:", err)
}

func (c *LogReceiverSocketHandler) OnPing(socket *gws.Conn, payload []byte) {
	_ = socket.SetDeadline(time.Now().Add(PingInterval + PingWait))
	_ = socket.WritePong(nil)
}

func (c *LogReceiverSocketHandler) OnPong(socket *gws.Conn, payload []byte) {}