reifydb_function/time/
subtract.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::{container::temporal::TemporalContainer, time::Time, r#type::Type};
6
7use crate::{ScalarFunction, ScalarFunctionContext, error::ScalarFunctionError, propagate_options};
8
9pub struct TimeSubtract;
10
11impl TimeSubtract {
12	pub fn new() -> Self {
13		Self
14	}
15}
16
17const NANOS_PER_DAY: i64 = 86_400_000_000_000;
18
19impl ScalarFunction for TimeSubtract {
20	fn scalar(&self, ctx: ScalarFunctionContext) -> crate::error::ScalarFunctionResult<ColumnData> {
21		if let Some(result) = propagate_options(self, &ctx) {
22			return result;
23		}
24		let columns = ctx.columns;
25		let row_count = ctx.row_count;
26
27		if columns.len() != 2 {
28			return Err(ScalarFunctionError::ArityMismatch {
29				function: ctx.fragment.clone(),
30				expected: 2,
31				actual: columns.len(),
32			});
33		}
34
35		let time_col = columns.get(0).unwrap();
36		let dur_col = columns.get(1).unwrap();
37
38		match (time_col.data(), dur_col.data()) {
39			(ColumnData::Time(time_container), ColumnData::Duration(dur_container)) => {
40				let mut container = TemporalContainer::with_capacity(row_count);
41
42				for i in 0..row_count {
43					match (time_container.get(i), dur_container.get(i)) {
44						(Some(time), Some(dur)) => {
45							let time_nanos = time.to_nanos_since_midnight() as i64;
46							let dur_nanos =
47								dur.get_nanos() + dur.get_days() as i64 * NANOS_PER_DAY;
48
49							let result_nanos =
50								(time_nanos - dur_nanos).rem_euclid(NANOS_PER_DAY);
51							match Time::from_nanos_since_midnight(result_nanos as u64) {
52								Some(result) => container.push(result),
53								None => container.push_default(),
54							}
55						}
56						_ => container.push_default(),
57					}
58				}
59
60				Ok(ColumnData::Time(container))
61			}
62			(ColumnData::Time(_), other) => Err(ScalarFunctionError::InvalidArgumentType {
63				function: ctx.fragment.clone(),
64				argument_index: 1,
65				expected: vec![Type::Duration],
66				actual: other.get_type(),
67			}),
68			(other, _) => Err(ScalarFunctionError::InvalidArgumentType {
69				function: ctx.fragment.clone(),
70				argument_index: 0,
71				expected: vec![Type::Time],
72				actual: other.get_type(),
73			}),
74		}
75	}
76
77	fn return_type(&self, _input_types: &[Type]) -> Type {
78		Type::Time
79	}
80}
reifydb_function/time/subtract.rs

reifydb_function/time/
subtract.rs
