Retrieves the value from the `TokenEntry`. Panics if the state is not `Ready` (should not happen if used correctly).

Retrieves short-lived access to the configuration. Avoid storing the returned reference.

Asynchronously sets a token entry in the store, transitioning it to `Ready` or `Failed` based on the future's result. It early returns with error if a

Analyze packet and create packet flow information

Encodes and writes an NGAP PDU to the specified TNLA connection. # Arguments `tnla` - Reference to the TNLA connection `pdu` - The NGAP PDU to encode

Find the value in a list of (key, value) pairs by matching the first element. Args: pairs (list

Format and log captured payload.

Attempts to parse HTTP/2 frames from a connection's buffer (client_buffer or server_buffer). Consumes successfully parsed data from t

Print packet flow with arrow notation

Helper to collect all completed streams, remove them from the connection, and return their data as a list of dicts. Keeps track of en

Adds headers to the appropriate side of the stream.

Converts a PLMN (Public Land Mobile Network) Identity back to MCC (Mobile Country Code) and MNC (Mobile Network Code) according to 3GPP decoding rules

Decode HPACK compressed headers using the correct decoder.

Attempts to decode an NGAP PDU payload and returns either the successfully decoded PDU or an error indication PDU that should be sent back to the send

Maps IP addresses to their corresponding network function names

Check if an IP address is a known network function

Processes a single TCP packet, identifies its direction within an HTTP/2 connection, adds its payload to the appropriate buffer, and

Reads data from the SCTP stream asynchronously. # Returns - `Ok(Some(Bytes))` - Successfully read data from the stream - `Ok(None)` - Stream has been

Helper function to resolve a string to IpAddr If the string is a valid IP address, it parses it directly Otherwise, it performs a DNS lookup to resolv

Helper to create the correct hyperframe object based on type.

Handles HTTP/2 frames with Stream ID 0 (connection-level frames).

Helper to convert a completed stream to a dict with request and response data.

Adds a new context element to the manager. This method creates a new `ContextQueue` for the provided context element and adds it to the manager, keye

Adds data to the appropriate side of the stream.

Adds a new TNLA association to the network. This function takes an `SctpStream`, creates a new `TnlaAssociation`, and adds it to the appropriate data

Analyze TCP packet for HTTP and other protocols.

Analyze UDP packet for PFCP and other protocols.

Benchmarks only the read operations after pre-filling the store.

Spawns multiple tasks onto runtime. In each task it writes to the store, and then reads it. It only benchmarks the read operation.

Benchmarks only the write operations.

Builds an error indication PDU with criticality diagnostics from a decoding error. # Arguments `request` - The raw NGAP PDU bytes to decode `error` -

Build the tshark command with the correct capture filter and options.

Clean up old entries from processed_files set.

TODO: Graceful RAN Connection Teardown When closing a RAN (gNB) connection, we must ensure that all associated UE (User Equipment) contexts are proper

Attempts to encode an NGAP PDU payload and returns the encoded bytes. # Arguments `data` - The NGAP PDU to encode # Returns `Ok(Vec<u8>)` - Successf

Updates the configuration and commits the changes atomically. This method takes a closure that modifies the Configuration, applies the changes, and t

Creates a subscriber using the provided token and subscriber data. Args: token (str): JWT token for authentication. subscribe

Loads subscribers from a YAML file and creates them via the API. Args: token (str): JWT token for authentication. yaml_path (

Enqueues a closure to be executed with exclusive access to the context, and sends the result of the closure through a oneshot channel. # Arguments `

Filter packets by specific source and destination IPs

Attempts to find the start of the next potential HTTP/2 frame header after an error or incomplete data. This is a heuristic for recov

Get protocol name from protocol number

Retrieves short-lived access to the Sbi configuration. Avoid storing the returned reference.

Authenticates with the user-init API and returns a JWT token. Args: username (str): The username to authenticate with. passw

TODO: Implement graceful shutdown for the network

Handles a stream-specific HTTP/2 frame, adding its data to the appropriate stream. Triggers logging when a server response is complet

Insert a packet analysis entry into MongoDB, with error handling.

Extracts the inner context value, consuming the queue. This should only be used when you are certain there are no pending operations.