Switch to amqtt

BananoCoin · Apr 5, 2021 · 4d04a80 · 4d04a80 · yhca · Apr 8, 2021
1 parent 0626961
commit 4d04a80
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/client/bpow_client.py b/client/bpow_client.py
@@ -7,8 +7,8 @@
 import asyncio
 import math
 from time import time
-from hbmqtt.client import MQTTClient, ClientException, ConnectException
-from hbmqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
+from amqtt.client import MQTTClient, ClientException, ConnectException
+from amqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
 
 from logger import get_logger
 from work_handler import WorkHandler

diff --git a/client/requirements.txt b/client/requirements.txt
@@ -1,4 +1,4 @@
-hbmqtt
+amqtt
 aiohttp
 requests
 
diff --git a/server/bpow/mqtt.py b/server/bpow/mqtt.py
@@ -4,8 +4,8 @@
 import json
 import logging
 from bpow.redis_db import BpowRedis
-from hbmqtt.client import MQTTClient, ClientException, ConnectException
-from hbmqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
+from amqtt.client import MQTTClient, ClientException, ConnectException
+from amqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
 
 class BpowMQTT(object):
 

diff --git a/server/bpow_server.py b/server/bpow_server.py
@@ -14,7 +14,7 @@
 from collections import defaultdict
 from asyncio_throttle import Throttler
 from aiohttp import web, WSMsgType
-from hbmqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
+from amqtt.mqtt.constants import QOS_0, QOS_1, QOS_2
 from random import randint
 
 asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())

diff --git a/server/kubernetes/bpow/payment_cron.yaml b/server/kubernetes/bpow/payment_cron.yaml
@@ -13,7 +13,7 @@ spec:
           - name: boompow
             image: replaceme
             command: ["/bin/bash", "-c"]
-            args: ["python payment_processor.py --node http://pippin-banano.pippin:11338 --wallet $(WALLET_ID) --dry_run"]
+            args: ["python payment_processor.py --node http://pippin-banano.pippin:11338 --wallet $(WALLET_ID)"]
             env:
               - name: REDIS_HOST
                 value: redis-0.redis

diff --git a/server/requirements.txt b/server/requirements.txt
@@ -2,7 +2,7 @@ ujson
 uvloop
 aiohttp
 aioredis
-hbmqtt
+amqtt
 websockets
 requests
 asyncio-throttle