Uploading a file to 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 client = new os.ObjectStorageClient({
  authenticationDetailsProvider: provider,
});

const upload = multer({ dest: "tmp/uploads/" });
app.post("/putObject", upload.single("file"), async (req, res) => {
  console.log(`${req.method} ${req.path}`);
  const { bucketName, objectName } = req.body;
  try {
    if (!req.file) {
      throw new Error("No file uploaded");
    }
    const { path: filePath, originalname: fileName } = req.file;
    const result = await putObject({
      bucketName,
      filePath,
      objectName,
    });
    console.log(`200 ${req.path}`);
    res.status(200).send(result);
  } catch (err) {
    console.error(err);
    res.status(500).send(err);
  }
});

/**
 * Put an object (replaces if exists) into an OCI bucket
 * @param putObjectDetails
 * @returns the response from the putObject call
 */
export async function putObject(putObjectDetails: {
  bucketName: string;
  filePath: string;
  objectName: string;
}) {
  const { bucketName, filePath, objectName } = putObjectDetails;
  console.log(
    `Beginning putting object ${objectName} into bucket ${bucketName}`
  );

  const content = convertFileToUint8Array(filePath);
  const putObjectRequest: os.requests.PutObjectRequest = {
    namespaceName: OCI_BUCKET_NAMESPACE,
    bucketName: bucketName,
    putObjectBody: content,
    objectName: objectName,
    contentLength: content.length,
  };
  const putObjectResponse = await client.putObject(putObjectRequest);
  console.log(
    `Successfully put object ${objectName} into bucket ${bucketName}`
  );
  return putObjectResponse;
}

function convertFileToUint8Array(filePath: string): Uint8Array {
  const data = new Uint8Array(fs.readFileSync(filePath));
  return data;
}

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