public/pogdark-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Disabling unused endpoints for new React frontend
All checks were successful
Build Pogdark API / Build Pogdark API (push) Successful in 34s
Details

Browse Source
This commit is contained in:
whysman 2025-02-20 12:28:34 -05:00
parent 268629a7ac
commit 807bc66acb
1 changed files with 82 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
main.go
View File

@ -149,7 +149,7 @@ func (s *Server) handleConnections(w http.ResponseWriter, r *http.Request) {
if err != nil { if err != nil {
log.Fatalf("Unable to marshal JSON due to %s", err) log.Fatalf("Unable to marshal JSON due to %s", err)
} }
fmt.Printf("Broadcasting ws message to %d clients", s.clients) fmt.Printf("Broadcasting ws message %s to %d clients\n", message, len(s.clients))
s.broadcast <- message s.broadcast <- message
} }
} }
@ -200,7 +200,7 @@ func broadcastExpiredRecords(s *Server, removed string) {
log.Println("Error marshalling json:", err) log.Println("Error marshalling json:", err)
return return
} }
fmt.Printf("Broadcasting expiration: %s to %s clients\n", string(msgJSON), len(s.clients)) fmt.Printf("Broadcasting expiration: %s to %d clients\n", string(msgJSON), len(s.clients))
for client := range s.clients { for client := range s.clients {
if err := client.conn.WriteMessage(websocket.TextMessage, msgJSON); err != nil { if err := client.conn.WriteMessage(websocket.TextMessage, msgJSON); err != nil {
log.Println("Failed to broadcast update:", err) log.Println("Failed to broadcast update:", err)
@ -267,6 +267,7 @@ func fetchAllRecords() (map[string]string, error) {
return records, nil return records, nil
} }
/*
func getState(w http.ResponseWriter, r *http.Request) { func getState(w http.ResponseWriter, r *http.Request) {
if r.Method != http.MethodPost { if r.Method != http.MethodPost {
http.Error(w, "Only POST method is allowed", http.StatusMethodNotAllowed) http.Error(w, "Only POST method is allowed", http.StatusMethodNotAllowed)
@ -319,7 +320,7 @@ func getState(w http.ResponseWriter, r *http.Request) {
http.Error(w, "Failed to encode response", http.StatusInternalServerError) http.Error(w, "Failed to encode response", http.StatusInternalServerError)
} }
} }
*/
func setState(w http.ResponseWriter, r *http.Request, s *Server) { func setState(w http.ResponseWriter, r *http.Request, s *Server) {
if r.Method != http.MethodPost { if r.Method != http.MethodPost {
http.Error(w, "Only POST method is allowed", http.StatusMethodNotAllowed) http.Error(w, "Only POST method is allowed", http.StatusMethodNotAllowed)
@ -362,6 +363,7 @@ func setState(w http.ResponseWriter, r *http.Request, s *Server) {
w.WriteHeader(http.StatusOK) w.WriteHeader(http.StatusOK)
} }
/*
func updateState(w http.ResponseWriter, r *http.Request) { func updateState(w http.ResponseWriter, r *http.Request) {
if r.Method != http.MethodGet { if r.Method != http.MethodGet {
http.Error(w, "Only GET method is allowed", http.StatusMethodNotAllowed) http.Error(w, "Only GET method is allowed", http.StatusMethodNotAllowed)
@ -393,7 +395,7 @@ func updateState(w http.ResponseWriter, r *http.Request) {
http.Error(w, "Failed to encode response", http.StatusInternalServerError) http.Error(w, "Failed to encode response", http.StatusInternalServerError)
} }
} }
*/
func enableCORS(next http.Handler) http.Handler { func enableCORS(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Access-Control-Allow-Origin", "*") // Allow all origins w.Header().Set("Access-Control-Allow-Origin", "*") // Allow all origins
@ -418,11 +420,11 @@ func main() {
// Register routes on the mux router // Register routes on the mux router
router.HandleFunc("/ws", server.handleConnections).Methods("GET") router.HandleFunc("/ws", server.handleConnections).Methods("GET")
router.HandleFunc("/get", getState).Methods("POST") //router.HandleFunc("/get", getState).Methods("POST")
router.HandleFunc("/set", func(w http.ResponseWriter, r *http.Request) { router.HandleFunc("/set", func(w http.ResponseWriter, r *http.Request) {
setState(w, r, server) setState(w, r, server)
}).Methods("POST") }).Methods("POST")
router.HandleFunc("/update", updateState).Methods("GET") //router.HandleFunc("/update", updateState).Methods("GET")
corsRouter := enableCORS(router) corsRouter := enableCORS(router)
// Start server and other necessary goroutines // Start server and other necessary goroutines