servicio_social_api/server/helper/drive.js

require('../config/config');
const fs = require('fs');
const { google } = require('googleapis');
const drive = google.drive('v3');
const credenciales = JSON.parse(fs.readFileSync('./cred.json', 'utf8'));
const jwtClient = new google.auth.JWT(
  credenciales.client_email,
  null,
  credenciales.private_key,
  ['https://www.googleapis.com/auth/drive']
);

const Servicio = require(`../db/tablas/Servicio`);
const Usuario = require(`../db/tablas/Usuario`);

const list = (pageToken) => {
  return new Promise((resolve, reject) => {
    jwtClient.authorize((err, tokens) => {
      if (err) reject('Error de autorización: ' + err);
      drive.files.list(
        {
          auth: jwtClient,
          corpora: 'user',
          supportsTeamDrives: true,
          includeTeamDriveItems: true,
          spaces: 'drive',
          pageSize: 1000,
          pageToken,
          // fields: '*',
          orderBy: 'name',
        },
        (err, resp) => {
          if (err) reject('Ha habido un error en la petición: ' + err);
          resolve(resp.data);
        }
      );
    });
  });
};

// Borrar archivo
const deleteFile = (fileId) => {
  if (fileId === process.env.CARPETA)
    throw new Error('No se puede eliminar este archivo/carpeta.');
  return new Promise((resolve, reject) => {
    jwtClient.authorize(async (err, tokens) => {
      if (err) reject(err);
      drive.files.delete(
        {
          fileId,
          auth: jwtClient,
        },
        (err, resp) => {
          if (err) reject(err);
          resolve(resp);
        }
      );
    });
  });
};

// SUBIR ARCHIVO
const uploadFile = (path, name, mimeType, parent) => {
  return new Promise((resolve, reject) => {
    const requestBody = {
      name,
      parents: [parent],
    };
    const media = {
      mimeType,
      body: fs.createReadStream(`${path}`),
    };

    jwtClient.authorize(function (err, tokens) {
      if (err) reject('Error de autorización: ' + err);
      drive.files.create(
        {
          media,
          requestBody,
          fields: 'id',
          auth: jwtClient,
        },
        (err, file) => {
          if (err) reject(err);
          fs.unlinkSync(path);
          resolve(file.data.id);
        }
      );
    });
  });
};

// CREAR CARPETA
const mkDir = (name) => {
  return new Promise((resolve, reject) => {
    const requestBody = {
      name,
      mimeType: 'application/vnd.google-apps.folder',
      parents: [process.env.CARPETA],
    };

    jwtClient.authorize((err, tokens) => {
      if (err) reject('Error de autorización: ' + err);
      drive.files.create(
        {
          fields: 'id',
          auth: jwtClient,
          requestBody,
        },
        (err, res) => {
          if (err) reject(err);
          resolve(res.data.id);
        }
      );
    });
  });
};

// Update File
const update = (fileId, addParents, removeParents) => {
  return new Promise((resolve, reject) => {
    jwtClient.authorize((err, tokens) => {
      if (err) reject('Error de autorización: ' + err);
      drive.files.update(
        { auth: jwtClient, fileId, addParents, removeParents },
        (err, resp) => {
          if (err) reject('Ha habido un error en la petición: ' + err);
          resolve(resp.data);
        }
      );
    });
  });
};

const folder = async (numeroCuenta) => {
  let pageToken = '';

  do {
    let res = await list(pageToken);

    for (let i = 0; i < res.files.length; i++)
      if (
        res.files[i].name === numeroCuenta &&
        res.files[i].mimeType === 'application/vnd.google-apps.folder'
      )
        return res.files[i].id;
    pageToken = res.nextPageToken ? res.nextPageToken : '';
  } while (pageToken);
  return mkDir(numeroCuenta);
};

const borrarTodo = () => {
  return findAll().then(async ({ folders, pdfs }) => {
    console.log('Eliminando pdfs');
    for (let i = 0; i < pdfs.length; i++) {
      if (pdfs[i] !== process.env.CARPETA) {
        await deleteFile(pdfs[i]);
        console.log(`${i + 1}/${pdfs.length}`);
      }
    }
    console.log('Eliminando folders');
    for (let i = 0; i < folders.length; i++) {
      if (folders[i] !== process.env.CARPETA) {
        await deleteFile(folders[i]);
        console.log(`${i + 1}/${folders.length}`);
      }
    }
  });
};

const findAll = async () => {
  const folders = [];
  const pdfs = [];
  let pageToken = '';

  do {
    await list(pageToken).then((res) => {
      for (let i = 0; i < res.files.length; i++) {
        if (res.files[i].id !== process.env.CARPETA) {
          if (res.files[i].mimeType === 'application/vnd.google-apps.folder')
            folders.push(res.files[i].id);
          if (res.files[i].mimeType === 'application/pdf')
            pdfs.push(res.files[i].id);
        }
      }
      pageToken = res.nextPageToken ? res.nextPageToken : '';
    });
  } while (pageToken);
  return { folders, pdfs };
};

const scriptCambioDeCarpeta = async () => {
  console.log('Entrando a scriptCambioDeCarpeta');

  const servicios = await Servicio.findAll({
    where: { idStatus: [1, 2, 3, 4, 5, 7, 8, 9] },
    include: [{ model: Usuario }],
  });

  for (let i = 0; i < servicios.length; i++) {
    // por cada cuenta
    console.log(`${i + 1}/${servicios.length}`);
    if (servicios[i].idStatus === 6) {
      console.log('algo mal');
      console.log(servicios[i]);
    }
    const carpetaCreada = await mkDir(`${servicios[i].Usuario.usuario}`); //se crea una crapeta dentro de la carpeta cuyo id guardamos antes y guardamos el id de la carpeta creada

    await Servicio.update(
      { carpeta: carpetaCreada },
      { where: { idServicio: servicios[i].idServicio } }
    ); // se actualiza el id de la carpeta por la que se acaba de crear
    console.log(
      `${i} - [${servicios[i].idServicio}] [${servicios[i].Usuario.usuario}] : [${carpetaCreada}] - [${servicios[i].carpeta}]`
    );
  }
  console.log('Saliendo de scriptCambioDeCarpeta');
};

// scriptCambioDeCarpeta();
// borrarTodo();

module.exports = {
  folder,
  uploadFile,
  deleteFile,
  mkDir,
};