88 lines
2.1 KiB
JavaScript
88 lines
2.1 KiB
JavaScript
const db = require('../models');
|
|
const assert = require('assert');
|
|
const services = require('../../services/file');
|
|
|
|
module.exports = class FileDBApi {
|
|
static async replaceRelationFiles(
|
|
relation,
|
|
rawFiles,
|
|
options,
|
|
) {
|
|
assert(relation.belongsTo, 'belongsTo is required');
|
|
assert(
|
|
relation.belongsToColumn,
|
|
'belongsToColumn is required',
|
|
);
|
|
assert(relation.belongsToId, 'belongsToId is required');
|
|
|
|
let files = [];
|
|
|
|
if (Array.isArray(rawFiles)) {
|
|
files = rawFiles;
|
|
} else {
|
|
files = rawFiles ? [rawFiles] : [];
|
|
}
|
|
|
|
await this._removeLegacyFiles(relation, files, options);
|
|
await this._addFiles(relation, files, options);
|
|
}
|
|
|
|
static async _addFiles(relation, files, options) {
|
|
const transaction = (options && options.transaction) || undefined;
|
|
const currentUser = (options && options.currentUser) || {id: null};
|
|
|
|
const inexistentFiles = files.filter(
|
|
(file) => !!file.new,
|
|
);
|
|
|
|
for (const file of inexistentFiles) {
|
|
await db.file.create(
|
|
{
|
|
belongsTo: relation.belongsTo,
|
|
belongsToColumn: relation.belongsToColumn,
|
|
belongsToId: relation.belongsToId,
|
|
name: file.name,
|
|
sizeInBytes: file.sizeInBytes,
|
|
privateUrl: file.privateUrl,
|
|
publicUrl: file.publicUrl,
|
|
createdById: currentUser.id,
|
|
updatedById: currentUser.id,
|
|
},
|
|
{
|
|
transaction,
|
|
},
|
|
);
|
|
}
|
|
}
|
|
|
|
static async _removeLegacyFiles(
|
|
relation,
|
|
files,
|
|
options,
|
|
) {
|
|
const transaction = (options && options.transaction) || undefined;
|
|
|
|
const filesToDelete = await db.file.findAll({
|
|
where: {
|
|
belongsTo: relation.belongsTo,
|
|
belongsToId: relation.belongsToId,
|
|
belongsToColumn: relation.belongsToColumn,
|
|
id: {
|
|
[db.Sequelize.Op
|
|
.notIn]: files
|
|
.filter((file) => !file.new)
|
|
.map((file) => file.id)
|
|
},
|
|
},
|
|
transaction,
|
|
});
|
|
|
|
for (let file of filesToDelete) {
|
|
await services.deleteGCloud(file.privateUrl);
|
|
await file.destroy({
|
|
transaction,
|
|
});
|
|
}
|
|
}
|
|
};
|