index.js

import Fastify from "fastify";

import dotenv from "dotenv";
import {google} from "googleapis";
import fs from "fs-extra";

import FolderQueue from "./lib/drive.js";
import {getOrCreateChatRoom, addMemberToSpace, getSpace, findSpace } from "./lib/chat.js";
import {jigFetch} from "./lib/jig.js";

dotenv.config();

const oauth2Client = new google.auth.OAuth2(
  process.env.GOOGLE_CLIENTID,
  process.env.GOOGLE_CLIENTSECRET,
  "https://jig.bebot.chat/oauth2callback"
);

let stored = fs.readJSONSync("./bebot.tokens.json");
oauth2Client.setCredentials(stored);

oauth2Client.on('tokens', (tokens) => {
  let stored = fs.readJSONSync("./bebot.tokens.json");
  if (tokens.refresh_token) {
    stored.refresh_token = tokens.refresh_token;
  }
  stored.access_token = tokens.access_token
  fs.writeJSONSync("./bebot.tokens.json", stored);
});

const queue = new FolderQueue();

const fastify = Fastify({
  logger: {
    level: 'info',
    file: './logs/request.log' // Will use pino.destination()
  },
  bodyLimit: 8388608,
  http2SessionTimeout: 0
});

fastify.addHook('onRequest', (request, reply, done) => {
  console.log("Request received");
  done();
})

/** Establish Oauth2 BEBot user credentials 
 *  https://developers.google.com/identity/protocols/oauth2/web-server#node.js
 *  https://developers.google.com/identity/protocols/oauth2/scopes#chat
 *  This is only for the BEBot user. We require user access to create chat rooms
 *  and add users to the rooms. Service accounts are not an option
 */
fastify.get("/auth", async function (request, reply) {
  const url = oauth2Client.generateAuthUrl({
    access_type: 'offline',
    scope: ["https://www.googleapis.com/auth/chat.spaces https://www.googleapis.com/auth/chat.memberships https://www.googleapis.com/auth/drive"]
  });
  reply.header('Content-Type', 'text/html');
  reply.send(`<a href="${url}">Authorize BeBot user</a>`);
});

fastify.get("/oauth2callback", async function (request, reply) {
  const {tokens} = await oauth2Client.getToken(request.query.code);
  oauth2Client.setCredentials(tokens);
  reply.send("Success");
});

fastify.post("/activity/add", async function (request, reply) {
  console.log(request.body.data);
  // request.body.data.project.forEach(async project => {
    
  //   // Get or create the client and project folders
  //   queue.add(project);

  //   // Get or create chat room for the project
  //   getOrCreateChatRoom(project);
    
  // });
  reply.send("Success");
});

fastify.post("/project/add", async function (request, reply) {
  request.body.data.project.forEach(async project => {
    
    if (!project.projectFullName.startsWith("Oppty")) {
      // Get or create the client and project folders
      queue.add(project);

      // Get or create chat room for the project
      getOrCreateChatRoom(project);
    }
  });
  reply.send("Success");
});

fastify.post("/project/status", async function (request, reply) {
  request.body.data.project.forEach(async project => {
    
    if (!project.projectFullName.startsWith("Oppty")) {
      // Get or create the client and project folders
      queue.add(project);

      // Get or create chat room for the project
      getOrCreateChatRoom(project);
    }
  });
  reply.send("Success");
});

fastify.post("/task/user/add", async function (request, reply) {
  console.log("Task user add");
  
  let project = await jigFetch(`projects?projectKey=${request.body.data.task.projectKey}`);
  let space = await findSpace(project.data.project[0].projectFullName);
  
  if (space) {

    let team = [];
    
    // get the list of task tsers
    request.body.data.task.taskUser.forEach(user => {
      team.push(user.userID);
    });

    // Add the list of task detail users
    request.body.data.task.details.forEach(detail => {
      team.push(detail.userID);
    });

    // Remove duplicates
    team = [...new Set(team)];
    
    // Add each member to the space
    // Could probably get a list of people in the room already and eliminate unnecessary calls
    await asyncForEach(team, async (user) => {
      if(user) {
        await addMemberToSpace(space.name, user);
      }
    });

  }
  reply.send("Success");
});

fastify.listen({ port: process.env.PORT || 3001 }, function (err, address) {
  if (err) {
    fastify.log.error(err);
    process.exit(1);
  }
  // Server is now listening on ${address}
});

async function getActivityDetail(activityKey) {
  let response = await fetch(`https://app21.workamajig.com/api/beta1/activities?activityKey=${activityKey}`, {

  });
}

( async () => {

})();

const asyncForEach = async (array, callback) => {
  for (let index = 0; index < array.length; index++) {
      await callback(array[index], index, array);
  }
}

// queue.add({
//   "accountManagerKey": "U2E1SlhXeXFFNXU3YkpGKy9PN2FXZz090",
//   "accountManagerName": "Jonathan Fisher",
//   "clientName": "Pinnacle Engineering",
//   "projectName": "PINN New Corporate Website",
//   "projectFullName": "23-PINN-10023 PINN New Corporate Website",
//   "accountManager": "Jonathan Fisher",
//   "projectType": "Website",
//   "projectTypeName": "Website"
// });