const functions = require("firebase-functions"); const admin = require("firebase-admin"); let key = "./serviceAccountKey.json"; if (process.env.GCLOUD_PROJECT === "monkey-type") { key = "./serviceAccountKey_live.json"; } var serviceAccount = require(key); admin.initializeApp({ credential: admin.credential.cert(serviceAccount), }); // // Create and Deploy Your First Cloud Functions // // https://firebase.google.com/docs/functions/write-firebase-functions // // exports.helloWorld = functions.https.onRequest((request, response) => { // response.send("Hello from Firebase!"); // }); exports.moveResults = functions .runWith({ timeoutSeconds: 540, memory: "2GB" }) .https.onCall((request, response) => { return admin .firestore() .collection("results") .orderBy("timestamp", "desc") .limit(2000) .get() .then((data) => { data.docs.forEach((doc) => { let result = doc.data(); if (result.moved === undefined || result.moved === false) { admin .firestore() .collection(`results`) .doc(doc.id) .update({ moved: true }); admin .firestore() .collection(`users/${result.uid}/results`) .add(result); console.log(`moving doc ${doc.id}`); } }); return; }); }); function getAllNames() { return admin .auth() .listUsers() .then((data) => { let names = []; data.users.forEach((user) => { names.push(user.displayName); }); return names; }); } function getAllUsers() { return admin .auth() .listUsers() .then((data) => { return data.users; }); } function isUsernameValid(name) { if (name === null || name === undefined || name === "") return false; if (/miodec/.test(name)) return false; if (name.length > 12) return false; return /^[0-9a-zA-Z_.-]+$/.test(name); } exports.checkNameAvailability = functions.https.onCall((request, response) => { // 1 - available // -1 - unavailable (taken) // -2 - not valid name // -999 - unknown error try { if (!isUsernameValid(request.name)) return -2; return getAllNames().then((data) => { let available = 1; data.forEach((name) => { try { if (name.toLowerCase() === request.name.toLowerCase()) available = -1; } catch (e) { // } }); return available; }); } catch (e) { return -999; } }); exports.changeName = functions.https.onCall((request, response) => { try { if (!isUsernameValid(request.name)) { console.warn( `${request.uid} tried to change their name to ${request.name} - not valid` ); return 0; } return getAllNames().then((data) => { let available = 1; data.forEach((name) => { try { if (name.toLowerCase() === request.name.toLowerCase()) available = 0; } catch (e) { // } }); if (available === 1) { return admin .auth() .updateUser(request.uid, { displayName: request.name, }) .then((d) => { console.log( `${request.uid} changed their name to ${request.name} - done` ); return 1; }) .catch((e) => { console.error( `${request.uid} tried to change their name to ${request.name} - ${e.message}` ); return -1; }); } else { console.warn( `${request.uid} tried to change their name to ${request.name} - already taken` ); return 0; } }); } catch (e) { console.error( `${request.uid} tried to change their name to ${request.name} - ${e}` ); return -1; } }); exports.checkIfNeedsToChangeName = functions.https.onCall( (request, response) => { try { return admin .auth() .getUser(request.uid) .then((requestUser) => { if (!isUsernameValid(requestUser.displayName)) { //invalid name, needs to change console.log( `user ${requestUser.uid} ${requestUser.displayName} needs to change name` ); return 1; } else { //valid name, but need to change if not duplicate return getAllUsers().then((users) => { let sameName = []; //look for name names users.forEach((user) => { if (user.uid !== requestUser.uid) { try { if ( user.displayName.toLowerCase() === requestUser.displayName.toLowerCase() ) { sameName.push(user); } } catch (e) { // } } }); if (sameName.length === 0) { return 0; } else { //check when the request user made the account compared to others let earliestTimestamp = 999999999999999; sameName.forEach((sn) => { let ts = new Date(sn.metadata.creationTime).getTime() / 1000; if (ts <= earliestTimestamp) { earliestTimestamp = ts; } }); if ( new Date(requestUser.metadata.creationTime).getTime() / 1000 > earliestTimestamp ) { console.log( `user ${requestUser.uid} ${requestUser.displayName} needs to change name` ); return 2; } else { return 0; } } }); } }); } catch (e) { return -1; } } ); function checkIfPB(uid, obj) { return admin .firestore() .collection(`users`) .doc(uid) .get() .then((data) => { let pbs = null; try { pbs = data.data().personalBests; if (pbs === undefined) { throw new Error("pb is undefined"); } } catch (e) { return admin .firestore() .collection("users") .doc(uid) .update({ personalBests: { [obj.mode]: { [obj.mode2]: [ { language: obj.language, difficulty: obj.difficulty, punctuation: obj.punctuation, wpm: obj.wpm, }, ], }, }, }) .then((e) => { return true; }) .catch((e) => { return admin .firestore() .collection("users") .doc(uid) .set({ personalBests: { [obj.mode]: { [obj.mode2]: [ { language: obj.language, difficulty: obj.difficulty, punctuation: obj.punctuation, wpm: obj.wpm, }, ], }, }, }) .then((e) => { return true; }); }); } // //check mode, mode2, punctuation, language and difficulty let toUpdate = false; let found = false; try { pbs[obj.mode][obj.mode2].forEach((pb) => { if ( pb.punctuation === obj.punctuation && pb.difficulty === obj.difficulty && pb.language === obj.language ) { //entry like this already exists, compare wpm found = true; if (pb.wpm < obj.wpm) { //new pb pb.wpm = obj.wpm; toUpdate = true; } else { //no pb return false; } } }); //checked all pbs, nothing found - meaning this is a new pb if (!found) { pbs[obj.mode][obj.mode2].push({ language: obj.language, difficulty: obj.difficulty, punctuation: obj.punctuation, wpm: obj.wpm, }); toUpdate = true; } } catch (e) { // console.log(e); pbs[obj.mode] = {}; pbs[obj.mode][obj.mode2] = [ { language: obj.language, difficulty: obj.difficulty, punctuation: obj.punctuation, wpm: obj.wpm, }, ]; toUpdate = true; } if (toUpdate) { return admin .firestore() .collection("users") .doc(uid) .update({ personalBests: pbs }) .then((e) => { return true; }); } else { return false; } }); } exports.testCompleted = functions.https.onCall((request, response) => { try { if (request.uid === undefined || request.obj === undefined) { console.error(`error saving result for ${request.uid} - missing input`); return { resultCode: -1 }; } let obj = request.obj; let err = false; Object.keys(obj).forEach((key) => { let val = obj[key]; if (Array.isArray(val)) { val.forEach((valarr) => { if (!/^[0-9a-zA-Z._]+$/.test(valarr)) err = true; }); } else { if (val === undefined || !/^[0-9a-zA-Z._]+$/.test(val)) err = true; } }); if (err) { console.error( `error saving result for ${request.uid} - bad input - ${JSON.stringify( request.obj )}` ); return { resultCode: -1 }; } if (obj.wpm <= 0 || obj.wpm > 350 || obj.acc < 50 || obj.acc > 100) { return { resultCode: -1 }; } return admin .firestore() .collection(`users/${request.uid}/results`) .add(obj) .then((e) => { return checkLeaderboards(request.obj).then((lb) => { return checkIfPB(request.uid, request.obj).then((e) => { let returnobj = { resultCode: null, leaderboard: lb, }; if (e) { console.log( `saved result for ${request.uid} (new PB) - ${JSON.stringify( request.obj )}` ); returnobj.resultCode = 2; } else { console.log( `saved result for ${request.uid} - ${JSON.stringify( request.obj )}` ); returnobj.resultCode = 1; } return returnobj; }); }); }) .catch((e) => { console.error( `error saving result when checking for PB for ${request.uid} - ${e.message}` ); return { resultCode: -1 }; }); } catch (e) { console.error(`error saving result for ${request.uid} - ${e}`); return { resultCode: -1 }; } }); function isTagValid(name) { if (name === null || name === undefined || name === "") return false; if (name.length > 16) return false; return /^[0-9a-zA-Z_.-]+$/.test(name); } exports.addTag = functions.https.onCall((request, response) => { try { if (!isTagValid(request.name)) { return { resultCode: -1 }; } else { return admin .firestore() .collection(`users/${request.uid}/tags`) .add({ name: request.name, }) .then((e) => { console.log(`user ${request.uid} created a tag: ${request.name}`); return { resultCode: 1, id: e.id, }; }) .catch((e) => { console.error( `error while creating tag for user ${request.uid}: ${e.message}` ); return { resultCode: -999 }; }); } } catch (e) { console.error(`error adding tag for ${request.uid} - ${e}`); return { resultCode: -999 }; } }); exports.editTag = functions.https.onCall((request, response) => { try { if (!isTagValid(request.name)) { return { resultCode: -1 }; } else { return admin .firestore() .collection(`users/${request.uid}/tags`) .doc(request.tagid) .update({ name: request.name, }) .then((e) => { console.log(`user ${request.uid} updated a tag: ${request.name}`); return { resultCode: 1, }; }) .catch((e) => { console.error( `error while updating tag for user ${request.uid}: ${e.message}` ); return { resultCode: -999 }; }); } } catch (e) { console.error(`error updating tag for ${request.uid} - ${e}`); return { resultCode: -999 }; } }); exports.removeTag = functions.https.onCall((request, response) => { try { return admin .firestore() .collection(`users/${request.uid}/tags`) .doc(request.tagid) .delete() .then((e) => { console.log(`user ${request.uid} deleted a tag`); return { resultCode: 1, }; }) .catch((e) => { console.error( `error deleting tag for user ${request.uid}: ${e.message}` ); return { resultCode: -999 }; }); } catch (e) { console.error(`error deleting tag for ${request.uid} - ${e}`); return { resultCode: -999 }; } }); exports.updateResultTags = functions.https.onCall((request, response) => { try { let validTags = true; request.tags.forEach((tag) => { if (!/^[0-9a-zA-Z]+$/.test(tag)) validTags = false; }); if (validTags) { return admin .firestore() .collection(`users/${request.uid}/results`) .doc(request.resultid) .update({ tags: request.tags, }) .then((e) => { console.log( `user ${request.uid} updated tags for result ${request.resultid}` ); return { resultCode: 1, }; }) .catch((e) => { console.error( `error while updating tags for result by user ${request.uid}: ${e.message}` ); return { resultCode: -999 }; }); } else { console.error(`invalid tags for user ${request.uid}: ${request.tags}`); return { resultCode: -1 }; } } catch (e) { console.error(`error updating tags by ${request.uid} - ${e}`); return { resultCode: -999 }; } }); function isConfigKeyValid(name) { if (name === null || name === undefined || name === "") return false; if (name.length > 30) return false; return /^[0-9a-zA-Z_.\-#]+$/.test(name); } exports.saveConfig = functions.https.onCall((request, response) => { try { if (request.uid === undefined || request.obj === undefined) { console.error(`error saving config for ${request.uid} - missing input`); return -1; } let obj = request.obj; let err = false; Object.keys(obj).forEach((key) => { let val = obj[key]; if (Array.isArray(val)) { val.forEach((valarr) => { if (!isConfigKeyValid(valarr)) { err = true; console.error(`${key}: ${valarr} failed regex check`); } }); } else { if (!isConfigKeyValid(val)) { err = true; console.error(`${key}: ${val} failed regex check`); } } }); if (err) { console.error( `error saving config for ${request.uid} - bad input - ${JSON.stringify( request.obj )}` ); return -1; } return admin .firestore() .collection(`users`) .doc(request.uid) .set( { config: obj, }, { merge: true } ) .then((e) => { return 1; }) .catch((e) => { console.error( `error saving config to DB for ${request.uid} - ${e.message}` ); return -1; }); } catch (e) { console.error(`error saving config for ${request.uid} - ${e}`); return { resultCode: -999 }; } }); class Leaderboard { constructor(size, mode, mode2, type, starting) { this.size = size; this.board = []; this.mode = mode; this.mode2 = mode2; this.type = type; if (starting !== undefined && starting !== null) { starting.forEach((entry) => { if (entry.mode === this.mode && entry.mode2 === this.mode2) { this.board.push({ uid: entry.uid, wpm: parseFloat(entry.wpm), raw: parseFloat(entry.raw), acc: parseFloat(entry.acc), mode: entry.mode, mode2: entry.mode2, timestamp: entry.timestamp, }); } }); } this.sortBoard(); this.clipBoard(); } sortBoard() { this.board.sort((a, b) => { if (a.wpm === b.wpm) { if (a.acc === b.acc) { return a.timestamp - b.timestamp; } else { return b.acc - a.acc; } } else { return b.wpm - a.wpm; } }); } clipBoard() { let boardLength = this.board.length; if (boardLength > this.size) { while (this.board.length !== this.size) { this.board.pop(); } } } logBoard() { console.log(this.board); } insert(a) { let insertedAt = -1; if (a.mode === this.mode && a.mode2 === this.mode2) { this.board.forEach((b, index) => { if (insertedAt !== -1) return; if (a.wpm === b.wpm) { if (a.acc === b.acc) { if (a.timestamp < b.timestamp) { this.board.splice(index, 0, { uid: a.uid, wpm: parseFloat(a.wpm), raw: parseFloat(a.raw), acc: parseFloat(a.acc), mode: a.mode, mode2: a.mode2, timestamp: a.timestamp, }); insertedAt = index; } } else { if (a.acc > b.acc) { this.board.splice(index, 0, { uid: a.uid, wpm: parseFloat(a.wpm), raw: parseFloat(a.raw), acc: parseFloat(a.acc), mode: a.mode, mode2: a.mode2, timestamp: a.timestamp, }); insertedAt = index; } } } else { if (a.wpm > b.wpm) { this.board.splice(index, 0, { uid: a.uid, wpm: parseFloat(a.wpm), raw: parseFloat(a.raw), acc: parseFloat(a.acc), mode: a.mode, mode2: a.mode2, timestamp: a.timestamp, }); insertedAt = index; } } }); if (this.board.length < this.size && insertedAt === -1) { this.board.push({ uid: a.uid, wpm: parseFloat(a.wpm), raw: parseFloat(a.raw), acc: parseFloat(a.acc), mode: a.mode, mode2: a.mode2, timestamp: a.timestamp, }); insertedAt = this.board.length - 1; } this.clipBoard(); return insertedAt; } else { return -999; } } } async function checkLeaderboards(resultObj) { return admin .firestore() .collection("leaderboards") .where("mode", "==", String(resultObj.mode)) .where("mode2", "==", String(resultObj.mode2)) .get() .then((data) => { if (data.docs.length === 0) return null; let boardInfo = data.docs[0].data(); let boardData = boardInfo.board; console.log(`info ${JSON.stringify(boardInfo)}`); console.log(`data ${JSON.stringify(boardData)}`); let lb = new Leaderboard( 20, resultObj.mode, resultObj.mode2, boardInfo.type, boardData ); console.log("board created"); lb.logBoard(); let insertResult = lb.insert(resultObj); console.log("board after inseft"); lb.logBoard(); if (insertResult >= 0) { //update the database here console.log("board changed"); admin.firestore().collection("leaderboards").doc(data.docs[0].id).set( { board: lb.board, }, { merge: true } ); } else { console.log("board is the same"); } return insertResult; }); } exports.getLeaderboard = functions.https.onCall((request, response) => { return admin .firestore() .collection("leaderboards") .where("mode", "==", String(request.mode)) .where("mode2", "==", String(request.mode2)) .get() .then(async (data) => { let lbdata = data.docs[0].data(); for (let i = 0; i < lbdata.board.length; i++) { await admin .auth() .getUser(lbdata.board[i].uid) .then((userrecord) => { lbdata.board[i].name = userrecord.displayName; lbdata.board[i].uid = null; }); } return lbdata; }); }); // exports.getConfig = functions.https.onCall((request,response) => { // try{ // if(request.uid === undefined){ // console.error(`error getting config for ${request.uid} - missing input`); // return -1; // } // return admin.firestore().collection(`users`).doc(request.uid).get().then(e => { // return e.data().config; // }).catch(e => { // console.error(`error getting config from DB for ${request.uid} - ${e.message}`); // return -1; // }); // }catch(e){ // console.error(`error getting config for ${request.uid} - ${e}`); // return {resultCode:-999}; // } // })