feat: image compression w/ sharp

website/src/lib/auth.ts

@@ -42,8 +42,7 @@ export const auth = betterAuth({
                             s3ImageKey = await uploadProfilePicture(
                                 profile.sub,
                                 new Uint8Array(arrayBuffer),
-                                blob.type,
-                                blob.size
+                                blob.type || 'image/jpeg'
                             );
                         }
                     } catch (error) {

website/src/lib/server/image.ts

@@ -0,0 +1,39 @@
+import sharp from 'sharp';
+
+const MAX_SIZE = 128;
+const WEBP_QUALITY = 50;
+
+export interface ProcessedImage {
+    buffer: Buffer;
+    contentType: string;
+    size: number;
+}
+
+export async function processImage(
+    inputBuffer: Buffer,
+): Promise<ProcessedImage> {
+    try {
+        const image = sharp(inputBuffer, { animated: true });
+
+        const processedBuffer = await image
+            .resize(MAX_SIZE, MAX_SIZE, {
+                fit: 'inside',
+                withoutEnlargement: true
+            })
+            .webp({
+                quality: WEBP_QUALITY,
+                effort: 6
+            })
+            .toBuffer();
+
+        return {
+            buffer: processedBuffer,
+            contentType: 'image/webp',
+            size: processedBuffer.length
+        };
+
+    } catch (error) {
+        console.error('Image processing failed:', error);
+        throw new Error('Failed to process image');
+    }
+}

website/src/lib/server/s3.ts

@@ -2,6 +2,7 @@ import { S3Client, GetObjectCommand, PutObjectCommand, DeleteObjectCommand } fro
 import { getSignedUrl } from '@aws-sdk/s3-request-presigner';
 import { PRIVATE_B2_KEY_ID, PRIVATE_B2_APP_KEY } from '$env/static/private';
 import { PUBLIC_B2_BUCKET, PUBLIC_B2_ENDPOINT, PUBLIC_B2_REGION } from '$env/static/public';
+import { processImage } from './image.js';
 
 const s3Client = new S3Client({
     endpoint: PUBLIC_B2_ENDPOINT,
@@ -47,7 +48,6 @@ export async function uploadProfilePicture(
     identifier: string, // Can be user ID or a unique ID from social provider
     body: Uint8Array,
     contentType: string,
-    contentLength?: number
 ): Promise<string> {
     if (!contentType || !contentType.startsWith('image/')) {
         throw new Error('Invalid file type. Only images are allowed.');
@@ -58,17 +58,16 @@ export async function uploadProfilePicture(
         throw new Error('Unsupported image format. Only JPEG, PNG, GIF, and WebP are allowed.');
     }
 
-    let fileExtension = contentType.split('/')[1];
-    if (fileExtension === 'jpeg') fileExtension = 'jpg';
-
-    const key = `avatars/${identifier}.${fileExtension}`;
+    const processedImage = await processImage(Buffer.from(body));
+    
+    const key = `avatars/${identifier}.webp`;
 
     const command = new PutObjectCommand({
         Bucket: PUBLIC_B2_BUCKET,
         Key: key,
-        Body: body,
-        ContentType: contentType,
-        ...(contentLength && { ContentLength: contentLength }),
+        Body: processedImage.buffer,
+        ContentType: processedImage.contentType,
+        ContentLength: processedImage.size,
     });
 
     await s3Client.send(command);
@@ -79,7 +78,6 @@ export async function uploadCoinIcon(
     coinSymbol: string,
     body: Uint8Array,
     contentType: string,
-    contentLength?: number
 ): Promise<string> {
     if (!contentType || !contentType.startsWith('image/')) {
         throw new Error('Invalid file type. Only images are allowed.');
@@ -90,17 +88,16 @@ export async function uploadCoinIcon(
         throw new Error('Unsupported image format. Only JPEG, PNG, GIF, and WebP are allowed.');
     }
 
-    let fileExtension = contentType.split('/')[1];
-    if (fileExtension === 'jpeg') fileExtension = 'jpg';
+    const processedImage = await processImage(Buffer.from(body));
 
-    const key = `coins/${coinSymbol.toLowerCase()}.${fileExtension}`;
+    const key = `coins/${coinSymbol.toLowerCase()}.webp`;
 
     const command = new PutObjectCommand({
         Bucket: PUBLIC_B2_BUCKET,
         Key: key,
-        Body: body,
-        ContentType: contentType,
-        ...(contentLength && { ContentLength: contentLength }),
+        Body: processedImage.buffer,
+        ContentType: processedImage.contentType,
+        ContentLength: processedImage.size,
     });
 
     await s3Client.send(command);