reifydb_function/text/
format_bytes_si.rs

1// SPDX-License-Identifier: AGPL-3.0-or-later
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_core::value::column::data::ColumnData;
5use reifydb_type::value::{constraint::bytes::MaxBytes, container::utf8::Utf8Container, r#type::Type};
6
7use super::format_bytes::{format_bytes_internal, process_decimal_column, process_float_column, process_int_column};
8use crate::{ScalarFunction, ScalarFunctionContext, error::ScalarFunctionError, propagate_options};
9
10const SI_UNITS: [&str; 6] = ["B", "KB", "MB", "GB", "TB", "PB"];
11
12/// Formats bytes using SI/decimal units (1000-based: B, KB, MB, GB, TB, PB)
13pub struct FormatBytesSi;
14
15impl FormatBytesSi {
16	pub fn new() -> Self {
17		Self
18	}
19}
20
21impl ScalarFunction for FormatBytesSi {
22	fn scalar(&self, ctx: ScalarFunctionContext) -> crate::error::ScalarFunctionResult<ColumnData> {
23		if let Some(result) = propagate_options(self, &ctx) {
24			return result;
25		}
26
27		let columns = ctx.columns;
28		let row_count = ctx.row_count;
29
30		if columns.len() != 1 {
31			return Err(ScalarFunctionError::ArityMismatch {
32				function: ctx.fragment.clone(),
33				expected: 1,
34				actual: columns.len(),
35			});
36		}
37
38		let column = columns.get(0).unwrap();
39
40		match &column.data() {
41			ColumnData::Int1(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
42			ColumnData::Int2(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
43			ColumnData::Int4(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
44			ColumnData::Int8(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
45			ColumnData::Uint1(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
46			ColumnData::Uint2(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
47			ColumnData::Uint4(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
48			ColumnData::Uint8(container) => process_int_column!(container, row_count, 1000.0, &SI_UNITS),
49			ColumnData::Float4(container) => process_float_column!(container, row_count, 1000.0, &SI_UNITS),
50			ColumnData::Float8(container) => process_float_column!(container, row_count, 1000.0, &SI_UNITS),
51			ColumnData::Decimal {
52				container,
53				..
54			} => {
55				process_decimal_column!(container, row_count, 1000.0, &SI_UNITS)
56			}
57			other => Err(ScalarFunctionError::InvalidArgumentType {
58				function: ctx.fragment.clone(),
59				argument_index: 0,
60				expected: vec![
61					Type::Int1,
62					Type::Int2,
63					Type::Int4,
64					Type::Int8,
65					Type::Uint1,
66					Type::Uint2,
67					Type::Uint4,
68					Type::Uint8,
69					Type::Float4,
70					Type::Float8,
71					Type::Decimal,
72				],
73				actual: other.get_type(),
74			}),
75		}
76	}
77
78	fn return_type(&self, _input_types: &[Type]) -> Type {
79		Type::Utf8
80	}
81}
reifydb_function/text/format_bytes_si.rs

reifydb_function/text/
format_bytes_si.rs
