//! Example of using async I2C target
//!
//! This uses the virtual COM port provided on the LP-MSPM0L1306 board.

#![no_std]
#![no_main]

use defmt::*;
use embassy_executor::Spawner;
use embassy_mspm0::i2c::Config;
use embassy_mspm0::i2c_target::{Command, Config as TargetConfig, I2cTarget, ReadStatus};
use embassy_mspm0::peripherals::I2C0;
use embassy_mspm0::{bind_interrupts, i2c};
use {defmt_rtt as _, panic_halt as _};

bind_interrupts!(struct Irqs {
    I2C0 => i2c::InterruptHandler<I2C0>;
});

#[embassy_executor::main]
async fn main(_spawner: Spawner) -> ! {
    let p = embassy_mspm0::init(Default::default());

    let instance = p.I2C0;
    let scl = p.PA1;
    let sda = p.PA0;

    let config = Config::default();
    let mut target_config = TargetConfig::default();
    target_config.target_addr = 0x48;
    target_config.general_call = true;
    let mut i2c = I2cTarget::new(instance, scl, sda, Irqs, config, target_config).unwrap();

    let mut read = [0u8; 8];
    let data = [8u8; 2];
    let data_wr = [9u8; 2];

    loop {
        match i2c.listen(&mut read).await {
            Ok(Command::GeneralCall(_)) => info!("General call received"),
            Ok(Command::Read) => {
                info!("Read command received");
                match i2c.respond_to_read(&data).await.unwrap() {
                    ReadStatus::Done => info!("Finished reading"),
                    ReadStatus::NeedMoreBytes => {
                        info!("Read needs more bytes - will reset");
                        i2c.reset().unwrap();
                    }
                    ReadStatus::LeftoverBytes(_) => {
                        info!("Leftover bytes received");
                        i2c.flush_tx_fifo();
                    }
                }
            }
            Ok(Command::Write(_)) => info!("Write command received"),
            Ok(Command::WriteRead(_)) => {
                info!("Write-Read command received");
                i2c.respond_and_fill(&data_wr, 0xFE).await.unwrap();
            }
            Err(e) => info!("Got error {}", e),
        }
    }
}