Add client

clients/typescript/.gitignore

@@ -0,0 +1,34 @@
+# dependencies (bun install)
+node_modules
+
+# output
+out
+dist
+*.tgz
+
+# code coverage
+coverage
+*.lcov
+
+# logs
+logs
+_.log
+report.[0-9]_.[0-9]_.[0-9]_.[0-9]_.json
+
+# dotenv environment variable files
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# caches
+.eslintcache
+.cache
+*.tsbuildinfo
+
+# IntelliJ based IDEs
+.idea
+
+# Finder (MacOS) folder config
+.DS_Store

clients/typescript/README.md

@@ -0,0 +1,21 @@
+# Metorial Function Bay Client
+
+A client library for interacting with the Metorial Function Bay platform using TypeScript.
+
+## Usage 
+
+```ts
+import { createFunctionBayClient } from '@lowerdeck/forge-client';
+
+let forge = createFunctionBayClient({
+  endpoint: '...'
+});
+```
+
+## License
+
+This project is licensed under the Apache License 2.0.
+
+<div align="center">
+  <sub>Built with ❤️ by <a href="https://metorial.com">Metorial</a></sub>
+</div>

clients/typescript/dts-bundle-generator.config.json

@@ -0,0 +1,20 @@
+{
+  "compilationOptions": {
+    "preferredConfigPath": "./tsconfig.dts.json"
+  },
+  "entries": [
+    {
+      "filePath": "./src/index.ts",
+      "outFile": "./dist/index.d.ts",
+      "noCheck": true,
+      "libraries": {
+        "inlinedLibraries": [
+          "@lowerdeck/rpc-client",
+          "@lowerdeck/rpc-server",
+          "@lowerdeck/validation",
+          "object-storage-client"
+        ]
+      }
+    }
+  ]
+}

clients/typescript/package.json

@@ -0,0 +1,42 @@
+{
+  "name": "@metorial-services/function-bay-client",
+  "version": "1.0.0",
+  "publishConfig": {
+    "access": "public"
+  },
+  "files": [
+    "src/**",
+    "dist/**",
+    "README.md",
+    "package.json"
+  ],
+  "author": "Tobias Herber",
+  "license": "Apache 2",
+  "type": "module",
+  "source": "src/index.ts",
+  "exports": {
+    "types": "./dist/index.d.ts",
+    "require": "./dist/index.cjs",
+    "import": "./dist/index.module.js",
+    "default": "./dist/index.module.js"
+  },
+  "main": "./dist/index.cjs",
+  "module": "./dist/index.module.js",
+  "types": "dist/index.d.ts",
+  "unpkg": "./dist/index.umd.js",
+  "scripts": {
+    "test": "vitest run --passWithNoTests",
+    "lint": "prettier src/**/*.ts --check",
+    "build": "rm -rf ./dist && microbundle && dts-bundle-generator --config dts-bundle-generator.config.json",
+    "prepublish": "bun run build"
+  },
+  "dependencies": {
+    "@lowerdeck/rpc-client": "^1.0.2"
+  },
+  "devDependencies": {
+    "dts-bundle-generator": "^9.5.1",
+    "microbundle": "^0.15.1",
+    "typescript": "^5.8.3",
+    "vitest": "^3.1.2"
+  }
+}

clients/typescript/src/index.ts

@@ -0,0 +1,5 @@
+import { createClient } from '@lowerdeck/rpc-client';
+import { ClientOpts } from '@lowerdeck/rpc-client/dist/shared/clientBuilder';
+import type { FunctionBayClient } from '../../../service/src/controllers';
+
+export let createFunctionBayClient = (o: ClientOpts) => createClient<FunctionBayClient>(o);

clients/typescript/tsconfig.dts.json

