app

type Command struct {
	Name string
	Help string
	Func func(rl *Relay, prefix string, ev *event.T, cmd *Command, args ...string) (reply *event.T, err error)
}

type Config struct {
	ExportCmd    *ExportCmd `arg:"subcommand:export" json:"-" help:"export database as line structured JSON"`
	ImportCmd    *ImportCmd `arg:"subcommand:import" json:"-" help:"import data from line structured JSON"`
	InitCfgCmd   *InitCfg   `arg:"subcommand:initcfg" json:"-" help:"initialize relay configuration files"`
	Listen       string     `arg:"-l,--listen" default:"0.0.0.0:3334" json:"listen" help:"network address to listen on"`
	EventStore   string     `arg:"-e,--eventstore" default:"ic" json:"eventstore" help:"select event store backend [ic,badger]"`
	CanisterAddr string     `arg:"-C,--canisteraddr" default:"127.0.0.1:46847" json:"canister_addr" help:"IC canister address to use"`
	CanisterID   string     `arg:"-I,--canisterid" json:"canister_id" help:"IC canister ID to use"`
	Profile      string     `arg:"-p,--profile" json:"-" default:"replicatr" help:"profile name to use for storage"`
	Name         string     `arg:"-n,--name" json:"name" default:"replicatr relay" help:"name of relay for NIP-11"`
	Description  string     `arg:"-d,--description" json:"description" help:"description of relay for NIP-11"`
	Pubkey       string     `arg:"--pubkey" json:"pubkey" help:"public key of relay operator"`
	Contact      string     `arg:"-c,--contact" json:"contact,omitempty" help:"non-nostr relay operator contact details"`
	Icon         string     `arg:"-i,--icon" json:"icon" default:"https://i.nostr.build/n8vM.png" help:"icon to show on relay information pages"`
	// Whitelist permits ONLY inbound connections from specified IP addresses.
	Whitelist []string `arg:"-w,--whitelist,separate" json:"ip_whitelist" help:"IP addresses that are only allowed to access"`
	// AllowIPs is for bypassing authentication required for clients based on IP
	// addresses... primarily for testing with wireguard VPN clients run by the
	// developer, as these are stable, non-routeable addresses, this skips the
	// requirement enforced by AuthRequired.
	AllowIPs     []string `arg:"-A,--allow,separate" json:"allow_ip" help:"IP addresses that are always allowed to access"`
	AuthRequired bool     `arg:"-a,--auth" json:"auth_required" default:"false" help:"NIP-42 authentication required for all access"`
	Public       bool     `arg:"--public" json:"public" default:"true" help:"allow public read access to users not on ACL"`
	Owners       []string `arg:"-o,--owner,separate" json:"owners" help:"specify public keys of users with owner level permissions on relay"`
	SecKey       string   `arg:"-s" json:"seckey" help:"identity key of relay, used to sign 30066 and 30166 events and for message control interface"`
	MaxProcs     int      `args:"-m" json:"max_procs" default:"128" help:"maximum number of goroutines to use"`
}

type CountEvents func(c context.T, f *filter.T) (cnt int, err error)

type Events func(c context.T, ev *event.T) error

type ExportCmd struct {
	ToFile string `arg:"-f,--tofile" help:"write to file instead of stdout"`
}

type Hook func(c context.T)

type ImportCmd struct {
	FromFile []string `arg:"-f,--fromfile,separate" help:"read from files instead of stdin (can use flag repeatedly for multiple files)"`
}

type InitCfg struct {
}

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

type ListenerMap = *xsync.MapOf[string, *Listener]

type OnEventSaved func(c context.T, ev *event.T)

type OverrideDeletionOutcome func(c context.T, tgt, del *event.T) (ok bool,
	msg string)

type OverwriteFilter func(c context.T, f *filter.T)

type OverwriteRelayInformation func(c context.T, r *http.Request,
	info *relayinfo.T) *relayinfo.T

type OverwriteResponseEvent func(c context.T, ev *event.T)

type QueryEvents func(c context.T, C chan *event.T,
	f *filter.T) (err error)

type RejectEvent func(c context.T, ev *event.T) (rej bool,
	msg string)

type RejectFilter func(c context.T, id subscriptionid.T,
	f *filter.T) (reject bool, msg string)

type Relay struct {
	ServiceURL             atomic.String
	RejectEvent            []RejectEvent
	RejectFilter           []RejectFilter
	RejectCountFilter      []RejectFilter
	OverrideDeletion       []OverrideDeletionOutcome
	OverwriteResponseEvent []OverwriteResponseEvent
	OverwriteFilter        []OverwriteFilter
	OverwriteCountFilter   []OverwriteFilter
	OverwriteRelayInfo     []OverwriteRelayInformation
	StoreEvent             []Events
	DeleteEvent            []Events
	QueryEvents            []QueryEvents
	CountEvents            []CountEvents
	OnConnect              []Hook
	OnDisconnect           []Hook
	OnEventSaved           []OnEventSaved
	Config                 *Config
	Info                   *relayinfo.T

	// in case you call Server.Start
	Addr string

	// websocket options
	// WriteWait is the time allowed to write a message to the peer.
	WriteWait time.Duration
	// PongWait is the time allowed to read the next pong message from the peer.
	PongWait time.Duration
	// PingPeriod is the tend pings to peer with this period. Must be less than
	// pongWait.
	PingPeriod     time.Duration
	MaxMessageSize int64    // Maximum message size allowed from peer.
	Whitelist      []string // whitelist of allowed IPs for access
	RelayPubHex    string
	RelayNpub      string
	// ACL is the list of users and privileges on this relay
	ACL *acl.T
	// contains filtered or unexported fields
}

type Spam struct {
	Spammers []Spam
}

type Spammer struct {
	Address     string
	Offenses    int
	BannedUntil time.Time
}