app

type App interface {
	Key() string
	SchemaBuilder() *schema.Builder
	DB() DBClient
	Resources() *ResourcesManager
	Reload(migration *Migration) (err error)
	Logger() Logger
	UpdateCache() error
	Roles() []*Role
	Disk(names ...string) Disk
	Disks() []Disk

	AddResource(resource *Resource)
	AddMiddlewares(hooks ...Middleware)
	Hooks() *Hooks
	OnPreResolve(hooks ...Middleware)
	OnPostResolve(hooks ...Middleware)
	OnPostDBGet(PostDBGetHook)
}

type Context interface {
	ID() string
	User() *User
	Value(string, ...any) (val any)
	Logger() Logger
	Parse(any) error
	Context() context.Context
	Args() map[string]string
	Arg(string, ...string) string
	ArgInt(string, ...int) int
	Entity() (*schema.Entity, error)
	Resource() *Resource
	AuthToken() string
	Next() error
	Result(...*Result) *Result
	Files() ([]*File, error)
}

type CountOption struct {
	Column string
	Unique bool
}

type DBClient interface {
	Dialect() string
	Exec(ctx context.Context, query string, args any, bindValue any) error
	Rollback() error
	Commit() error
	CreateDBModel(s *schema.Schema, rs ...*schema.Relation) Model
	Tx(ctx context.Context) (DBClient, error)
	IsTx() bool
	Model(name string) (Model, error)
	Close() error
	SchemaBuilder() *schema.Builder
	Reload(newSchemaBuilder *schema.Builder, migration *Migration) (DBClient, error)
	DB() *sql.DB
	Config() *DBConfig
	Hooks() *Hooks
}

type DBConfig struct {
	Driver          string
	Name            string
	Host            string
	Port            string
	User            string
	Pass            string
	Logger          Logger
	LogQueries      bool
	MigrationDir    string
	IgnoreMigration bool
	Hooks           func() *Hooks
}

type Disk interface {
	Name() string
	Root() string
	URL(filepath string) string
	Delete(c context.Context, filepath string) error
	Put(c context.Context, file *File) (*File, error)
	PutReader(c context.Context, in io.Reader, size uint64, mime, dst string) (*File, error)
	PutMultipart(c context.Context, m *multipart.FileHeader, dsts ...string) (*File, error)
	LocalPublicPath() string
}

type DiskConfig struct {
	Name            string        `json:"name"`
	Driver          string        `json:"driver"`
	Root            string        `json:"root"`
	BaseURL         string        `json:"base_url"`
	PublicPath      string        `json:"public_path"`
	GetBaseURL      func() string `json:"-"`
	Provider        string        `json:"provider"`
	Endpoint        string        `json:"endpoint"`
	Region          string        `json:"region"`
	Bucket          string        `json:"bucket"`
	AccessKeyID     string        `json:"access_key_id"`
	SecretAccessKey string        `json:"secret_access_key"`
	ACL             string        `json:"acl"`
}

type File struct {
	ID        uint64     `json:"id,omitempty"`
	Disk      string     `json:"disk,omitempty"`
	Name      string     `json:"name,omitempty"`
	Path      string     `json:"path,omitempty"`
	Type      string     `json:"type,omitempty"`
	Size      uint64     `json:"size,omitempty"`
	UserID    uint64     `json:"user_id,omitempty"`
	User      *User      `json:"user,omitempty"`
	URL       string     `json:"url,omitempty"`
	CreatedAt *time.Time `json:"created_at,omitempty"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
	DeletedAt *time.Time `json:"deleted_at,omitempty"`
	Reader    io.Reader  `json:"-"`
}

type Hooks struct {
	PreResolve  []ResolveHook
	PostResolve []ResolveHook
	PostDBGet   []PostDBGetHook
}

type LogContext Map

type Logger interface {
	Info(...any)
	Infof(string, ...any)
	Error(...any)
	Errorf(string, ...any)
	Debug(...any)
	Fatal(...any)
	Warn(...any)
	Panic(...any)
	DPanic(...any)
	WithContext(context LogContext, callerSkips ...int) Logger
}

type Map map[string]any

type Meta Map

type Middleware func(c Context) error

type Migration struct {
	Dir          string
	RenameTables []*RenameItem
	RenameFields []*RenameItem
}

type MockLogger struct {
	Silence  bool
	Messages []*MockLoggerMessage
}

type MockLoggerMessage struct {
	Type   string `json:"type"`
	Params []any  `json:"params"`
}

type Model interface {
	Query(predicates ...*Predicate) Query
	Mutation(skipTxs ...bool) Mutation
	Schema() *schema.Schema
	CreateFromJSON(json string) (id uint64, err error)
	Create(e *schema.Entity) (id uint64, err error)
	SetClient(client DBClient) Model
	Clone() Model
}

type Mutation interface {
	Where(predicates ...*Predicate) Mutation
	GetRelationEntityIDs(fieldName string, fieldValue any) ([]driver.Value, error)
	Create(e *schema.Entity) (id uint64, err error)
	Update(e *schema.Entity) (affected int, err error)
	Delete() (affected int, err error)
}

type NotFoundError struct {
	Message string
}

type OperatorType int

type Pagination struct {
	Pagination *PaginationInfo `json:"pagination"`
	Data       any             `json:"data"`
}

type PaginationInfo struct {
	Total       uint `json:"total"`
	PerPage     uint `json:"per_page"`
	CurrentPage uint `json:"current_page"`
	LastPage    uint `json:"last_page"`
}

type Permission struct {
	ID       int    `json:"id,omitempty"`
	RoleID   int    `json:"role_id,omitempty"`
	Resource string `json:"resource,omitempty"`
	Value    string `json:"value,omitempty"`
	Role     *Role  `json:"role,omitempty"`

	CreatedAt *time.Time `json:"created_at,omitempty"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
	DeletedAt *time.Time `json:"Deleted_at,omitempty"`
}