@@ -0,0 +1,15 @@
+{
+  "$schema": "https://json.schemastore.org/tsconfig",
+  "extends": "./tsconfig.json",
+  "compilerOptions": {
+    "skipLibCheck": true,
+    "noEmit": true,
+    "skipDefaultLibCheck": true,
+    "types": []
+  },
+  "exclude": [
+    "dist",
+    "node_modules",
+    "../../node_modules/bun-types"
+  ]
+}

clients/typescript/tsconfig.json

@@ -0,0 +1,36 @@
+{
+  "$schema": "https://json.schemastore.org/tsconfig",
+  "display": "Default",
+  "include": [
+    "src"
+  ],
+  "compilerOptions": {
+    "outDir": "dist",
+    "composite": false,
+    "declaration": true,
+    "declarationMap": true,
+    "esModuleInterop": true,
+    "forceConsistentCasingInFileNames": true,
+    "inlineSources": false,
+    "isolatedModules": true,
+    "moduleResolution": "node",
+    "module": "esnext",
+    "lib": [
+      "ESNext",
+      "DOM",
+      "DOM.Iterable"
+    ],
+    "target": "ESNext",
+    "noUnusedLocals": false,
+    "noUnusedParameters": false,
+    "preserveWatchOutput": true,
+    "skipLibCheck": true,
+    "strict": true,
+    "downlevelIteration": true,
+    "resolveJsonModule": true,
+  },
+  "exclude": [
+    "dist",
+    "node_modules"
+  ]
+}

service/src/controllers/function.ts

@@ -69,22 +69,6 @@ export let functionController = app.controller({
     )
     .do(async ctx => functionPresenter(ctx.function)),
 
-  delete: functionApp
-    .handler()
-    .input(
-      v.object({
-        instanceId: v.string(),
-        functionId: v.string()
-      })
-    )
-    .do(async ctx => {
-      let func = await functionService.deleteFunction({
-        function: ctx.function
-      });
-
-      return functionPresenter(func);
-    }),
-
   update: functionApp
     .handler()
     .input(

service/src/forge.ts

@@ -6,7 +6,7 @@ import { db } from './db';
 import { env } from './env';
 import { snowflake } from './id';
 
-export let forge = createForgeClient({
+export let forge: ReturnType<typeof createForgeClient> = createForgeClient({
   endpoint: env.forge.FORGE_API_URL
 });
 

service/src/providers/_lib.ts

@@ -13,7 +13,8 @@ import type {
 import type { ForgeWorkflowStep } from '../forge';
 
 export interface ProviderRuntimeResult {
-  runtime: FunctionBayRuntimeConfig;
+  runtime: Runtime;
+  spec: FunctionBayRuntimeSpec;
   layer: FunctionBayLayer;
   workflow: ForgeWorkflowStep[];
   identifier: string;

service/src/providers/aws-lambda/runtime.ts

@@ -29,7 +29,7 @@ export let getRuntime = async (
   spec: FunctionBayRuntimeSpec
 ): Promise<{
   runtime: Runtime;
-  spec: FunctionBayRuntimeConfig;
+  spec: FunctionBayRuntimeSpec;
   layer: FunctionBayLayer;
   workflow: ForgeWorkflowStep[];
   identifier: string;

service/src/queues/build.ts

@@ -414,7 +414,7 @@ let uploadBundleQueueProcessor = uploadBundleQueue.process(async data => {
     await storage.putObject(
       bucket,
       storageKey,
-      await fetch(data.outputUrl).then(res => Readable.fromWeb(res.body!) as any),
+      await fetch(data.outputUrl).then(res => Readable.fromWeb(res.body! as any) as any),
       'application/zip'
     );
 

service/src/services/function.ts

@@ -81,16 +81,6 @@ class functionServiceImpl {
       include
     });
   }
-
-  async deleteFunction(d: { function: Function }) {
-    throw new Error('Not implemented');
-
-    return await db.function.update({
-      where: { oid: d.function.oid },
-      data: { status: 'deleted' },
-      include
-    });
-  }
 }
 
 export let functionService = Service.create(