adding image optimizer

functions/package.json

@@ -9,12 +9,14 @@
   "dependencies": {
     "@google-cloud/functions-framework": "^3.3.0",
     "@google-cloud/logging": "^10.5.0",
+    "@google-cloud/storage": "^6.12.0",
     "@google/events": "^5.4.0",
     "@typescript-eslint/eslint-plugin": "^6.2.1",
     "@typescript-eslint/parser": "^6.2.1",
     "eslint": "^8.46.0",
     "eslint-config-google": "^0.14.0",
     "eslint-plugin-import": "^2.28.0",
+    "sharp": "^0.32.4",
     "typescript": "^5.1.6"
   },
   "engines": {
@@ -23,6 +25,6 @@
   "scripts": {
     "lint": "eslint --fix --ext .js,.ts .",
     "build": "tsc",
-    "gcp-build": "yarn build"
+    "gcp-build": "yarn add sharp && yarn build"
   }
 }

functions/src/helpers/gCloudClients.ts

@@ -0,0 +1,3 @@
+import {Storage} from "@google-cloud/storage";
+
+export const storage = new Storage();

functions/src/storage/index.ts

@@ -1 +1 @@
-export * from "./moveToMainBucket";
+export * from "./optimizeImages";

functions/src/storage/optimizeImages.ts

@@ -0,0 +1,42 @@
+import type {
+  StorageObjectData,
+} from "@google/events/cloud/storage/v1/StorageObjectData";
+import {storage} from "../helpers/gCloudClients";
+import * as sharp from "sharp";
+
+const options = {
+  destBucket: "derlev.xyz",
+};
+
+export const optimizeImages = async (
+  event: StorageObjectData
+) => {
+  if (
+    !event.bucket ||
+    !event.name ||
+    !event.contentType?.startsWith("image/")
+  ) return;
+
+  const file = storage.bucket(event.bucket)
+    .file(event.name);
+
+  const fileRead = file.createReadStream();
+
+  const sharpRezise = sharp().webp({force: false, quality: 80, effort: 6})
+    .png({force: false, compressionLevel: 7, effort: 7})
+    .jpeg({force: false, quality: 80, mozjpeg: true})
+    .gif({force: false})
+    .tiff({force: false, quality: 80});
+
+  const sharpStream = fileRead.pipe(sharpRezise);
+
+  const destFile = storage.bucket(options.destBucket)
+    .file(event.name)
+    .createWriteStream();
+
+  const writeDestStream = sharpStream.pipe(destFile);
+
+  writeDestStream.on("close", async () => {
+    await file.delete();
+  });
+};