IGS streamer help, need help with a little code

[LordNadimi]

Hi all

I am quite stuck on this, and any tip that solves the issue will be greatly appreciated.

    def handle_trades_update(deal_status):
        global trade
        if deal_status["name"] == "TRADE:" + config.acc_number:
            print("DealStatus: %s " % deal_status)
            current_deal_status = deal_status["values"]["status"]
            trade.append(current_deal_status)

       ig_stream_service = IGStreamService(ig_service)
        ig_stream_service.create_session()
        subscription_prices = Subscription(
            mode="MERGE",
            items=["MARKET:" + epic],
            fields=["UPDATE_TIME", "BID", "OFFER"],
        )
        # Adding the "handle_streaming_data" function to Subscription
        subscription_prices.addlistener(handle_streaming_data)
        # Registering the Subscription
        sub_key_prices = ig_stream_service.ls_client.subscribe(subscription_prices)

        # subscribe to the TRADES topic
        subscription_trades = Subscription(
            mode="DISTINCT",
            items=["TRADE:" + config.acc_number],
            fields=["direction", "dealStatus", "status"],
        )
        # add a handler for CONFIRMS updates
        subscription_trades.addlistener(handle_trades_update)

        sub_key_trades = ig_stream_service.ls_client.subscribe(subscription_trades)

Bla bla bla lots of other code

        if trade and trade[-1] == 'OPEN':
            sub_routine_trigger = 1`

The point being:
I need to have my script change the sub_routine_trigger = 1 each time trade gets an update to "OPEN"

[LordNadimi]

Took me some time, but I managed to crack this one as well! Learning by trying (again and again)!! For anyone else ever needing some assistance here is the code

from trading_ig import IGService, IGStreamService
from trading_ig.config import config
from trading_ig.lightstreamer import Subscription
import json

def handle_trades_update(trades_update):
    if trades_update["name"] == "TRADE:" + config.acc_number:
        opu_data = trades_update["values"]["OPU"]
    if opu_data is not None:
        opu_data = json.loads(opu_data)
        deal_id = opu_data["dealId"]
        current_trade_status = opu_data["status"]
        current_trade_direction = opu_data["direction"]
        
# subscribe to the TRADES topic
subscription_trades = Subscription(
    mode="DISTINCT",
    items=["TRADE:" + config.acc_number],
    fields=["OPU"],
    )
# add a listener for OPU updates
subscription_trades.addlistener(handle_trades_update)

sub_key_trades = ig_stream_service.ls_client.subscribe(subscription_trades)