openapi

type AuthConfig struct {
	// Scheme: bearer | basic | api_key | oauth2_client_credentials | token_exchange
	Scheme string `mapstructure:"scheme" json:"scheme" yaml:"scheme"`

	// Bearer: a static or env-supplied token. Use TokenFromRequest for
	// per-request tokens forwarded from the incoming GraphJin request.
	Token            string            `mapstructure:"token" json:"token" yaml:"token"`
	TokenFromRequest *TokenFromRequest `mapstructure:"token_from_request" json:"token_from_request" yaml:"token_from_request"`

	// Basic auth.
	Username string `mapstructure:"username" json:"username" yaml:"username"`
	Password string `mapstructure:"password" json:"password" yaml:"password"`

	// API key (header or query).
	KeyName  string `mapstructure:"key_name" json:"key_name" yaml:"key_name"`
	KeyValue string `mapstructure:"key_value" json:"key_value" yaml:"key_value"`
	KeyIn    string `mapstructure:"key_in" json:"key_in" yaml:"key_in"` // "header" | "query"

	// OAuth2 client_credentials grant.
	TokenURL     string   `mapstructure:"token_url" json:"token_url" yaml:"token_url"`
	ClientID     string   `mapstructure:"client_id" json:"client_id" yaml:"client_id"`
	ClientSecret string   `mapstructure:"client_secret" json:"client_secret" yaml:"client_secret"`
	Scopes       []string `mapstructure:"scopes" json:"scopes" yaml:"scopes"`

	// token_exchange — generic "POST credentials → JSON with token" flow.
	// Covers Salesforce Marketing Cloud Personalization and similar
	// vendor-specific token endpoints that aren't standard OAuth2.
	Request  *TokenExchangeRequest  `mapstructure:"request" json:"request" yaml:"request"`
	Response *TokenExchangeResponse `mapstructure:"response" json:"response" yaml:"response"`

	// How the resolved token attaches to outgoing operation requests.
	AttachAs     string `mapstructure:"attach_as" json:"attach_as" yaml:"attach_as"`             // "header" | "query"
	AttachName   string `mapstructure:"attach_name" json:"attach_name" yaml:"attach_name"`       // e.g. "Authorization"
	AttachFormat string `mapstructure:"attach_format" json:"attach_format" yaml:"attach_format"` // e.g. "Bearer {token}"

	// CacheTTL overrides the token cache TTL when the auth response
	// doesn't include an expires_in field. Format: Go duration ("3500s").
	CacheTTL string `mapstructure:"cache_ttl" json:"cache_ttl" yaml:"cache_ttl"`
}

type AuthProvider interface {
	Apply(ctx context.Context, req *http.Request, hdrIn http.Header) error
	OnUnauthorized(ctx context.Context) error
}

type CallParams struct {
	PathValues      map[string]string
	QueryValues     map[string]string
	HeaderValues    map[string]string
	IncomingHeaders http.Header
}

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

type ConcurrencyConfig struct {
	MaxConcurrent   int `mapstructure:"max_concurrent" json:"max_concurrent" yaml:"max_concurrent"`
	RateLimitPerSec int `mapstructure:"rate_limit_per_second" json:"rate_limit_per_second" yaml:"rate_limit_per_second"`
}

type JoinConfig struct {
	ParentTable  string `mapstructure:"parent_table" json:"parent_table" yaml:"parent_table"`
	ParentColumn string `mapstructure:"parent_column" json:"parent_column" yaml:"parent_column"`
	Param        string `mapstructure:"param" json:"param" yaml:"param"`             // OpenAPI param name receiving the column value
	ExposeAs     string `mapstructure:"expose_as" json:"expose_as" yaml:"expose_as"` // GraphQL field name on the parent
}

type LoadResult struct {
	Registry *Registry
	Warnings []string
}

type LoaderOptions struct {
	SpecsDir string
}

