Visa-Mail.ipynb

{
 "cells": [
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "## Twilio Call Account "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "from twilio.rest import Client\n",
    "\n",
    "# Your Account SID from twilio.com/console\n",
    "account_sid = \"ENTER SID HERE\"\n",
    "# Your Auth Token from twilio.com/console\n",
    "auth_token  = \"ENTER AUTH TOKEN HERE\"\n",
    "\n",
    "client = Client(account_sid, auth_token)\n",
    "\n",
    "def callShivam():\n",
    "        call = client.calls.create(\n",
    "                        url='http://demo.twilio.com/docs/voice.xml',\n",
    "                        to='+TO PHONE NUMNBER',\n",
    "                        from_='+ FROM PHONE NUMBER'\n",
    "                    )\n",
    "        print(call.sid)\n",
    "        \n",
    "def callAbhi():\n",
    "        call = client.calls.create(\n",
    "                        url='http://demo.twilio.com/docs/voice.xml',\n",
    "                        to='+TO PHONE NUMNBER',\n",
    "                        from_='+ FROM PHONE NUMBER'\n",
    "                    )\n",
    "        print(call.sid)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "## GMAIL API"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "from __future__ import print_function\n",
    "import webbrowser\n",
    "traveldocsurl = \"https://atlas.my.salesforce-sites.com/\"\n",
    "\n",
    "import os.path\n",
    "\n",
    "from google.auth.transport.requests import Request\n",
    "from google.oauth2.credentials import Credentials\n",
    "from google_auth_oauthlib.flow import InstalledAppFlow\n",
    "from googleapiclient.discovery import build\n",
    "from googleapiclient.errors import HttpError\n",
    "import datetime\n",
    "import time\n",
    "from playsound import playsound\n",
    "import random\n",
    "\n",
    "\n",
    "# If modifying these scopes, delete the file token.json.\n",
    "SCOPES = ['https://www.googleapis.com/auth/gmail.readonly']\n",
    "faces = [\"( ͡° ͜ʖ ͡°)\",\"(▀̿Ĺ̯▀̿ ̿)\",\"¯\\_(ツ)_/¯\",\"ಠ_ಠ\",\"(͡ ͡° ͜ つ ͡͡°)\"]\n",
    "flag = 0\n",
    "\n",
    "def main():\n",
    "    \"\"\"Shows basic usage of the Gmail API.\n",
    "    Lists the user's Gmail labels.\n",
    "    \"\"\"\n",
    "    creds = None\n",
    "    # The file token.json stores the user's access and refresh tokens, and is\n",
    "    # created automatically when the authorization flow completes for the first\n",
    "    # time.\n",
    "    if os.path.exists('newToken.json'):\n",
    "        creds = Credentials.from_authorized_user_file('newToken.json', SCOPES)\n",
    "    # If there are no (valid) credentials available, let the user log in.\n",
    "    if not creds or not creds.valid:\n",
    "        if creds and creds.expired and creds.refresh_token:\n",
    "            creds.refresh(Request())\n",
    "        else:\n",
    "            flow = InstalledAppFlow.from_client_secrets_file(\n",
    "                'CLIENT_SECRET.JSON', SCOPES)\n",
    "            creds = flow.run_local_server(port=0)\n",
    "        # Save the credentials for the next run\n",
    "        with open('newToken.json', 'w') as token:\n",
    "            token.write(creds.to_json())\n",
    "\n",
    "    try:\n",
    "        service = build('gmail', 'v1', credentials=creds)\n",
    "        while(True):\n",
    "            try: \n",
    "                # GET MESSAGES LIST\n",
    "                print(datetime.datetime.now(), \"LOOKING FOR NEW SLOTS... \"+random.choice(faces))\n",
    "                messagesList = service.users().messages().list(userId='me', q = \"from: alerts@checkvisaslots.com is:unread\").execute()\n",
    "                # IF SLOTS ARE AVAILABLE\n",
    "                if(messagesList['resultSizeEstimate'] > 0 ):\n",
    "                    # GETTING MESSAGE SUBJECT OF THE EMAIL\n",
    "                    messageData = service.users().messages().get(userId='me', id = messagesList['messages'][0]['id'] ).execute()\n",
    "                    for i in messageData['payload']['headers']:\n",
    "                        if(i['name'] == 'Subject'):\n",
    "                            print(\"SLOTS FOUND\" , i['value'])\n",
    "                            flag=1\n",
    "                    # IF SUBJECT OF THE EMAIL IS NOT FOUND\n",
    "                    if(flag == 0):\n",
    "                        print(\"Error Finding Subject !\")\n",
    "                    ##CALL MOBILE PHONE FUNCTIONS\n",
    "                    callShivam()\n",
    "                    callAbhi()\n",
    "                    #OPEN BROWSER \n",
    "                    webbrowser.open(traveldocsurl)\n",
    "                    # PLAYING ALERT SOUND WHEN SLOTS ARE FOUND \n",
    "                    playsound(\"Red Alert Ringtone-tones6.com.mp3\");\n",
    "                    time.sleep(10)\n",
    "                else:\n",
    "                    print(datetime.datetime.now(), \"Still looking... \"+random.choice(faces))\n",
    "                    time.sleep(5)\n",
    "            except Exception as e:\n",
    "                print(datetime.datetime.now(), \"API Unresponsive\", e)\n",
    "                time.sleep(20)\n",
    "        \n",
    "    except HttpError as error:\n",
    "        # TODO(developer) - Handle errors from gmail API.\n",
    "        print(f'An error occurred: {error}')\n",
    "\n",
    "\n",
    "if __name__ == '__main__':\n",
    "    main()"
   ]
  }
 ],
 "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.7.9"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}