types

type AWSDataInfo struct {
	Bucket         string    `db:"bucket"`
	Cid            string    `db:"cid"`
	Replicas       int       `db:"replicas"`
	IsDistribute   bool      `db:"is_distribute"`
	DistributeTime time.Time `db:"distribute_time"`
	Size           float64   `db:"size"`
}

type AWSDownloadSources struct {
	Bucket string
	Key    string
}

type AccessPointRsp struct {
	Schedulers []string
	GeoInfo    *region.GeoInfo
}

type ActivationDetail struct {
	NodeID        string   `json:"node_id" db:"node_id"`
	AreaID        string   `json:"area_id" `
	ActivationKey string   `json:"activation_key" db:"activation_key"`
	NodeType      NodeType `json:"node_type" db:"node_type"`
	IP            string   `json:"ip" db:"ip"`
}

type AppType int

type Arguments []string

type AssetGroup struct {
	ID          int       `db:"id"`
	UserID      string    `db:"user_id"`
	Name        string    `db:"name"`
	Parent      int       `db:"parent"`
	AssetCount  int       `db:"asset_count"`
	AssetSize   int64     `db:"asset_size"`
	CreatedTime time.Time `db:"created_time"`
}

type AssetHash string

type AssetOverview struct {
	AssetRecord      *AssetRecord
	UserAssetDetail  *UserAssetDetail
	VisitCount       int
	RemainVisitCount int
}

type AssetPullProgress struct {
	CID             string
	Status          ReplicaStatus
	Msg             string
	BlocksCount     int
	DoneBlocksCount int
	Size            int64
	DoneSize        int64
}

type AssetPullRequest struct {
	AssetCID   string
	Dss        *DownloadSources
	WorkloadID string
}

type AssetRecord struct {
	CID                   string          `db:"cid"`
	Hash                  string          `db:"hash"`
	NeedEdgeReplica       int64           `db:"edge_replicas"`
	TotalSize             int64           `db:"total_size"`
	TotalBlocks           int64           `db:"total_blocks"`
	Expiration            time.Time       `db:"expiration"`
	CreatedTime           time.Time       `db:"created_time"`
	EndTime               time.Time       `db:"end_time"`
	NeedCandidateReplicas int64           `db:"candidate_replicas"`
	ServerID              dtypes.ServerID `db:"scheduler_sid"`
	State                 string          `db:"state"`
	NeedBandwidth         int64           `db:"bandwidth"` // unit:MiB/
	Note                  string          `db:"note"`
	Source                int64           `db:"source"`

	RetryCount        int64 `db:"retry_count"`
	ReplenishReplicas int64 `db:"replenish_replicas"`
	ReplicaInfos      []*ReplicaInfo

	SPCount int64
}

type AssetSource int64

type AssetSourceDownloadInfoRsp struct {
	WorkloadID string

	// download from aws
	AWSBucket string
	// download from aws
	AWSKey string

	SchedulerURL string

	SourceList []*SourceDownloadInfo
}

type AssetStateInfo struct {
	State             string `db:"state"`
	RetryCount        int64  `db:"retry_count"`
	Hash              string `db:"hash"`
	ReplenishReplicas int64  `db:"replenish_replicas"`
}

type AssetStatistics struct {
	ReplicaCount      int
	UserDownloadCount int
}

type AssetStats struct {
	TotalAssetCount     int
	TotalBlockCount     int
	WaitCacheAssetCount int
	InProgressAssetCID  string
	DiskUsage           float64
}

type AssetStatus struct {
	IsExist           bool
	IsExpiration      bool
	IsVisitOutOfLimit bool
}

type AssetType int

type AssetView struct {
	TopHash string
	// key bucketID, value bucketHash
	BucketHashes map[uint32]string
}

type AuthUserDeployment struct {
	UserID       string
	DeploymentID string
	Expiration   time.Time
}

type AuthUserUploadDownloadAsset struct {
	UserID     string
	AssetCID   string
	AssetSize  int64
	Expiration time.Time
}

type CPUCores struct {
	MaxCPUCores float64
	Available   float64
	Active      float64
	Pending     float64
}

