ferrijs-std 0.2.3

use crate::utils::module::{export_default, ModuleInfo};
use rquickjs::{
    module::{Declarations, Exports, ModuleDef},
    Class, Ctx, Result,
};

use self::decoder::StringDecoder;

mod decoder;

pub struct StringDecoderModule;

impl ModuleDef for StringDecoderModule {
    fn declare(declare: &Declarations) -> Result<()> {
        declare.declare(stringify!(StringDecoder))?;
        declare.declare("default")?;

        Ok(())
    }

    fn evaluate<'js>(ctx: &Ctx<'js>, exports: &Exports<'js>) -> Result<()> {
        export_default(ctx, exports, |default| {
            Class::<StringDecoder>::define(default)?;
            Ok(())
        })?;

        Ok(())
    }
}

impl From<StringDecoderModule> for ModuleInfo<StringDecoderModule> {
    fn from(val: StringDecoderModule) -> Self {
        ModuleInfo {
            name: "string_decoder",
            module: val,
        }
    }
}

#[cfg(test)]
mod tests {
    use crate::test::{call_test, test_async_with, ModuleEvaluator};

    use super::*;

    #[tokio::test]
    async fn test_utf_8() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('utf-8');

                            const cent = Buffer.from([0xC2, 0xA2]);

                            return decoder.write(cent);
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "¢");
            })
        })
        .await;
    }

    #[tokio::test]
    async fn test_utf8_byte_by_byte() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('utf8');
                            const data = Buffer.from("☃💩");

                            let res = "";
                            for (let i = 0; i < data.length; i++) {
                                res += decoder.write(data.slice(i, i + 1));
                            }
                            res += decoder.end();

                            return res;
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "☃💩");
            })
        })
        .await;
    }

    #[tokio::test]
    async fn test_base64() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('base64');
                            let res = "";
                            res += decoder.write(Buffer.of(0x61));
                            res += decoder.end();
                            res += decoder.write(Buffer.of());
                            res += decoder.end();
                            return res;
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "YQ==");
            })
        })
        .await;
    }

    #[tokio::test]
    async fn test_utf16le() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('utf16le');
                            let res = "";
                            res += decoder.write(Buffer.of(0x61, 0x00));
                            res += decoder.end();
                            res += decoder.write(Buffer.of());
                            res += decoder.end();
                            return res;
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "a");
            })
        })
        .await;
    }

    #[tokio::test]
    async fn test_utf16le_invalid_high_surrogate() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('utf16le');
                            let res = "";
                            res += decoder.write(Buffer.of(0x3d, 0xd8));
                            res += decoder.write(Buffer.of(0x61, 0x00));
                            res += decoder.end();
                            return res;
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "\u{FFFD}a");
            })
        })
        .await;
    }

    #[tokio::test]
    async fn test_utf16le_byte_by_byte() {
        test_async_with(|ctx| {
            Box::pin(async move {
                crate::buffer::init(&ctx).unwrap();
                ModuleEvaluator::eval_rust::<StringDecoderModule>(ctx.clone(), "string_decoder")
                    .await
                    .unwrap();

                let module = ModuleEvaluator::eval_js(
                    ctx.clone(),
                    "test",
                    r#"
                        import { StringDecoder } from 'string_decoder';

                        export async function test() {
                            const decoder = new StringDecoder('utf16le');

                            let res = "";

                            res += decoder.write(Buffer.of(0x3d, 0xd8, 0x4d));
                            res += decoder.write(Buffer.of(0xdc));
                            res += decoder.end();

                            res += decoder.write(Buffer.of(0x3d, 0xd8));
                            res += decoder.write(Buffer.of(0x4d));
                            res += decoder.write(Buffer.of(0xdc));
                            res += decoder.end();

                            res += decoder.write(Buffer.of(0x3d));
                            res += decoder.write(Buffer.of(0xd8));
                            res += decoder.write(Buffer.of(0x4d));
                            res += decoder.write(Buffer.of(0xdc));
                            res += decoder.end();

                            res += decoder.write(Buffer.of(0x3d));
                            res += decoder.write(Buffer.of(0xd8, 0x4d));
                            res += decoder.write(Buffer.of(0xdc));
                            res += decoder.end();

                            res += decoder.write(Buffer.of(0x3d));
                            res += decoder.write(Buffer.of(0xd8));
                            res += decoder.write(Buffer.of(0x4d, 0xdc));
                            res += decoder.end();

                            res += decoder.write(Buffer.of(0x3d));
                            res += decoder.write(Buffer.of(0xd8, 0x4d, 0Xdc));
                            res += decoder.end();

                            return res;
                        }
                    "#,
                )
                .await
                .unwrap();
                let result = call_test::<String, _>(&ctx, &module, ()).await;
                assert_eq!(result, "👍👍👍👍👍👍");
            })
        })
        .await;
    }
}