fyers21022022.ipynb

{
  "nbformat": 4,
  "nbformat_minor": 0,
  "metadata": {
    "colab": {
      "name": "Untitled2.ipynb",
      "provenance": [],
      "authorship_tag": "ABX9TyNqVGTqPrcaylSopm6hhok/",
      "include_colab_link": true
    },
    "kernelspec": {
      "name": "python3",
      "display_name": "Python 3"
    },
    "language_info": {
      "name": "python"
    }
  },
  "cells": [
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "view-in-github",
        "colab_type": "text"
      },
      "source": [
        "<a href=\"https://colab.research.google.com/github/anvy87/AlgoTrading/blob/master/fyers21022022.ipynb\" target=\"_parent\"><img src=\"https://colab.research.google.com/assets/colab-badge.svg\" alt=\"Open In Colab\"/></a>"
      ]
    },
    {
      "cell_type": "code",
      "source": [
        "pip install fyers-apiv2"
      ],
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 780
        },
        "id": "h_sCgqmikeE2",
        "outputId": "e78da4b6-d852-4534-dad9-0cdc20236f3e"
      },
      "execution_count": 2,
      "outputs": [
        {
          "output_type": "stream",
          "name": "stdout",
          "text": [
            "Collecting fyers-apiv2\n",
            "  Downloading fyers_apiv2-2.0.5-py3-none-any.whl (15 kB)\n",
            "Collecting requests==2.25.1\n",
            "  Downloading requests-2.25.1-py2.py3-none-any.whl (61 kB)\n",
            "\u001b[K     |████████████████████████████████| 61 kB 2.9 MB/s \n",
            "\u001b[?25hCollecting websocket-client==1.2.1\n",
            "  Downloading websocket_client-1.2.1-py2.py3-none-any.whl (52 kB)\n",
            "\u001b[K     |████████████████████████████████| 52 kB 1.6 MB/s \n",
            "\u001b[?25hCollecting websockets==8.1\n",
            "  Downloading websockets-8.1-cp37-cp37m-manylinux2010_x86_64.whl (79 kB)\n",
            "\u001b[K     |████████████████████████████████| 79 kB 7.8 MB/s \n",
            "\u001b[?25hCollecting asyncio==3.4.3\n",
            "  Downloading asyncio-3.4.3-py3-none-any.whl (101 kB)\n",
            "\u001b[K     |████████████████████████████████| 101 kB 11.4 MB/s \n",
            "\u001b[?25hCollecting tornado==6.1\n",
            "  Downloading tornado-6.1-cp37-cp37m-manylinux2010_x86_64.whl (428 kB)\n",
            "\u001b[K     |████████████████████████████████| 428 kB 51.3 MB/s \n",
            "\u001b[?25hRequirement already satisfied: idna<3,>=2.5 in /usr/local/lib/python3.7/dist-packages (from requests==2.25.1->fyers-apiv2) (2.10)\n",
            "Requirement already satisfied: certifi>=2017.4.17 in /usr/local/lib/python3.7/dist-packages (from requests==2.25.1->fyers-apiv2) (2021.10.8)\n",
            "Requirement already satisfied: urllib3<1.27,>=1.21.1 in /usr/local/lib/python3.7/dist-packages (from requests==2.25.1->fyers-apiv2) (1.24.3)\n",
            "Requirement already satisfied: chardet<5,>=3.0.2 in /usr/local/lib/python3.7/dist-packages (from requests==2.25.1->fyers-apiv2) (3.0.4)\n",
            "Installing collected packages: websockets, websocket-client, tornado, requests, asyncio, fyers-apiv2\n",
            "  Attempting uninstall: tornado\n",
            "    Found existing installation: tornado 5.1.1\n",
            "    Uninstalling tornado-5.1.1:\n",
            "      Successfully uninstalled tornado-5.1.1\n",
            "  Attempting uninstall: requests\n",
            "    Found existing installation: requests 2.23.0\n",
            "    Uninstalling requests-2.23.0:\n",
            "      Successfully uninstalled requests-2.23.0\n",
            "\u001b[31mERROR: pip's dependency resolver does not currently take into account all the packages that are installed. This behaviour is the source of the following dependency conflicts.\n",
            "google-colab 1.0.0 requires requests~=2.23.0, but you have requests 2.25.1 which is incompatible.\n",
            "google-colab 1.0.0 requires tornado~=5.1.0; python_version >= \"3.0\", but you have tornado 6.1 which is incompatible.\n",
            "datascience 0.10.6 requires folium==0.2.1, but you have folium 0.8.3 which is incompatible.\u001b[0m\n",
            "Successfully installed asyncio-3.4.3 fyers-apiv2-2.0.5 requests-2.25.1 tornado-6.1 websocket-client-1.2.1 websockets-8.1\n"
          ]
        },
        {
          "output_type": "display_data",
          "data": {
            "application/vnd.colab-display-data+json": {
              "pip_warning": {
                "packages": [
                  "asyncio",
                  "tornado"
                ]
              }
            }
          },
          "metadata": {}
        }
      ]
    },
    {
      "cell_type": "code",
      "execution_count": 1,
      "metadata": {
        "id": "Sgoji_rHkTm-"
      },
      "outputs": [],
      "source": [
        "import os\n",
        "import sys\n",
        "from urllib.parse import urlparse, parse_qs\n",
        "from fyers_api import fyersModel\n",
        "from fyers_api import accessToken\n",
        "import requests"
      ]
    },
    {
      "cell_type": "code",
      "source": [
        "username = \"XA01965\"  # fyers_id\n",
        "password = \"Baroda@3893\"  # fyers_password\n",
        "pin = 2017  # your integer pin\n",
        "client_id = \"5MT9C46SQ3-100\"  # \"L9NY****W-100\" (Client_id here refers to APP_ID of the created app)\n",
        "secret_key = \"OYQHON8TJ7\"  # app_secret key which you got after creating the app\n",
        "redirect_uri = \"http://localhost:8080\"  # redircet_uri you entered while creating APP.\n",
        "\n",
        "app_id = client_id[:-4]  # \"L9NY****W\" (don't change this app_id variable)"
      ],
      "metadata": {
        "id": "MryPelW-kUaH"
      },
      "execution_count": 2,
      "outputs": []
    },
    {
      "cell_type": "code",
      "source": [
        "def read_file():\n",
        "    with open(\"tokenf.txt\", \"r\") as f:\n",
        "        token = f.read()\n",
        "    return token"
      ],
      "metadata": {
        "id": "aXqmvGJ6k1vR"
      },
      "execution_count": 3,
      "outputs": []
    },
    {
      "cell_type": "code",
      "source": [
        "def write_file(token):\n",
        "    with open(\"tokenf.txt\", \"w\") as f:\n",
        "        f.write(token)"
      ],
      "metadata": {
        "id": "l2YeXTSGk7iR"
      },
      "execution_count": 4,
      "outputs": []
    },
    {
      "cell_type": "code",
      "source": [
        "def setup():\n",
        "    session = accessToken.SessionModel(\n",
        "        client_id=client_id,\n",
        "        secret_key=secret_key,\n",
        "        redirect_uri=redirect_uri,\n",
        "        response_type=\"code\",\n",
        "        grant_type=\"authorization_code\",\n",
        "    )\n",
        "    \n",
        "    headers = {\n",
        "        \"accept\": \"application/json\",\n",
        "        \"user-agent\": \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.45 Safari/537.36\",\n",
        "        \"accept-language\": \"en-US,en;q=0.9\",\n",
        "    }\n",
        "\n",
        "\n",
        "    s = requests.Session()\n",
        "\n",
        "    data1 = f'{{\"fy_id\":\"{username}\",\"password\":\"{password}\",\"app_id\":\"2\",\"imei\":\"\",\"recaptcha_token\":\"\"}}'\n",
        "    r1 = s.post(\"https://api.fyers.in/vagator/v1/login\", data=data1)\n",
        "\n",
        "    assert r1.status_code == 200, f\"Error in r1:\\n {r1.json()}\"\n",
        "\n",
        "    request_key = r1.json()[\"request_key\"]\n",
        "\n",
        "    data2 = f'{{\"request_key\":\"{request_key}\",\"identity_type\":\"pin\",\"identifier\":\"{pin}\",\"recaptcha_token\":\"\"}}'\n",
        "    r2 = s.post(\"https://api.fyers.in/vagator/v1/verify_pin\", data=data2)\n",
        "\n",
        "    assert r2.status_code == 200, f\"Error in r2:\\n {r2.json()}\"\n",
        "\n",
        "    headers = {\"authorization\": f\"Bearer {r2.json()['data']['access_token']}\", \"content-type\": \"application/json; charset=UTF-8\"}\n",
        "    data3 = f'{{\"fyers_id\":\"{username}\",\"app_id\":\"{app_id}\",\"redirect_uri\":\"{redirect_uri}\",\"appType\":\"100\",\"code_challenge\":\"\",\"state\":\"abcdefg\",\"scope\":\"\",\"nonce\":\"\",\"response_type\":\"code\",\"create_cookie\":true}}'\n",
        "    r3 = s.post(\"https://api.fyers.in/api/v2/token\", headers=headers, data=data3)\n",
        "\n",
        "    assert r3.status_code == 308, f\"Error in r3:\\n {r3.json()}\"\n",
        "\n",
        "    parsed = urlparse(r3.json()[\"Url\"])\n",
        "    auth_code = parse_qs(parsed.query)[\"auth_code\"][0]\n",
        "    session.set_token(auth_code)\n",
        "    response = session.generate_token()\n",
        "    token = response[\"access_token\"]\n",
        "    write_file(token)\n",
        "    print(\"Got the access token!!!\")\n",
        "    fyers = fyersModel.FyersModel(client_id=client_id, token=token, log_path=os.getcwd())\n",
        "    print(fyers.get_profile())"
      ],
      "metadata": {
        "id": "s3vi6_czk-YV"
      },
      "execution_count": 8,
      "outputs": []
    },
    {
      "cell_type": "code",
      "source": [
        "def check():\n",
        "    try:\n",
        "        token = read_file()\n",
        "    except FileNotFoundError:\n",
        "        print(\"Getting the access token!\")\n",
        "        setup()\n",
        "        sys.exit()\n",
        "    fyers = fyersModel.FyersModel(client_id=client_id, token=token, log_path=os.getcwd())\n",
        "    response = fyers.get_profile()\n",
        "    if \"error\" in response[\"s\"] or \"error\" in response[\"message\"] or \"expired\" in response[\"message\"]:\n",
        "        print(\"Getting a access token!\")\n",
        "        setup()\n",
        "    else:\n",
        "        print(\"You already have a access token!\")\n",
        "        print(response)\n",
        "\n",
        "\n",
        "if __name__ == \"__main__\":\n",
        "    check()"
      ],
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 538
        },
        "id": "QU3U0tZllDlb",
        "outputId": "43d2ace0-6567-40c4-9660-0d9e1dae7a0f"
      },
      "execution_count": 9,
      "outputs": [
        {
          "output_type": "stream",
          "name": "stdout",
          "text": [
            "Getting the access token!\n"
          ]
        },
        {
          "output_type": "error",
          "ename": "AssertionError",
          "evalue": "ignored",
          "traceback": [
            "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
            "\u001b[0;31mFileNotFoundError\u001b[0m                         Traceback (most recent call last)",
            "\u001b[0;32m<ipython-input-9-0ecb4a94b336>\u001b[0m in \u001b[0;36mcheck\u001b[0;34m()\u001b[0m\n\u001b[1;32m      2\u001b[0m     \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 3\u001b[0;31m         \u001b[0mtoken\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mread_file\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m      4\u001b[0m     \u001b[0;32mexcept\u001b[0m \u001b[0mFileNotFoundError\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
            "\u001b[0;32m<ipython-input-3-5829183631ed>\u001b[0m in \u001b[0;36mread_file\u001b[0;34m()\u001b[0m\n\u001b[1;32m      1\u001b[0m \u001b[0;32mdef\u001b[0m \u001b[0mread_file\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 2\u001b[0;31m     \u001b[0;32mwith\u001b[0m \u001b[0mopen\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"tokenf.txt\"\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m\"r\"\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0mf\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m      3\u001b[0m         \u001b[0mtoken\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mf\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mread\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
            "\u001b[0;31mFileNotFoundError\u001b[0m: [Errno 2] No such file or directory: 'tokenf.txt'",
            "\nDuring handling of the above exception, another exception occurred:\n",
            "\u001b[0;31mAssertionError\u001b[0m                            Traceback (most recent call last)",
            "\u001b[0;32m<ipython-input-9-0ecb4a94b336>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m()\u001b[0m\n\u001b[1;32m     17\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     18\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0m__name__\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0;34m\"__main__\"\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 19\u001b[0;31m     \u001b[0mcheck\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
            "\u001b[0;32m<ipython-input-9-0ecb4a94b336>\u001b[0m in \u001b[0;36mcheck\u001b[0;34m()\u001b[0m\n\u001b[1;32m      4\u001b[0m     \u001b[0;32mexcept\u001b[0m \u001b[0mFileNotFoundError\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      5\u001b[0m         \u001b[0mprint\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"Getting the access token!\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 6\u001b[0;31m         \u001b[0msetup\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m      7\u001b[0m         \u001b[0msys\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mexit\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      8\u001b[0m     \u001b[0mfyers\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mfyersModel\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mFyersModel\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mclient_id\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mclient_id\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mtoken\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mtoken\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mlog_path\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mos\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mgetcwd\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
            "\u001b[0;32m<ipython-input-8-ec08124722e4>\u001b[0m in \u001b[0;36msetup\u001b[0;34m()\u001b[0m\n\u001b[1;32m     33\u001b[0m     \u001b[0mr3\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0ms\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mpost\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"https://api.fyers.in/api/v2/token\"\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mheaders\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mheaders\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mdata\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mdata3\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     34\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 35\u001b[0;31m     \u001b[0;32massert\u001b[0m \u001b[0mr3\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstatus_code\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0;36m308\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34mf\"Error in r3:\\n {r3.json()}\"\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     36\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     37\u001b[0m     \u001b[0mparsed\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0murlparse\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mr3\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mjson\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;34m\"Url\"\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
            "\u001b[0;31mAssertionError\u001b[0m: Error in r3:\n {'s': 'ok', 'code': '', 'message': '', 'data': {'appName': 'test11', 'image': None, 'app_id': '5MT9C46SQ3', 'user_id': 'XA01965', 'redirectUrl': 'http://localhost:8080', 'permissions': ['x:2', 'd:1', 'd:2'], 'auth': 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJhcGkuZnllcnMuaW4iLCJpYXQiOjE2NDUzODUzNDIsImV4cCI6MTY0NTM4NTY0MiwibmJmIjoxNjQ1Mzg1MzQyLCJhdWQiOiJbXCJ4OjBcIiwgXCJ4OjFcIiwgXCJ4OjJcIiwgXCJkOjFcIiwgXCJkOjJcIiwgXCJ4OjFcIiwgXCJ4OjBcIl0iLCJzdWIiOiJhY2Nlc3NfdG9rZW4iLCJhdF9oYXNoIjoiZ0FBQUFBQmlFcFotWmtUd09QTzdpZVJWZnNvNWRqcWRXZTRYU1RfelRRS204NGVXV3ZTM3BNY3A3VFJvNGVMT2I4elpmMTdtV0ZoaDIzQ2VDY0VLN3kwY3h4bmFFUGhnMV9GM2tLYkhPeFRlY0dsWHZtamI5S2M9IiwiZGlzcGxheV9uYW1lIjoiWEEwMTk2NSJ9.NE9xwFl-KNeq0RN7_2wZDjYy2VbWak64M_2R_0VLztE', 'response_type': 'code', 'scope': '', 'nonce': '', 'state': 'abcdefg'}}"
          ]
        }
      ]
    },
    {
      "cell_type": "code",
      "source": [
        ""
      ],
      "metadata": {
        "id": "o5oTfEl6lGgx"
      },
      "execution_count": null,
      "outputs": []
    }
  ]
}