Update Day-39

Author: abhijeetpandit7

Day-39-FlightFinderV1/README.md

@@ -0,0 +1,9 @@
+# Flight Finder V1
+
+### APIs Required
+
+- Google Sheet Data Management
+
+- Kiwi Partners Flight Search API
+
+<img src= 'https://user-images.githubusercontent.com/65078610/107887388-cab3f400-6f2b-11eb-93a6-95f296321214.PNG' width="350">

Day-39-FlightFinderV1/data_manager.py

@@ -0,0 +1,37 @@
+#This class is responsible for talking to the Google Sheet.
+import os
+import json
+import requests
+from dotenv import load_dotenv
+load_dotenv()
+
+class DataManager:
+    
+    def __init__(self):
+        self.sheety_endpoint = "https://api.sheety.co/126f9e38bb1fc18f122cb26e242ee654/flightDeals/prices"
+        self.headers = {
+        'Authorization': os.getenv('AUTH_TOKEN')
+        }
+
+    def get_data(self):
+        response = requests.get(url=self.sheety_endpoint, headers=self.headers)
+        data = json.loads(response.text)['prices']
+        # data = [
+        #     {
+        #         "city": "Kolkata",
+        #         "iataCode": "CCU",
+        #         "lowestPrice": 3345,
+        #         "id": 12
+        #     }
+        # ]
+        return data
+
+    def update_data(self, row_id, new_price):
+        sheety_update_endpoint = f"{self.sheety_endpoint}/{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)

Day-39-FlightFinderV1/flight_data.py

@@ -0,0 +1,36 @@
+#This class is responsible for structuring the flight data.
+class FlightData:
+
+    def __init__(self):
+        pass
+
+    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:
+            # print(f"{data['price']} {(data['route'][0]['local_arrival'])[:10]}")
+            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*14.8/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-39-FlightFinderV1/flight_search.py

@@ -0,0 +1,37 @@
+#This class is responsible for talking to the Flight Search API.
+from dotenv import load_dotenv
+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)
+        data = response.json()['data']
+        return data

Day-39-FlightFinderV1/main.py

@@ -0,0 +1,22 @@
+#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()
+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)
+    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)

Day-39-FlightFinderV1/notification_manager.py

@@ -0,0 +1,29 @@
+#This class is responsible for sending notifications with the deal flight details.
+from dotenv import load_dotenv
+import smtplib
+import os
+
+load_dotenv()
+my_email = os.getenv('EMAIL')
+to_email = os.getenv('TO_EMAIL')
+my_password = os.getenv('PASSWORD')
+
+class NotificationManager:
+    
+    def __init__(self):
+        pass
+
+    def send_alert(self, data):
+        with smtplib.SMTP(host="smtp.gmail.com", port=587) as connection:
+            connection.starttls()
+            connection.login(my_email, my_password)
+            connection.sendmail(
+                from_addr=my_email,
+                to_addrs=to_email,
+                msg=("Subject:Cheap Fare Alert!\n\n"+
+                    "Low price alert!\n"+
+                    f"Only Rs.{data['price']} "+
+                    f"to fly from {data['cityFrom']}-{data['cityCodeFrom']} "+
+                    f"to {data['cityTo']}-{data['cityCodeTo']},\n"+
+                    f"from {data['dateFrom']} to {data['dateTo']}")
+            )