summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-13 15:21:49 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-13 15:21:49 +0200
commitee5873da3d2167a38e9f5b77fbb5f9a04ce8d781 (patch)
tree630d9e8371cba48f39d4de217c2f5c090d18e95d
parentc2fbfa06eb48240033c22ffedac0afd425199348 (diff)
downloadapigrabber-ee5873da3d2167a38e9f5b77fbb5f9a04ce8d781.tar.gz
apigrabber-ee5873da3d2167a38e9f5b77fbb5f9a04ce8d781.zip
notify for grab_done at the end instead of grab_fail
-rw-r--r--worker.js4
1 files changed, 2 insertions, 2 deletions
diff --git a/worker.js b/worker.js
index 7e30db7..3301ce2 100644
--- a/worker.js
+++ b/worker.js
@@ -102,14 +102,14 @@ if (MADGLORY_TOKEN == undefined) throw "Need an API token";
}
console.log(err.statusCode);
failed = true;
- await ch.publish("amq.topic", notify,
- new Buffer("grab_failed"));
}
// next page
if (!failed)
payload.params["page[offset]"] += payload.params["page[limit]"]
}
+ await ch.publish("amq.topic", notify,
+ new Buffer("grab_done"));
}
// download a sample ZIP and send to processor