en

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

type FileInfo struct {
	Name      string   `json:"name"`      // 文件名称(上传的文件名称)
	ReName    string   `json:"rename"`    // 文件完整信息名称(主要信息组成), 命名保存文件的名称
	Path      string   `json:"path"`      // 文件路径
	Md5       string   `json:"md5"`       // 文件标识 (文件(路径)Hash)
	Size      int64    `json:"size"`      // 文件大小
	Peers     []string `json:"peers"`     // 文件存在的集群节点
	Scene     string   `json:"scene"`     // 文件场景
	TimeStamp int64    `json:"timeStamp"` // 文件时间戳
	OffSet    int64    `json:"offset"`    // -1 上传后新建的文件 , -2 文件变更后的文件 | >= 0 small file | 文件偏移, 小文件合并时, 包含文件数的偏移 , 值大于等于0
	Retry     int      // 重试次数计数器 (文件下载)
	Op        string   // 操作描述, 用于描述监视过程中发生的事件类型
}

type FileInfoResult struct {
	Name    string `json:"name"`   // 文件名
	Md5     string `json:"md5"`    // 文件标识
	Path    string `json:"path"`   // 文件路径
	Size    int64  `json:"size"`   // 文件大小
	ModTime int64  `json:"mtime"`  // 时间戳
	IsDir   bool   `json:"is_dir"` // 是否为目录
}

type FileLog struct {
	FileInfo *FileInfo // 文件信息
	FileName string    // 文件处理信息保存的文件名 (根据处理不同, 存放在不同的文件)
}

type FileUploadResult struct {
	Url     string `json:"url"`    // 下载地址
	Md5     string `json:"md5"`    // 文件标识
	Path    string `json:"path"`   // 文件路径 (下载路径)
	Src     string `json:"src"`    // 文件路径 (存储路径)
	Domain  string `json:"domain"` // 下载域, 配置的下载地址或者获取本节点地址
	Scene   string `json:"scene"`  // 文件场景
	Size    int64  `json:"size"`   // 文件大小
	ModTime int64  `json:"mtime"`  // 文件时间戳
	Scenes  string `json:"scenes"`
	Retmsg  string `json:"retmsg"`
	Retcode int    `json:"retcode"`
}

type HookDataStore struct {
	tusd.DataStore
}

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

type JsonResult struct {
	Message string      `json:"message"`
	Status  string      `json:"status"`
	Data    interface{} `json:"data"`
}

type Server interface {
	GetServerName() string     // 获取服务名称
	GetGroupRouteName() string // 获取访问路由名称, 未配置使用服务名称
	GetHost() string
	GetLdb() *leveldb.DB
	GetStatMap() *goutil.CommonMap
	GetSceneMap() *goutil.CommonMap
	GetSumMap() *goutil.CommonMap
	GetQueueUpload() chan WrapReqResp
	GetQueueFromPeers() chan FileInfo
	GetQueueToPeers() chan FileInfo
	GetQueueFileLog() chan *FileLog

	// 重新加载后台服务
	Reload(w http.ResponseWriter, r *http.Request)

	//
	AppendToQueue(fileInfo *FileInfo)
	AppendToDownloadQueue(fileInfo *FileInfo)

	// 上传文件
	Upload(w http.ResponseWriter, r *http.Request)

	// 文件下载
	DownloadFromPeer(peer string, fileInfo *FileInfo)                               // 从集群(查找到文件的节点 peer)中下载文件
	NotPermit(w http.ResponseWriter, r *http.Request)                               // 返回 401 , 没有访问权限
	CheckAuth(w http.ResponseWriter, r *http.Request) bool                          //
	CheckPeerFileExist(peer string, md5sum string, fpath string) (*FileInfo, error) // 检测文件是否存在, 并获取文件信息
	GetFileInfoFromLevelDB(key string) (*FileInfo, error)                           // 从数据库中查询文件
	VerifyGoogleCode(secret string, code string, discrepancy int64) bool

	RemoveKeyFromLevelDB(key string, db *leveldb.DB) error                                   // 从数据库删除文件信息
	SaveFileInfoToLevelDB(key string, fileInfo *FileInfo, db *leveldb.DB) (*FileInfo, error) // 保存文件信息到数据库
	SaveFileMd5Log(fileInfo *FileInfo, filename string)                                      // 保存文件日志信息数据
	CheckFileAndSendToPeer(date string, filename string, isForceUpload bool)
	//
	AutoRepair(forceRepair bool)
	RepairStatByDate(date string) StatDateFileInfo
	RepairFileInfoFromFile()
	BackUpMetaDataByDate(date string)

	GetRequestURI(action string) string
	GetMd5sByDate(date string, filename string) (mapset.Set, error)
}

type StatDateFileInfo struct {
	Date      string `json:"date"`
	TotalSize int64  `json:"totalSize"`
	FileCount int64  `json:"fileCount"`
}

type WrapReqResp struct {
	W    *http.ResponseWriter
	R    *http.Request
	Done chan bool
}