btfxwss/queue_processor.py
def _handle_subscribed(self, dtype, data, ts,):
        """Handles responses to subscribe() commands.

        Registers a channel id with the client and assigns a data handler to it.

        :param dtype:
        :param data:
        :param ts:
        :return:
        """
        self.log.debug("_handle_subscribed: %s - %s - %s", dtype, data, ts)
        channel_name = data.pop('channel')
        channel_id = data.pop('chanId')
        config = data

        if 'pair' in config:
            symbol = config['pair']
            if symbol.startswith('t'):
                symbol = symbol[1:]
        elif 'symbol' in config:
            symbol = config['symbol']
            if symbol.startswith('t'):
                symbol = symbol[1:]
        elif 'key' in config:
            symbol = config['key'].split(':')[2][1:]  #layout type:interval:tPair
        else:
            symbol = None

        if 'prec' in config and config['prec'].startswith('R'):
            channel_name = 'raw_' + channel_name

        self.channel_handlers[channel_id] = self._data_handlers[channel_name]

        # Create a channel_name, symbol tuple to identify channels of same type
        if 'key' in config:
            identifier = (channel_name, symbol, config['key'].split(':')[1])
        else:
            identifier = (channel_name, symbol)
        self.channel_handlers[channel_id] = identifier
        self.channel_directory[identifier] = channel_id
        self.channel_directory[channel_id] = identifier
        self.log.info("Subscription succesful for channel %s", identifier)
def _handle_subscribed(self, dtype, data, ts,):
        """Handles responses to subscribe() commands.

        Registers a channel id with the client and assigns a data handler to it.

        :param dtype:
        :param data:
        :param ts:
        :return:
        """
        self.log.debug("_handle_subscribed: %s - %s - %s", dtype, data, ts)
        channel_name = data.pop('channel')
        channel_id = data.pop('chanId')
        config = data

        if 'pair' in config:
            symbol = config['pair']
            if symbol.startswith('t'):
                symbol = symbol[1:]
        elif 'symbol' in config:
            symbol = config['symbol']
            if symbol.startswith('t'):
                symbol = symbol[1:]
        elif 'key' in config:
            symbol = config['key'].split(':')[2][1:]  #layout type:interval:tPair
        else:
            symbol = None

        if 'prec' in config and config['prec'].startswith('R'):
            channel_name = 'raw_' + channel_name

        self.channel_handlers[channel_id] = self._data_handlers[channel_name]

        # Create a channel_name, symbol tuple to identify channels of same type
        if 'key' in config:
            identifier = (channel_name, symbol, config['key'].split(':')[1])
        else:
            identifier = (channel_name, symbol)
        self.channel_handlers[channel_id] = identifier
        self.channel_directory[identifier] = channel_id
        self.channel_directory[channel_id] = identifier
        self.log.info("Subscription succesful for channel %s", identifier)
def _handle_subscribed ( self , dtype , data , ts , ) : self . log . debug ( "_handle_subscribed: %s - %s - %s" , dtype , data , ts ) channel_name = data . pop ( 'channel' ) channel_id = data . pop ( 'chanId' ) config = data if 'pair' in config : symbol = config [ 'pair' ] if symbol . startswith ( 't' ) : symbol = symbol [ 1 : ] elif 'symbol' in config : symbol = config [ 'symbol' ] if symbol . startswith ( 't' ) : symbol = symbol [ 1 : ] elif 'key' in config : symbol = config [ 'key' ] . split ( ':' ) [ 2 ] [ 1 : ] #layout type:interval:tPair else : symbol = None if 'prec' in config and config [ 'prec' ] . startswith ( 'R' ) : channel_name = 'raw_' + channel_name self . channel_handlers [ channel_id ] = self . _data_handlers [ channel_name ] # Create a channel_name, symbol tuple to identify channels of same type if 'key' in config : identifier = ( channel_name , symbol , config [ 'key' ] . split ( ':' ) [ 1 ] ) else : identifier = ( channel_name , symbol ) self . channel_handlers [ channel_id ] = identifier self . channel_directory [ identifier ] = channel_id self . channel_directory [ channel_id ] = identifier self . log . info ( "Subscription succesful for channel %s" , identifier )
Handles responses to subscribe() commands.

        Registers a channel id with the client and assigns a data handler to it.

        :param dtype:
        :param data:
        :param ts:
        :return:
Handles responses to subscribe () commands .