删除测试代码

common/pkgs/downloader/downloader.go

@@ -76,14 +76,6 @@ func (d *Downloader) DownloadObjects(reqs []DownloadReqeust) DownloadIterator {
 		return iterator.FuseError[*Downloading](fmt.Errorf("request to coordinator: %w", err))
 	}
 
-	// 测试使用：将文件pin到ipfs
-	go func() {
-		err := PinFileToIPFS(*objDetails)
-		if err != nil {
-			print(err)
-		}
-	}()
-
 	req2s := make([]downloadReqeust2, len(reqs))
 	for i, req := range reqs {
 		req2s[i] = downloadReqeust2{

common/pkgs/downloader/ipfs_pin.go

@@ -1,36 +0,0 @@
-package downloader
-
-import (
-	stgglb "gitlink.org.cn/cloudream/storage/common/globals"
-	coormq "gitlink.org.cn/cloudream/storage/common/pkgs/mq/coordinator"
-)
-
-type PinConfig struct {
-	IpfsPin IpfsConfig
-}
-
-type IpfsConfig struct {
-	IpfsUrl string `json:"ipfsUrl"`
-}
-
-// PinFileToIPFS pin file to IPFS
-func PinFileToIPFS(objDetails coormq.GetObjectDetailsResp) error {
-
-	client, err := stgglb.IPFSPool.Acquire()
-	if err != nil {
-		print(err)
-	}
-
-	objs := objDetails.Objects
-	// 遍历objDetails
-	for _, obj := range objs {
-		cid := obj.Object.FileHash
-		err := client.Pin(cid)
-		if err != nil {
-			return err
-		}
-		print("IPFS pin success, filehash: " + cid)
-	}
-
-	return nil
-}