CIDWA/servicio_social_api
12
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

carpetas beta

Browse Source
This commit is contained in:
Lemuel Helon Marquez Rosas
2021-01-19 21:10:49 -06:00
parent f22ffca48c
commit 21900828c2
4 changed files with 3304 additions and 137 deletions
Download Patch File Download Diff File Expand all files Collapse all files
package-lock.json
Generated
+3147 -6
View File
File diff suppressed because it is too large Load Diff
package.json
-1
View File
@@ -28,7 +28,6 @@
"dotenv": "^8.2.0",
"express": "^4.17.1",
"gmail-send": "^1.8.10",
"google-auth-library": "^6.1.3",
"googleapis": "^65.0.0",
"jsonwebtoken": "^8.5.1",
"mariadb": "^2.5.1",
server/db/capetasDrive.js
+37 -20
View File
@@ -3,29 +3,46 @@ const Usuario = require('../db/tablas/Usuario');
const Servicio = require('../db/tablas/Servicio');
const borrarCarpetas = async () => {
let carpetas = await drive.buscarCarpeta('418089309');
let archivos = await drive.archivosCarpeta(carpetas[0].id);
await Usuario.findAll({ where: { idTipoUsuario: 3 } }).then(async (res) => {
for (let i = 0; i < res.length; i++) {
let carpetasAlumno = await drive.buscarCarpetas(res[i].usuario);
console.log(carpetas);
console.log(
`El numero de cuenta ${res[i].usuario} tiene ${carpetasAlumno.length} carpetas.`
);
if (carpetasAlumno.length > 0) {
for (let j = 0; j < carpetasAlumno.length; j++) {
let archivos = await drive.archivosCarpeta(carpetasAlumno[j].id);
console.log(archivos);
console.log(archivos.length);
// await Usuario.findAll({ where: { idTipoUsuario: 3 } }).then(async (res) => {
// for (let i = 0; i < res.length; i++) {
// let carpetas = await drive.buscarCarpeta(res[i].usuario);
console.log(
`La carpeta ${carpetasAlumno[j].name} con id ${carpetasAlumno[j].id} tiene ${carpetasAlumno[j].length} archivos.`
);
if (j > 0) {
for (let k = 0; k < archivos.length; k++) {
console.log(
`Se movio el archivo ${archivos[k].name} con id ${archivos[k].id} de la carpeta ${carpetasAlumno[j].id} a la carpeta ${carpetasAlumno[0].id}`
);
// await drive.update(
// archivos[k].id,
// carpetasAlumno[0].id,
// carpetasAlumno[j].id
// );
}
console.log(`Se borro la carpet ${carpetasAlumno[j].id}`);
// await drive.deleteFile(carpetasAlumno[j].id)
}
}
// console.log(
// `En numero de cuenta ${res[i].usuario} tiene ${carpetas.length} carpetas.`
// );
// if (carpetas.length === 1) {
// await Servicio.update(
// { carpeta: carpetas[0].id },
// { where: { idUsuario: res.idUsuario } }
// );
// } else if (carpetas.length > 1) {
// }
// }
// });
// await Servicio.update(
// { carpeta: carpetasAlumno[0].id },
// { where: { idUsuario: res[i].idUsuario } }
// );
}
console.log(
'------------------------------------------------------------------'
);
}
});
};
borrarCarpetas();
server/helper/drive.js
+120 -110
View File
@@ -1,20 +1,93 @@
//Instalación normal mediante NPM
const { google } = require('googleapis');
const googleAuth = require('google-auth-library');
const fs = require('fs');
require('../config/config');
drive = google.drive('v3');
credenciales = JSON.parse(fs.readFileSync('./cred.json', 'utf8'));
//Crear objeto de autorización JWT
jwtClient = new google.auth.JWT(
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']
);
// Borrar archivo
const deleteFile = (fileId) => {
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) => {
jwtClient.authorize(function (err, tokens) {
if (err) reject('Error de autorización: ' + err);
let requestBody = {
name,
parents: [parent],
};
let media = {
mimeType: mimeType,
body: fs.createReadStream(`${path}`),
};
drive.files.create(
{
media: media,
fields: 'id',
requestBody,
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) => {
jwtClient.authorize((err, tokens) => {
if (err) reject('Error de autorización: ' + err);
let requestBody = {
name,
mimeType: 'application/vnd.google-apps.folder',
parents: [process.env.CARPETA],
};
drive.files.create(
{
fields: 'id',
auth: jwtClient,
requestBody,
},
(err, res) => {
if (err) reject(err);
resolve(res.data.id);
}
);
});
});
};
const list = (pageToken) => {
return new Promise((resolve, reject) => {
jwtClient.authorize((err, tokens) => {
@@ -40,8 +113,24 @@ const list = (pageToken) => {
});
};
// 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);
}
);
});
});
};
// Buscar carpeta
const buscarCarpeta = async (name) => {
const buscarCarpetas = async (name) => {
const data = [];
let pageToken = '';
@@ -77,111 +166,30 @@ const archivosCarpeta = async (id) => {
return data;
};
// Borrar archivo
const deleteFile = (fileId) => {
return new Promise((resolve, reject) => {
jwtClient.authorize(async (err, tokens) => {
if (err) reject(err);
const folder = async (numeroCuenta) => {
let pageToken = '';
drive.files.delete(
{
fileId,
auth: jwtClient,
},
(err, resp) => {
if (err) reject(err);
resolve(resp);
}
);
});
});
};
do {
let response = await list(pageToken);
let files = response.files;
// CREAR CARPETA
const mkDir = (name) => {
return new Promise((resolve, reject) => {
jwtClient.authorize((err, tokens) => {
if (err) reject('Error de autorización: ' + err);
let requestBody = {
name,
mimeType: 'application/vnd.google-apps.folder',
parents: [process.env.CARPETA],
};
drive.files.create(
{
fields: 'id',
auth: jwtClient,
requestBody,
},
(err, res) => {
if (err) reject(err);
resolve(res.data.id);
}
);
});
});
};
// CREAR ARCHIVO
const uploadFile = (path, name, mimeType, parent) => {
return new Promise((resolve, reject) => {
jwtClient.authorize(function (err, tokens) {
if (err) reject('Error de autorización: ' + err);
let requestBody = {
name,
parents: [parent],
};
let media = {
mimeType: mimeType,
body: fs.createReadStream(`${path}`),
};
drive.files.create(
{
media: media,
fields: 'id',
requestBody,
auth: jwtClient,
},
(err, file) => {
if (err) reject(err);
fs.unlinkSync(path);
resolve(file.data.id);
}
);
});
});
};
//deleteFile("");
//mkDir("316313528");
//uploadFile("arturo.jpg","image/jpeg","1DswUbL4uWE2RlB01XHLAIlPwh_0AXBHw");
//list()
const folder = (numeroCuenta) => {
return list()
.then((res) => {
for (let i = 0; i < res.length; i++) {
if (
res[i].mimeType === 'application/vnd.google-apps.folder' &&
res[i].name === numeroCuenta
)
return res[i].id;
}
return mkDir(numeroCuenta);
})
.then((res) => {
return res;
});
for (let i = 0; i < files.length; i++)
if (
files[i].name === numeroCuenta &&
files[i].mimeType === 'application/vnd.google-apps.folder'
)
return files[i].id;
pageToken = '';
if (response.nextPageToken) pageToken = response.nextPageToken;
} while (pageToken);
return mkDir(numeroCuenta);
};
const borrarTodo = () => {
return list().then(async (res) => {
console.log(res);
// for (let i = 0; i < res.length; i++)
// if (res[i].name !== 'Babyhelon') await deleteFile(res[i].id);
// for (let i = 0; i < res.files.length; i++)
// if (res.files[i].name !== 'Babyhelon') await deleteFile(res.files[i].id);
});
};
@@ -190,6 +198,8 @@ const borrarTodo = () => {
module.exports = {
folder,
uploadFile,
buscarCarpeta,
buscarCarpetas,
archivosCarpeta,
deleteFile,
update,
};