parse.rs 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191
  1. use sha2::{Digest, Sha256};
  2. use std::iter::FromIterator;
  3. use std::str::FromStr;
  4. use crate::{
  5. serial::{deserialize, serialize},
  6. util::{NetworkName, SolTokenList},
  7. Error, Result,
  8. };
  9. // hash the external token ID and NetworkName param.
  10. // if fails, change the last 4 bytes and hash it again. keep repeating until it works.
  11. pub fn generate_id(tkn_str: &str, network: &NetworkName) -> Result<jubjub::Fr> {
  12. let mut id_string = network.to_string();
  13. id_string.push_str(tkn_str);
  14. let mut data: Vec<u8> = serialize(&id_string);
  15. let token_id = match deserialize::<jubjub::Fr>(&data) {
  16. Ok(v) => v,
  17. Err(_) => {
  18. let mut counter = 0;
  19. loop {
  20. data.truncate(28);
  21. let serialized_counter = serialize(&counter);
  22. data.extend(serialized_counter.iter());
  23. let mut hasher = Sha256::new();
  24. hasher.update(&data);
  25. let hash = hasher.finalize();
  26. let token_id = deserialize::<jubjub::Fr>(&hash);
  27. if token_id.is_err() {
  28. counter += 1;
  29. continue;
  30. }
  31. return Ok(token_id.unwrap());
  32. }
  33. }
  34. };
  35. Ok(token_id)
  36. }
  37. pub fn assign_id(network: &str, token: &str, _tokenlist: &SolTokenList) -> Result<String> {
  38. let token = token.to_lowercase();
  39. let _token = token.as_str();
  40. match NetworkName::from_str(network)? {
  41. #[cfg(feature = "sol")]
  42. NetworkName::Solana => {
  43. // (== 44) can represent a Solana base58 token mint address
  44. let id = if _token.len() == 44 {
  45. _token.to_string()
  46. } else {
  47. symbol_to_id(_token, _tokenlist)?
  48. };
  49. Ok(id)
  50. }
  51. #[cfg(feature = "btc")]
  52. NetworkName::Bitcoin => Err(Error::NotSupportedToken),
  53. _ => Err(Error::NotSupportedNetwork),
  54. }
  55. }
  56. pub fn decimals(token: &str, tokenlist: &SolTokenList) -> Result<usize> {
  57. match token.to_lowercase().as_str() {
  58. "btc" => Err(Error::NotSupportedToken),
  59. _ => {
  60. let decimals = tokenlist.search_decimal(token)?;
  61. if let Some(decimals) = decimals {
  62. Ok(decimals)
  63. } else {
  64. Err(Error::NotSupportedToken)
  65. }
  66. }
  67. }
  68. }
  69. pub fn symbol_to_id(token: &str, tokenlist: &SolTokenList) -> Result<String> {
  70. let vec: Vec<char> = token.chars().collect();
  71. let mut counter = 0;
  72. for c in vec {
  73. if c.is_alphabetic() {
  74. counter += 1;
  75. }
  76. }
  77. if counter == token.len() {
  78. if let Some(id) = tokenlist.search_id(token)? {
  79. Ok(id)
  80. } else {
  81. Err(Error::TokenParseError)
  82. }
  83. } else {
  84. Ok(token.to_string())
  85. }
  86. }
  87. fn is_digit(c: char) -> bool {
  88. ('0'..='9').contains(&c)
  89. }
  90. fn char_eq(a: char, b: char) -> bool {
  91. a == b
  92. }
  93. pub fn decode_base10(amount: &str, decimal_places: usize, strict: bool) -> Result<u64> {
  94. let mut s: Vec<char> = amount.to_string().chars().collect();
  95. // Get rid of the decimal point:
  96. let point: usize;
  97. if let Some(p) = amount.find('.') {
  98. s.remove(p);
  99. point = p;
  100. } else {
  101. point = s.len();
  102. }
  103. // Only digits should remain
  104. for i in &s {
  105. if !is_digit(*i) {
  106. return Err(Error::ParseFailed("Found non-digits"));
  107. }
  108. }
  109. // Add digits to the end if there are too few:
  110. let actual_places = s.len() - point;
  111. if actual_places < decimal_places {
  112. s.extend(vec!['0'; decimal_places - actual_places])
  113. }
  114. // Remove digits from the end if there are too many:
  115. let mut round = false;
  116. if actual_places > decimal_places {
  117. let end = point + decimal_places;
  118. for i in &s[end..s.len()] {
  119. if !char_eq(*i, '0') {
  120. round = true;
  121. break;
  122. }
  123. }
  124. s.truncate(end);
  125. }
  126. if strict && round {
  127. return Err(Error::ParseFailed("Would end up rounding while strict"));
  128. }
  129. // Convert to an integer
  130. let number = u64::from_str(&String::from_iter(&s))?;
  131. // Round and return
  132. if round && number == u64::MAX {
  133. return Err(Error::ParseFailed("u64 overflow"));
  134. }
  135. Ok(number + round as u64)
  136. }
  137. pub fn encode_base10(amount: u64, decimal_places: usize) -> String {
  138. let mut s: Vec<char> = format!("{:0width$}", amount, width = 1 + decimal_places)
  139. .chars()
  140. .collect();
  141. s.insert(s.len() - decimal_places, '.');
  142. String::from_iter(&s)
  143. .trim_end_matches('0')
  144. .trim_end_matches('.')
  145. .to_string()
  146. }
  147. #[allow(unused_imports)]
  148. mod tests {
  149. use crate::util::decode_base10;
  150. use crate::util::encode_base10;
  151. #[test]
  152. fn test_decode_base10() {
  153. assert_eq!(124, decode_base10("12.33", 1, false).unwrap());
  154. assert_eq!(1233000, decode_base10("12.33", 5, false).unwrap());
  155. assert_eq!(1200000, decode_base10("12.", 5, false).unwrap());
  156. assert_eq!(1200000, decode_base10("12", 5, false).unwrap());
  157. assert!(decode_base10("12.33", 1, true).is_err());
  158. }
  159. #[test]
  160. fn test_encode_base10() {
  161. assert_eq!("23.4321111", &encode_base10(234321111, 7));
  162. assert_eq!("23432111.1", &encode_base10(234321111, 1));
  163. assert_eq!("234321.1", &encode_base10(2343211, 1));
  164. assert_eq!("2343211", &encode_base10(2343211, 0));
  165. assert_eq!("0.00002343", &encode_base10(2343, 8));
  166. }
  167. }