faas

type ApiWorkerOptions struct {
	ApiName          string
	Path             string
	Security         map[string][]string
	SecurityDisabled bool
}

type BucketNotificationContext struct {
	Request  BucketNotificationRequest
	Response *BucketNotificationResponse
	Extras   map[string]interface{}
}

type BucketNotificationHandler = func(*BucketNotificationContext) (*BucketNotificationContext, error)

type BucketNotificationMiddleware = func(*BucketNotificationContext, BucketNotificationHandler) (*BucketNotificationContext, error)

type BucketNotificationRequest interface {
	Key() string
	NotificationType() NotificationType
}

type BucketNotificationResponse struct {
	Success bool
}

type BucketNotificationWorkerOptions struct {
	Bucket                   string
	NotificationType         NotificationType
	NotificationPrefixFilter string
}

type CronWorkerOptions struct {
	Description string
	Cron        string
}

type DataRequest interface {
	Data() []byte
	MimeType() string
	Context() context.Context
}

type EventContext struct {
	Request  EventRequest
	Response *EventResponse
	Extras   map[string]interface{}
}

type EventHandler = func(*EventContext) (*EventContext, error)

type EventMiddleware = func(*EventContext, EventHandler) (*EventContext, error)

type EventRequest interface {
	DataRequest
	Topic() string
}

type EventResponse struct {
	Success bool
}

type Frequency string //= "days" | "hours" | "minutes";

type HandlerBuilder interface {
	Http(string, ...HttpMiddleware) HandlerBuilder
	Event(...EventMiddleware) HandlerBuilder
	BucketNotification(...BucketNotificationMiddleware) HandlerBuilder
	Websocket(...WebsocketMiddleware) HandlerBuilder
	Default(...TriggerMiddleware) HandlerBuilder
	WithApiWorkerOpts(ApiWorkerOptions) HandlerBuilder
	WithRateWorkerOpts(RateWorkerOptions) HandlerBuilder
	WithCronWorkerOpts(CronWorkerOptions) HandlerBuilder
	WithSubscriptionWorkerOpts(SubscriptionWorkerOptions) HandlerBuilder
	WithBucketNotificationWorkerOptions(BucketNotificationWorkerOptions) HandlerBuilder
	WithWebsocketWorkerOptions(WebsocketWorkerOptions) HandlerBuilder
	Start() error
	String() string
}

type HandlerProvider interface {
	GetHttp(method string) HttpMiddleware
	GetEvent() EventMiddleware
	GetBucketNotification() BucketNotificationMiddleware
	GetWebsocket() WebsocketMiddleware
	GetDefault() TriggerMiddleware
}

type HttpContext struct {
	Request  HttpRequest
	Response *HttpResponse
	Extras   map[string]interface{}
}

type HttpHandler = func(*HttpContext) (*HttpContext, error)

type HttpMiddleware = func(*HttpContext, HttpHandler) (*HttpContext, error)

type HttpRequest interface {
	DataRequest
	Context() context.Context
	Method() string
	Path() string
	Query() map[string][]string
	Headers() map[string][]string
	PathParams() map[string]string
}

type HttpResponse struct {
	Status  int
	Headers map[string][]string
	Body    []byte
}

type NotificationType string

type RateWorkerOptions struct {
	Description string
	Rate        int
	Frequency   Frequency
}

type SubscriptionWorkerOptions struct {
	Topic string
}

type TriggerContext interface {
	Http() *HttpContext
	Event() *EventContext
	BucketNotification() *BucketNotificationContext
	Websocket() *WebsocketContext
}

type TriggerHandler = func(TriggerContext) (TriggerContext, error)

type TriggerMiddleware = func(TriggerContext, TriggerHandler) (TriggerContext, error)

type WebsocketContext struct {
	Request  WebsocketRequest
	Response *WebsocketResponse
	Extras   map[string]interface{}
}

type WebsocketEventType string

type WebsocketHandler = func(*WebsocketContext) (*WebsocketContext, error)

type WebsocketMiddleware = func(*WebsocketContext, WebsocketHandler) (*WebsocketContext, error)

type WebsocketRequest interface {
	DataRequest

	Socket() string
	EventType() WebsocketEventType
	ConnectionID() string
	QueryParams() map[string][]string
}

type WebsocketResponse struct {
	Success bool
}

type WebsocketWorkerOptions struct {
	Socket    string
	EventType WebsocketEventType
}