admin/nats-ui
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bug fixes linter

Browse Source
This commit is contained in:
admin 2026-02-06 15:50:12 +07:00
parent beb09cb7c6
commit 9cafd66b61
1 changed files with 21 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
main.go
View File

@ -106,7 +106,9 @@ func (h *Hub) Run() {
case conn := <-h.unregister: case conn := <-h.unregister:
if _, ok := h.clients[conn]; ok { if _, ok := h.clients[conn]; ok {
delete(h.clients, conn) delete(h.clients, conn)
conn.Close() if err := conn.Close(); err != nil {
log.Printf("WebSocket close error: %v", err)
}
} }
case message := <-h.broadcast: case message := <-h.broadcast:
for conn := range h.clients { for conn := range h.clients {
@ -114,7 +116,9 @@ func (h *Hub) Run() {
if err != nil { if err != nil {
log.Printf("WebSocket error: %v", err) log.Printf("WebSocket error: %v", err)
delete(h.clients, conn) delete(h.clients, conn)
conn.Close() if closeErr := conn.Close(); closeErr != nil {
log.Printf("WebSocket close error: %v", closeErr)
}
} }
} }
} }
@ -184,7 +188,8 @@ func main() {
log.Printf("Connected to NATS at %s", config.NatsURL) log.Printf("Connected to NATS at %s", config.NatsURL)
subjectsList := parseSubjects(config.Subjects) subjectsList := parseSubjects(config.Subjects)
for _, subject := range subjectsList { for _, subject := range subjectsList {
sub, err := nc.Subscribe(subject, func(msg *nats.Msg) { subj := subject
sub, err := nc.Subscribe(subj, func(msg *nats.Msg) {
message := Message{ message := Message{
ID: fmt.Sprintf("%d", time.Now().UnixNano()), ID: fmt.Sprintf("%d", time.Now().UnixNano()),
Subject: msg.Subject, Subject: msg.Subject,
@ -197,10 +202,14 @@ func main() {
log.Printf("Received message on %s: %d bytes", msg.Subject, len(msg.Data)) log.Printf("Received message on %s: %d bytes", msg.Subject, len(msg.Data))
}) })
if err != nil { if err != nil {
log.Fatalf("Failed to subscribe to %s: %v", subject, err) log.Fatalf("Failed to subscribe to %s: %v", subj, err)
} }
log.Printf("Subscribed to: %s", subject) log.Printf("Subscribed to: %s", subj)
defer sub.Unsubscribe() defer func() {
if err := sub.Unsubscribe(); err != nil {
log.Printf("Failed to unsubscribe from %s: %v", subj, err)
}
}()
} }
// Определяем путь к index.html // Определяем путь к index.html
indexPath := "index.html" indexPath := "index.html"
@ -229,11 +238,15 @@ func main() {
} else { } else {
messages = store.GetAll() messages = store.GetAll()
} }
json.NewEncoder(w).Encode(messages) if err := json.NewEncoder(w).Encode(messages); err != nil {
log.Printf("Failed to encode messages: %v", err)
}
}) })
http.HandleFunc("/api/subjects", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/api/subjects", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json") w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(store.GetSubjects()) if err := json.NewEncoder(w).Encode(store.GetSubjects()); err != nil {
log.Printf("Failed to encode subjects: %v", err)
}
}) })
http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) {
conn, err := upgrader.Upgrade(w, r, nil) conn, err := upgrader.Upgrade(w, r, nil)