[feat] gva: add query currentBlock

rust-libs/modules/gva/gql/src/queries.rs

@@ -14,6 +14,7 @@
 // along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
 pub mod account_balance;
+pub mod current_block;
 pub mod current_frame;
 pub mod gen_tx;
 pub mod txs_history;
@@ -27,6 +28,7 @@ use duniter_dbs::databases::cm_v1::CmV1DbReadable as _;
 pub struct QueryRoot(
     queries::NodeQuery,
     queries::account_balance::AccountBalanceQuery,
+    queries::current_block::CurrentBlockQuery,
     queries::current_frame::CurrentFrameQuery,
     queries::gen_tx::GenTxsQuery,
     queries::txs_history::TxsHistoryBlockchainQuery,

rust-libs/modules/gva/gql/src/queries/current_block.rs

+//  Copyright (C) 2020 Éloïs SANCHEZ.
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+use crate::*;
+
+#[derive(Default)]
+pub(crate) struct CurrentBlockQuery;
+#[async_graphql::Object]
+impl CurrentBlockQuery {
+    /// Get current block
+    async fn current_block(
+        &self,
+        ctx: &async_graphql::Context<'_>,
+    ) -> async_graphql::Result<BlockMeta> {
+        let data = ctx.data::<GvaSchemaData>()?;
+        let dbs_reader = data.dbs_reader();
+
+        if let Some(current_block_meta) = data
+            .dbs_pool
+            .execute(move |dbs| dbs_reader.get_current_block(&dbs.cm_db))
+            .await??
+            .map(Into::into)
+        {
+            Ok(current_block_meta)
+        } else {
+            Err(async_graphql::Error::new("no blockchain"))
+        }
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use crate::tests::*;
+    use duniter_dbs::databases::cm_v1::CmV1Db;
+    use duniter_dbs::BlockMetaV2;
+
+    #[tokio::test]
+    async fn query_current_frame() -> anyhow::Result<()> {
+        let mut dbs_reader = MockDbsReader::new();
+        dbs_reader
+            .expect_get_current_block::<CmV1Db<MemSingleton>>()
+            .times(1)
+            .returning(|_| {
+                Ok(Some(BlockMetaV2 {
+                    ..Default::default()
+                }))
+            });
+        let schema = create_schema(dbs_reader)?;
+        assert_eq!(
+            exec_graphql_request(&schema, r#"{ currentBlock {nonce} }"#).await?,
+            serde_json::json!({
+                "data": {
+                    "currentBlock": {
+                      "nonce": 0
+                    }
+                }
+            })
+        );
+        Ok(())
+    }
+}