use std::fmt;
use std::time::{Duration, SystemTime, UNIX_EPOCH};
use chrono::naive::{NaiveDate, NaiveDateTime, NaiveTime};
use chrono::{Datelike, Timelike};
use crate::function::OptionalArg;
use crate::obj::objstr::PyStringRef;
use crate::obj::objtuple::PyTupleRef;
use crate::obj::objtype::PyClassRef;
use crate::pyobject::{Either, PyClassImpl, PyObjectRef, PyResult, TryFromObject};
use crate::vm::VirtualMachine;
#[cfg(unix)]
fn time_sleep(dur: Duration, vm: &VirtualMachine) -> PyResult<()> {
let mut ts = libc::timespec {
tv_sec: std::cmp::min(libc::time_t::max_value() as u64, dur.as_secs()) as libc::time_t,
tv_nsec: dur.subsec_nanos().into(),
};
let res = unsafe { libc::nanosleep(&ts, &mut ts) };
let interrupted = res == -1 && nix::errno::errno() == libc::EINTR;
if interrupted {
vm.check_signals()?;
}
Ok(())
}
#[cfg(not(unix))]
fn time_sleep(dur: Duration) {
std::thread::sleep(dur);
}
#[cfg(any(not(target_arch = "wasm32"), target_os = "wasi"))]
pub fn get_time() -> f64 {
match SystemTime::now().duration_since(UNIX_EPOCH) {
Ok(v) => v.as_secs_f64(),
Err(err) => panic!("Time error: {:?}", err),
}
}
#[cfg(all(target_arch = "wasm32", not(target_os = "wasi")))]
pub fn get_time() -> f64 {
use wasm_bindgen::prelude::*;
#[wasm_bindgen]
extern "C" {
type Date;
#[wasm_bindgen(static_method_of = Date)]
fn now() -> f64;
}
Date::now() / 1000.0
}
fn time_time(_vm: &VirtualMachine) -> f64 {
get_time()
}
fn time_monotonic(_vm: &VirtualMachine) -> f64 {
match SystemTime::now().duration_since(UNIX_EPOCH) {
Ok(v) => v.as_secs_f64(),
Err(err) => panic!("Time error: {:?}", err),
}
}
fn pyobj_to_naive_date_time(value: Either<f64, i64>) -> NaiveDateTime {
match value {
Either::A(float) => {
let secs = float.trunc() as i64;
let nsecs = (float.fract() * 1e9) as u32;
NaiveDateTime::from_timestamp(secs, nsecs)
}
Either::B(int) => NaiveDateTime::from_timestamp(int, 0),
}
}
fn time_gmtime(secs: OptionalArg<Either<f64, i64>>, vm: &VirtualMachine) -> PyObjectRef {
let default = chrono::offset::Utc::now().naive_utc();
let instant = match secs {
OptionalArg::Present(secs) => pyobj_to_naive_date_time(secs),
OptionalArg::Missing => default,
};
PyStructTime::new(vm, instant, 0).into_obj(vm)
}
fn time_localtime(secs: OptionalArg<Either<f64, i64>>, vm: &VirtualMachine) -> PyObjectRef {
let instant = optional_or_localtime(secs);
PyStructTime::new(vm, instant, -1).into_obj(vm)
}
fn time_mktime(t: PyStructTime, vm: &VirtualMachine) -> PyResult {
let datetime = t.to_date_time(vm)?;
let seconds_since_epoch = datetime.timestamp() as f64;
Ok(vm.ctx.new_float(seconds_since_epoch))
}
fn optional_or_localtime(secs: OptionalArg<Either<f64, i64>>) -> NaiveDateTime {
let default = chrono::offset::Local::now().naive_local();
match secs {
OptionalArg::Present(secs) => pyobj_to_naive_date_time(secs),
OptionalArg::Missing => default,
}
}
const CFMT: &str = "%a %b %e %H:%M:%S %Y";
fn time_asctime(t: OptionalArg<PyStructTime>, vm: &VirtualMachine) -> PyResult {
let default = chrono::offset::Local::now().naive_local();
let instant = match t {
OptionalArg::Present(t) => t.to_date_time(vm)?,
OptionalArg::Missing => default,
};
let formatted_time = instant.format(&CFMT).to_string();
Ok(vm.ctx.new_str(formatted_time))
}
fn time_ctime(secs: OptionalArg<Either<f64, i64>>) -> String {
let instant = optional_or_localtime(secs);
instant.format(&CFMT).to_string()
}
fn time_strftime(
format: PyStringRef,
t: OptionalArg<PyStructTime>,
vm: &VirtualMachine,
) -> PyResult {
let default = chrono::offset::Local::now().naive_local();
let instant = match t {
OptionalArg::Present(t) => t.to_date_time(vm)?,
OptionalArg::Missing => default,
};
let formatted_time = instant.format(format.as_str()).to_string();
Ok(vm.ctx.new_str(formatted_time))
}
fn time_strptime(
string: PyStringRef,
format: OptionalArg<PyStringRef>,
vm: &VirtualMachine,
) -> PyResult {
let format = match format {
OptionalArg::Present(ref format) => format.as_str(),
OptionalArg::Missing => "%a %b %H:%M:%S %Y",
};
let instant = NaiveDateTime::parse_from_str(string.as_str(), format)
.map_err(|e| vm.new_value_error(format!("Parse error: {:?}", e)))?;
Ok(PyStructTime::new(vm, instant, -1).into_obj(vm))
}
#[pystruct_sequence(name = "time.struct_time")]
#[allow(dead_code)]
struct PyStructTime {
tm_year: PyObjectRef,
tm_mon: PyObjectRef,
tm_mday: PyObjectRef,
tm_hour: PyObjectRef,
tm_min: PyObjectRef,
tm_sec: PyObjectRef,
tm_wday: PyObjectRef,
tm_yday: PyObjectRef,
tm_isdst: PyObjectRef,
}
impl fmt::Debug for PyStructTime {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "struct_time()")
}
}
impl PyStructTime {
fn new(vm: &VirtualMachine, tm: NaiveDateTime, isdst: i32) -> Self {
PyStructTime {
tm_year: vm.ctx.new_int(tm.year()),
tm_mon: vm.ctx.new_int(tm.month()),
tm_mday: vm.ctx.new_int(tm.day()),
tm_hour: vm.ctx.new_int(tm.hour()),
tm_min: vm.ctx.new_int(tm.minute()),
tm_sec: vm.ctx.new_int(tm.second()),
tm_wday: vm.ctx.new_int(tm.weekday().num_days_from_monday()),
tm_yday: vm.ctx.new_int(tm.ordinal()),
tm_isdst: vm.ctx.new_int(isdst),
}
}
fn to_date_time(&self, vm: &VirtualMachine) -> PyResult<NaiveDateTime> {
let invalid = || vm.new_value_error("invalid struct_time parameter".to_owned());
macro_rules! field {
($field:ident) => {
TryFromObject::try_from_object(vm, self.$field.clone())?
};
}
let dt = NaiveDateTime::new(
NaiveDate::from_ymd_opt(field!(tm_year), field!(tm_mon), field!(tm_mday))
.ok_or_else(invalid)?,
NaiveTime::from_hms_opt(field!(tm_hour), field!(tm_min), field!(tm_sec))
.ok_or_else(invalid)?,
);
Ok(dt)
}
fn into_obj(self, vm: &VirtualMachine) -> PyObjectRef {
self.into_struct_sequence(vm, vm.class("time", "struct_time"))
.unwrap()
.into_object()
}
fn tp_new(cls: PyClassRef, seq: PyObjectRef, vm: &VirtualMachine) -> PyResult<PyTupleRef> {
Self::try_from_object(vm, seq)?.into_struct_sequence(vm, cls)
}
}
impl TryFromObject for PyStructTime {
fn try_from_object(vm: &VirtualMachine, seq: PyObjectRef) -> PyResult<Self> {
let seq = vm.extract_elements::<PyObjectRef>(&seq)?;
if seq.len() != 9 {
return Err(
vm.new_type_error("time.struct_time() takes a sequence of length 9".to_owned())
);
}
let mut i = seq.into_iter();
Ok(PyStructTime {
tm_year: i.next().unwrap(),
tm_mon: i.next().unwrap(),
tm_mday: i.next().unwrap(),
tm_hour: i.next().unwrap(),
tm_min: i.next().unwrap(),
tm_sec: i.next().unwrap(),
tm_wday: i.next().unwrap(),
tm_yday: i.next().unwrap(),
tm_isdst: i.next().unwrap(),
})
}
}
pub fn make_module(vm: &VirtualMachine) -> PyObjectRef {
let ctx = &vm.ctx;
let struct_time_type = PyStructTime::make_class(ctx);
extend_class!(ctx, struct_time_type, {
(slot new) => PyStructTime::tp_new,
});
py_module!(vm, "time", {
"asctime" => ctx.new_function(time_asctime),
"ctime" => ctx.new_function(time_ctime),
"gmtime" => ctx.new_function(time_gmtime),
"mktime" => ctx.new_function(time_mktime),
"localtime" => ctx.new_function(time_localtime),
"monotonic" => ctx.new_function(time_monotonic),
"strftime" => ctx.new_function(time_strftime),
"strptime" => ctx.new_function(time_strptime),
"sleep" => ctx.new_function(time_sleep),
"struct_time" => struct_time_type,
"time" => ctx.new_function(time_time),
"perf_counter" => ctx.new_function(time_time),
})
}