xsender 0.1.0

use std::io::{Cursor, Read, Write};

use base64::engine::general_purpose;
use base64::{DecodeError, Engine};
use zip::result::{ZipError, ZipResult};
use zip::write::FileOptions;
use zip::{ZipArchive, ZipWriter};

pub fn create_zip(filename_without_extension: &str, content: &str) -> ZipResult<Vec<u8>> {
    let mut data = Vec::new();

    {
        let buff = Cursor::new(&mut data);
        let mut zip = ZipWriter::new(buff);

        let file_options = FileOptions::default();
        zip.start_file(format!("{filename_without_extension}.xml"), file_options)?;
        zip.write_all(content.as_bytes())?;
        zip.finish()?;
    }

    Ok(data)
}

#[derive(Debug)]
pub struct ExtractCdrFromBase64ZipError {
    pub message: String,
}

pub fn extract_cdr_from_base64_zip(base64: &str) -> Result<String, ExtractCdrFromBase64ZipError> {
    let zip_buf = general_purpose::STANDARD.decode(base64)?;
    let reader = Cursor::new(zip_buf);
    let mut archive = ZipArchive::new(reader)?;

    let mut cdr_xml_content = "".to_string();
    for index in 0..archive.len() {
        let mut entry = archive.by_index(index)?;
        if entry.is_file() && entry.name().ends_with(".xml") {
            entry.read_to_string(&mut cdr_xml_content)?;
            break;
        }
    }

    Ok(cdr_xml_content)
}

impl From<DecodeError> for ExtractCdrFromBase64ZipError {
    fn from(e: DecodeError) -> Self {
        ExtractCdrFromBase64ZipError {
            message: e.to_string(),
        }
    }
}

impl From<ZipError> for ExtractCdrFromBase64ZipError {
    fn from(e: ZipError) -> Self {
        ExtractCdrFromBase64ZipError {
            message: e.to_string(),
        }
    }
}

impl From<std::io::Error> for ExtractCdrFromBase64ZipError {
    fn from(e: std::io::Error) -> Self {
        ExtractCdrFromBase64ZipError {
            message: e.to_string(),
        }
    }
}

#[cfg(test)]
mod tests {
    use crate::zip_manager::extract_cdr_from_base64_zip;

    #[test]
    fn read_base64_zip() {
        let cdr = "UEsDBBQAAgAIAEwklVcAAAAAAgAAAAAAAAAGAAAAZHVtbXkvAwBQSwMEFAACAAgATCSVVwwGkuIxBAAAGQ0AABsAAABSLTEyMzQ1Njc4OTEyLTAxLUYwMDEtMS54bWy1V2FP2zwQ/r5fEZUPk6Y3OElbWKPQqVDGsgFitDC0byY52uhN7WA7peXXv+e4SdMStHbSq/LBuXvuubvHZ1sEXxaz1JqDkAlnJy330GlZwCIeJ2xy0robf7U/t770PwRU+IMsS5OIKgTegsw4k2BhMJMnrVwwn1OZSJ/RGUhfZhAlTyuwnz+mvoymMKP+QsZ+yOY8icD2Wibcp2JPhoZK1mywUHvSnfHZjLPzhQKmVcBPpASm5Jo0eoz+ivQU4VEjIf07wsFkImBCFTSRxrgVU6Uyn5CXl5fDl/YhFxPiOY5DnB5BTCyTyUGJlpxmFd4kkofo0vYiUC8IsDmkPANSJcHkVRgsZKoKsDZLm7LYVgn2UiUp+5Q5o+rdPjMQeb3ZkUY39eqWxIv3enXJw9XlqKAqscgCi6yhaHTkKRU2egVIvfmy1Q9wgvy708tqIGQ55g0+Y6nNDsOV6gejZIId5KI6IjvsCx4zHQZxyJ54/4NlBWeUcYY6pclrodUVqCmPrUE64SJR09m7EriOpsW+IjtyO+zgF6L1AGkNW6TgrircmdTplLXaMy7gQEhqyyntut6K8haeQODtAdbdbajlQiOax4Iy+cTFTBpD3fTHtBsSlcMY27Ks3qTek3QXgZCQbFceDJMJSLWnYqjIQV2niueepjn0H16PRPsBEvXt+ntGw3m4hMvrQXZ+OoB0zKYv98+/w2V4/hS/dm/uur+PB/C8OLvoEX41ypxzGf5KLn9cPF9E38/vczn8OVVikRz9PDkJSD2L3h9SbRCOGtmctfpEmIhPNyKZ4+mz/oWl9fEUFL3Bo4rXGQj10WJcWXn2ydDUooIfsCw4g4eu0xtSRc1KR5kzj8zXeA3EVrQ2rfhNQmSo8W8HF2yhlDmIEYiEpnWLJt6fvhZbcBne63z2CGJ/to3oeoKyXLJWhlRqrXXEdfOdQt5ePm9Msh/gW6VN9+ZND4d979AJyBtrgTvLpeKz1e2CRreEbjsKtAYcO20XJ/mo2z72DLTy6iaHeos8x+3Zrmd7nbHj+MXfClpB1hFjfC76DbDCXsDKN37F7bULbtdgN5wbcEPc8dsd3+tuglfcNPJrqq960ZbR3fVgXOuuAnKxvKFCLY2tWIYxbk71mlU0qEEbf16v210TkfejSoeZQh1QrGqVGA/ZQpL3isPDnyiaVg0OlKLRdFZMkvbrkRGMpus7wUzObdg/2NJA20yihiDyp2RkW2f9CSwG8f9ISRoT3EIEyXznnK7X7nSPjj/3XG/nnA0phjzKtQrl4JW1VF/FUK60xBRf8dWwq8le2zcG+4zHONibE13YCtQQZCSSrKjrklpfaYSyU4thHYJbJsE/1pRaMom5RSPIFI2pYavHlj3VC1+3szEzW4VXUjXBjU5JlqB9x704wvNe/fbZjY0spHk/SPN/Nv3/AFBLAQIAABQAAgAIAEwklVcAAAAAAgAAAAAAAAAGAAAAAAAAAAAAAAAAAAAAAABkdW1teS9QSwECAAAUAAIACABMJJVXDAaS4jEEAAAZDQAAGwAAAAAAAAABAAAAAAAmAAAAUi0xMjM0NTY3ODkxMi0wMS1GMDAxLTEueG1sUEsFBgAAAAACAAIAfQAAAJAEAAAAAA==";

        let result = extract_cdr_from_base64_zip(cdr).expect("Could not extract cdr file");
        assert!(!result.is_empty());
    }
}