engine

type AuthConfig struct {
	Provider string `json:"provider"`
	TokenURL string `json:"token_url"`
	ClientID string `json:"client_id"`
	Secret   string `json:"client_secret"`
	Scope    string `json:"scope"`
}

type DynamoGetter interface {
	GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
}

type Engine interface {
	// Init inicializa o motor com a configuração fornecida.
	// Retorna um Executor pronto para processar requisições ou erro.
	Init(cfg *config.ServiceConfig) (Executor, error)
}

type EnrichmentConfig struct {
	Strategy string             `json:"strategy"`
	Sources  []EnrichmentSource `json:"sources"`
}

type EnrichmentSource struct {
	Name    string                 `json:"name"`
	Type    string                 `json:"type"`
	Params  map[string]interface{} `json:"params"`
	Headers map[string]string      `json:"headers"`
}

type Executor interface {
	// Execute processa uma única requisição seguindo o roteiro do serviço.
	// Recebe o payload bruto (bytes) e retorna a resposta processada (bytes) ou erro.
	Execute(ctx context.Context, payload []byte) (int, []byte, map[string]string, error)

	// Shutdown realiza o encerramento gracioso de recursos (fechar conexões, flush de logs).
	Shutdown(ctx context.Context) error
}

type Loader interface {
	// Load lê a configuração a partir de uma origem e retorna a struct validada.
	Load(ctx context.Context, source string) (*config.ServiceConfig, error)
}

type RateLimitConfig struct {
	RPS   int `json:"rps"`
	Burst int `json:"burst"`
}

type S3Downloader interface {
	GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
}

type ServiceEngine struct {
	ConfigSource    string
	Config          *config.ServiceConfig
	Logger          zerolog.Logger
	Metrics         metrics.Provider
	MetricProcessor *metrics.Processor
	RuleManager     *rules.RuleManager
	Responder       *responder.ResponseBuilder
	GraphQLEngine   *graphql.GraphQLEngine
	AuthManagers    map[string]*auth.Manager
	// contains filtered or unexported fields
}

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

type ValidationReport struct {
	Valid    bool     `json:"valid"`
	Errors   []string `json:"errors,omitempty"`
	Warnings []string `json:"warnings,omitempty"`
}