toasty 0.5.0

use toasty_core::stmt;

use super::LowerStatement;

impl LowerStatement<'_, '_> {
    pub(super) fn rewrite_offset_after_as_filter(&self, stmt: &mut stmt::Query) {
        // Only do this for SQL statements
        if !self.capability().sql {
            return;
        }

        let Some(order_by) = &mut stmt.order_by else {
            return;
        };

        let Some(stmt::Limit::Cursor(cursor)) = &mut stmt.limit else {
            return;
        };

        let Some(after) = cursor.after.take() else {
            return;
        };

        let stmt::ExprSet::Select(body) = &mut stmt.body else {
            todo!("stmt={stmt:#?}");
        };

        match after {
            stmt::Expr::Value(stmt::Value::Record(value)) => {
                for (index, value) in value.fields.into_iter().enumerate() {
                    let expr = self.rewrite_offset_after_field_as_filter(
                        &order_by.exprs[index],
                        value,
                        true,
                    );
                    body.filter.add_filter(expr);
                }
            }
            stmt::Expr::Value(value) => {
                let expr =
                    self.rewrite_offset_after_field_as_filter(&order_by.exprs[0], value, true);
                body.filter.add_filter(expr);
            }
            _ => todo!(),
        }
    }

    fn rewrite_offset_after_field_as_filter(
        &self,
        order_by: &stmt::OrderByExpr,
        value: stmt::Value,
        last: bool,
    ) -> stmt::Expr {
        let op = match (order_by.order, last) {
            (Some(stmt::Direction::Desc), true) => stmt::BinaryOp::Lt,
            (Some(stmt::Direction::Desc), false) => stmt::BinaryOp::Le,
            (_, true) => stmt::BinaryOp::Gt,
            (_, false) => stmt::BinaryOp::Ge,
        };

        stmt::Expr::binary_op(order_by.expr.clone(), op, value)
    }
}