messages

type A primitive.A

type DebugLogger interface {
	Debug(msg string, keyVals ...interface{})
}

type Filter struct {
	IDs     []event.ID      `json:"ids" bson:"ids"`
	Authors []event.PubKey  `json:"authors" bson:"authors"`
	Kinds   []event.Kind    `json:"kinds" bson:"kinds"`
	E       []event.ID      `json:"#e" bson:"#e"`
	P       []event.PubKey  `json:"#p" bson:"#p"`
	Since   event.Timestamp `json:"since" bson:"since"`
	Until   event.Timestamp `json:"until" bson:"until"`
	Limit   int64           `json:"limit" bson:"limit"`
}

type M primitive.M

type MessageReader interface {
	Read(ctx context.Context) (websocket.MessageType, []byte, error)
}

type MessageType string

type SessionID string

type Subscription struct {
	ID        SubscriptionID `bson:"id"`
	Filters   []Filter       `bson:"filter"`
	SessionID SessionID      `bson:"session"`
}

type SubscriptionID string

type SubscriptionUUID string

type WebsocketMessage struct {
	MsgType MessageType
	Err     error
	Value   interface{}
}