import * as Minio from 'minio';
import config from '../../config';
import { DriveFile } from '../../models/entities/drive-file';
import { InternalStorage } from './internal-storage';
import { DriveFiles, Instances } from '../../models';
import { driveChart, perUserDriveChart, instanceChart } from '../chart';
export default async function(file: DriveFile, isExpired = false) {
if (file.storedInternal) {
InternalStorage.del(file.accessKey);
if (file.thumbnailUrl) {
InternalStorage.del(file.thumbnailAccessKey);
}
if (file.webpublicUrl) {
InternalStorage.del(file.webpublicAccessKey);
} else if (!file.isRemote) {
const minio = new Minio.Client(config.drive.config);
await minio.removeObject(config.drive.bucket, file.accessKey);
await minio.removeObject(config.drive.bucket, file.thumbnailAccessKey);
await minio.removeObject(config.drive.bucket, file.webpublicAccessKey);
// リモートファイル期限切れ削除後は直リンクにする
if (isExpired && file.userHost !== null) {
DriveFiles.update(file.id, {
isRemote: true,
url: file.uri,
thumbnailUrl: null,
webpublicUrl: null
});
} else {
DriveFiles.delete(file.id);
// 統計を更新
driveChart.update(file, false);
perUserDriveChart.update(file, false);
if (file.userHost !== null) {
instanceChart.updateDrive(file, false);
Instances.decrement({ host: file.userHost }, 'driveUsage', file.size);
Instances.decrement({ host: file.userHost }, 'driveFiles', 1);