openapi

type DeliverChan chan *Delivery

type Delivery struct {
	SubId string   `json:"sub_id"`
	Event *event.E `json:"event"`
}

type Event struct {
	SubID string   `json:"sub_id"`
	Event *event.J `json:"event"`
}

type EventInput struct {
	Auth   string   `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"false"`
	Accept string   `header:"Accept" default:"application/nostr+json"`
	Body   *event.J `doc:"event JSON"`
}

type EventOutput struct{}

type EventsInput struct {
	Auth   string  `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"false"`
	Accept string  `header:"Accept" default:"application/nostr+json"`
	Body   *Filter `doc:"filter JSON (standard NIP-01 filter syntax)"`
}

type EventsOutput struct {
	Body []*event.J
}

type ExportInput struct {
	Auth string `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"true"`
}

type ExportOutput struct{ RawBody []byte }

type Filter struct {
	Ids     []string `json:"ids,omitempty"`
	Kinds   []int    `json:"kinds,omitempty"`
	Authors []string `json:"authors,omitempty"`
	Tag_a   []string `json:"#a,omitempty"`
	Tag_b   []string `json:"#b,omitempty"`
	Tag_c   []string `json:"#c,omitempty"`
	Tag_d   []string `json:"#d,omitempty"`
	Tag_e   []string `json:"#e,omitempty"`
	Tag_f   []string `json:"#f,omitempty"`
	Tag_g   []string `json:"#g,omitempty"`
	Tag_h   []string `json:"#h,omitempty"`
	Tag_i   []string `json:"#i,omitempty"`
	Tag_j   []string `json:"#j,omitempty"`
	Tag_k   []string `json:"#k,omitempty"`
	Tag_l   []string `json:"#l,omitempty"`
	Tag_m   []string `json:"#m,omitempty"`
	Tag_n   []string `json:"#n,omitempty"`
	Tag_o   []string `json:"#o,omitempty"`
	Tag_p   []string `json:"#p,omitempty"`
	Tag_q   []string `json:"#q,omitempty"`
	Tag_r   []string `json:"#r,omitempty"`
	Tag_s   []string `json:"#s,omitempty"`
	Tag_t   []string `json:"#t,omitempty"`
	Tag_u   []string `json:"#u,omitempty"`
	Tag_v   []string `json:"#v,omitempty"`
	Tag_w   []string `json:"#w,omitempty"`
	Tag_x   []string `json:"#x,omitempty"`
	Tag_y   []string `json:"#y,omitempty"`
	Tag_z   []string `json:"#z,omitempty"`
	Tag_A   []string `json:"#A,omitempty"`
	Tag_B   []string `json:"#B,omitempty"`
	Tag_C   []string `json:"#C,omitempty"`
	Tag_D   []string `json:"#D,omitempty"`
	Tag_E   []string `json:"#E,omitempty"`
	Tag_F   []string `json:"#F,omitempty"`
	Tag_G   []string `json:"#G,omitempty"`
	Tag_H   []string `json:"#H,omitempty"`
	Tag_I   []string `json:"#I,omitempty"`
	Tag_J   []string `json:"#J,omitempty"`
	Tag_K   []string `json:"#K,omitempty"`
	Tag_L   []string `json:"#L,omitempty"`
	Tag_M   []string `json:"#M,omitempty"`
	Tag_N   []string `json:"#N,omitempty"`
	Tag_O   []string `json:"#O,omitempty"`
	Tag_P   []string `json:"#P,omitempty"`
	Tag_Q   []string `json:"#Q,omitempty"`
	Tag_R   []string `json:"#R,omitempty"`
	Tag_S   []string `json:"#S,omitempty"`
	Tag_T   []string `json:"#T,omitempty"`
	Tag_U   []string `json:"#U,omitempty"`
	Tag_V   []string `json:"#V,omitempty"`
	Tag_W   []string `json:"#W,omitempty"`
	Tag_X   []string `json:"#X,omitempty"`
	Tag_Y   []string `json:"#Y,omitempty"`
	Tag_Z   []string `json:"#Z,omitempty"`
	Since   *int64   `json:"since,omitempty"`
	Until   *int64   `json:"until,omitempty"`
	Search  *string  `json:"search,omitempty"`
	Limit   *int     `json:"limit,omitempty"`
}

type H struct {
	sync.Mutex

	// If Cancel is true, this is a close command (must be done when a listener
	// connection is closed).
	Cancel bool

	// New is a flag that signifies a newly created client_id
	New bool

	// Id is the identifier for an HTTP subscription listener channel
	Id string

	// FilterMap is the collection of filters associated with a listener.
	FilterMap map[string]*filter.F

	// Receiver is the channel for receiving events
	Receiver DeliverChan

	// Pubkey is the authenticated public key for this listener
	Pubkey []byte
}

type ImportInput struct {
	Auth string `header:"Authorization" doc:"nostr nip-98 (and expiring variant) token for authentication" required:"true"`
	Body string `doc:"events in line structured JSON (JSONL)"`
}

type ImportOutput struct{}

type ListenInput struct {
	Auth   string `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"false"`
	Accept string `header:"Accept" default:"text/event-stream" enum:"text/event-stream" required:"true"`
}

type OK func(
	a *Operations, env eventId.Ider, format string, params ...any,
) (err error)

type OKs struct {
	Ok           OK
	AuthRequired OK
	PoW          OK
	Duplicate    OK
	Blocked      OK
	RateLimited  OK
	Invalid      OK
	Error        OK
	Unsupported  OK
	Restricted   OK
}

type Operations struct {
	server.I

	*servemux.S
	// contains filtered or unexported fields
}

type Publisher struct {
	sync.Mutex

	// ListenMap maps listener IDs to listener objects
	ListenMap map[string]*H

	// Server is an interface to the server
	Server server.I
}

type SubscribeInput struct {
	Auth     string  `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"false"`
	Accept   string  `header:"Accept" default:"application/nostr+json"`
	ClientId string  `path:"client_id" doc:"Client identifier code associated with subscription channel created with /listen"`
	Id       string  `path:"id" doc:"Identifier of the subscription associated with the filter"`
	Body     *Filter `doc:"filter JSON (standard NIP-01 filter syntax)"`
}

type UnsubscribeInput struct {
	ClientId string `path:"client_id" doc:"Client identifier code associated with subscription channel created with /listen"`
	Id       string `path:"id" doc:"Identifier of the subscription to cancel"`
}