pass requested player name to job queue

1 files changed, 7 insertions, 0 deletions

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):