// Copyright (C) Microsoft Corporation. All rights reserved.

use super::Access;
use super::Client;
use super::DropReason;
use crate::ChecksumState;
use crate::MIN_MTU;
use smoltcp::wire::ArpOperation;
use smoltcp::wire::ArpPacket;
use smoltcp::wire::ArpRepr;
use smoltcp::wire::EthernetFrame;
use smoltcp::wire::EthernetProtocol;
use smoltcp::wire::EthernetRepr;

impl<T: Client> Access<'_, T> {
    pub(crate) fn handle_arp(
        &mut self,
        frame: &EthernetRepr,
        payload: &[u8],
    ) -> Result<(), DropReason> {
        let arp = ArpRepr::parse(&ArpPacket::new_unchecked(payload))?;
        match arp {
            ArpRepr::EthernetIpv4 {
                operation: ArpOperation::Request,
                source_hardware_addr,
                source_protocol_addr,
                target_hardware_addr: _,
                target_protocol_addr,
            } if target_protocol_addr == self.inner.state.gateway_ip => {
                let e_repr = EthernetRepr {
                    src_addr: self.inner.state.gateway_mac,
                    dst_addr: frame.src_addr,
                    ethertype: EthernetProtocol::Arp,
                };
                let arp_repr = ArpRepr::EthernetIpv4 {
                    operation: ArpOperation::Reply,
                    source_hardware_addr: self.inner.state.gateway_mac,
                    source_protocol_addr: target_protocol_addr,
                    target_hardware_addr: source_hardware_addr,
                    target_protocol_addr: source_protocol_addr,
                };
                let mut buffer = [0; MIN_MTU];
                let mut response = EthernetFrame::new_unchecked(&mut buffer);
                e_repr.emit(&mut response);
                let mut arp_response = ArpPacket::new_unchecked(response.payload_mut());
                arp_repr.emit(&mut arp_response);
                let len = e_repr.buffer_len() + arp_repr.buffer_len();
                self.client.recv(&buffer[..len], &ChecksumState::NONE);
            }

            _ => return Err(DropReason::UnsupportedArp),
        };
        Ok(())
    }
}
