Development

.gitignore

@@ -1,2 +1,3 @@
 node_modules/
+dataSources/
 .env

assets/AppStrings.js

@@ -0,0 +1,7 @@
+export const AppStrings = {
+  "user-already-exists-err-msg": "User with email address already exists",
+  "user-no-admin-access-err-msg": "Need admin access",
+  "user-not-logged-in": "You're not logged in",
+
+  "airline-already-exists-err-msg": "Airline already exists"
+}

controllers/AirlinesControllers.js

@@ -0,0 +1,43 @@
+import { User } from "../models/UsersModel"
+import { Airline } from "../models/AirlinesModel"
+import { AppStrings } from "../assets/AppStrings"
+
+export const AddAirline = async(req, res) => {
+  const { userId, admin, IATA, ICAO, name, country } = req.body
+
+  // TODO: AUTH implementation
+  if(!admin){
+    res.send(AppStrings["user-no-admin-access-err-msg"])
+  }
+
+  else{
+    const accessingUser = await User.findById(userId)
+
+    if(accessingUser){
+      const existingAirline = await Airline.find({ $and: [{ name }, { country }]}).exec()
+
+      if(existingAirline.length){
+        res.send(AppStrings["airline-already-exists-err-msg"])
+      }
+      else{
+        const NewAirline = new Airline({
+          IATA,
+          ICAO,
+          name: name.toUpperCase(),
+          country: country.toUpperCase()
+        })
+
+        NewAirline.save((err, SavedAirline) => {
+          if(err){
+            res.send(err)
+          }
+          res.json(SavedAirline)
+        })
+      }
+    }
+    else{
+      res.send(AppStrings["user-not-logged-in"])
+    }
+
+  }
+}

controllers/FlightsControllers.js

@@ -1,15 +1,82 @@
-export const GetFlights = async(req, res) => {
+import axios from "axios"
+import dayjs from "dayjs"
+import dotenv from "dotenv";
+
+import { asyncMap } from "../helpers"
+
+dotenv.config();
+export const GetFlights = async (req, res) => {
+
   try {
 
-  } catch(e){
-    console.log(e)
+  } catch (e) {
+    res.send(e);
   }
-}
+};
 
-export const AddNewFlight = async(req, res) => {
+export const AddNewFlight = async (req, res) => {
+  const { flightNumber, flightDate } = req.body
   try {
+    const flightDateDayJsObject = dayjs(flightDate).toISOString()
+
+    // Flightaware API calls to fetch aircraft registration based on the flight number
+    const flightsWithThisFlightNumberData = await axios.get(`${process.env.FLIGHTAWARE_API_DOMAIN}/flights/${flightNumber.toUpperCase()}`, { headers: {"x-apikey": process.env.FLIGHTAWARE_API_KEY } })
+
+    const flightsWithThisFlightNumber = flightsWithThisFlightNumberData.data.flights.filter((flight) => dayjs(flight.scheduled_out).isSame(flightDateDayJsObject, "day"))
+
+    const flightInformation = await asyncMap(flightsWithThisFlightNumber, async({ registration, scheduled_out, scheduled_in, status, progress_percent }) => {
+      const aircraftRegistration = registration
+
+      let aircraftImageResponse = []
+      if(aircraftRegistration !== null){
+        // Get aircraft picture
+        const flickrUrl = `${process.env.FLICKR_PHOTO_SEARCH_URL}&text=${aircraftRegistration}`
+
+        const aircraftPhotosReq = await axios.get(flickrUrl)
+
+        const aircraftPhotos = aircraftPhotosReq.data.photos.photo
+        const numOfPhotos = aircraftPhotos.length
+
+        let photosToConsider = []
+
+        // If there are more than 5 pictures, only show 5
+        // If less than 5, make sure there are atleast 2 and show them
+        // Else show the last image
+
+        if(numOfPhotos > 5){
+          photosToConsider = aircraftPhotos.slice(0,5)
+        }
+        if(numOfPhotos >= 2 && numOfPhotos < 5){
+          photosToConsider = aircraftPhotos.slice(0,2)
+        }
+
+        if(numOfPhotos < 2){
+          photosToConsider = [aircraftPhotos[numOfPhotos-1]]
+        }
+
+        aircraftImageResponse = photosToConsider.map(({ server, id, secret, title }) => {
+          const aircraftPhotoURL = `${process.env.FLICKR_PHOTO_URL}/${server}/${id}_${secret}.jpg`
+
+          return {
+            aircraftPhotoURL,
+            aircraftPhotoTitle: title
+          }
+        })
+      }
+
+      return {
+        aircraftRegistration,
+        status,
+        scheduledOut: scheduled_out,
+        scheduledIn: scheduled_in,
+        progressPercent: progress_percent,
+        aircraftImageResponse
+      }
+    })
 
-  } catch(e){
+    res.send(flightInformation)
+  } catch (e) {
     console.log(e)
+    res.send(e)
   }
-}
+};

controllers/UsersController.js

@@ -0,0 +1,30 @@
+import mongoose from "mongoose"
+import { AppStrings } from "../assets/AppStrings"
+import { User } from "../models/UsersModel"
+
+export const SignUpUser = async(req, res) => {
+  const { firstName, lastName, email } = req.body
+
+  const existingUser = await User.find({ email: email }).exec()
+  console.log(existingUser)
+
+  if(existingUser){
+    res.send(AppStrings["user-already-exists-err-msg"])
+  }
+
+  else{
+    const NewUser = new User({
+      firstName,
+      lastName,
+      email
+    })
+
+    NewUser.save((err, User) => {
+      if(err){
+        res.send(err)
+      }
+      res.json(User)
+    })
+  }
+
+}

