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

Merge pull request #2851 from rhafer/issue/2844

Browse Source 
fix: Send SSE events for SpaceCreated/-Disabled/-Deleted
This commit is contained in:
Ralf Haferkamp
2026-05-28 17:02:03 +02:00
committed by GitHub
parent 11b6d7793d 69b9031b2d
commit 31340e30fb
2 changed files with 26 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
services/clientlog/pkg/command/server.go
View File

@@ -34,6 +34,9 @@ var _registeredEvents = []events.Unmarshaller{
events.FileLocked{},
events.FileUnlocked{},
events.FileTouched{},
events.SpaceCreated{},
events.SpaceDeleted{},
events.SpaceDisabled{},
events.SpaceShared{},
events.SpaceShareUpdated{},
events.SpaceUnshared{},

23
services/clientlog/pkg/service/service.go
View File

@@ -131,6 +131,11 @@ func (cl *ClientlogService) processEvent(event events.Event) {
users, data, err = processShareEvent(ctx, ref, gwc, event.InitiatorID, uid, gid)
}
spaceEv := func(typ string, id *provider.StorageSpaceId, uids []string) {
evType = typ
users, data, err = processSpaceEvent(ctx, id, gwc, event.InitiatorID, uids)
}
switch e := event.Event.(type) {
default:
err = errors.New("unhandled event")
@@ -160,6 +165,16 @@ func (cl *ClientlogService) processEvent(event events.Event) {
fileEv("file-unlocked", e.Ref)
case events.FileTouched:
fileEv("file-touched", e.Ref)
case events.SpaceCreated:
spaceEv("space-created", e.ID, []string{e.Executant.GetOpaqueId()})
case events.SpaceDisabled:
spaceEv("space-disabled", e.ID, []string{e.Executant.GetOpaqueId()})
case events.SpaceDeleted:
uids := []string{}
for k := range e.FinalMembers {
uids = append(uids, k)
}
spaceEv("space-deleted", e.ID, uids)
case events.SpaceShared:
r, _ := storagespace.ParseReference(e.ID.GetOpaqueId())
shareEv("space-member-added", &r, e.GranteeUserID, e.GranteeGroupID)
@@ -239,6 +254,14 @@ func processShareEvent(ctx context.Context, ref *provider.Reference, gwc gateway
return addShareeData(ctx, gwc, data, users, shareeID, shareeGroupID)
}
func processSpaceEvent(ctx context.Context, id *provider.StorageSpaceId, gwc gateway.GatewayAPIClient, initiatorid string, uids []string) ([]string, FileEvent, error) {
data := FileEvent{
SpaceID: id.GetOpaqueId(),
InitiatorID: initiatorid,
}
return uids, data, nil
}
// custom logic for item trashed event
func processItemTrashedEvent(ctx context.Context, ref *provider.Reference, gwc gateway.GatewayAPIClient, initiatorid string, itemID *provider.ResourceId) ([]string, FileEvent, error) {
data := FileEvent{