service

type ClientStateInfo struct {
	Network       stdchat.NetworkStateInfo
	Subscriptions []stdchat.SubscriptionStateInfo
}

type LocalTransport struct {
	Protocol       string
	PublishHandler func(tp *LocalTransport,
		network, chat, node string, payload interface{}) error
	WebServer
}

type MultiTransport struct {
	Protocol string
	WebServer
	// contains filtered or unexported fields
}

type MultiTransportError struct {
	Errors []SingleTransportError
}

type MultiTransporter interface {
	Transporter
	AddTransport(transport Transporter)
	RemoveTransport(transport Transporter)
}

type Networker interface {
	io.Closer
	Receiver
	Logout(reason string) error                 // Same as Close() with logout reason.
	Start(ctx context.Context, id string) error // id = request id
	NetworkID() string
	ConnID() string // empty if no connections.
	Context() context.Context
	Closed() bool
	GetStateInfo() ClientStateInfo
}

type NewClientFunc = func(svc *Service, remote, userID, auth string, values stdchat.ValuesInfo) (Networker, error)

type Receiver interface {
	Handler(msg *stdchat.ChatMsg)
	CmdHandler(msg *stdchat.CmdMsg)
}

type Service struct {
	Verbose bool // verbose output to log.Print/Printf
	// contains filtered or unexported fields
}

type ServiceStateInfo struct {
	Protocol      stdchat.ProtocolStateInfo
	Networks      []stdchat.NetworkStateInfo
	Subscriptions []stdchat.SubscriptionStateInfo
}

type Servicer interface {
	io.Closer
	Receiver
	GenericError(err error) // An error from outside, such as during msg dispatch.
	GetClients() []Networker
	GetClientByNetwork(networkID string) Networker
	Protocol() string
	Context() context.Context
	Closed() bool
	GetStateInfo() ServiceStateInfo
}

type SingleTransportError struct {
	Transport Transporter
	Err       error
}

type Transporter interface {
	io.Closer

	GetProtocol() string

	// Advertise the service is up,
	// this needs to be called before clients can do anything.
	Advertise() error
	// Publish a message.
	// network and chat can be empty.
	// node is the final part in the topic name, as in chat/Protocol/node
	// e.g. to publish a protocol msg, use Publish("", "", "my-info", payload)
	Publish(network, chat, node string, payload interface{}) error

	// id should be the ID of the request (if a request), which can be empty.
	// network can be empty if a protocol msg.
	PublishError(id string, network string, err error) error

	// Full URL returned.
	// pathSuffix is the last part of the URL path, such as userA/foo4.png
	// handler is set to a HTTP client handler to serve the headers+content.
	// It is resonable that a directory is served.
	// Use StopServeURL to stop serving.
	ServeURL(network, pathSuffix string, handler http.Handler) (string, error)

	// Cancel serving a URL.
	// If this is the last served URL, the web service may shut down.
	StopServeURL(network, pathSuffix string)
}

type WebServer struct {
	PublicURL string // uses localhost and a random port if empty.
	BindAddr  string // parses from PublicURL if empty.
	// contains filtered or unexported fields
}