Real-Time WebSocket API: Refinitiv Real-Time Optimized Version 2 Authentication Migration Guide

    	
            auth_url = 'https://api.refinitiv.com/auth/oauth2/v2/token'
        
        Copy
    

    	
            
def get_auth_token(url=None):
    """
    Retrieves an authentication token.
    """
 
    if url is None:
        url = auth_url
 
    data = {'grant_type': 'client_credentials', 'scope': scope, 'client_id': clientid, 'client_secret': client_secret}
 
    print("\n" + str(datetime.now()) + \
            " Sending authentication request with client credentials to ", url, "...\n")
    try:
        # Request with auth for https protocol    
        r = requests.post(url,
                headers={'Accept' : 'application/json'},
                          data=data,
                          verify=True,
                          allow_redirects=False)
 
    except requests.exceptions.RequestException as e:
        print('Refinitiv Data Platform authentication exception failure:', e)
        return None, None

        
        Copy
    

    	
            if r.status_code == 200:

    auth_json = r.json()

    print(str(datetime.now()) + " Refinitiv Data Platform Authentication succeeded. RECEIVED:")

    print(json.dumps(auth_json, sort_keys=True, indent=2, separators=(',', ':')))

    return auth_json['access_token'], auth_json['expires_in']
        
        Copy
    

    	
            try:

      r = requests.get(url, headers={"Authorization": "Bearer " + auth_token}, params={"transport": "websocket"}, allow_redirects=False)



except requests.exceptions.RequestException as e:

      print('Refinitiv Data Platform service discovery exception failure:', e)

      return False
        
        Copy
    

    	
            
{
    "ID": 1,
    "Domain": "Login",
    "Key": {
        "NameType": "AuthnToken",
        "Elements": {
            "ApplicationId": "<APP ID>",
            "Position": "<Position>",
            "AuthenticationToken": "<Access Token>"
        }
    }
}

        
        Copy
    

    	
            
def _send_login_request(self, authn_token):
  """
  Send login request with authentication token.
  Used both for the initial login and subsequent reissues to update the authentication token
  """
  login_json = {
    'ID': 1,
    'Domain': 'Login',
      'Key': {
        'NameType': 'AuthnToken',
        'Elements': {
          'ApplicationId': '',
          'Position': '',
          'AuthenticationToken': ''
          }
        }
      }
 
  login_json['Key']['Elements']['ApplicationId'] = app_id
  login_json['Key']['Elements']['Position'] = position
  login_json['Key']['Elements']['AuthenticationToken'] = authn_token
 
  self.web_socket_app.send(json.dumps(login_json))

        
        Copy
    

    	
            
while True:
  # NOTE about connection recovery: When connecting or reconnecting 
  #   to the server, a valid token must be used. Upon being disconnecting, initial 
  #   reconnect attempt must be done with  a new token.
  #   If a successful reconnect takes longer than token expiration time, 
  #   a new token must be obtained proactively. 
 
  # Waiting a few seconds before checking for connection down and attempting reconnect
  time.sleep(4)
  if not session1.web_socket_open or ( session2 and not session2.web_socket_open ) :
    if session1.reconnecting or ( session2 and session2.reconnecting ) :
        curTS = time.time()
        if (int(expire_time) < 600):
          deltaTime = float(expire_time) * 0.90
        else:
          deltaTime = 300
        if (int(curTS) >= int(float(tokenTS) + float(deltaTime))):
          auth_token, expire_time = get_auth_token() 
          tokenTS = time.time()
    else:
      auth_token, expire_time = get_auth_token() 
      tokenTS = time.time()
    if auth_token is not None:
      if not session1.disconnected_by_user:
        session1.reconnecting = True
        session1.connect()
      if session2 and not session2.disconnected_by_user:
        session2.reconnecting = True
        session2.connect()
  else:
    print("Failed authentication with Refinitiv Data Platform. Exiting...")
    sys.exit(1) 

        
        Copy
    

    	
            
if session1.reconnecting or ( session2 and session2.reconnecting ) :
    # Check Time Logic
else:
    auth_token, expire_time = get_auth_token() 
    tokenTS = time.time()

        
        Copy
    

    	
            
else:
  auth_token, expire_time = get_auth_token() 
  tokenTS = time.time()
if auth_token is not None:
  if not session1.disconnected_by_user:
    session1.reconnecting = True
    session1.connect()

        
        Copy
    

    	
            
if session1.reconnecting or ( session2 and session2.reconnecting ) :
  curTS = time.time()
  if (int(expire_time) < 600):
    deltaTime = float(expire_time) * 0.90
  else:
    deltaTime = 300
  if (int(curTS) >= int(float(tokenTS) + float(deltaTime))):
    auth_token, expire_time = get_auth_token() 
    tokenTS = time.time()
else:
  # Re-request Access Token for an initial disconnect

        
        Copy
    

    	
            $>python market_price_rdpgw_client_cred_auth.py --clientid <clientid> --clientsecret <clientsecret>
        
        Copy
    

    	
            $>ant
        
        Copy
    

    	
            $>export CLASSPATH=lib/accessors-smart-1.1.jar:lib/asm-5.0.3.jar:lib/commons-cli-1.3.jar:lib/commons-codec-1.9.jar:lib/commons-logging-1.2.jar:lib/hamcrest-core-1.3.jar:lib/httpclient-4.5.3.jar:lib/httpcore-4.4.6.jar:lib/json-20160810.jar:lib/json-path-2.1.0.jar:lib/json-smart-2.2.jar:lib/junit-4.12.jar:lib/mockito-core-1.9.5.jar:lib/nv-websocket-client-1.30.jar:lib/objenesis-1.0.jar:lib/slf4j-api-1.7.13.jar:bin
        
        Copy
    

    	
            $>java MarketPriceRdpGwClientCredAuth --clientid <ClientID> --clientsecret <ClientSecret> --ric /EUR=
        
        Copy