[feature] #2050: Add role-related queries.

[feature] #1986: Add Trigger-related queries.
Signed-off-by: Aleksandr Petrosyan <[email protected]>

CHANGELOG.rst

@@ -7,6 +7,21 @@ Changelog
 
 Features
 ~~~~~~~~
+- 2050 Add role-related queries. [Aleksandr Petrosyan]
+
+  [feature] #1986: Add Trigger-related queries.
+- 2121 Check keypair is valid when constructed (#2130) [Marin Veršić]
+- 2099 Add WASM integration test based on Orillion use-case (#2122)
+  [Daniil]
+- 2003 Introduce Parity Scale Decoder tool (#2080) [Daniil]
+- 1952 Add a TPS benchmark as a standard for optimizations (#1963)
+  [s8sato]
+- 2040 Add integration test with transaction execution limit (#2051)
+  [Daniil]
+- 1890 Introduce integration tests based on Orillion use-cases (#2038)
+  [Daniil]
+- 2048 Add toolchain file (#2049) [Daniil]
+- 2037 Introduce Pre-commit Triggers (#2041) [Daniil]
 - 1621 Introduce By Call Triggers (#2006) [Daniil]
 - 1970 Add optional schema endpoint. [Aleksandr]
 - 1620 Introduce time based triggers (#1961) [Daniil]
@@ -115,6 +130,16 @@ Features
 
 Fixes
 ~~~~~
+- 2081 Fix role registration. [Aleksandr Petrosyan]
+- 1640 Generate config.json and genesis.json. [Aleksandr Petrosyan]
+- 1716 Fix consensus failure with f=0 cases (#2124) [s8sato]
+- 1845 Non-mintable assets can be minted once only. [Aleksandr
+  Petrosyan]
+- 2005 Fix `Client::listen_for_events()` not closing WebSocket stream
+  (#2095) [Daniil]
+- 1623 Create a RawGenesisBlockBuilder. [Sam H. Smith]
+- 1917 Add easy_from_str_impl macro (#2054) [Sam Smith]
+- 1922 Move crypto_cli into tools. [Sam H. Smith]
 - 1969 Make the `roles` feature part of the default feature set.
   [Aleksandr]
 - 2013 Hotfix CLI args. [Aleksandr]
@@ -190,6 +215,18 @@ Fixes
 
 Refactor
 ~~~~~~~~
+- 2144 redesign client's http workflow, expose internal api (#2147)
+  [0x009922]
+- : Move to `clap`. [Aleksandr Petrosyan]
+- : Create `iroha_gen` binary, consolidating docs, schema_bin.
+  [Aleksandr Petrosyan]
+- 2109 Make `integration::events::pipeline` test stable (#2110) [s8sato]
+- 1982 encapsulate access to `iroha_crypto` structures (#2077) [Marin
+  Veršić]
+- : Add `AssetDefinition` builder. [Aleksandr Petrosyan]
+- : Remove unnecessary `&mut` from the API. (#2057) [Aleksandr
+  Petrosyan]
+- : encapsulate access to data model structures (#1984) [Marin Veršić]
 - : Core, `sumeragi`, instance functions, `torii` (#1965) [Aleksandr
   Petrosyan]
 - 1903 move event emission to `modify_*` methods (#1931) [Daniil]
@@ -221,6 +258,9 @@ Refactor
 
 Documentation
 ~~~~~~~~~~~~~
+- : Add QuentinI to codeowners file (#2138) [Quentin Inkling]
+- Add samhsmith to codeowners file. [Sam Smith]
+- : generate latest changelog. [Aleksandr Petrosyan]
 - : Generate changelog. [Aleksandr]
 - : Update outdated README files. [Aleksandr]
 - : Added missing docs to `api_spec.md`. (#1941) [Aleksandr Petrosyan]
@@ -234,6 +274,10 @@ Documentation
 
 CI/CD changes
 ~~~~~~~~~~~~~
+- : Add genesis check and update documentation. [Aleksandr Petrosyan]
+- : Bump rust, mold and nightly to 1.60, 1.2.0 and 1.62 respectively.
+  (#2129) [Aleksandr Petrosyan]
+- Load-rs triggers. [BAStos525]
 - : Fix push workflow. [Aleksandr]
 - : Add telemetry to default features. [Aleksandr]
 - : add proper tag to push workflow on main. [Aleksandr]
@@ -327,6 +371,8 @@ Version bumps
 
 Schema
 ~~~~~~
+- 2114 Sorted collections support in schemas (#2115) [Marin Veršić]
+- 2108 Add pagination (#2107) [Aleksandr Petrosyan]
 - Make schema, version and macro no_std compatible (#1781) [Marin
   Veršić]
 - Fix signatures in schema. [i1i1]
@@ -336,6 +382,7 @@ Schema
 
 Tests
 ~~~~~
+- : Add roles integration tests. [Aleksandr Petrosyan]
 - Standardize ui tests format, move derive ui tests to derive crates
   (#1708) [Marin Veršić]
 - Fix mock tests - futures unordered bug (#1642) [Egor Ivkov]
@@ -363,6 +410,7 @@ Tests
 
 Other
 ~~~~~
+- Remove `roles` feature. [Daniil Polyakov]
 - Share workdir as a volume with dev docker instances (#1910) [Marin
   Veršić]
 - Remove Diff associated type in Execute (#1895) [Marin Veršić]
@@ -1078,3 +1126,4 @@ Other
   * civetweb as http server.
 
 
+Error: Keyboard Interrupt. Bailing out.

cli/src/torii/routing.rs

@@ -19,7 +19,10 @@ use iroha_core::{
     wsv::WorldTrait,
 };
 use iroha_crypto::SignatureOf;
-use iroha_data_model::{prelude::*, query};
+use iroha_data_model::{
+    prelude::*,
+    query::{self, SignedQueryRequest},
+};
 #[cfg(feature = "telemetry")]
 use iroha_telemetry::metrics::Status;
 use parity_scale_codec::{Decode, Encode};

client/src/client.rs

@@ -13,7 +13,7 @@ use eyre::{eyre, Result, WrapErr};
 use http_default::WebSocketStream;
 use iroha_config::{GetConfiguration, PostConfiguration};
 use iroha_crypto::{HashOf, KeyPair};
-use iroha_data_model::prelude::*;
+use iroha_data_model::{prelude::*, query::SignedQueryRequest};
 use iroha_logger::prelude::*;
 use iroha_telemetry::metrics::Status;
 use iroha_version::prelude::*;

core/src/smartcontracts/isi/asset.rs

@@ -343,7 +343,7 @@ pub mod isi {
 
 /// Asset-related query implementations.
 pub mod query {
-    use eyre::{Result, WrapErr};
+    use eyre::{Result, WrapErr as _};
     use iroha_logger::prelude::*;
 
     use super::*;

core/src/smartcontracts/isi/query.rs

@@ -122,8 +122,13 @@ impl<W: WorldTrait> ValidQuery<W> for QueryBox {
             FindTransactionByHash(query) => query.execute_into_value(wsv),
             FindPermissionTokensByAccountId(query) => query.execute_into_value(wsv),
             FindAssetDefinitionKeyValueByIdAndKey(query) => query.execute_into_value(wsv),
+            FindAllActiveTriggerIds(query) => query.execute_into_value(wsv),
+            FindTriggerById(query) => query.execute_into_value(wsv),
+            FindTriggerKeyValueByIdAndKey(query) => query.execute_into_value(wsv),
             FindAllRoles(query) => query.execute_into_value(wsv),
+            FindAllRoleIds(query) => query.execute_into_value(wsv),
             FindRolesByAccountId(query) => query.execute_into_value(wsv),
+            FindRoleByRoleId(query) => query.execute_into_value(wsv),
         }
     }
 }

core/src/smartcontracts/isi/triggers.rs

@@ -136,3 +136,61 @@ pub mod isi {
         }
     }
 }
+
+pub mod query {
+    //! Queries associated to triggers.
+    use iroha_logger::prelude::*;
+
+    use super::*;
+    use crate::{
+        prelude::*,
+        smartcontracts::{isi::prelude::WorldTrait, query::Error, Evaluate as _, FindError},
+    };
+
+    impl<W: WorldTrait> ValidQuery<W> for FindAllActiveTriggerIds {
+        #[log]
+        #[metrics(+"find_all_active_triggers")]
+        fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
+            Ok(wsv.world.triggers.clone().into())
+        }
+    }
+
+    impl<W: WorldTrait> ValidQuery<W> for FindTriggerById {
+        #[log]
+        #[metrics(+"find_trigger_by_id")]
+        fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
+            let id = self
+                .id
+                .evaluate(wsv, &Context::new())
+                .map_err(|e| Error::Evaluate(format!("Failed to evaluate trigger id. {}", e)))?;
+            let action = wsv.world.triggers.get(&id)?;
+
+            // TODO: Should we redact the metadata if the account is not the technical account/owner?
+            Ok(Trigger {
+                id,
+                action: action.clone(),
+            })
+        }
+    }
+
+    impl<W: WorldTrait> ValidQuery<W> for FindTriggerKeyValueByIdAndKey {
+        #[log]
+        #[metrics(+"find_trigger_key_value_by_id_and_key")]
+        fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
+            let id = self
+                .id
+                .evaluate(wsv, &Context::new())
+                .map_err(|e| Error::Evaluate(format!("Failed to evaluate trigger id. {}", e)))?;
+            let action = wsv.world.triggers.get(&id)?;
+            let key = self
+                .key
+                .evaluate(wsv, &Context::new())
+                .map_err(|e| Error::Evaluate(format!("Failed to evaluate key. {}", e)))?;
+            action
+                .metadata
+                .get(&key)
+                .map(Clone::clone)
+                .ok_or_else(|| FindError::MetadataKey(key).into())
+        }
+    }
+}

core/src/smartcontracts/isi/world.rs

@@ -1,13 +1,14 @@
 //! `World`-related ISI implementations.
 
+use iroha_telemetry::metrics;
+
 use super::prelude::*;
 use crate::prelude::*;
 
 /// Iroha Special Instructions that have `World` as their target.
 pub mod isi {
     use eyre::Result;
     use iroha_data_model::prelude::*;
-    use iroha_telemetry::metrics;
 
     use super::*;
 
@@ -202,6 +203,7 @@ pub mod query {
 
     impl<W: WorldTrait> ValidQuery<W> for FindAllRoles {
         #[log]
+        #[metrics(+"find_all_roles")]
         fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
             Ok(wsv
                 .world
@@ -212,8 +214,39 @@ pub mod query {
         }
     }
 
+    impl<W: WorldTrait> ValidQuery<W> for FindAllRoleIds {
+        #[log]
+        #[metrics(+"find_all_role_ids")]
+        fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
+            Ok(wsv
+               .world
+               .roles
+               .iter()
+               // To me, this should probably be a method, not a field.
+               .map(|role| role.id().clone())
+               .collect())
+        }
+    }
+
+    impl<W: WorldTrait> ValidQuery<W> for FindRoleByRoleId {
+        #[log]
+        #[metrics(+"find_role_by_role_id")]
+        fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
+            let role_id = self
+                .id
+                .evaluate(wsv, &Context::new())
+                .map_err(|e| Error::Evaluate(e.to_string()))?;
+
+            wsv.world.roles.get(&role_id).map_or_else(
+                || Err(Error::Find(Box::new(FindError::Role(role_id)))),
+                |role_ref| Ok(role_ref.clone()),
+            )
+        }
+    }
+
     impl<W: WorldTrait> ValidQuery<W> for FindAllPeers {
         #[log]
+        #[metrics("find_all_peers")]
         fn execute(&self, wsv: &WorldStateView<W>) -> Result<Self::Output, Error> {
             Ok(wsv.peers())
         }

core/src/triggers.rs

@@ -24,6 +24,14 @@ pub struct TriggerSet(
     DashMap<trigger::Id, Action>, // TODO: Consider tree structures.
 );
 
+impl From<TriggerSet> for Vec<trigger::Id> {
+    fn from(TriggerSet(map): TriggerSet) -> Self {
+        map.iter()
+            .map(|reference| reference.key().clone())
+            .collect()
+    }
+}
+
 impl TriggerSet {
     /// Add another trigger to the [`TriggerSet`].
     ///
@@ -46,13 +54,8 @@ impl TriggerSet {
     ///
     /// # Errors
     /// - If [`TriggerSet`] doesn't contain the trigger with the given `id`.
-    pub fn get(
-        &self,
-        id: &trigger::Id,
-    ) -> Result<impl Deref<Target = Action> + '_, smartcontracts::Error> {
-        self.0
-            .get(id)
-            .ok_or_else(|| smartcontracts::Error::Find(Box::new(FindError::Trigger(id.clone()))))
+    pub fn get(&self, id: &trigger::Id) -> Result<impl Deref<Target = Action> + '_, FindError> {
+        self.0.get(id).ok_or_else(|| FindError::Trigger(id.clone()))
     }
 
     /// Remove a trigger from the [`TriggerSet`].
@@ -76,6 +79,13 @@ impl TriggerSet {
         self.0.contains_key(key)
     }
 
+    /// Forward the internal immutable iterator.
+    pub fn iter(
+        &self,
+    ) -> dashmap::iter::Iter<iroha_data_model::trigger::Id, iroha_data_model::trigger::Action> {
+        self.0.iter()
+    }
+
     /// Modify repetitions of the hook identified by [`trigger::Id`].
     ///
     /// # Errors