From 454cba195536540120ded6424c937204a0ad55e7 Mon Sep 17 00:00:00 2001
From: Janne Koschinski <janne@kuschku.de>
Date: Sat, 17 Mar 2018 21:51:28 +0100
Subject: [PATCH] Fixed multi-upload
---
main.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/main.go b/main.go
index 71d935d..6f0fa59 100644
--- a/main.go
+++ b/main.go
@@ -180,7 +180,7 @@ func main() {
}
pubsub := client.Subscribe(config.ResultChannel)
-
+ waiting := make(map[string]bool)
for _, image := range images {
_, err = db.Exec("INSERT INTO images (id, owner, created_at, original_name, type) VALUES ($1, $2, $3, $4, $5)", image.Id, user.Id, image.CreatedAt, image.OriginalName, image.MimeType)
if err != nil {
@@ -204,11 +204,11 @@ func main() {
fmt.Printf("Created task %s at %d\n", image.Id, time.Now().Unix())
client.RPush(fmt.Sprintf("queue:%s", config.ImageQueue), data)
fmt.Printf("Submitted task %s at %d\n", image.Id, time.Now().Unix())
+
+ waiting[image.Id] = true
}
var results []Result
-
- var waiting map[string]bool
for len(waiting) != 0 {
message, err := pubsub.ReceiveMessage()
if err != nil {
--
GitLab