49 lines
1.6 KiB
JavaScript
49 lines
1.6 KiB
JavaScript
// @ts-check
|
|
|
|
import { createWriteStream, unlink } from "node:fs";
|
|
|
|
import shortId from "shortid";
|
|
|
|
import UPLOAD_DIRECTORY_URL from "./config/UPLOAD_DIRECTORY_URL.mjs";
|
|
|
|
/**
|
|
* Stores a GraphQL file upload in the filesystem.
|
|
* @param {Promise<
|
|
* import("graphql-upload/processRequest.mjs").FileUpload
|
|
* >} upload GraphQL file upload.
|
|
* @returns {Promise<string>} Resolves the stored file name.
|
|
*/
|
|
export default async function storeUpload(upload) {
|
|
const { createReadStream, filename } = await upload;
|
|
const stream = createReadStream();
|
|
const storedFileName = `${shortId.generate()}-${filename}`;
|
|
const storedFileUrl = new URL(storedFileName, UPLOAD_DIRECTORY_URL);
|
|
|
|
// Store the file in the filesystem.
|
|
await new Promise((resolve, reject) => {
|
|
// Create a stream to which the upload will be written.
|
|
const writeStream = createWriteStream(storedFileUrl);
|
|
|
|
// When the upload is fully written, resolve the promise.
|
|
writeStream.on("finish", resolve);
|
|
|
|
// If there's an error writing the file, remove the partially written file
|
|
// and reject the promise.
|
|
writeStream.on("error", (error) => {
|
|
unlink(storedFileUrl, () => {
|
|
reject(error);
|
|
});
|
|
});
|
|
|
|
// In Node.js <= v13, errors are not automatically propagated between piped
|
|
// streams. If there is an error receiving the upload, destroy the write
|
|
// stream with the corresponding error.
|
|
stream.on("error", (error) => writeStream.destroy(error));
|
|
|
|
// Pipe the upload into the write stream.
|
|
stream.pipe(writeStream);
|
|
});
|
|
|
|
return storedFileName;
|
|
}
|