its: Fixed IssueRepository::save

bouzuya · Feb 7, 2022 · 3265b74 · 3265b74
1 parent 2771f9a
commit 3265b74
Showing 1 changed file with 6 additions and 1 deletion.
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
@@ -133,7 +133,12 @@ impl IssueRepository for SqliteIssueRepository {
             let version = event.version();
             EventStore::save(
                 &mut transaction,
-                None, // FIXME
+                version.prev().map(|version| {
+                    u32::try_from(u64::from(version))
+                        .map(AggregateVersion::from)
+                        .map_err(|_| RepositoryError::IO)
+                        .expect("parse aggregate version")
+                }),
                 Event {
                     aggregate_id,
                     data: serde_json::to_string(&EventDto::from(event))