diff options
| author | bt <bt@localhost> | 2026-03-31 09:01:29 +0200 |
|---|---|---|
| committer | bt <bt@localhost> | 2026-03-31 10:38:03 +0200 |
| commit | 75504a81885db55a3f5f9041dcda6b9d2ef421b2 (patch) | |
| tree | b2b254240ec380b875380f5390d30dfa9cb0ad42 /server/message.go | |
| parent | 5e8c7c1c967f01f588655aced32b6b4ca6408850 (diff) | |
| download | solec-75504a81885db55a3f5f9041dcda6b9d2ef421b2.tar.gz solec-75504a81885db55a3f5f9041dcda6b9d2ef421b2.zip | |
[daemon] Better error handling
Diffstat (limited to 'server/message.go')
| -rw-r--r-- | server/message.go | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/server/message.go b/server/message.go new file mode 100644 index 0000000..8d89797 --- /dev/null +++ b/server/message.go @@ -0,0 +1,29 @@ +package server + +import ( + "log" + "time" + + "git.rctt.net/solec/core" +) + +func (s *Server) SendBroadcast(msg string) { + payload := core.Message{ + Source: "op@example.org", + Target: "*@example.org", + Timestamp: time.Now(), + Content: msg, + } + data, err := core.Encode(payload) + if err != nil { + panic(err) + } + + for _, u := range s.users { + for c := range u.Conns { + if _, err := c.Write(data); err != nil { + log.Println("cannot send", err) + } + } + } +} |
