uploadFile.js

import fs from "fs";
import { Blob } from "buffer";
import { Readable } from "stream";
import pkg from "@reactioncommerce/file-collections";

// import * as buffer from "buffer";
global.Blob = Blob;

const { FileRecord } = pkg;


export default async function uploadImages(context) {
  const { collections: { Media } } = context;
  const data = fs.readFileSync("./custom-packages/sample-data/src/images/fatbear.jpg");
  const blob = new Blob([data], { type: "image/jpg" });
  const fileRecord = FileRecord.fromBlob(blob);
  fileRecord.name("fatbear.jpg");
  await Media.insert(fileRecord);

  const writeStream = await Media.stores[0].createWriteStream(fileRecord);
  await new Promise((resolve, reject) => {
    writeStream.once("error", (err) => err && reject(err));
    writeStream.once("stored", resolve);
    Readable.from(data).pipe(writeStream);
  });
  console.log("done uploading images");
}