Steem engine market discord notifications (requires redis, meeseeker, webcord)

marketwatch.py

from webcord import Webhook
import redis
import json
import time
palwebhook = Webhook("URLHERE", avatar_url=None)
paltokens = ['PAL','PALM','PALMM']
r = redis.Redis()

def buy(message):
	data = message['data'].decode()
	jsondata = json.loads(data)
	key = jsondata['key']
	tx = json.loads(r.get(key).decode())
	payload = tx['payload']
	payload = json.loads(payload)
	print(tx['sender'], 'bought ', payload['quantity'], ' ', payload['symbol'], ' for ', payload['price'], ' steem each')
	msg = ":arrow_up_small: ***" + tx['sender'] + "*** bids **`" + payload['price'] + "`** STEEM for **" + payload['quantity'] + "** " + payload['symbol']
	if payload['symbol'] in paltokens:
		palwebhook.send_message(msg,"PALmarket")
		
def sell(message):
	data = message['data'].decode()
	jsondata = json.loads(data)
	key = jsondata['key']
	tx = json.loads(r.get(key).decode())
	payload = tx['payload']
	payload = json.loads(payload)
	print(tx['sender'], 'sold ', payload['quantity'], ' ', payload['symbol'], ' for ', payload['price'], ' steem each')
	msg = ":small_red_triangle_down: ***" + tx['sender'] + "*** asks **`" + payload['price'] + "`** STEEM for **" + payload['quantity'] + "** " + payload['symbol']
	if payload['symbol'] in paltokens:
		palwebhook.send_message(msg,"PALmarket")

b = r.pubsub(ignore_subscribe_messages=True)
b.subscribe(**{'steem_engine:market:buy': buy})
buythread = b.run_in_thread(sleep_time=0.001)
print('Subscribed to steem engine buys')

s = r.pubsub(ignore_subscribe_messages=True)
s.subscribe(**{'steem_engine:market:sell': sell})
sellthread = s.run_in_thread(sleep_time=0.001)
print('Subscribed to steem engine sells')