first commit

app/controllers/sessionsController.js

@@ -0,0 +1,86 @@
+const moment = require('moment');
+const { getUserFromReferenceTable } = require('../db/mongo/mongoPilots');
+const { getSessions } = require('../db/mongo/mongoSessions');
+const { getHistoricalSessions } = require('../requests/ivao/session');
+
+async function getTodaySessionsFromIvao(callsign, incompletes) {
+  const from = moment().utc().startOf('day').format();
+  const to = moment().utc().endOf('day').format();
+  const params = {
+    callsign,
+    from,
+    to,
+  };
+  const data = await getHistoricalSessions(params);
+  if (!incompletes) {
+    return data.filter(d => d.isCompleted);
+  }
+  return data;
+
+}
+
+async function checkUsername(user, key) {
+  const u = {...user };
+  if (!u.name) {
+    const ref = await getUserFromReferenceTable(key);
+    if (ref) {
+      u.name = ref.name;
+    } else {
+      console.log(`Couldn't find info for ${key}`);
+    }
+  }
+  return u;
+}
+
+async function getList(callsign) {
+  const from = moment().utc().startOf('month');
+  const to = moment().subtract(1, 'day').utc().endOf('day');
+  const todayData = await getTodaySessionsFromIvao(callsign);
+  const monthData = await getSessions(from, to);
+  const allData = [...todayData, ...monthData];
+
+  const totalsByUserId = allData.reduce((acc, d) => {
+    const userId = d.userId;
+    const flightPlan = d.flightPlans[d.flightPlans.length - 1];
+    const date = moment(d.completedAt);
+    // console.log(date);
+
+    if (!acc[userId]) {
+      acc[userId] = {
+        time: 0,
+        flights: 0
+      };
+    }
+    acc[userId].time += d.time;
+    acc[userId].flights++;
+
+    if (!acc[userId].lastFlight || date.isAfter(acc[userId].lastFlightDate)) {
+      acc[userId].lastFlight = {...flightPlan };
+      acc[userId].lastFlightDate = date;
+      acc[userId].lastCallsign = d.callsign;
+
+      delete acc[userId].lastFlight.id;
+      if (d.user.firstName) {
+        acc[userId].name = `${d.user.firstName} ${d.user.lastName || ''}`;
+      }
+      acc[userId].division = d.user.divisionId;
+    }
+
+    return acc;
+  }, {});
+
+  const array = [];
+  for (const key in totalsByUserId) {
+    if (Object.hasOwnProperty.call(totalsByUserId, key)) {
+      const user = await checkUsername(totalsByUserId[key], key);
+      user.vid = key;
+      array.push(user);
+    }
+  }
+
+  return array;
+}
+
+module.exports = {
+  getList,
+};

app/db/mongo/mongoDBPool.js

@@ -0,0 +1,21 @@
+const { MongoClient } = require('mongodb');
+const {
+  MONGO_HOST,
+  MONGO_PORT,
+  MONGO_USER,
+  MONGO_PASS,
+  MONGO_DB,
+} = process.env;
+
+const uri = `mongodb://${MONGO_USER}:${MONGO_PASS}@${MONGO_HOST}:${MONGO_PORT}/?maxPoolSize=20`;
+
+module.exports = {
+  getMongoConnection: async() => {
+    const client = new MongoClient(uri);
+    return await client.connect();
+  },
+  getMongoDatabase: (client, db) => {
+    const DB = db || MONGO_DB || 'lsa_leaderboard';
+    return client.db(DB);
+  }
+};

app/db/mongo/mongoPilots.js

@@ -0,0 +1,24 @@
+const { getMongoConnection } = require("./mongoDBPool");
+const {
+  MONGO_DB,
+} = process.env;
+
+const DB = MONGO_DB || 'lts';
+
+async function getUserFromReferenceTable(vid) {
+  const conn = await getMongoConnection();
+  try {
+    const db = conn.db(DB);
+    const col = db.collection('pilots_ref');
+    const user = await col.findOne({ vid }, {});
+    return user;
+  } catch (err) {
+    console.error(err);
+  } finally {
+    await conn.close();
+  }
+}
+
+module.exports = {
+  getUserFromReferenceTable
+};

app/db/mongo/mongoSessions.js

@@ -0,0 +1,75 @@
+const moment = require("moment/moment");
+const { getMongoConnection } = require("./mongoDBPool");
+const {
+  MONGO_DB,
+} = process.env;
+
+const DB = MONGO_DB || 'lts';
+
+async function insertSessions(sessions, clear) {
+  const conn = await getMongoConnection();
+  try {
+    const db = conn.db(DB);
+    const sessionsCollection = db.collection('sessions');
+
+    if (clear) {
+      sessionsCollection.deleteMany({});
+    }
+
+    await sessionsCollection.insertMany(sessions);
+
+  } catch (err) {
+    console.error(err);
+  } finally {
+    await conn.close();
+  }
+}
+
+async function getSessions(start, end) {
+  const conn = await getMongoConnection();
+  try {
+    const db = conn.db(DB);
+    const sessionsCollection = db.collection('sessions');
+
+    const startDate = moment(start).utc().startOf('day').toDate();
+    const endDate = moment(end).utc().endOf('day').toDate();
+    const result = await sessionsCollection.aggregate([{
+      $addFields: {
+        completedDate: {
+          $dateFromString: {
+            "dateString": "$completedAt"
+          }
+        },
+        createdDate: {
+          $dateFromString: {
+            "dateString": "$createdAt"
+          }
+        },
+        updatedDate: {
+          $dateFromString: {
+            "dateString": "$updatedAt"
+          }
+        }
+      }
+    }, {
+      $match: {
+        createdDate: {
+          $gt: startDate,
+          $lte: endDate
+        }
+      }
+    }]).toArray();
+    return result;
+  } catch (err) {
+    console.error(err);
+  } finally {
+    await conn.close();
+  }
+}
+
+module.exports = {
+  insertSessions,
+  getSessions,
+};
+
+//http://localhost:3001/api/v1/ivao/init-sessions?callsign=LTS&from=2022-01-01T00:00:00&to=2023-01-04T23:59:59

