Add pubsub app

Author: heykarimoff

Makefile

@@ -9,13 +9,13 @@ build:
 	docker-compose build
 
 up:
-	docker-compose up -d app
+	docker-compose up -d
 
 down:
 	docker-compose down
 
 logs:
-	docker-compose logs --tail=100 app
+	docker-compose logs --tail=100
 
 test: up test-e2e test-integration test-unit
 

docker-compose.yml

@@ -1,6 +1,7 @@
 version: "3"
 services:
   app:
+    image: consmicpython/app
     build:
       context: .
       dockerfile: Dockerfile
@@ -19,6 +20,27 @@ services:
     ports:
       - "5005:80"
 
+  pubsub:
+    image: consmicpython/pubsub
+    build:
+      context: .
+      dockerfile: Dockerfile
+    depends_on:
+      - postgres
+      - redis
+    environment:
+      - DB_HOST=postgres
+      - DB_PASSWORD=abc123
+      - API_HOST=pubsub
+      - REDIS_HOST=redis
+      - PYTHONDONTWRITEBYTECODE=1
+    volumes:
+      - ./src:/src
+      - ./tests:/tests
+    entrypoint:
+      - python
+      - /src/allocation/entrypoints/event_consumer.py
+
   postgres:
     image: postgres:9.6
     environment:

src/allocation/entrypoints/event_consumer.py

@@ -5,7 +5,7 @@
 from allocation.domain import commands
 from redis import Redis
 
-logger = logging.getLevelName(__name__)
+logger = logging.getLogger(__name__)
 redis_client = Redis(**config.get_redis_host_and_port())
 
 
@@ -21,7 +21,7 @@ def main():
 
 def handle_change_batch_quantity(message, messagebus):
     data = json.loads(message["data"])
-    command = commands.ChangeBatchQuantity(data["reference"], data["qty"])
+    command = commands.ChangeBatchQuantity(data["batchref"], data["qty"])
     messagebus.handle(message=command)