parser.rs

//  Copyright (C) 2017-2019  The AXIOM TEAM Association.
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as
// published by the Free Software Foundation, either version 3 of the
// License, or (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <https://www.gnu.org/licenses/>.

//! Parsers for block.

use crate::block::{BlockDocument, BlockDocumentV10};
use dubp_common_doc::{BlockHash, BlockNumber};
use dubp_currency_params::genesis_block_params::v10::BlockV10Parameters;
use dubp_currency_params::CurrencyName;
use dubp_user_docs::documents::membership::v10::MembershipType;
use dubp_user_docs::documents::transaction::TransactionDocument;
use dubp_user_docs::parsers::{serde_json_value_to_pest_json_value, DefaultHasher};
use dup_crypto::bases::BaseConvertionError;
use dup_crypto::hashs::Hash;
use dup_crypto::keys::*;
use failure::Error;
use json_pest_parser::*;
use std::str::FromStr;

pub fn parse_json_block_from_serde_value(
    serde_json_value: &serde_json::Value,
) -> Result<BlockDocument, Error> {
    parse_json_block(&serde_json_value_to_pest_json_value(serde_json_value)?)
}

pub fn parse_json_block(json_block: &JSONValue<DefaultHasher>) -> Result<BlockDocument, Error> {
    if !json_block.is_object() {
        return Err(ParseJsonError {
            cause: "Json block must be an object !".to_owned(),
        }
        .into());
    }

    let json_block = json_block.to_object().expect("safe unwrap");

    let currency = get_str(json_block, "currency")?;

    let block_number = get_number(json_block, "number")?.trunc() as u32;

    Ok(BlockDocument::V10(BlockDocumentV10 {
        version: get_number(json_block, "version")?.trunc() as u32,
        nonce: get_u64(json_block, "nonce")?,
        number: BlockNumber(block_number),
        pow_min: get_number(json_block, "powMin")?.trunc() as usize,
        time: get_number(json_block, "time")?.trunc() as u64,
        median_time: get_number(json_block, "medianTime")?.trunc() as u64,
        members_count: get_number(json_block, "membersCount")?.trunc() as usize,
        monetary_mass: get_number(json_block, "monetaryMass")
            .unwrap_or(0f64)
            .trunc() as usize,
        unit_base: get_number(json_block, "unitbase")?.trunc() as usize,
        issuers_count: get_number(json_block, "issuersCount")?.trunc() as usize,
        issuers_frame: get_number(json_block, "issuersFrame")?.trunc() as usize,
        issuers_frame_var: get_number(json_block, "issuersFrameVar")?.trunc() as isize,
        currency: CurrencyName(currency.to_owned()),
        issuers: vec![PubKey::Ed25519(ed25519::PublicKey::from_base58(get_str(
            json_block, "issuer",
        )?)?)],