From 31b4f2d4196a5ba3f4990efde2485729e9fdf9f7 Mon Sep 17 00:00:00 2001
From: ts0yu <120932697+ts0yu@users.noreply.github.com>
Date: Fri, 16 Feb 2024 19:57:17 +0000
Subject: [PATCH] feat: rm incrementer

---
 Cargo.toml                   |  2 +-
 src/behaviors/incrementer.rs | 55 ------------------------------------
 src/behaviors/mod.rs         | 12 --------
 src/main.rs                  | 27 +-----------------
 4 files changed, 2 insertions(+), 94 deletions(-)
 delete mode 100644 src/behaviors/incrementer.rs

diff --git a/Cargo.toml b/Cargo.toml
index fe42528..345eb32 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -8,7 +8,7 @@ tracing = "0.1.40"
 tracing-subscriber = "0.3.18"
 arbiter-core = { version = "0.10.1" }
 arbiter-macros = { version = "0.1.1" }
-arbiter-engine = { version = "0.2.0" }
+arbiter-engine = { version = "0.3.0" }
 tokio = { version = "1.36.0", features = ["full"] }
 ethers = { version = "2.0.10" }
 serde = { version = "1.0.189", features = ["derive"] }
diff --git a/src/behaviors/incrementer.rs b/src/behaviors/incrementer.rs
deleted file mode 100644
index 3fc567a..0000000
--- a/src/behaviors/incrementer.rs
+++ /dev/null
@@ -1,55 +0,0 @@
-use std::sync::Arc;
-
-use anyhow::Result;
-use arbiter_core::{events::stream_event, middleware::ArbiterMiddleware};
-use arbiter_engine::{
-    machine::{Behavior, ControlFlow, EventStream},
-    messager::Messager,
-};
-use tracing::{debug, info};
-
-use super::*;
-use crate::bindings::modified_counter::{IncrementedFilter, ModifiedCounter};
-
-#[derive(Debug, Serialize, Deserialize)]
-pub struct Incrementer {
-    #[serde(default)]
-    curr_number_of_times: u64,
-    max_number_of_times: u64,
-    #[serde(skip)]
-    counter: Option<ModifiedCounter<ArbiterMiddleware>>,
-}
-
-#[async_trait::async_trait]
-impl Behavior<IncrementedFilter> for Incrementer {
-    async fn startup(
-        &mut self,
-        client: Arc<ArbiterMiddleware>,
-        _messager: Messager,
-    ) -> Result<EventStream<IncrementedFilter>> {
-        debug!("Incrementer starting up");
-        let counter = ModifiedCounter::deploy(client.clone(), ())?.send().await?;
-        let stream = stream_event(counter.incremented_filter());
-        counter.increment().send().await?.await?;
-        self.curr_number_of_times += 1;
-        let curr_number = counter.number().call().await?;
-        debug!("Incremented to: {}", curr_number);
-        self.counter = Some(counter);
-        Ok(stream)
-    }
-
-    async fn process(&mut self, _event: IncrementedFilter) -> Result<ControlFlow> {
-        debug!("Incrementer processing event");
-        let counter = self.counter.as_ref().unwrap();
-        if self.curr_number_of_times < self.max_number_of_times {
-            counter.increment().send().await?.await?;
-            self.curr_number_of_times += 1;
-            let curr_number = counter.number().call().await?;
-            debug!("Incremented to: {}", curr_number);
-            Ok(ControlFlow::Continue)
-        } else {
-            info!("Incrementer done");
-            return Ok(ControlFlow::Halt);
-        }
-    }
-}
diff --git a/src/behaviors/mod.rs b/src/behaviors/mod.rs
index 09bbbd1..e69de29 100644
--- a/src/behaviors/mod.rs
+++ b/src/behaviors/mod.rs
@@ -1,12 +0,0 @@
-use arbiter_engine::machine::{CreateStateMachine, Engine, StateMachine};
-use arbiter_macros::Behaviors;
-use serde::{Deserialize, Serialize};
-
-pub mod incrementer;
-
-use incrementer::Incrementer;
-
-#[derive(Debug, Serialize, Deserialize, Behaviors)]
-pub enum Behaviors {
-    Incrementer(Incrementer),
-}
diff --git a/src/main.rs b/src/main.rs
index ed16fb9..e71fdf5 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,26 +1 @@
-pub mod behaviors;
-pub mod bindings;
-
-use behaviors::Behaviors;
-
-/// To run this example, you can do the following from the `arbiter/` directory:
-/// ```sh
-/// cargo run --example project simulate examples/project/configs/example.toml
-/// ```
-/// If you would like to see more detailed logs, you can run the following:
-/// ```sh
-/// cargo run --example project simulate examples/project/configs/example.toml -vvv
-/// ```
-/// to get `debug` level logs.
-///
-/// By running
-/// ```sh
-/// cargo run --example project
-/// ```
-/// you will get the `--help` message for the project.
-#[arbiter_macros::main(
-    name = "ExampleArbiterProject",
-    about = "Our example to get you started.",
-    behaviors = Behaviors
-)]
-pub async fn main() {}
+fn main() {}
\ No newline at end of file