server

type ApiDiscovery interface {
	ApiForScope() Endpoint
	ApiForFunc(func(context.Context, http.ResponseWriter, *http.Request)) Endpoint
}

type Auth struct {
	IsAuthOnFunc      func() bool
	GetTimeFunc       func() time.Time
	VerifyKeyFunc     func() []byte
	ErrorRenderFunc   func(http.ResponseWriter, *http.Request, string, int) error
	InterceptAuthFunc func(bool, context.Context) (bool, context.Context)
}

type AuthManager interface {
	IsAuthOn() bool
	IsAuthorized(AuthScope, *http.Request) (bool, *auth.Token, error)
	// contains filtered or unexported methods
}

type AuthScope string

type Endpoint struct {
	Doc                  string                          `json:"doc,omitempty"`
	UrlRoute             string                          `json:"route,omitempty"`
	HttpHeaders          HttpHeaders                     `json:"headers,omitempty"`
	HttpMethod           HttpMethod                      `json:"method,omitempty"`
	HttpMethods          []HttpMethod                    `json:"methods,omitempty"`
	UrlQueries           UrlQueries                      `json:"queries,omitempty"`
	FormParams           FormParams                      `json:"params,omitempty"`
	ContentType          encoding.ContentType            `json:"contentType,omitempty"`
	RequestBody          func(*http.Request) interface{} `json:"requestBody,omitempty"`
	ResponseBody         func(*http.Request) interface{} `json:"responseBody,omitempty"`
	CallbackEvent        EventKey                        `json:"callbackEvent,omitempty"`
	CallbackBodyTemplate string                          `json:"callbackBody,omitempty"`
	AuthScope            AuthScope                       `json:"scope,omitempty"`
}

type EventKey string

type EventKeyUrlMap map[string]Webhook

type FormParams UrlQueries

type Handler func(auth context.Context, resp http.ResponseWriter, req *http.Request)

type HttpHeaders map[string]string

type HttpMethod string

type QueryDefault interface{}

type ReverseProxy struct {
	http.Handler
	// contains filtered or unexported fields
}

type Server interface {
	ApiDiscovery
	http.Handler
	Handle(string, http.Handler)
}

type ServerEvent struct {
	Timestamp time.Time
	Key       string
	Route     string
	Body      interface{}
}

type Streamer interface {
	EventChannel() chan<- *ServerEvent
	StreamChannel(contentType, eventType, key string) (*sseChannel, bool)
	MergeHttpStream(w http.ResponseWriter, r *http.Request, contentType, eventType, key string, src <-chan interface{}) error
	DirectHttpStream(http.ResponseWriter, *http.Request) (chan<- interface{}, error)
}

type UrlQueries map[string]QueryDefault

type Webhook struct {
	Url       string `json:"destination_url"`
	AuthToken string `json:"auth_token,omitempty"`
}

type WebhookManager interface {
	Send(service string, event string, message interface{}, templateString string) error
	RegisterWebhooks(service string, ekum EventKeyUrlMap) error
	RemoveWebhooks(service string) error
}

type WebhookMap map[string]EventKeyUrlMap