notifications

type Auther interface {
	// JWTAuth implements the authorization logic for the JWT security scheme.
	JWTAuth(ctx context.Context, token string, schema *security.JWTScheme) (context.Context, error)
}

type Client struct {
	ListenEndpoint goa.Endpoint
	SeenEndpoint   goa.Endpoint
}

type Endpoints struct {
	Listen goa.Endpoint
	Seen   goa.Endpoint
}

type ListenClientStream interface {
	// Send streams instances of "map[string]any".
	Send(map[string]any) error
	// SendWithContext streams instances of "map[string]any" with context.
	SendWithContext(context.Context, map[string]any) error
	// Recv reads instances of "map[string]any" from the stream.
	Recv() (map[string]any, error)
	// RecvWithContext reads instances of "map[string]any" from the stream with
	// context.
	RecvWithContext(context.Context) (map[string]any, error)
	// Close closes the stream.
	Close() error
}

type ListenEndpointInput struct {
	// Stream is the server stream used by the "listen" method to send data.
	Stream ListenServerStream
}

type ListenServerStream interface {
	// Send streams instances of "map[string]any".
	Send(map[string]any) error
	// SendWithContext streams instances of "map[string]any" with context.
	SendWithContext(context.Context, map[string]any) error
	// Recv reads instances of "map[string]any" from the stream.
	Recv() (map[string]any, error)
	// RecvWithContext reads instances of "map[string]any" from the stream with
	// context.
	RecvWithContext(context.Context) (map[string]any, error)
	// Close closes the stream.
	Close() error
}

type SeenPayload struct {
	Auth string
	Ids  []int64
}

type Service interface {
	// Listen implements listen.
	Listen(context.Context, ListenServerStream) (err error)
	// Seen implements seen.
	Seen(context.Context, *SeenPayload) (err error)
}