-
Notifications
You must be signed in to change notification settings - Fork 20
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
3 changed files
with
96 additions
and
91 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,95 @@ | ||
| use crate::node_interface::{NodeError, NodeInterface, Result}; | ||
| use crate::JsonString; | ||
| use crate::TxId; | ||
| use ergo_lib::chain::transaction::unsigned::UnsignedTransaction; | ||
| use ergo_lib::chain::transaction::Transaction; | ||
| use json::JsonValue; | ||
|
|
||
| impl NodeInterface { | ||
| /// Submits a Signed Transaction provided as input as JSON | ||
| /// to the Ergo Blockchain mempool. | ||
| pub fn submit_json_transaction(&self, signed_tx_json: &JsonString) -> Result<TxId> { | ||
| let endpoint = "/transactions"; | ||
| let res_json = self.use_json_endpoint_and_check_errors(endpoint, signed_tx_json)?; | ||
|
|
||
| // If tx is valid and is posted, return just the tx id | ||
| let tx_id = res_json.dump(); | ||
| return Ok(tx_id); | ||
| } | ||
|
|
||
| /// Sign an Unsigned Transaction which is formatted in JSON | ||
| pub fn sign_json_transaction(&self, unsigned_tx_string: &JsonString) -> Result<JsonValue> { | ||
| let endpoint = "/wallet/transaction/sign"; | ||
| let unsigned_tx_json = json::parse(&unsigned_tx_string) | ||
| .map_err(|_| NodeError::FailedParsingNodeResponse(unsigned_tx_string.to_string()))?; | ||
|
|
||
| let prepared_body = object! { | ||
| tx: unsigned_tx_json | ||
| }; | ||
|
|
||
| println!("Unsigned tx Json: {:?}", prepared_body.dump()); | ||
|
|
||
| let res_json = self.use_json_endpoint_and_check_errors(endpoint, &prepared_body.dump())?; | ||
|
|
||
| Ok(res_json) | ||
| } | ||
|
|
||
| /// Sign an Unsigned Transaction which is formatted in JSON | ||
| /// and then submit it to the mempool. | ||
| pub fn sign_and_submit_json_transaction( | ||
| &self, | ||
| unsigned_tx_string: &JsonString, | ||
| ) -> Result<TxId> { | ||
| let signed_tx = self.sign_json_transaction(unsigned_tx_string)?; | ||
| let signed_tx_json = json::stringify(signed_tx); | ||
|
|
||
| self.submit_json_transaction(&signed_tx_json) | ||
| } | ||
|
|
||
| /// Submits a Signed `Transaction` provided as input | ||
| /// to the Ergo Blockchain mempool. | ||
| pub fn submit_transaction(&self, signed_tx: &Transaction) -> Result<TxId> { | ||
| let signed_tx_json = &serde_json::to_string(&signed_tx) | ||
| .map_err(|_| NodeError::Other("Failed Converting `Transaction` to json".to_string()))?; | ||
| self.submit_json_transaction(signed_tx_json) | ||
| } | ||
|
|
||
| /// Sign an `UnsignedTransaction` | ||
| pub fn sign_transaction(&self, unsigned_tx: &UnsignedTransaction) -> Result<Transaction> { | ||
| let json_tx = | ||
| self.sign_json_transaction(&serde_json::to_string(&unsigned_tx).map_err(|_| { | ||
| NodeError::Other("Failed Converting `UnsignedTransaction` to json".to_string()) | ||
| })?)?; | ||
|
|
||
| serde_json::from_str(&json_tx.dump()) | ||
| .map_err(|_| NodeError::Other("Failed Converting `Transaction` to json".to_string())) | ||
| } | ||
|
|
||
| /// Sign an `UnsignedTransaction` and then submit it to the mempool. | ||
| pub fn sign_and_submit_transaction(&self, unsigned_tx: &UnsignedTransaction) -> Result<TxId> { | ||
| let signed_tx = self.sign_transaction(unsigned_tx)?; | ||
| self.submit_transaction(&signed_tx) | ||
| } | ||
|
|
||
| /// Generates and submits a tx using the node endpoints. Input is | ||
| /// a json formatted request with rawInputs (and rawDataInputs) | ||
| /// manually selected or inputs will be automatically selected by wallet. | ||
| /// Returns the resulting `TxId`. | ||
| pub fn generate_and_submit_transaction(&self, tx_request_json: &JsonString) -> Result<TxId> { | ||
| let endpoint = "/wallet/transaction/send"; | ||
| let res_json = self.use_json_endpoint_and_check_errors(endpoint, tx_request_json)?; | ||
| // If tx is valid and is posted, return just the tx id | ||
| let tx_id = res_json.dump(); | ||
| return Ok(tx_id); | ||
| } | ||
|
|
||
| /// Generates Json of an Unsigned Transaction. | ||
| /// Input must be a json formatted request with rawInputs (and rawDataInputs) | ||
| /// manually selected or will be automatically selected by wallet. | ||
| pub fn generate_json_transaction(&self, tx_request_json: &JsonString) -> Result<JsonValue> { | ||
| let endpoint = "/wallet/transaction/generate"; | ||
| let res_json = self.use_json_endpoint_and_check_errors(endpoint, tx_request_json)?; | ||
|
|
||
| Ok(res_json) | ||
| } | ||
| } |