Improve/logs

apps/websocket-server/internal/app/app.go

@@ -59,23 +59,11 @@ var Module = fx.Module("app",
 
 			// Web socket route
 			a.Use("/ws", setUpgradable)
-			a.Use("/logs", setUpgradable)
-
-			a.Use("/logs", func(c *fiber.Ctx) error {
-				ctx := c.Context()
-
-				return websocket.New(func(sockConn *websocket.Conn) {
-					if err := d.HandleWebSocketForLogs(ctx, sockConn); err != nil {
-						logr.Errorf(err, "while handling websocket for logs")
-					}
-				})(c)
-			})
-
 			a.Use("/ws", func(c *fiber.Ctx) error {
 				ctx := c.Context()
 
 				return websocket.New(func(sockConn *websocket.Conn) {
-					if err := d.HandleWebSocketForRUpdate(ctx, sockConn); err != nil {
+					if err := d.HandleWebSocket(ctx, sockConn); err != nil {
 						logr.Errorf(err, "while handling websocket for resource update")
 					}
 				})(c)

apps/websocket-server/internal/domain/commons.go

@@ -23,10 +23,6 @@ func (d *domain) checkAccountAccess(ctx context.Context, accountName string, use
 		Action:       string(action),
 	})
 
-	// if err != nil {
-	// return err
-	// }
-
 	if err != nil {
 		d.logger.Errorf(err, "iam.can check for action: ", action)
 		return errors.Newf("unauthorized to perform action: %s", action)

apps/websocket-server/internal/domain/domain.go

@@ -13,8 +13,7 @@ import (
 )
 
 type SocketService interface {
-	HandleWebSocketForRUpdate(ctx context.Context, c *websocket.Conn) error
-	HandleWebSocketForLogs(ctx context.Context, c *websocket.Conn) error
+	HandleWebSocket(ctx context.Context, c *websocket.Conn) error
 }
 
 type Domain interface {