pointbreak 0.10.0

Durable terminal code review for changes humans and coding agents collaborate on together
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

//! Product attention reads over the active derived generation.

use super::history::{
    CurrentRead, DerivedHistoryAccess, DerivedHistoryMode, DerivedHistoryStatus,
    catching_up_status, projection_stamp,
};
use super::locator::LocatorRead;
use crate::model::RevisionId;
use crate::session::workflow::attention::scope_attention_items;
use crate::session::{AttentionItem, ProjectionDiagnostic};

#[doc(hidden)]
pub enum DerivedAttentionRoute {
    Off,
    Ready(DerivedAttention),
    Unavailable(DerivedHistoryStatus),
}

#[derive(Clone, Debug)]
#[doc(hidden)]
pub struct DerivedAttention {
    pub projection_stamp: String,
    pub event_count: usize,
    pub items: Vec<AttentionItem>,
    pub diagnostics: Vec<ProjectionDiagnostic>,
}

impl DerivedHistoryAccess {
    pub fn attention(
        &self,
        revision: Option<&RevisionId>,
    ) -> Result<DerivedAttentionRoute, String> {
        let DerivedHistoryMode::Active { store_identity, .. } = &self.mode else {
            return Ok(DerivedAttentionRoute::Off);
        };
        let current = match self.current()? {
            CurrentRead::Ready(current) => current,
            CurrentRead::Unavailable(status) => {
                return Ok(DerivedAttentionRoute::Unavailable(status));
            }
        };
        let snapshot = match current
            .service()
            .semantic_materialized_attention_snapshot()
            .map_err(|error| error.to_string())?
        {
            LocatorRead::Ready(snapshot) => snapshot,
            LocatorRead::CatchUpRequired { .. } => {
                return Ok(DerivedAttentionRoute::Unavailable(catching_up_status()));
            }
        };
        let mut items = snapshot.attention.items;
        if let Some(revision) = revision {
            scope_attention_items(&mut items, revision, &snapshot.supersession);
        }
        super::threads::record_active_ownership();
        Ok(DerivedAttentionRoute::Ready(DerivedAttention {
            projection_stamp: projection_stamp(store_identity, snapshot.as_of)?,
            event_count: snapshot.state.event_count,
            items,
            diagnostics: snapshot.attention.diagnostics,
        }))
    }
}