setup

type CRUDConfig[Entity database.CRUDEntity] struct {
	SystemID      string
	URL           string
	Stack         endpoint.Stack
	EmitterLogger event.EmitterLogger

	ConnFn        db.ConnFn
	APIToDBFields inpututil.APIToDBFields

	ConversionRules map[string]func(any) any
	CustomRules     map[string]func(any) error

	Create *CreateConfig[Entity]
	Get    *GetConfig[Entity]
	Update *UpdateConfig[Entity]
	Delete *DeleteConfig[Entity]
}

type CRUDDefinitions struct {
	Endpoints map[CRUDOperation]endpoint.Definition
}

type CRUDOperation string

type CRUDOption[Entity database.CRUDEntity] func(*CRUDConfig[Entity])

type CreateConfig[Entity database.Mutator] struct {
	// Default config for the create input handler.
	DefaultInputHandlerConfig *DefaultCreateInputHandlerConfig[Entity]
	// Override config for the create handler logic.
	InputHandlerFactoryFn func() endpoint.InputHandler[services.CreateInputer[Entity]]

	// Default config for the create handler logic.
	DefaultHandlerLogicConfig *DefaultCreateHandlerLogicConfig[Entity]
	// Override for the create handler logic.
	HandlerLogicFnFactoryFn func() endpoint.HandlerLogicFn[services.CreateInputer[Entity]]

	ErrorHandlerFactoryFn  func() endpoint.ErrorHandler
	OutputHandlerFactoryFn func() endpoint.OutputHandler
}

type CreateHandler[Entity database.Mutator] interface {
	Handle(
		w http.ResponseWriter, r *http.Request, i *services.CreateInputer[Entity],
	) (any, error)
}

type DefaultCRUDConfig[Entity database.CRUDEntity] struct {
	SystemID              string
	URL                   string
	ConnFn                db.ConnFn
	EntityFn              func(...db.EntityOption[Entity]) Entity
	APIToDBFields         inpututil.APIToDBFields
	AllAPIFields          input.APIFields
	CreateAPIFields       input.APIFields
	CreateInputFactoryFn  func() services.CreateInputer[Entity]
	CreateOutputFactoryFn func() services.CreateOutputer[Entity]
	GetAPIFields          input.APIFields
	GetOutputFactoryFn    func() services.GetOutputer[Entity]
	UpdateAPIFields       input.APIFields
	DeleteAPIFields       input.APIFields
}

type DefaultCreateHandlerLogicConfig[Entity database.Mutator] struct {
	OutputFactoryFn func() services.CreateOutputer[Entity]
	BeforeCallback  services.BeforeCreateCallback[Entity]
	AfterCallback   services.AfterCreate[Entity]
	TxManager       db.TxManager[Entity]
	MutatorRepo     db.MutatorRepository[Entity]
}

type DefaultCreateInputHandlerConfig[Entity database.Mutator] struct {
	APIFields      input.APIFields
	InputFactoryFn func() services.CreateInputer[Entity]
}

type DefaultDeleteHandlerLogicConfig[Entity database.Mutator] struct {
	OutputFactoryFn func() services.DeleteOutputer
	BeforeCallback  services.BeforeDeleteCallback[Entity]
	AfterCallback   services.AfterDelete
	EntityFn        func(...db.EntityOption[Entity]) Entity
}

type DefaultDeleteInput struct {
	Selectors apidb.APISelectors `json:"selectors"`
}

type DefaultDeleteInputHandlerConfig struct {
	APIFields      input.APIFields
	InputFactoryFn func() services.DeleteInputer
}

type DefaultDeleteOutput struct {
	Count int64 `json:"count"`
}

type DefaultGetHandlerLogicConfig[Entity database.Getter] struct {
	OutputFactoryFn func() services.GetOutputer[Entity]
	BeforeCallback  services.BeforeGetCallback
	AfterGetFn      services.AfterGet[Entity]
	EntityFn        func(...db.EntityOption[Entity]) Entity
	TxManager       db.TxManager[Entity]
	ReaderRepo      db.ReaderRepository[Entity]
}

