accesspoint

type Client interface {
	Close()

	GetConnID() string
	GetConn() Conn
	GetUser() rprt.User

	IsAllowed(member rprt.Member) bool

	LogError(format string, args ...interface{})
	LogWarn(format string, args ...interface{})
	LogInfo(format string, args ...interface{})
	LogDebug(format string, args ...interface{})

	Auth(Request) (interface{}, error)
	GetMethods(Request) (interface{}, error)
	GetUsers(Request) (interface{}, error)

	SubscribeToLog(Request) (interface{}, error)
	UnsubscribeFromLog(Request) (interface{}, error)

	AddReport(Request) (interface{}, error)
	GetReportList(Request) (interface{}, error)
	SubscribeToReports(Request) (interface{}, error)
	UnsubscribeFromReports(Request) (interface{}, error)

	Test(Request) (interface{}, error)
}

type Clients interface {
	// Close closes the database.
	Close()

	// Get returns client by kite.Client.
	Get(*kite.Client) (Client, error)

	// Add adds new connetion in the database.
	Add(Client)
	// Remove removes a connetion from the database.
	Remove(*kite.Client)

	// RegisterMethod informs the client object about new method for users.
	RegisterMethod(rprt.UserMethod)
	// GetMethod returns a method list witch available.
	GetMethods() []rprt.UserMethod
}

type Conn interface {
	Close()
	GetHandle() *kite.Client
	CallRemoteWithTimeout(
		method string, timeout time.Duration, args ...interface{}) (
		*dnode.Partial, error)
}

type GroupMessage struct {
	Domain string
	Name   string
}

type LogRecordMessage struct {
	SequenceNumber int64  `json:"seqNum"`
	Time           int64  `json:"time"`
	Text           string `json:"text"`
	Severity       string `json:"severity"`
	NodeType       string `json:"nodeType"`
	NodeName       string `json:"nodeName"`
}

type ReportMessage struct {
	ID         rprt.ReportID `json:"id"`
	Title      string        `json:"title"`
	Desc       string        `json:"desc"`
	Author     string        `json:"author"`
	Membership GroupMessage  `json:"membership"`
}

type Request interface {
	GetArgs() RequestArgs
}

type RequestArgs interface {
	GetString() string
	Unmarshal(interface{}) error
}