✨ Able to handle websocket incoming packet

pkg/internal/server/api/ws.go

@@ -1,10 +1,17 @@
 package api
 
 import (
+	"context"
+	"fmt"
+	"git.solsynth.dev/hydrogen/dealer/pkg/hyper"
+	"git.solsynth.dev/hydrogen/dealer/pkg/internal/directory"
 	"git.solsynth.dev/hydrogen/dealer/pkg/internal/models"
 	"git.solsynth.dev/hydrogen/dealer/pkg/internal/services"
+	"git.solsynth.dev/hydrogen/dealer/pkg/proto"
 	"github.com/gofiber/contrib/websocket"
+	jsoniter "github.com/json-iterator/go"
 	"github.com/rs/zerolog/log"
+	"github.com/spf13/viper"
 )
 
 func listenWebsocket(c *websocket.Conn) {
@@ -15,11 +22,58 @@ func listenWebsocket(c *websocket.Conn) {
 	log.Debug().Uint("user", user.ID).Msg("New websocket connection established...")
 
 	// Event loop
+	var mt int
+	var data []byte
 	var err error
 
+	var packet hyper.NetworkPackage
+
 	for {
-		if _, _, err = c.ReadMessage(); err != nil {
+		if mt, data, err = c.ReadMessage(); err != nil {
 			break
+		} else if err := jsoniter.Unmarshal(data, &packet); err != nil {
+			_ = c.WriteMessage(mt, hyper.NetworkPackage{
+				Action:  "error",
+				Message: "unable to unmarshal your command, requires json request",
+			}.Marshal())
+			continue
+		}
+
+		aliasingMap := viper.GetStringMapString("services.aliases")
+		if val, ok := aliasingMap[packet.Endpoint]; ok {
+			packet.Endpoint = val
+		}
+
+		service := directory.GetServiceInstanceByType(packet.Endpoint)
+		if service == nil {
+			_ = c.WriteMessage(mt, hyper.NetworkPackage{
+				Action:  "error",
+				Message: "service not found",
+			}.Marshal())
+			continue
+		}
+		pc, err := service.GetGrpcConn()
+		if err != nil {
+			_ = c.WriteMessage(mt, hyper.NetworkPackage{
+				Action:  "error",
+				Message: fmt.Sprintf("unable to connect to service: %v", err.Error()),
+			}.Marshal())
+			continue
+		}
+
+		sc := proto.NewStreamControllerClient(pc)
+		_, err = sc.EmitStreamEvent(context.Background(), &proto.StreamEventRequest{
+			Event:   packet.Action,
+			UserId:  uint64(user.ID),
+			Payload: packet.RawPayload(),
+		})
+
+		if err != nil {
+			_ = c.WriteMessage(mt, hyper.NetworkPackage{
+				Action:  "error",
+				Message: fmt.Sprintf("unable send message to service: %v", err.Error()),
+			}.Marshal())
+			continue
 		}
 	}