feat: initial genkit feature draft

Author: cabljac

extensions/image-processing-api/functions/src/operations/genkit.ts

@@ -0,0 +1,47 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import sharp from 'sharp';
+import superstruct from 'superstruct';
+import { OperationBuilder, ValidatedOperation } from '../types';
+
+const name = 'genkit';
+
+const struct = superstruct.object({
+  operation: superstruct.literal(name),
+  // Add any parameters for your external API if needed.
+});
+
+export const operationGenkit: OperationBuilder = {
+  name,
+  struct,
+  async build(
+    operation: ValidatedOperation,
+    fileMetadata: sharp.Metadata | null,
+  ) {
+    // Instead of returning a standard sharp method action,
+    // return a custom action that signals the external API call.
+    return [
+      {
+        method: 'genkitCall',
+        arguments: [],
+      },
+    ];
+  },
+};
+
+// TODO: Genkit implementation
+export const callGenkit: (any) => Promise<any> = async (x: any) => x;

extensions/image-processing-api/functions/src/operations/index.ts

@@ -15,7 +15,7 @@
  */
 
 import { AssertionError } from 'assert';
-import sharp, { SharpOptions } from 'sharp';
+import sharp from 'sharp';
 import superstruct from 'superstruct';
 
 import { omitKey, omitUndefinedValues } from '../utils';
@@ -56,6 +56,7 @@ import { operationTint } from './tint';
 import { operationGrayScale } from './grayscale';
 import { operationModulate } from './modulate';
 import { operationLinear } from './linear';
+import { callGenkit, operationGenkit } from './genkit';
 
 export * from './input';
 export * from './output';
@@ -115,6 +116,7 @@ const builders: { [key: string]: OperationBuilder } = {
   grayscale: operationGrayScale,
   modulate: operationModulate,
   linear: operationLinear,
+  genkit: operationGenkit,
 };
 
 export function builderForOperation(operation: Operation): OperationBuilder {
@@ -259,8 +261,25 @@ export async function applyValidatedOperation(
   );
   for (let i = 0; i < builtOperation.actions.length; i++) {
     const action = builtOperation.actions[i];
+
+    // Handle our custom external API action.
+    if (action.method === 'genkitCall' && currentInstance) {
+      // Convert the current image buffer to a base64 string.
+      const buffer = await currentInstance.toBuffer();
+      const base64Image = buffer.toString('base64');
+      // Call the external API (here, the mock function).
+      const newBase64 = await callGenkit(base64Image);
+      // Convert the returned base64 string back to a buffer.
+      const newBuffer = Buffer.from(newBase64, 'base64');
+      // Wrap the new buffer in a sharp instance.
+      currentInstance = sharp(newBuffer);
+      continue; // Move on to the next action.
+    }
+
     if (action.method == 'constructor') {
-      currentInstance = sharp(...(action.arguments as SharpOptions[]));
+      currentInstance = sharp(
+        ...(action.arguments as Parameters<typeof sharp>),
+      );
     } else if (currentInstance != null) {
       currentInstance = (
         currentInstance[action.method] as (...args: unknown[]) => sharp.Sharp