uploads

type ControlCommand string

type ErrorType string

type EventType string

type FileMeta struct {
	FileID      string // 文件唯一标识，用于在系统内部唯一区分文件
	Name        string // 文件名，包括扩展名，描述文件的名称
	Extension   string // 文件的扩展名
	Size        int64  // 文件大小，单位为字节，描述文件的总大小
	ContentType string // MIME类型，表示文件的内容类型，如"text/plain"
	Checksum    []byte // 文件的校验和，用于在上传前后验证文件的完整性和一致性
}

type FileSecurity struct {
	Secret        []byte            // 文件加密密钥
	EncryptionKey [][]byte          // 文件加密密钥，用于在上传过程中保证文件数据的安全
	PrivateKey    *ecdsa.PrivateKey // 文件签名密钥
	P2PKHScript   []byte            // P2PKH 脚本，用于区块链场景中验证文件所有者的身份
	P2PKScript    []byte            // P2PK 脚本，用于区块链场景中进行文件验签操作
}

type FileSecuritySerializable struct {
	Secret        []byte   `json:"secret"`         // 文件加密密钥
	EncryptionKey [][]byte `json:"encryption_key"` // 文件加密密钥
	PrivateKey    []byte   `json:"private_key"`    // 文件签名密钥的序列化字节
	P2PKHScript   []byte   `json:"p2pkh_script"`   // P2PKH 脚本
	P2PKScript    []byte   `json:"p2pk_script"`    // P2PK 脚本
}

type FileSegment struct {
	Index     int                 // 分片索引，表示该片段在文件中的顺序
	SegmentID string              // 文件片段的唯一标识
	Size      int                 // 分片大小，单位为字节，描述该片段的数据量大小
	Checksum  []byte              // 分片的校验和，用于验证该片段的完整性和一致性
	IsRsCodes bool                // 是否是纠删码片段
	Status    SegmentUploadStatus // 分片的上传状态，描述该片段的上传进度和结果
}

type FileSegmentInfo struct {
	TaskID        string // 任务ID
	FileID        string // 文件唯一标识，用于在系统内部唯一区分文件
	TempStorage   string // 文件的临时存储位置，用于保存文件分片的临时数据
	SegmentID     string // 文件片段的唯一标识
	TotalSegments int    // 文件总分片数
	Index         int    // 分片索引，表示该片段在文件中的顺序
	Size          int    // 分片大小，单位为字节，描述该片段的数据量大小
	IsRsCodes     bool   // 标记该分片是否使用了纠删码技术，用于数据的恢复和冗余
}

type HashTable struct {
	Checksum  []byte // 分片的校验和，用于校验分片数据的完整性和一致性
	IsRsCodes bool   // 标记该分片是否使用了纠删码技术，用于数据的恢复和冗余
}

type NetworkResponse struct {
	Index          int     // 文件片段索引，表示该片段在文件中的顺序
	ReceiverPeerID peer.ID // 接收该文件片段的节点ID
}

type NewUploadManagerInput struct {
	fx.In
	LC  fx.Lifecycle
	Ctx context.Context // 全局上下文
}

type NewUploadManagerOutput struct {
	fx.Out
	Upload *UploadManager // 管理所有上传会话
}

type PeerDistanceInfo struct {
	Peer peer.ID
	Dist *big.Int
}

type PeerDistanceReq struct {
	SegmentID     string   // 文件片段的唯一标识
	Size          int      // 分片大小，单位为字节，描述该片段的数据量大小
	IsRsCodes     bool     // 标记该分片是否使用了纠删码技术，用于数据的恢复和冗余
	ExcludedPeers []string // 需要过滤的节点ID列表
}

type PeerInfo struct {
	IDs     []peer.ID // 节点的ID数组
	IsLocal bool      // 是否有本地节点为最近节点的标志
}

type RegisterStreamProtocolInput struct {
	fx.In
	LC     fx.Lifecycle
	Ctx    context.Context     // 全局上下文
	Opt    *opts.Options       // 文件存储选项配置
	Afe    afero.Afero         // 文件系统接口
	P2P    *dep2p.DeP2P        // 网络主机
	PubSub *pubsub.DeP2PPubSub // 网络订阅
	Upload *UploadManager      // 管理所有上传任务
}

type SegmentUploadStatus string

type SendingToNetworkReq struct {
	FileID        string // 文件唯一标识，用于在系统内部唯一区分文件
	SegmentID     string // 文件片段的唯一标识
	TotalSegments int    // 文件总分片数
	Index         int    // 分片索引，表示该片段在文件中的顺序
	IsRsCodes     bool   // 标记该分片是否使用了纠删码技术，用于数据的恢复和冗余
	SliceByte     []byte // 切片内容
}

