Update Day-40

Author: abhijeetpandit7

Day-40-FlightFinderV2/README.md

@@ -0,0 +1,11 @@
+# Flight Finder V2
+
+### Sign up [here](https://repl.it/@abhijeetpandit/FlightDealsClub?embed=1&output=1#main.py), We'll let you know when flights to amazing destinations go really, reaaally cheap!
+
+### Here's is How it Works
+
+- Join Flight Club
+- Get cheapest flight deals
+- You get to go on a holiday
+
+<img src= 'https://user-images.githubusercontent.com/65078610/108055938-a6b0f980-7076-11eb-971c-41370a14bfb8.PNG' width="500">

Day-40-FlightFinderV2/data_manager.py

@@ -0,0 +1,35 @@
+#This class is responsible for talking to the Google Sheet.
+import os
+import json
+from pprint import pprint
+import requests
+from dotenv import load_dotenv
+load_dotenv()
+
+class DataManager:
+    
+    def __init__(self):
+        self.sheety_endpoint = "https://api.sheety.co/126f9e38bb1fc18f122cb26e242ee654/flightDeals"
+        self.headers = {
+        'Authorization': os.getenv('AUTH_TOKEN')
+        }
+
+    def get_data(self):
+        response = requests.get(url=self.sheety_endpoint+'/prices', headers=self.headers)
+        data = json.loads(response.text)['prices']
+        return data
+
+    def update_data(self, row_id, new_price):
+        sheety_update_endpoint = f"{self.sheety_endpoint+'/prices'}/{row_id}"
+        price_config = {
+            'price': {
+                "lowestPrice": round(new_price)
+            }
+        }
+        response = requests.put(url=sheety_update_endpoint, json=price_config , headers=self.headers)
+        print(response.text)
+
+    def get_users(self):
+        response = requests.get(url=self.sheety_endpoint+'/users', headers=self.headers)
+        data = json.loads(response.text)['users']
+        return data

Day-40-FlightFinderV2/flight_data.py

@@ -0,0 +1,32 @@
+#This class is responsible for structuring the flight data.
+class FlightData:
+
+    def compare(self, price_data, lowest_price):
+        # Normalize API price hike
+        lowest_price += lowest_price*14.8/100
+        self.price_data = price_data
+        self.price_array = []
+        self.date_array = []
+        for data in self.price_data:
+            self.price_array.append(int(data['price']))
+            self.date_array.append((data['route'][0]['local_arrival'])[:10])
+        self.min_price = min(self.price_array)
+        return self.min_price < lowest_price
+
+    def get_data(self):
+        low_limit = self.price_array.index(self.min_price)
+        self.price_array.reverse()
+        high_limit = self.price_array.index(self.min_price)
+        self.min_price -= self.min_price*13/100
+        flight_details = {
+            'price': round(self.min_price),
+            'cityFrom': self.price_data[0]['route'][0]['cityFrom'],
+            'cityCodeFrom': self.price_data[0]['route'][0]['cityCodeFrom'],
+            'cityTo': self.price_data[0]['route'][0]['cityTo'],   
+            'cityCodeTo': self.price_data[0]['route'][0]['cityCodeTo'],
+            'dateFrom': self.date_array[low_limit],
+            'dateTo': ''
+        }
+        self.date_array.reverse()
+        flight_details['dateTo'] = self.date_array[high_limit]
+        return flight_details

Day-40-FlightFinderV2/flight_search.py

@@ -0,0 +1,44 @@
+#This class is responsible for talking to the Flight Search API.
+from dotenv import load_dotenv
+from pprint import pprint
+from datetime import *
+import requests
+import os
+
+load_dotenv()
+FLY_FROM = 'BOM'
+CURRENCY = 'INR'
+FLIGHT_TYPE = 'oneway'
+SORT_BY = 'date'
+
+class FlightSearch:
+
+    def __init__(self):
+        self.from_date =(datetime.now()+timedelta(days=1)).strftime('%d/%m/%Y')
+        self.to_date =(datetime.now()+timedelta(days=180)).strftime('%d/%m/%Y')
+        self.kiwi_endpoint = "https://tequila-api.kiwi.com/v2/search/"
+        self.headers = {
+        'apikey': os.getenv('API_KEY')
+        }
+        self.parameters = {
+            'fly_from': FLY_FROM,
+            'fly_to': '',
+            'date_from': self.from_date,
+            'date_to': self.to_date,
+            'curr': CURRENCY,
+            'flight_type': FLIGHT_TYPE,
+            'one_per_date': 1,
+            'sort': SORT_BY
+        }
+    
+    def get_data(self, fly_to):
+        self.parameters['fly_to'] = fly_to
+        response = requests.get(url=self.kiwi_endpoint, params=self.parameters, headers=self.headers)
+        try:
+            data = response.json()['data']
+        except KeyError:
+            print(f"No flights available to {fly_to}")
+            return []
+        else:
+            # pprint(data[0])
+            return data