type PermissionType uint

type PostDBGetHook = func(query *QueryOption, entities []*schema.Entity) ([]*schema.Entity, error)

type Predicate struct {
	Field              string
	Operator           OperatorType
	Value              any
	RelationFieldNames []string
	And                []*Predicate
	Or                 []*Predicate
}

type Query interface {
	Where(predicates ...*Predicate) Query
	Limit(limit uint) Query
	Offset(offset uint) Query
	Select(columns ...string) Query
	Order(order ...string) Query
	Count(options *CountOption, ctxs ...context.Context) (int, error)
	Get(ctxs ...context.Context) ([]*schema.Entity, error)
	First(ctxs ...context.Context) (*schema.Entity, error)
	Only(ctxs ...context.Context) (*schema.Entity, error)
	Options() *QueryOption
}

type QueryOption struct {
	Limit      uint         `json:"limit"`
	Offset     uint         `json:"offset"`
	Columns    []string     `json:"columns"`
	Order      []string     `json:"order"`
	Predicates []*Predicate `json:"predicates"`
	Model      Model        `json:"-"`
}

type RenameItem struct {
	Type            string `json:"type"` // "column" or "table"
	From            string `json:"from"`
	To              string `json:"to"`
	IsJunctionTable bool   `json:"is_junction_table,omitempty"` // use in rename table: If the table is a junction table
	SchemaName      string `json:"schema,omitempty"`            // use in rename column: The schema name of the column
	SchemaNamespace string `json:"schema_namespace,omitempty"`  // use in rename column: The schema name of the column
}

type ResolveHook = Middleware

type Resolver func(c Context) (any, error)

type ResolverGenerator[Input, Output any] func(c Context, input *Input) (Output, error)

type Resource struct {
	// contains filtered or unexported fields
}

type ResourcesManager struct {
	*Resource
	Middlewares []Middleware
	Hooks       func() *Hooks
}

type Result struct {
	Error *errors.Error `json:"error,omitempty"`
	Data  any           `json:"data,omitempty"`
}

type Role struct {
	ID          uint64        `json:"id,omitempty"`
	Name        string        `json:"name,omitempty"`
	Description string        `json:"description,omitempty"`
	Root        bool          `json:"root,omitempty"`
	Users       []*User       `json:"users,omitempty"`
	Permissions []*Permission `json:"permissions,omitempty"`

	CreatedAt *time.Time `json:"created_at,omitempty"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
	DeletedAt *time.Time `json:"deleted_at,omitempty"`
}

type Signature = [2]any

type StaticFs struct {
	Root       http.FileSystem
	BasePath   string
	PathPrefix string
}

type StorageConfig struct {
	DefaultDisk string        `json:"default_disk"`
	DisksConfig []*DiskConfig `json:"disks"`
}

type User struct {
	ID       uint64 `json:"id,omitempty"`
	Username string `json:"username,omitempty"`
	Email    string `json:"email,omitempty"`
	Password string `json:"password,omitempty"`

	Provider         string `json:"provider,omitempty"`
	ProviderID       string `json:"provider_id,omitempty"`
	ProviderUsername string `json:"provider_username,omitempty"`

	RoleIDs []uint64 `json:"role_ids,omitempty"`
	Roles   []*Role  `json:"roles,omitempty"`
	Active  bool     `json:"active,omitempty"`

	CreatedAt *time.Time `json:"created_at,omitempty"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
	DeletedAt *time.Time `json:"deleted_at,omitempty"`
}

type UserJwtClaims struct {
	jwt.RegisteredClaims
	User *User `json:"user"`
}