implement simple sample downloads

1 files changed, 14 insertions, 1 deletions

diff --git a/server.js b/server.js
index c921d00..e16090a 100644
--- a/server.js
+++ b/server.js
@@ -60,7 +60,7 @@ function requestUpdate(name, region, last_match_created_date, id) {
     };
     console.log("requesting update for", name, region);
     return ch.sendToQueue("grab", new Buffer(JSON.stringify(payload)),
-        { persistent: true });
+        { persistent: true, type: "matches" });
 }
 
 // search for player name on all shards
@@ -159,6 +159,19 @@ app.post("/api/player", async (req, res) => {
     await updatePlayer(player);
     res.json(player);
 });
+// download sample sets
+// (TODO download only samples since last update)
+app.post("/api/samples", async (req, res) => {
+    await ch.sendToQueue("grab", new Buffer(
+        JSON.stringify({
+            region: "eu",
+            params: {
+                sort: "-createdAt"
+            }
+        })),
+        { persistent: true, type: "samples" });
+    res.sendStatus(204);
+});
 
 // crunch data
 app.post("/api/stats/:dimension_on/update", async (req, res) => {