UBERF-12153 Transcode only created blobs (#24)

internal/pkg/queue/queue.go

@@ -36,14 +36,16 @@ type TranscodeRequest struct {
 	BlobID        string
 	WorkspaceUUID string
 	ContentType   string
+	Source        map[string]any
 }
 
 // TranscodeResult represents transcode result.
 type TranscodeResult struct {
-	BlobID        string `json:"blobId"`
-	WorkspaceUUID string `json:"workspaceUuid"`
-	Playlist      string `json:"playlist"`
-	Thumbnail     string `json:"thumbnail"`
+	BlobID        string         `json:"blobId"`
+	WorkspaceUUID string         `json:"workspaceUuid"`
+	Source        map[string]any `json:"source"`
+	Playlist      string         `json:"playlist"`
+	Thumbnail     string         `json:"thumbnail"`
 }
 
 // ConsumerOptions represents options for the consumer

internal/pkg/queue/worker.go

@@ -115,6 +115,7 @@ func (w *Worker) processMessage(ctx context.Context, msg kafka.Message, logger *
 		result := TranscodeResult{
 			BlobID:        req.BlobID,
 			WorkspaceUUID: req.WorkspaceUUID,
+			Source:        req.Source,
 			Playlist:      res.Playlist,
 			Thumbnail:     res.Thumbnail,
 		}