131 lines
2.4 KiB
Go
131 lines
2.4 KiB
Go
package chat
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"time"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
"golang.org/x/net/websocket"
|
|
|
|
"github.com/gabek/owncast/models"
|
|
)
|
|
|
|
var (
|
|
_server *server
|
|
)
|
|
|
|
//Server represents the server which handles the chat
|
|
type server struct {
|
|
Messages []models.ChatMessage
|
|
Clients map[string]*Client
|
|
|
|
pattern string
|
|
listener models.ChatListener
|
|
|
|
addCh chan *Client
|
|
delCh chan *Client
|
|
sendAllCh chan models.ChatMessage
|
|
pingCh chan models.PingMessage
|
|
doneCh chan bool
|
|
errCh chan error
|
|
}
|
|
|
|
//Add adds a client to the server
|
|
func (s *server) add(c *Client) {
|
|
s.addCh <- c
|
|
}
|
|
|
|
//Remove removes a client from the server
|
|
func (s *server) remove(c *Client) {
|
|
s.delCh <- c
|
|
}
|
|
|
|
//SendToAll sends a message to all of the connected clients
|
|
func (s *server) SendToAll(msg models.ChatMessage) {
|
|
s.sendAllCh <- msg
|
|
}
|
|
|
|
//Done marks the server as done
|
|
func (s *server) done() {
|
|
s.doneCh <- true
|
|
}
|
|
|
|
//Err handles an error
|
|
func (s *server) err(err error) {
|
|
s.errCh <- err
|
|
}
|
|
|
|
func (s *server) sendPastMessages(c *Client) {
|
|
for _, msg := range s.Messages {
|
|
c.Write(msg)
|
|
}
|
|
}
|
|
|
|
func (s *server) sendAll(msg models.ChatMessage) {
|
|
for _, c := range s.Clients {
|
|
c.Write(msg)
|
|
}
|
|
}
|
|
|
|
func (s *server) ping() {
|
|
ping := models.PingMessage{MessageType: "PING"}
|
|
for _, c := range s.Clients {
|
|
c.pingch <- ping
|
|
}
|
|
}
|
|
|
|
func (s *server) onConnection(ws *websocket.Conn) {
|
|
client := NewClient(ws)
|
|
|
|
defer func() {
|
|
log.Tracef("The client was connected for %s and sent %d messages (%s)", time.Since(client.ConnectedAt), client.MessageCount, client.id)
|
|
|
|
if err := ws.Close(); err != nil {
|
|
s.errCh <- err
|
|
}
|
|
}()
|
|
|
|
s.add(client)
|
|
client.Listen()
|
|
}
|
|
|
|
// Listen and serve.
|
|
// It serves client connection and broadcast request.
|
|
func (s *server) Listen() {
|
|
http.Handle(s.pattern, websocket.Handler(s.onConnection))
|
|
|
|
log.Tracef("Starting the websocket listener on: %s", s.pattern)
|
|
|
|
for {
|
|
select {
|
|
// add new a client
|
|
case c := <-s.addCh:
|
|
s.Clients[c.id] = c
|
|
|
|
s.listener.ClientAdded(c.id)
|
|
s.sendPastMessages(c)
|
|
|
|
// remove a client
|
|
case c := <-s.delCh:
|
|
delete(s.Clients, c.id)
|
|
s.listener.ClientRemoved(c.id)
|
|
|
|
// broadcast a message to all clients
|
|
case msg := <-s.sendAllCh:
|
|
s.Messages = append(s.Messages, msg)
|
|
s.listener.MessageSent(msg)
|
|
s.sendAll(msg)
|
|
addMessage(msg)
|
|
case ping := <-s.pingCh:
|
|
fmt.Println("PING?", ping)
|
|
|
|
case err := <-s.errCh:
|
|
log.Error("Error:", err.Error())
|
|
|
|
case <-s.doneCh:
|
|
return
|
|
}
|
|
}
|
|
}
|