object/dragonfly: fix filter parse issue.

Signed-off-by: XDTD <[email protected]>
juicedata · Oct 18, 2023 · 2f1015c · 2f1015c
1 parent dd27441
commit 2f1015c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/object/dragonfly.go b/pkg/object/dragonfly.go
@@ -232,6 +232,10 @@ func (d *dragonfly) Get(key string, off, limit int64) (io.ReadCloser, error) {
 	}
 
 	query := u.Query()
+	if d.Filter != "" {
+		query.Add("filter", d.Filter)
+	}
+
 	u.RawQuery = query.Encode()
 
 	req, err := http.NewRequestWithContext(ctx, http.MethodGet, u.String(), nil)
@@ -518,7 +522,7 @@ func newDragonfly(_endpoint, _accessKey, _secretKey, _token string) (ObjectStora
 	}
 
 	if value := uri.Query().Get("filter"); value != "" {
-		filter = value
+		filter = strings.ReplaceAll(value, ",", "&")
 	}
 
 	return &dragonfly{