syncdrive

type BoltDb struct {
	Path string
	// contains filtered or unexported fields
}

type BoltItem struct {
	FilePath string
	IsFolder bool
	Data     string
}

type CycleMode string

type FileAction string

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

type FileActionTaskList []*FileActionTask

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

type LocalFileItem struct {
	// FileName 文件名
	FileName string `json:"fileName"`
	// FileSize 文件大小
	FileSize int64 `json:"fileSize"`
	// 文件类别 folder / file
	FileType string `json:"fileType"`
	// 创建时间
	CreatedAt string `json:"createdAt"`
	// 最后修改时间
	UpdatedAt string `json:"updatedAt"`
	// 后缀名，例如：dmg
	FileExtension string `json:"fileExtension"`
	// 内容Hash值，只有文件才会有
	Sha1Hash string `json:"sha1Hash"`
	// FilePath 文件的完整路径
	Path string `json:"path"`
	// ScanTimeAt 扫描时间
	ScanTimeAt string `json:"scanTimeAt"`
	// ScanStatus 扫描状态
	ScanStatus ScanStatus `json:"scanStatus"`
}

type LocalFileList []*LocalFileItem

type LocalSyncDb interface {
	// Open 打开并准备数据库
	Open() (bool, error)
	// Add 存储一个数据项
	Add(item *LocalFileItem) (bool, error)
	// AddFileList 存储批量数据项
	AddFileList(items LocalFileList) (bool, error)
	// Get 获取一个数据项
	Get(filePath string) (*LocalFileItem, error)
	// GetFileList 获取文件夹下的所有的文件列表
	GetFileList(filePath string) (LocalFileList, error)
	// Delete 删除一个数据项，如果是文件夹，则会删除文件夹下面所有的文件列表
	Delete(filePath string) (bool, error)
	// Update 更新一个数据项数据
	Update(item *LocalFileItem) (bool, error)
	// Close 关闭数据库
	Close() (bool, error)
}

type LocalSyncDbBolt struct {
	Path string
	// contains filtered or unexported fields
}

type PanFileItem struct {
	// 网盘ID
	DriveId string `json:"driveId"`
	// 域ID
	DomainId string `json:"domainId"`
	// FileId 文件ID
	FileId string `json:"fileId"`
	// FileName 文件名
	FileName string `json:"fileName"`
	// FileSize 文件大小
	FileSize int64 `json:"fileSize"`
	// 文件类别 folder / file
	FileType string `json:"fileType"`
	// 创建时间
	CreatedAt string `json:"createdAt"`
	// 最后修改时间
	UpdatedAt string `json:"updatedAt"`
	// 后缀名，例如：dmg
	FileExtension string `json:"fileExtension"`
	// 文件上传ID
	UploadId string `json:"uploadId"`
	// 父文件夹ID
	ParentFileId string `json:"parentFileId"`
	// 内容CRC64校验值，只有文件才会有
	Crc64Hash string `json:"crc64Hash"`
	// 内容Hash值，只有文件才会有
	Sha1Hash string `json:"sha1Hash"`
	// FilePath 文件的完整路径
	Path string `json:"path"`
	// Category 文件分类，例如：image/video/doc/others
	Category string `json:"category"`
	// ScanTimeAt 扫描时间
	ScanTimeAt string `json:"scanTimeAt"`
	// ScanStatus 扫描状态
	ScanStatus ScanStatus `json:"scanStatus"`
}

type PanFileList []*PanFileItem

type PanSyncDb interface {
	// Open 打开并准备数据库
	Open() (bool, error)
	// Add 存储一个数据项
	Add(item *PanFileItem) (bool, error)
	// AddFileList 存储批量数据项
	AddFileList(items PanFileList) (bool, error)
	// Get 获取一个数据项
	Get(filePath string) (*PanFileItem, error)
	// GetFileList 获取文件夹下的所有的文件列表
	GetFileList(filePath string) (PanFileList, error)
	// Delete 删除一个数据项，如果是文件夹，则会删除文件夹下面所有的文件列表
	Delete(filePath string) (bool, error)
	// Update 更新一个数据项数据
	Update(item *PanFileItem) (bool, error)
	// Close 关闭数据库
	Close() (bool, error)
}

