its: Renamed Event::version to stream_seq

bouzuya · Apr 26, 2022 · 3753c93 · 3753c93
1 parent 324e840
commit 3753c93
Show file tree

Hide file tree

Showing 6 changed files with 13 additions and 13 deletions.
diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/event_store.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/event_store.rs
@@ -51,7 +51,7 @@ pub async fn save(
     if let Some(current_version) = current_version {
         let query: Query<Any, AnyArguments> =
             sqlx::query(include_str!("../../../sql/command/update_event_stream.sql"))
-                .bind(i64::from(event.version))
+                .bind(i64::from(event.stream_seq))
                 .bind(event.stream_id.to_string())
                 .bind(i64::from(current_version));
         let result = query.execute(&mut *transaction).await?;
@@ -62,7 +62,7 @@ pub async fn save(
         let query: Query<Any, AnyArguments> =
             sqlx::query(include_str!("../../../sql/command/insert_event_stream.sql"))
                 .bind(event.stream_id.to_string())
-                .bind(i64::from(event.version));
+                .bind(i64::from(event.stream_seq));
         let result = query.execute(&mut *transaction).await?;
         if result.rows_affected() == 0 {
             return Err(EventStoreError::InsertEventStream);
@@ -72,7 +72,7 @@ pub async fn save(
     let query: Query<Any, AnyArguments> =
         sqlx::query(include_str!("../../../sql/command/insert_event.sql"))
             .bind(event.stream_id.to_string())
-            .bind(i64::from(event.version))
+            .bind(i64::from(event.stream_seq))
             .bind(event.data);
     let result = query.execute(&mut *transaction).await?;
     if result.rows_affected() == 0 {
@@ -149,7 +149,7 @@ mod tests {
         let create_event = Event {
             stream_id: event_stream_id,
             data: r#"{"type":"issue_created"}"#.to_string(),
-            version,
+            stream_seq: version,
         };
         save(&mut transaction, None, create_event).await?;
 
@@ -171,7 +171,7 @@ mod tests {
         let update_event = Event {
             stream_id: event_stream_id,
             data: r#"{"type":"issue_updated"}"#.to_string(),
-            version: EventStreamVersion::from(2_u32),
+            stream_seq: EventStreamVersion::from(2_u32),
         };
         save(&mut transaction, Some(version), update_event).await?;
         transaction.commit().await?;

diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/event_store/event.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/event_store/event.rs
@@ -3,6 +3,6 @@ use super::{event_stream_id::EventStreamId, event_stream_version::EventStreamVer
 #[derive(Clone, Debug)]
 pub struct Event {
     pub stream_id: EventStreamId,
+    pub stream_seq: EventStreamVersion,
     pub data: String,
-    pub version: EventStreamVersion,
 }
diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/event_store/event_row.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/event_store/event_row.rs
@@ -41,7 +41,7 @@ impl From<EventRow> for Event {
         Self {
             stream_id: row.event_stream_id(),
             data: row.data(),
-            version: row.version(),
+            stream_seq: row.version(),
         }
     }
 }
diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_issue_block_link_repository.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_issue_block_link_repository.rs
@@ -131,7 +131,7 @@ impl IssueBlockLinkRepository for SqliteIssueBlockLinkRepository {
                     Event {
                         stream_id: event_stream_id,
                         data: DomainEvent::from(event.clone()).to_string(),
-                        version: event_stream_version_from(version)?,
+                        stream_seq: event_stream_version_from(version)?,
                     },
                 )
                 .await
@@ -145,7 +145,7 @@ impl IssueBlockLinkRepository for SqliteIssueBlockLinkRepository {
                     Event {
                         stream_id: event_stream_id,
                         data: DomainEvent::from(event.clone()).to_string(),
-                        version: event_stream_version_from(version)?,
+                        stream_seq: event_stream_version_from(version)?,
                     },
                 )
                 .await

diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_issue_repository.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_issue_repository.rs
@@ -203,7 +203,7 @@ impl SqliteIssueRepository {
                     Event {
                         stream_id: event_stream_id,
                         data: DomainEvent::from(event).to_string(),
-                        version: Self::version_to_event_stream_version(version)?,
+                        stream_seq: Self::version_to_event_stream_version(version)?,
                     },
                 )
                 .await?
@@ -217,7 +217,7 @@ impl SqliteIssueRepository {
                     Event {
                         stream_id: event_stream_id,
                         data: DomainEvent::from(event).to_string(),
-                        version: Self::version_to_event_stream_version(version)?,
+                        stream_seq: Self::version_to_event_stream_version(version)?,
                     },
                 )
                 .await?;

diff --git a/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_query_handler.rs b/its/crates/adapter_sqlite/src/adapter/sqlite/sqlite_query_handler.rs
@@ -148,7 +148,7 @@ impl SqliteQueryHandler {
                         event_store::find_events_by_event_stream_id_and_version_less_than_equal(
                             &mut transaction,
                             event.stream_id,
-                            event.version,
+                            event.stream_seq,
                         )
                         .await?
                         .into_iter()
@@ -168,7 +168,7 @@ impl SqliteQueryHandler {
                         event_store::find_events_by_event_stream_id_and_version_less_than_equal(
                             &mut transaction,
                             event.stream_id,
-                            event.version,
+                            event.stream_seq,
                         )
                         .await?
                         .into_iter()