diff --git a/changelog/unreleased/link-sses.md b/changelog/unreleased/link-sses.md new file mode 100644 index 0000000000..6ac8fbb3d0 --- /dev/null +++ b/changelog/unreleased/link-sses.md @@ -0,0 +1,5 @@ +Enhancement: Add Link SSEs + +Add sses for link created/updated/removed. + +https://github.com/owncloud/ocis/pull/8908 diff --git a/services/clientlog/pkg/command/server.go b/services/clientlog/pkg/command/server.go index 7c41e7a36e..0723a7485a 100644 --- a/services/clientlog/pkg/command/server.go +++ b/services/clientlog/pkg/command/server.go @@ -39,6 +39,9 @@ var _registeredEvents = []events.Unmarshaller{ events.ShareCreated{}, events.ShareRemoved{}, events.ShareUpdated{}, + events.LinkCreated{}, + events.LinkUpdated{}, + events.LinkRemoved{}, } // Server is the entrypoint for the server command. diff --git a/services/clientlog/pkg/service/service.go b/services/clientlog/pkg/service/service.go index 841b13e3f4..70341aa30f 100644 --- a/services/clientlog/pkg/service/service.go +++ b/services/clientlog/pkg/service/service.go @@ -177,6 +177,12 @@ func (cl *ClientlogService) processEvent(event events.Event) { case events.ShareRemoved: p("share-removed", &provider.Reference{ResourceId: e.ItemID}) users, err = addSharees(ctx, users, gwc, e.GranteeUserID, e.GranteeGroupID) + case events.LinkCreated: + p("link-created", &provider.Reference{ResourceId: e.ItemID}) + case events.LinkUpdated: + p("link-updated", &provider.Reference{ResourceId: e.ItemID}) + case events.LinkRemoved: + p("link-removed", &provider.Reference{ResourceId: e.ItemID}) } if err != nil {