type CandidateCodeInfo struct {
	Code       string    `db:"code"`
	NodeType   NodeType  `db:"node_type"`
	Expiration time.Time `db:"expiration"`
	NodeID     string    `db:"node_id"`
	IsTest     bool      `db:"is_test"`
}

type CandidateDownloadInfo struct {
	NodeID  string
	Address string
	Tk      *Token
	// download from aws
	AWSBucket string
	// download from aws
	AWSKey string
}

type Certificate struct {
	Hostname    string
	PrivateKey  []byte
	Certificate []byte
}

type ComputeResources struct {
	CPU     float64  `db:"cpu"`
	GPU     float64  `db:"gpu"`
	Memory  int64    `db:"memory"`
	Storage Storages `db:"storage"`
}

type ConnectOptions struct {
	Token         string
	TcpServerPort int
	// private minio storage only, not public storage
	IsPrivateMinioOnly bool
	ExternalURL        string

	GeoInfo *region.GeoInfo
}

type CreateAssetReq struct {
	UserID        string
	AssetCID      string
	AssetSize     int64
	NodeID        string
	ReplicaCount  int64
	ExpirationDay int
}

type CreateSyncAssetReq struct {
	AssetCID      string
	AssetSize     int64
	ReplicaCount  int64
	ExpirationDay int

	DownloadInfo *SourceDownloadInfo
}

type CreateTunnelReq struct {
	NodeID    string
	ProjectID string
	WsURL     string
	TunnelID  string
}

type DeployProjectReq struct {
	UUID       string
	Name       string
	BundleURL  string
	UserID     string
	Replicas   int64
	Expiration time.Time

	CPUCores int64
	Memory   float64
	AreaID   string
	NodeIDs  []string
}

type Deployment struct {
	ID        DeploymentID    `db:"id"`
	Name      string          `db:"name"`
	Owner     string          `db:"owner"`
	State     DeploymentState `db:"state"`
	Version   string          `db:"version"`
	Authority bool            `db:"authority"`
	Services  []*Service

	// Internal
	Type             DeploymentType `db:"type"`
	Balance          float64        `db:"balance"`
	Cost             float64        `db:"cost"`
	ProviderID       string         `db:"provider_id"`
	Expiration       time.Time      `db:"expiration"`
	CreatedAt        time.Time      `db:"created_at"`
	UpdatedAt        time.Time      `db:"updated_at"`
	ProviderExposeIP string         `db:"provider_expose_ip"`
}

type DeploymentDomain struct {
	ID           int       `db:"id"`
	Name         string    `db:"name"`
	State        string    `db:"state"`
	DeploymentID string    `db:"deployment_id"`
	ProviderID   string    `db:"provider_id"`
	CreatedAt    time.Time `db:"created_at"`
	UpdatedAt    time.Time `db:"updated_at"`
}

type DeploymentID string

type DeploymentState int

type DeploymentType int

type DownloadHistory struct {
	ID           string    `json:"-"`
	NodeID       string    `json:"node_id" db:"node_id"`
	BlockCID     string    `json:"block_cid" db:"block_cid"`
	AssetCID     string    `json:"asset_cid" db:"asset_cid"`
	BlockSize    int       `json:"block_size" db:"block_size"`
	Speed        int64     `json:"speed" db:"speed"`
	Reward       int64     `json:"reward" db:"reward"`
	Status       int       `json:"status" db:"status"`
	FailedReason string    `json:"failed_reason" db:"failed_reason"`
	ClientIP     string    `json:"client_ip" db:"client_ip"`
	CreatedTime  time.Time `json:"created_time" db:"created_time"`
	CompleteTime time.Time `json:"complete_time" db:"complete_time"`
}

type DownloadSources struct {
	Nodes []*SourceDownloadInfo
	AWS   *AWSDownloadSources
}

type EdgeDownloadInfo struct {
	Address string
	Tk      *Token
	NodeID  string
	NatType string
}

type EdgeDownloadInfoList struct {
	Infos        []*EdgeDownloadInfo
	SchedulerURL string
	SchedulerKey string
}

type Env map[string]string

type Event string

type EventTopics string

type ExecResult struct {
	Code int
}

