crud

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

type CloneResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Entry                 Entry
}

type CreateResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Entry                 Entry
}

type DeliveryClient interface {
	GetEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		filter *Filter,
		wait *Wait,
		options *GetSingleEntryOptions,
	) (*Entry, error)
	GetEntryList(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		pagination *Pagination,
		filter *Filter,
		order []Order,
		wait *ListWait,
		options *GetEntryOptions,
	) (*EntryList, error)
	GetViewEntry(
		ctx context.Context,
		view string,
		authData *AuthData,
		filter *Filter,
		wait *Wait,
		options *GetEntryOptions,
	) (*Entry, error)
	GetViewEntryList(
		ctx context.Context,
		view string,
		authData *AuthData,
		pagination *Pagination,
		filter *Filter,
		order []Order,
		wait *ListWait,
		options *GetEntryOptions,
	) (*EntryList, error)
	CreateEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		data Entry,
		eventMetadata *EventMetadata,
	) (*CreateResponse, error)
	UpsertEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		data Entry,
		eventMetadata *EventMetadata,
	) (*UpsertResponse, error)
	UpdateEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		data Entry,
		eventMetadata *EventMetadata,
	) (*UpdateResponse, error)
	UpdateEntryByFilter(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		filter *Filter,
		data Entry,
		eventMetadata *EventMetadata,
	) (*UpdateByFilterResponse, error)
	CloneEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		newId string,
		eventMetadata *EventMetadata,
	) (*CloneResponse, error)
	DeleteEntryById(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		eventMetadata *EventMetadata,
	) (int64, error)
	DeleteEntryByFilter(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		filter *Filter,
		eventMetadata *EventMetadata,
	) (int64, error)
	Close() error
}

type DeploymentOptions struct {
	Target managementpb.DeploymentTarget
	Force  bool
}

type Entry map[string]any

type EntryList struct {
	Limit   int64
	Page    int64
	Total   int64
	Entries []Entry
}

type EnumType struct {
	Name   string
	Values []string
}

type EventMetadata struct {
	CorrelationId string
	CausationId   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 GetEntryOptions struct {
	// contains filtered or unexported fields
}

type GetEntryOptionsBuilder struct {
	Target                   deliverypb.DeploymentTarget
	UseStrongConsistency     bool
	UseStrongConsistencyById string
}

type GetSingleEntryOptions struct {
	GetEntryOptions
	// contains filtered or unexported fields
}

type GetSingleEntryOptionsBuilder struct {
	GetEntryOptionsBuilder
	ReturnEmptyDataIfNotFound bool
}

type ListWait struct {
	Condition        []ListWaitCondition
	ConditionTimeout time.Duration
}

type ListWaitCondition struct {
	Operation string
	Value     int64
}

type ManagementClient interface {
	DeploySchema(
		ctx context.Context,
		deploymentId int64,
		namespace string,
		projectionTypes []ObjectType,
		crudTypes []ObjectType,
		nestedTypes []ObjectType,
		enums []EnumType,
		views []View,
		baseViews []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 UpdateByFilterDataValidationErrorResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
}

type UpdateByFilterResponse struct {
	NumberOfUpdatedEntries int64
	ValidationErrors       map[string]UpdateByFilterDataValidationErrorResponse
}

type UpdateResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Entry                 Entry
}

type UpsertResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Entry                 Entry
}

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

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