start doing prototype

Author: Wasin Waeosri

.gitignore

@@ -1,2 +1,3 @@
 .vscode/
-market_price.py
+market_price.py
+mrn_python/

mrn_prototype.py

@@ -0,0 +1,202 @@
+# |-----------------------------------------------------------------------------
+# |            This source code is provided under the Apache 2.0 license      --
+# |  and is provided AS IS with no warranty or guarantee of fit for purpose.  --
+# |                See the project's LICENSE.md for details.                  --
+# |           Copyright Thomson Reuters 2017. All rights reserved.            --
+# |-----------------------------------------------------------------------------
+
+
+#!/usr/bin/env python
+""" Simple example of outputting Market Price JSON data using Websockets """
+
+import sys
+import time
+import getopt
+import socket
+import json
+import websocket
+import threading
+from threading import Thread, Event
+
+# Global Default Variables
+hostname = '172.20.33.30'
+port = '15000'
+user = 'root'
+app_id = '256'
+position = socket.gethostbyname(socket.gethostname())
+mrn_domain = 'NewsTextAnalytics'
+mrn_item = 'MRN_STORY'
+
+# Global Variables
+web_socket_app = None
+web_socket_open = False
+
+''' MRN Process Code '''
+
+
+def send_mrn_request(ws):
+    """ Create and send MRN request """
+    mrn_req_json = {
+        'ID': 2,
+        'Domain': mrn_domain,
+        'Key': {
+            'Name': mrn_item
+        }
+    }
+
+    ws.send(json.dumps(mrn_req_json))
+    print("SENT:")
+    print(json.dumps(mrn_req_json, sort_keys=True, indent=2, separators=(',', ':')))
+
+
+def processRefresh(ws):
+    return None
+
+
+def processUpdate(ws):
+    return None
+
+
+''' JSON-OMM Process functions '''
+
+
+def process_message(ws, message_json):
+    """ Parse at high level and output JSON of message """
+    message_type = message_json['Type']
+
+    if message_type == "Refresh":
+        if 'Domain' in message_json:
+            message_domain = message_json['Domain']
+            if message_domain == "Login":
+                process_login_response(ws, message_json)
+    elif message_type == "Ping":
+        pong_json = {'Type': 'Pong'}
+        ws.send(json.dumps(pong_json))
+        print("SENT:")
+        print(json.dumps(pong_json, sort_keys=True,
+                         indent=2, separators=(',', ':')))
+
+
+def process_login_response(ws, message_json):
+    """ Send item request """
+    # send_market_price_request(ws)
+    send_mrn_request(ws)
+
+
+def send_market_price_request(ws):
+    """ Create and send simple Market Price request """
+    mp_req_json = {
+        'ID': 2,
+        'Key': {
+            'Name': ['EUR=', 'JPY=', 'THB='],
+        },
+    }
+    ws.send(json.dumps(mp_req_json))
+    print("SENT:")
+    print(json.dumps(mp_req_json, sort_keys=True, indent=2, separators=(',', ':')))
+
+
+def send_login_request(ws):
+    """ Generate a login request from command line data (or defaults) and send """
+    login_json = {
+        'ID': 1,
+        'Domain': 'Login',
+        'Key': {
+            'Name': '',
+            'Elements': {
+                'ApplicationId': '',
+                'Position': ''
+            }
+        }
+    }
+
+    login_json['Key']['Name'] = user
+    login_json['Key']['Elements']['ApplicationId'] = app_id
+    login_json['Key']['Elements']['Position'] = position
+
+    ws.send(json.dumps(login_json))
+    print("SENT:")
+    print(json.dumps(login_json, sort_keys=True, indent=2, separators=(',', ':')))
+
+
+''' WebSocket Process functions '''
+
+
+def on_message(ws, message):
+    """ Called when message received, parse message into JSON for processing """
+    print("RECEIVED: ")
+    message_json = json.loads(message)
+    print(json.dumps(message_json, sort_keys=True, indent=2, separators=(',', ':')))
+
+    for singleMsg in message_json:
+        process_message(ws, singleMsg)
+
+
+def on_error(ws, error):
+    """ Called when websocket error has occurred """
+    print(error)
+
+
+def on_close(ws):
+    """ Called when websocket is closed """
+    global web_socket_open
+    print("WebSocket Closed")
+    web_socket_open = False
+
+
+def on_open(ws):
+    """ Called when handshake is complete and websocket is open, send login """
+
+    print("WebSocket successfully connected!")
+    global web_socket_open
+    web_socket_open = True
+    send_login_request(ws)
+
+
+''' Main Process Code '''
+
+if __name__ == "__main__":
+
+    # Get command line parameters
+    try:
+        opts, args = getopt.getopt(sys.argv[1:], "", [
+                                   "help", "hostname=", "port=", "app_id=", "user=", "position="])
+    except getopt.GetoptError:
+        print(
+            'Usage: market_price.py [--hostname hostname] [--port port] [--app_id app_id] [--user user] [--position position] [--help]')
+        sys.exit(2)
+    for opt, arg in opts:
+        if opt in ("--help"):
+            print(
+                'Usage: market_price.py [--hostname hostname] [--port port] [--app_id app_id] [--user user] [--position position] [--help]')
+            sys.exit(0)
+        elif opt in ("--hostname"):
+            hostname = arg
+        elif opt in ("--port"):
+            port = arg
+        elif opt in ("--app_id"):
+            app_id = arg
+        elif opt in ("--user"):
+            user = arg
+        elif opt in ("--position"):
+            position = arg
+
+    # Start websocket handshake
+    ws_address = "ws://{}:{}/WebSocket".format(hostname, port)
+    print("Connecting to WebSocket " + ws_address + " ...")
+    web_socket_app = websocket.WebSocketApp(ws_address, header=['User-Agent: Python'],
+                                            on_message=on_message,
+                                            on_error=on_error,
+                                            on_close=on_close,
+                                            subprotocols=['tr_json2'])
+    web_socket_app.on_open = on_open
+
+    # Event loop
+    wst = threading.Thread(target=web_socket_app.run_forever)
+    wst.start()
+
+    try:
+        while True:
+            time.sleep(1)
+    except KeyboardInterrupt:
+        web_socket_app.close()