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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134

use crate::error::{Error, Result};
use crate::model::{Address, ByteString};
use crate::util::JsonDeserializer;
use crate::waves_proto::PaymentTransactionData;
use serde_json::Value;

const TYPE: u8 = 2;

#[derive(Clone, Eq, PartialEq, Debug)]
pub struct PaymentTransactionInfo {
    recipient: Address,
    amount: u64,
}

impl PaymentTransactionInfo {
    pub fn new(recipient: Address, amount: u64) -> Self {
        Self { recipient, amount }
    }

    pub fn recipient(&self) -> Address {
        self.recipient.clone()
    }

    pub fn amount(&self) -> u64 {
        self.amount
    }
}

#[derive(Clone, Eq, PartialEq, Debug)]
pub struct PaymentTransaction {
    recipient: Address,
    amount: u64,
}

impl PaymentTransaction {
    pub fn new(recipient: Address, amount: u64) -> Self {
        Self { recipient, amount }
    }

    pub fn recipient(&self) -> Address {
        self.recipient.clone()
    }

    pub fn amount(&self) -> u64 {
        self.amount
    }

    pub fn tx_type() -> u8 {
        TYPE
    }
}

impl TryFrom<&PaymentTransaction> for PaymentTransactionData {
    type Error = Error;

    fn try_from(value: &PaymentTransaction) -> Result<Self> {
        Ok(PaymentTransactionData {
            recipient_address: value.recipient().bytes(),
            amount: value.amount() as i64,
        })
    }
}

impl TryFrom<&Value> for PaymentTransactionInfo {
    type Error = Error;

    fn try_from(value: &Value) -> Result<Self> {
        let amount = JsonDeserializer::safe_to_int_from_field(value, "amount")?;
        let recipient = JsonDeserializer::safe_to_string_from_field(value, "recipient")?;
        Ok(PaymentTransactionInfo {
            recipient: Address::from_string(&recipient)?,
            amount: amount as u64,
        })
    }
}

impl TryFrom<&Value> for PaymentTransaction {
    type Error = Error;

    fn try_from(value: &Value) -> Result<Self> {
        let amount = JsonDeserializer::safe_to_int_from_field(value, "amount")?;
        let recipient = JsonDeserializer::safe_to_string_from_field(value, "recipient")?;
        Ok(PaymentTransaction {
            recipient: Address::from_string(&recipient)?,
            amount: amount as u64,
        })
    }
}

#[cfg(test)]
mod tests {
    use crate::error::Result;
    use crate::model::{
        Address, ByteString, PaymentTransaction, SignedTransaction, TransactionInfoResponse,
    };
    use crate::waves_proto::PaymentTransactionData;
    use serde_json::Value;
    use std::fs;

    #[test]
    fn test_json_to_payment_transaction() -> Result<()> {
        let data = fs::read_to_string("./tests/resources/payment_transaction_rs.json")
            .expect("Unable to read file");
        let json: &Value = &serde_json::from_str(&data).expect("failed to generate json from str");

        let payment_tx: SignedTransaction = json.try_into()?;

        let payment_tx_info: TransactionInfoResponse = json.try_into()?;

        assert_eq!(payment_tx.id()?, payment_tx_info.id());

        let payment_from_json: PaymentTransaction = json.try_into().unwrap();

        assert_eq!(910924657498, payment_from_json.amount());
        assert_eq!(
            "3PP4hNGAJaMqmx9vpdYUHk8owF3mwbUevoz",
            payment_from_json.recipient().encoded()
        );
        Ok(())
    }

    #[test]
    fn test_payment_to_proto() -> Result<()> {
        let payment_tx = &PaymentTransaction::new(
            Address::from_string("3PP4hNGAJaMqmx9vpdYUHk8owF3mwbUevoz")?,
            32,
        );
        let proto: PaymentTransactionData = payment_tx.try_into()?;

        assert_eq!(proto.recipient_address, payment_tx.recipient().bytes());
        assert_eq!(proto.amount as u64, payment_tx.amount());
        Ok(())
    }
}