mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-07-19 20:14:17 -04:00
Code Issues Packages Projects Releases Wiki Activity

purge recycle bin

Browse Source
This commit is contained in:
A.Unger
2021-04-26 14:27:36 +02:00
parent 332a0a6cce
commit 6497743a02
1 changed files with 49 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
ocs/pkg/service/v0/users.go
View File

@@ -12,6 +12,7 @@ import (
"github.com/asim/go-micro/plugins/client/grpc/v3"
merrors "github.com/asim/go-micro/v3/errors"
gateway "github.com/cs3org/go-cs3apis/cs3/gateway/v1beta1"
cs3 "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
revauser "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
rpcv1beta1 "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
@@ -437,6 +438,54 @@ func (o Ocs) DeleteUser(w http.ResponseWriter, r *http.Request) {
Msg("DeleteUser: could not delete user home: delete failed")
return
}
// delete trash is a combination of ListRecycle + PurgeRecycle (iterative)
listRecycle := &gateway.ListRecycleRequest{
Ref: &provider.Reference{
Spec: &provider.Reference_Path{
Path: homeResp.Path,
},
},
}
listRecycleResponse, err := gwc.ListRecycle(ctx, listRecycle)
if err != nil {
render.Render(w, r, response.ErrRender(data.MetaServerError.StatusCode, errors.Wrap(err, "could not delete trash").Error()))
return
}
if listRecycleResponse.Status.Code != rpcv1beta1.Code_CODE_OK {
o.logger.Error().
Str("stat_status_code", statResp.Status.Code.String()).
Str("stat_message", statResp.Status.Message).
Msg("DeleteUser: could not delete user trash: delete failed")
return
}
// now that we've got the items, we iterate, create references and fire PurgeRecycleRequests to the Reva gateway.
//for i := range listRecycleResponse.RecycleItems {
// craft purge request
req := &gateway.PurgeRecycleRequest{
Ref: &provider.Reference{
Spec: &provider.Reference_Path{
Path: homeResp.Path,
},
},
}
// do request
purgeRecycleResponse, err := gwc.PurgeRecycle(ctx, req)
if err != nil {
}
if purgeRecycleResponse.Status.Code != rpcv1beta1.Code_CODE_OK {
o.logger.Error().
Str("stat_status_code", statResp.Status.Code.String()).
Str("stat_message", statResp.Status.Message).
Msg("DeleteUser: could not delete user trash: delete failed")
return
}
}
req := accounts.DeleteAccountRequest{