From 72082994e4019b93db4780180f47ea4b7a52d959 Mon Sep 17 00:00:00 2001 From: cheetah Date: Fri, 28 Jul 2023 02:39:41 -0500 Subject: [PATCH] fixing major fuckup --- main.go | 26 ++++++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/main.go b/main.go index 89b3247..c5f23a9 100644 --- a/main.go +++ b/main.go @@ -636,6 +636,32 @@ func ProcessGMA(pw progress.Writer, filePath string) (err error) { //fmt.Printf("res.StatusCode = %d\n", res.StatusCode) if res.StatusCode == http.StatusAlreadyReported { trackerUpload.UpdateMessage(fmt.Sprintf("Skipping %s", niceName)) + + for _, dboGMA2File := range dboGMA2Files { + if dboFileID == dboGMA2File.File { + // Create File and dboGMA2File Object + exists, err := colGMA2File.DocumentExists(arangoCTX, dboGMA2File.ID) + if err != nil { + log.Println("err @colGMA2File.DocumentExists") + log.Println("oopsie") + undoBatch(true, dboGMA.ID, fileIDs, gma2FileIDs) + trackerUpload.MarkAsErrored() + return err + } + if !exists { + _, err = colGMA2File.CreateDocument(arangoCTX, dboGMA2File) + if err != nil { + log.Println("err @colGMA2File.CreateDocument") + log.Println("oopsie") + undoBatch(true, dboGMA.ID, fileIDs, gma2FileIDs) + trackerUpload.MarkAsErrored() + return err + } + } + break + } + } + trackerUpload.Increment(1) continue }