qubit-progress 0.8.2

Generic progress reporting abstractions for Qubit Rust libraries
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
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

// =============================================================================
//    Copyright (c) 2025 - 2026 Haixing Hu.
//
//    SPDX-License-Identifier: Apache-2.0
//
//    Licensed under the Apache License, Version 2.0.
// =============================================================================
//! Optional operation stage metadata.

use std::sync::Arc;

#[cfg(feature = "serde")]
use serde::{
    Deserialize,
    Deserializer,
};

#[cfg(feature = "serde")]
use crate::validation::validate_stage;

/// Human-readable sub-stage attached to subsequently emitted events.
#[cfg_attr(feature = "serde", derive(serde::Serialize))]
#[derive(Clone, Debug, Eq, PartialEq)]
pub struct Stage {
    /// Machine-readable stage identifier.
    pub(crate) id: Arc<str>,
    /// Human-readable stage name.
    pub(crate) name: Arc<str>,
    /// One-based stage position when present.
    pub(crate) position: Option<u64>,
    /// Number of stages when present.
    pub(crate) total: Option<u64>,
}

/// Serializable wire representation used to validate standalone stages.
#[cfg(feature = "serde")]
#[derive(Deserialize)]
struct StageWire {
    /// Machine-readable stage identifier.
    id: Arc<str>,
    /// Human-readable stage name.
    name: Arc<str>,
    /// One-based stage position when present.
    position: Option<u64>,
    /// Number of stages when present.
    total: Option<u64>,
}

#[cfg(feature = "serde")]
impl<'de> Deserialize<'de> for Stage {
    /// Deserializes and validates one standalone stage.
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        let wire = StageWire::deserialize(deserializer)?;
        let stage = Self {
            id: wire.id,
            name: wire.name,
            position: wire.position,
            total: wire.total,
        };
        validate_stage(&stage).map_err(serde::de::Error::custom)?;
        Ok(stage)
    }
}

impl Stage {
    /// Creates stage metadata without sequence position information.
    #[must_use]
    pub fn new(id: &str, name: &str) -> Self {
        Self {
            id: Arc::from(id),
            name: Arc::from(name),
            position: None,
            total: None,
        }
    }
    /// Sets one-based stage position and total number of stages.
    #[must_use]
    pub const fn position(mut self, position: u64, total: u64) -> Self {
        self.position = Some(position);
        self.total = Some(total);
        self
    }
    /// Returns the stage's stable ID.
    #[must_use]
    pub fn id(&self) -> &str {
        &self.id
    }
    /// Returns the stage's display name.
    #[must_use]
    pub fn name(&self) -> &str {
        &self.name
    }
    /// Returns the one-based position, if present.
    #[must_use]
    pub const fn position_value(&self) -> Option<u64> {
        self.position
    }
    /// Returns the stage count, if present.
    #[must_use]
    pub const fn total(&self) -> Option<u64> {
        self.total
    }
}