Gtt order updates streamer (#99)

* added gtt_order update in portfolio streamer

* added gtt error message

Author: KetanGupta12

README.md

@@ -9,7 +9,7 @@ The official Python client for communicating with the <a href="https://upstox.co
 Upstox API is a set of rest APIs that provide data required to build a complete investment and trading platform. Execute orders in real time, manage user portfolio, stream live market data (using Websocket), and more, with the easy to understand API collection. 
 
 - API version: v2
-- Package version: 2.13.0
+- Package version: 2.14.0
 - Build package: io.swagger.codegen.v3.generators.python.PythonClientCodegen
 
 This Python package is automatically generated by the [Swagger Codegen](https://github.com/swagger-api/swagger-codegen) project.
@@ -728,7 +728,7 @@ if __name__ == "__main__":
 ```
 <br/>
 
-Position and holding updates can be enabled by setting the corresponding flag to `True` in the constructor of the `PortfolioDataStreamer` class.
+Position, holding, and GTT order updates can be enabled by setting the corresponding flag to `True` in the constructor of the `PortfolioDataStreamer` class.
 
 ```python
 import upstox_client
@@ -747,7 +747,11 @@ def main():
     configuration = upstox_client.Configuration()
     configuration.access_token = <ACCESS_TOKEN>
 
-    streamer = upstox_client.PortfolioDataStreamer(upstox_client.ApiClient(configuration),order_update=True,position_update=True,holding_update=True)
+    streamer = upstox_client.PortfolioDataStreamer(upstox_client.ApiClient(configuration),
+                                                  order_update=True,
+                                                  position_update=True,
+                                                  holding_update=True,
+                                                  gtt_update=True)
 
     streamer.on("message", on_message)
     streamer.on("open", on_open)
@@ -763,6 +767,13 @@ if __name__ == "__main__":
 
 ### Exploring the PortfolioDataStreamer Functionality
 
+#### Constructor Parameters
+1. **api_client**: Your API client instance
+2. **order_update**: Set to `True` to receive real-time order updates (default: `True`)
+3. **position_update**: Set to `True` to receive position updates (default: `False`) 
+4. **holding_update**: Set to `True` to receive holding updates (default: `False`)
+5. **gtt_update**: Set to `True` to receive GTT order updates (default: `False`)
+
 #### Functions
 1. **constructor PortfolioDataStreamer()**: Initializes the streamer.
 2. **connect()**: Establishes the WebSocket connection.

setup.py

@@ -18,7 +18,7 @@
 long_description = (this_directory / "README.md").read_text()
 
 NAME = "upstox-python-sdk"
-VERSION = "2.13.0"
+VERSION = "2.14.0"
 # To install the library, run the following
 #
 # python setup.py install

test/sdk_tests/portfolio_update_type.py

@@ -14,7 +14,7 @@ def main():
     configuration = upstox_client.Configuration()
     configuration.access_token = data_token.access_token
 
-    streamer = upstox_client.PortfolioDataStreamer(upstox_client.ApiClient(configuration),order_update=True,position_update=True,holding_update=True)
+    streamer = upstox_client.PortfolioDataStreamer(upstox_client.ApiClient(configuration),order_update=True,position_update=True,holding_update=True, gtt_update=True)
 
     streamer.on("message", on_message)
     streamer.on("open", on_open)

upstox_client/api_client.py

@@ -74,7 +74,7 @@ def __init__(self, configuration=None, header_name=None, header_value=None,
         # Set default User-Agent.
         self.user_agent = 'Swagger-Codegen/1.0.0/python'
         self.default_headers["X-Upstox-SDK-Language"] = "python"
-        self.default_headers["X-Upstox-SDK-Version"] = "2.13.0"
+        self.default_headers["X-Upstox-SDK-Version"] = "2.14.0"
 
     def __del__(self):
         try:

upstox_client/feeder/portfolio_data_feeder.py

@@ -7,7 +7,7 @@
 class PortfolioDataFeeder(Feeder):
 
     def __init__(self, api_client=None, on_open=None, on_message=None, on_error=None, on_close=None, order_update=True,
-                 position_update=False, holding_update=False):
+                 position_update=False, holding_update=False, gtt_update=False):
         super().__init__(api_client=api_client)
         self.api_client = api_client
         self.on_open = on_open
@@ -19,6 +19,7 @@ def __init__(self, api_client=None, on_open=None, on_message=None, on_error=None
         self.order_update = order_update
         self.position_update = position_update
         self.holding_update = holding_update
+        self.gtt_update = gtt_update
 
     def connect(self):
         if self.ws and self.ws.sock:
@@ -51,6 +52,8 @@ def get_websocket_url(self):
             update_types.append("holding")
         if self.position_update:
             update_types.append("position")
+        if self.gtt_update:
+            update_types.append("gtt_order")
 
         if update_types:
             ws_url += "?update_types=" + "%2C".join(update_types)

upstox_client/feeder/portfolio_data_streamer.py

@@ -4,19 +4,20 @@
 
 class PortfolioDataStreamer(Streamer):
 
-    def __init__(self, api_client=None, order_update=True, position_update=False, holding_update=False):
+    def __init__(self, api_client=None, order_update=True, position_update=False, holding_update=False, gtt_update=False):
         super().__init__(api_client)
         self.api_client = api_client
         self.order_update = order_update
         self.position_update = position_update
         self.holding_update = holding_update
+        self.gtt_update = gtt_update
         self.feeder = None
 
     def connect(self):
         self.feeder = PortfolioDataFeeder(
             api_client=self.api_client, on_open=self.handle_open, on_message=self.handle_message,
             on_error=self.handle_error, on_close=self.handle_close, order_update=self.order_update,
-            position_update=self.position_update, holding_update=self.holding_update)
+            position_update=self.position_update, holding_update=self.holding_update, gtt_update=self.gtt_update)
         self.feeder.connect()
 
     def handle_open(self, ws):

upstox_client/models/rule.py

@@ -30,6 +30,7 @@ class Rule(object):
     swagger_types = {
         'strategy': 'str',
         'status': 'str',
+        'message': 'str',
         'trigger_type': 'str',
         'trigger_price': 'float',
         'transaction_type': 'str',
@@ -39,16 +40,18 @@ class Rule(object):
     attribute_map = {
         'strategy': 'strategy',
         'status': 'status',
+        'message': 'message',
         'trigger_type': 'trigger_type',
         'trigger_price': 'trigger_price',
         'transaction_type': 'transaction_type',
         'order_id': 'order_id'
     }
 
-    def __init__(self, strategy=None, status=None, trigger_type=None, trigger_price=None, transaction_type=None, order_id=None):  # noqa: E501
+    def __init__(self, strategy=None, status=None, message=None, trigger_type=None, trigger_price=None, transaction_type=None, order_id=None):  # noqa: E501
         """Rule - a model defined in Swagger"""  # noqa: E501
         self._strategy = None
         self._status = None
+        self._message = None
         self._trigger_type = None
         self._trigger_price = None
         self._transaction_type = None
@@ -58,6 +61,8 @@ def __init__(self, strategy=None, status=None, trigger_type=None, trigger_price=
             self.strategy = strategy
         if status is not None:
             self.status = status
+        if message is not None:
+            self.message = message
         if trigger_type is not None:
             self.trigger_type = trigger_type
         if trigger_price is not None:
@@ -109,6 +114,27 @@ def status(self, status):
 
         self._status = status
 
+    @property
+    def message(self):
+        """Gets the message of this Rule.  # noqa: E501
+
+
+        :return: The message of this Rule.  # noqa: E501
+        :rtype: str
+        """
+        return self._message
+
+    @message.setter
+    def message(self, message):
+        """Sets the message of this Rule.
+
+
+        :param message: The message of this Rule.  # noqa: E501
+        :type: str
+        """
+
+        self._message = message
+
     @property
     def trigger_type(self):
         """Gets the trigger_type of this Rule.  # noqa: E501