// Take a look at the license at the top of the repository in the LICENSE file.

use std::iter::Peekable;

use proc_macro::{
    token_stream::IntoIter as ProcIter, Delimiter, Group, Ident, Literal, Punct, Spacing, Span,
    TokenStream, TokenTree,
};

use crate::utils::crate_ident_new;

struct PeekableProcIter {
    inner: Peekable<ProcIter>,
    current_span: Option<Span>,
    next_span: Option<Span>,
}

impl<'a> From<&'a Group> for PeekableProcIter {
    fn from(f: &'a Group) -> Self {
        let current_span = Some(f.span());
        let mut inner = f.stream().into_iter().peekable();
        let next_span = inner.peek().map(|n| n.span());
        Self {
            inner,
            current_span,
            next_span,
        }
    }
}

impl From<TokenStream> for PeekableProcIter {
    fn from(f: TokenStream) -> Self {
        let mut inner = f.into_iter().peekable();
        let next_span = inner.peek().map(|n| n.span());
        Self {
            inner,
            current_span: None,
            next_span,
        }
    }
}

impl Iterator for PeekableProcIter {
    type Item = TokenTree;

    fn next(&mut self) -> Option<Self::Item> {
        let next = self.inner.next()?;
        self.current_span = Some(next.span());
        self.next_span = self.inner.peek().map(|n| n.span());
        Some(next)
    }
}

impl PeekableProcIter {
    fn peek(&mut self) -> Option<&TokenTree> {
        self.inner.peek()
    }

    fn generate_error(&self, message: &str) -> TokenStream {
        self.generate_error_with_span(message, self.current_span)
    }

    fn generate_error_with_next_span(&self, message: &str) -> TokenStream {
        self.generate_error_with_span(message, self.next_span)
    }

    fn generate_error_with_span(&self, message: &str, span: Option<Span>) -> TokenStream {
        let span = span.unwrap_or_else(Span::call_site);
        // We generate a `compile_error` macro and assign it to the current span so the error
        // displayed by rustc points to the right location.
        let mut stream = TokenStream::new();
        stream.extend(vec![TokenTree::Literal(Literal::string(message))]);

        let mut tokens = vec![
            TokenTree::Ident(Ident::new("compile_error", span)),
            TokenTree::Punct(Punct::new('!', Spacing::Alone)),
            TokenTree::Group(Group::new(Delimiter::Parenthesis, stream)),
            TokenTree::Punct(Punct::new(';', Spacing::Alone)),
        ];

        for tok in &mut tokens {
            tok.set_span(span);
        }

        let mut stream = TokenStream::new();
        stream.extend(tokens);
        let mut t = TokenTree::Group(Group::new(Delimiter::Brace, stream));
        t.set_span(span);

        let mut stream = TokenStream::new();
        stream.extend(vec![t]);
        stream
    }
}

#[derive(Clone, Copy, Debug)]
enum BorrowKind {
    Weak,
    WeakAllowNone,
    Strong,
    ToOwned,
}

impl BorrowKind {
    fn to_str(self) -> &'static str {
        match self {
            Self::Weak => "@weak",
            Self::WeakAllowNone => "@weak-allow-none",
            Self::Strong => "@strong",
            Self::ToOwned => "@to-owned",
        }
    }
}

enum WrapperKind {
    DefaultPanic,
    DefaultReturn(String),
}

impl WrapperKind {
    fn to_str(&self) -> String {
        match *self {
            Self::DefaultPanic => "@default-panic".to_owned(),
            Self::DefaultReturn(ref r) => format!("@default-return {r}"),
        }
    }

    fn keyword(&self) -> &'static str {
        match *self {
            Self::DefaultPanic => "default-panic",
            Self::DefaultReturn(_) => "default-return",
        }
    }
}

#[derive(Debug)]
struct ElemToClone {
    name: String,
    alias: Option<String>,
    borrow_kind: BorrowKind,
}

impl ElemToClone {
    fn to_str_before(&self) -> String {
        match self.borrow_kind {
            BorrowKind::Weak | BorrowKind::WeakAllowNone => format!(
                "let {} = {}::clone::Downgrade::downgrade(&{});",
                if let Some(ref a) = self.alias {
                    a
                } else {
                    &self.name
                },
                crate_ident_new(),
                self.name,
            ),
            BorrowKind::Strong => format!(
                "let {} = {}.clone();",
                if let Some(ref a) = self.alias {
                    a
                } else {
                    &self.name
                },
                self.name,
            ),
            BorrowKind::ToOwned => format!(
                "let {} = ::std::borrow::ToOwned::to_owned(&*{});",
                if let Some(ref a) = self.alias {
                    a
                } else {
                    &self.name
                },
                self.name,
            ),
        }
    }

