Engine/testing behavior update

Cargo.toml

@@ -34,16 +34,16 @@ path = "examples/minter/main.rs"
 
 [workspace.dependencies]
 # Arbiter local for development
-# arbiter-bindings = { path = "arbiter-bindings" }
-# arbiter-core = { path = "arbiter-core" }
-# arbiter-engine = { path = "arbiter-engine" }
-# arbiter-macros = { path = "arbiter-macros" }
+arbiter-bindings = { path = "bindings" }
+arbiter-core = { path = "core" }
+arbiter-engine = { path = "engine" }
+arbiter-macros = { path = "macros" }
 
 # Arbiter crates.io for release, these need to be used to do crate releases!
-arbiter-bindings = "0.1.4"
-arbiter-core = "0.10.2"
-arbiter-engine = "0.3.0"
-arbiter-macros = "0.1.1"
+# arbiter-bindings = "0.1.4"
+# arbiter-core = "0.10.2"
+# arbiter-engine = "0.3.0"
+# arbiter-macros = "0.1.1"
 
 revm = { version = "5.0.0", features = ["ethersdb", "std", "serde"] }
 revm-primitives = "=2.0.0"

bin/fork/tests.rs

@@ -6,13 +6,15 @@ const FORK_CONFIG_PATH: &str = "examples/fork/weth_config.toml";
 const PATH_TO_DISK_STORAGE: &str = "examples/fork/test.json";
 
 #[test]
+#[ignore]
 fn create_forked_db() {
     let fork_config = ForkConfig::new(FORK_CONFIG_PATH).unwrap();
     let fork = fork_config.into_fork().unwrap();
     assert!(!fork.db.accounts.is_empty());
 }
 
 #[test]
+#[ignore]
 fn write_out() {
     let fork_config =
         ForkConfig::new(FORK_CONFIG_PATH).expect("WARNING: Failed to create ForkConfig");
@@ -27,6 +29,7 @@ fn write_out() {
 }
 
 #[test]
+#[ignore]
 fn read_in() {
     // First write out so we know the file exists.
     let fork_config = ForkConfig::new(FORK_CONFIG_PATH);

engine/src/agent.rs

@@ -1,15 +1,9 @@
 //! The agent module contains the core agent abstraction for the Arbiter Engine.
 
-use std::{fmt::Debug, sync::Arc};
-
 use arbiter_core::middleware::ArbiterMiddleware;
-use serde::{de::DeserializeOwned, Serialize};
 
 use super::*;
-use crate::{
-    machine::{Behavior, Engine, StateMachine},
-    messager::Messager,
-};
+use crate::machine::{Behavior, Engine, StateMachine};
 
 /// An agent is an entity capable of processing events and producing actions.
 /// These are the core actors in simulations or in onchain systems.
@@ -21,7 +15,6 @@ use crate::{
 /// each of its [`Behavior`]s `startup()` methods. The [`Behavior`]s themselves
 /// will return a stream of events that then let the [`Behavior`] move into the
 /// `State::Processing` stage.
-#[derive(Debug)]
 pub struct Agent {
     /// Identifier for this agent.
     /// Used for routing messages.
@@ -78,10 +71,11 @@ pub struct AgentBuilder {
 impl AgentBuilder {
     /// Appends a behavior onto an [`AgentBuilder`]. Behaviors are initialized
     /// when the agent builder is added to the [`crate::world::World`]
-    pub fn with_behavior<E: DeserializeOwned + Serialize + Send + Sync + Debug + 'static>(
-        mut self,
-        behavior: impl Behavior<E> + Serialize + DeserializeOwned + 'static,
-    ) -> Self {
+    pub fn with_behavior<B, E>(mut self, behavior: B) -> Self
+    where
+        B: Behavior<E> + Send + 'static,
+        E: Send + Debug + 'static,
+    {
         let engine = Engine::new(behavior);
         if let Some(engines) = &mut self.behavior_engines {
             engines.push(Box::new(engine));