diff --git a/mapper.go b/mapper.go index 88a285e..f69d40d 100644 --- a/mapper.go +++ b/mapper.go @@ -10,7 +10,8 @@ import ( ) const ( - videoUUIDField = "id" + videoUUIDField = "uuid" + videoIDField = "id" relatedField = "related" deletedField = "deleted" relatedItemIDField = "uuid" @@ -28,7 +29,15 @@ type relatedContentMapper struct { } func (m *relatedContentMapper) mapRelatedContent() ([]byte, string, error) { - videoUUID, err := getRequiredStringField(videoUUIDField, m.unmarshalled) + var uuidField string + + if m.isDeleteEvent() { + uuidField = videoUUIDField + } else { + uuidField = videoIDField + } + + videoUUID, err := getRequiredStringField(uuidField, m.unmarshalled) if err != nil { return nil, "", err } diff --git a/test-resources/next-video-delete-input.json b/test-resources/next-video-delete-input.json index 7449fed..646f9fb 100644 --- a/test-resources/next-video-delete-input.json +++ b/test-resources/next-video-delete-input.json @@ -1 +1,7 @@ -{"deleted": true,"lastModified": "2017-04-04T14:42:58.920Z","publishReference": "tid_bycjmmcj4r","type": "video","id": "e2290d14-7e80-4db8-a715-949da4de9a07"} \ No newline at end of file +{ + "deleted": true, + "lastModified": "2017-04-04T14:42:58.920Z", + "publishReference": "tid_bycjmmcj4r", + "type": "video", + "uuid": "e2290d14-7e80-4db8-a715-949da4de9a07" +}