eventstore

type RelayInterface interface {
	Publish(c context.T, evt *event.T) error
	QuerySync(c context.T, f *filter.T, opts ...relay.SubscriptionOption) ([]*event.T, error)
}

type RelayWrapper struct {
	Store
}

type Store interface {
	// Init is called at the very beginning by [Server.Start], after [Relay.Init],
	// allowing a storage to initialize its internal resources.
	Init() error

	// Close must be called after you're done using the store, to free up resources and so on.
	Close()

	// QueryEvents is invoked upon a client's REQ as described in NIP-01.
	// it should return a channel with the events as they're recovered from a database.
	// the channel should be closed after the events are all delivered.
	QueryEvents(context.T, *filter.T) (chan *event.T, error)
	// DeleteEvent is used to handle deletion events, as per NIP-09.
	DeleteEvent(context.T, *event.T) error
	// SaveEvent is called once Relay.AcceptEvent reports true.
	SaveEvent(context.T, *event.T) error
}