type ExitProfitRsp struct {
	CurrentPoint   float64
	RemainingPoint float64
	PenaltyRate    float64
}

type FreeUpDiskResp struct {
	Hashes   []string
	NextTime int64
}

type FreeUpDiskState struct {
	Hash   string
	ErrMsg string
}

type FreeUpDiskStateResp struct {
	Hashes   []*FreeUpDiskState
	NextTime int64
}

type GeneratedCarInfo struct {
	DataCid   string
	PieceCid  string
	PieceSize uint64
	Path      string
}

type GetDeploymentListResp struct {
	Deployments []*Deployment
	Total       int64
}

type GetDeploymentOption struct {
	Owner        string
	DeploymentID DeploymentID
	ProviderID   string
	State        []DeploymentState
	Page         int
	Size         int
}

type GetProviderOption struct {
	Owner string
	ID    string
	State []ProviderState
	Page  int
	Size  int
}

type InProgressAsset struct {
	CID       string
	TotalSize int64
	DoneSize  int64
}

type Ingress struct {
	Annotations map[string]string
}

type JWTPayload struct {
	// role base access controller permission
	Allow []auth.Permission
	ID    string
	// TODO remove NodeID later, any role id replace as ID
	NodeID string
	// Extend is json string
	Extend string
	// The sub permission of user
	AccessControlList []UserAccessControl
}

type LeaseEndpoint struct {
	Scheme    string
	Host      string
	ShellPath string
	Token     string
}

type ListAssetGroupRsp struct {
	Total       int           `json:"total"`
	AssetGroups []*AssetGroup `json:"infos"`
}

type ListAssetRecordRsp struct {
	Total          int              `json:"total"`
	AssetOverviews []*AssetOverview `json:"asset_infos"`
}

type ListAssetSummaryRsp struct {
	Total int                 `json:"total"`
	List  []*UserAssetSummary `json:"list"`
}

type ListDownloadRecordRsp struct {
	Data  []DownloadHistory `json:"data"`
	Total int64             `json:"total"`
}

type ListNodeAssetRsp struct {
	Total          int              `json:"total"`
	NodeAssetInfos []*NodeAssetInfo `json:"asset_infos"`
}

type ListNodeProfitDetailsRsp struct {
	Total int              `json:"total"`
	Infos []*ProfitDetails `json:"infos"`
}

type ListNodeReplicaRsp struct {
	Total            int                `json:"total"`
	NodeReplicaInfos []*NodeReplicaInfo `json:"infos"`
}

type ListNodesRsp struct {
	Data  []NodeInfo `json:"data"`
	Total int64      `json:"total"`
}

type ListReplicaEventRsp struct {
	Total         int                 `json:"total"`
	ReplicaEvents []*ReplicaEventInfo `json:"replica_events"`
}

type ListReplicaRsp struct {
	Total        int            `json:"total"`
	ReplicaInfos []*ReplicaInfo `json:"replica_infos"`
}

type ListRetrieveEventRsp struct {
	Total              int              `json:"total"`
	RetrieveEventInfos []*RetrieveEvent `json:"retrieve_event_infos"`
}

type ListStorageStatsRsp struct {
	Total    int             `json:"total"`
	Storages []*StorageStats `json:"infos"`
}

type ListValidationResultRsp struct {
	Total                 int                    `json:"total"`
	ValidationResultInfos []ValidationResultInfo `json:"validation_result_infos"`
}

type ListWorkloadRecordRsp struct {
	Total               int               `json:"total"`
	WorkloadRecordInfos []*WorkloadRecord `json:"workload_result_infos"`
}

type Log string

type Memory struct {
	MaxMemory uint64
	Available uint64
	Active    uint64
	Pending   uint64
}

type MinioConfig struct {
	Endpoint        string
	AccessKeyID     string
	SecretAccessKey string
}

type MinioUploadFileEvent struct {
	AssetCID   string
	Size       int64
	CreateTime time.Time
	Expiration time.Time
}

type NatPunchReq struct {
	Tk      *Token
	NodeID  string
	Timeout time.Duration
}

type NatType int

