wasmbus

type AnyServerHandler interface {
	HandleMessage(ctx context.Context, msg *Message) error
}

type Bus interface {
	// Subscribe creates a subscription for the given subject.
	// The backlog parameter is the maximum number of messages that can be buffered in memory.
	Subscribe(subject string, backlog int) (Subscription, error)
	// QueueSubscribe creates a subscription for the given subject and queue group.
	// The backlog parameter is the maximum number of messages that can be buffered in memory.
	QueueSubscribe(subject string, queue string, backlog int) (Subscription, error)
	// Request sends a request message and waits for a reply.
	// The context is used for the request timeout.
	Request(ctx context.Context, msg *Message) (*Message, error)
	// Publish sends a message to `msg.Subject`.
	Publish(msg *Message) error
}

type Header = http.Header

type LatticeRequest[T any, Y any] struct {
	// Request should be a reference to the request struct
	Request T
	// Response should be a struct that the response will be unmarshaled into
	// and should be passed by value
	Response    Y
	Subject     string
	Bus         Bus
	PreRequest  func(context.Context, T, *Message) error
	PostRequest func(context.Context, *Y, *Message) error
}

type Message struct {
	Subject string
	Reply   string
	Header  Header
	Data    []byte
	// contains filtered or unexported fields
}

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

type NatsOption = nats.Option

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

type RequestHandler[T any, Y any] struct {
	Request     T
	Response    Y
	PreRequest  func(context.Context, *T, *Message) error
	PostRequest func(context.Context, *Y, *Message) error
	Handler     func(context.Context, *T) (*Y, error)
}

type Server struct {
	Bus
	// Lattice is an informative field containing the lattice name.
	// It is NOT used when manipulating subjects.
	Lattice string
	// ContextFunc is a function that returns a new context for each message.
	// Defaults to `context.Background`.
	ContextFunc func() context.Context
	// contains filtered or unexported fields
}

type ServerError struct {
	Context context.Context
	Err     error
	Request *Message
}

type ServerHandlerFunc func(context.Context, *Message) error

type Subscription interface {
	// Handle starts the subscription and calls the callback for each message.
	// Does not block.
	Handle(callback SubscriptionCallback)
	// Drain stops the subscription and closes the channel.
	// Blocks until all messages are processed, releasing the Subscription Thread.
	Drain() error
}

type SubscriptionCallback func(msg *Message)