aion-cli 0.26.0

The `aion` command line: operate Aion durable workflows over gRPC and run the Aion server.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Shared paged history reads for CLI commands that need the complete oplog.

use aion_client::Client;
use aion_core::{Event, WorkflowId};
use anyhow::{Context, Result};

/// Reads every history page in sequence without bounding the total answer.
pub(crate) async fn read_all(client: &Client, workflow_id: &WorkflowId) -> Result<Vec<Event>> {
    let mut events = Vec::new();
    let mut from_seq = Some(1);

    loop {
        let page = client
            .read_history(workflow_id, from_seq, None)
            .await
            .context("failed to read workflow history")?;
        events.extend(page.events);
        let Some(next_from_seq) = page.next_from_seq else {
            return Ok(events);
        };
        from_seq = Some(next_from_seq);
    }
}