queries

type CreateExecutionParams struct {
	Slug   slug.Slug
	Status string
	Result json.RawMessage
}

type CreateParams struct {
	Slug                     slug.Slug
	Name                     string
	Description              *string
	DataSourceSlug           slug.Slug
	Data                     json.RawMessage
	ExpectedInputContract    json.RawMessage
	ExpectedInputContractRef json.RawMessage
	OutputContract           json.RawMessage
	OutputContractRef        json.RawMessage
	Parameters               []*QueryParameterParams
}

type OperationSnapshot struct {
	DataSourceType           model.DataSourceType
	Data                     json.RawMessage
	ExpectedInputContract    json.RawMessage
	ExpectedInputContractRef json.RawMessage
	OutputContract           json.RawMessage
	OutputContractRef        json.RawMessage
	Parameters               json.RawMessage
	UpdatedAt                time.Time
}

type Query struct {
	Slug                     slug.Slug
	Name                     string
	Description              *string
	Data                     json.RawMessage
	ExpectedInputContract    json.RawMessage
	ExpectedInputContractRef json.RawMessage
	OutputContract           json.RawMessage
	OutputContractRef        json.RawMessage
	DataSourceSlug           slug.Slug
	CreatedAt                time.Time
	UpdatedAt                time.Time
	DeletedAt                *time.Time
}

type QueryExecution struct {
	Slug         slug.Slug
	Status       string
	Result       json.RawMessage
	ErrorMessage *string
	DurationMs   *int32
	ExecutedAt   time.Time
}

type QueryExecutionIdentity struct {
	ExecutionSlug  slug.Slug
	DataSourceSlug slug.Slug
	QuerySlug      slug.Slug
	ExecutedAt     time.Time
}

type QueryParameter struct {
	Slug         slug.Slug
	Name         string
	DataType     string
	IsRequired   bool
	DefaultValue *string
	Description  *string
	CreatedAt    time.Time
}

type QueryParameterParams struct {
	Slug         slug.Slug
	Name         string
	DataType     string
	IsRequired   bool
	DefaultValue *string
	Description  *string
}

type Repository interface {
	FindSnapshot(context.Context, postgres.DBTX, slug.Slug, slug.Slug, slug.Slug) (*OperationSnapshot, error)
	// Create inserts a new query and returns it with its parameters.
	Create(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug slug.Slug,
		dsSlug slug.Slug,
		params *CreateParams,
	) (*Query, []*QueryParameter, error)

	// FindBySlug fetches a query by its slug within a data source with its parameters.
	FindBySlug(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug, querySlug slug.Slug,
	) (*Query, []*QueryParameter, error)

	// ListByDataSource lists all queries in a data source with pagination.
	ListByDataSource(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug slug.Slug,
		req model.ListRequest,
		includeDeleted bool,
	) ([]*Query, error)

	// Update updates an existing query by slug and replaces its parameters.
	Update(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug, querySlug slug.Slug,
		params *UpdateParams,
	) (*Query, []*QueryParameter, error)

	// Delete soft-deletes a query by slug.
	Delete(ctx context.Context, tx postgres.DBTX, orgSlug, dsSlug, querySlug slug.Slug) error

	// Restore clears the deletion tombstone for a query by slug.
	Restore(ctx context.Context, tx postgres.DBTX, orgSlug, dsSlug, querySlug slug.Slug) error

	// Purge permanently deletes a soft-deleted query by slug.
	Purge(ctx context.Context, tx postgres.DBTX, orgSlug, dsSlug, querySlug slug.Slug) error

	// CreateExecution records a query execution.
	CreateExecution(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug, querySlug slug.Slug,
		params *CreateExecutionParams,
	) (*QueryExecution, error)

	// ListExecutions lists query executions for a query with pagination.
	ListExecutions(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug, querySlug slug.Slug,
		req model.ListRequest,
	) ([]*QueryExecution, error)

	// GetExecution fetches a query execution by slug.
	GetExecution(
		ctx context.Context,
		tx postgres.DBTX,
		orgSlug, dsSlug, querySlug, executionSlug slug.Slug,
	) (*QueryExecution, error)

	// FindLatestSuccessfulExecution returns the latest recorded successful execution in an organization.
	FindLatestSuccessfulExecution(context.Context, postgres.DBTX, slug.Slug) (*QueryExecutionIdentity, error)
}

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

type UpdateParams struct {
	Name                     string
	Description              *string
	Data                     json.RawMessage
	ExpectedInputContract    json.RawMessage
	ExpectedInputContractRef json.RawMessage
	OutputContract           json.RawMessage
	OutputContractRef        json.RawMessage
	Parameters               []*QueryParameterParams
}