Merge pull request #245 from lightpanda-io/add-cancel-test

cbk: add cancel test

Author: krichprollsch

src/tests/cbk_test.zig

@@ -32,6 +32,12 @@ pub const OtherCbk = struct {
 };
 
 pub const Window = struct {
+
+    // store a map between internal timeouts ids and pointers to uint.
+    // the maximum number of possible timeouts is fixed.
+    timeoutid: u32 = 0,
+    timeoutids: [10]u64 = undefined,
+
     pub fn constructor() Window {
         return Window{};
     }
@@ -45,26 +51,39 @@ pub const Window = struct {
     }
 
     pub fn _cbkAsync(
-        _: Window,
+        self: *Window,
         loop: *jsruntime.Loop,
         callback: Callback,
         milliseconds: u32,
-    ) void {
+    ) u32 {
         const n: u63 = @intCast(milliseconds);
-        // TODO: check this value can be holded in u63
-        _ = loop.timeout(n * std.time.ns_per_ms, callback);
+        const id = loop.timeout(n * std.time.ns_per_ms, callback);
+
+        defer self.timeoutid += 1;
+        self.timeoutids[self.timeoutid] = id;
+
+        return self.timeoutid;
     }
 
     pub fn _cbkAsyncWithJSArg(
-        _: Window,
+        self: *Window,
         loop: *jsruntime.Loop,
         callback: Callback,
         milliseconds: u32,
         _: CallbackArg,
-    ) void {
+    ) u32 {
         const n: u63 = @intCast(milliseconds);
-        // TODO: check this value can be holded in u63
-        _ = loop.timeout(n * std.time.ns_per_ms, callback);
+        const id = loop.timeout(n * std.time.ns_per_ms, callback);
+
+        defer self.timeoutid += 1;
+        self.timeoutids[self.timeoutid] = id;
+
+        return self.timeoutid;
+    }
+
+    pub fn _cancel(self: Window, loop: *jsruntime.Loop, id: u32) void {
+        if (id >= self.timeoutid) return;
+        loop.cancel(self.timeoutids[id], null);
     }
 
     pub fn _cbkAsyncWithNatArg(_: Window, callback: Callback) !void {
@@ -163,7 +182,7 @@ pub fn exec(
             \\};
             \\window.cbkAsync(f, 100); // 0.1 second
             ,
-            .ex = "undefined",
+            .ex = "0",
         },
         // arrow functional
         .{
@@ -174,7 +193,7 @@ pub fn exec(
             \\if (p != 2) {throw Error('cases_cbk_async error: p is not equal to 2');}
             \\}, 100); // 0.1 second
             ,
-            .ex = "undefined",
+            .ex = "1",
         },
     };
     try tests.checkCases(js_env, &cases_cbk_async);
@@ -191,7 +210,7 @@ pub fn exec(
             \\};
             \\window.cbkAsyncWithJSArg(f, 100, 2); // 0.1 second
             ,
-            .ex = "undefined",
+            .ex = "2",
         },
         // arrow functional
         .{
@@ -202,7 +221,7 @@ pub fn exec(
             \\if (j != 3) {throw Error('j is not equal to 3');}
             \\}, 100, 2); // 0.1 second
             ,
-            .ex = "undefined",
+            .ex = "3",
         },
     };
     try tests.checkCases(js_env, &cases_cbk_async_with_js_arg);
@@ -240,4 +259,18 @@ pub fn exec(
         .{ .src = "v", .ex = "1" },
     };
     try tests.checkCases(js_env, &cases_cbk_setter_arg);
+
+    // cancel cbk
+    var cases_cbk_cancel = [_]tests.Case{
+        .{
+            .src =
+            \\let vv = 0;
+            \\const id = window.cbkAsync(() => {vv += 1}, 100);
+            \\window.cancel(id);
+            ,
+            .ex = "undefined",
+        },
+        .{ .src = "vv", .ex = "0" },
+    };
+    try tests.checkCases(js_env, &cases_cbk_cancel);
 }