Downloading a file from Oracle Object Storage using Node.JS

npm i oci-common oci-sdk

import express, { Request } from "express";
import cors from "cors";
import multer from "multer";
import fs from "fs";
import os = require("oci-objectstorage");
import { ConfigFileAuthenticationDetailsProvider } from "oci-common";

// Create express app
const app = express();

app.use(express.json());
app.use(cors());

app.get("/helloText", (req, res) => {
  res.send({ myResponse: "Hello World!" });
});

const provider = new ConfigFileAuthenticationDetailsProvider(
  "~/.oci/config",
  "DEFAULT"
);

const OCI_BUCKET_NAMESPACE = "id9ek7fershl";
const MAX_OBJECT_SIZE = 1_000_000_000; // 1 GB

const client = new os.ObjectStorageClient({
  authenticationDetailsProvider: provider,
});

app.get(
  "/getObject",
  async (
    req: Request<
      void,
      unknown,
      void,
      { bucketName: string; objectName: string }
    >,
    res
  ) => {
    console.log(`${req.method} ${req.path}`);
    const { bucketName, objectName } = req.query;
    function onFinish(filepath: string, lastModified: Date) {
      console.log("Last modified: ", lastModified);
      res.status(200).download(filepath);
      console.log(
        `Successfully got object ${objectName} from bucket ${bucketName}`
      );
    }
    try {
      if (!bucketName || !objectName) {
        throw new Error("Missing required parameters");
      }
      await getObject({
        bucketName,
        objectName,
        onFinish,
      });
      console.log(`200 ${req.path}`);
    } catch (err) {
      console.error(err);
      res.status(500).send(err);
    }
  }
);

/**
 * Get an object from an OCI bucket
 * @param getObjectDetails
 * @returns the filepath of the temporary object and the last modified date of the object
 */
export async function getObject(getObjectDetails: {
  objectName: string;
  bucketName: string;
  onFinish: (filepath: string, lastModified: Date) => void;
}) {
  const { objectName, bucketName, onFinish } = getObjectDetails;
  console.log(
    `Beginning getting object ${objectName} from bucket ${bucketName}`
  );
  const getObjectRequest: os.requests.GetObjectRequest = {
    objectName: objectName,
    bucketName: bucketName,
    namespaceName: OCI_BUCKET_NAMESPACE,
  };
  let reader: ReadableStreamDefaultReader<any> | undefined;
  try {
    const getObjectResponse = await client.getObject(getObjectRequest);
    const stream = getObjectResponse.value as ReadableStream<any>;
    reader = stream.getReader();
    const downloadFilepath = "./temp/" + objectName;
    const writableStream = fs.createWriteStream(downloadFilepath);

    while (writableStream.bytesWritten < MAX_OBJECT_SIZE) {
      const { done, value } = await reader.read();
      if (done) {
        writableStream.end();
        reader.releaseLock();
        break;
      }
      writableStream.write(value);
    }

    writableStream.on("finish", () => {
      console.log(bucketName);
      onFinish(downloadFilepath, getObjectResponse.lastModified);
    });
  } catch (err) {
    reader?.releaseLock();
    if (err.statusCode === 404) {
      throw new Error(`Object ${objectName} not found in bucket ${bucketName}`);
    }
  }
}

app.listen(8000, () => {
  console.log(`Server is running on port ${8000}`);
});