entity

type Aggregate struct {
	ID               uuid.UUID
	AggregateName    string
	SchemaVersion    string
	AggregateVersion string
	CreatedAt        time.Time
	UpdatedAt        time.Time
	Body             any
}

type Configurable interface {
	Configure(map[string]interface{})
	GetConfig() interface{}
}

type EchoRouter interface {
	CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

type HTTPMethod string

type HTTPServiceRequest struct {
	ID           uuid.UUID        // Unique identifier for the request
	ApiName      string           // Name of the API being called
	ServiceName  string           // Name of the specific service within the API
	Method       HTTPMethod       // HTTP method of the request
	URL          *url.URL         // Full URL of the request
	InternalPath string           // Internal path after removing prefixes
	Body         []byte           // Raw body of the request
	Form         *url.Values      // URL-encoded form data
	PostForm     *url.Values      // Posted form data
	Multipart    *MultipartData   // Multipart form data, including file uploads
	Response     *ServiceResponse // Associated response (if any)
	RequestMeta  RequestMeta      // Additional metadata about the request
	Header       http.Header      // HTTP headers
	Trailer      http.Header      // HTTP trailers
}

type Handler struct {
	InboundWorkflow  Workflow // Workflow to be applied to incoming requests
	OutboundWorkflow Workflow // Workflow to be applied to outgoing responses
	Target           Target   // The target operation to be executed
}

type HasPrecedence interface {
	Precedence() int // a value indicating precedence when a chain of

}

type HttpResponseMeta struct {
	OriginalResponse *http.Response // The original http.Response
	Status           string         // Status line of the response
	StatusCode       int            // Status code of the response
	Proto            string         // Protocol version
	ProtoMajor       int            // Major protocol version
	ProtoMinor       int            // Minor protocol version
	TransferEncoding []string       // Transfer encodings
	Header           http.Header    // HTTP headers
	Trailer          http.Header    // HTTP trailers
}

type HttpServiceResponse struct {
	ResponseMeta ResponseMeta // Metadata about the response
	Body         []byte       // Raw body of the response
}

type Hub struct {
	APIVersion      string
	Version         string
	ApplicationName string
	// contains filtered or unexported fields
}

type MultipartData struct {
	Value    map[string][]string // Regular form values
	FileData map[string][]byte   // File data, keyed by field name
}

type MultipartDataInterface interface {
	GetValue() map[string][]string
	SetValue(value map[string][]string)
	GetFileData() map[string][]byte
	SetFileData(fileData map[string][]byte)
}

type NoOpTarget struct{}

type RegisteredTargets map[string]TargetConstructor

type RegisteredTaskTypes map[string]TaskConstructor

type RequestMeta struct {
	OriginalRequest  *http.Request     // The original http.Request
	Params           map[string]string // Additional parameters (e.g., from router)
	Proto            string            // Protocol version
	ProtoMajor       int               // Major protocol version
	ProtoMinor       int               // Minor protocol version
	ContentLength    int64             // Length of the request body
	TransferEncoding []string          // Transfer encodings
	Host             string            // Requested host
	RemoteAddr       string            // Remote address of the client
	RequestURI       string            // Unmodified request-target of the Request-Line
}

type RequestMetaInterface interface {
	GetOriginalRequest() *http.Request
	SetOriginalRequest(req *http.Request)
	GetParams() map[string]string
	SetParams(params map[string]string)
	GetProto() string
	SetProto(proto string)
	GetProtoMajor() int
	SetProtoMajor(major int)
	GetProtoMinor() int
	SetProtoMinor(minor int)
	GetContentLength() int64
	SetContentLength(length int64)
	GetTransferEncoding() []string
	SetTransferEncoding(encoding []string)
	GetHost() string
	SetHost(host string)
	GetRemoteAddr() string
	SetRemoteAddr(addr string)
	GetRequestURI() string
	SetRequestURI(uri string)
}

type ResponseMeta interface {
	GetOriginalResponse() *http.Response
	GetStatus() string
	SetStatus(status string)
	GetStatusCode() int
	SetStatusCode(code int)
	GetProto() string
	SetProto(proto string)
	GetProtoMajor() int
	SetProtoMajor(major int)
	GetProtoMinor() int
	SetProtoMinor(minor int)
	GetTransferEncoding() []string
	SetTransferEncoding(encoding []string)
	GetHeader() http.Header
	SetHeader(header http.Header)
	GetTrailer() http.Header
	SetTrailer(trailer http.Header)
}

type Schema struct {
	Name    string
	Version string
	Data    []byte
}

type Service struct {
	Name           string                  // Name of the service
	SchemaName     string                  // Name of the schema used by the service
	SchemaVersion  string                  // Version of the schema
	APIName        string                  // Name of the API this service belongs to
	IsPublic       bool                    // Indicates if the service is publicly accessible
	ServiceTimeout *time.Duration          // Timeout for service operations
	Methods        map[HTTPMethod]*Handler // Map of HTTP methods to their respective handlers
}

type ServiceRequest interface {
	GetID() uuid.UUID
	GetAPIName() string
	GetServiceName() string
	GetMethod() HTTPMethod
	GetURL() *url.URL
	GetInternalPath() string
	GetBody() []byte
	SetBody(body []byte)
	GetForm() *url.Values
	SetForm(form *url.Values)
	GetPostForm() *url.Values
	SetPostForm(form *url.Values)
	GetMultipart() MultipartDataInterface
	SetMultipart(data MultipartDataInterface)
	GetResponse() ServiceResponse
	SetResponse(response ServiceResponse)
	GetRequestMeta() RequestMetaInterface
	SetRequestMeta(meta RequestMetaInterface)
	GetHeader() http.Header
	SetHeader(header http.Header)
	GetTrailer() http.Header
	SetTrailer(trailer http.Header)
}

type ServiceResponse interface {
	GetResponseMeta() ResponseMeta
	SetResponseMeta(meta ResponseMeta)
	GetBody() []byte
	SetBody(body []byte)
}

type Target interface {
	Apply(ctx context.Context, request ServiceRequest) (ServiceResponse, error)
}

type TargetConstructor interface {
	New(config map[string]any) (Target, error)
}

type TargetConstructorFunc func(config map[string]any) (Target, error)

type Task interface {
	Name() string
	Apply(ctx context.Context, request ServiceRequest) error
}

type TaskConstructor interface {
	New(config map[string]any) (Task, error)
}

type TaskConstructorFunc func(config map[string]any) (Task, error)

type Workflow interface {
	Apply(ctx context.Context, in ServiceRequest) error
}

type WorkflowStep struct {
	Task          Task // the task to be applied
	Name          string
	Description   string
	TaskType      string
	Ref           string
	ExecutionType string
	Config        map[string]interface{}
	Precedence    int // a value indicating precedence within a chain of

}

type WorkflowTasks struct {
	Steps map[int][]*WorkflowStep
}