From 10a205e97d399d1736fd9c806e1e309bb31ff28d Mon Sep 17 00:00:00 2001 From: Christopher Baklid Date: Thu, 24 May 2018 21:45:25 +0200 Subject: generate new queue based on session id to lock user to their own event chain --- snekbox.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'snekbox.py') diff --git a/snekbox.py b/snekbox.py index b58447e..4dfcc48 100644 --- a/snekbox.py +++ b/snekbox.py @@ -3,6 +3,7 @@ import sys import time import pika import io +import json from rmq.consumer import consume from rmq.publisher import publish @@ -39,9 +40,11 @@ def message_handler(ch, method, properties, body): # Execute code snippets here print(f"incoming: {msg}", flush=True) - result = execute(msg) - print(f"outgoing: {result}", flush=True) - publish(result, host=HOST, queue=RETURN_QUEUE, routingkey=RETURN_ROUTING_KEY, exchange=RETURN_EXCHANGE, exchange_type=EXCHANGE_TYPE) + snek_msg = json.loads(msg) + for snekid, snekcode in snek_msg.items(): + result = execute(snekcode) + print(f"outgoing: {result}", flush=True) + publish(result, host=HOST, queue=snekid, routingkey=snekid, exchange=snekid, exchange_type=EXCHANGE_TYPE) ch.basic_ack(delivery_tag = method.delivery_tag) -- cgit v1.2.3