next/lib/server/storyHelpers/replaceGridFS.ts

17 lines
513 B
TypeScript

import getBucket from "./getBucket";
import { Readable } from "stream";
export default async function replaceGridFS(chapterID: number | undefined, content: string) {
let filename = `/stories/${chapterID}.txt`;
const bucket = getBucket();
if (chapterID) {
const curs = bucket.find({ filename }).limit(1);
for await (const d of curs) {
await bucket.delete(d._id);
}
}
const readable = new Readable();
readable.push(content);
readable.push(null);
readable.pipe(bucket.openUploadStream(filename));
}