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,
		namespace string,
		projectionTypes []ObjectType,
		crudTypes []ObjectType,
		nestedTypes []ObjectType,
		enums []EnumType,
		views []View,
		options *DeploymentOptions,
	) error
	ConfirmSchema(ctx context.Context, deploymentId int64) error
	RollbackSchema(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
}