From 778e8f80d742b61e347aea562fcd879c12925cb9 Mon Sep 17 00:00:00 2001 From: leandrofars Date: Sun, 4 Feb 2024 16:42:02 -0300 Subject: [PATCH] chore: remove deprecated code --- backend/services/controller/internal/ws/ws.go | 88 ------------------- 1 file changed, 88 deletions(-) delete mode 100644 backend/services/controller/internal/ws/ws.go diff --git a/backend/services/controller/internal/ws/ws.go b/backend/services/controller/internal/ws/ws.go deleted file mode 100644 index 2750c22..0000000 --- a/backend/services/controller/internal/ws/ws.go +++ /dev/null @@ -1,88 +0,0 @@ -package ws - -import ( - "fmt" - "log" - "net/http" - "time" - - socketio "github.com/googollee/go-socket.io" - "github.com/googollee/go-socket.io/engineio" - "github.com/googollee/go-socket.io/engineio/transport" - "github.com/googollee/go-socket.io/engineio/transport/polling" - "github.com/googollee/go-socket.io/engineio/transport/websocket" - "github.com/gorilla/mux" - "github.com/leandrofars/oktopus/internal/api/cors" -) - -/* ----------- [Deprecated code] migrated to Socketio with NodeJs ----------- */ -func Ws() { - server := socketio.NewServer(&engineio.Options{ - PingTimeout: 5 * time.Second, - PingInterval: 10 * time.Second, - Transports: []transport.Transport{ - &polling.Transport{ - Client: &http.Client{ - Timeout: time.Minute, - }, - CheckOrigin: func(r *http.Request) bool { - return true - }, - }, - &websocket.Transport{ - CheckOrigin: func(r *http.Request) bool { - return true - }, - }, - }, - }) - - server.OnConnect("/", func(s socketio.Conn) error { - s.SetContext("") - fmt.Println("connected:", s.ID()) - return nil - }) - - server.OnEvent("/", "offer", func(s socketio.Conn, msg string) string { - log.Printf("offer: %s", msg) - - return "test" - }) - - server.OnError("/", func(s socketio.Conn, e error) { - fmt.Println("error:", e) - }) - - server.OnDisconnect("/", func(s socketio.Conn, reason string) { - fmt.Println("closed", reason) - }) - - go func() { - if err := server.Serve(); err != nil { - log.Fatalf("socketio listen error: %s\n", err) - } - }() - - const wsPort = "5000" - - r := mux.NewRouter() - r.Handle("/socket.io/", server) - - //r.Use(func(handler http.Handler) http.Handler { - // return middleware.Middleware(handler) - //}) - - corsOpts := cors.GetCorsConfig() - - srv := &http.Server{ - Addr: "0.0.0.0:" + wsPort, - Handler: corsOpts.Handler(r), // Pass our instance of gorilla/mux in. - } - - go func() { - if err := srv.ListenAndServe(); err != nil { - log.Println(err) - } - }() - log.Printf("Running websocket at port %s", wsPort) -}