aipack 0.8.22

Command Agent runner to accelerate production coding with genai.
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
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use crate::Result;
use std::num::NonZeroU8;
use std::time::{Duration, SystemTime, UNIX_EPOCH};
use time::format_description::well_known::Iso8601;
use time::format_description::well_known::iso8601::{Config, EncodedConfig, TimePrecision};
use time::formatting::Formattable;
use time::{OffsetDateTime, UtcOffset};

const RFC3339_SEC_CONFIG: EncodedConfig = Config::DEFAULT
	.set_time_precision(TimePrecision::Second {
		decimal_digits: NonZeroU8::new(0),
	})
	.encode();
const RFC3339_SEC: Iso8601<RFC3339_SEC_CONFIG> = Iso8601;

const RFC3339_MICRO_CONFIG: EncodedConfig = Config::DEFAULT
	.set_time_precision(TimePrecision::Second {
		decimal_digits: NonZeroU8::new(6),
	})
	.encode();
const RFC3339_MICRO: Iso8601<RFC3339_MICRO_CONFIG> = Iso8601;

/// Returns the Unix Time in microseconds.
///
/// Note 1: If there is any error with `duration_since UNIX_EPOCH` (which should almost never happen),
///         it returns the start of the EPOCH.
/// Note 2: The maximum UTC epoch date that can be stored in i64 with microseconds precision
///         would be approximately `292277-01-09 ... UTC`.
///         Thus, for all practical purposes, it is sufficiently distant to be of no concern.
pub fn now_micro() -> i64 {
	let now = SystemTime::now();
	let since_the_epoch = now.duration_since(UNIX_EPOCH).unwrap_or(Duration::new(0, 0));
	since_the_epoch.as_micros().min(i64::MAX as u128) as i64
}

pub fn now_rfc3339_local_micro() -> Result<String> {
	now_fmt_local(&RFC3339_MICRO)
}

pub fn now_rfc3339_utc_micro() -> Result<String> {
	now_fmt_utc(&RFC3339_MICRO)
}

pub fn now_rfc3339_local_sec() -> Result<String> {
	now_fmt_local(&RFC3339_SEC)
}

pub fn now_rfc3339_utc_sec() -> Result<String> {
	now_fmt_utc(&RFC3339_SEC)
}

pub fn today_local() -> Result<String> {
	let now_utc = OffsetDateTime::now_utc();

	let local_offset = UtcOffset::current_local_offset()
		.map_err(|err| format!("Cannot get local offset for {now_utc}\nCause: {err}"))?;
	let now_local = now_utc.to_offset(local_offset);
	let date = now_local.date();

	let res = format!("{:04}-{:02}-{:02}", date.year(), date.month() as u8, date.day());
	Ok(res)
}

pub fn today_utc() -> Result<String> {
	let now_utc = OffsetDateTime::now_utc();
	let date = now_utc.date();
	let res = format!("{:04}-{:02}-{:02}", date.year(), date.month() as u8, date.day());
	Ok(res)
}

fn now_fmt_utc<F: Formattable + ?Sized>(fmt: &F) -> Result<String> {
	let now_utc = OffsetDateTime::now_utc();
	now_utc
		.format(fmt)
		.map_err(|err| format!("Cannot format time {now_utc}\nCause: {err}").into())
}

fn now_fmt_local<F: Formattable + ?Sized>(fmt: &F) -> Result<String> {
	let now_utc = OffsetDateTime::now_utc();

	let local_offset = UtcOffset::current_local_offset()
		.map_err(|err| format!("Cannot get local offset for {now_utc}\nCause: {err}"))?;
	let now_local = now_utc.to_offset(local_offset);

	now_local
		.format(fmt)
		.map_err(|err| format!("Cannot format time {now_local}\nCause: {err}").into())
}

// region:    --- Tick

/// Number of whole ticks since `epoch_micros`.
/// e.g., 1s with 0.2s tick → 5
pub fn tick_count(time_micro: i64, tick_seconds: f64) -> i64 {
	let safe_tick = if tick_seconds <= 0.0 { 0.1 } else { tick_seconds };
	let micros_per_tick = ((safe_tick * 1_000_000.0).round() as i64).max(1);
	(time_micro.max(0)) / micros_per_tick
}

/// Tick phase in a `k`-cycle (0..k-1).
/// e.g., 0.2s tick, k=2 → alternates 0/1 every 200ms
#[allow(unused)]
pub fn tick_phase(time_micro: i64, tick_seconds: f64, k: i64) -> i64 {
	let cycle = if k <= 0 { 1 } else { k };
	tick_count(time_micro, tick_seconds) % cycle
}

/// True if this tick is the first in a `k`-cycle.
/// e.g., 0.2s tick, k=2 → true every 400ms
#[allow(unused)]
pub fn every_kth_tick(time_micro: i64, tick_seconds: f64, k: i64) -> bool {
	tick_phase(time_micro, tick_seconds, k) == 0
}

// endregion: --- Tick