posts.run/lib/storage/r2Client.ts at main · hmmhmmhm/posts.run

Repository navigation

import { PutObjectCommand, S3 } from "@aws-sdk/client-s3";

import { nanoid } from "nanoid";

import sharp from "sharp";

export const r2Client = new S3({

region: " 53C7 auto",

endpoint: `https://${process.env.CLOUDFLARE_ACCOUNT_ID}.r2.cloudflarestorage.com`,

credentials: {

accessKeyId: process.env.R2_ACCESS_KEY_ID!,

secretAccessKey: process.env.R2_SECRET_ACCESS_KEY!,

});

export const R2_BUCKET = { bucketName: process.env.R2_BUCKET_NAME } as const;

export const uploadImageFile = async ({

buffer,

folder,

info,

compress = true,

}: {

buffer: ArrayBuffer;

folder: string;

info?: string;

compress?: boolean;

}): Promise<string> => {

const imageId = nanoid();

let compressedBuffer: Buffer;

if (compress) {

compressedBuffer = await sharp(buffer).webp().toBuffer();

} else {

compressedBuffer = Buffer.from(buffer);

}

const command: PutObjectCommand = new PutObjectCommand({

Bucket: process.env.R2_BUCKET_NAME!,

Key: `${folder}/${imageId}`,

Body: compressedBuffer,

ACL: "public-read",

ContentType: compress ? "image/webp" : "image/png",

...(info && { Metadata: { info } }),

});

await r2Client.send(command);

return `${process.env.STATIC_URL}/${folder}/${imageId}`;

};