mizzkey/src/api/common/add-file-to-drive.ts

import * as mongodb from 'mongodb';
import * as crypto from 'crypto';
import * as gm from 'gm';
import * as debug from 'debug';
import fileType = require('file-type');
import prominence = require('prominence');
import DriveFile, { getGridFSBucket } from '../models/drive-file';
import DriveFolder from '../models/drive-folder';
import serialize from '../serializers/drive-file';
import event from '../event';
import config from '../../conf';
import { Buffer } from 'buffer';
import * as fs from 'fs';
import * as tmp from 'tmp';
import * as stream from 'stream';

const log = debug('misskey:register-drive-file');

const tmpFile = (): Promise<string> => new Promise((resolve, reject) => {
	tmp.file((e, path) => {
		if (e) return reject(e);
		resolve(path);
	});
});

const addToGridFS = (name: string, readable: stream.Readable, type: string, metadata: any): Promise<any> =>
	getGridFSBucket()
		.then(bucket => new Promise((resolve, reject) => {
			const writeStream = bucket.openUploadStream(name, { contentType: type, metadata });
			writeStream.once('finish', (doc) => { resolve(doc); });
			writeStream.on('error', reject);
			readable.pipe(writeStream);
		}));

/**
 * Add file to drive
 *
 * @param user User who wish to add file
 * @param file File path, binary, or readableStream
 * @param comment Comment
 * @param type File type
 * @param folderId Folder ID
 * @param force If set to true, forcibly upload the file even if there is a file with the same hash.
 * @return Object that represents added file
 */
export default (
	user: any,
	file: string | Buffer | stream.Readable,
	name: string = null,
	comment: string = null,
	folderId: mongodb.ObjectID = null,
	force: boolean = false
) => new Promise<any>((resolve, reject) => {
	log(`registering ${name} (user: ${user.username})`);

	// Get file path
	new Promise((res: (v: string) => void, rej) => {
		if (typeof file === 'string') {
			res(file);
			return;
		}
		if (file instanceof Buffer) {
			tmpFile()
				.then(path => {
					fs.writeFile(path, file, (err) => {
						if (err) rej(err);
						res(path);
					});
				})
				.catch(rej);
			return;
		}
		if (typeof file === 'object' && typeof file.read === 'function') {
			tmpFile()
				.then(path => {
					const readable: stream.Readable = file;
					const writable = fs.createWriteStream(path);
					readable
						.on('error', rej)
						.on('end', () => {
							res(path);
						})
						.pipe(writable)
						.on('error', rej);
				})
				.catch(rej);
		}
		rej(new Error('un-compatible file.'));
	})
		// Calculate hash, get content type and get file size
		.then(path => Promise.all([
			path,
			// hash
			((): Promise<string> => new Promise((res, rej) => {
				const readable = fs.createReadStream(path);
				const hash = crypto.createHash('md5');
				const chunks = [];
				readable
					.on('error', rej)
					.pipe(hash)
					.on('error', rej)
					.on('data', (chunk) => chunks.push(chunk))
					.on('end', () => {
						const buffer = Buffer.concat(chunks);
						res(buffer.toString('hex'));
					});
			}))(),
			// mime
			((): Promise<[string, string | null]> => new Promise((res, rej) => {
				const readable = fs.createReadStream(path);
				readable
					.on('error', rej)
					.once('data', (buffer: Buffer) => {
						readable.destroy();
						const type = fileType(buffer);
						if (!type) {
							return res(['application/octet-stream', null]);
						}
						return res([type.mime, type.ext]);
					});
			}))(),
			// size
			((): Promise<number> => new Promise((res, rej) => {
				fs.stat(path, (err, stats) => {
					if (err) return rej(err);
					res(stats.size);
				});
			}))()
		]))
		.then(async ([path, hash, [mime, ext], size]) => {
			log(`hash: ${hash}, mime: ${mime}, ext: ${ext}, size: ${size}`);

			// detect name
			const detectedName: string = name || (ext ? `untitled.${ext}` : 'untitled');

			if (!force) {
				// Check if there is a file with the same hash
				const much = await DriveFile.findOne({
					md5: hash,
					'metadata.user_id': user._id
				});

				if (much !== null) {
					log('file with same hash is found');
					return resolve(much);
				} else {
					log('file with same hash is not found');
				}
			}

			const [properties, folder] = await Promise.all([
				// properties
				(async () => {
					if (!/^image\/.*$/.test(mime)) {
						return null;
					}
					// If the file is an image, calculate width and height to save in property
					const g = gm(fs.createReadStream(path), name);
					const size = await prominence(g).size();
					const properties = {
						width: size.width,
						height: size.height
					};
					log('image width and height is calculated');
					return properties;
				})(),
				// folder
				(async () => {
					if (!folderId) {
						return null;
					}
					const driveFolder = await DriveFolder.findOne({
						_id: folderId,
						user_id: user._id
					});
					if (!driveFolder) {
						throw 'folder-not-found';
					}
					return driveFolder;
				})(),
				// usage checker
				(async () => {
					// Calculate drive usage
					const usage = await DriveFile
						.aggregate([
							{ $match: { 'metadata.user_id': user._id } },
							{
								$project: {
									length: true
								}
							},
							{
								$group: {
									_id: null,
									usage: { $sum: '$length' }
								}
							}
						])
						.then((aggregates: any[]) => {
							if (aggregates.length > 0) {
								return aggregates[0].usage;
							}
							return 0;
						});

					log(`drive usage is ${usage}`);

					// If usage limit exceeded
					if (usage + size > user.drive_capacity) {
						throw 'no-free-space';
					}
				})()
			]);

			const readable = fs.createReadStream(path);

			return addToGridFS(name, readable, mime, {
				user_id: user._id,
				folder_id: folder !== null ? folder._id : null,
				comment: comment,
				properties: properties
			});
		})
		.then(file => {
			log(`drive file has been created ${file._id}`);
			resolve(file);
			return serialize(file);
		})
		.then(serializedFile => {
			// Publish drive_file_created event
			event(user._id, 'drive_file_created', fileObj);

			// Register to search database
			if (config.elasticsearch.enable) {
				const es = require('../../db/elasticsearch');
				es.index({
					index: 'misskey',
					type: 'drive_file',
					id: file._id.toString(),
					body: {
						name: file.name,
						user_id: user._id.toString()
					}
				});
			}
		})
		.catch(reject);
});