fix: store duration in microsecond

node/pkg/dal/api/controller.go

@@ -103,7 +103,8 @@ func (c *Controller) castSubmissionData(data *dalcommon.OutgoingSubmissionData,
 	}
 }
 
-func (c *Controller) handleWebsocket(ctx context.Context, conn *websocket.Conn) {
+func (c *Controller) handleWebsocket(conn *websocket.Conn) {
+	ctx := context.Background()
 	c.register <- conn
 	apiKey := conn.Headers("X-Api-Key")
 	if apiKey == "" {

node/pkg/dal/api/route.go

@@ -1,8 +1,6 @@
 package api
 
 import (
-	"context"
-
 	"github.com/gofiber/contrib/websocket"
 	"github.com/gofiber/fiber/v2"
 )
@@ -13,12 +11,5 @@ func Routes(router fiber.Router) {
 	api.Get("/symbols", getSymbols)
 	api.Get("/latest-data-feeds/all", getLatestFeeds)
 	api.Get("/latest-data-feeds/:symbol", getLatestFeed)
-	api.Get("/ws", func(c *fiber.Ctx) error {
-		if websocket.IsWebSocketUpgrade(c) {
-			return websocket.New(func(conn *websocket.Conn) {
-				ApiController.handleWebsocket(context.Background(), conn)
-			})(c)
-		}
-		return fiber.ErrUpgradeRequired
-	})
+	api.Get("/ws", websocket.New(ApiController.handleWebsocket))
 }

node/pkg/dal/utils/stats/stats.go

@@ -38,12 +38,13 @@ type websocketId struct {
 }
 
 func InsertRestCall(ctx context.Context, apiKey string, endpoint string, statusCode int, responseTime time.Duration) error {
-	responseTimeMilli := int(responseTime.Milliseconds())
+
+	responseTimeMicro := responseTime.Microseconds()
 	return db.QueryWithoutResult(ctx, INSERT_REST_CALLS, map[string]any{
 		"api_key":       apiKey,
 		"endpoint":      endpoint,
 		"status_code":   statusCode,
-		"response_time": responseTimeMilli,
+		"response_time": responseTimeMicro,
 	})
 }
 
@@ -72,7 +73,6 @@ func InsertWebsocketSubscription(ctx context.Context, connectionId int32, topic
 
 func StatsMiddleware(c *fiber.Ctx) error {
 	start := time.Now()
-
 	if err := c.Next(); err != nil {
 		return err
 	}