projections

type AuthData struct {
	TenantId string
	Scopes   []string
	Data     map[string]any
}

type Data map[string]any

type DataList struct {
	Limit int64
	Page  int64
	Total int64
	Data  []Data
}

type DeliveryClient interface {
	GetData(
		ctx context.Context,
		projection string,
		authData *AuthData,
		id string,
		filter *Filter,
		returnEmptyDataIfNotFound bool,
		wait *Wait,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*Data, error)
	GetViewData(
		ctx context.Context,
		view string,
		authData *AuthData,
		filter *Filter,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*Data, error)
	GetDataList(
		ctx context.Context,
		projection string,
		authData *AuthData,
		pagination *Pagination,
		filter *Filter,
		order []Order,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*DataList, error)
	GetViewDataList(
		ctx context.Context,
		view string,
		authData *AuthData,
		pagination *Pagination,
		filter *Filter,
		order []Order,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*DataList, error)
	UpsertData(
		ctx context.Context,
		projection string,
		authData *AuthData,
		id string,
		payload Data,
		eventMetadata *EventMetadata,
	) (*UpsertResponse, error)
	DeleteDataById(
		ctx context.Context,
		projection string,
		authData *AuthData,
		id string,
		eventMetadata *EventMetadata,
	) (int64, error)
	DeleteDataByFilter(
		ctx context.Context,
		projection string,
		authData *AuthData,
		filter *Filter,
		eventMetadata *EventMetadata,
	) (int64, error)
	Close() error
}

type DeploymentOptions struct {
	DangerouslyRemoveGdprFields bool
	Target                      managementpb.DeploymentTarget
	Force                       bool
}

type EnumType struct {
	Name   string
	Values []string
}

type EventMetadata struct {
	CorrelationId string
	CausationId   string
	UserId        string
	Target        deliverypb.DeploymentTarget
}

type FieldFilter struct {
	Operation string
	Type      string
	Value     any
}

type Filter struct {
	// all these field filters have to match
	Fields map[string]FieldFilter
	// these filters will be calculated using the and operator
	And []Filter
	// these filters will be calculated using the or operator
	Or []Filter
}

type ManagementClient interface {
	DeploySchema(
		ctx context.Context,
		deploymentId int64,
		namespace string,
		projectionTypes []ObjectType,
		crudTypes []ObjectType,
		nestedTypes []ObjectType,
		enums []EnumType,
		views []View,
		options *DeploymentOptions,
	) error
	ActivateSchema(ctx context.Context, deploymentId int64) error
	ConfirmSchema(ctx context.Context, deploymentId int64) error
	RollbackSchema(ctx context.Context, namespace string, target managementpb.DeploymentTarget) error
	RollbackSchemaByDeployment(ctx context.Context, deploymentId int64) error
	GetSchemaDeployment(ctx context.Context, deploymentId int64) (uint32, error)
	Close() error
}

type MockDeliveryClient struct {
	mock.Mock
}

type MockManagementClient struct {
	mock.Mock
}

type ObjectType struct {
	Name       string
	Directives []TypeDirective
	Fields     []TypeField
}

type Order struct {
	Field      string
	Descending bool
}

type Pagination struct {
	Limit int64
	Page  int64
}

type TypeArgument struct {
	Name  string
	Value any
}

type TypeDirective struct {
	Name      string
	Arguments []TypeArgument
}

type TypeField struct {
	Name       string
	Type       []string
	Directives []TypeDirective
}

type UpsertResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Data                  Data
	ID                    string
}

type View struct {
	Name       string
	Sql        string
	Directives []TypeDirective
	Fields     []TypeField
}

type Wait struct {
	ConditionFilter  *Filter
	ConditionTimeout time.Duration
}