Disintegrate v3.0.0 (#225)

* feat: add stream end

* remove hash indexes

* refactor: allow event in mutate_all

* chore: add break listener when processing timeout occurs

* refactor: example rename

* test: add insert test

* chore: add migrator

* update lock

* improve migrator

* fix migrator

* reuse transaction to stream events

* refactoring stream_with

* wip: add retry

* Impl listener constructor for AbortRetry retry policy

* rename stop to abort

* stop main listener loop if after retries

* add retry callback to example

* doc fixes

* return the handler error after releasing the lock

* refactoring

* fix docker-compose

* better query

* change epoch_id name

* fix rebase

* rename

* bump disintegrate version

* update deps

* reset subscriptions_concurrency

---------

Co-authored-by: Valerio Iachini <valerio.iachini@gmail.com>
Co-authored-by: Valerio <valerio.iachini@prima.it>

Author: luca-iachini

Cargo.lock

@@ -2,11 +2,24 @@
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/disintegrate-es/disintegrate"
-keywords = ["event-sourcing", "domain-driven-design", "ddd", "event-driven-architecture", "cqrs", "aggregate", "event-store"]
-categories = ["development-tools", "software-libraries", "event-sourcing", "domain-driven-design"]
+keywords = [
+	"event-sourcing",
+	"domain-driven-design",
+	"ddd",
+	"event-driven-architecture",
+	"cqrs",
+	"aggregate",
+	"event-store",
+]
+categories = [
+	"development-tools",
+	"software-libraries",
+	"event-sourcing",
+	"domain-driven-design",
+]
 authors = [
-    "Luca Iachini <luca.iachini89@gmail.com>",
-    "Valerio Iachini <valerio.iachini@gmail.com>",
+	"Luca Iachini <luca.iachini89@gmail.com>",
+	"Valerio Iachini <valerio.iachini@gmail.com>",
 ]
 readme = "README.md"
 
@@ -20,6 +33,5 @@ members = [
 	"disintegrate-serde",
 	"examples/cart",
 	"examples/courses",
-	"examples/banking"
+	"examples/banking",
 ]
-

Cargo.toml

@@ -69,16 +69,16 @@ To add Disintegrate to your project, follow these steps:
 
     ```toml
     [dependencies]
-    disintegrate = "2.1.0"
-    disintegrate-postgres = "2.1.0"
+    disintegrate = "3.0.0"
+    disintegrate-postgres = "3.0.0"
     ```
 
     * Disintegrate provides several features that you can enable based on your project requirements. You can include them in your `Cargo.toml` file as follows:
 
     ```toml
     [dependencies]
-    disintegrate = { version = "2.1.0", features = ["macros", "serde-prost"] }
-    disintegrate-postgres = { version = "2.1.0", features = ["listener"] }
+    disintegrate = { version = "3.0.0", features = ["macros", "serde-prost"] }
+    disintegrate-postgres = { version = "3.0.0", features = ["listener"] }
     ```
 
     * The macros feature enables the use of derive macros to simplify events implementations.
@@ -90,7 +90,7 @@ To add Disintegrate to your project, follow these steps:
         * To enable Prost serialization, use the `serde-prost` feature: `features = ["serde-prost"]`.
         * To enable Protocol Buffers serialization, use the `serde-protobuf` feature: `features = ["serde-protobuf"]`.
 
-    * If you're using the PostgreSQL event store backend and want to use the listener mechanism, you can enable the `listener` feature: `disintegrate-postgres = {version = "2.1.0", features = ["listener"]}`.
+    * If you're using the PostgreSQL event store backend and want to use the listener mechanism, you can enable the `listener` feature: `disintegrate-postgres = {version = "3.0.0", features = ["listener"]}`.
 
 2. Define the list of events in your application. You can use the Event Storming technique to identify the events that occur in your system. Here's an example of defining events using Disintegrate:
 

README.md

@@ -1,7 +1,7 @@
 [package]
 name = "disintegrate-macros"
 description = "Disintegrate macros. Not for direct use. Refer to the `disintegrate` crate for details."
-version = "2.1.0"
+version = "3.0.0"
 license.workspace = true
 edition.workspace = true
 authors.workspace = true
@@ -16,12 +16,12 @@ never = []
 
 [dependencies]
 heck = "0.5.0"
-proc-macro2 = "1.0.86"
-quote = "1.0.38"
-syn = { version = "2.0.65", features = ["full"] }
+proc-macro2 = "1.0.103"
+quote = "1.0.42"
+syn = { version = "2.0.111", features = ["full"] }
 
 [dev-dependencies]
-disintegrate = { version = "2.1.0", path = "../disintegrate", features = ["macros"] }
+disintegrate = { version = "3.0.0", path = "../disintegrate", features = ["macros"] }
 
 [package.metadata.docs.rs]
 all-features = true

disintegrate-macros/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "disintegrate-postgres"
 description = "Disintegrate PostgresDB implementation. Not for direct use. Refer to the `disintegrate` crate for details."
-version = "2.1.0"
+version = "3.0.0"
 license.workspace = true
 edition.workspace = true
 authors.workspace = true
@@ -13,24 +13,24 @@ default = []
 listener = ["dep:tokio-util"]
 
 [dependencies]
-disintegrate = { version = "2.1.0", path = "../disintegrate" }
-disintegrate-serde = { version = "2.1.0", path = "../disintegrate-serde" }
-disintegrate-macros = { version = "2.1.0", path = "../disintegrate-macros" }
-serde = "1.0.217"
-serde_json = "1.0.140"
+disintegrate = { version = "3.0.0", path = "../disintegrate" }
+disintegrate-serde = { version = "3.0.0", path = "../disintegrate-serde" }
+disintegrate-macros = { version = "3.0.0", path = "../disintegrate-macros" }
+serde = "1.0.228"
+serde_json = "1.0.146"
 sqlx = { version = "0.8.6", features = ["postgres", "runtime-tokio-rustls", "uuid"] }
-async-trait = "0.1.88"
-futures = "0.3.30"
-async-stream = "0.3.5"
-thiserror = "2.0.11"
-tokio = {version = "1.47.1", features = ["macros"]}
-tokio-util = {version = "0.7.16", optional = true}
-uuid = { version = "1.16.0", features = ["v3"] }
+async-trait = "0.1.89"
+futures = "0.3.31"
+async-stream = "0.3.6"
+thiserror = "2.0.17"
+tokio = {version = "1.48.0", features = ["macros"]}
+tokio-util = {version = "0.7.17", optional = true}
+uuid = { version = "1.19.0", features = ["v3"] }
 md-5 = "0.10.6"
-paste = "1.0.14"
+paste = "1.0.15"
 
 [dev-dependencies]
-disintegrate-serde = { version = "2.1.0", path = "../disintegrate-serde", features = ["json"] }
+disintegrate-serde = { version = "3.0.0", path = "../disintegrate-serde", features = ["json"] }
 
 [package.metadata.docs.rs]
 all-features = true

disintegrate-postgres/Cargo.toml

@@ -1,9 +1,14 @@
 use std::error::Error as StdError;
 use thiserror::Error;
 
+use crate::migrator;
+
 /// Represents all the ways a method can fail within Disintegrate Postgres.
 #[derive(Error, Debug)]
 pub enum Error {
+    /// Error returned from the migrator.
+    #[error(transparent)]
+    Migration(#[from] migrator::Error),
     /// Error returned from the database.
     #[error(transparent)]
     Database(#[from] sqlx::Error),