pezkuwi-subxt/examples/wasm-example/src/routes/fetching.rs

use futures::FutureExt;
use yew::prelude::*;

use crate::services;

pub struct FetchingExamplesComponent {
    operation_title: Option<AttrValue>,
    lines: Vec<AttrValue>,
}

pub enum Message {
    Error(subxt::Error),
    Reload,
    Line(AttrValue),
    Lines(Vec<AttrValue>),
    ButtonClick(Button),
}

pub enum Button {
    SubscribeFinalized,
    FetchConstant,
    FetchEvents,
}

impl Component for FetchingExamplesComponent {
    type Message = Message;
    type Properties = ();

    fn create(_ctx: &Context<Self>) -> Self {
        FetchingExamplesComponent {
            lines: Vec::new(),
            operation_title: None,
        }
    }

    fn update(&mut self, ctx: &Context<Self>, msg: Self::Message) -> bool {
        match msg {
            Message::Error(err) => {
                self.lines.insert(0, err.to_string().into());
            }
            Message::Reload => {
                let window = web_sys::window().expect("Failed to access the window object");
                window
                    .location()
                    .reload()
                    .expect("Failed to reload the page");
            }
            Message::Line(line) => {
                // newer lines go to the top
                self.lines.insert(0, line);
            }
            Message::Lines(lines) => {
                for line in lines {
                    self.lines.insert(0, line);
                }
            }
            Message::ButtonClick(button) => match button {
                Button::SubscribeFinalized => {
                    self.operation_title = Some("Subscribe to finalized blocks:".into());
                    let cb: Callback<AttrValue> = ctx.link().callback(Message::Line);
                    ctx.link()
                        .send_future(services::subscribe_to_finalized_blocks(cb).map(|result| {
                            let err = result.unwrap_err();
                            Message::Error(err)
                        }));
                }
                Button::FetchConstant => {
                    self.operation_title =
                        Some("Fetch the constant \"block_length\" of \"System\" pallet:".into());
                    ctx.link()
                        .send_future(services::fetch_constant_block_length().map(|result| {
                            match result {
                                Ok(value) => Message::Line(
                                    format!(
                                    "constant \"block_length\" of \"System\" pallet:\n    {value}"
                                )
                                    .into(),
                                ),
                                Err(err) => Message::Error(err),
                            }
                        }))
                }
                Button::FetchEvents => {
                    self.operation_title = Some("Fetch events:".into());
                    ctx.link()
                        .send_future(services::fetch_events_dynamically().map(
                            |result| match result {
                                Ok(value) => {
                                    Message::Lines(value.into_iter().map(AttrValue::from).collect())
                                }
                                Err(err) => Message::Error(err),
                            },
                        ))
                }
            },
        }
        true
    }

    fn view(&self, ctx: &Context<Self>) -> Html {
        let reload: Callback<MouseEvent> = ctx.link().callback(|_| Message::Reload);

        let subscribe_finalized = ctx
            .link()
            .callback(|_| Message::ButtonClick(Button::SubscribeFinalized));

        let fetch_constant = ctx
            .link()
            .callback(|_| Message::ButtonClick(Button::FetchConstant));

        let fetch_events = ctx
            .link()
            .callback(|_| Message::ButtonClick(Button::FetchEvents));

        html! {
            <div>
                if let Some(operation_title) = &self.operation_title{
                    <button onclick={reload}>{"<= Back"}</button>
                    <h1>{operation_title}</h1>
                    if self.lines.is_empty(){
                        <p>{"Loading..."}</p>
                    }
                    else{

                    }
                    { for self.lines.iter().map(|line| html! {<p> {line} </p>}) }
                }
                else{
                    <>
                        <a href="/"> <button>{"<= Back"}</button></a>
                        <h1>{"Subxt Fetching and Subscribing Examples"}</h1>
                        <button onclick={subscribe_finalized}>{"Example: Subscribe to Finalized blocks"}</button>
                        <button onclick={fetch_constant}>{"Example: Fetch constant value"}</button>
                        <button onclick={fetch_events}>{"Example: Fetch events"}</button>
                    </>
                }
            </div>
        }
    }
}