feature: add GetHTTPPath function for cdn mgr

Signed-off-by: Starnop <starnop@163.com>

Author: starnop

supernode/daemon/mgr/cdn/manager.go

@@ -106,6 +106,15 @@ func (cm *Manager) TriggerCDN(ctx context.Context, task *types.TaskInfo) (*types
 	}, nil
 }
 
+// GetHTTPPath returns the http download path of taskID.
+func (cm *Manager) GetHTTPPath(ctx context.Context, taskID string) (string, error) {
+	info, err := cm.cacheStore.Stat(ctx, getDownloadRawFunc(taskID))
+	if err != nil {
+		return "", err
+	}
+	return info.Path, nil
+}
+
 // GetStatus get the status of the file.
 func (cm *Manager) GetStatus(ctx context.Context, taskID string) (cdnStatus string, err error) {
 	return "", nil

supernode/daemon/mgr/cdn_mgr.go

@@ -19,6 +19,9 @@ type CDNMgr interface {
 	// In addition, it's not thread-safe.
 	TriggerCDN(ctx context.Context, taskInfo *types.TaskInfo) (*types.TaskInfo, error)
 
+	// GetHTTPPath returns the http download path of taskID.
+	GetHTTPPath(ctx context.Context, taskID string) (path string, err error)
+
 	// GetStatus get the status of the file.
 	GetStatus(ctx context.Context, taskID string) (cdnStatus string, err error)
 

supernode/daemon/mgr/mock/mock_cdn_mgr.go

@@ -247,7 +247,7 @@ func (ls *localStorage) PutBytes(ctx context.Context, raw *Raw, data []byte) err
 
 // Stat determine whether the file exists.
 func (ls *localStorage) Stat(ctx context.Context, raw *Raw) (*StorageInfo, error) {
-	path, fileInfo, err := ls.statPath(raw.Bucket, raw.Key)
+	_, fileInfo, err := ls.statPath(raw.Bucket, raw.Key)
 	if err != nil {
 		return nil, err
 	}
@@ -257,7 +257,7 @@ func (ls *localStorage) Stat(ctx context.Context, raw *Raw) (*StorageInfo, error
 		return nil, fmt.Errorf("get create time error")
 	}
 	return &StorageInfo{
-		Path:       path,
+		Path:       path.Join(raw.Bucket, raw.Key),
 		Size:       fileInfo.Size(),
 		CreateTime: util.Ctime(sys),
 		ModTime:    fileInfo.ModTime(),

supernode/store/local_storage.go

@@ -323,7 +323,7 @@ func (s *LocalStorageSuite) checkStat(raw *Raw, c *check.C) {
 	sys, _ := util.GetSys(f)
 
 	c.Assert(info, check.DeepEquals, &StorageInfo{
-		Path:       pathTemp,
+		Path:       path.Join(raw.Bucket, raw.Key),
 		Size:       f.Size(),
 		ModTime:    f.ModTime(),
 		CreateTime: util.Ctime(sys),