messages

type A primitive.A

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 Subscription struct {
	ID      SubscriptionID `json:"id" bson:"id"`
	Filters []Filter       `bson:"filter"`
}

type SubscriptionID string

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