gws

type AuthorizeFunc func(Context, string) error

type CacheAdaptor interface {
	Set(key []byte, data []byte, ttl time.Duration) error
	Get(key []byte) ([]byte, error)
}

type Condition struct {
	EqIDs  []int64  `protobuf:"varint,10,rep,packed,name=EqIDs" json:"EqIDs,omitempty"`
	NeIDs  []int64  `protobuf:"varint,11,rep,packed,name=NeIDs" json:"NeIDs,omitempty"`
	EqKeys []string `protobuf:"bytes,20,rep,name=EqKeys" json:"EqKeys,omitempty"`
	NeKeys []string `protobuf:"bytes,21,rep,name=NeKeys" json:"NeKeys,omitempty"`
}

type Context interface {
	Identity() Identity
	MachineID() string
	ProcessID() string
	Context() context.Context
	Req() *http.Request
	Res() http.ResponseWriter
	Client() router.Client
	Cookie() router.Cookie
	Header() router.Header
	Subscriptions() Subscriptions
	Connection() *websocket.Conn
	Cache() CacheAdaptor
	Message() MessageAdaptor
	Write(string, interface{}) error
	Error(string, interface{}) error
	Close() error
	BeforeOpen()
	AfterClose()
}

type DataMessagePayload struct {
	Data   interface{} `json:"data"`
	Errors []error     `json:"errors"`
}

type Distribution struct {
	Field     string     `protobuf:"bytes,10,opt,name=field" json:"field,omitempty"`
	Payload   []byte     `protobuf:"bytes,20,opt,name=payload,proto3" json:"payload,omitempty"`
	Filters   []*Filter  `protobuf:"bytes,30,rep,name=filters" json:"filters,omitempty"`
	Condition *Condition `protobuf:"bytes,50,opt,name=condition" json:"condition,omitempty"`
	Strict    bool       `protobuf:"varint,60,opt,name=strict" json:"strict,omitempty"`
}

type Filter struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// Types that are valid to be assigned to ValOneof:
	//	*Filter_StringValue
	//	*Filter_IntValue
	//	*Filter_FloatValue
	//	*Filter_BoolValue
	//	*Filter_BytesValue
	//	*Filter_TimeValue
	ValOneof isFilter_ValOneof `protobuf_oneof:"val_oneof"`
}

type Filter_BoolValue struct {
	BoolValue bool `protobuf:"varint,13,opt,name=bool_value,json=boolValue,oneof"`
}

type Filter_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,14,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Filter_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,12,opt,name=float_value,json=floatValue,oneof"`
}

type Filter_IntValue struct {
	IntValue int64 `protobuf:"varint,11,opt,name=int_value,json=intValue,oneof"`
}

type Filter_StringValue struct {
	StringValue string `protobuf:"bytes,10,opt,name=string_value,json=stringValue,oneof"`
}

type Filter_TimeValue struct {
	TimeValue int64 `protobuf:"varint,15,opt,name=time_value,json=timeValue,oneof"`
}

type HandlerFunc func([]byte, Context)

type HookFunc func(Context)

type Identity interface {
	HasID() bool
	GetID() int
	SetID(int)
	HasKey() bool
	GetKey() string
	SetKey(string)
}

type InitMessagePayload struct {
	AuthToken string `json:"authToken"`
}

type MessageAdaptor interface {
	Emit([]byte, []byte) error
	Listen([]byte, message.Handler) message.Close
}

type OperationMessage struct {
	ID      string      `json:"id,omitempty"`
	Type    string      `json:"type"`
	Payload interface{} `json:"payload,omitempty"`
}

type Option func(*Options)

type Options struct {

	// engine server unique id
	ID string

	// message broker topic
	Topic []byte

	// graphql schema
	Schema graphql.Schema

	// cache engine
	Cache cache.Service

	// message broker
	Message message.Service
}

type Service interface {
	Start() error
	Stop() error
	Publish(*Distribution) error
	Subscribe(*Distribution) error
	Subscriptions() Store
	Handle(router.Context, *websocket.Conn)
	Schema(graphql.Schema)
	Adaptor() router.GQLSubscriptionAdaptor
	Authorize(AuthorizeFunc)
	BeforeOpen(HookFunc)
	AfterClose(HookFunc)
	String() string
}

type StartMessagePayload struct {
	Query         string                 `json:"query"`
	Variables     map[string]interface{} `json:"variables"`
	OperationName string                 `json:"operationName"`
}

type Store interface {
	Has(Subscription) bool
	Add(Subscription, ...bool) bool
	Del(Subscription) bool
	Get(...string) []Subscription
}

type Subscription interface {
	ID() string
	Query() string
	Variables() map[string]interface{}
	Arguments() map[string]interface{}
	OperationName() string
	Document() *ast.Document
	Fields() []string
	Connection() Context
}

type Subscriptions interface {
	Has(string) bool
	Add(Subscription, ...bool) bool
	Del(Subscription) bool
	Get(string) Subscription
	List() []Subscription
	Len() int
}