blob: c1384f7adc9a66062a146873b3a59aec509c57a1 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package server
import (
"log"
"time"
"go.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)
}
}
}
}
|