type NodeActivation struct {
	NodeID         string
	ActivationCode string
}

type NodeAssetInfo struct {
	Hash       string    `db:"hash"`
	Cid        string    `db:"cid"`
	TotalSize  int64     `db:"total_size"`
	Expiration time.Time `db:"expiration"`
	EndTime    time.Time `db:"end_time"`
}

type NodeClientType int

type NodeDynamicInfo struct {
	NodeID             string    `json:"node_id" form:"nodeId" gorm:"column:node_id;comment:;" db:"node_id"`
	OnlineDuration     int       `db:"online_duration"`  // unit:Minute
	OfflineDuration    int       `db:"offline_duration"` // unit:Minute
	DiskUsage          float64   `json:"disk_usage" form:"diskUsage" gorm:"column:disk_usage;comment:;" db:"disk_usage"`
	LastSeen           time.Time `db:"last_seen"`
	Profit             float64   `db:"profit"`
	PenaltyProfit      float64   `db:"penalty_profit"`
	TitanDiskUsage     float64   `db:"titan_disk_usage"`
	AvailableDiskSpace float64   `json:"available_disk_space" form:"availableDiskSpace" gorm:"column:available_disk_space;comment:;" db:"available_disk_space"`
	BandwidthUp        int64     `json:"bandwidth_up" db:"bandwidth_up"`
	BandwidthDown      int64     `json:"bandwidth_down" db:"bandwidth_down"`
	DownloadTraffic    int64     `db:"download_traffic"`
	UploadTraffic      int64     `db:"upload_traffic"`
}

type NodeIPInfo struct {
	NodeID      string
	IP          string
	ExternalURL string
}

type NodeInfo struct {
	IsTestNode      bool
	Type            NodeType
	ExternalIP      string
	InternalIP      string
	CPUUsage        float64
	MemoryUsage     float64
	Status          NodeStatus
	NATType         string
	ClientType      NodeClientType
	BackProjectTime int64
	RemoteAddr      string
	Level           int
	IncomeIncr      float64 // Base points increase every half hour (30 minute)
	AreaID          string
	Mx              float64
	AssetCount      int64 `db:"asset_count"`
	RetrieveCount   int64 `db:"retrieve_count"`

	FirstTime      time.Time       `db:"first_login_time"`
	NetFlowUp      int64           `json:"netflow_up" db:"netflow_up" gorm:"column:netflow_up;"`
	NetFlowDown    int64           `json:"netflow_down" db:"netflow_down" gorm:"column:netflow_down;"`
	DiskSpace      float64         `json:"disk_space" form:"diskSpace" gorm:"column:disk_space;comment:;" db:"disk_space"`
	SystemVersion  string          `json:"system_version" form:"systemVersion" gorm:"column:system_version;comment:;" db:"system_version"`
	DiskType       string          `json:"disk_type" form:"diskType" gorm:"column:disk_type;comment:;" db:"disk_type"`
	IoSystem       string          `json:"io_system" form:"ioSystem" gorm:"column:io_system;comment:;" db:"io_system"`
	NodeName       string          `json:"node_name" form:"nodeName" gorm:"column:node_name;comment:;" db:"node_name"`
	Memory         float64         `json:"memory" form:"memory" gorm:"column:memory;comment:;" db:"memory"`
	CPUCores       int             `json:"cpu_cores" form:"cpuCores" gorm:"column:cpu_cores;comment:;" db:"cpu_cores"`
	MacLocation    string          `json:"mac_location" form:"macLocation" gorm:"column:mac_location;comment:;" db:"mac_location"`
	PortMapping    string          `db:"port_mapping"`
	SchedulerID    dtypes.ServerID `db:"scheduler_sid"`
	DeactivateTime int64           `db:"deactivate_time"`
	CPUInfo        string          `json:"cpu_info" form:"cpuInfo" gorm:"column:cpu_info;comment:;" db:"cpu_info"`
	GPUInfo        string          `json:"gpu_info" form:"gpuInfo" gorm:"column:gpu_info;comment:;" db:"gpu_info"`
	FreeUpFiskTime time.Time       `db:"free_up_disk_time"`
	WSServerID     string          `db:"ws_server_id"`

	NodeDynamicInfo
}

