#![no_std]
#![no_main]
#[allow(unused_imports)]
use defmt::{debug, info, warn, error};
use {defmt_rtt as _, panic_probe as _};
use core::fmt::Write;
use embassy_rp::gpio::Pin;
use embassy_executor::Spawner;
use embassy_futures::join::join;
use embassy_rp::bind_interrupts;
use embassy_rp::peripherals::USB;
use embassy_usb::class::cdc_acm::{CdcAcmClass, State};
use embassy_rp::usb::{InterruptHandler};
use embassy_usb::{Builder, Config};
bind_interrupts!(struct Irqs {
USBCTRL_IRQ => InterruptHandler<USB>;
});
#[embassy_executor::main]
async fn main(_spawner: Spawner) {
info!("top");
let mut p = embassy_rp::init(Default::default());
let driver = embassy_rp::usb::Driver::new(p.USB, Irqs);
let mut config = Config::new(0x6666, 0x5c4f);
config.manufacturer = Some("Matt Johnston");
config.product = Some("caprand raw noise");
config.serial_number = Some("12345678");
config.max_power = 100;
config.max_packet_size_0 = 64;
config.device_class = 0xEF;
config.device_sub_class = 0x02;
config.device_protocol = 0x01;
config.composite_with_iads = true;
let mut config_descriptor = [0; 256];
let mut bos_descriptor = [0; 256];
let mut msos_descriptor = [0; 16];
let mut control_buf = [0; 64];
let mut state = State::new();
let mut builder = Builder::new(
driver,
config,
&mut config_descriptor,
&mut bos_descriptor,
&mut msos_descriptor,
&mut control_buf,
);
let mut class = CdcAcmClass::new(&mut builder, &mut state, 64);
let mut usb = builder.build();
let usb_fut = usb.run();
let echo_fut = async {
loop {
class.wait_connection().await;
info!("Connected");
let pin = &mut p.PIN_10;
let _ = run(pin, &mut class).await;
info!("Disconnected");
}
};
join(usb_fut, echo_fut).await;
}
async fn run<'d, D: embassy_usb_driver::Driver<'d>>(pin: &mut impl Pin, class: &mut CdcAcmClass<'d, D>) -> Result<(), ()> {
let low_cycles = 1;
let mut noise = caprand::cap::RawNoise::new(pin, low_cycles);
noise.next();
loop {
let mut b = heapless::String::<64>::new();
while b.len() <= b.capacity() - 2 {
let (c, _valid) = noise.next().unwrap();
write!(b, "{:02x}\n", c).unwrap();
}
class.write_packet(b.as_bytes()).await.unwrap()
}
}