fix execution states for long running async tasks

Author: kvey

README.md

@@ -19,7 +19,7 @@ https://github.com/ThousandBirdsInc/chidori/assets/515757/6b088f7d-d8f7-4c7e-900
 Star us on Github! Join us on [Discord](https://discord.gg/CJwKsPSgew).
 
 ## Contents
-- [📖 Chidori](#-chidori)
+- [📖 Chidori V2](#-chidori-v2)
 - [⚡️ Getting Started](#️-getting-started)
   - [Installation](#installation)
   - [Environment Variables](#environment-variables)

media/ChidoriPanel.png

@@ -1,6 +1,52 @@
 # This agent demonstrates how to traverse multiple parts of a website, extract data, and produce a structured report.
 
+We use Astral rather than Playwright for Deno support
+https://astral.deno.dev/guides/navigation/
 
+```ts
+import { launch } from "https://deno.land/x/astral/mod.ts";
+
+
+// Connect to remote endpoint
+const browser = await launch({
+    wsEndpoint: `wss://connect.browserbase.com?apiKey=${Deno.env.get("BROWSERBASE_API_KEY")}`
+});
+
+// Do stuff
+// Open the webpage
+const page = await browser.newPage("https://deno.land");
+
+// Click the search button
+const button = await page.$("button");
+await button!.click();
+
+// Type in the search input
+const input = await page.$("#search-input");
+await input!.type("pyro", { delay: 1000 });
+
+// Wait for the search results to come back
+await page.waitForNetworkIdle({ idleConnections: 0, idleTime: 1000 });
+
+// Click the 'pyro' link
+const xLink = await page.$("a.justify-between:nth-child(1)");
+await Promise.all([
+    xLink!.click(),
+    page.waitForNavigation(),
+]);
+
+// Click the link to 'pyro.deno.dev'
+const dLink = await page.$(
+    ".markdown-body > p:nth-child(8) > a:nth-child(1)",
+);
+await Promise.all([
+    dLink!.click(),
+    page.waitForNavigation(),
+]);
+
+
+// Close connection
+await browser.close();
+```
 
 
 

toolchain/chidori-core/examples/demo1_business_analyst/demo.md

@@ -552,7 +552,8 @@ pub async fn source_code_run_deno(
         let mut flags = deno::args::Flags::default();
         // TODO: give user control over this in configuration
         // TODO: allow_net is causing this to block our execution entirely
-        // flags.allow_net = Some(vec![]);
+        flags.allow_net = Some(vec![]);
+        flags.allow_env = Some(vec![]);
         let factory = deno::factory::CliFactory::from_flags(flags)?;
         let cli_options = factory.cli_options();
         let file_fetcher = factory.file_fetcher()?;
@@ -594,6 +595,7 @@ pub async fn source_code_run_deno(
             dbg!(&e);
             e
         })?;
+        println!("After the runtime block on in source_code_run_deno");
         // TODO: map error
 
         let mut my_op_state = my_op_state.lock().unwrap();
@@ -656,7 +658,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().insert_number("y", 10).build(),
+                Ok(RkyvObjectBuilder::new().insert_number("y", 10).build()),
                 vec![],
                 vec![],
             )
@@ -683,7 +685,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().insert_number("z", 25).build(),
+                Ok(RkyvObjectBuilder::new().insert_number("z", 25).build()),
                 vec![],
                 vec![],
             )
@@ -697,7 +699,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().insert_number("x", 42).build(),
+                Ok(RkyvObjectBuilder::new().insert_number("x", 42).build()),
                 vec![],
                 vec![],
             )
@@ -718,12 +720,12 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new()
+                Ok(RkyvObjectBuilder::new()
                     .insert_object(
                         "obj",
                         RkyvObjectBuilder::new().insert_string("foo", "bar".to_string())
                     )
-                    .build(),
+                    .build()),
                 vec![],
                 vec![],
             )
@@ -736,7 +738,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().insert_number("x", 30).build(),
+                Ok(RkyvObjectBuilder::new().insert_number("x", 30).build()),
                 vec![],
                 vec![],
             )
@@ -753,7 +755,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvSerializedValue::Number(30),
+                Ok(RkyvSerializedValue::Number(30)),
                 vec![],
                 vec![],
             )
@@ -773,7 +775,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().build(),
+                Ok(RkyvObjectBuilder::new().build()),
                 vec![String::from("[out]: \"testing, output\"\n")],
                 vec![String::from("[out]: \"testing, stderr\"\n")],
             )
@@ -813,7 +815,7 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new().insert_number("x", 42).build(),
+                Ok(RkyvObjectBuilder::new().insert_number("x", 42).build()),
                 vec![],
                 vec![],
             )
@@ -833,14 +835,14 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new()
+                Ok(RkyvObjectBuilder::new()
                     .insert_object(
                         "person",
                         RkyvObjectBuilder::new()
                             .insert_string("name", "Alice".to_string())
                             .insert_number("age", 30)
                     )
-                    .build(),
+                    .build()),
                 vec![],
                 vec![],
             )
@@ -859,10 +861,10 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new()
+                Ok(RkyvObjectBuilder::new()
                     .insert_string("identity", "function".to_string())
                     .insert_string("result", "TypeScript".to_string())
-                    .build(),
+                    .build()),
                 vec![],
                 vec![],
             )
@@ -881,10 +883,10 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new()
+                Ok(RkyvObjectBuilder::new()
                     .insert_string("data", "Data".to_string())
                     .insert_string("fetchData", "function".to_string())
-                    .build(),
+                    .build()),
                 vec![],
                 vec![],
             )
@@ -905,9 +907,9 @@ mod tests {
         assert_eq!(
             result.unwrap(),
             (
-                RkyvObjectBuilder::new()
+                Ok(RkyvObjectBuilder::new()
                     .insert_number("selectedColor", 1)
-                    .build(),
+                    .build()),
                 vec![],
                 vec![],
             )