helpers.js

@@ -0,0 +1,14 @@
+export const asyncForEach = async (arr, callback) => {
+  for (let index = 0; index < arr.length; index += 1) {
+    await callback(arr[index], index, arr);
+  }
+};
+
+export const asyncMap = async (array = [], callback) => {
+  const resultArray = [];
+  for (let index = 0; index < array.length; index++) {
+    const mappedValue = await callback(array[index], index, array);
+    resultArray[index] = mappedValue;
+  }
+  return resultArray;
+};

index.js

@@ -1,25 +1,55 @@
-import express from 'express'
-import mongoose from 'mongoose'
-import bodyparser from 'body-parser'
-import cors from 'cors'
-import dotenv from 'dotenv'
-import { pool } from "./dbConnection"
-import { routes } from "./routes/appRoutes"
+import express from "express";
+import mongoose from "mongoose";
+import bodyparser from "body-parser";
+import cors from "cors";
+import dotenv from "dotenv";
 
-dotenv.config()
+import { checkJwtAuth } from "./middlewares/auth"
+import { routes } from "./routes/appRoutes";
 
-const app = express()
+import { createUsers } from "./migration/createUsers"
+import { ImportAirports } from "./migration/importAirports"
+import { ImportAirlines } from "./migration/importAirlines"
 
-app.use(bodyparser.urlencoded({
-  extended: true
-}))
+dotenv.config();
 
-app.use(bodyparser.json())
+const app = express();
 
-app.use(cors())
+mongoose.connect(`mongodb://${process.env.DB_HOST}:${process.env.DB_PORT}/${process.env.DB_NAME}`,{
+  useNewUrlParser: true,
+  useUnifiedTopology: true
+})
 
-routes(app)
 
-app.listen(process.env.SERVER_PORT, () => {
-  console.log("Server running on port 3000")
-})
+app.use(
+  bodyparser.urlencoded({
+    extended: true
+  })
+);
+
+app.use(bodyparser.json());
+
+app.use(cors());
+
+app.use(checkJwtAuth);
+
+routes(app);
+
+app.listen(process.env.SERVER_PORT, async() => {
+  console.log(`Server running on port ${process.env.SERVER_PORT}`);
+
+  // Run to create users
+  // console.log("Creating user(s)")
+  // await createUsers()
+  // console.log("Finished creating users")
+
+  // Run to ingest airports data (Just USA for now)
+  // console.log("Initiating Airports Data load")
+  // await ImportAirports()
+  // console.log("Finished Airports Data Load")
+
+  // Run to ingest airlines data (Just USA for now)
+  // console.log("Initiating Airlines Data load")
+  // await ImportAirlines()
+  // console.log("Finished Airlines Data Load")
+});

middlewares/auth.js

@@ -0,0 +1,19 @@
+import jwt from "express-jwt";
+import jwksRsa from "jwks-rsa"
+import dotenv from "dotenv";
+
+dotenv.config();
+
+export const checkJwtAuth = jwt({
+  secret: jwksRsa.expressJwtSecret({
+    cache: true,
+    rateLimit: true,
+    jwksRequestsPerMinute: 5,
+    jwksUri: `https://${process.env.AUTH0_DOMAIN}/.well-known/jwks.json`
+  }),
+
+  // Validate the audience and the issuer.
+  audience: `https://${process.env.AUTH0_IDENTIFIER}`,
+  issuer: `https://${process.env.AUTH0_DOMAIN}/`,
+  algorithms: [`${process.env.AUTH0_ALGORITHM}`]
+});

migration/createUsers.js

@@ -0,0 +1,24 @@
+import mongoose from "mongoose"
+import { User } from "../models/UsersModel"
+import { asyncForEach } from "../helpers"
+
+const usersToAdd = []
+
+export const createUsers = async() => {
+  await asyncForEach(usersToAdd, async({ firstName, lastName, email }) => {
+    const UserToSave = new User({
+      firstName,
+      lastName,
+      email
+    })
+
+    UserToSave.save((err, UserSaved) => {
+      if(err){
+        console.error(err)
+      }
+      return UserSaved
+    })
+  })
+
+  return 1
+}

migration/importAirlines.js

@@ -0,0 +1,33 @@
+import mongoose from "mongoose"
+import axios from "axios"
+import dotenv from "dotenv";
+import { Airline } from "../models/AirlinesModel"
+import { AirlinesUsaData } from "../dataSources/AirlinesUsaData"
+import { asyncForEach } from "../helpers"
+
+dotenv.config();
+
+export const ImportAirlines = async() => {
+  const inputData = AirlinesUsaData
+
+  await asyncForEach(inputData, async({ Name, IATA, ICAO, Country, Active }) => {
+    const active = Active === "Y" ? true : false
+
+    const AirlineToSave = new Airline({
+      ICAO: ICAO.toUpperCase(),
+      IATA: IATA.toUpperCase(),
+      name: Name.toUpperCase(),
+      country: Country.toLowerCase(),
+      active
+    })
+
+    AirlineToSave.save((err, AirlineSaved) => {
+      if(err){
+        console.error(err)
+      }
+      return AirlineSaved
+    })
+  })
+
+  return 1
+}