sbp3-streamHandles.py

# Stream listeners


@conn.on(r'trade_updates')
async def trade_updates_handler(conn, chan, data):
    if data.event == "new":
        return ""
    elif data.event == "fill" or data.event == "partial_fill":
        text = f'*Event*: {data.event}, {data.order["type"]} order of | {data.order["side"]} {data.order["qty"]} {data.order["symbol"]} {data.order["time_in_force"]} | {data.event} at {data.price}'
    else:
        text = f'*Event*: {data.event}, {data.order["type"]} order of | {data.order["side"]} {data.order["qty"]} {data.order["symbol"]} {data.order["time_in_force"]} {data.event}'
    response = requests.post(url="https://slack.com/api/chat.postMessage", data={
        "token": config["slack_token"],
        "channel": config["channel"],
        "text": text
    })
    return ""