Day-40-FlightFinderV2/main.py

@@ -0,0 +1,26 @@
+#This file will need to use the DataManager,FlightSearch, FlightData, NotificationManager classes to achieve the program requirements.
+from notification_manager import NotificationManager
+from flight_search import FlightSearch
+from flight_data import FlightData
+from data_manager import DataManager
+
+notification_manager = NotificationManager()
+flight_search = FlightSearch()
+flight_data = FlightData()
+data_manger = DataManager()
+user_list = data_manger.get_users()
+destination_list = data_manger.get_data()
+
+for city in destination_list:
+    city_id = city['id']
+    lowest_price = city['lowestPrice']
+    fly_to = city['iataCode']
+    price_data = flight_search.get_data(fly_to)
+    # Check if no flights available
+    if not price_data:
+        continue
+    is_cheap_deal = flight_data.compare(price_data, lowest_price)
+    if is_cheap_deal:
+        flight_details = flight_data.get_data()
+        data_manger.update_data(city_id, flight_data.min_price)
+        notification_manager.send_alert(flight_details, user_list)

Day-40-FlightFinderV2/notification_manager.py

@@ -0,0 +1,39 @@
+# This class is responsible for sending notifications with the deal flight details.
+from calendar import month_name
+from dotenv import load_dotenv
+import smtplib
+import os
+
+load_dotenv()
+my_email = os.getenv('EMAIL')
+my_password = os.getenv('PASSWORD')
+
+class NotificationManager:
+
+    def send_alert(self, data, users):
+        link = (f"https://www.google.co.in/flights?hl=en#flt={data['cityCodeFrom']}.{data['cityCodeTo']}."+
+            f"{data['dateFrom']}*{data['cityCodeTo']}.{data['cityCodeFrom']}.{data['dateTo']}")
+        with smtplib.SMTP(host="smtp.gmail.com", port=587) as connection:
+            connection.starttls()
+            connection.login(my_email, my_password)
+            for user in users:
+                to_email = user['email']
+                fName = user['firstName']
+                connection.sendmail(
+                    from_addr=my_email,
+                    to_addrs=to_email,
+                    msg=("Subject:Flight Deals Alert!✈️\n\n"+
+                        f"Hi, {fName},\n"
+                        f"Super cheap fares to {data['cityTo']}. Get in. On this!\n"+
+                        f"This is the cheapest deal to {data['cityTo']} in the upcoming 6 months.\n\n"
+                        f"Only ₹{data['price']:,} to fly from, \n"+
+                        f"{data['cityFrom']} ({data['cityCodeFrom']}) "+
+                        f"to {data['cityTo']} ({data['cityCodeTo']}).\n"+
+                        f"Tickets available from {self.dateFormat(data['dateFrom'])} to {self.dateFormat(data['dateTo'])}\n"+
+                        f"{link}\n\n"+
+                        "Cheers, \nAbhijeet").encode('utf-8')
+                )
+
+    def dateFormat(self, str):
+        arr = str.split('-')
+        return (f"{arr[2]} {month_name[int(arr[1].strip('0'))]}, {arr[0]}")

Day-40-FlightFinderV2/signup.py

@@ -0,0 +1,27 @@
+# Sign up for new user
+import os
+import requests
+from dotenv import load_dotenv
+load_dotenv()
+
+print("Welcome to the Flight Club!.")
+print("Join our Flight Club and never pay full fare again")
+fName = input("What is your first name?\n")
+lName = input("What is your last name?\n")
+email = input("What is your email?\n")
+print("You're in the club, We'll email you with amazing flight deals!")
+
+# Add new user to sheets
+sheety_endpoint = "https://api.sheety.co/126f9e38bb1fc18f122cb26e242ee654/flightDeals/users"
+headers = {
+'Authorization': os.getenv('AUTH_TOKEN')
+}
+user_config = {
+    'user': {
+      "firstName": fName,
+      "lastName": lName,
+      "email": email
+    }
+}
+response = requests.post(url=sheety_endpoint, json=user_config, headers=headers)
+print(response.text)