diff --git a/.deploy/deploy-dev.yaml b/.deploy/deploy-dev.yaml index 302ba1d..676403b 100644 --- a/.deploy/deploy-dev.yaml +++ b/.deploy/deploy-dev.yaml @@ -6,6 +6,8 @@ services: image: mathwave/sprint-repo:queues networks: - queues-development + ports: + - 1239:1239 environment: MONGO_HOST: "mongo.develop.sprinthub.ru" MONGO_PASSWORD: $MONGO_PASSWORD_DEV diff --git a/app/routers/take.go b/app/routers/take.go index 7545cc7..90e4545 100644 --- a/app/routers/take.go +++ b/app/routers/take.go @@ -20,6 +20,7 @@ func Take(w http.ResponseWriter, r *http.Request) { queue := r.Header.Get("queue") task, err := tasks.Take(queue) if err != nil { + println("Error taking") w.WriteHeader(http.StatusInternalServerError) return } @@ -37,6 +38,7 @@ func Take(w http.ResponseWriter, r *http.Request) { data, err := json.Marshal(response) if err != nil { + println("Error marshalling") w.WriteHeader(http.StatusInternalServerError) return } diff --git a/app/storage/mongo/collections/tasks.go b/app/storage/mongo/collections/tasks.go index a479d4c..089a65a 100644 --- a/app/storage/mongo/collections/tasks.go +++ b/app/storage/mongo/collections/tasks.go @@ -64,6 +64,8 @@ func Take(queue string) (*Task, error) { } _, err = collection().UpdateByID(context.TODO(), task.Id, bson.M{"$set": bson.M{"taken_at": now, "attempts": task.Attempts + 1}}) if err != nil { + println("Error updaing") + println(err.Error()) return nil, errors.ErrInternalError } return task, nil @@ -78,12 +80,16 @@ func findTask(queue string, now time.Time) (*Task, error) { }, ) if err != nil { + println("Error find") + println(err.Error()) return nil, errors.ErrInternalError } var results []Task err = cursor.All(context.TODO(), &results) if err != nil { + println("Error all") + println(err.Error()) return nil, errors.ErrInternalError }