From 9c640db98ac68bae9b77b5b36240957fb86f05f8 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Mon, 10 Apr 2017 19:25:52 +0200
Subject: add cruncher API

---
 server.js | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

(limited to 'server.js')

diff --git a/server.js b/server.js
index 3dddb38..235723d 100644
--- a/server.js
+++ b/server.js
@@ -28,6 +28,7 @@ var rabbit, ch, seq,
             ch = await rabbit.createChannel();
             await ch.assertQueue("grab", {durable: true});
             await ch.assertQueue("process", {durable: true});
+            await ch.assertQueue("crunch", {durable: true});
             break;
         } catch (err) {
             console.error(err);
@@ -158,6 +159,19 @@ app.post("/api/player/:name/update", async (req, res) => {
     await updatePlayer(player);
     res.sendStatus(204);
 });
+// crunch a known user
+app.post("/api/player/:name/crunch", async (req, res) => {
+    let player = await model.Player.findOne({ where: { name: req.params.name } });
+    if (player == undefined) {
+        console.log("player not found in db, won't crunch", req.params.name);
+        res.sendStatus(404);
+        return;
+    }
+    console.log("player in db, crunching", req.params.name);
+    await ch.sendToQueue("crunch", new Buffer(player.api_id),
+        { persistent: true, type: "player" });
+    res.sendStatus(204);
+});
 // update a random user
 app.post("/api/player", async (req, res) => {
     let player = await model.Player.findOne({ order: [ Seq.fn("RAND") ] });
-- 
cgit v1.3.1