Merge pull request #46 from FellouAI/develop

Develop

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@eko-ai/eko",
-  "version": "1.0.8",
+  "version": "1.0.9",
   "description": "Empowering language to transform human words into action.",
   "main": "dist/index.cjs.js",
   "module": "dist/index.esm.js",
@@ -102,6 +102,5 @@
   },
   "engines": {
     "node": ">=18.0.0"
-  },
-  "packageManager": "[email protected]+sha512.a6b2f7906b721bba3d67d4aff083df04dad64c399707841b7acf00f6b133b7ac24255f2652fa22ae3534329dc6180534e98d17432037ff6fd140556e2bb3137e"
+  }
 }

publish.sh

@@ -5,10 +5,14 @@ npm config get registry
 npm config set registry=https://registry.npmjs.org
 
 echo 'Login'
-npm login 
+npm login
+
+# npm version patch
+# npm version minor
+# npm version major
 
 echo "Publish..."
-npm publish
+npm publish --access=public
 
 npm run docs
 

rollup.config.js

@@ -49,7 +49,7 @@ export default [
         tsconfig: './tsconfig.json',
         declaration: true,
         declarationDir: 'dist',
-        include: ['src/types/*', 'src/extension/**/*'],
+        include: ['src/types/*', 'src/extension/**/*', 'src/universal_tools/**/*'],
         exclude: ['src/extension/script']
       }),
       copy({
@@ -115,7 +115,7 @@ export default [
         tsconfig: './tsconfig.json',
         declaration: true,
         declarationDir: 'dist',
-        include: ['src/types/*', 'src/nodejs/**/*']
+        include: ['src/types/*', 'src/nodejs/**/*', 'src/universal_tools/**/*']
       })
     ]
   },
@@ -135,7 +135,7 @@ export default [
         tsconfig: './tsconfig.json',
         declaration: true,
         declarationDir: 'dist',
-        include: ['src/types/*', 'src/nodejs/**/*']
+        include: ['src/types/*', 'src/nodejs/**/*', 'src/universal_tools/**/*']
       }),
       replace({
         preventAssignment: true,

src/core/eko.ts

@@ -10,6 +10,7 @@ import {
   ClaudeConfig,
   OpenaiConfig,
   WorkflowCallback,
+  NodeOutput,
 } from '../types';
 import { ToolRegistry } from './tool-registry';
 
@@ -69,13 +70,33 @@ export class Eko {
     return workflow;
   }
 
+  public async execute(workflow: Workflow, callback?: WorkflowCallback): Promise<NodeOutput[]> {
+    // Inject LLM provider at workflow level
+    workflow.llmProvider = this.llmProvider;
+
+    // Process each node's action
+    for (const node of workflow.nodes) {
+      if (node.action.type === 'prompt') {
+        // Inject LLM provider
+        node.action.llmProvider = this.llmProvider;
+
+        // Resolve tools
+        node.action.tools = node.action.tools.map(tool => {
+          if (typeof tool === 'string') {
+            return this.toolRegistry.getTool(tool);
+          }
+          return tool;
+        });
+      }
+    }
+
+    return await workflow.execute(callback);
+  }
+
   public async cancel(workflow: Workflow): Promise<void> {
     return await workflow.cancel();
   }
 
-  public async execute(workflow: Workflow, callback?: WorkflowCallback): Promise<void> {
-    return await workflow.execute(callback);
-  }
 
   public async modify(workflow: Workflow, prompt: string): Promise<Workflow> {
     const generator = this.workflowGeneratorMap.get(workflow) as WorkflowGenerator;