websocket

type Channel[I, M any] struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Filterable[M any] interface {
	Filter(c client, msg M) bool
}

type Filters struct {
	// contains filtered or unexported fields
}

type HeadFilter struct{}

type Manager struct {
	// contains filtered or unexported fields
}

type Message struct {
	Method string          `json:"method" validate:"required,oneof=subscribe,unsubscribe"`
	Body   json.RawMessage `json:"body"   validate:"required"`
}

type Subscribe struct {
	Channel string          `json:"channel" validate:"required,oneof=head tx"`
	Filters json.RawMessage `json:"filters" validate:"required"`
}

type TransactionFilters struct {
	Status   []string `json:"status,omitempty"`
	Messages []string `json:"msg_type,omitempty"`
}

type TxFilter struct{}

type Unsubscribe struct {
	Channel string `json:"channel" validate:"required,oneof=head tx"`
}