Struct ParserProxyServer 

pub struct ParserProxyServer { /* private fields */ }

The main parser proxy server that handles gRPC subscriptions and WebSocket broadcasting

Implementations

impl ParserProxyServer

pub fn new<P: AsRef<Path>>(config_path: P) -> Result<Self>

Create a new parser proxy server with the specified config file path

Arguments

• config_path - Path to the TOML configuration file

Examples

use parser_proxy_ws::ParserProxyServer;

let server = ParserProxyServer::new("config.toml")?;

pub fn with_config(config: Config) -> Self

Create a new parser proxy server with an existing config

Arguments

• config - Pre-loaded configuration

pub async fn start(self) -> Result<()>

Start the parser proxy server

This method will:

1. Initialize the WebSocket server
2. Connect to the Yellowstone gRPC endpoint
3. Subscribe to configured DEX events
4. Start broadcasting events to WebSocket clients

The method will run indefinitely until interrupted.

Examples

use parser_proxy_ws::ParserProxyServer;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let server = ParserProxyServer::new("config.toml")?;
    server.start().await?;
    Ok(())
}

pub async fn run(self) -> Result<()>

Start the parser proxy server and wait for shutdown signal

This is a convenience method that calls start() and waits for Ctrl+C.

pub fn config(&self) -> &Config

Get the server configuration

pub fn ws_url(&self) -> String

Get the WebSocket URL that clients can connect to