✨ Implement websocket gateway

pkg/internal/http/ws/ws.go

@@ -1,11 +1,16 @@
 package ws
 
 import (
+	"context"
+	"fmt"
+	"git.solsynth.dev/hypernet/nexus/pkg/internal/directory"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
+	"git.solsynth.dev/hypernet/nexus/pkg/proto"
 	"github.com/gofiber/contrib/websocket"
 	jsoniter "github.com/json-iterator/go"
 	"github.com/rs/zerolog/log"
+	"github.com/samber/lo"
 	"github.com/spf13/viper"
 )
 
@@ -42,10 +47,9 @@ func Listen(c *websocket.Conn) {
 			packet.Endpoint = val
 		}
 
-		/*
 		service := directory.GetServiceInstanceByType(packet.Endpoint)
 		if service == nil {
-				_ = c.WriteMessage(mt, nex.NetworkPackage{
+			_ = c.WriteMessage(mt, nex.WebSocketPackage{
 				Action:  "error",
 				Message: "service not found",
 			}.Marshal())
@@ -53,7 +57,7 @@ func Listen(c *websocket.Conn) {
 		}
 		pc, err := service.GetGrpcConn()
 		if err != nil {
-				_ = c.WriteMessage(mt, nex.NetworkPackage{
+			_ = c.WriteMessage(mt, nex.WebSocketPackage{
 				Action:  "error",
 				Message: fmt.Sprintf("unable to connect to service: %v", err.Error()),
 			}.Marshal())
@@ -61,19 +65,18 @@ func Listen(c *websocket.Conn) {
 		}
 
 		sc := proto.NewStreamServiceClient(pc)
-			_, err = sc.EmitStreamEvent(context.Background(), &proto.StreamEventRequest{
-				Event:    packet.Action,
-				UserId:   uint64(user.ID),
-				ClientId: uint64(clientId),
-				Payload:  packet.RawPayload(),
+		_, err = sc.PushStream(context.Background(), &proto.PushStreamRequest{
+			UserId:   lo.ToPtr(uint64(user.ID)),
+			ClientId: lo.ToPtr(clientId),
+			Body:     packet.Marshal(),
 		})
 		if err != nil {
-				_ = c.WriteMessage(mt, nex.NetworkPackage{
+			_ = c.WriteMessage(mt, nex.WebSocketPackage{
 				Action:  "error",
 				Message: fmt.Sprintf("unable send message to service: %v", err.Error()),
 			}.Marshal())
 			continue
-			}*/
+		}
 	}
 
 	// Pop connection