Merge pull request #28 from FyersDev/tbtexample

chore: added tbt sample code

Author: piyushfs2

v3/python/websocket/tbt_socket/order_socket/ondepth.py

@@ -0,0 +1,81 @@
+from  fyers_apiv3.FyersWebsocket.tbt_ws import FyersTbtSocket, SubscriptionModes
+
+def on_depth_update(ticker, message):
+    """
+    Callback function to handle incoming messages from the FyersDataSocket WebSocket.
+
+    Parameters:
+        ticker (str): The symbol for which the message is received.
+        message (dict): The received message from the WebSocket.
+
+    """
+    print("Depth Response:", ticker, message)
+
+
+def onerror_message( message):
+    """
+    Callback function to handle incoming messages from the FyersDataSocket WebSocket.
+
+    Parameters:
+        message (str): error message from the server
+
+    """
+    print("server returned error:", message)
+
+
+def onerror(message):
+    """
+    Callback function to handle WebSocket errors.
+
+    Parameters:
+        message (dict): The error message received from the WebSocket.
+
+
+    """
+    print("Error:", message)
+
+
+def onclose(message):
+    """
+    Callback function to handle WebSocket connection close events.
+    """
+    print("Connection closed:", message)
+
+
+def onopen():
+    """
+    Callback function to subscribe to data type and symbols upon WebSocket connection.
+
+    """
+    print("Connection opened")
+    # Specify the data type and symbols you want to subscribe to
+    mode = SubscriptionModes.DEPTH
+    Channel = '1'
+    # Subscribe to the specified symbols and data type
+    symbols = ['NSE:NIFTY25MARFUT']
+    
+    fyers.subscribe(symbol_tickers=symbols, channelNo=Channel, mode=mode)
+    fyers.switchChannel(resume_channels=[Channel], pause_channels=[])
+
+    # Keep the socket running to receive real-time data
+    fyers.keep_running()
+
+
+# Replace the sample access token with your actual access token obtained from Fyers
+access_token = "XCXXXXXXM-100:eyJ0tHfZNSBoLo"
+
+fyers = FyersTbtSocket(
+    access_token=access_token,  # Your access token for authenticating with the Fyers API.
+    write_to_file=False,        # A boolean flag indicating whether to write data to a log file or not.
+    log_path="",                # The path to the log file if write_to_file is set to True (empty string means current directory).
+    on_open=onopen,          # Callback function to be executed upon successful WebSocket connection.
+    on_close=onclose,           # Callback function to be executed when the WebSocket connection is closed.
+    on_error=onerror,           # Callback function to handle any WebSocket errors that may occur.
+    on_depth_update=on_depth_update, # Callback function to handle depth-related events from the WebSocket
+    on_error_message=onerror_message         # Callback function to handle server-related erros from the WebSocket.
+)
+
+
+# Establish a connection to the Fyers WebSocket
+fyers.connect()
+

v3/python/websocket/tbt_socket/order_socket/order_websocket_background.py

@@ -0,0 +1,26 @@
+from fyers_apiv3.FyersWebsocket.tbt_ws import FyersTbtSocket, SubscriptionModes
+
+# Replace the sample access token with your actual access token obtained from Fyers
+access_token = "XCXXXXXXM-100:eyJ0tHfZNSBoLo"
+
+# Create a FyersDataSocket instance with the provided parameters
+fyers = FyersTbtSocket(
+    access_token=access_token,  # Your access token for authenticating with the Fyers API.
+    write_to_file=True,        # A boolean flag indicating whether to write data to a log file or not.
+    log_path="",                # The path to the log file if write_to_file is set to True (empty string means current directory).
+)
+
+
+# Establish a connection to the Fyers WebSocket
+fyers.connect()
+
+mode = SubscriptionModes.DEPTH
+Channel = '1'
+# Subscribe to the specified symbols and data type
+symbols = ['NSE:NIFTY25MARFUT']
+
+fyers.subscribe(symbol_tickers=symbols, channelNo=Channel, mode=mode)
+fyers.switchChannel(resume_channels=[Channel], pause_channels=[])
+
+# Keep the socket running to receive real-time data
+fyers.keep_running()

v3/python/websocket/tbt_socket/order_socket/order_websocket_foreground.py

@@ -0,0 +1,81 @@
+from  fyers_apiv3.FyersWebsocket.tbt_ws import FyersTbtSocket, SubscriptionModes
+
+def on_depth_update(ticker, message):
+    """
+    Callback function to handle incoming messages from the FyersDataSocket WebSocket.
+
+    Parameters:
+        ticker (str): The symbol for which the message is received.
+        message (dict): The received message from the WebSocket.
+
+    """
+    print("Depth Response:", ticker, message)
+
+
+def onerror_message( message):
+    """
+    Callback function to handle incoming messages from the FyersDataSocket WebSocket.
+
+    Parameters:
+        message (str): error message from the server
+
+    """
+    print("server returned error:", message)
+
+
+def onerror(message):
+    """
+    Callback function to handle WebSocket errors.
+
+    Parameters:
+        message (dict): The error message received from the WebSocket.
+
+
+    """
+    print("Error:", message)
+
+
+def onclose(message):
+    """
+    Callback function to handle WebSocket connection close events.
+    """
+    print("Connection closed:", message)
+
+
+def onopen():
+    """
+    Callback function to subscribe to data type and symbols upon WebSocket connection.
+
+    """
+    print("Connection opened")
+    # Specify the data type and symbols you want to subscribe to
+    mode = SubscriptionModes.DEPTH
+    Channel = '1'
+    # Subscribe to the specified symbols and data type
+    symbols = ['NSE:NIFTY25MARFUT']
+    
+    fyers.subscribe(symbol_tickers=symbols, channelNo=Channel, mode=mode)
+    fyers.switchChannel(resume_channels=[Channel], pause_channels=[])
+
+    # Keep the socket running to receive real-time data
+    fyers.keep_running()
+
+
+# Replace the sample access token with your actual access token obtained from Fyers
+access_token = "XCXXXXXXM-100:eyJ0tHfZNSBoLo"
+
+fyers = FyersTbtSocket(
+    access_token=access_token,  # Your access token for authenticating with the Fyers API.
+    write_to_file=False,        # A boolean flag indicating whether to write data to a log file or not.
+    log_path="",                # The path to the log file if write_to_file is set to True (empty string means current directory).
+    on_open=onopen,          # Callback function to be executed upon successful WebSocket connection.
+    on_close=onclose,           # Callback function to be executed when the WebSocket connection is closed.
+    on_error=onerror,           # Callback function to handle any WebSocket errors that may occur.
+    on_depth_update=on_depth_update, # Callback function to handle depth-related events from the WebSocket
+    on_error_message=onerror_message         # Callback function to handle server-related erros from the WebSocket.
+)
+
+
+# Establish a connection to the Fyers WebSocket
+fyers.connect()
+