// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

// UNSAFETY: Calling BCrypt APIs.
#![allow(unsafe_code)]

use crate::error::Error;
use anyhow::anyhow;
use std::marker::PhantomData;
use vmgs_format::VMGS_ENCRYPTION_KEY_SIZE;
use windows::Win32::Security::Cryptography::BCryptCloseAlgorithmProvider;
use windows::Win32::Security::Cryptography::BCryptDecrypt;
use windows::Win32::Security::Cryptography::BCryptDestroyKey;
use windows::Win32::Security::Cryptography::BCryptEncrypt;
use windows::Win32::Security::Cryptography::BCryptImportKey;
use windows::Win32::Security::Cryptography::BCryptOpenAlgorithmProvider;
use windows::Win32::Security::Cryptography::BCryptSetProperty;
use windows::Win32::Security::Cryptography::BCRYPT_AES_ALGORITHM;
use windows::Win32::Security::Cryptography::BCRYPT_ALG_HANDLE;
use windows::Win32::Security::Cryptography::BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO;
use windows::Win32::Security::Cryptography::BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO_VERSION;
use windows::Win32::Security::Cryptography::BCRYPT_CHAINING_MODE;
use windows::Win32::Security::Cryptography::BCRYPT_KEY_DATA_BLOB;
use windows::Win32::Security::Cryptography::BCRYPT_KEY_DATA_BLOB_MAGIC;
use windows::Win32::Security::Cryptography::BCRYPT_KEY_DATA_BLOB_VERSION1;
use windows::Win32::Security::Cryptography::BCRYPT_KEY_HANDLE;
use zerocopy::AsBytes;

// BCryptImportKey expects a key header immediately followed by a key of size key_len
#[repr(C)]
#[derive(AsBytes)]
struct KeyBlob {
    header_magic: u32,
    header_version: u32,
    key_len: u32,
    key: [u8; VMGS_ENCRYPTION_KEY_SIZE],
}

impl KeyBlob {
    fn new(key: &[u8]) -> Result<Self, Error> {
        let key_a: [u8; VMGS_ENCRYPTION_KEY_SIZE] = key
            .try_into()
            .map_err(|e| Error::Other(anyhow!("KeyBlob: invalid key size: {}", e)))?;

        Ok(KeyBlob {
            header_magic: BCRYPT_KEY_DATA_BLOB_MAGIC,
            header_version: BCRYPT_KEY_DATA_BLOB_VERSION1,
            key_len: VMGS_ENCRYPTION_KEY_SIZE as u32,
            key: key_a,
        })
    }
}

#[repr(transparent)]
struct CipherModeInfoRef<'a>(BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO, PhantomData<&'a [u8]>);

impl<'a> CipherModeInfoRef<'a> {
    pub fn new(nonce: &'a mut [u8], tag: &'a mut [u8]) -> Self {
        Self(
            BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO {
                cbSize: size_of::<BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO>() as u32,
                dwInfoVersion: BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO_VERSION,
                cbNonce: nonce.len() as u32,
                pbNonce: nonce.as_mut_ptr(),
                cbTag: tag.len() as u32,
                pbTag: tag.as_mut_ptr(),
                ..Default::default()
            },
            PhantomData,
        )
    }

    fn get_padding_info(&self) -> *const BCRYPT_AUTHENTICATED_CIPHER_MODE_INFO {
        &self.0
    }
}

struct KeyWrapper {
    key: BCRYPT_KEY_HANDLE,
}

impl Drop for KeyWrapper {
    fn drop(&mut self) {
        // SAFETY: KeyWrapper guarantees that the key handle is valid
        unsafe {
            let _ret = BCryptDestroyKey(self.key);
        }
    }
}

struct AlgWrapper {
    alg: BCRYPT_ALG_HANDLE,
}

impl Drop for AlgWrapper {
    fn drop(&mut self) {
        // SAFETY: AlgWrapper guarantees that the algorithm handle is valid
        unsafe {
            let _ret = BCryptCloseAlgorithmProvider(self.alg, 0);
        }
    }
}

