add Server

Author: thomas779

.DS_Store

@@ -0,0 +1,77 @@
+const Airtable = require("airtable");
+const settings = require("../settings.json");
+const colors = require("./json/tagColors.json");
+
+const API_KEY = "keyIUNtxniyBauoVn";
+
+const fcm = new Airtable({ apiKey: API_KEY }).base("appOXVfqFCJGee5KS");
+const emails = new Airtable({ apiKey: API_KEY }).base("apphtMo2vEtgp6IQg");
+const tags = new Airtable({ apiKey: API_KEY }).base("appHe5CWHGqSHbejn");
+
+exports.getFCMTokensForUsers = async function (users = []) {
+  var tokens = [];
+  console.log("[Info] Getting tokens for", users.length, "users");
+  await Promise.all(
+    await users.map(
+      async (uid) =>
+        await fcm("FCM Tokens")
+          .select({
+            filterByFormula: `{uid} = \"${uid}\"`,
+          })
+          .all()
+          .then(async (res) => {
+            res.forEach((elem) => {
+              tokens.push(elem.fields.token);
+            });
+          })
+          .catch((err) => {
+            console.warn("Could not get uid tokens from airtable", err);
+
+            return [];
+          })
+    )
+  );
+  tokens = [...new Set(tokens)]; // Remove duplicates
+  console.log("[Info] Received", tokens.length, "tokens");
+  return tokens;
+};
+
+const getAllTags = async function () {
+  return tags("Colors")
+    .select()
+    .all()
+    .then((tags) => {
+      return tags.map((elem) => {
+        return {
+          tag: elem.fields.Tag,
+          name: elem.fields.Tag,
+          value: elem.fields.Tag,
+          color: elem.fields.Color,
+        }; // Make key names lowerCase and suitable for enquirer
+      });
+    })
+    .catch((err) => {
+      throw err;
+    });
+};
+exports.getAllTags = getAllTags;
+exports.createTag = async function (tag) {
+  const existingTags = await getAllTags();
+
+  if (existingTags.every((elem) => elem.tag !== tag)) {
+    const color = colors[Math.floor(Math.random() * colors.length)];
+    tags("Colors")
+      .create({
+        Tag: tag,
+        Color: color,
+      })
+      .then(() => {
+        console.log("[Info] Created tag '" + tag + "'");
+        return { tag: tag };
+      })
+      .catch((err) => {
+        settings.debugErrors && console.trace("[Error]", err);
+        return { error: err };
+      });
+  } else console.log("[Info] Tag '" + tag + "' already existss");
+};

assets/airtable.js

@@ -0,0 +1,12 @@
+{
+  "type": "service_account",
+  "project_id": "campus42",
+  "private_key_id": "b97f4f6a0dba9dc045f9e2cb48e54e240ed0a895",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQC/5x8Zn+0bOG+c\n7LWzKXzRVbQI/mAznfgk9xPPGfwyyaYR7Ub6Nx6pyFrZ9e15v/6SiN25aUR7e7Q9\nHf24UBDYCUw0khDl8jjeIOPjybSqo7Yjy3W50s0V/ZBQa1/Zq4wDrYpkQl342RP1\nRkP4iYbGR+uSMmmSXoRmcTONla03iZAjdmLf4LTCmoIi4zYStGxiZV7diz884hST\nGRyCqjeK/uqu27J/CYO1SP68dobSVQxHPT87SMmsY1yxANgqu3AY8OKInBhYpX8Y\n8/Y1Is6bQoW5iU+bwcjQWNAcgcuncpt/9em3W7iKz96lfP4Pkq0Z3dOdUAvf0ENt\nQFhM7zfnAgMBAAECggEAAQvCpAi2toYRbBEjBGQrfzCXMWon60aAvbxv0GcoQSNp\nBk8wXdjDEAXWVbqWnfbculiIoAp7PXkOu6G+nXlb175lOrwfeQ4shSyeUVvq4is2\nQoevXC3r9Dy6w28L/LG7ETuqHDwuxImnJ2UUpcKKIem7PPbAk8DahxYC3YV9UwCO\n7DQ9uXACSqFbo8cL8mHtsLfRnEZSCaTVN+Y6+lsGPBG+kTE7RpVp+lCkIEnl5yyC\n0tlPkNvLh1jJ5SiBEQXMH/1H73LcDgHFi92RONMMT20DntWm0eLGneY8+ouI21wp\n+t/XIpWoZPGiBGNzhURoV+l8+u5DlDZiPytYDAGFMQKBgQDn1A4dg6hOeESq6PHV\n2/jhghvL1nz2mqz5asQQvY4F6ty2jc8dRgKtAb9AqqUf66Y8KCLMKd+l4l81EaNk\n5iiokW2UczLacUs2N7Uq4ssJGaav7rxT2VLUs9zz9zzOe6A/7LAjmlQ5uvltO6FT\n2K9sgcPLdU52LkbZjYn8oQlUbQKBgQDT6WCU/9DRVcRNq0KzwiVF5cyiukbSQ0SK\nuOykJbe4uamhimcfiDpTBoREI9xx4vIu5WKuScUr25AFi98nEKO7EYrP/1dAJkI8\n0BtTyNUYTVhKSlGsrqftm3DpDtPlBdKLR27C8SxZHO77SdhKPKw0Cb7NqUO6VUEh\nF57W1X1BIwKBgQDlmYx9SKaJSO3hQyI4h0rftSdoYz6SUjCcOVSDq+icDbaYiqwk\ntvDxfbh4CEnP6mhSTgHgqFwbA679dUGZLaX5BUc87jbgR7KQuO2R0tn5YlFHDy+v\n753skVJ0wVmUurXEedsc970RDA/6UkN+Mi3TTlWnDMAvpbd/wYF3FdqSpQKBgHqS\n/36wCgVL6uRSL57yqcSoi5mEzfpJVpg3Jwo7lu2O1wPNnqCql7H2jwMrCxQFBbkC\njfXqTdZ0hfXvVgCuq0ZFe1mchMdiWeX7KhNok3ofIva1zlBoJlJWGxVzsjVDDOnr\nQ7IW9mQFTGal7CnktmbTTD6Brd9V+Po/Q21Yx76pAoGBAN6VKzoyrMkm0qZvFqOw\nGE8VgKsZGwiLuP8neqBFFiyNAFyp1sCK7pR8WdHyCk7C5Me0Q9Rr/NX7YGvIpUTf\npREAkHLMXBsLBoCxQmmKpHu+66exHzC7Dy4NyAbPNpLGgQlXqkaEytY9gtPMmAXa\ndWk3rt4YrHjBxgCDXd75REjw\n-----END PRIVATE KEY-----\n",
+  "client_email": "[email protected]",
+  "client_id": "113137761909559070249",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-nda4u%40campus42.iam.gserviceaccount.com"
+}

