diff --git a/real_time_chat/real.time.chat.go b/real_time_chat/real.time.chat.go index 91f15df..e6ffcb2 100644 --- a/real_time_chat/real.time.chat.go +++ b/real_time_chat/real.time.chat.go @@ -15,85 +15,6 @@ import ( realtimego "github.com/overseedio/realtime-go" ) -// func handleConnections(c *gin.Context) { -// ws, err := upgrader.Upgrade(c.Writer, c.Request, nil) -// if err != nil { -// log.Println(err) -// return -// } -// defer ws.Close() -// clients[ws] = true - -// for { -// var msg Message -// err := ws.ReadJSON(&msg) -// if err != nil { -// log.Printf("error: %v", err) -// delete(clients, ws) -// break -// } -// broadcast <- msg -// } -// } - -// func subscribeToRealtime() { -// client := supabase.NewClient(os.Getenv("SUPABASE_PROJECT_URL"), os.Getenv("SUPABASE_ANON_KEY"), nil) -// rtClient, err := realtime.NewClient(client) -// if err != nil { -// log.Fatalf("Error creating Realtime client: %v", err) -// } - -// rtClient.On("postgres_changes", map[string]string{ -// "schema": "public", -// "table": "messages", -// "event": "*", -// }, func(payload realtime.Payload) { -// log.Printf("Realtime message: %v", payload) - -// msg := Message{ -// ID: payload.New["id"].(string), -// Content: payload.New["content"].(string), -// Username: payload.New["username"].(string), -// CreatedAt: payload.New["created_at"].(string), -// } - -// broadcast <- msg -// }) - -// err = rtClient.Start() -// if err != nil { -// log.Fatalf("Error starting Realtime client: %v", err) -// } -// } - -// func handleMessages() { -// db, dbClose := dbflow.ConnectHackDatabase() -// defer dbClose.Close() -// for { -// msg := <-broadcast - -// for client := range clients { -// err := client.WriteJSON(msg) -// if err != nil { -// log.Printf("error: %v", err) -// client.Close() -// delete(clients, client) -// } -// } - -// db.Create(&msg) -// } -// } - -// Message represents a chat message -// type Message struct { -// ID uint `json:"id" gorm:"primaryKey"` -// Content string `json:"content"` -// Username string `json:"username"` -// CreatedAt time.Time `json:"created_at"` -// } - -// var db *gorm.DB var clients = make(map[*websocket.Conn]bool) var broadcast = make(chan VoyagerRandomeMessages) var upgrader = websocket.Upgrader{ @@ -117,6 +38,7 @@ func RealtimeChatVoigerConnection() { if err != nil { log.Fatal(err) } + defer c.Disconnect() dbName := os.Getenv("SUPABASE_DB_NAME") schema := os.Getenv("SCHEMA")