update received share event

Signed-off-by: jkoberg <[email protected]>

internal/grpc/interceptors/eventsmiddleware/conversion.go

@@ -63,6 +63,20 @@ func ShareUpdated(r *collaboration.UpdateShareResponse, req *collaboration.Updat
 	}
 }
 
+// ReceivedShareUpdated converts the response to an event
+func ReceivedShareUpdated(r *collaboration.UpdateReceivedShareResponse) events.ReceivedShareUpdated {
+	return events.ReceivedShareUpdated{
+		ShareID:        r.Share.Share.Id,
+		ItemID:         r.Share.Share.ResourceId,
+		Permissions:    r.Share.Share.Permissions,
+		GranteeUserID:  r.Share.Share.GetGrantee().GetUserId(),
+		GranteeGroupID: r.Share.Share.GetGrantee().GetGroupId(),
+		Sharer:         r.Share.Share.Creator,
+		MTime:          r.Share.Share.Mtime,
+		State:          collaboration.ShareState_name[int32(r.Share.State)],
+	}
+}
+
 // LinkCreated converts the response to an event
 func LinkCreated(r *link.CreatePublicShareResponse) events.LinkCreated {
 	return events.LinkCreated{

internal/grpc/interceptors/eventsmiddleware/events.go

@@ -72,6 +72,10 @@ func NewUnary(m map[string]interface{}) (grpc.UnaryServerInterceptor, int, error
 			if isSuccess(v) {
 				ev = ShareUpdated(v, req.(*collaboration.UpdateShareRequest))
 			}
+		case *collaboration.UpdateReceivedShareResponse:
+			if isSuccess(v) {
+				ev = ReceivedShareUpdated(v)
+			}
 		case *link.CreatePublicShareResponse:
 			if isSuccess(v) {
 				ev = LinkCreated(v)

pkg/events/example/consumer/consumer.go

@@ -37,6 +37,7 @@ func Example(c events.Consumer) {
 		events.ShareCreated{},
 		events.ShareUpdated{},
 		events.ShareRemoved{},
+		events.ReceivedShareUpdated{},
 		events.LinkCreated{},
 		events.LinkUpdated{},
 		events.LinkRemoved{},

pkg/events/types.go

@@ -82,6 +82,26 @@ func (ShareUpdated) Unmarshal(v []byte) (interface{}, error) {
 	return e, err
 }
 
+// ReceivedShareUpdated is emitted when a received share is accepted or declined
+type ReceivedShareUpdated struct {
+	ShareID        *collaboration.ShareId
+	ItemID         *provider.ResourceId
+	Permissions    *collaboration.SharePermissions
+	GranteeUserID  *user.UserId
+	GranteeGroupID *group.GroupId
+	Sharer         *user.UserId
+	MTime          *types.Timestamp
+
+	State string
+}
+
+// Unmarshal to fulfill umarshaller interface
+func (ReceivedShareUpdated) Unmarshal(v []byte) (interface{}, error) {
+	e := ReceivedShareUpdated{}
+	err := json.Unmarshal(v, &e)
+	return e, err
+}
+
 // LinkCreated is emitted when a public link is created
 type LinkCreated struct {
 	ShareID           *link.PublicShareId