feat: dfdaemon upload and object storage add middlewares

Signed-off-by: Gaius <[email protected]>

Author: gaius-qi

client/daemon/daemon.go

@@ -219,7 +219,7 @@ func New(opt *config.DaemonOption, d dfpath.Dfpath) (Daemon, error) {
 		return nil, err
 	}
 
-	uploadManager, err := upload.NewUploadManager(storageManager,
+	uploadManager, err := upload.NewUploadManager(opt, storageManager, d.LogDir(),
 		upload.WithLimiter(rate.NewLimiter(opt.Upload.RateLimit.Limit, int(opt.Upload.RateLimit.Limit))))
 	if err != nil {
 		return nil, err

client/daemon/upload/upload_manager_test.go

@@ -30,6 +30,7 @@ import (
 	testifyassert "github.com/stretchr/testify/assert"
 	"golang.org/x/time/rate"
 
+	"d7y.io/dragonfly/v2/client/config"
 	"d7y.io/dragonfly/v2/client/daemon/storage"
 	"d7y.io/dragonfly/v2/client/daemon/test"
 	mock_storage "d7y.io/dragonfly/v2/client/daemon/test/mock/storage"
@@ -55,7 +56,7 @@ func TestUploadManager_Serve(t *testing.T) {
 				io.NopCloser(nil), nil
 		})
 
-	um, err := NewUploadManager(mockStorageManager, WithLimiter(rate.NewLimiter(16*1024, 16*1024)))
+	um, err := NewUploadManager(config.NewDaemonConfig(), mockStorageManager, os.TempDir(), WithLimiter(rate.NewLimiter(16*1024, 16*1024)))
 	assert.Nil(err, "NewUploadManager")
 
 	listen, err := net.Listen("tcp4", "127.0.0.1:0")