linera_chain/certificate/
timeout.rs

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
// Copyright (c) Facebook, Inc. and its affiliates.
// Copyright (c) Zefchain Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

use linera_base::{
    crypto::{ValidatorPublicKey, ValidatorSignature},
    data_types::Round,
};
use serde::{
    ser::{Serialize, SerializeStruct, Serializer},
    Deserialize, Deserializer,
};

use super::{generic::GenericCertificate, Certificate};
use crate::block::{ConversionError, Timeout};

impl TryFrom<Certificate> for GenericCertificate<Timeout> {
    type Error = ConversionError;

    fn try_from(cert: Certificate) -> Result<Self, Self::Error> {
        match cert {
            Certificate::Timeout(timeout) => Ok(timeout),
            _ => Err(ConversionError::Timeout),
        }
    }
}

impl From<GenericCertificate<Timeout>> for Certificate {
    fn from(cert: GenericCertificate<Timeout>) -> Certificate {
        Certificate::Timeout(cert)
    }
}

impl Serialize for GenericCertificate<Timeout> {
    fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
        let mut state = serializer.serialize_struct("TimeoutCertificate", 4)?;
        state.serialize_field("value", self.inner())?;
        state.serialize_field("round", &self.round)?;
        state.serialize_field("signatures", self.signatures())?;
        state.end()
    }
}

impl<'de> Deserialize<'de> for GenericCertificate<Timeout> {
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        #[derive(Deserialize)]
        #[serde(rename = "TimeoutCertificate")]
        struct Inner {
            value: Timeout,
            round: Round,
            signatures: Vec<(ValidatorPublicKey, ValidatorSignature)>,
        }
        let inner = Inner::deserialize(deserializer)?;
        if !crate::data_types::is_strictly_ordered(&inner.signatures) {
            Err(serde::de::Error::custom("Vector is not strictly sorted"))
        } else {
            Ok(Self::new(inner.value, inner.round, inner.signatures))
        }
    }
}