pub fn vmgs_encrypt(key: &[u8], iv: &[u8], data: &[u8], tag: &mut [u8]) -> Result<Vec<u8>, Error> {
    let mut encrypted_len = 0;
    let mut iv_buffer = iv.to_vec();
    let mut nonce_buffer = iv.to_vec();

    let encrypt_key = import_bcrypt_key(key)?;
    let auth_mode = CipherModeInfoRef::new(&mut nonce_buffer, tag);

    let mut encrypted_data = vec![0; data.len()];
    // SAFETY: CipherModeInfoRef ensures the nonce and tag pointers maintain their lifetime
    unsafe {
        BCryptEncrypt(
            encrypt_key.key,
            Some(data),
            Some(auth_mode.get_padding_info().cast()),
            Some(&mut iv_buffer),
            Some(&mut encrypted_data),
            &mut encrypted_len,
            Default::default(),
        )
        .ok()
        .map_err(|e| Error::Other(anyhow!("BCrypt: Failed to perform encryption: {:?}", e)))?;
    }
    assert_eq!(encrypted_len as usize, encrypted_data.len());
    Ok(encrypted_data)
}

pub fn vmgs_decrypt(key: &[u8], iv: &[u8], data: &[u8], tag: &[u8]) -> Result<Vec<u8>, Error> {
    let mut decrypted_len = 0;
    let mut auth_tag: Vec<u8> = tag.to_vec();
    let mut iv_buffer: Vec<u8> = iv.to_vec();
    let mut nonce_buffer: Vec<u8> = iv.to_vec();

    let decrypt_key = import_bcrypt_key(key)?;
    let auth_mode = CipherModeInfoRef::new(&mut nonce_buffer, &mut auth_tag);

    let mut decrypted_data = vec![0; data.len()];
    // SAFETY: CipherModeInfoRef ensures the nonce and tag pointers maintain their lifetime
    unsafe {
        BCryptDecrypt(
            decrypt_key.key,
            Some(data),
            Some(auth_mode.get_padding_info().cast()),
            Some(&mut iv_buffer),
            Some(&mut decrypted_data),
            &mut decrypted_len,
            Default::default(),
        )
        .ok()
        .map_err(|e| Error::Other(anyhow!("BCrypt: Failed to perform decryption: {:?}", e,)))?;
    }
    assert_eq!(decrypted_len as usize, decrypted_data.len());
    Ok(decrypted_data)
}

/// Configure bcrypt algorithm handle to use AES_GCM and wrap provided key with bcrypt metadata
fn import_bcrypt_key(key: &[u8]) -> Result<KeyWrapper, Error> {
    let mut alg = Default::default();
    let mut bcrypt_key: BCRYPT_KEY_HANDLE = Default::default();
    let key_blob = KeyBlob::new(key)?;
    let chaining_mode = "ChainingModeGCM\0".encode_utf16().collect::<Vec<u16>>();

    //SAFETY: Algorithm and key handles are properly destroyed when exiting scope
    unsafe {
        let alg_handle = {
            BCryptOpenAlgorithmProvider(&mut alg, BCRYPT_AES_ALGORITHM, None, Default::default())
                .ok()
                .map_err(|e| Error::Other(anyhow!("BCrypt: Failed to set GCM Property: {}", e)))?;
            AlgWrapper { alg }
        };

        BCryptSetProperty(
            alg_handle.alg.into(),
            BCRYPT_CHAINING_MODE,
            chaining_mode.as_bytes(),
            Default::default(),
        )
        .ok()
        .map_err(|e| Error::Other(anyhow!("BCrypt: Failed to set GCM Property: {}", e)))?;

        BCryptImportKey(
            alg_handle.alg,
            None,
            BCRYPT_KEY_DATA_BLOB,
            &mut bcrypt_key,
            None,
            key_blob.as_bytes(),
            Default::default(),
        )
        .ok()
        .map_err(|e| Error::Other(anyhow!("BCrypt: Failed to import key {}", e)))?;
        Ok(KeyWrapper { key: bcrypt_key })
    }
}
