From c5a1c8d9ca67f6dd3cc139ab9bb0782701f560bd Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sat, 5 Aug 2017 16:31:20 +0200
Subject: add env var to auto telesuck

---
 worker.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/worker.py b/worker.py
index 9b0c9ef..591a39e 100644
--- a/worker.py
+++ b/worker.py
@@ -22,6 +22,8 @@ IDLE_TIMEOUT = float(os.environ.get("IDLE_TIMEOUT") or 1)  # s
 QUEUE = os.environ.get("QUEUE") or "analyze"
 DOCRUNCHMATCH = os.environ.get("DOCRUNCHMATCH") == "true"
 CRUNCH_PLAYER_QUEUE = os.environ.get("CRUNCH_PLAYER_QUEUE") or "crunch_player"
+DOTELESUCKMATCH = os.environ.get("DOTELESUCKMATCH") == "true"
+TELESUCK_QUEUE = os.environ.get("TELESUCK_QUEUE") or "telesuck"
 
 # mapping from Tier (-1 - 30) to average skill tier points
 vst_points = {
@@ -136,6 +138,12 @@ def try_process():
                                   routing_key=CRUNCH_PLAYER_QUEUE,
                                   body=body,
                                   properties=prop)
+        if DOTELESUCKMATCH:
+            # forward to telesucker
+            channel.basic_publish(exchange="",
+                                  routing_key=TELESUCK_QUEUE,
+                                  body=body,
+                                  properties=prop)
     queue = []
 
 
-- 
cgit v1.3.1