client

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

type WorkflowCatalogClient interface {
	GetWorkflowByID(ctx context.Context, params ogenclient.GetWorkflowByIDParams) (ogenclient.GetWorkflowByIDRes, error)
}

type WorkflowCatalogMetadata struct {
	ExecutionEngine       string
	WorkflowName          string
	ExecutionBundle       string
	ExecutionBundleDigest string
	ServiceAccountName    string
	EngineConfig          json.RawMessage
	Dependencies          *models.WorkflowDependencies
}

type WorkflowQuerier interface {
	GetWorkflowDependencies(ctx context.Context, workflowID string) (*models.WorkflowDependencies, error)
	// GetWorkflowEngineConfig retrieves the engine_config for a workflow from the catalog.
	// DD-WORKFLOW-017: Execution details (engine, engineConfig) come from the workflow catalog entry.
	// Returns nil when the workflow has no engineConfig.
	GetWorkflowEngineConfig(ctx context.Context, workflowID string) (json.RawMessage, error)
	// GetWorkflowExecutionEngine retrieves the execution engine and workflow name
	// from the DS catalog. Issue #518: the WE controller resolves the engine at
	// runtime rather than reading it from the WFE spec.
	GetWorkflowExecutionEngine(ctx context.Context, workflowID string) (engine string, workflowName string, err error)
	// GetWorkflowExecutionBundle retrieves the execution bundle OCI reference and
	// its digest from the DS catalog. Defense-in-depth: the WE controller resolves
	// the bundle at runtime rather than blindly trusting the WFE spec value.
	GetWorkflowExecutionBundle(ctx context.Context, workflowID string) (bundle string, digest string, err error)
	// ResolveWorkflowCatalogMetadata fetches all workflow metadata (engine, bundle,
	// SA, engineConfig, dependencies) from DS in a single GetWorkflowByID call.
	// Issue #650: Replaces the 4 individual methods above.
	ResolveWorkflowCatalogMetadata(ctx context.Context, workflowID string) (*WorkflowCatalogMetadata, error)
}