mina_producer_dashboard/rpc/
mod.rs

1pub mod filters;
2pub mod handlers;
3
4use serde::Deserialize;
5use tokio::task::JoinHandle;
6
7use crate::{storage::db_sled::Database, NodeStatus};
8
9pub fn spawn_rpc_server(
10    port: u16,
11    db: Database,
12    node_status: NodeStatus,
13    producer_pk: String,
14) -> JoinHandle<()> {
15    tokio::spawn(async move {
16        let api = filters::filters(db.clone(), node_status.clone(), producer_pk);
17
18        warp::serve(api).run(([0, 0, 0, 0], port)).await;
19    })
20}
21
22#[derive(Deserialize)]
23pub struct PaginationParams {
24    limit: Option<usize>,
25}