anypay 0.1.0

AnyPay is a payment processing platform that allows you to accept payments from multiple cryptocurrencies and fiat currencies.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use xrpl::asynch::clients::{
    AsyncWebSocketClient, SingleExecutorMutex, WebSocketOpen, XRPLAsyncWebsocketIO,
};
use xrpl::models::requests::subscribe::{StreamParameter, Subscribe};
use tracing::info;

pub struct XRPLClient {}

impl XRPLClient {
    pub fn new() -> Self {
        Self {}
    }

    pub async fn run_with_url(&mut self, url: &str) -> Result<(), Box<dyn std::error::Error>> {
        info!("Connecting to XRP Ledger at {}", url);
        let mut client: AsyncWebSocketClient<SingleExecutorMutex, WebSocketOpen> = 
            AsyncWebSocketClient::open(url.parse()?).await?;
        info!("✅ Connected to XRPL");

        let subscribe = Subscribe::new(
            None, None, None, None,
            Some(vec![StreamParameter::Ledger, StreamParameter::Transactions]),
            None, None, None,
        );

        client.xrpl_send(subscribe.into()).await?;
        info!("Subscribed to XRPL streams");

        loop {
            if let Some(msg) = client.xrpl_receive().await? {
                //info!("XRPL Event: {:#?}", msg);
            }
        }
    }
}