Fixed issue #166: api.get_quotes is returning None after few successful returns

api.get_quotes.py

@@ -0,0 +1,40 @@
+async def websocket(token, exch="NFO"):
+    global feedjson, orderJson
+
+    try:
+        feed_opened = False
+
+        # feedjson = {}
+        # orderJson = {}
+
+        def event_handler_feed_update(tick_data):
+            if ("lp" in tick_data) & ("tk" in tick_data):
+                print("tis is the webstocket function")
+                feedjson[tick_data["tk"]] = float(tick_data["lp"])
+                print(feedjson)
+
+        def event_handler_order_update(order):
+            print(f"order feed {order}")
+            if ("norenordno" in order) & ("status" in order):
+                orderJson[order["norenordno"]] = order["status"]
+
+        def open_callback():
+            nonlocal feed_opened
+            feed_opened = True
+
+        api.start_websocket(
+            order_update_callback=event_handler_order_update,
+            subscribe_callback=event_handler_feed_update,
+            socket_open_callback=open_callback,
+        )
+
+        while feed_opened == False:
+            pass
+
+        # token = api.get_quotes(exchange=exch, token=token)
+        # token = token["token"]
+
+        api.subscribe(f"{exch}|{token}")
+
+    except Exception as err:
+        error(f"this is error in the webstocket {err}")

ssl_error_fixer.py

@@ -0,0 +1,46 @@
+# install_certifi.py
+#
+# sample script to install or update a set of default Root Certificates
+# for the ssl module.  Uses the certificates provided by the certifi package:
+#       https://pypi.python.org/pypi/certifi
+
+import os
+import os.path
+import ssl
+import stat
+import subprocess
+import sys
+
+STAT_0o775 = ( stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR
+             | stat.S_IRGRP | stat.S_IWGRP | stat.S_IXGRP
+             | stat.S_IROTH |                stat.S_IXOTH )
+
+
+def main():
+    openssl_dir, openssl_cafile = os.path.split(
+        ssl.get_default_verify_paths().openssl_cafile)
+
+    print(" -- pip install --upgrade certifi")
+    subprocess.check_call([sys.executable,
+        "-E", "-s", "-m", "pip", "install", "--upgrade", "certifi"])
+
+    import certifi
+    if not os.path.exists(openssl_dir):
+        os.makedirs(openssl_dir)
+        print(" -- Creating SSL Folder")
+    # change working directory to the default SSL directory
+    os.chdir(openssl_dir)
+    relpath_to_certifi_cafile = os.path.relpath(certifi.where())
+    print(" -- removing any existing file or link")
+    try:
+        os.remove(openssl_cafile)
+    except FileNotFoundError:
+        pass
+    print(" -- creating symlink to certifi certificate bundle")
+    os.symlink(relpath_to_certifi_cafile, openssl_cafile)
+    print(" -- setting permissions")
+    os.chmod(openssl_cafile, STAT_0o775)
+    print(" -- update complete")
+
+if __name__ == '__main__':
+    main()