From f54bb387475cd19e2f8d32cca131e2abb5eea8fd Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sun, 26 Feb 2017 17:17:56 +0100
Subject: pass requested player name to job queue

---
 api.py | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'api.py')

diff --git a/api.py b/api.py
index 8559288..2dfa964 100644
--- a/api.py
+++ b/api.py
@@ -43,6 +43,12 @@ class Worker(object):
         """Finish a job."""
         api = crawler.Crawler(self._apitoken)
         logging.debug("%s: getting matches from API", jobid)
+        # if a player is queried, pass that information to processor
+        if "filter[playerNames]" in payload["params"]:
+            playername = payload["params"]["filter[playerNames]"]
+        else:
+            playername = ""
+
         async with self._pool.acquire() as con:
             async for data in api.matches(region=payload["region"],
                                           params=payload["params"]):
@@ -54,6 +60,7 @@ class Worker(object):
                                               priority=priority,
                                               payload={
                                                   "id": matchid["id"],
+                                                  "playername": playername
                                               })
 
     async def _work(self):
-- 
cgit v1.3.1