fix: revert unimplemented endpoint handlers to minimum form

Signed-off-by: William Hankins <[email protected]>

Author: whankinsiv

modules/rest_blockfrost/src/handlers/accounts.rs

@@ -640,149 +640,19 @@ pub async fn handle_account_addresses_blockfrost(
 
 /// Handle `/accounts/{stake_address}/addresses/assets` Blockfrost-compatible endpoint
 pub async fn handle_account_assets_blockfrost(
-    context: Arc<Context<Message>>,
-    params: Vec<String>,
-    handlers_config: Arc<HandlersConfig>,
+    _context: Arc<Context<Message>>,
+    _params: Vec<String>,
+    _handlers_config: Arc<HandlersConfig>,
 ) -> Result<RESTResponse> {
-    let account = match parse_stake_address(&params) {
-        Ok(addr) => addr,
-        Err(resp) => return Ok(resp),
-    };
-
-    // Prepare the message
-    let msg = Arc::new(Message::StateQuery(StateQuery::Accounts(
-        AccountsStateQuery::GetAccountAssociatedAddresses { account },
-    )));
-
-    // Get addresses from historical accounts state
-    let addresses = query_state(
-        &context,
-        &handlers_config.historical_accounts_query_topic,
-        msg,
-        |message| match message {
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::AccountAssociatedAddresses(addresses),
-            )) => Ok(Some(addresses)),
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::NotFound,
-            )) => Ok(None),
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::Error(e),
-            )) => Err(anyhow::anyhow!(
-                "Internal server error while retrieving account addresses: {e}"
-            )),
-            _ => Err(anyhow::anyhow!(
-                "Unexpected message type while retrieving account addresses"
-            )),
-        },
-    )
-    .await?;
-
-    let Some(addresses) = addresses else {
-        return Ok(RESTResponse::with_text(404, "Account not found"));
-    };
-
-    let msg = Arc::new(Message::StateQuery(StateQuery::Addresses(
-        AddressStateQuery::GetAddressesAssets { addresses },
-    )));
-
-    // Get assets from address state
-    let _assets = query_state(
-        &context,
-        &handlers_config.historical_accounts_query_topic,
-        msg,
-        |message| match message {
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::AddressesAssets(assets),
-            )) => Ok(Some(assets)),
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::NotFound,
-            )) => Ok(None),
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::Error(e),
-            )) => Err(anyhow::anyhow!(
-                "Internal server error while retrieving account assets: {e}"
-            )),
-            _ => Err(anyhow::anyhow!(
-                "Unexpected message type while retrieving account assets"
-            )),
-        },
-    )
-    .await?;
     Ok(RESTResponse::with_text(501, "Not implemented"))
 }
 
 /// Handle `/accounts/{stake_address}/addresses/total` Blockfrost-compatible endpoint
 pub async fn handle_account_totals_blockfrost(
-    context: Arc<Context<Message>>,
-    params: Vec<String>,
-    handlers_config: Arc<HandlersConfig>,
+    _context: Arc<Context<Message>>,
+    _params: Vec<String>,
+    _handlers_config: Arc<HandlersConfig>,
 ) -> Result<RESTResponse> {
-    let account = match parse_stake_address(&params) {
-        Ok(addr) => addr,
-        Err(resp) => return Ok(resp),
-    };
-
-    // Prepare the message
-    let msg = Arc::new(Message::StateQuery(StateQuery::Accounts(
-        AccountsStateQuery::GetAccountAssociatedAddresses { account },
-    )));
-
-    // Get addresses from historical accounts state
-    let addresses = query_state(
-        &context,
-        &handlers_config.historical_accounts_query_topic,
-        msg,
-        |message| match message {
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::AccountAssociatedAddresses(addresses),
-            )) => Ok(Some(addresses)),
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::NotFound,
-            )) => Ok(None),
-            Message::StateQueryResponse(StateQueryResponse::Accounts(
-                AccountsStateQueryResponse::Error(e),
-            )) => Err(anyhow::anyhow!(
-                "Internal server error while retrieving account addresses: {e}"
-            )),
-            _ => Err(anyhow::anyhow!(
-                "Unexpected message type while retrieving account addresses"
-            )),
-        },
-    )
-    .await?;
-
-    let Some(addresses) = addresses else {
-        return Ok(RESTResponse::with_text(404, "Account not found"));
-    };
-
-    let msg = Arc::new(Message::StateQuery(StateQuery::Addresses(
-        AddressStateQuery::GetAddressesTotals { addresses },
-    )));
-
-    // Get totals from address state
-    let _totals = query_state(
-        &context,
-        &handlers_config.historical_accounts_query_topic,
-        msg,
-        |message| match message {
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::AddressesTotals(totals),
-            )) => Ok(Some(totals)),
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::NotFound,
-            )) => Ok(None),
-            Message::StateQueryResponse(StateQueryResponse::Addresses(
-                AddressStateQueryResponse::Error(e),
-            )) => Err(anyhow::anyhow!(
-                "Internal server error while retrieving account totals: {e}"
-            )),
-            _ => Err(anyhow::anyhow!(
-                "Unexpected message type while retrieving account totals"
-            )),
-        },
-    )
-    .await?;
     Ok(RESTResponse::with_text(501, "Not implemented"))
 }