implementation

Documentation

Overview

Used to prevent import cycle

Index

• type WebsocketHolder
  • func (w *WebsocketHolder) Connect(oauthToken, username string) (err error)
  • func (w *WebsocketHolder) GetWS() *websocket.Conn
  • func (w *WebsocketHolder) Join(channel string) error
  • func (w *WebsocketHolder) Listen()
  • func (w *WebsocketHolder) Pong(server string) error
  • func (w *WebsocketHolder) Send(channel, messageRaw string) error

Types

type WebsocketHolder

type WebsocketHolder struct {
	// Websocket
	WS *websocket.Conn
	// Done is used to gracefully exit all WS connections
	Done  chan struct{}
	TRoom string

	Users       map[string]*user.ASUser
	RealUsers   map[string]*user.RealUser
	TwitchUsers map[string]*user.ASUser
	TwitchRooms map[string]string
}

func (*WebsocketHolder) Connect

func (w *WebsocketHolder) Connect(oauthToken, username string) (err error)

Connect opens a Websocket and requests the needed Capabilities and does the Login

func (*WebsocketHolder) GetWS

func (w *WebsocketHolder) GetWS() *websocket.Conn

func (*WebsocketHolder) Join

func (w *WebsocketHolder) Join(channel string) error

func (*WebsocketHolder) Listen

func (w *WebsocketHolder) Listen()

Listen answers to the PING messages by Twitch and relays messages to Matrix

func (*WebsocketHolder) Pong

func (w *WebsocketHolder) Pong(server string) error

func (*WebsocketHolder) Send

func (w *WebsocketHolder) Send(channel, messageRaw string) error