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,
		returnEmptyDataIfNotFound bool,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*Entry, error)
	GetEntryList(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		pagination *Pagination,
		filter *Filter,
		order []Order,
		useStrongConsistency bool,
		target deliverypb.DeploymentTarget,
	) (*EntryList, error)
	CreateEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		data Entry,
		eventMetadata *EventMetadata,
	) (*CreateResponse, error)
	UpdateEntry(
		ctx context.Context,
		typeName string,
		authData *AuthData,
		id string,
		data Entry,
		eventMetadata *EventMetadata,
	) (*UpdateResponse, 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 ManagementClient interface {
	DeploySchema(
		ctx context.Context,
		deploymentId int64,
		namespace string,
		projectionTypes []ObjectType,
		crudTypes []ObjectType,
		nestedTypes []ObjectType,
		enums []EnumType,
		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 UpdateResponse struct {
	ValidationErrors      []string
	FieldValidationErrors map[string]string
	Entry                 Entry
}

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