authz

type CreateObjectTypeSpec struct {
	Type      string                  `json:"type"             validate:"required,valid_object_type"`
	Source    *Source                 `json:"source,omitempty"`
	Relations map[string]RelationRule `json:"relations"        validate:"required,dive"` // NOTE: map key = name of relation
}

type ForeignKeySpec struct {
	Column   string `json:"column"   validate:"required"`
	Relation string `json:"relation" validate:"required,valid_relation"`
	Type     string `json:"type"     validate:"required,valid_object_type"`
	Subject  string `json:"subject"  validate:"required"`
}

type ListObjectTypesSpecV1 []ObjectTypeSpec

type ListObjectTypesSpecV2 struct {
	Results    []ObjectTypeSpec `json:"results"`
	PrevCursor *service.Cursor  `json:"prevCursor,omitempty"`
	NextCursor *service.Cursor  `json:"nextCursor,omitempty"`
}

type Model interface {
	GetID() int64
	GetTypeId() string
	GetDefinition() string
	SetDefinition(string)
	GetCreatedAt() time.Time
	GetUpdatedAt() time.Time
	GetDeletedAt() *time.Time
	ToObjectTypeSpec() (*ObjectTypeSpec, error)
}

type MySQLRepository struct {
	database.SQLRepository
}

type ObjectType struct {
	ID         int64      `mysql:"id"         postgres:"id"         sqlite:"id"`
	TypeId     string     `mysql:"typeId"     postgres:"type_id"    sqlite:"typeId"`
	Definition string     `mysql:"definition" postgres:"definition" sqlite:"definition"`
	CreatedAt  time.Time  `mysql:"createdAt"  postgres:"created_at" sqlite:"createdAt"`
	UpdatedAt  time.Time  `mysql:"updatedAt"  postgres:"updated_at" sqlite:"updatedAt"`
	DeletedAt  *time.Time `mysql:"deletedAt"  postgres:"deleted_at" sqlite:"deletedAt"`
}

type ObjectTypeListParamParser struct{}

type ObjectTypeRepository interface {
	Create(ctx context.Context, objectType Model) (int64, error)
	GetById(ctx context.Context, id int64) (Model, error)
	GetByTypeId(ctx context.Context, typeId string) (Model, error)
	List(ctx context.Context, listParams service.ListParams) ([]Model, *service.Cursor, *service.Cursor, error)
	UpdateByTypeId(ctx context.Context, typeId string, objectType Model) error
	DeleteByTypeId(ctx context.Context, typeId string) error
}

type ObjectTypeService struct {
	service.BaseService
	// contains filtered or unexported fields
}

type ObjectTypeSpec struct {
	Type      string                  `json:"type"`
	Source    *Source                 `json:"source,omitempty"`
	Relations map[string]RelationRule `json:"relations"`
	CreatedAt time.Time               `json:"createdAt,omitempty"`
}

type PostgresRepository struct {
	database.SQLRepository
}

type RelationRule struct {
	InheritIf    string         `json:"inheritIf,omitempty"    validate:"required_with=Rules OfType WithRelation,valid_inheritif"`
	Rules        []RelationRule `json:"rules,omitempty"        validate:"required_if_oneof=InheritIf anyOf allOf noneOf,omitempty,min=1,dive"` // Required if InheritIf is "anyOf", "allOf", or "noneOf", empty otherwise
	OfType       string         `json:"ofType,omitempty"       validate:"required_with=WithRelation,valid_relation"`
	WithRelation string         `json:"withRelation,omitempty" validate:"required_with=OfType,valid_relation"`
}

type SQLiteRepository struct {
	database.SQLRepository
}

type Service interface {
	Create(ctx context.Context, spec CreateObjectTypeSpec) (*ObjectTypeSpec, *wookie.Token, error)
	GetByTypeId(ctx context.Context, typeId string) (*ObjectTypeSpec, error)
	List(ctx context.Context, listParams service.ListParams) ([]ObjectTypeSpec, *service.Cursor, *service.Cursor, error)
	UpdateByTypeId(ctx context.Context, typeId string, spec UpdateObjectTypeSpec) (*ObjectTypeSpec, *wookie.Token, error)
	DeleteByTypeId(ctx context.Context, typeId string) (*wookie.Token, error)
}

type Source struct {
	DatabaseType string           `json:"dbType"                validate:"required"`
	DatabaseName string           `json:"dbName"                validate:"required"`
	Table        string           `json:"table"                 validate:"required"`
	PrimaryKey   []string         `json:"primaryKey"            validate:"min=1"`
	ForeignKeys  []ForeignKeySpec `json:"foreignKeys,omitempty"`
}

type UpdateObjectTypeSpec struct {
	Type      string                  `json:"type"` // NOTE: used internally for updates, but value from request is ignored
	Source    *Source                 `json:"source,omitempty"`
	Relations map[string]RelationRule `json:"relations"        validate:"required,dive"` // NOTE: map key = name of relation
}