lix 0.15.1

Embeddable version control for apps and AI agents.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

//! Typed cell extraction from DataFusion record batches, shared by all table
//! specs. `ctx` is the error-message prefix (e.g. "INSERT lix_branch") so each
//! surface keeps its exact wording; messages
//! are only formatted on the error path.

use datafusion::arrow::record_batch::RecordBatch;
use datafusion::common::{DataFusionError, Result, ScalarValue};

pub(super) fn required_string_value(
    batch: &RecordBatch,
    row_index: usize,
    column_name: &str,
    ctx: &str,
) -> Result<String> {
    optional_string_value(batch, row_index, column_name, ctx)?.ok_or_else(|| {
        DataFusionError::Execution(format!(
            "{ctx} requires non-null text column '{column_name}'"
        ))
    })
}

pub(super) fn optional_string_value(
    batch: &RecordBatch,
    row_index: usize,
    column_name: &str,
    ctx: &str,
) -> Result<Option<String>> {
    match optional_scalar_value(batch, row_index, column_name)? {
        None
        | Some(
            ScalarValue::Null
            | ScalarValue::Utf8(None)
            | ScalarValue::Utf8View(None)
            | ScalarValue::LargeUtf8(None),
        ) => Ok(None),
        Some(
            ScalarValue::Utf8(Some(value))
            | ScalarValue::Utf8View(Some(value))
            | ScalarValue::LargeUtf8(Some(value)),
        ) => Ok(Some(value)),
        Some(other) => Err(DataFusionError::Execution(format!(
            "{ctx} expected text-compatible column '{column_name}', got {other:?}"
        ))),
    }
}

pub(super) fn required_bool_value(
    batch: &RecordBatch,
    row_index: usize,
    column_name: &str,
    ctx: &str,
) -> Result<bool> {
    optional_bool_value(batch, row_index, column_name, ctx)?.ok_or_else(|| {
        DataFusionError::Execution(format!(
            "{ctx} requires non-null boolean column '{column_name}'"
        ))
    })
}

pub(super) fn optional_bool_value(
    batch: &RecordBatch,
    row_index: usize,
    column_name: &str,
    ctx: &str,
) -> Result<Option<bool>> {
    match optional_scalar_value(batch, row_index, column_name)? {
        None | Some(ScalarValue::Null | ScalarValue::Boolean(None)) => Ok(None),
        Some(ScalarValue::Boolean(Some(value))) => Ok(Some(value)),
        Some(other) => Err(DataFusionError::Execution(format!(
            "{ctx} expected boolean column '{column_name}', got {other:?}"
        ))),
    }
}

pub(super) fn optional_scalar_value(
    batch: &RecordBatch,
    row_index: usize,
    column_name: &str,
) -> Result<Option<ScalarValue>> {
    let Ok(column_index) = batch.schema().index_of(column_name) else {
        return Ok(None);
    };
    Ok(Some(ScalarValue::try_from_array(
        batch.column(column_index).as_ref(),
        row_index,
    )?))
}

/// Extract a string literal from a logical expression, shared by the specs
/// that parse pushed-down filters.
pub(super) fn string_expr_literal(expr: &datafusion::logical_expr::Expr) -> Option<String> {
    let datafusion::logical_expr::Expr::Literal(literal, _) = expr else {
        return None;
    };
    match literal {
        ScalarValue::Utf8(Some(value))
        | ScalarValue::Utf8View(Some(value))
        | ScalarValue::LargeUtf8(Some(value)) => Some(value.clone()),
        _ => None,
    }
}