diff --git a/changelog/unreleased/resume-postprocessing-event.md b/changelog/unreleased/resume-postprocessing-event.md new file mode 100644 index 0000000000..81ca456e92 --- /dev/null +++ b/changelog/unreleased/resume-postprocessing-event.md @@ -0,0 +1,5 @@ +Enhancement: ResumePostprocessing Event + +Add a new event: `ResumePostprocessing`. It can be emitted to repair broken postprocessing + +https://github.com/cs3org/reva/pull/3965 diff --git a/pkg/events/postprocessing.go b/pkg/events/postprocessing.go index 74968e28e3..0b01050112 100644 --- a/pkg/events/postprocessing.go +++ b/pkg/events/postprocessing.go @@ -171,3 +171,16 @@ func (UploadReady) Unmarshal(v []byte) (interface{}, error) { err := json.Unmarshal(v, &e) return e, err } + +// ResumePostprocessing can be emitted to repair broken postprocessing +type ResumePostprocessing struct { + UploadID string + Timestamp *types.Timestamp +} + +// Unmarshal to fulfill umarshaller interface +func (ResumePostprocessing) Unmarshal(v []byte) (interface{}, error) { + e := ResumePostprocessing{} + err := json.Unmarshal(v, &e) + return e, err +}