mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-04-28 11:18:24 -04:00
Code Issues Packages Projects Releases Wiki Activity

pass upload data to storageclient

Browse Source 
Signed-off-by: Christian Richter <c.richter@opencloud.eu>
This commit is contained in:
Christian Richter
2025-05-14 11:12:24 +02:00
committed by Florian Schade
parent df93ea4649
commit 0f5855cef4
2 changed files with 23 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/systemstorageclient/systemstorageclient.go
View File

@@ -2,6 +2,7 @@ package systemstorageclient
import (
"context"
"fmt"
"github.com/opencloud-eu/opencloud/pkg/log"
"github.com/opencloud-eu/reva/v2/pkg/storage/utils/metadata"
@@ -17,8 +18,8 @@ func (s SystemDataStorageClient) SimpleDownload(ctx context.Context, userID, ide
}
func (s SystemDataStorageClient) SimpleUpload(ctx context.Context, userID, identifier string, content []byte) error {
//TODO implement me
panic("implement me")
fmt.Println(content)
return nil
}
func (s SystemDataStorageClient) Delete(ctx context.Context, userID, identifier string) error {

23
services/graph/pkg/service/v0/photo.go
View File

@@ -7,6 +7,7 @@ import (
"github.com/opencloud-eu/opencloud/pkg/systemstorageclient"
"github.com/opencloud-eu/opencloud/services/graph/pkg/errorcode"
revactx "github.com/opencloud-eu/reva/v2/pkg/ctx"
"io"
"net/http"
"net/url"
)
@@ -89,14 +90,30 @@ func (g Graph) UpdatePhoto(w http.ResponseWriter, r *http.Request) {
func (g Graph) updatePhoto(w http.ResponseWriter, r *http.Request, u *userpb.UserId) {
logger := g.logger.SubloggerWithRequestID(r.Context())
logger.Debug().Msg("UpdatePhoto called")
content, err := io.ReadAll(r.Body)
if err != nil {
logger.Debug().Err(err).Msg("could not read body")
errorcode.InvalidRequest.Render(w, r, http.StatusBadRequest, "could not read body")
return
}
if len(content) == 0 {
logger.Debug().Msg("could not read body: empty body")
errorcode.InvalidRequest.Render(w, r, http.StatusBadRequest, "empty body")
return
}
g.getSystemStorageClient()
g.sdsc.SimpleUpload(r.Context(), u.GetOpaqueId(), identifier, []byte("test"))
// TODO: use proper default return
render.Status(r, http.StatusForbidden)
err = g.sdsc.SimpleUpload(r.Context(), u.GetOpaqueId(), identifier, content)
if err != nil {
logger.Debug().Err(err).Msg("could not upload photo")
errorcode.GeneralException.Render(w, r, http.StatusInternalServerError, "could not upload photo")
return
}
render.Status(r, http.StatusOK)
render.JSON(w, r, nil)
}
func (g Graph) getSystemStorageClient() systemstorageclient.SystemDataStorageClient {
// TODO: this needs a check if the client is already initialized and if not, initialize it
g.sdsc = systemstorageclient.NewSystemStorageClient(
namespace,
g.logger,