protocol

Documentation

Index

• Constants
• func AcceptConnections()
• type Client
  • func (client *Client) IsNotFromSelf(message *Message) bool
  • func (client *Client) Register(token []byte)
• type ClientManager
  • func (m *ClientManager) HandleMessage(b []byte, h *Header)
  • func (manager *ClientManager) Receive(client *Client)
  • func (manager *ClientManager) Send(client *Client)
  • func (manager *ClientManager) Start()
• type Header
  • func NewHeader(b []byte) (header *Header)
  • func (h *Header) GetOPCode() OPCODE
  • func (h *Header) GetRequestLength() int
• type Message
  • func ParseMessage(b []byte, h *Header) *Message
  • func (m *Message) GetClientColor() int
  • func (m *Message) GetClientURL() string
  • func (m *Message) GetReceiveChannels() []int
  • func (m *Message) GetSendChannels() []int
  • func (m *Message) ToString() (buffer string)
• type OPCODE
  • func GetOPCode(b byte) OPCODE
• type OverwriteData

Constants

const (
	HostnameLen   = 64
	ClientIDLen   = 64
	ClientNameLen = 32
)

Functions

func AcceptConnections

func AcceptConnections()

Types

type Client

type Client struct {
	Socket net.Conn
	Data   chan []byte
	ID     string
}

func (*Client) IsNotFromSelf

func (client *Client) IsNotFromSelf(message *Message) bool

func (*Client) Register

func (client *Client) Register(token []byte)

type ClientManager

type ClientManager struct {
	Clients    map[*Client]bool
	Bot        chan *Message
	Router     chan *Message
	Register   chan *Client
	Unregister chan *Client
}

var (
	NetListener net.Listener
	NetManager  *ClientManager
)

func (*ClientManager) HandleMessage

func (m *ClientManager) HandleMessage(b []byte, h *Header)

func (*ClientManager) Receive

func (manager *ClientManager) Receive(client *Client)

func (*ClientManager) Send

func (manager *ClientManager) Send(client *Client)

func (*ClientManager) Start

func (manager *ClientManager) Start()

type Header

type Header struct {
	Sender        *Client
	OPCode        OPCODE
	RequestLength int
}

func NewHeader

func NewHeader(b []byte) (header *Header)

func (*Header) GetOPCode

func (h *Header) GetOPCode() OPCODE

func (*Header) GetRequestLength

func (h *Header) GetRequestLength() int

type Message

type Message struct {
	Header     *Header
	Overwrite  *OverwriteData
	Hostname   string
	ClientID   string
	ClientName string
	Content    string
}

func ParseMessage

func ParseMessage(b []byte, h *Header) *Message

func (*Message) GetClientColor

func (m *Message) GetClientColor() int

func (*Message) GetClientURL

func (m *Message) GetClientURL() string

func (*Message) GetReceiveChannels

func (m *Message) GetReceiveChannels() []int

func (*Message) GetSendChannels

func (m *Message) GetSendChannels() []int

func (*Message) ToString

func (m *Message) ToString() (buffer string)

type OPCODE

type OPCODE int

const (
	AuthenticateFrame OPCODE = iota // 0
	MessageFrame
	UnknownFrame
)

func GetOPCode

func GetOPCode(b byte) OPCODE

type OverwriteData

type OverwriteData struct {
	ReceiveChannels []int
	SendChannels    []int
}