type NodeReplicaInfo struct {
	Hash      string        `db:"hash"`
	Cid       string        `db:"cid"`
	TotalSize int64         `db:"total_size"`
	Status    ReplicaStatus `db:"status"`
	DoneSize  int64         `db:"done_size"`
	StartTime time.Time     `db:"start_time"`
	EndTime   time.Time     `db:"end_time"`
}

type NodeReplicaRsp struct {
	Replica    []*NodeReplicaStatus
	TotalCount int
}

type NodeReplicaStatus struct {
	Hash   string        `db:"hash"`
	Status ReplicaStatus `db:"status"`
}

type NodeStatus int

type NodeType int

type NodeUploadInfo struct {
	UploadURL string
	Token     string
	NodeID    string
}

type NodeWorkloadReport struct {
	// CipherText encrypted []*WorkloadReport by scheduler public key
	CipherText []byte
	// Sign signs CipherText by node private key
	Sign []byte
}

type OSType string

type OpenRPCDocument map[string]interface{}

type Port struct {
	Protocol   Protocol `db:"protocol"`
	Port       int      `db:"port"`
	ExposePort int      `db:"expose_port"`
}

type Ports []Port

type ProfitDetails struct {
	ID          int64      `db:"id"`
	NodeID      string     `db:"node_id"`
	Profit      float64    `db:"profit"`
	CreatedTime time.Time  `db:"created_time"`
	PType       ProfitType `db:"profit_type"`
	Size        int64      `db:"size"`
	Note        string     `db:"note"`
	CID         string     `db:"cid"`
	Rate        float64    `db:"rate"`
	Penalty     float64
}

type ProfitType int

type Project struct {
	ID        string // Id
	Name      string
	Status    ProjectReplicaStatus
	BundleURL string
	Port      int

	Msg string
}

type ProjectEvent int

type ProjectInfo struct {
	// uuid
	UUID        string          `db:"id"`
	State       string          `db:"state"`
	Name        string          `db:"name"`
	BundleURL   string          `db:"bundle_url"`
	Replicas    int64           `db:"replicas"`
	ServerID    dtypes.ServerID `db:"scheduler_sid"`
	Expiration  time.Time       `db:"expiration"`
	CreatedTime time.Time       `db:"created_time"`
	UserID      string          `db:"user_id"`

	CPUCores int64   `db:"cpu_cores"`
	Memory   float64 `db:"memory"`
	AreaID   string  `db:"area_id"`

	DetailsList       []*ProjectReplicas
	RetryCount        int64 `db:"retry_count"`
	ReplenishReplicas int64 `db:"replenish_replicas"`
}

type ProjectRecordReq struct {
	NodeID            string
	ProjectID         string
	BandwidthUpSize   float64
	BandwidthDownSize float64
	StartTime         time.Time
	EndTime           time.Time
}

type ProjectReplicaStatus int

type ProjectReplicas struct {
	Id          string               `db:"id"`
	Status      ProjectReplicaStatus `db:"status"`
	NodeID      string               `db:"node_id"`
	CreatedTime time.Time            `db:"created_time"`
	EndTime     time.Time            `db:"end_time"`

	WsURL     string
	BundleURL string
	IP        string
	GeoID     string
}

type ProjectReq struct {
	UUID   string
	NodeID string
	UserID string

	Name      string
	BundleURL string
	Replicas  int64
}

type ProjectStateInfo struct {
	ID                string `db:"id"`
	State             string `db:"state"`
	RetryCount        int64  `db:"retry_count"`
	ReplenishReplicas int64  `db:"replenish_replicas"`
}

type Properties struct {
	ProviderID string  `db:"provider_id"`
	AppID      string  `db:"app_id"`
	AppType    AppType `db:"app_type"`

	// internal
	ID        int       `db:"id"`
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
}

type Protocol string

type Provider struct {
	ID         string        `db:"id"`
	Owner      string        `db:"owner"`
	RemoteAddr string        `db:"remote_addr"`
	IP         string        `db:"ip"`
	State      ProviderState `db:"state"`
	Scheme     string        `db:"-"`
	CreatedAt  time.Time     `db:"created_at"`
	UpdatedAt  time.Time     `db:"updated_at"`
}

