Adjust stopLevel using streaming api data

[wki]

Hi, I am trying to update the stops for an existing order using the streaming API.  Working / fledgling code so far:

import time

from ig_streaming_client import IgStreamingSession
from lightstreamer_client import LightstreamerSubscription
api_key = ""; account_id = ''; rest_api_username = ""; rest_api_password = ""

session = IgStreamingSession(api_key, account_id, rest_api_username, rest_api_password)

subscription = LightstreamerSubscription('MERGE',
                                         ['MARKET:CS.D.BITCOIN.TODAY.IP'],
                                         ['UPDATE_TIME', 'BID', 'OFFER'])

print(subscription.addlistener(lambda item: print(item['values']['OFFER']))) #####thisone
session.subscribe(subscription)

time.sleep(10)

session.log_out()

This successfully prints out the latest offer prices for 10 seconds. However, I am struggling to figure out how to take the real time offer values from the streaming data and check against my current order stopLevel and change the stopLevel if the streaming offer price goes below my threshold.

For the #####thisone line above, I am needing something like this (58000 is my threshold):

if subscription.addlistener(lambda item: item['values']['OFFER']) < 58000:
    ig_service.update_open_position(limit_level = None, stop_level = 58100, deal_id = dealId)

Massive gap in my streaming api knowledge I accept but any help would be appreciated.  There does not seem to be much out there that uses streaming data and "does stuff" with the outputs, apart from displaying in an html of course.

Edited April 3, 2021 by wki

[wki]

ok I think I have figured out how to extract the value from lightstreamer and then do something with it.  I pass the streaming item through a function that extracts the appropriate value from the item, adds this value to a list, looks at the last item of that list and does something based on that value. Seems to work ok...

lst = []
def add2list(item):
    val = float(item['values']['OFFER'])
    lst.append(val)
    if lst[-1] < 58000:
        return print('below',lst[-1])
    else:
        return print('above',lst[-1])

session = IgStreamingSession(api_key, account_id, rest_api_username, rest_api_password)

subscription = LightstreamerSubscription('MERGE',
                                         ['MARKET:CS.D.BITCOIN.TODAY.IP'],
                                         ['UPDATE_TIME', 'BID', 'OFFER'])
subscription.addlistener(lambda item: add2list(item))

[Panda_don]

Hey,

See you are using the same a me and am wondering about two things:

1) do you know how to unsubscribe from the subscription just made
2) how to update the subscription eg. from bitcoin to ethereum