88 lines
2.9 KiB
Rust
88 lines
2.9 KiB
Rust
|
|
use crate::html::component::header::HeaderHtml;
|
||
|
|
use crate::html::page::not_found::not_found_html_response;
|
||
|
|
use crate::http_util::rpc_method_err;
|
||
|
|
use crate::model::announcement_selector::AnnouncementSelector;
|
||
|
|
use crate::model::announcement_type::AnnouncementType;
|
||
|
|
use crate::model::app_state::AppState;
|
||
|
|
use axum::extract::rejection::PathRejection;
|
||
|
|
use axum::extract::Path;
|
||
|
|
use axum::extract::State;
|
||
|
|
use axum::response::Html;
|
||
|
|
use axum::response::Response;
|
||
|
|
use html_escaper::Escape;
|
||
|
|
use html_escaper::Trusted;
|
||
|
|
use neptune_cash::api::export::BlockHeight;
|
||
|
|
use neptune_cash::prelude::tasm_lib::prelude::Digest;
|
||
|
|
use neptune_cash::prelude::triton_vm::prelude::BFieldCodec;
|
||
|
|
use neptune_cash::prelude::twenty_first::tip5::Tip5;
|
||
|
|
use std::sync::Arc;
|
||
|
|
use tarpc::context;
|
||
|
|
|
||
|
|
#[axum::debug_handler]
|
||
|
|
pub async fn announcement_page(
|
||
|
|
maybe_path: Result<Path<AnnouncementSelector>, PathRejection>,
|
||
|
|
State(state_rw): State<Arc<AppState>>,
|
||
|
|
) -> Result<Html<String>, Response> {
|
||
|
|
#[derive(Debug, Clone, boilerplate::Boilerplate)]
|
||
|
|
#[boilerplate(filename = "web/html/page/announcement.html")]
|
||
|
|
pub struct AnnouncementHtmlPage<'a> {
|
||
|
|
header: HeaderHtml<'a>,
|
||
|
|
index: usize,
|
||
|
|
num_announcements: usize,
|
||
|
|
block_hash: Digest,
|
||
|
|
block_height: BlockHeight,
|
||
|
|
announcement_type: AnnouncementType,
|
||
|
|
}
|
||
|
|
|
||
|
|
let state = &state_rw.load();
|
||
|
|
|
||
|
|
let Path(AnnouncementSelector {
|
||
|
|
block_selector,
|
||
|
|
index,
|
||
|
|
}) = maybe_path.map_err(|e| not_found_html_response(state, Some(e.to_string())))?;
|
||
|
|
|
||
|
|
let block_info = state
|
||
|
|
.rpc_client
|
||
|
|
.block_info(context::current(), state.token(), block_selector)
|
||
|
|
.await
|
||
|
|
.map_err(|e| not_found_html_response(state, Some(e.to_string())))?
|
||
|
|
.map_err(rpc_method_err)?
|
||
|
|
.ok_or(not_found_html_response(
|
||
|
|
state,
|
||
|
|
Some("The requested block does not exist".to_string()),
|
||
|
|
))?;
|
||
|
|
let block_hash = block_info.digest;
|
||
|
|
let block_height = block_info.height;
|
||
|
|
|
||
|
|
let announcements = state
|
||
|
|
.rpc_client
|
||
|
|
.announcements_in_block(context::current(), state.token(), block_selector)
|
||
|
|
.await
|
||
|
|
.map_err(|e| not_found_html_response(state, Some(e.to_string())))?
|
||
|
|
.map_err(rpc_method_err)?
|
||
|
|
.expect(
|
||
|
|
"block guaranteed to exist because we got here; getting its announcements should work",
|
||
|
|
);
|
||
|
|
let num_announcements = announcements.len();
|
||
|
|
let announcement = announcements
|
||
|
|
.get(index)
|
||
|
|
.ok_or(not_found_html_response(
|
||
|
|
state,
|
||
|
|
Some("The requested announcement does not exist".to_string()),
|
||
|
|
))?
|
||
|
|
.clone();
|
||
|
|
let announcement_type = AnnouncementType::parse(announcement);
|
||
|
|
|
||
|
|
let header = HeaderHtml { state };
|
||
|
|
|
||
|
|
let utxo_page = AnnouncementHtmlPage {
|
||
|
|
index,
|
||
|
|
header,
|
||
|
|
block_hash,
|
||
|
|
block_height,
|
||
|
|
num_announcements,
|
||
|
|
announcement_type,
|
||
|
|
};
|
||
|
|
Ok(Html(utxo_page.to_string()))
|
||
|
|
}
|