type ProviderState int

type PullAssetReq struct {
	CID        string
	Replicas   int64
	Expiration time.Time

	Bucket    string
	Hash      string
	Bandwidth int64 // unit:MiB/s

	SeedNodeID        string
	CandidateReplicas int64

	CandidateNodeList []string
	EdgeNodeList      []string
}

type PullResult struct {
	Progresses       []*AssetPullProgress
	DiskUsage        float64
	TotalBlocksCount int
	AssetCount       int
}

type RateLimiter struct {
	BandwidthUpLimiter   *rate.Limiter
	BandwidthDownLimiter *rate.Limiter
}

type RemoveAssetResult struct {
	BlocksCount int
	DiskUsage   float64
}

type ReplicaEvent int

type ReplicaEventInfo struct {
	NodeID  string       `db:"node_id"`
	Event   ReplicaEvent `db:"event"`
	Hash    string       `db:"hash"`
	EndTime time.Time    `db:"end_time"`
	Source  int64        `db:"source"`

	Cid        string    `db:"cid"`
	TotalSize  int64     `db:"total_size"`
	Expiration time.Time `db:"expiration"`
}

type ReplicaInfo struct {
	Hash        string        `db:"hash"`
	NodeID      string        `db:"node_id"`
	Status      ReplicaStatus `db:"status"`
	IsCandidate bool          `db:"is_candidate"`
	EndTime     time.Time     `db:"end_time"`
	DoneSize    int64         `db:"done_size"`
	StartTime   time.Time     `db:"start_time"`
}

type ReplicaStatus int

type ReplicasStatus struct {
	TotalReplicas     int
	ReadyReplicas     int
	AvailableReplicas int
}

type ResourcesStatistics struct {
	Memory   Memory
	CPUCores CPUCores
	Storage  StorageStat
}

type RetrieveEvent struct {
	TokenID     string  `db:"token_id"`
	NodeID      string  `db:"node_id"`
	ClientID    string  `db:"client_id"`
	CID         string  `db:"cid"`
	Size        int64   `db:"size"`
	CreatedTime int64   `db:"created_time"`
	EndTime     int64   `db:"end_time"`
	Profit      float64 `db:"profit"`
}

type SchedulerCfg struct {
	SchedulerURL string `db:"scheduler_url"`
	AreaID       string `db:"area_id"`
	Weight       int    `db:"weight"`
	AccessToken  string `db:"access_token"`
}

type Service struct {
	Image        string         `db:"image"`
	Name         string         `db:"name"`
	Ports        Ports          `db:"ports"`
	Env          Env            `db:"env"`
	Status       ReplicasStatus `db:"status"`
	ErrorMessage string         `db:"error_message"`
	Arguments    Arguments      `db:"arguments"`
	ComputeResources
	OSType   OSType `db:"os_type"`
	Replicas int32  `db:"replicas"`

	// Internal
	ID           int64        `db:"id"`
	DeploymentID DeploymentID `db:"deployment_id"`
	CreatedAt    time.Time    `db:"created_at"`
	UpdatedAt    time.Time    `db:"updated_at"`
}

type ServiceEvent struct {
	ServiceName string
	Events      []Event
}

type ServiceLog struct {
	ServiceName string
	Logs        []Log
}

type ShellResponse struct {
	ExitCode int    `json:"exit_code"`
	Message  string `json:"message,omitempty"`
}

type SourceDownloadInfo struct {
	NodeID  string
	Address string
	Tk      *Token
}

type Storage struct {
	Name       string `db:"name"`
	Quantity   int64  `db:"quantity"`
	Persistent bool   `db:"persistent"`
	Mount      string `db:"mount"`
}

type StorageStat struct {
	MaxStorage uint64
	Available  uint64
	Active     uint64
	Pending    uint64
}

type StorageStats struct {
	TotalSize    int64 `db:"total_storage_size"`
	UsedSize     int64 `db:"used_storage_size"`
	TotalTraffic int64 `db:"total_traffic"`
	EnableVIP    bool  `db:"enable_vip"`
	AssetCount   int   `db:"asset_count"`
}