type DefaultGetInput struct {
	Selectors apidb.APISelectors `json:"selectors"`
	Orders    apidb.Orders       `json:"orders"`
	Page      *apidb.Page        `json:"page"`
	Count     bool               `json:"count"`
}

type DefaultGetInputHandlerConfig struct {
	APIFields      input.APIFields
	InputFactoryFn func() services.GetInputer
}

type DefaultGetOutput[Entity database.Getter] struct {
	Entities []Entity `json:"entities"`
	Count    int      `json:"count"`
}

type DefaultUpdateHandlerLogicConfig[Entity database.Mutator] struct {
	OutputFactoryFn func() services.UpdateOutputer
	BeforeCallback  services.BeforeUpdateCallback[Entity]
	AfterUpdateFn   services.AfterUpdate[Entity]
	EntityFn        func(...db.EntityOption[Entity]) Entity
}

type DefaultUpdateInput struct {
	Selectors apidb.APISelectors `json:"selectors"`
	Updates   apidb.APIUpdates   `json:"updates"`
	Upsert    bool               `json:"upsert"`
}

type DefaultUpdateInputHandlerConfig struct {
	APIFields      input.APIFields
	InputFactoryFn func() services.UpdateInputer
}

type DefaultUpdateOutput struct {
	Count int64 `json:"count"`
}

type DeleteConfig[Entity database.Mutator] struct {
	// Default config for the delete input handler.
	DefaultInputHandlerConfig *DefaultDeleteInputHandlerConfig
	// Override for the delete input handler.
	InputHandlerFactoryFn func() endpoint.InputHandler[services.DeleteInputer]

	// Default config for the delete handler logic.
	DefaultHandlerLogicConfig *DefaultDeleteHandlerLogicConfig[Entity]
	// Override for the delete handler logic.
	HandlerLogicFnFactoryFn func() endpoint.HandlerLogicFn[services.DeleteInputer]

	ErrorHandlerFactoryFn  func() endpoint.ErrorHandler
	OutputHandlerFactoryFn func() endpoint.OutputHandler
}

type DeleteHandler interface {
	Handle(
		w http.ResponseWriter, r *http.Request, i services.DeleteInputer,
	) (any, error)
}

type GetConfig[Entity database.Getter] struct {
	// Default config for the get input handler.
	DefaultInputHandlerConfig *DefaultGetInputHandlerConfig
	// Override for the get input handler.
	InputHandlerFactoryFn func() endpoint.InputHandler[services.GetInputer]

	// Default config for the get handler logic.
	DefaultHandlerLogicConfig *DefaultGetHandlerLogicConfig[Entity]
	// Override for the get handler logic.
	HandlerLogicFnFactoryFn func() endpoint.HandlerLogicFn[services.GetInputer]

	ErrorHandlerFactoryFn  func() endpoint.ErrorHandler
	OutputHandlerFactoryFn func() endpoint.OutputHandler
}

type GetHandler interface {
	Handle(
		w http.ResponseWriter, r *http.Request, i *services.GetInputer,
	) (any, error)
}

type UpdateConfig[Entity database.Mutator] struct {
	// Default config for the update input handler.
	DefaultInputHandlerConfig *DefaultUpdateInputHandlerConfig
	// Override for the update input handler.
	InputHandlerFactoryFn func() endpoint.InputHandler[services.UpdateInputer]

	// Default config for the update handler logic.
	DefaultHandlerLogicConfig *DefaultUpdateHandlerLogicConfig[Entity]
	// Override for the update handler logic.
	HandlerLogicFnFactoryFn func() endpoint.HandlerLogicFn[services.UpdateInputer]

	ErrorHandlerFactoryFn  func() endpoint.ErrorHandler
	OutputHandlerFactoryFn func() endpoint.OutputHandler
}

type UpdateHandler interface {
	Handle(
		w http.ResponseWriter, r *http.Request, i *services.UpdateInputer,
	) (any, error)
}