From c9e9d789f052a59b00b23ab583b4747888af19d9 Mon Sep 17 00:00:00 2001 From: Annisa Rachmadiyanti Date: Tue, 18 Nov 2025 14:53:36 +0700 Subject: [PATCH] Update ke DB Prod --- internal/handlers/websocket/websocket.go | 4 ++-- internal/services/websocket/handlers.go | 6 +++--- internal/services/websocket/hub.go | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/handlers/websocket/websocket.go b/internal/handlers/websocket/websocket.go index f9a0621..eccf2f9 100644 --- a/internal/handlers/websocket/websocket.go +++ b/internal/handlers/websocket/websocket.go @@ -147,7 +147,7 @@ func (h *WebSocketHandler) BroadcastQris(c *gin.Context) { return } - dbConn, err := h.hub.GetDatabaseConnection("simrs_backup") + dbConn, err := h.hub.GetDatabaseConnection("simrs_prod") if err != nil || dbConn == nil { c.JSON(500, gin.H{"error": "Database connection failed"}) return @@ -201,7 +201,7 @@ func (h *WebSocketHandler) BroadcastCheck(c *gin.Context) { return } - dbConn, err := h.hub.GetDatabaseConnection("simrs_backup") + dbConn, err := h.hub.GetDatabaseConnection("simrs_prod") if err != nil || dbConn == nil { c.JSON(500, gin.H{"error": "Database connection failed"}) return diff --git a/internal/services/websocket/handlers.go b/internal/services/websocket/handlers.go index 40c13e8..30b039e 100644 --- a/internal/services/websocket/handlers.go +++ b/internal/services/websocket/handlers.go @@ -55,7 +55,7 @@ func (h *DatabaseHandler) handleDatabaseInsert(client *Client, message WebSocket // Perform actual database insert if h.hub.dbService != nil { // Get database connection - db, err := h.hub.GetDatabaseConnection("simrs_backup") + db, err := h.hub.GetDatabaseConnection("simrs_prod") if err != nil { client.sendErrorResponse("Database connection error", err.Error()) return nil @@ -117,7 +117,7 @@ func (h *DatabaseHandler) handleDatabaseQuery(client *Client, message WebSocketM } // Execute query - results, err := h.hub.ExecuteDatabaseQuery("simrs_backup", fmt.Sprintf("SELECT * FROM %s LIMIT 100", table)) + results, err := h.hub.ExecuteDatabaseQuery("simrs_prod", fmt.Sprintf("SELECT * FROM %s LIMIT 100", table)) if err != nil { client.sendErrorResponse("Database query error", err.Error()) return nil @@ -142,7 +142,7 @@ func (h *DatabaseHandler) handleDatabaseCustomQuery(client *Client, message WebS database, ok := data["database"].(string) if !ok || database == "" { - database = "simrs_backup" + database = "simrs_prod" } query, ok := data["query"].(string) diff --git a/internal/services/websocket/hub.go b/internal/services/websocket/hub.go index ee52213..444999d 100644 --- a/internal/services/websocket/hub.go +++ b/internal/services/websocket/hub.go @@ -347,7 +347,7 @@ func (h *Hub) setupDatabaseListeners() { // Listen for changes on retribusi table channels := []string{"data_changes"} - err := h.dbService.ListenForChanges(h.ctx, "simrs_backup", channels, func(channel, payload string) { + err := h.dbService.ListenForChanges(h.ctx, "simrs_prod", channels, func(channel, payload string) { h.handleDatabaseChange(channel, payload) })