relay

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

type Relay struct {
	ServiceURL string

	RejectEvent               []func(c context.T, ev *event.T) (reject bool, msg string)
	RejectFilter              []func(c context.T, f *filter.T) (reject bool, msg string)
	RejectCountFilter         []func(c context.T, f *filter.T) (reject bool, msg string)
	OverwriteDeletionOutcome  []func(c context.T, target *event.T, deletion *event.T) (acceptDeletion bool, msg string)
	OverwriteResponseEvent    []func(c context.T, ev *event.T)
	OverwriteFilter           []func(c context.T, f *filter.T)
	OverwriteCountFilter      []func(c context.T, f *filter.T)
	OverwriteRelayInformation []func(c context.T, r *http.Request, info *relayinfo.T) *relayinfo.T
	StoreEvent                []func(c context.T, ev *event.T) error
	DeleteEvent               []func(c context.T, ev *event.T) error
	QueryEvents               []func(c context.T, f *filter.T) (chan *event.T, error)
	CountEvents               []func(c context.T, f *filter.T) (int64, error)
	OnAuth                    []func(c context.T, pubkey string)
	OnConnect                 []func(c context.T)
	OnDisconnect              []func(c context.T)
	OnEventSaved              []func(c context.T, ev *event.T)

	// editing info will affect
	Info *relayinfo.T

	// Default logger, as set by NewServer, is a stdlib logger prefixed with "[khatru-relay] ",
	// outputting to stderr.
	*log2.Log

	// in case you call Server.Start
	Addr string

	// websocket options
	WriteWait      time.Duration // Time allowed to write a message to the peer.
	PongWait       time.Duration // Time allowed to read the next pong message from the peer.
	PingPeriod     time.Duration // Send pings to peer with this period. Must be less than pongWait.
	MaxMessageSize int64         // Maximum message size allowed from peer.
	// contains filtered or unexported fields
}

type WebSocket struct {

	// original request
	Request *http.Request

	// nip42
	Challenge       string
	AuthedPublicKey string
	Authed          chan struct{}
	// contains filtered or unexported fields
}