    fn to_str_after(&self, wrapper_kind: &Option<WrapperKind>) -> String {
        let name = if let Some(ref a) = self.alias {
            a
        } else {
            &self.name
        };
        match (self.borrow_kind, wrapper_kind) {
            (BorrowKind::Weak, Some(WrapperKind::DefaultPanic)) => {
                format!(
                    "\
let {0} = match {1}::clone::Upgrade::upgrade(&{0}) {{
    Some(val) => val,
    None => panic!(
        \"failed to upgrade `{0}` (if you don't want to panic, use @default-return)\",
    ),
}};",
                    name,
                    crate_ident_new(),
                )
            }
            (BorrowKind::Weak, Some(WrapperKind::DefaultReturn(ref r))) => {
                let not_unit_ret = r.chars().any(|c| c != '(' && c != ')' && c != ' ');
                format!(
                    "\
let {0} = match {1}::clone::Upgrade::upgrade(&{0}) {{
    Some(val) => val,
    None => {{
        {1}::g_debug!(
            {1}::CLONE_MACRO_LOG_DOMAIN,
            \"Failed to upgrade {0}\",
        );
        let ___return_value = || {{ {2} }};
        return ___return_value();
    }}
}};",
                    name,
                    crate_ident_new(),
                    if not_unit_ret { r } else { "" },
                )
            }
            (BorrowKind::Weak, None) => {
                format!(
                    "\
let {0} = match {1}::clone::Upgrade::upgrade(&{0}) {{
    Some(val) => val,
    None => {{
        {1}::g_debug!(
            {1}::CLONE_MACRO_LOG_DOMAIN,
            \"Failed to upgrade {0}\",
        );
        return;
    }}
}};",
                    name,
                    crate_ident_new(),
                )
            }
            (BorrowKind::WeakAllowNone, _) => format!(
                "let {0} = {1}::clone::Upgrade::upgrade(&{0});",
                name,
                crate_ident_new(),
            ),
            _ => String::new(),
        }
    }
}

