event-store-adapter-rs

This library is designed to turn DynamoDB into an Event Store for Event Sourcing.

Usage

You can easily implement an Event Sourcing-enabled repository using EventStore.

```rust pub struct UserAccountRepository { event_store: EventStore, }

impl UserAccountRepository { pub async fn storeevent(&mut self, event: &UserAccountEvent, version: usize) -> Result<(), RepositoryError> { let result = self.eventstore.persistevent(event, version).await; match result { Ok() => Ok(()), Err(err) => Err(Self::handleeventstorewriteerror(err)), } }

pub async fn storeeventandsnapshot( &mut self, event: &UserAccountEvent, snapshot: &UserAccount, ) -> Result<(), RepositoryError> { let result = self.eventstore.persisteventandsnapshot(event, snapshot).await; match result { Ok() => Ok(()), Err(err) => Err(Self::handleeventstorewriteerror(err)), } }

pub async fn findbyid(&self, id: &UserAccountId) -> Result, RepositoryError> { let snapshotresult = self.eventstore.getlatestsnapshotbyid(id).await; match snapshotresult { Ok(snapshotopt) => match snapshotopt { Some(snapshot) => { let events = self .eventstore .geteventsbyidsinceseqnr(id, snapshot.seqnr() + 1) .await; match events { Ok(events) => Ok(Some(UserAccount::replay(events, snapshot))), Err(err) => Err(Self::handleeventstorereaderror(err)), } } None => Ok(None), }, Err(err) => Err(Self::handleeventstoreread_error(err)), } }

} ```

The following is an example of the repository usage.

```rust let eventstore = EventStore::new( awsdynamodbclient.clone(), journaltablename.tostring(), journalaidindexname.tostring(), snapshottablename.tostring(), snapshotaidindexname.to_string(), 64, );

let mut repository = UserAccountRepository::new(event_store);

// Replay the aggregate from the event store let mut useraccount = repository.findbyid(useraccount_id).await.unwrap();

// Execute a command on the aggregate let useraccountevent = user_account.rename(name).unwrap();

// Store the new event without a snapshot repository .storeevent(&useraccountevent, useraccount.version()) .await // Store the new event with a snapshot // repository // .storeeventandsnapshot(&useraccountevent, &useraccount) // .await ```

event-store-adapter-rs

Usage

Table Specifications

License.

Other language implementations