qail-core 0.27.9

use super::base::parse_identifier;
use super::expressions::parse_expression;
use crate::ast::*;
use nom::{
    IResult, Parser,
    branch::alt,
    bytes::complete::tag_no_case,
    character::complete::{char, multispace0, multispace1},
    combinator::{map, opt},
    sequence::preceded,
};

/// Parse join clause: [left|right|inner] join table [on col = col]
pub fn parse_join_clause(input: &str) -> IResult<&str, Join> {
    let (input, kind) = alt((
        map(
            (tag_no_case("left"), multispace1, tag_no_case("join")),
            |_| JoinKind::Left,
        ),
        map(
            (tag_no_case("right"), multispace1, tag_no_case("join")),
            |_| JoinKind::Right,
        ),
        map(
            (tag_no_case("inner"), multispace1, tag_no_case("join")),
            |_| JoinKind::Inner,
        ),
        // Default: just "join" = LEFT join
        map(tag_no_case("join"), |_| JoinKind::Left),
    ))
    .parse(input)?;

    let (input, _) = multispace1(input)?;
    let (input, table) = parse_identifier(input)?;
    let (input, _) = multispace0(input)?;

    // Optional ON clause: either ON TRUE or ON condition
    // First check for ON TRUE (unconditional join)
    let (input, on_true_result) =
        opt((tag_no_case("on"), multispace1, tag_no_case("true"))).parse(input)?;

    let (input, on_clause, on_true) = if on_true_result.is_some() {
        (input, None, true)
    } else {
        // Try parsing ON condition
        let (input, cond) = opt(preceded(
            (tag_no_case("on"), multispace1),
            parse_join_condition,
        ))
        .parse(input)?;
        (input, cond, false)
    };

    // Consume trailing whitespace so many0 can find the next JOIN
    let (input, _) = multispace0(input)?;

    Ok((
        input,
        Join {
            table: table.to_string(),
            kind,
            on: on_clause,
            on_true,
        },
    ))
}

/// Parse join condition: table.col = table.col
pub fn parse_join_condition(input: &str) -> IResult<&str, Vec<Condition>> {
    let (input, left_expr) = parse_expression(input)?;
    let (input, _) = multispace0(input)?;
    let (input, _) = char('=').parse(input)?;
    let (input, _) = multispace0(input)?;
    let (input, right_col) = parse_identifier(input)?;

    Ok((
        input,
        vec![Condition {
            left: left_expr, // Use parsed expression
            op: Operator::Eq,
            value: Value::Column(right_col.to_string()),
            is_array_unnest: false,
        }],
    ))
}