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

Added theme to message structure.
All checks were successful
Build Pogdark API / Build Pogdark API (pull_request) Successful in 15s
Details

Browse Source
This commit is contained in:
whysman 2025-02-26 11:56:42 -05:00
parent 0eee8e006d
commit 6a26238712
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
main.go
View File

@ -32,6 +32,7 @@ type Message struct {
Name string `json:"Name"` Name string `json:"Name"`
Image string `json:"Image"` Image string `json:"Image"`
Status string `json:"Status"` Status string `json:"Status"`
Theme string `json:"Theme"`
Timestamp string `json:"Timestamp"` Timestamp string `json:"Timestamp"`
} }
@ -190,7 +191,7 @@ func sendAllRecordsToClient(client *Client) {
if err != nil { if err != nil {
log.Println("Unable to marshal JSON due to: ", err) log.Println("Unable to marshal JSON due to: ", err)
} }
fmt.Printf("Broadcasting %s,%s,%s,%s\n", message.Id, message.Status, message.Name, message.Timestamp) fmt.Printf("Broadcasting %s,%s,%s,%s,%s\n", message.Id, message.Status, message.Name, message.Theme, message.Timestamp)
go sendToClient(client, []byte(msgContent)) go sendToClient(client, []byte(msgContent))
} }
} }
@ -209,7 +210,7 @@ func (s *Server) listenForExpirationEvents() {
expiredID := msg.Payload expiredID := msg.Payload
fmt.Println(expiredID) fmt.Println(expiredID)
// Broadcast expiration event // Broadcast expiration event
var message = Message{Id: expiredID, Name: "", Image: "", Status: "removed", Timestamp: ""} var message = Message{Id: expiredID, Name: "", Image: "", Status: "removed", Theme: "", Timestamp: ""}
fmt.Printf("Broadcasting expiration: %s to %d clients\n", message, len(s.clients)) fmt.Printf("Broadcasting expiration: %s to %d clients\n", message, len(s.clients))
broadcastSingleRecord(s, message) broadcastSingleRecord(s, message)
} }
@ -320,7 +321,7 @@ func setState(w http.ResponseWriter, r *http.Request, s *Server) {
http.Error(w, "Failed to store data", http.StatusInternalServerError) http.Error(w, "Failed to store data", http.StatusInternalServerError)
return return
} }
fmt.Printf("Broadcasting message: %s,%s,%s,%s to %d clients\n", message.Id, message.Status, message.Name, message.Timestamp, len(s.clients)) fmt.Printf("Broadcasting message: %s,%s,%s,%s,%s to %d clients\n", message.Id, message.Status, message.Name, message.Theme, message.Timestamp, len(s.clients))
} }
broadcastSingleRecord(s, message) broadcastSingleRecord(s, message)