fix(import): import from slave not working / fix(recycle): skip sending delete request if no blob needs to be deleted in this batch

This commit is contained in:
Aaron Liu
2025-05-20 10:46:27 +08:00
parent 2fac086127
commit 7bace40a4d
5 changed files with 10 additions and 12 deletions

View File

@@ -190,8 +190,7 @@ func SlaveFileListRoute(srcPath string, recursive bool) string {
query := url.Values{}
query.Set("recursive", strconv.FormatBool(recursive))
query.Set("path", srcPath)
route, _ := url.Parse(constants.APIPrefixSlave + fmt.Sprintf("%s?%s", base, query.Encode()))
return route.String()
return fmt.Sprintf("%s?%s", base, query.Encode())
}
func SlaveThumbUrl(base *url.URL, srcPath, ext string) *url.URL {

View File

@@ -245,7 +245,7 @@ func (c *remoteClient) List(ctx context.Context, path string, recursive bool) ([
}
if resp.Code != 0 {
return nil, fmt.Errorf(resp.Error)
return nil, serializer.NewErrorFromResponse(resp)
}
var objects []fs.PhysicalObject

View File

@@ -225,10 +225,12 @@ func (m *manager) RecycleEntities(ctx context.Context, force bool, entityIDs ...
}), func(entity fs.Entity, index int) string {
return entity.Source()
})
res, err := d.Delete(ctx, toBeDeletedSrc...)
if err != nil {
for _, src := range res {
ae.Add(strconv.Itoa(mapSrcToId[src]), err)
if len(toBeDeletedSrc) > 0 {
res, err := d.Delete(ctx, toBeDeletedSrc...)
if err != nil {
for _, src := range res {
ae.Add(strconv.Itoa(mapSrcToId[src]), err)
}
}
}