I am having trouble uploading images to s3 using bun and hono.

[thadkrugman]

Hey everyone. I am having a lot of trouble figuring out how to upload images to s3. I thought I finally had it all figured out and I got all the errors to go away but my images are not actually showing up in my bucket. I'm not sure if I'm just doing something wrong or if it is something hono or bun specific. Any help would be appreciated.

//s3.ts

import {
  S3Client,
  PutObjectCommand,
  DeleteObjectCommand,
  GetObjectCommand,
} from '@aws-sdk/client-s3';
import { getSignedUrl } from '@aws-sdk/s3-request-presigner';

const bucketName = process.env.AWS_BUCKET_NAME;
const region = process.env.AWS_BUCKET_REGION;

const s3Client = new S3Client({
  region,
});

export function uploadFile(
  fileBuffer: Buffer,
  fileName: string,
  mimetype: string,
) {
  const uploadParams = {
    Bucket: bucketName,
    Body: fileBuffer,
    Key: fileName,
    ContentType: mimetype,
  };

  return s3Client.send(new PutObjectCommand(uploadParams));
}

export function deleteFile(fileName: string) {
  const deleteParams = {
    Bucket: bucketName,
    Key: fileName,
  };

  return s3Client.send(new DeleteObjectCommand(deleteParams));
}

export async function getObjectSignedUrl(key: string) {
  const params = {
    Bucket: bucketName,
    Key: key,
  };

  // https://aws.amazon.com/blogs/developer/generate-presigned-url-modular-aws-sdk-javascript/
  const command = new GetObjectCommand(params);
  const seconds = 60;
  const url = await getSignedUrl(s3Client, command, { expiresIn: seconds });

  return url;
}

// propertyRoutes.ts

import { Hono } from 'hono';
import { Clerk } from '@clerk/backend';
import { db } from '../lib/db';
import { property } from '../../.drizzle/schema';
import { eq } from 'drizzle-orm';
import { File } from 'buffer';
import { uploadFile, deleteFile, getObjectSignedUrl } from '../lib/aws/s3';
import { v4 as uuidv4 } from 'uuid';

const propertyRoutes = new Hono();
const clerk = Clerk({ apiKey: process.env.CLERK_API_KEY });

// get single property (finished)
propertyRoutes.get('/', async (c) => {
  try {
    const result = await db.query.property.findMany();
    return c.json(result);
  } catch (error) {
    console.error('Error fetching properties:', error);
    return c.text('Internal Server Error', 500);
  }
});

// get single property by id (finished)
propertyRoutes.get('/:id', async (c) => {
  try {
    const id = Number(c.req.param('id'));
    const result = await db.select().from(property).where(eq(property.id, id));

    if (result === null) {
      return c.notFound();
    }

    return c.json(result);
  } catch (error) {
    console.error('Error fetching property:', error);
    return c.text('Internal Server Error', 500);
  }
});

// create property (working on it)
propertyRoutes.post('/', async (c) => {
  const sessionId = c.req.header('sessionId');
  const token = c.req.header('authorization');

  if (sessionId && token) {
    try {
      const session = await clerk.sessions.verifySession(sessionId, token);
      if (session && session.status === 'active') {
        const createdBy = session.userId;
        const formData = await c.req.formData();

        const imageUrls = formData.get('imageUrls');

        if (imageUrls instanceof File) {
          const buffer = await imageUrls.arrayBuffer();
          const nodeBuffer = Buffer.from(buffer);
          const imageName = uuidv4();
          const response = await uploadFile(nodeBuffer, imageName, imageUrls.type);

          console.log('Image uploaded successfully');
        } else {
          return c.text('No file uploaded', 400);
        }

        /* return c.json(property); */
        return c.text('Property created successfully', 200);
      } else {
        return c.text('Unauthorized', 401);
      }
    } catch (error) {
      console.error('Error creating property:', error);
      return c.text('Internal Server Error', 500);
    }
  } else {
    return c.text('Unauthorized', 401);
  }
});

export default propertyRoutes;

//response from await uploadFile(nodeBuffer, imageName, imageUrls.type);

{
  $metadata: {
    httpStatusCode: 100,
    requestId: undefined,
    extendedRequestId: undefined,
    cfId: undefined,
    attempts: 1,
    totalRetryDelay: 0
  }