assets/campus42-firebase-adminsdk-nda4u-b97f4f6a0d.json

@@ -0,0 +1 @@
+exports.campuses = ["university_of_buckingham", "campus_test"];

assets/campuses.js

@@ -0,0 +1,93 @@
+const settings = require("../settings.json");
+const d3 = require("d3-time-format");
+
+const validDate = (date) => date instanceof Date && !isNaN(date) && date.getTime() !== NaN;
+function parseTimeString(timeString) {
+  const pmHours = timeString.includes("pm") ? 12 : 0; // Add 12 hours if it is in the evening
+  var numbers = timeString.replace(/\D/g, ":").split(":");
+  const hours = parseInt(numbers[0]) + pmHours;
+  const mins = isNaN(numbers[1]) ? 0 : numbers[1] == "" ? 0 : parseInt(numbers[1]) || 0;
+  return { hours, mins };
+}
+
+exports.getDateFromSUEvent = async function (rawDate, time) {
+  const start = new Date(rawDate);
+  const end = new Date(rawDate);
+
+  if (!time) throw new Error("Non existing event date");
+  const timeParts = (time || "").split("-");
+
+  timeParts.forEach((elem, index) => {
+    var txt = elem.trim().toLowerCase();
+    var hour = 0;
+    var mins = 0;
+
+    if (elem.includes("midnight")) {
+      hour = index == 0 ? 0 : 23;
+      mins = index == 0 ? 0 : 59;
+    } else {
+      const time = parseTimeString(txt);
+      if (isNaN(time.hours) || isNaN(time.hours)) throw new Error("invalid date");
+      hour = time.hours;
+      mins = time.mins;
+    }
+
+    if (index == 0) {
+      start.setHours(hour);
+      start.setMinutes(mins, 0, 0);
+    } else if (index == 1) {
+      end.setHours(hour);
+      end.setMinutes(mins, 0, 0);
+    }
+  });
+
+  return {
+    start: start,
+    end: end,
+  };
+};
+
+exports.getMinutesFromDate = async function (minutes = 15) {
+  const date = new Date();
+  date.setMinutes(date.getMinutes() + minutes);
+  return date.getTime();
+};
+exports.getFutureDateMSInDays = async function (days = 14, date = new Date()) {
+  const startDate = new Date(date);
+  startDate.setDate(startDate.getDate() + days);
+  return startDate.getTime();
+};
+exports.getFutureDateMSInMinutes = async function (minutes = 15, startDate = new Date()) {
+  const date = startDate;
+  date.setMinutes(date.getMinutes() + minutes);
+  return date.getTime();
+};
+
+exports.getClosestRunIntervalDate = async function () {
+  const date = new Date();
+  const intervals = [];
+  // Create the intervals per hour and insert into intervals array
+  for (var x = 0; x < 60 / settings.scriptInterval; x++) {
+    intervals.push(x * settings.scriptInterval);
+  }
+  // Loop through these intervals and set minutes for and seconds so they match the start of the script time
+  const dateMins = date.getMinutes();
+  const len = intervals.length;
+
+  for (var i = 0; i < len; i++) {
+    if (i == len - 1 && dateMins >= intervals[len - 1]) {
+      date.setMinutes(intervals[i], 0, 0);
+    } else if (dateMins >= intervals[i] && dateMins < intervals[i + 1]) {
+      date.setMinutes(intervals[i], 0, 0);
+    }
+  }
+  return date;
+};
+
+exports.getFutureDateWithSetHours = async function (hours, mins, secs, days = settings.repeatCreationDaysAdvance) {
+  const futureDate = new Date();
+  futureDate.setDate(futureDate.getDate() + days);
+
+  futureDate.setHours(hours, mins, secs, 0);
+  return futureDate;
+};