grain/relay/relay.go

69 lines
1.4 KiB
Go
Raw Normal View History

2024-07-23 17:30:29 +00:00
package relay
2024-07-20 12:41:47 +00:00
import (
"encoding/json"
"fmt"
"grain/relay/handlers"
2024-07-26 14:02:34 +00:00
"grain/relay/utils"
2024-07-20 12:41:47 +00:00
"golang.org/x/net/websocket"
)
2024-07-25 13:57:24 +00:00
func WebSocketHandler(ws *websocket.Conn) {
2024-07-20 12:41:47 +00:00
defer ws.Close()
var msg string
2024-07-26 14:02:34 +00:00
rateLimiter := utils.GetRateLimiter()
2024-07-20 12:41:47 +00:00
for {
err := websocket.Message.Receive(ws, &msg)
if err != nil {
fmt.Println("Error receiving message:", err)
2024-07-30 13:31:26 +00:00
// Send a close message with an error code and reason
ws.Close()
2024-07-20 12:41:47 +00:00
return
}
fmt.Println("Received message:", msg)
2024-07-26 14:02:34 +00:00
if allowed, msg := rateLimiter.AllowWs(); !allowed {
websocket.Message.Send(ws, fmt.Sprintf(`{"error": "%s"}`, msg))
2024-07-30 13:31:26 +00:00
ws.Close()
2024-07-26 14:02:34 +00:00
return
}
2024-07-20 12:41:47 +00:00
var message []interface{}
err = json.Unmarshal([]byte(msg), &message)
if err != nil {
fmt.Println("Error parsing message:", err)
continue
}
if len(message) < 2 {
fmt.Println("Invalid message format")
continue
}
messageType, ok := message[0].(string)
if !ok {
fmt.Println("Invalid message type")
continue
}
switch messageType {
case "EVENT":
2024-07-25 13:57:24 +00:00
handlers.HandleEvent(ws, message)
2024-07-20 12:41:47 +00:00
case "REQ":
2024-07-26 14:02:34 +00:00
if allowed, msg := rateLimiter.AllowReq(); !allowed {
websocket.Message.Send(ws, fmt.Sprintf(`{"error": "%s"}`, msg))
2024-07-30 13:31:26 +00:00
ws.Close()
2024-07-26 14:02:34 +00:00
return
}
handlers.HandleReq(ws, message)
2024-07-20 12:41:47 +00:00
case "CLOSE":
handlers.HandleClose(ws, message)
2024-07-20 12:41:47 +00:00
default:
fmt.Println("Unknown message type:", messageType)
}
}
2024-07-25 13:57:24 +00:00
}