YHT_12_part_17_10_2020_version.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# MANUAL LOGIN-1 of 3 #\n",
    "#######################\n",
    "\n",
    "# import logging\n",
    "# from kiteconnect import KiteConnect\n",
    "# logging.basicConfig(level=logging.ERROR)\n",
    "# import threading\n",
    "# kite = KiteConnect(api_key=\"w19o0chuo929jxkp\")\n",
    "# import joblib\n",
    "# kite = joblib.load('kitefile.p')\n",
    "# print(kite.login_url())"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 2,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# MANUAL LOGIN-2 of 3 #\n",
    "#######################\n",
    "\n",
    "# mytoken = input('Enter Token Here : ')  \n",
    "# data = kite.generate_session(mytoken,api_secret=\"gsw8ps17ex7lf3cuji4prfnwb4vlyr4y\")\n",
    "# kite.set_access_token(data[\"access_token\"])\n",
    "# import joblib\n",
    "# joblib.dump(kite,'kitefile.p')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# MANUAL LOGIN-3 of 3 #\n",
    "####################### \n",
    "\n",
    "# import act"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "IJnSAjBcFY8Nvp75hD3j63GX6DFvNhd4\n"
     ]
    }
   ],
   "source": [
    "# #####################\n",
    "# # AUTO LOGIN-1 of 1 #\n",
    "# #####################\n",
    "\n",
    "import login\n",
    "from login import *\n",
    "import pandas as pd"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# OPTIONAL RUN-1 of 4 #\n",
    "#######################\n",
    "\n",
    "#kite.orders()[-1]"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 6,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# OPTIONAL RUN-2 of 4 #\n",
    "#######################\n",
    "\n",
    "#kite.positions()['net']"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 7,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# OPTIONAL RUN-3 of 4 #\n",
    "#######################\n",
    "\n",
    "#kite.holdings()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 8,
   "metadata": {},
   "outputs": [],
   "source": [
    "#######################\n",
    "# OPTIONAL RUN-4 of 4 #\n",
    "#######################\n",
    "\n",
    "#kite.margins(segment = 'equity')['available']['live_balance']"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 16,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Today Date : 2020-10-17\n",
      "Yestreday Date : 2020-10-16\n",
      "last close : 73.4225\n",
      "last high : 73.515\n",
      "last low : 73.33\n",
      "HL Range : 0.185\n",
      "My Margin : 447064.53\n",
      "Pivot Price : 73.4225\n",
      "Full Quantity : 223\n",
      "Stoploss On ? : True\n",
      "Order Type : MIS\n",
      "\n",
      "\n",
      "pivot price : 73.4225\n",
      "\n",
      "p1b = 73.4\n",
      "p2b = 73.38\n",
      "p3b = 73.3525\n",
      "p4b = 73.3075\n",
      "p5b = 73.2375\n",
      "p6b = 73.215\n",
      "p7b = 73.195\n",
      "p8b = 73.1675\n",
      "p9b = 73.1225\n",
      "p10b = 73.0525\n",
      "p11b = 73.03\n",
      "p12b = 72.9825\n",
      "\n",
      "p1s = 73.445\n",
      "p2s = 73.465\n",
      "p3s = 73.4925\n",
      "p4s = 73.5375\n",
      "p5s = 73.6075\n",
      "p6s = 73.63\n",
      "p7s = 73.65\n",
      "p8s = 73.6775\n",
      "p9s = 73.7225\n",
      "p10s = 73.7925\n",
      "p11s = 73.815\n",
      "p12s = 73.8625\n",
      "\n",
      "p1q : 6\n",
      "p2q : 13\n",
      "p3q : 27\n",
      "p4q : 55\n",
      "p5q : 111\n",
      "p6q : 117\n",
      "p7q : 124\n",
      "p8q : 138\n",
      "p9q : 166\n",
      "p10q : 222\n",
      "p11q : 222\n",
      "p12q : 0\n"
     ]
    }
   ],
   "source": [
    "#####################\n",
    "# NORMAL RUN-1 of 3 #\n",
    "#####################\n",
    "fullquantity = 0 # set \n",
    "powermulti = 2\n",
    "inst_token = 690691\n",
    "one_dollar_margin = 2000     # (USD-MIS=984/NRML=1967)(GBP-MIS=1948/NRML=3895)(EUR-MIS=1313/NRML=2625)(JPY-MIS=1333/NRML=2667)\n",
    "order_type = 'MIS'           # MIS / NRML\n",
    "symbol_ip = 'USDINR20OCTFUT' # USDINR20OCTFUT / GBPINR20OCTFUT / EURINR20OCTFUT / JPYINR20OCTFUT\n",
    "inst_token = 690691          # 690691(USD) / 490755(GBP) / 278019(EUR) / 690435(JPY)\n",
    "stoploss_on = True          # True / False\n",
    "#####################################################################################\n",
    "\n",
    "import datetime\n",
    "interval='day'\n",
    "todaydt=datetime.date.today()\n",
    "hud_ago=todaydt-datetime.timedelta(days=10)\n",
    "to_date=datetime.date.isoformat(todaydt)\n",
    "\n",
    "from_date=datetime.date.isoformat(hud_ago)\n",
    "data = kite.historical_data(inst_token, from_date, to_date, interval, continuous=False)\n",
    "\n",
    "import pandas as pd\n",
    "mydata = pd.DataFrame(data)\n",
    "\n",
    "last_close = 123.0\n",
    "last_high = 123.0\n",
    "last_low = 123.0\n",
    "\n",
    "from datetime import date\n",
    "\n",
    "today = date.today()\n",
    "\n",
    "print('Today Date : '+str(today))\n",
    "yest_date = ''\n",
    "\n",
    "for i in range(len(mydata['date'])):\n",
    "    if(mydata['date'][i].date()==today-datetime.timedelta(days=1) or mydata['date'][i].date()==today-datetime.timedelta(days=2) or mydata['date'][i].date()==today-datetime.timedelta(days=3)):\n",
    "        #print('Yestreday Date : '+str(mydata['date'][i].date()))\n",
    "        yest_date = mydata['date'][i].date()\n",
    "        last_close = mydata['close'][i]\n",
    "        last_high = mydata['high'][i]\n",
    "        last_low = mydata['low'][i]\n",
    "        pivot_range = last_high - last_low\n",
    "        \n",
    "print('Yestreday Date : '+str(yest_date))       \n",
    "print('last close : '+ str(last_close))\n",
    "print('last high : '+ str(last_high))\n",
    "print('last low : '+ str(last_low))\n",
    "print('HL Range : '+ str(round(pivot_range,4)))\n",
    "\n",
    "mymargin = round(kite.margins(segment = 'equity')['available']['live_balance'],4)\n",
    "\n",
    "pivot_price = last_close\n",
    "\n",
    "if (fullquantity==0):\n",
    "    fullquantity = int(mymargin / one_dollar_margin)\n",
    "\n",
    "\n",
    "print('My Margin : '+str(mymargin))\n",
    "print('Pivot Price : ' + str(pivot_price))\n",
    "print('Full Quantity : '+str(fullquantity))\n",
    "print('Stoploss On ? : '+str(stoploss_on))\n",
    "print('Order Type : '+str(order_type))\n",
    "print()\n",
    "\n",
    "total_parts = 24\n",
    "\n",
    "scounter = int(total_parts/2)\n",
    "\n",
    "fibonmulti1=0.1180\n",
    "fibonmulti2=0.2360\n",
    "fibonmulti3=0.3820\n",
    "fibonmulti4=0.6180\n",
    "fibonmulti5=1.0000  # 100% Range\n",
    "fibonmulti6=1.1180\n",
    "fibonmulti7=1.2360\n",
    "fibonmulti8=1.3820\n",
    "fibonmulti9=1.6180\n",
    "fibonmulti10=2.0000 # Max Quantity @ 200% Range\n",
    "fibonmulti11=2.1180 # Stop Trading here\n",
    "fibonmulti12=2.3820 # STOPLOSS\n",
    "\n",
    "print()\n",
    "print('pivot price : ' +str(pivot_price))\n",
    "\n",
    "print()\n",
    "base=0.0025\n",
    "# mynewdf = pd.DataFrame({'Buy Price':[],'Quantity':[],'Sell Price':[],})\n",
    "\n",
    "for i in range(1, int(total_parts/2)+1):\n",
    "    globals()['p'+str(i)+'b'] = round(pivot_price - pivot_range*(globals()['fibonmulti'+str(i)]),4)\n",
    "    globals()['p'+str(i)+'b'] = round(base * round(globals()['p'+str(i)+'b'] /base),4)\n",
    "#     mynewdf.loc[i]['Buy Price'] = globals()['p'+str(i)+'b']\n",
    "    print('p'+str(i)+'b = '+str(globals()['p'+str(i)+'b']))\n",
    "\n",
    "print()\n",
    "for i in range(1, int(total_parts/2)+1):\n",
    "    globals()['p'+str(i)+'s'] = round(pivot_price + pivot_range*(globals()['fibonmulti'+str(i)]),4)\n",
    "    globals()['p'+str(i)+'s'] = round(base * round(globals()['p'+str(i)+'s'] /base),4)\n",
    "#     mynewdf.loc[i]['Sell Price'] = globals()['p'+str(i)+'s']\n",
    "    print('p'+str(i)+'s = '+str(globals()['p'+str(i)+'s']))\n",
    "\n",
    "print()\n",
    "\n",
    "halfqunat = fullquantity/2\n",
    "tempcounter = 1\n",
    "\n",
    "for j in range(2):\n",
    "    for i in range(4,-1,-1):\n",
    "        globals()['p'+str(tempcounter)+'q'] = int((halfqunat*j) + int(halfqunat/pow(powermulti,i)))\n",
    "        print('p'+str(tempcounter)+'q : ' + str(globals()['p'+str(tempcounter)+'q']))\n",
    "#         mynewdf.loc[i]['Quantity'] = globals()['p'+str(i)+'q']\n",
    "        tempcounter = tempcounter+1\n",
    "\n",
    "p11q = p10q\n",
    "if(stoploss_on==True):\n",
    "    p12q = 0\n",
    "else :\n",
    "    p12q = p11q\n",
    "\n",
    "print('p11q : '+ str(p11q))\n",
    "print('p12q : '+ str(p12q))"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "mynewdf"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": 10,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "My Quantity : 0\n"
     ]
    }
   ],
   "source": [
    "#####################\n",
    "# NORMAL RUN-2 of 3 #\n",
    "#####################\n",
    "\n",
    "myquantity = 0\n",
    "def getquant():\n",
    "    global myquantity\n",
    "    global order_type\n",
    "    global symbol_ip\n",
    "    allpos = kite.positions()['net']\n",
    "    for i in range(len(allpos)):\n",
    "        if(allpos[i]['tradingsymbol']==symbol_ip and  allpos[i]['product']== order_type):\n",
    "            myquantity = allpos[i]['quantity']\n",
    "            print('My Quantity : ' + str(allpos[i]['quantity']))\n",
    "        \n",
    "getquant()\n",
    "\n",
    "\n",
    "def ckqnt_old (orderprice,orderquant):\n",
    "    allpos = kite.positions()['net']\n",
    "    for i in range(len(allpos)):\n",
    "        if(allpos[i]['tradingsymbol']=='USDINR20OCTFUT'):\n",
    "            print('Position Quantity : ' + str(allpos[i]['quantity']))\n",
    "            quantdiff = orderquant - allpos[i]['quantity']\n",
    "            quantabs = abs(quantdiff)\n",
    "            if(quantdiff>0):\n",
    "                try:\n",
    "                    order_id =  kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                                exchange=kite.EXCHANGE_CDS,\n",
    "                                transaction_type=kite.TRANSACTION_TYPE_BUY,\n",
    "                                quantity=quantabs,\n",
    "                                order_type=kite.ORDER_TYPE_MARKET,\n",
    "                                variety = kite.VARIETY_REGULAR,\n",
    "                                product=kite.PRODUCT_MIS if order_type=='MIS' else kite.PRODUCT_NRML)\n",
    "                    \n",
    "                    allpos = kite.positions()['net']\n",
    "                except Exception as e:\n",
    "                    print(e)\n",
    "                    \n",
    "            if(quantdiff<0):\n",
    "                sellnewquant =  allpos[i]['quantity'] - orderquant\n",
    "                try:\n",
    "                    order_id =  kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                                exchange=kite.EXCHANGE_CDS,\n",
    "                                transaction_type=kite.TRANSACTION_TYPE_SELL,\n",
    "                                quantity=quantabs,\n",
    "                                order_type=kite.ORDER_TYPE_MARKET,\n",
    "                                variety = kite.VARIETY_REGULAR,\n",
    "                                product=kite.PRODUCT_MIS if order_type=='MIS' else kite.PRODUCT_NRML)\n",
    "                except Exception as e:\n",
    "                    print(e)\n",
    "                    \n",
    "    return allpos[i]['quantity']\n",
    "\n",
    "def placeneworder(quantdiff):\n",
    "    if(quantdiff>0):\n",
    "        try:\n",
    "                order_id= kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                            exchange=kite.EXCHANGE_CDS,\n",
    "                            transaction_type=kite.TRANSACTION_TYPE_BUY,\n",
    "                            quantity=abs(quantdiff),\n",
    "                            order_type=kite.ORDER_TYPE_MARKET,\n",
    "                            variety = kite.VARIETY_REGULAR,\n",
    "                            product=kite.PRODUCT_MIS if order_type=='MIS' else kite.PRODUCT_NRML)\n",
    "                getquant()\n",
    "        except Exception as e:\n",
    "            print(e)\n",
    "            getquant()\n",
    "    if(quantdiff<0):\n",
    "        try:\n",
    "                order_id= kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                            exchange=kite.EXCHANGE_CDS,\n",
    "                            transaction_type=kite.TRANSACTION_TYPE_SELL,\n",
    "                            quantity=abs(quantdiff),\n",
    "                            order_type=kite.ORDER_TYPE_MARKET,\n",
    "                            variety = kite.VARIETY_REGULAR,\n",
    "                            product=kite.PRODUCT_MIS if order_type=='MIS' else kite.PRODUCT_NRML)\n",
    "                getquant()\n",
    "        except Exception as e:\n",
    "            print(e)\n",
    "            getquant()\n",
    "\n",
    "\n",
    "def ckqnt (orderprice,orderquant):\n",
    "    global myquantity\n",
    "    quantdiff = orderquant - myquantity\n",
    "    placeneworder(quantdiff)\n",
    "    return myquantity\n",
    "\n",
    "\n",
    "def checkpivot(ltps):\n",
    "    if ((ltps>=(pivot_price-0.0050)) and (ltps<=(pivot_price+0.0050))):\n",
    "        ckqnt(pivot_price,0)\n",
    "        print('in pivot range')\n",
    "        \n",
    "    for i in range(1,int(total_parts/2)+1):\n",
    "        if(i==int(total_parts/2)):\n",
    "            if ((ltps <= (globals()['p'+str(i)+'b']-0.0025)) and stoploss_on==True ):\n",
    "                ckqnt(globals()['p'+str(i)+'b'],globals()['p'+str(i)+'q'])\n",
    "                print('==========' + 'p'+str(i)+'b' +'===========')\n",
    "                print(str(ltps)+ ' < ' + 'p'+str(i)+'b')\n",
    "            if ((ltps >= (globals()['p'+str(i)+'s']+0.0025)) and stoploss_on==True):\n",
    "                ckqnt(globals()['p'+str(i)+'s'],-(globals()['p'+str(i)+'q']))\n",
    "                print('==========' + 'p'+str(i)+'b' +'===========')\n",
    "                print(str(ltps)+ ' < ' + 'p'+str(i)+'b')\n",
    "        else:\n",
    "            if (ltps < (globals()['p'+str(i)+'b'] -0.0025) and ltps > (globals()['p'+str(i+1)+'b']+0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'b'],globals()['p'+str(i)+'q'])\n",
    "                print('==========' +'p'+str(i)+'b' + '==============' )\n",
    "                print(str(globals()['p'+str(i+1)+'b'])+ ' < ' +str(ltps)+ ' < ' +str(globals()['p'+str(i)+'b']))\n",
    "            if (ltps > (globals()['p'+str(i)+'s'] +0.0025) and ltps < (globals()['p'+str(i+1)+'s']-0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'s'],-(globals()['p'+str(i)+'q']))\n",
    "                print('==========' +'p'+str(i)+'s' + '==============' )\n",
    "                print(str(globals()['p'+str(i)+'s'])+ ' < ' +str(ltps)+ ' < ' +str(globals()['p'+str(i+1)+'s']))\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 11,
   "metadata": {
    "scrolled": true
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "in pivot range\n",
      "==========================\n",
      "LTP : 73.4275\n"
     ]
    },
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "Unhandled Error\n",
      "Traceback (most recent call last):\n",
      "  File \"<ipython-input-11-fd86e9b04400>\", line 57, in <module>\n",
      "    kws.connect()\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\kiteconnect\\ticker.py\", line 532, in connect\n",
      "    reactor.run(**opts)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 1283, in run\n",
      "    self.mainLoop()\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 1292, in mainLoop\n",
      "    self.runUntilCurrent()\n",
      "--- <exception caught here> ---\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 886, in runUntilCurrent\n",
      "    f(*a, **kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 646, in stop\n",
      "    raise error.ReactorNotRunning(\n",
      "twisted.internet.error.ReactorNotRunning: Can't stop reactor that isn't running.\n",
      "\n",
      "ERROR:kiteconnect.ticker:Connection error: 1006 - connection was closed uncleanly (peer dropped the TCP connection without previous WebSocket closing handshake)\n",
      "ERROR:root:closed connection on error: 1006 connection was closed uncleanly (peer dropped the TCP connection without previous WebSocket closing handshake)\n",
      "ERROR:kiteconnect.ticker:Connection closed: 1006 - connection was closed uncleanly (peer dropped the TCP connection without previous WebSocket closing handshake)\n",
      "Unhandled Error\n",
      "Traceback (most recent call last):\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\defer.py\", line 311, in addCallbacks\n",
      "    self._runCallbacks()\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\defer.py\", line 654, in _runCallbacks\n",
      "    current.result = callback(current.result, *args, **kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 447, in _continueFiring\n",
      "    callable(*args, **kwargs)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 704, in disconnectAll\n",
      "    log.callWithLogger(reader,\n",
      "--- <exception caught here> ---\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\python\\log.py\", line 103, in callWithLogger\n",
      "    return callWithContext({\"system\": lp}, func, *args, **kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\python\\log.py\", line 86, in callWithContext\n",
      "    return context.call({ILogContext: newCtx}, func, *args, **kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\python\\context.py\", line 122, in callWithContext\n",
      "    return self.currentContext().callWithContext(ctx, func, *args, **kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\python\\context.py\", line 85, in callWithContext\n",
      "    return func(*args,**kw)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\tcp.py\", line 519, in connectionLost\n",
      "    self._commonConnection.connectionLost(self, reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\tcp.py\", line 327, in connectionLost\n",
      "    protocol.connectionLost(reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\protocols\\tls.py\", line 403, in connectionLost\n",
      "    ProtocolWrapper.connectionLost(self, reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\protocols\\policies.py\", line 125, in connectionLost\n",
      "    self.wrappedProtocol.connectionLost(reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\autobahn\\twisted\\websocket.py\", line 287, in connectionLost\n",
      "    self._connectionLost(reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\autobahn\\websocket\\protocol.py\", line 3412, in _connectionLost\n",
      "    WebSocketProtocol._connectionLost(self, reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\autobahn\\websocket\\protocol.py\", line 1126, in _connectionLost\n",
      "    self._onClose(self.wasClean, WebSocketProtocol.CLOSE_STATUS_CODE_ABNORMAL_CLOSE, \"connection was closed uncleanly (%s)\" % self.wasNotCleanReason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\autobahn\\twisted\\websocket.py\", line 330, in _onClose\n",
      "    self.onClose(wasClean, code, reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\kiteconnect\\ticker.py\", line 81, in onClose\n",
      "    self.factory.on_close(self, code, reason)\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\kiteconnect\\ticker.py\", line 654, in _on_close\n",
      "    self.on_close(self, code, reason)\n",
      "  File \"<ipython-input-11-fd86e9b04400>\", line 34, in on_close\n",
      "    ws.stop()\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\kiteconnect\\ticker.py\", line 555, in stop\n",
      "    reactor.stop()\n",
      "  File \"C:\\Users\\YOGESH\\AppData\\Local\\Packages\\PythonSoftwareFoundation.Python.3.8_qbz5n2kfra8p0\\LocalCache\\local-packages\\Python38\\site-packages\\twisted\\internet\\base.py\", line 646, in stop\n",
      "    raise error.ReactorNotRunning(\n",
      "twisted.internet.error.ReactorNotRunning: Can't stop reactor that isn't running.\n",
      "\n"
     ]
    }
   ],
   "source": [
    "#####################\n",
    "# NORMAL RUN-3 of 3 #\n",
    "#####################\n",
    "#################\n",
    "# START TRADING #\n",
    "#################\n",
    "moving_pivot_on = 2\n",
    "import logging\n",
    "from kiteconnect import KiteTicker\n",
    "logging.basicConfig(level=logging.DEBUG)\n",
    "# kws = KiteTicker(\"w19o0chuo929jxkp\", \"eA5B5OJQNOtZ0OYihkBmYw7Ke3B9pmCC\")\n",
    "\n",
    "def on_ticks(ws, ticks):\n",
    "    global pivot_price, moving_pivot_on\n",
    "    checkpivot(ticks[0]['last_price'])\n",
    "\n",
    "#     if(moving_pivot_on):\n",
    "#         pivot_price =round(base * round(ticks[0]['average_price']/base),4) # Moving Trade Average Line : 1\n",
    "#         calc_pivots();                                                     # Moving Trade Average Line : 2\n",
    "        \n",
    "    #print('===========================')\n",
    "    #print(type(ticks[0]['last_price']))\n",
    "    print('==========================')\n",
    "    print( 'LTP : ' + str(ticks[0]['last_price']))\n",
    "    #print('==========================')\n",
    "    #print()\n",
    "\n",
    "def on_connect(ws, response):\n",
    "    global inst_token\n",
    "    ws.subscribe([inst_token])\n",
    "    ws.set_mode(ws.MODE_FULL, [inst_token])\n",
    "\n",
    "def on_close(ws, code, reason):\n",
    "    ws.stop()\n",
    "    \n",
    "def on_error(ws, code, reason):\n",
    "    logging.error(\"closed connection on error: {} {}\".format(code, reason))\n",
    "\n",
    "def on_noreconnect(ws):\n",
    "    logging.error(\"Reconnecting the websocket failed\")\n",
    "\n",
    "def on_reconnect(ws, attempt_count):\n",
    "    logging.debug(\"Reconnecting the websocket: {}\".format(attempt_count))\n",
    "\n",
    "#def on_order_update(ws, data):\n",
    "#    print(\"order update: \", data)\n",
    "\n",
    "kws.on_error = on_error\n",
    "kws.on_noreconnect = on_noreconnect\n",
    "kws.on_reconnect = on_reconnect\n",
    "#kws.on_order_update = on_order_update\n",
    "\n",
    "kws.on_ticks = on_ticks\n",
    "kws.on_connect = on_connect\n",
    "kws.on_close = on_close\n",
    "\n",
    "kws.connect()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.8.6"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}