type PanSyncDbBolt struct {
	Path string
	// contains filtered or unexported fields
}

type ScanStatus string

type SyncDriveConfig struct {
	ConfigVer    string      `json:"configVer"`
	SyncTaskList []*SyncTask `json:"syncTaskList"`
}

type SyncFileAction string

type SyncFileDb interface {
	// Open 打开并准备数据库
	Open() (bool, error)
	// Add 存储一个数据项
	Add(item *SyncFileItem) (bool, error)
	// Get 获取一个数据项
	Get(id string) (*SyncFileItem, error)
	// GetFileList 获取文件夹下的所有的文件列表
	GetFileList(Status SyncFileStatus) (SyncFileList, error)
	// Delete 删除一个数据项，如果是文件夹，则会删除文件夹下面所有的文件列表
	Delete(id string) (bool, error)
	// Update 更新一个数据项数据
	Update(item *SyncFileItem) (bool, error)
	// Close 关闭数据库
	Close() (bool, error)
}

type SyncFileDbBolt struct {
	Path string
	// contains filtered or unexported fields
}

type SyncFileItem struct {
	Action    SyncFileAction `json:"action"`
	Status    SyncFileStatus `json:"status"`
	LocalFile *LocalFileItem `json:"localFile"`
	PanFile   *PanFileItem   `json:"panFile"`
	// LocalFolderPath 本地目录
	LocalFolderPath string `json:"localFolderPath"`
	// PanFolderPath 云盘目录
	PanFolderPath    string `json:"panFolderPath"`
	StatusUpdateTime string `json:"statusUpdateTime"`

	DriveId           string                            `json:"driveId"`
	DownloadRange     *transfer.Range                   `json:"downloadRange"`
	DownloadBlockSize int64                             `json:"downloadBlockSize"`
	UploadRange       *transfer.Range                   `json:"uploadRange"`
	UploadEntity      *aliyunpan.CreateFileUploadResult `json:"uploadEntity"`
	// UploadPartSeq 上传序号，从0开始
	UploadPartSeq   int   `json:"uploadPartSeq"`
	UploadBlockSize int64 `json:"uploadBlockSize"`
}

type SyncFileList []*SyncFileItem

type SyncFileStatus string

type SyncMode string

type SyncOption struct {
	FileDownloadParallel  int   // 文件下载并发数
	FileUploadParallel    int   // 文件上传并发数
	FileDownloadBlockSize int64 // 文件下载分片大小
	FileUploadBlockSize   int64 // 文件上传分片大小

	MaxDownloadRate int64 // 限制最大下载速度
	MaxUploadRate   int64 // 限制最大上传速度

	// 优先级选项
	SyncPriority SyncPriorityOption

	// 本地文件修改检测间隔
	LocalFileModifiedCheckIntervalSec int

	// 文件记录器
	FileRecorder *log.FileRecorder
}

type SyncPolicy string

type SyncPriorityOption string

type SyncTask struct {
	// Name 任务名称
	Name string `json:"name"`
	// Id 任务ID
	Id string `json:"id"`
	// UserId 账号ID
	UserId string `json:"userId"`
	// DriveName 网盘名称，backup-备份盘，resource-资源盘
	DriveName string `json:"driveName"`
	// DriveId 网盘ID，目前支持文件网盘
	DriveId string `json:"-"`
	// LocalFolderPath 本地目录
	LocalFolderPath string `json:"localFolderPath"`
	// PanFolderPath 云盘目录
	PanFolderPath string `json:"panFolderPath"`
	// Mode 备份模式
	Mode SyncMode `json:"mode"`
	// Policy 备份策略
	Policy SyncPolicy `json:"policy"`
	// CycleMode 循环模式，OneTime-运行一次，InfiniteLoop-无限循环模式
	CycleModeType CycleMode `json:"-"`
	// Priority 优先级选项
	Priority SyncPriorityOption `json:"-"`
	// LastSyncTime 上一次同步时间
	LastSyncTime string `json:"lastSyncTime"`
	// contains filtered or unexported fields
}

type SyncTaskManager struct {
	PanUser              *config.PanUser
	PanClient            *config.PanClient
	SyncConfigFolderPath string
	// contains filtered or unexported fields
}