From ae92ce5080f1a82c30cd39f37475346069a5ef4f Mon Sep 17 00:00:00 2001
From: Sydonian <794346190@qq.com>
Date: Fri, 28 Jul 2023 11:42:59 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=A3=80=E6=9F=A5=E8=8A=82?=
 =?UTF-8?q?=E7=82=B9=E7=8A=B6=E6=80=81=E7=9A=84=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/services/cmd/ipfs.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/internal/services/cmd/ipfs.go b/internal/services/cmd/ipfs.go
index ade8741..7030568 100644
--- a/internal/services/cmd/ipfs.go
+++ b/internal/services/cmd/ipfs.go
@@ -36,6 +36,7 @@ func (svc *Service) checkIncrement(msg *agtmsg.CheckIPFS, filesMap map[string]sh
 			if cache.State == consts.CACHE_STATE_PINNED {
 				// 不处理
 			} else if cache.State == consts.CACHE_STATE_TEMP {
+				logger.WithField("FileHash", cache.FileHash).Debugf("unpin for cache entry state is temp")
 				err := svc.ipfs.Unpin(cache.FileHash)
 				if err != nil {
 					logger.WithField("FileHash", cache.FileHash).Warnf("unpin file failed, err: %s", err.Error())
@@ -70,6 +71,7 @@ func (svc *Service) checkComplete(msg *agtmsg.CheckIPFS, filesMap map[string]she
 			if cache.State == consts.CACHE_STATE_PINNED {
 				// 不处理
 			} else if cache.State == consts.CACHE_STATE_TEMP {
+				logger.WithField("FileHash", cache.FileHash).Debugf("unpin for cache entry state is temp")
 				err := svc.ipfs.Unpin(cache.FileHash)
 				if err != nil {
 					logger.WithField("FileHash", cache.FileHash).Warnf("unpin file failed, err: %s", err.Error())
@@ -93,6 +95,7 @@ func (svc *Service) checkComplete(msg *agtmsg.CheckIPFS, filesMap map[string]she
 
 	// map中剩下的数据是没有被遍历过，即Cache中没有记录的，那么就Unpin文件，并产生一条Temp记录
 	for hash := range filesMap {
+		logger.WithField("FileHash", hash).Debugf("unpin for no cacah entry")
 		err := svc.ipfs.Unpin(hash)
 		if err != nil {
 			logger.WithField("FileHash", hash).Warnf("unpin file failed, err: %s", err.Error())