feat: add knowledge to agent (#108)

We separate knowledge from workflow description to avoid
tasks/descriptions interfering with agent. This could possibly be
something else in the future, like a method that gets it from the
database/something.

This is just demonstration, as alternative to #105. I am still not sure
about this.

example/src/surprise_trip.ts

@@ -2,7 +2,6 @@ import { agent } from 'fabrice-ai/agent'
 import { parallelSupervisor } from 'fabrice-ai/agents/supervisor'
 import { solution } from 'fabrice-ai/solution'
 import { teamwork } from 'fabrice-ai/teamwork'
-import { logger } from 'fabrice-ai/telemetry'
 import { workflow } from 'fabrice-ai/workflow'
 
 import { lookupWikipedia } from './tools/wikipedia.js'
@@ -59,7 +58,8 @@ const researchTripWorkflow = workflow({
       - highly-rated restaurants and dining experiences.
       - landmarks with historic context.
       - picturesque and entertaining locations.
-
+  `,
+  knowledge: `
     Traveler's information:
       - Origin: New York, USA
       - Destination: Wrocław, Poland
@@ -72,7 +72,6 @@ const researchTripWorkflow = workflow({
     Comprehensive day-by-day itinerary for the trip to Wrocław, Poland.
     Ensure the itinerary includes flights, hotel information, and all planned activities and dining experiences.
   `,
-  snapshot: logger,
 })
 
 const result = await teamwork(researchTripWorkflow)

packages/framework/src/agent.ts

@@ -30,7 +30,7 @@ export const agent = (options: AgentOptions = {}): Agent => {
     provider,
     run:
       options.run ??
-      (async (state, context) => {
+      (async (state, context, workflow) => {
         const mappedTools = tools
           ? Object.entries(tools).map(([name, tool]) =>
               zodFunction({
@@ -41,6 +41,8 @@ export const agent = (options: AgentOptions = {}): Agent => {
             )
           : []
 
+        const [, ...messages] = context
+
         const res = await provider.completions({
           messages: [
             {
@@ -59,7 +61,13 @@ export const agent = (options: AgentOptions = {}): Agent => {
               `,
             },
             response('What have been done so far?'),
-            request(`Here is all the work done so far by other agents: ${JSON.stringify(context)}`),
+            request(
+              `Here is all the work done so far by other agents: ${JSON.stringify(messages)}`
+            ),
+            response(`Is there anything else I need to know?`),
+            workflow.knowledge
+              ? request(`Here is all the knowledge available: ${workflow.knowledge}`)
+              : request(`No, I do not have any additional information.`),
             response('What do you want me to do now?'),
             ...state.messages,
           ],

packages/framework/src/agents/supervisor.ts

@@ -11,7 +11,7 @@ type ParallelSupervisorOptions = AgentOptions & {
   parallelism?: number
 }
 
-export const parallelSupervisor = (options: ParallelSupervisorOptions) => {
+export const parallelSupervisor = (options: ParallelSupervisorOptions = {}) => {
   const { parallelism = 3 } = options
 
   return agent({
@@ -78,7 +78,7 @@ export const parallelSupervisor = (options: ParallelSupervisorOptions) => {
   })
 }
 
-export const supervisor = (options: AgentOptions) => {
+export const supervisor = (options?: AgentOptions) => {
   return agent({
     run: async (state, context, workflow) => {
       const [workflowRequest, ...messages] = state.messages

packages/framework/src/workflow.ts

@@ -11,6 +11,7 @@ type WorkflowOptions = {
 
   team: Team
 
+  knowledge?: string
   provider?: Provider
   maxIterations?: number
   snapshot?: Telemetry
@@ -37,4 +38,6 @@ export const workflow = (options: WorkflowOptions): Workflow => {
   }
 }
 
-export type Workflow = Required<WorkflowOptions>
+export type Workflow = Required<Omit<WorkflowOptions, 'knowledge'>> & {
+  knowledge?: string
+}