[refactor]: remove Value enum

Signed-off-by: Marin Veršić <[email protected]>

client/src/client.rs

@@ -14,6 +14,7 @@ use eyre::{eyre, Result, WrapErr};
 use futures_util::StreamExt;
 use http_default::{AsyncWebSocketStream, WebSocketStream};
 pub use iroha_config::client_api::ConfigDTO;
+use iroha_data_model::query::QueryOutputBox;
 use iroha_logger::prelude::*;
 use iroha_telemetry::metrics::Status;
 use iroha_torii_const::uri as torii_uri;
@@ -29,9 +30,8 @@ use crate::{
     data_model::{
         block::SignedBlock,
         isi::Instruction,
-        predicate::PredicateBox,
         prelude::*,
-        query::{Pagination, Query, Sorting},
+        query::{predicate::PredicateBox, Pagination, Query, Sorting},
         transaction::TransactionPayload,
         BatchedResponse, ChainId, ValidationFail,
     },
@@ -82,13 +82,13 @@ impl Sign for SignedTransaction {
 
 impl<R: QueryOutput> QueryResponseHandler<R>
 where
-    <R as TryFrom<Value>>::Error: Into<eyre::Error>,
+    <R as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
 {
     fn handle(&mut self, resp: &Response<Vec<u8>>) -> QueryResult<R> {
         // Separate-compilation friendly response handling
         fn _handle_query_response_base(
             resp: &Response<Vec<u8>>,
-        ) -> QueryResult<BatchedResponse<Value>> {
+        ) -> QueryResult<BatchedResponse<QueryOutputBox>> {
             match resp.status() {
                 StatusCode::OK => {
                     let res = BatchedResponse::decode_all_versioned(resp.body());
@@ -128,12 +128,12 @@ where
 
         let (batch, cursor) = _handle_query_response_base(resp)?.into();
 
-        let value = R::try_from(batch)
+        let output = R::try_from(batch)
             .map_err(Into::into)
             .wrap_err("Unexpected type")?;
 
         self.query_request.request = crate::data_model::query::QueryRequest::Cursor(cursor);
-        Ok(value)
+        Ok(output)
     }
 }
 
@@ -216,12 +216,12 @@ impl From<ResponseReport> for eyre::Report {
 }
 
 /// Output of a query
-pub trait QueryOutput: Into<Value> + TryFrom<Value> {
+pub trait QueryOutput: Into<QueryOutputBox> + TryFrom<QueryOutputBox> {
     /// Type of the query output
     type Target: Clone;
 
     /// Construct query output from query response
-    fn new(value: Self, query_request: QueryResponseHandler<Self>) -> Self::Target;
+    fn new(output: Self, query_request: QueryResponseHandler<Self>) -> Self::Target;
 }
 
 /// Iterable query output
@@ -245,7 +245,7 @@ impl<T> ResultSet<T> {
 impl<T: Clone> Iterator for ResultSet<T>
 where
     Vec<T>: QueryOutput,
-    <Vec<T> as TryFrom<Value>>::Error: Into<eyre::Error>,
+    <Vec<T> as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
 {
     type Item = QueryResult<T>;
 
@@ -269,11 +269,11 @@ where
                 Err(err) => return Some(Err(ClientQueryError::Other(err))),
                 Ok(ok) => ok,
             };
-            let value = match self.query_handler.handle(&response) {
+            let output = match self.query_handler.handle(&response) {
                 Err(err) => return Some(Err(err)),
                 Ok(ok) => ok,
             };
-            self.iter = value;
+            self.iter = output;
             self.client_cursor = 0;
         }
 
@@ -285,14 +285,14 @@ where
 
 impl<T: Debug + Clone> QueryOutput for Vec<T>
 where
-    Self: Into<Value> + TryFrom<Value>,
+    Self: Into<QueryOutputBox> + TryFrom<QueryOutputBox>,
 {
     type Target = ResultSet<T>;
 
-    fn new(value: Self, query_handler: QueryResponseHandler<Self>) -> Self::Target {
+    fn new(output: Self, query_handler: QueryResponseHandler<Self>) -> Self::Target {
         ResultSet {
             query_handler,
-            iter: value,
+            iter: output,
             client_cursor: 0,
         }
     }
@@ -303,23 +303,21 @@ macro_rules! impl_query_output {
         impl QueryOutput for $ident {
             type Target = Self;
 
-            fn new(value: Self, _query_handler: QueryResponseHandler<Self>) -> Self::Target {
-                value
+            fn new(output: Self, _query_handler: QueryResponseHandler<Self>) -> Self::Target {
+                output
             }
         } )+
     };
 }
 impl_query_output! {
-    bool,
-    crate::data_model::Value,
     crate::data_model::numeric::NumericValue,
     crate::data_model::role::Role,
     crate::data_model::asset::Asset,
     crate::data_model::asset::AssetDefinition,
     crate::data_model::account::Account,
     crate::data_model::domain::Domain,
     crate::data_model::block::BlockHeader,
-    crate::data_model::query::MetadataValue,
+    crate::data_model::metadata::MetadataValue,
     crate::data_model::query::TransactionQueryOutput,
     crate::data_model::permission::PermissionTokenSchema,
     crate::data_model::trigger::Trigger<crate::data_model::events::TriggeringFilterBox>,
@@ -792,7 +790,7 @@ impl Client {
         fetch_size: FetchSize,
     ) -> (DefaultRequestBuilder, QueryResponseHandler<R::Output>)
     where
-        <R::Output as TryFrom<Value>>::Error: Into<eyre::Error>,
+        <R::Output as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
     {
         let query_builder = QueryBuilder::new(request, self.account_id.clone()).with_filter(filter);
         let request = self.sign_query(query_builder).encode_versioned();
@@ -827,15 +825,15 @@ impl Client {
     ) -> QueryResult<<R::Output as QueryOutput>::Target>
     where
         R::Output: QueryOutput,
-        <R::Output as TryFrom<Value>>::Error: Into<eyre::Error>,
+        <R::Output as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
     {
         iroha_logger::trace!(?request, %pagination, ?sorting, ?filter);
         let (req, mut resp_handler) =
             self.prepare_query_request::<R>(request, filter, pagination, sorting, fetch_size);
 
         let response = req.build()?.send()?;
-        let value = resp_handler.handle(&response)?;
-        let output = QueryOutput::new(value, resp_handler);
+        let output = resp_handler.handle(&response)?;
+        let output = QueryOutput::new(output, resp_handler);
 
         Ok(output)
     }
@@ -848,7 +846,7 @@ impl Client {
     where
         R: Query + Debug,
         R::Output: QueryOutput,
-        <R::Output as TryFrom<Value>>::Error: Into<eyre::Error>,
+        <R::Output as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
     {
         self.build_query(request).execute()
     }
@@ -866,7 +864,7 @@ impl Client {
     ) -> QueryResult<O::Target>
     where
         O: QueryOutput,
-        <O as TryFrom<Value>>::Error: Into<eyre::Error>,
+        <O as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
     {
         let request = QueryRequest {
             torii_url: self.torii_url.clone(),
@@ -876,8 +874,8 @@ impl Client {
         let response = request.clone().assemble().build()?.send()?;
 
         let mut resp_handler = QueryResponseHandler::<O>::new(request);
-        let value = resp_handler.handle(&response)?;
-        let output = O::new(value, resp_handler);
+        let output = resp_handler.handle(&response)?;
+        let output = O::new(output, resp_handler);
 
         Ok(output)
     }
@@ -891,7 +889,7 @@ impl Client {
     where
         R: Query + Debug,
         R::Output: QueryOutput,
-        <R::Output as TryFrom<Value>>::Error: Into<eyre::Error>,
+        <R::Output as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
     {
         QueryRequestBuilder::new(self, request)
     }

client/src/query_builder.rs

@@ -1,12 +1,10 @@
 use std::fmt::Debug;
 
+use iroha_data_model::query::QueryOutputBox;
+
 use crate::{
     client::{Client, QueryOutput, QueryResult},
-    data_model::{
-        predicate::PredicateBox,
-        query::{sorting::Sorting, FetchSize, Pagination, Query},
-        Value,
-    },
+    data_model::query::{predicate::PredicateBox, sorting::Sorting, FetchSize, Pagination, Query},
 };
 
 pub struct QueryRequestBuilder<'a, R> {
@@ -22,7 +20,7 @@ impl<'a, R> QueryRequestBuilder<'a, R>
 where
     R: Query + Debug,
     R::Output: QueryOutput,
-    <R::Output as TryFrom<Value>>::Error: Into<eyre::Error>,
+    <R::Output as TryFrom<QueryOutputBox>>::Error: Into<eyre::Error>,
 {
     pub(crate) fn new(client: &'a Client, request: R) -> Self {
         Self {

client/tests/integration/queries/asset.rs

@@ -159,7 +159,6 @@ fn test_total_quantity<T>(
 ) -> Result<()>
 where
     T: Copy + Into<AssetValue>,
-    Value: From<T>,
     Mint<T, Asset>: Instruction,
     Burn<T, Asset>: Instruction,
 {

client/tests/integration/queries/mod.rs

@@ -8,6 +8,7 @@ use iroha_client::{
         query::{cursor::ForwardCursor, error::QueryExecutionFail, MAX_FETCH_SIZE},
     },
 };
+use iroha_data_model::metadata::MetadataValue;
 use test_network::*;
 
 mod account;
@@ -57,8 +58,8 @@ fn live_query_is_dropped_after_smart_contract_end() -> Result<()> {
         client.account_id.clone(),
         Name::from_str("cursor").unwrap(),
     ))?;
-    let Value::String(cursor) = metadata_value.0 else {
-        bail!("Expected `Value::String`, got {:?}", metadata_value.0);
+    let MetadataValue::String(cursor) = metadata_value else {
+        bail!("Expected `Value::String`, got {:?}", metadata_value);
     };
     let asset_cursor = serde_json::from_str::<ForwardCursor>(&cursor)?;
 

client/tests/integration/roles.rs

@@ -6,6 +6,7 @@ use iroha_client::{
     crypto::KeyPair,
     data_model::prelude::*,
 };
+use iroha_data_model::metadata::MetadataValue;
 use serde_json::json;
 use test_network::*;
 
@@ -87,7 +88,7 @@ fn register_and_grant_role_for_metadata_access() -> Result<()> {
     let set_key_value = SetKeyValue::account(
         mouse_id,
         Name::from_str("key").expect("Valid"),
-        Value::String("value".to_owned()),
+        MetadataValue::String("value".to_owned()),
     );
     test_client.submit_blocking(set_key_value)?;
 

client/tests/integration/smartcontracts/query_assets_and_save_cursor/src/lib.rs

@@ -10,7 +10,7 @@ extern crate alloc;
 use alloc::string::ToString as _;
 use core::num::NonZeroU32;
 
-use iroha_smart_contract::{parse, prelude::*};
+use iroha_smart_contract::{data_model::metadata::MetadataValue, parse, prelude::*};
 use lol_alloc::{FreeListAllocator, LockedAllocator};
 
 #[global_allocator]
@@ -31,7 +31,7 @@ fn main(owner: AccountId) {
     SetKeyValue::account(
         owner,
         parse!("cursor" as Name),
-        Value::String(
+        MetadataValue::String(
             serde_json::to_value(cursor)
                 .dbg_expect("Failed to convert cursor to JSON")
                 .to_string(),