pub(crate) async fn mpool_push<DB, KS, B>(
    data: Data<RpcState<DB, KS, B>>,
    Params(params): Params<(SignedMessageJson,)>,
) -> Result<CidJson, JsonRpcError>
where
    DB: BlockStore + Send + Sync + 'static,
    KS: KeyStore + Send + Sync + 'static,
    B: Beacon + Send + Sync + 'static,
{
    let (SignedMessageJson(smsg),) = params;

    let cid = data.mpool.as_ref().push(smsg).await?;

    Ok(CidJson(cid))
}
/// Add SignedMessage to mpool, return msg CID
Add SignedMessage to mpool, return msg CID
Add SignedMessage to mpool return msg CID
pub(crate) async fn mpool_push<DB, KS, B>(
    data: Data<RpcState<DB, KS, B>>,
    Params(params): Params<(SignedMessageJson,)>,
) -> Result<CidJson, JsonRpcError>
where
    DB: BlockStore + Send + Sync + 'static,
    KS: KeyStore + Send + Sync + 'static,
    B: Beacon + Send + Sync + 'static,
{
    let (SignedMessageJson(smsg),) = params;
    let cid = data.mpool.as_ref().push(smsg).await?;
    Ok(CidJson(cid))
}
pub ( crate ) async fn mpool_push < DB , KS , B > ( data : Data < RpcState < DB , KS , B > > , Params ( params ) : Params < ( SignedMessageJson , ) > , ) -> Result < CidJson , JsonRpcError > where DB : BlockStore + Send + Sync + ' static , KS : KeyStore + Send + Sync + ' static , B : Beacon + Send + Sync + ' static , { let ( SignedMessageJson ( smsg ) , ) = params ; let cid = data . mpool . as_ref ( ) . push ( smsg ) . await ? ; Ok ( CidJson ( cid ) ) }
Add SignedMessage to mpool, return msg CID
Add SignedMessage to mpool return msg CID
data
Params<(SignedMessageJson,)>