relayer

Sep 29, 2024

Changes in this version

+ func BroadcastEvent(evt *nostr.Event)

Jul 14, 2024

Changes in this version

type Option

+ func WithSkipEventFunc(skipEventFunc func(*nostr.Event) bool) Option

Oct 7, 2023

Changes in this version

+ type ReqAccepter interface

+ AcceptReq func(context.Context, string, nostr.Filters) bool

Oct 5, 2023

Changes in this version

+ type Option func(*Options)

+ func WithPerConnectionLimiter(rps rate.Limit, burst int) Option

+ type Options struct

+ func DefaultOptions() *Options

Jul 15, 2023

Changes in this version

+ const AUTH_CONTEXT_KEY

+ func GetAuthStatus(ctx context.Context) (pubkey string, ok bool)

May 18, 2023

Changes in this version

+ func AddEvent(ctx context.Context, relay Relay, evt nostr.Event) (accepted bool, message string)

+ func GetListeningFilters() nostr.Filters

+ type AdvancedDeleter interface

+ AfterDelete func(id string, pubkey string)

+ BeforeDelete func(ctx context.Context, id string, pubkey string)

+ type AdvancedSaver interface

+ AfterSave func(*nostr.Event)

+ BeforeSave func(context.Context, *nostr.Event)

+ type Auther interface

+ ServiceURL func() string

+ type CustomWebSocketHandler interface

+ HandleUnknownType func(ws *WebSocket, typ string, request []json.RawMessage)

+ type EventCounter interface

+ CountEvents func(ctx context.Context, filter *nostr.Filter) (int64, error)

+ type Informationer interface

+ GetNIP11InformationDocument func() nip11.RelayInformationDocument

+ type Injector interface

+ InjectEvents func() chan nostr.Event

+ type Listener struct

+ type Logger interface

+ Errorf func(format string, v ...any)

+ Infof func(format string, v ...any)

+ Warningf func(format string, v ...any)

+ type Notice struct

+ Kind string

+ Message string

+ type Relay interface

+ AcceptEvent func(context.Context, *nostr.Event) bool

+ Init func() error

+ Name func() string

+ Storage func(context.Context) Storage

+ type Server struct

+ Addr string

+ Log Logger

+ func NewServer(relay Relay) (*Server, error)

+ func (s *Server) HandleNIP11(w http.ResponseWriter, r *http.Request)

+ func (s *Server) HandleWebsocket(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Router() *http.ServeMux

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Shutdown(ctx context.Context)

+ func (s *Server) Start(host string, port int, started ...chan bool) error

+ type ShutdownAware interface

+ OnShutdown func(context.Context)

+ type Storage interface

+ DeleteEvent func(ctx context.Context, id string, pubkey string) error

+ Init func() error

+ QueryEvents func(ctx context.Context, filter *nostr.Filter) (chan *nostr.Event, error)

+ SaveEvent func(ctx context.Context, event *nostr.Event) error

+ type WebSocket struct

+ func (ws *WebSocket) WriteJSON(any interface{}) error

+ func (ws *WebSocket) WriteMessage(t int, b []byte) error