diff --git a/main.go b/main.go index 704652b..91e208b 100644 --- a/main.go +++ b/main.go @@ -103,11 +103,20 @@ func UploadHandler(w http.ResponseWriter, r *http.Request, pipes []pipelines.IPi return } + // execute pipeline + output, err := execPipe.Run("source.jpg", bucket, storageProvider) + if err != nil { + writeError(w, http.StatusInternalServerError, "error executing pipeline") + return + } + w.Header().Set("Content-Type", "application/json") err = json.NewEncoder(w).Encode(struct { - Message string `json:"message"` - }{"ok"}) + Message string `json:"message"` + OutputFiles []string `json:"output_files"` + }{"ok", []string{output}}) + if err != nil { w.WriteHeader(http.StatusInternalServerError) }