app/requests/airports.js

@@ -0,0 +1,22 @@
+//https://www.airport-data.com/api/ap_info.json?icao=KMIA
+//https://airportdb.io/api/v1/airport/KMIA?apiToken=1419332340d1ac0b8c7921d2e38d763532b3d93e7f81382fd87356ac74347004877a5126bae6ef9de3a85f49b90e2426
+
+const {
+  request
+} = require('./request');
+
+const apiToken = process.env.TOKEN_AIRPORTDB;
+
+async function getAirport(icao = '') {
+  const url = `https://airportdb.io/api/v1/airport/${icao.toUpperCase()}`;
+  const options = {
+    params: {
+      apiToken
+    }
+  };
+  return await request(url, options);
+}
+
+module.exports = {
+  getAirport
+};

app/requests/ivao/session.js

@@ -0,0 +1,47 @@
+const { request } = require('../request');
+
+const getHistoricalSessions = async({ callsign, userId, from, to }) => {
+  //https://api.ivao.aero/v2/tracker/sessions?connectionType=PILOT&callsign=LTS&from=2022-01-01T00:00:00&to=2023-01-04T23:59:59&perPage=50
+  const url = 'https://api.ivao.aero/v2/tracker/sessions';
+  const params = {
+    connectionType: 'PILOT',
+    from,
+    page: 1,
+    perPage: 100,
+    to,
+  };
+
+  if (callsign) {
+    params.callsign = callsign;
+  }
+
+  if (userId) {
+    params.userId = userId;
+  }
+
+  const options = {
+    headers: {
+      apiKey: process.env.IVAO_APIKEY,
+    },
+    params,
+  };
+
+  return await _requestHistoricalRecursive([], url, options);
+};
+
+async function _requestHistoricalRecursive(data, url, options) {
+  console.log('options :>> ', options);
+  const { page, pages, items } = await request(url, options);
+  data = [...data, ...items];
+
+  if (page !== pages) {
+    options.params.page++;
+    return await _requestHistoricalRecursive(data, url, options)
+  } else {
+    return data;
+  }
+}
+
+module.exports = {
+  getHistoricalSessions,
+}

app/requests/ivao/wazzup.js

@@ -0,0 +1,8 @@
+const { request } = require('../request');
+const url = 'https://api.ivao.aero/v2/tracker/whazzup';
+
+const getIvaoWazzup = async() => {
+  return await request(url);
+};
+
+module.exports = { getIvaoWazzup };

app/requests/request.js

@@ -0,0 +1,10 @@
+const axios = require('axios');
+
+const request = async(url, options) => {
+  const response = await axios.get(url, options);
+  return response.data;
+};
+
+module.exports = {
+  request,
+};

app/routes/ivao.js

@@ -0,0 +1,50 @@
+const express = require('express');
+const { getList } = require('../controllers/sessionsController');
+const { insertSessions, getSessions } = require('../db/mongo/mongoSessions');
+const { getHistoricalSessions } = require('../requests/ivao/session');
+const router = express.Router();
+
+const { getIvaoWazzup } = require('../requests/ivao/wazzup');
+
+router.get('/wazzup', async(req, res) => {
+  try {
+    const data = await getIvaoWazzup();
+    res.status(200).json(data);
+  } catch (err) {
+    console.log(err);
+  }
+});
+
+router.get('/sessions', async(req, res) => {
+  try {
+    const data = await getSessions(req.query);
+    res.status(200).json(data);
+  } catch (err) {
+    console.log(err);
+  }
+});
+
+router.get('/list/today', async(req, res) => {
+  try {
+    const data = await getList('LTS');
+    res.status(200).json(data);
+  } catch (err) {
+    console.log(err);
+  }
+})
+
+router.get('/init-sessions', async(req, res) => {
+  try {
+    const data = await getHistoricalSessions(req.query);
+    await insertSessions(data);
+    console.log(`${data.length} sessions inserted.`);
+    res.status(200);
+  } catch (err) {
+    console.log(err);
+  }
+});
+
+module.exports = router;
+
+// http://localhost:3001/api/v1/ivao/sessions?callsign=LTS&from=2022-01-01T00:00:00&to=2022-12-31T23:59:59
+// http://localhost:3001/api/v1/ivao/sessions?start=2023-01-05&to=2023-01-05