Function send_rpc

packages/server/src/webkit.rs:971–995

(
    writer: &mut W,
    selector: &str,
    args: Dictionary,
)

}

async fn send_rpc<W: AsyncWrite + Unpin>(
    writer: &mut W,
    selector: &str,
    args: Dictionary,
) -> Result<(), AppError> {
    let mut message = Dictionary::new();
    message.insert("__selector".to_owned(), Value::String(selector.to_owned()));
    message.insert("__argument".to_owned(), Value::Dictionary(args));

    let mut payload = Vec::new();
    plist::to_writer_binary(&mut payload, &Value::Dictionary(message))
        .map_err(|error| AppError::internal(format!("Unable to encode WebKit plist: {error}")))?;
    if payload.len() > WEBKIT_PACKET_MAX_LEN {
        return Err(AppError::internal("WebKit plist packet is too large."));
    }

    let mut packet = Vec::with_capacity(payload.len() + 4);
    packet.extend_from_slice(&(payload.len() as u32).to_be_bytes());
    packet.extend_from_slice(&payload);
    writer
        .write_all(&packet)
        .await
        .map_err(|error| AppError::native(format!("Unable to write WebKit packet: {error}")))?;
    Ok(())
}

async fn read_packet<R: AsyncRead + Unpin>(reader: &mut R) -> Result<Vec<u8>, AppError> {
    let mut header = [0u8; 4];