auv-scan 0.0.22

Scroll scanning interaction implementation for AUV
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

//! Evidence-first anchor lifecycle evaluator (crate-local v1; no durable wire).

use thiserror::Error;

#[derive(Clone, Debug, PartialEq, Eq)]
pub struct TransitionEvidence {
  pub kind: String,
  pub ref_id: String,
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub enum LifecycleEvent {
  Observed {
    observation_id: String,
    evidence: TransitionEvidence,
  },
  AssociationLinked {
    track_id: String,
    evidence: TransitionEvidence,
  },
  Stale {
    reason_code: String,
    evidence: TransitionEvidence,
  },
  ReacquisitionNeeded {
    track_id: String,
    evidence: TransitionEvidence,
  },
  Reacquired {
    track_id: String,
    evidence: TransitionEvidence,
  },
  Lost {
    track_id: String,
    evidence: TransitionEvidence,
  },
  AmbiguousReacquire {
    track_id: String,
    evidence: TransitionEvidence,
  },
  ObservationFailed {
    reason_code: String,
    evidence: TransitionEvidence,
  },
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub enum LifecycleVerdict {
  Reacquired { track_id: String },
  Lost { track_id: String },
  AmbiguousReacquire { track_id: String },
  ObservationFailed { reason_code: String },
  Incomplete,
}

#[derive(Debug, Error, PartialEq, Eq)]
pub enum LifecycleError {
  #[error("lifecycle event missing transition evidence at index {index}")]
  MissingEvidence { index: usize },
  #[error("empty lifecycle event stream")]
  EmptyEvents,
}

fn has_evidence(event: &LifecycleEvent) -> bool {
  match event {
    LifecycleEvent::Observed { evidence, .. }
    | LifecycleEvent::AssociationLinked { evidence, .. }
    | LifecycleEvent::Stale { evidence, .. }
    | LifecycleEvent::ReacquisitionNeeded { evidence, .. }
    | LifecycleEvent::Reacquired { evidence, .. }
    | LifecycleEvent::Lost { evidence, .. }
    | LifecycleEvent::AmbiguousReacquire { evidence, .. }
    | LifecycleEvent::ObservationFailed { evidence, .. } => !evidence.kind.is_empty() && !evidence.ref_id.is_empty(),
  }
}

/// Evaluate a baked lifecycle event stream into a terminal verdict (evidence-first).
pub fn evaluate_lifecycle(events: &[LifecycleEvent]) -> Result<LifecycleVerdict, LifecycleError> {
  if events.is_empty() {
    return Err(LifecycleError::EmptyEvents);
  }
  for (index, event) in events.iter().enumerate() {
    if !has_evidence(event) {
      return Err(LifecycleError::MissingEvidence { index });
    }
  }

  for event in events.iter().rev() {
    match event {
      LifecycleEvent::Reacquired { track_id, .. } => {
        return Ok(LifecycleVerdict::Reacquired {
          track_id: track_id.clone(),
        });
      }
      LifecycleEvent::Lost { track_id, .. } => {
        return Ok(LifecycleVerdict::Lost {
          track_id: track_id.clone(),
        });
      }
      LifecycleEvent::AmbiguousReacquire { track_id, .. } => {
        return Ok(LifecycleVerdict::AmbiguousReacquire {
          track_id: track_id.clone(),
        });
      }
      LifecycleEvent::ObservationFailed { reason_code, .. } => {
        return Ok(LifecycleVerdict::ObservationFailed {
          reason_code: reason_code.clone(),
        });
      }
      _ => {}
    }
  }

  Ok(LifecycleVerdict::Incomplete)
}