type Storages []*Storage

type SufficientResourceNode struct {
	Name string
	ResourcesStatistics
}

type Token struct {
	ID string
	// CipherText encrypted TokenPayload by public key
	CipherText string
	// Sign signs CipherText by scheduler private key
	Sign string
}

type TokenPayload struct {
	ID          string    `db:"token_id"`
	NodeID      string    `db:"node_id"`
	AssetCID    string    `db:"asset_id"`
	ClientID    string    `db:"client_id"`
	LimitRate   int64     `db:"limit_rate"`
	CreatedTime time.Time `db:"created_time"`
	Expiration  time.Time `db:"expiration"`
}

type TunserverReq struct {
	IP     string
	AreaID string
}

type TunserverRsp struct {
	URL    string
	NodeID string
}

type UploadInfo struct {
	List          []*NodeUploadInfo
	AlreadyExists bool
}

type UploadProgress struct {
	TotalSize int64
	DoneSize  int64
}

type UploadingAsset struct {
	UserID          string
	TokenExpiration time.Time
	Progress        *UploadProgress
}

type UserAPIKeysInfo struct {
	CreatedTime time.Time
	APIKey      string
}

type UserAccessControl string

type UserAssetDetail struct {
	UserID      string    `db:"user_id"`
	Hash        string    `db:"hash"`
	AssetName   string    `db:"asset_name"`
	AssetType   string    `db:"asset_type"`
	ShareStatus int64     `db:"share_status"`
	Expiration  time.Time `db:"expiration"`
	CreatedTime time.Time `db:"created_time"`
	TotalSize   int64     `db:"total_size"`
	Password    string    `db:"password"`
	GroupID     int       `db:"group_id"`
}

type UserAssetShareStatus int

type UserAssetSummary struct {
	AssetOverview *AssetOverview
	AssetGroup    *AssetGroup
}

type UserInfo struct {
	TotalSize     int64 `db:"total_storage_size"`
	UsedSize      int64 `db:"used_storage_size"`
	TotalTraffic  int64 `db:"total_traffic"`
	PeakBandwidth int64 `db:"peak_bandwidth"`
	DownloadCount int64 `db:"download_count"`
	EnableVIP     bool  `db:"enable_vip"`

	UpdateTime time.Time `db:"update_peak_time"`
}

type ValidationInfo struct {
	NextElectionTime time.Time
}

type ValidationResultInfo struct {
	ID               int              `db:"id"`
	RoundID          string           `db:"round_id"`
	NodeID           string           `db:"node_id"`
	Cid              string           `db:"cid"`
	ValidatorID      string           `db:"validator_id"`
	BlockNumber      int64            `db:"block_number"` // number of blocks verified
	Status           ValidationStatus `db:"status"`
	Duration         int64            `db:"duration"` // validator duration, microsecond
	Bandwidth        float64          `db:"bandwidth"`
	StartTime        time.Time        `db:"start_time"`
	EndTime          time.Time        `db:"end_time"`
	Profit           float64          `db:"profit"`
	CalculatedProfit bool             `db:"calculated_profit"`
	TokenID          string           `db:"token_id"`
	FileSaved        bool             `db:"file_saved"`
	NodeCount        int              `db:"node_count"`
}

type ValidationStatus int

type Workload struct {
	SourceID     string
	DownloadSize int64
	CostTime     int64 // Millisecond
}

type WorkloadEvent int

type WorkloadRecord struct {
	WorkloadID    string         `db:"workload_id"`
	AssetCID      string         `db:"asset_cid"`
	ClientID      string         `db:"client_id"`
	AssetSize     int64          `db:"asset_size"`
	CreatedTime   time.Time      `db:"created_time"`
	ClientEndTime time.Time      `db:"client_end_time"`
	Workloads     []byte         `db:"workloads"`
	Status        WorkloadStatus `db:"status"`
	Event         WorkloadEvent  `db:"event"`
}

type WorkloadRecordReq struct {
	WorkloadID string
	AssetCID   string
	Workloads  []Workload
}

type WorkloadStatus int