enum SimpleToken {
    Punct(&'static str),
    Ident(&'static str),
}

impl SimpleToken {
    fn to_str(&self) -> &str {
        match *self {
            Self::Punct(p) => p,
            Self::Ident(i) => i,
        }
    }
}

impl PartialEq<TokenTree> for SimpleToken {
    fn eq(&self, other: &TokenTree) -> bool {
        match (self, other) {
            (SimpleToken::Punct(p1), TokenTree::Punct(ref p2)) => *p1 == p2.to_string(),
            (SimpleToken::Ident(i1), TokenTree::Ident(ref i2)) => *i1 == i2.to_string(),
            _ => false,
        }
    }
}

fn is_punct(elem: &TokenTree, punct: &str) -> bool {
    match elem {
        TokenTree::Punct(ref p) => p.to_string() == punct,
        _ => false,
    }
}

enum TokenCheck {
    UnexpectedToken(String, String),
    UnexpectedEnd(String),
}

fn check_tokens(
    tokens_to_check: &[SimpleToken],
    parts: &mut PeekableProcIter,
) -> Result<(), TokenCheck> {
    let mut tokens = String::new();

    for token in tokens_to_check {
        if let Some(next) = parts.peek() {
            if token != next {
                return Err(TokenCheck::UnexpectedToken(tokens, next.to_string()));
            }
            tokens.push_str(token.to_str());
            parts.next();
        } else {
            return Err(TokenCheck::UnexpectedEnd(tokens));
        }
    }
    Ok(())
}

#[doc(alias = "get_full_ident")]
fn full_ident(
    parts: &mut PeekableProcIter,
    borrow_kind: BorrowKind,
) -> Result<String, TokenStream> {
    let mut name = String::new();
    let mut prev_is_ident = false;

    loop {
        match parts.peek() {
            Some(TokenTree::Punct(p)) => {
                let p_s = p.to_string();
                if p_s == "," || p_s == "=" {
                    break;
                } else if p_s == "." {
                    if !prev_is_ident {
                        return Err(parts.generate_error_with_next_span(&format!(
                            "Unexpected `.` after `{}`",
                            borrow_kind.to_str()
                        )));
                    }
                    prev_is_ident = false;
                    name.push('.');
                    parts.next();
                } else if name.is_empty() {
                    return Err(parts
                        .generate_error_with_next_span(&format!("Expected ident, found `{p_s}`")));
                } else {
                    return Err(parts.generate_error_with_next_span(&format!(
                        "Expected ident, found `{p_s}` after `{name}`"
                    )));
                }
            }
            Some(TokenTree::Ident(i)) => {
                if prev_is_ident {
                    break;
                }
                prev_is_ident = true;
                name.push_str(&i.to_string());
                parts.next();
            }
            Some(x) if name.is_empty() => {
                let err = format!("Expected ident, found `{x}`");
                return Err(parts.generate_error_with_next_span(&err));
            }
            Some(x) => {
                let err = &format!("Expected ident, found `{x}` after `{name}`");
                return Err(parts.generate_error_with_next_span(err));
            }
            None => {
                return Err(parts.generate_error(&format!("Unexpected end after ident `{name}`")));
            }
        }
    }
    if name.is_empty() {
        if let Some(next) = parts.next() {
            return Err(parts.generate_error(&format!("Expected ident, found `{next}`")));
        }
        return Err(parts.generate_error("Expected something after, found nothing"));
    }
    Ok(name)
}

#[doc(alias = "get_keyword")]
fn keyword(parts: &mut PeekableProcIter) -> Result<BorrowKind, TokenStream> {
    let mut ret = String::new();
    let mut prev_is_ident = false;
    let mut stored = false;
    // We unfortunately can't join spans since the `Span::join` method is nightly-only. Well, we'll
    // do our best...
    let start_span = parts.next_span;

    loop {
        match parts.peek() {
            Some(TokenTree::Ident(i)) => {
                if prev_is_ident {
                    break;
                }
                prev_is_ident = true;
                if stored {
                    ret.push('-');
                    stored = false;
                }
                ret.push_str(&i.to_string());
            }
            Some(TokenTree::Punct(p)) if p.to_string() == "-" => {
                if !prev_is_ident {
                    break;
                }
                // This is to prevent to push `-` if the next item isn't an ident.
                prev_is_ident = false;
                stored = true;
            }
            _ => break,
        }
        parts.next();
    }
    let ret = match ret.as_str() {
        "strong" => BorrowKind::Strong,
        "weak" => BorrowKind::Weak,
        "weak-allow-none" => BorrowKind::WeakAllowNone,
        "to-owned" => BorrowKind::ToOwned,
        "default-return" => {
            return Err(parts
                .generate_error_with_span("`@default-return` should be after `=>`", start_span));
        }
        "default-panic" => {
            return Err(
                parts.generate_error_with_span("`@default-panic` should be after `=>`", start_span)
            );
        }
        k => {
            return Err(parts.generate_error_with_span(
                &format!(
                    "Unknown keyword `{k}`, only `weak`, `weak-allow-none`, `to-owned` and \
                    `strong` are allowed"
                ),
                start_span,
            ));
        }
    };
    Ok(ret)
}

fn parse_ident(
    parts: &mut PeekableProcIter,
    elements: &mut Vec<ElemToClone>,
) -> Result<(), TokenStream> {
    let borrow_kind = keyword(parts)?;
    let name = full_ident(parts, borrow_kind)?;
    let name_span = parts.current_span;
    if name.ends_with('.') {
        return Err(
            parts.generate_error_with_span(&format!("Invalid variable name: `{name}`"), name_span)
        );
    }
    let alias = match parts.peek() {
        Some(TokenTree::Ident(p)) if p.to_string() == "as" => {
            parts.next();
            let current_span = parts.current_span;
            match parts.next() {
                Some(TokenTree::Ident(i)) => Some(i.to_string()),
                Some(x) => {
                    let err = format!("Expected ident after `as` keyword, found `{x}`");
                    return Err(parts.generate_error(&err));
                }
                None => {
                    return Err(parts.generate_error_with_span(
                        "Unexpected end after `as` keyword",
                        current_span,
                    ))
                }
            }
        }
        Some(TokenTree::Ident(p)) => {
            let err = format!("Unexpected `{p}`");
            return Err(parts.generate_error(&err));
        }
        _ => None,
    };
    if name == "self" && alias.is_none() {
        return Err(parts.generate_error_with_span(
            "Can't use `self` as variable name. Try storing it in a temporary variable or \
                rename it using `as`.",
            name_span,
        ));
    } else if name.contains('.') && alias.is_none() {
        let err = format!("`{name}`: Field accesses are not allowed as is, you must rename it!");
        return Err(parts.generate_error_with_span(&err, name_span));
    }

    elements.push(ElemToClone {
        name,
        alias,
        borrow_kind,
    });
    Ok(())
}

fn delimiter_to_string(delimiter: Delimiter, open: bool) -> &'static str {
    match delimiter {
        Delimiter::Parenthesis => {
            if open {
                "("
            } else {
                ")"
            }
        }
        Delimiter::Brace => {
            if open {
                "{"
            } else {
                "}"
            }
        }
        Delimiter::Bracket => {
            if open {
                "["
            } else {
                "]"
            }
        }
        Delimiter::None => "",
    }
}

fn group_to_string(g: &Group) -> String {
    format!(
        "{}{}{}",
        delimiter_to_string(g.delimiter(), true),
        tokens_to_string(PeekableProcIter::from(g)),
        delimiter_to_string(g.delimiter(), false),
    )
}

#[doc(alias = "get_expr")]
fn expr(parts: &mut PeekableProcIter) -> Result<String, TokenStream> {
    let mut ret = String::new();
    let mut total = 0;
    let span = parts.current_span;
    match parts.next() {
        Some(TokenTree::Literal(l)) => ret.push_str(&l.to_string()),
        Some(TokenTree::Ident(i)) => ret.push_str(&i.to_string()),
        Some(TokenTree::Punct(p)) => match p.to_string().as_str() {
            "[" | "{" | "(" => {
                total += 1;
            }
            x => {
                return Err(parts
                    .generate_error(&format!("Unexpected token `{x}` after `@default-return`")))
            }
        },
        Some(TokenTree::Group(g)) => return Ok(group_to_string(&g)),
        None => {
            return Err(
                parts.generate_error_with_span("Unexpected end after `@default-return`", span)
            )
        }
    };
    loop {
        match parts.peek() {
            Some(TokenTree::Punct(p)) => {
                let p_s = p.to_string();
                if p_s == "{" || p_s == "(" || p_s == "[" || p_s == "<" {
                    total += 1;
                } else if p_s == "}" || p_s == ")" || p_s == "]" || p_s == ">" {
                    total -= 1;
                } else if p_s == "," && total == 0 {
                    return Ok(ret);
                }
                ret.push_str(&p_s);
            }
            Some(TokenTree::Group(g)) => {
                ret.push_str(&group_to_string(g));
            }
            Some(x) => {
                if total == 0 && !ret.ends_with(':') {
                    return Ok(ret);
                }
                ret.push_str(&x.to_string())
            }
            None => return Err(parts.generate_error(
                "Unexpected end after `{ret}`. Did you forget a `,` after the @default-return value?",
            )),
        }
        parts.next();
    }
}

#[doc(alias = "get_return_kind")]
fn return_kind(parts: &mut PeekableProcIter) -> Result<WrapperKind, TokenStream> {
    match check_tokens(
        &[SimpleToken::Ident("default"), SimpleToken::Punct("-")],
        parts,
    ) {
        Err(TokenCheck::UnexpectedToken(tokens, unexpected_token)) => {
            return Err(
                parts.generate_error(&format!("Unknown keyword `{tokens}{unexpected_token}`"))
            );
        }
        Err(TokenCheck::UnexpectedEnd(tokens)) => {
            return Err(parts.generate_error(&format!("Unexpected end after tokens `{tokens}`")));
        }
        Ok(()) => {}
    }
    let prev = parts.current_span;
    match parts.next() {
        Some(TokenTree::Ident(i)) => {
            let i_s = i.to_string();
            if i_s == "panic" {
                return Ok(WrapperKind::DefaultPanic);
            }
            assert!(i_s == "return", "Unknown keyword `@default-{i_s}`");
        }
        Some(x) => {
            let err = format!("Unknown token `{x}` after `@default-`");
            return Err(parts.generate_error(&err));
        }
        None => {
            return Err(parts.generate_error_with_span("Unexpected end after `@default-`", prev))
        }
    }
    Ok(WrapperKind::DefaultReturn(expr(parts)?))
}

fn parse_return_kind(parts: &mut PeekableProcIter) -> Result<Option<WrapperKind>, TokenStream> {
    match parts.peek() {
        Some(TokenTree::Punct(p)) if p.to_string() == "@" => {}
        None => return Err(parts.generate_error("Unexpected end 2")),
        _ => return Ok(None),
    }
    parts.next();
    let ret = return_kind(parts)?;
    match check_tokens(&[SimpleToken::Punct(",")], parts) {
        Err(TokenCheck::UnexpectedToken(_, unexpected_token)) => {
            let err = format!(
                "Expected `,` after `{}`, found `{unexpected_token}`",
                ret.to_str(),
            );
            return Err(parts.generate_error_with_next_span(&err));
        }
        Err(TokenCheck::UnexpectedEnd(tokens)) => {
            let err = format!("Expected `,` after `{}{tokens}`", ret.to_str());
            return Err(parts.generate_error(&err));
        }
        Ok(()) => {}
    }
    Ok(Some(ret))
}

enum BlockKind {
    Closure(Vec<TokenTree>),
    ClosureWrappingAsync(Vec<TokenTree>),
    AsyncClosure(Vec<TokenTree>),
    AsyncBlock,
}

impl BlockKind {
    #[doc(alias = "get_closure")]
    fn closure(self) -> Option<Vec<TokenTree>> {
        match self {
            Self::AsyncBlock => None,
            Self::Closure(c) | Self::ClosureWrappingAsync(c) | Self::AsyncClosure(c) => Some(c),
        }
    }
}

fn check_move_after_async(parts: &mut PeekableProcIter) -> Result<(), TokenStream> {
    let span = parts.current_span;
    match parts.next() {
        Some(TokenTree::Ident(i)) if i.to_string() == "move" => Ok(()),
        // The next checks are just for better error messages.
        Some(TokenTree::Ident(i)) => {
            let err = format!("Expected `move` after `async`, found `{i}`");
            Err(parts.generate_error(&err))
        }
        Some(TokenTree::Punct(p)) => {
            let err = format!("Expected `move` after `async`, found `{p}`");
            Err(parts.generate_error(&err))
        }
        Some(TokenTree::Group(g)) => {
            let err = format!(
                "Expected `move` after `async`, found `{}`",
                delimiter_to_string(g.delimiter(), true),
            );
            Err(parts.generate_error(&err))
        }
        _ => Err(parts.generate_error_with_span("Expected `move` after `async`", span)),
    }
}

fn check_async_syntax(parts: &mut PeekableProcIter) -> Result<BlockKind, TokenStream> {
    check_move_after_async(parts)?;
    match parts.peek() {
        Some(TokenTree::Punct(p)) if p.to_string() == "|" => {
            parts.next();
            Ok(BlockKind::AsyncClosure(closure(parts)?))
        }
        Some(TokenTree::Punct(p)) => {
            let err = format!("Expected closure or block after `async move`, found `{p}`");
            Err(parts.generate_error_with_next_span(&err))
        }
        Some(TokenTree::Group(g)) if g.delimiter() == Delimiter::Brace => Ok(BlockKind::AsyncBlock),
        Some(TokenTree::Group(g)) => {
            let err = format!(
                "Expected closure or block after `async move`, found `{}`",
                delimiter_to_string(g.delimiter(), true),
            );
            Err(parts.generate_error_with_next_span(&err))
        }
        _ => Err(parts.generate_error("Expected closure or block after `async move`")),
    }
}

// Returns `true` if this is an async context.
fn check_before_closure(parts: &mut PeekableProcIter) -> Result<BlockKind, TokenStream> {
    let is_async = match parts.peek() {
        Some(TokenTree::Ident(i)) if i.to_string() == "move" => false,
        Some(TokenTree::Ident(i)) if i.to_string() == "async" => true,
        Some(TokenTree::Ident(i)) if i.to_string() == "default" => {
            let span = parts.next_span;
            let ret = return_kind(parts)?;
            let err = format!("Missing `@` before `{}`", ret.keyword());
            return Err(parts.generate_error_with_span(&err, span));
        }
        Some(TokenTree::Punct(p)) if p.to_string() == "|" => {
            return Err(parts.generate_error_with_next_span(
                "Closure needs to be \"moved\" so please add `move` before closure",
            ));
        }
        _ => {
            return Err(
                parts.generate_error_with_next_span("Missing `move` and closure declaration")
            )
        }
    };
    parts.next();
    if is_async {
        return check_async_syntax(parts);
    }
    match parts.peek() {
        Some(TokenTree::Punct(p)) if p.to_string() == "|" => {}
        Some(x) => {
            let err = format!("Expected closure, found `{x}`");
            return Err(parts.generate_error_with_next_span(&err));
        }
        None => return Err(parts.generate_error("Expected closure")),
    }
    parts.next();

    let closure = closure(parts)?;
    match parts.peek() {
        Some(TokenTree::Ident(i)) if i.to_string() == "async" => {
            parts.next();
            check_move_after_async(parts)?;
            match parts.peek() {
                Some(TokenTree::Group(g)) if g.delimiter() == Delimiter::Brace => {
                    Ok(BlockKind::ClosureWrappingAsync(closure))
                }
                // The next matchings are for better error messages.
                Some(TokenTree::Punct(p)) => {
                    let err = format!("Expected block after `| async move`, found `{p}`");
                    Err(parts.generate_error_with_next_span(&err))
                }
                Some(TokenTree::Group(g)) => {
                    let err = format!(
                        "Expected block after `| async move`, found `{}`",
                        delimiter_to_string(g.delimiter(), true),
                    );
                    Err(parts.generate_error_with_next_span(&err))
                }
                _ => {
                    Err(parts.generate_error_with_next_span("Expected block after `| async move`"))
                }
            }
        }
        _ => Ok(BlockKind::Closure(closure)),
    }
}

#[doc(alias = "get_closure")]
fn closure(parts: &mut PeekableProcIter) -> Result<Vec<TokenTree>, TokenStream> {
    let mut ret = Vec::new();

    loop {
        let span = parts.current_span;
        match parts.next() {
            Some(TokenTree::Punct(p)) if p.to_string() == "|" => break,
            Some(x) => ret.push(x),
            None => return Err(parts.generate_error_with_span("Unexpected end 3", span)),
        }
    }
    Ok(ret)
}

fn tokens_to_string(parts: impl Iterator<Item = TokenTree>) -> String {
    let mut ret = String::new();
    // This is used in case of "if ident" or other similar cases.
    let mut prev_is_ident = false;
    let handle_ident_like = |i: String, ret: &mut String, prev_is_ident: &mut bool| {
        if *prev_is_ident {
            ret.push(' ');
        }
        ret.push_str(&i);
        *prev_is_ident = true;
    };

    for token in parts {
        match token {
            TokenTree::Punct(p) => {
                prev_is_ident = false;
                ret.push_str(&p.to_string());
            }
            TokenTree::Ident(i) => handle_ident_like(i.to_string(), &mut ret, &mut prev_is_ident),
            TokenTree::Literal(l) => handle_ident_like(l.to_string(), &mut ret, &mut prev_is_ident),
            TokenTree::Group(g) => {
                prev_is_ident = false;
                ret.push_str(&group_to_string(&g));
            }
        }
    }
    ret
}

fn build_closure(
    parts: PeekableProcIter,
    elements: Vec<ElemToClone>,
    return_kind: Option<WrapperKind>,
    kind: BlockKind,
) -> TokenStream {
    let mut body = TokenStream::new();

    for el in &elements {
        let stream: TokenStream = el
            .to_str_after(&return_kind)
            .parse()
            .expect("failed to convert element after");
        body.extend(stream.into_iter().collect::<Vec<_>>());
    }
    body.extend(parts.collect::<Vec<_>>());

    // To prevent to lose the spans in case some errors occur in the code, we need to keep `body`!
    //
    // If we replaced everything that follows with a `format!`, it'd look like this:
    //
    // format!(
    //     "{{\n{}\nmove |{}| {{\n{}\nlet ____ret = {{ {} }};\n____ret\n}}\n}}",
    //     elements
    //         .iter()
    //         .map(|x| x.to_str_before())
    //         .collect::<Vec<_>>()
    //         .join("\n"),
    //     closure,
    //     elements
    //         .iter()
    //         .map(|x| x.to_str_after(&return_kind))
    //         .collect::<Vec<_>>()
    //         .join("\n"),
    //     body,
    // )
    let mut ret: Vec<TokenTree> = vec![];
    for el in elements {
        let stream: TokenStream = el
            .to_str_before()
            .parse()
            .expect("failed to convert element");
        ret.extend(stream.into_iter().collect::<Vec<_>>());
    }

    // This part is creating the TokenStream using the variables that needs to be cloned (from the
    // @weak and @strong annotations).
    let mut inner: Vec<TokenTree> = Vec::new();

    if matches!(kind, BlockKind::ClosureWrappingAsync(_)) {
        inner.extend(vec![
            TokenTree::Ident(Ident::new("async", Span::call_site())),
            TokenTree::Ident(Ident::new("move", Span::call_site())),
        ]);
    }

    let is_async_closure_kind = matches!(kind, BlockKind::AsyncClosure(_));
    if let Some(closure) = kind.closure() {
        if is_async_closure_kind {
            ret.push(TokenTree::Ident(Ident::new("async", Span::call_site())));
        }
        ret.extend(vec![
            TokenTree::Ident(Ident::new("move", Span::call_site())),
            TokenTree::Punct(Punct::new('|', Spacing::Alone)),
        ]);
        ret.extend(closure);
        ret.extend(vec![TokenTree::Punct(Punct::new('|', Spacing::Alone))]);
    } else {
        ret.extend(vec![
            TokenTree::Ident(Ident::new("async", Span::call_site())),
            TokenTree::Ident(Ident::new("move", Span::call_site())),
        ]);
    }
    // The commented lines that follow *might* be useful, don't know. Just in case, I'm keeping
    // them around. You're welcome future me!
    inner.extend(vec![
        // TokenTree::Ident(Ident::new("let", Span::call_site())),
        // TokenTree::Ident(Ident::new("____ret", Span::call_site())),
        // TokenTree::Punct(Punct::new('=', Spacing::Alone)),
        TokenTree::Group(Group::new(Delimiter::Brace, body)),
        // TokenTree::Punct(Punct::new(';', Spacing::Alone)),
        // TokenTree::Ident(Ident::new("____ret", Span::call_site())),
    ]);
    let mut inners = TokenStream::new();
    inners.extend(inner);
    ret.extend(vec![TokenTree::Group(Group::new(Delimiter::Brace, inners))]);

    let mut rets = TokenStream::new();
    rets.extend(ret);

    TokenTree::Group(Group::new(Delimiter::Brace, rets)).into()
}

pub(crate) fn clone_inner(item: TokenStream) -> TokenStream {
    let mut parts: PeekableProcIter = item.into();
    let mut elements = Vec::new();
    let mut prev_is_ident = false;

    loop {
        let prev = parts.current_span;
        match parts.next() {
            Some(TokenTree::Punct(ref p)) => {
                let p_s = p.to_string();
                if p_s == "=" && parts.peek().map_or_else(|| false, |n| is_punct(n, ">")) {
                    parts.next();
                    break;
                } else if p_s == "@" {
                    if let Err(e) = parse_ident(&mut parts, &mut elements) {
                        return e;
                    }
                    prev_is_ident = true;
                } else if p_s == "," {
                    assert!(prev_is_ident, "Unexpected `,`");
                    prev_is_ident = false;
                } else if p_s == "|" {
                    assert!(
                        !elements.is_empty(),
                        "If you have nothing to clone, no need to use this macro!"
                    );
                    return parts.generate_error("Expected `=>` before closure");
                }
            }
            Some(TokenTree::Ident(i)) => {
                let err = format!(
                    "Unexpected ident `{i}`: you need to specify if this is a weak or a strong \
                     clone.",
                );
                return parts.generate_error(&err);
            }
            Some(t) => {
                let err = format!("Unexpected token `{t}`");
                return parts.generate_error(&err);
            }
            None => return parts.generate_error_with_span("Unexpected end 4", prev),
        }
    }
    assert!(
        !elements.is_empty(),
        "If you have nothing to clone, no need to use this macro!"
    );
    let return_kind = match parse_return_kind(&mut parts) {
        Ok(r) => r,
        Err(e) => return e,
    };
    let kind = match check_before_closure(&mut parts) {
        Ok(r) => r,
        Err(e) => return e,
    };
    build_closure(parts, elements, return_kind, kind)
}