Rename client to producer (#49)

open-chat-labs · Mar 8, 2024 · 27624b9 · 27624b9
1 parent bbfa5b0
commit 27624b9
Show file tree

Hide file tree

Showing 10 changed files with 15 additions and 17 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -2,9 +2,9 @@
 members = [
     "rs/canister/api",
     "rs/canister/impl",
-    "rs/client",
-    "rs/client/agent_runtime",
-    "rs/client/cdk_runtime",
+    "rs/producer",
+    "rs/producer/agent_runtime",
+    "rs/producer/cdk_runtime",
     "rs/integration_tests",
     "rs/utils",
 ]

diff --git a/rs/client/Cargo.lock → rs/producer/Cargo.lock b/rs/client/Cargo.lock → rs/producer/Cargo.lock
diff --git a/rs/client/Cargo.toml → rs/producer/Cargo.toml b/rs/client/Cargo.toml → rs/producer/Cargo.toml
@@ -1,5 +1,5 @@
 [package]
-name = "event_store_client"
+name = "event_store_producer"
 version = "0.1.0"
 edition = "2021"
 

diff --git a/rs/client/agent_runtime/Cargo.toml → rs/producer/agent_runtime/Cargo.toml b/rs/client/agent_runtime/Cargo.toml → rs/producer/agent_runtime/Cargo.toml
@@ -1,5 +1,5 @@
 [package]
-name = "event_store_client_agent_runtime"
+name = "event_store_producer_agent_runtime"
 version = "0.1.0"
 edition = "2021"
 
@@ -8,7 +8,7 @@ edition = "2021"
 [dependencies]
 candid.workspace = true
 event_store_canister.path = "../../canister/api"
-event_store_client.path = ".."
+event_store_producer.path = ".."
 ic-agent.workspace = true
 ic_principal.workspace = true
 rand.workspace = true

diff --git a/rs/client/agent_runtime/src/lib.rs → rs/producer/agent_runtime/src/lib.rs b/rs/client/agent_runtime/src/lib.rs → rs/producer/agent_runtime/src/lib.rs
@@ -1,5 +1,5 @@
 use event_store_canister::{IdempotentEvent, PushEventsArgs, TimestampMillis};
-use event_store_client::{
+use event_store_producer::{
     FlushOutcome, Runtime, FLUSH_OUTCOME_FAILED_SHOULD_RETRY, FLUSH_OUTCOME_SUCCESS,
 };
 use ic_agent::Agent;

diff --git a/rs/client/cdk_runtime/Cargo.toml → rs/producer/cdk_runtime/Cargo.toml b/rs/client/cdk_runtime/Cargo.toml → rs/producer/cdk_runtime/Cargo.toml
@@ -1,13 +1,13 @@
 [package]
-name = "event_store_client_cdk_runtime"
+name = "event_store_producer_cdk_runtime"
 version = "0.1.0"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
 event_store_canister.path = "../../canister/api"
-event_store_client.path = ".."
+event_store_producer.path = ".."
 ic-cdk.workspace = true
 ic-cdk-timers.workspace = true
 ic_principal.workspace = true

diff --git a/rs/client/cdk_runtime/src/lib.rs → rs/producer/cdk_runtime/src/lib.rs b/rs/client/cdk_runtime/src/lib.rs → rs/producer/cdk_runtime/src/lib.rs
@@ -1,5 +1,5 @@
 use event_store_canister::{IdempotentEvent, PushEventsArgs, TimestampMillis};
-use event_store_client::{
+use event_store_producer::{
     FlushOutcome, Runtime, FLUSH_OUTCOME_FAILED_SHOULD_RETRY, FLUSH_OUTCOME_SUCCESS,
 };
 use ic_cdk_timers::TimerId;

diff --git a/rs/client/src/lib.rs → rs/producer/src/lib.rs b/rs/client/src/lib.rs → rs/producer/src/lib.rs
@@ -33,9 +33,7 @@ struct ClientInner<R> {
     events: Vec<IdempotentEvent>,
     #[serde(skip)]
     next_flush_scheduled: Option<TimestampMillis>,
-    #[serde(default)]
     flush_in_progress: bool,
-    #[serde(default)]
     total_events_flushed: u64,
 }
 

diff --git a/rs/client/src/tests.rs → rs/producer/src/tests.rs b/rs/client/src/tests.rs → rs/producer/src/tests.rs