Update version to 0.1.0-alpha.5 and enhance CHANGELOG

- Bumped the version of the `rillflow` package to 0.1.0-alpha.5 in `Cargo.toml` and `Cargo.lock`.
- Updated the CHANGELOG with highlights for the new version, including improvements to the Snapshotter, document repository, stream aliases, and added tests for various features.
- Made minor code adjustments for clarity and performance in `subscriptions.rs`, `events.rs`, and `query/mod.rs`.

Author: jordcodes

CHANGELOG.md

@@ -1,3 +1,14 @@
+## 0.1.0-alpha.5
+
+Highlights:
+- Snapshotter: background compaction API (`Snapshotter`, `AggregateFolder`), CLI (`snapshots compact-once`, `run-until-idle`), metrics/tracing, README example.
+- Document repo DX: optimistic concurrency (`put`, `update`), versioned `get`, soft delete column and DSL knobs (`include_deleted`, `only_deleted`), CLI for docs.
+- Stream aliases: `stream_aliases` table, `Store::resolve_stream_alias`, CLI `streams resolve`.
+- Projection: metrics command (`projections metrics`).
+
+Tests:
+- Snapshotter test for long streams, docs repo e2e, idempotency conflict, consumer groups and manual ack, stream aliases.
+
 ## 0.1.0-alpha.4
 
 Highlights:

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "rillflow"
-version = "0.1.0-alpha.4"
+version = "0.1.0-alpha.5"
 edition = "2024"
 rust-version = "1.85"
 description = "Rillflow — a lightweight document + event store for Rust, powered by Postgres."

Cargo.toml

@@ -100,6 +100,7 @@ impl Events {
     }
 
     pub async fn read_stream_envelopes(&self, stream_id: Uuid) -> Result<Vec<EventEnvelope>> {
+        #[allow(clippy::type_complexity)]
         let rows: Vec<(
             i64,
             Uuid,

src/events.rs

@@ -177,7 +177,6 @@ impl QuerySpec {
         if !include_deleted {
             builder.push(if has_where { " and " } else { " where " });
             builder.push("deleted_at is null");
-            has_where = true;
         }
 
         if !sort.is_empty() {

src/query/mod.rs

@@ -110,7 +110,7 @@ impl Subscriptions {
                 Ok(c) => c,
                 Err(_) => return,
             };
-            let set_path = format!("set search_path to \"{}\"", schema.replace('"', "\""));
+            let set_path = format!("set search_path to \"{}\"", schema);
             let _ = sqlx::query(&set_path).execute(&mut *conn).await;
             // Start optional listener for NOTIFY wakeups
             let mut listener = if let Some(chan) = &opts.notify_channel {
@@ -312,16 +312,14 @@ impl Subscriptions {
                             .execute(&mut *conn)
                             .await;
                         }
-                    } else {
-                        if matches!(opts.ack_mode, AckMode::Auto) {
-                            let _ = sqlx::query(
-                                "update subscriptions set last_seq = $2, updated_at = now() where name = $1",
-                            )
-                            .bind(&name_s)
-                            .bind(cursor)
-                            .execute(&mut *conn)
-                            .await;
-                        }
+                    } else if matches!(opts.ack_mode, AckMode::Auto) {
+                        let _ = sqlx::query(
+                            "update subscriptions set last_seq = $2, updated_at = now() where name = $1",
+                        )
+                        .bind(&name_s)
+                        .bind(cursor)
+                        .execute(&mut *conn)
+                        .await;
                     }
                     last_checkpoint = Instant::now();
                 }

src/subscriptions.rs

@@ -1,5 +1,5 @@
 use anyhow::Result;
-use rillflow::{Error, Event, Expected, Store};
+use rillflow::{Error, Event, Store};
 use serde_json::json;
 use testcontainers::{
     GenericImage, ImageExt,