feat: ⚡ 2x faster, critical fix on block detector, new serve({...}) to support new features like optimistic cache

Author: Lucas

.vscode/launch.json

@@ -4,6 +4,23 @@
   // Pour plus d'informations, visitez : https://go.microsoft.com/fwlink/?linkid=830387
   "version": "0.2.0",
   "configurations": [
+    {
+      "request": "launch",
+      "name": "Launch Example",
+      "type": "node",
+      "program": "${workspaceFolder}/main.ts",
+      "cwd": "${workspaceFolder}",
+      "env": {},
+      "runtimeExecutable": "/Users/lucas/.deno/bin/deno",
+      "runtimeArgs": [
+        "run",
+        "--allow-all",
+        "--unstable-ffi",
+        "--inspect-brk",
+        "${workspaceFolder}/examples/helloworld.ts"
+      ],
+      "attachSimplePort": 9229
+    },
     {
       "request": "launch",
       "name": "Launch Program",

examples/helloworld.ts

@@ -6,7 +6,7 @@ const fns = new Fns({
   dev: true,
   baseUrl: "https://api.fns.run",
 });
-fns.createFunction(
+const workflowtest = fns.createFunction(
   { name: "WorkflowTest", version: 1 },
   () => {
     return async ({ step }) => {
@@ -21,7 +21,7 @@ fns.createFunction(
     };
   },
 );
-fns.createFunction(
+const realapitest = fns.createFunction(
   { name: "helloworld", version: 1 },
   ({ useState, useSignal }) => {
     const [name, setName] = useState<string>("name", "John Travolta");
@@ -44,17 +44,16 @@ fns.createFunction(
             .then((res) => res.name),
       );
 
-      await step.condition(
-        "wait-until-name-is-good",
-        () => name() === `${firstName} ${lastName}`,
-      );
-
       return `Hello ${firstName} ${lastName}`;
     };
   },
 );
 const app = express();
-app.use("/api-fns", express.raw({ type: "application/json" }), serve(fns));
+app.use(
+  "/api-fns",
+  express.raw({ type: "application/json" }),
+  serve({ client: fns, functions: [workflowtest, realapitest] }),
+);
 app.use(express.json());
 app.get("/", (_, res) => res.json({ message: "Hello World" }));
 app.listen(3100, () => console.log("Server running on port 3100"));

libs/helper.ts

@@ -1,25 +1,5 @@
-export const resolveNextTick = (timeouts: number[]) =>
-  new Promise((resolve) => timeouts.push(Number(setTimeout(resolve, 0))));
-export async function execute(
-  fn: Promise<unknown>,
-): Promise<[boolean, unknown]> {
-  const timeouts: number[] = [];
-  try {
-    const result = await Promise.race([
-      fn.then((data: unknown) => [true, data]),
-      resolveNextTick(timeouts).then(() => [false, null]),
-    ]) as [boolean, unknown];
-    return result;
-  } catch (err) {
-    throw err;
-  } finally {
-    for (let i = 0; i < timeouts.length; i++) {
-      clearTimeout(timeouts[i]);
-    }
-  }
-}
 export function block<T = unknown>(): Promise<T> {
-  return new Promise(() => {});
+  return new Promise<T>(() => {});
 }
 
-export default { resolveNextTick, execute, block };
+export default { block };