Struct RadiusPacket 

pub struct RadiusPacket {
    pub code: u8,
    pub identifier: u8,
    pub length: u16,
    pub authenticator: [u8; 16],
    pub attributes: Vec<RadiusAttribute>,
}

Fields

code: u8

identifier: u8

length: u16

authenticator: [u8; 16]

attributes: Vec<RadiusAttribute>

Implementations

impl RadiusPacket

pub fn from_bytes(buf: &[u8]) -> Result<Self, String>

pub fn to_bytes(&self) -> Vec<u8>

pub fn access_accept(identifier: u8, attributes: Vec<RadiusAttribute>) -> Self

pub fn access_reject(identifier: u8, msg: &str) -> Self

pub fn access_challenge(identifier: u8, msg: &str) -> Self

pub fn log(&self)

pub fn reply_accept(&self, attributes: Vec<RadiusAttribute>) -> RadiusPacket

Examples found in repository

examples/server.rs (lines 34-37)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dict = Arc::new(Dictionary::load_embedded()?);
    let secret = "test123";

    let dict_acct = dict.clone();
    let dict_auth = dict.clone();
    let secret_acct = secret.to_string();
    let secret_auth = secret.to_string();

    let acct_server = serve_accounting_async("0.0.0.0:1813", dict_acct, &secret_acct, move |packet| async move {
        println!("📨 Accounting ID {} from {:?}", packet.identifier, packet.username());
        for attr in packet.attributes {
            println!("  → Type {}: {:?}", attr.typ, attr.value);
        }
        Ok(())
    });

    let auth_server = serve_async("0.0.0.0:1812", dict_auth, &secret_auth, move |packet| async move {
        println!("🔍 Incoming ID {} from {:?}", packet.identifier, packet.username());
      let acc_pkt: AccountingPacket = packet.clone().into();
    println!("{:?}", acc_pkt);

        if let Some(username) = packet.username() {
            if username.trim() == " " {
                Ok(packet.reply_accept(vec![
                    RadiusAttribute::session_timeout(3600),
                    RadiusAttribute::reply_message("Welcome, admin."),
                ]))
            } else {
                Ok(packet.reply_reject("User not allowed"))
            }
        } else {
            Ok(packet.reply_reject("Missing username"))
        }
    });

    // Run both servers concurrently
    tokio::try_join!(acct_server, auth_server)?;

    Ok(())
}

pub fn reply_reject(&self, message: &str) -> RadiusPacket

Examples found in repository

examples/server.rs (line 39)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dict = Arc::new(Dictionary::load_embedded()?);
    let secret = "test123";

    let dict_acct = dict.clone();
    let dict_auth = dict.clone();
    let secret_acct = secret.to_string();
    let secret_auth = secret.to_string();

    let acct_server = serve_accounting_async("0.0.0.0:1813", dict_acct, &secret_acct, move |packet| async move {
        println!("📨 Accounting ID {} from {:?}", packet.identifier, packet.username());
        for attr in packet.attributes {
            println!("  → Type {}: {:?}", attr.typ, attr.value);
        }
        Ok(())
    });

    let auth_server = serve_async("0.0.0.0:1812", dict_auth, &secret_auth, move |packet| async move {
        println!("🔍 Incoming ID {} from {:?}", packet.identifier, packet.username());
      let acc_pkt: AccountingPacket = packet.clone().into();
    println!("{:?}", acc_pkt);

        if let Some(username) = packet.username() {
            if username.trim() == " " {
                Ok(packet.reply_accept(vec![
                    RadiusAttribute::session_timeout(3600),
                    RadiusAttribute::reply_message("Welcome, admin."),
                ]))
            } else {
                Ok(packet.reply_reject("User not allowed"))
            }
        } else {
            Ok(packet.reply_reject("Missing username"))
        }
    });

    // Run both servers concurrently
    tokio::try_join!(acct_server, auth_server)?;

    Ok(())
}

pub fn reply_challenge(&self, message: &str) -> RadiusPacket

pub fn username(&self) -> Option<String>

Examples found in repository

examples/server.rs (line 20)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dict = Arc::new(Dictionary::load_embedded()?);
    let secret = "test123";

    let dict_acct = dict.clone();
    let dict_auth = dict.clone();
    let secret_acct = secret.to_string();
    let secret_auth = secret.to_string();

    let acct_server = serve_accounting_async("0.0.0.0:1813", dict_acct, &secret_acct, move |packet| async move {
        println!("📨 Accounting ID {} from {:?}", packet.identifier, packet.username());
        for attr in packet.attributes {
            println!("  → Type {}: {:?}", attr.typ, attr.value);
        }
        Ok(())
    });

    let auth_server = serve_async("0.0.0.0:1812", dict_auth, &secret_auth, move |packet| async move {
        println!("🔍 Incoming ID {} from {:?}", packet.identifier, packet.username());
      let acc_pkt: AccountingPacket = packet.clone().into();
    println!("{:?}", acc_pkt);

        if let Some(username) = packet.username() {
            if username.trim() == " " {
                Ok(packet.reply_accept(vec![
                    RadiusAttribute::session_timeout(3600),
                    RadiusAttribute::reply_message("Welcome, admin."),
                ]))
            } else {
                Ok(packet.reply_reject("User not allowed"))
            }
        } else {
            Ok(packet.reply_reject("Missing username"))
        }
    });

    // Run both servers concurrently
    tokio::try_join!(acct_server, auth_server)?;

    Ok(())
}

Trait Implementations

impl Clone for RadiusPacket

fn clone(&self) -> RadiusPacket

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RadiusPacket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<RadiusPacket> for AccountingPacket

fn from(pkt: RadiusPacket) -> Self

Converts to this type from the input type.