type OpDescriptor struct {
	SpecKey      string // YAML filename without extension (e.g. "interaction_studio")
	OperationID  string // OpenAPI operationId (synthesised when the spec omits it)
	Method       string // always GET in the read-only first cut
	PathTemplate string // OpenAPI path template, e.g. "/users/{userId}"

	Mode       OpMode
	SkipReason string // populated only when Mode == OpModeSkipped

	// Parameters bucketed by location — populated for non-skipped operations.
	PathParams   []ParamSpec
	QueryParams  []ParamSpec
	HeaderParams []ParamSpec

	// ResultPath strips the response down to the actual payload (e.g. when
	// a list endpoint wraps results in {data: [...]}). Empty means "use
	// the response body as-is".
	ResultPath []string

	// IsArrayResponse signals list-shape responses to the GraphQL adapter
	// so it knows whether to expose a singular or plural field.
	IsArrayResponse bool

	// ExposeAs is the GraphQL field name. Defaulted to
	// <spec_key>_<operation_id_snake> by the loader; user config can override.
	ExposeAs string

	// Join carries the user-supplied parent-table mapping when the
	// operation is wired as a row join (Mode == OpModeRowJoin). Nil for
	// auto-exposed top-level operations.
	Join *JoinConfig

	// ResponseSchema points at the success-response body schema. Used
	// by the bridge to synthesise DBColumn entries for top-level virtual
	// tables so they are visible to GraphQL introspection.
	ResponseSchema *openapi3.SchemaRef

	// Defaults: fallback values for path/query params; caller args win.
	Defaults map[string]string
}

type OpMode int

type OperationOverride struct {
	ExposeAs       string `mapstructure:"expose_as" json:"expose_as" yaml:"expose_as"`
	ResultPath     string `mapstructure:"result_path" json:"result_path" yaml:"result_path"`
	Disabled       bool   `mapstructure:"disabled" json:"disabled" yaml:"disabled"`
	ExposeTopLevel bool   `mapstructure:"expose_top_level" json:"expose_top_level" yaml:"expose_top_level"`

	// Defaults supplies fallback values for path/query params; caller args win.
	Defaults map[string]string `mapstructure:"defaults" json:"defaults" yaml:"defaults"`
}

type ParamLocation string

type ParamSpec struct {
	Name     string
	In       ParamLocation
	Required bool
	Type     string // OpenAPI primitive type: string | integer | number | boolean
	Format   string // optional secondary type info (date-time, uuid, etc.)
}

type Registry struct {
	Specs []*Spec
	// contains filtered or unexported fields
}

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

type Spec struct {
	Key         string
	SourcePath  string
	Doc         *openapi3.T
	BaseURL     string
	Auth        AuthConfig
	Concurrency ConcurrencyConfig
	Operations  []OpDescriptor

	// SkippedCount is a precomputed tally for boot logging; the per-op
	// reasons live on individual OpDescriptors.
	SkippedCount int
}

type SpecConfig struct {
	// BaseURL overrides the spec's servers[0].url. Useful when the spec
	// hard-codes a sandbox/prod URL that doesn't match the deployment, or
	// when env-var interpolation is needed (e.g. https://${IS_ACCOUNT}...).
	BaseURL string `mapstructure:"base_url" json:"base_url" yaml:"base_url"`

	// Auth carries credentials and the auth flow shape. One AuthConfig per
	// spec — we don't currently support per-operation auth.
	Auth AuthConfig `mapstructure:"auth" json:"auth" yaml:"auth"`

	// Joins maps an operationId to a DB table/column. Without an entry, an
	// operation is still queryable as a top-level field; with an entry, it
	// also becomes a child field on the named DB table.
	Joins map[string]JoinConfig `mapstructure:"joins" json:"joins" yaml:"joins"`

	// Operations carries per-operation overrides that aren't joins (e.g.
	// renaming the auto-exposed top-level field, overriding result_path).
	// Optional; auto-classification provides sensible defaults.
	Operations map[string]OperationOverride `mapstructure:"operations" json:"operations" yaml:"operations"`

	// Concurrency bounds the goroutine fan-out and request rate per spec.
	// Without this, a 1000-row parent select would spawn 1000 parallel
	// HTTP calls to the upstream — a reliable way to get rate-limited.
	Concurrency ConcurrencyConfig `mapstructure:"concurrency" json:"concurrency" yaml:"concurrency"`
}

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

type TokenExchangeRequest struct {
	Method     string                 `mapstructure:"method" json:"method" yaml:"method"`                // default POST
	BodyFormat string                 `mapstructure:"body_format" json:"body_format" yaml:"body_format"` // "json" | "form"
	Body       map[string]interface{} `mapstructure:"body" json:"body" yaml:"body"`
	Headers    map[string]string      `mapstructure:"headers" json:"headers" yaml:"headers"`
}

type TokenExchangeResponse struct {
	TokenField   string `mapstructure:"token_field" json:"token_field" yaml:"token_field"`
	ExpiresField string `mapstructure:"expires_field" json:"expires_field" yaml:"expires_field"` // seconds
}

type TokenFromRequest struct {
	Header string `mapstructure:"header" json:"header" yaml:"header"`
	Query  string `mapstructure:"query" json:"query" yaml:"query"`
}