cwa: implement time_now spec (#15)

* internal/abi/cwa: support the time_now call

* cwa: use time_now call, test it

Author: Xe

cwa/libcwa/Cargo.lock

@@ -9,3 +9,4 @@ repository = "https://github.com/Xe/olin"
 homepage = "https://github.com/Xe/olin"
 
 [dependencies]
+chrono = "0.4"

cwa/libcwa/Cargo.toml

@@ -24,6 +24,8 @@ pub mod sys {
         pub fn resource_write(id: i32, data_ptr: *const u8, data_len: usize) -> i32;
         pub fn resource_close(id: i32);
         pub fn resource_flush(id: i32) -> i32;
+
+        pub fn time_now() -> i64;
     }
 }
 
@@ -267,3 +269,17 @@ impl Write for Resource {
                    .unwrap_err());
     }
 }
+
+pub mod time {
+    extern crate chrono;
+
+    use time::chrono::TimeZone;
+
+    pub fn now() -> chrono::DateTime<chrono::Utc> {
+        return chrono::Utc.timestamp(ts(), 0);
+    }
+
+    pub fn ts() -> i64 {
+        unsafe { ::sys::time_now() }
+    }
+}

cwa/libcwa/src/lib.rs

@@ -6,3 +6,4 @@ authors = ["Christine Dodrill <[email protected]>"]
 [dependencies]
 libcwa = { path = "../libcwa" }
 httparse = "1.3.2"
+chrono = "0.4"

cwa/tests/Cargo.lock

@@ -8,6 +8,7 @@ extern crate libcwa;
 use libcwa::*;
 
 mod http;
+mod time;
 
 #[no_mangle]
 pub extern "C" fn cwa_main() -> i32 {
@@ -29,6 +30,17 @@ pub extern "C" fn cwa_main() -> i32 {
         Err(e) => result = e as i32,
     }
 
+    if result != 0 {
+        return result;
+    }
+
+    log::info("time test");
+    let result: i32;
+    match time::test() {
+        Ok(()) => result = 0,
+        Err(e) => result = e as i32,
+    }
+
     result
 }
 

cwa/tests/Cargo.toml

@@ -0,0 +1,19 @@
+extern crate chrono;
+extern crate libcwa;
+
+use time::chrono::TimeZone;
+use std::io;
+use libcwa::*;
+
+pub fn test() -> Result<(), i32> {
+    let now: i64 = time::ts();
+    let dt = chrono::Utc.timestamp(now, 0);
+
+    log::info(&format!("ts: {}, dt: {}", now, dt.to_rfc3339()));
+
+    let now = time::now();
+    log::info(&format!("time::now(): {}", now.to_rfc3339()));
+
+    log::info("time test passed");
+    Ok(())
+}

cwa/tests/src/main.rs

@@ -222,6 +222,12 @@ func (p *Process) ResolveFunc(module, field string) exec.FunctionImport {
 
 				return 0
 			}
+		case "time_now":
+			return func(vm *exec.VirtualMachine) int64 {
+				p.SetVM(vm)
+
+				return p.timeNow()
+			}
 		default:
 			log.Panicf("unknown import %s::%s", module, field)
 		}

cwa/tests/src/time.rs

@@ -0,0 +1,7 @@
+package cwa
+
+import "time"
+
+func (p *Process) timeNow() int64 {
+	return time.Now().UTC().Unix()
+}