type SendingToNetworkRes struct {
	FileID        string  // 文件唯一标识，用于在系统内部唯一区分文件
	SegmentID     string  // 文件片段的唯一标识
	TotalSegments int     // 文件总分片数
	Index         int     // 分片索引，表示该片段在文件中的顺序
	IsRsCodes     bool    // 标记该分片是否使用了纠删码技术，用于数据的恢复和冗余
	ID            peer.ID // 节点的ID
	UploadAt      int64   // 文件片段上传的时间戳
}

type StreamProtocol struct {
	Ctx    context.Context     // 全局上下文
	Opt    *opts.Options       // 文件存储选项配置
	Afe    afero.Afero         // 文件系统接口
	P2P    *dep2p.DeP2P        // 网络主机
	PubSub *pubsub.DeP2PPubSub // 网络订阅
	Upload *UploadManager      // 管理所有上传任务
}

type UploadChan struct {
	TaskID           string  // 任务唯一标识
	UploadProgress   int     // 上传进度百分比
	IsComplete       bool    // 上传任务是否完成
	SegmentID        string  // 文件片段唯一标识
	SegmentIndex     int     // 文件片段索引，表示该片段在文件中的顺序
	SegmentSize      int     // 文件片段大小，单位为字节
	UsesErasureCodes bool    // 是否使用纠删码技术
	NodeID           peer.ID // 存储该文件片段的节点ID
	UploadTime       int64   // 上传完成时间的时间戳
}

type UploadFile struct {
	FileMeta                         // 文件的元数据，如文件名、大小、类型等
	Segments    map[int]*FileSegment // 文件分片信息，详细描述了文件如何被分割为多个片段进行上传
	TempStorage string               // 文件的临时存储位置，用于保存文件分片的临时数据
	Security    *FileSecurity        // 文件的安全和加密相关信息
	SliceTable  map[int]*HashTable   // 文件片段的哈希表，记录每个片段的哈希值，支持纠错和数据完整性验证
	StartedAt   int64                // 文件上传的开始时间戳，记录任务开始执行的时间点
	FinishedAt  int64                // 文件上传的完成时间戳，记录任务完成执行的时间点
}

type UploadManager struct {
	Mu              sync.Mutex             // 用于保护状态的互斥锁
	Tasks           map[string]*UploadTask // 上传任务的映射表，键为任务ID，值为上传任务对象
	UploadChan      chan *UploadChan       // 上传状态更新通道，用于通知外部上传进度和状态
	SaveTasksToFile chan struct{}          // 保存任务至文件通道
	Scheme          *shamir.ShamirScheme   // 创建一个新的ShamirScheme实例
	// contains filtered or unexported fields
}

type UploadStatus string

type UploadSuccessInfo struct {
	TaskID      string // 任务唯一标识，用于区分和管理不同的上传任务。
	FileID      string // 文件唯一标识，用于在系统内部唯一区分文件。
	Checksum    string // 文件的校验和
	Name        string // 文件名，包括扩展名，描述文件的名称。
	Size        int64  // 文件大小，单位为字节，描述文件的总大小。
	TotalSlices int    // 文件总切片总数，描述文件的总切片数。
	Extension   string // 文件的扩展名
	ContentType string // MIME类型，表示文件的内容类型，如"text/plain"。
	UploadTime  int64  // 文件开始上传的时间。

}

type UploadTask struct {
	Mu         sync.RWMutex // 控制对Progress的并发访问
	Status     UploadStatus // 上传任务的当前状态，如进行中、暂停、完成等
	StatusCond *sync.Cond

	TaskID   string      // 任务唯一标识，用于区分和管理不同的上传任务
	File     *UploadFile // 待上传的文件信息，包含文件的元数据和分片信息
	Progress util.BitSet // 上传任务的进度，表示为0到100之间的百分比

	SegmentReady    chan struct{}         // 用于通知准备好本地存储文件片段的通道
	SendToNetwork   chan int              // 用于触发向网络发送已存储文件片段的动作的通道
	UploadDone      chan struct{}         // 用于通知上传完成的通道
	NetworkReceived chan *NetworkResponse // 用于接收网络返回的接受方节点地址信息的通道
	// contains filtered or unexported fields
}

type UploadTaskSerializable struct {
	TaskID       string                    `json:"task_id"`       // 任务唯一标识
	FileMeta     *FileMeta                 `json:"file_meta"`     // 文件元数据
	Segments     map[int]*FileSegment      `json:"segments"`      // 文件分片信息
	TempStorage  string                    `json:"temp_storage"`  // 文件的临时存储位置
	SliceTable   map[int]*HashTable        `json:"slice_table"`   // 文件片段的哈希表
	StartedAt    int64                     `json:"started_at"`    // 文件上传的开始时间戳
	FinishedAt   int64                     `json:"finished_at"`   // 文件上传的完成时间戳
	Progress     util.BitSet               `json:"progress"`      // 上传任务的进度
	Status       UploadStatus              `json:"status"`        // 上传任务的状态
	FileSecurity *FileSecuritySerializable `json:"file_security"` // 文件安全信息
}