mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-01-04 11:19:39 -06:00
Code Issues Packages Projects Releases Wiki Activity

look up personal space for GDPR export

Browse Source 
Signed-off-by: Jörn Friedrich Dreyer <jfd@butonic.de>
This commit is contained in:
Jörn Friedrich Dreyer
2025-03-03 13:00:55 +01:00
parent 63c4f0b1b4
commit 5ee01dcd97
1 changed files with 47 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
services/graph/pkg/service/v0/personaldata.go
View File

@@ -16,6 +16,7 @@ import (
user "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
rpc "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
provider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
storageprovider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
"github.com/go-chi/chi/v5"
ehmsg "github.com/opencloud-eu/opencloud/protogen/gen/opencloud/messages/eventhistory/v0"
ehsvc "github.com/opencloud-eu/opencloud/protogen/gen/opencloud/services/eventhistory/v0"
@@ -40,6 +41,44 @@ type ExportPersonalDataRequest struct {
StorageLocation string `json:"storageLocation"`
}
func (g Graph) getPersonalSpace(ctx context.Context, u *user.UserId) (*provider.StorageSpace, error) {
// we cannot assume the space id is the same as the user id, so we have to look up his personal space first
lReq := &storageprovider.ListStorageSpacesRequest{
Filters: []*storageprovider.ListStorageSpacesRequest_Filter{
{
Type: storageprovider.ListStorageSpacesRequest_Filter_TYPE_OWNER,
Term: &storageprovider.ListStorageSpacesRequest_Filter_Owner{
Owner: u,
},
},
{
Type: storageprovider.ListStorageSpacesRequest_Filter_TYPE_SPACE_TYPE,
Term: &storageprovider.ListStorageSpacesRequest_Filter_SpaceType{
SpaceType: "personal",
},
},
},
}
gatewayClient, err := g.gatewaySelector.Next()
if err != nil {
return nil, err
}
res, err := gatewayClient.ListStorageSpaces(ctx, lReq)
if err != nil {
return nil, err
}
if res.Status.Code != rpc.Code_CODE_OK {
return nil, errorcode.FromCS3Status(res.Status, fmt.Errorf("could not list storage spaces"))
}
if len(res.GetStorageSpaces()) == 0 {
return nil, fmt.Errorf("could not find personal space for user %s", u.GetOpaqueId())
}
return res.GetStorageSpaces()[0], nil
}
// ExportPersonalData exports all personal data the system holds
func (g Graph) ExportPersonalData(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
@@ -65,8 +104,15 @@ func (g Graph) ExportPersonalData(w http.ResponseWriter, r *http.Request) {
marsh = json.Marshal
}
personalSpace, err := g.getPersonalSpace(ctx, u.GetId())
if err != nil {
g.logger.Error().Err(err).Msg("could not get personal space")
errorcode.ServiceNotAvailable.Render(w, r, http.StatusInternalServerError, "could not get personal space, aborting")
return
}
ref := &provider.Reference{
ResourceId: &provider.ResourceId{SpaceId: u.GetId().GetOpaqueId(), OpaqueId: u.GetId().GetOpaqueId()},
ResourceId: personalSpace.GetRoot(),
Path: loc,
}