feat(ext/ffi): Callbacks

cli/dts/lib.deno.unstable.d.ts

@@ -81,10 +81,7 @@ declare namespace Deno {
    * });
    * ```
    */
-  export function bench(
-    name: string,
-    fn: () => void | Promise<void>,
-  ): void;
+  export function bench(name: string, fn: () => void | Promise<void>): void;
 
   /** Register a bench which will be run when `deno bench` is used on the command
    * line and the containing module looks like a bench module.
@@ -201,9 +198,7 @@ declare namespace Deno {
    * const { columns, rows } = Deno.consoleSize(Deno.stdout.rid);
    * ```
    */
-  export function consoleSize(
-    rid: number,
-  ): {
+  export function consoleSize(rid: number): {
     columns: number;
     rows: number;
   };
@@ -346,9 +341,16 @@ declare namespace Deno {
     | "f64"
     | "pointer";
 
+  type NativeParameterType =
+    | NativeType
+    | {
+      function: Omit<ForeignFunction, "nonblocking">;
+    };
+
   /** A foreign function as defined by its parameter and result types */
   export interface ForeignFunction<
-    Parameters extends readonly NativeType[] = readonly NativeType[],
+    Parameters extends readonly NativeParameterType[] =
+      readonly NativeParameterType[],
     Result extends NativeType = NativeType,
     NonBlocking extends boolean = boolean,
   > {
@@ -395,7 +397,9 @@ declare namespace Deno {
     : unknown;
 
   /** Infers a foreign function parameter list. */
-  type StaticForeignFunctionParameters<T extends readonly NativeType[]> = [
+  type StaticForeignFunctionParameters<
+    T extends readonly NativeParameterType[],
+  > = [
     ...{
       [K in keyof T]: StaticForeignFunctionParameter<T[K]>;
     },
@@ -412,8 +416,10 @@ declare namespace Deno {
       : T extends ForeignStatic ? StaticForeignFunctionResult<T["type"]>
       : never;
 
-  type ConditionalAsync<IsAsync extends boolean | undefined, T> =
-    IsAsync extends true ? Promise<T> : T;
+  type ConditionalAsync<
+    IsAsync extends boolean | undefined,
+    T,
+  > = IsAsync extends true ? Promise<T> : T;
 
   /** Infers a foreign library interface */
   type StaticForeignLibraryInterface<T extends ForeignLibraryInterface> = {
@@ -513,6 +519,31 @@ declare namespace Deno {
     >;
   }
 
+  /**
+   * **UNSTABLE**: Unsafe and new API, beware!
+   *
+   * An unsafe function pointer for passing JavaScript functions
+   * as C function pointers to ffi calls.
+   *
+   * The function pointer remains valid until the `close()` method is called.
+   */
+  export class UnsafeCallback<Fn extends ForeignFunction> {
+    constructor(
+      definition: Fn,
+      callback: (
+        ...args: StaticForeignFunctionParameters<Fn["parameters"]>
+      ) => StaticForeignFunctionResult<Fn["result"]>,
+    );
+
+    pointer: UnsafePointer;
+    definition: Fn;
+    callback: (
+      ...args: StaticForeignFunctionParameters<Fn["parameters"]>
+    ) => StaticForeignFunctionResult<Fn["result"]>;
+
+    close(): void;
+  }
+
   /** A dynamic library resource */
   export interface DynamicLibrary<S extends ForeignLibraryInterface> {
     /** All of the registered library along with functions for calling them */
@@ -848,12 +879,8 @@ declare namespace Deno {
    * ```
    *
    * Requires `allow-net` permission for "tcp" and `allow-read` for "unix". */
-  export function connect(
-    options: ConnectOptions,
-  ): Promise<TcpConn>;
-  export function connect(
-    options: UnixConnectOptions,
-  ): Promise<UnixConn>;
+  export function connect(options: ConnectOptions): Promise<TcpConn>;
+  export function connect(options: UnixConnectOptions): Promise<UnixConn>;
 
   export interface ConnectTlsOptions {
     /** PEM formatted client certificate chain. */

cli/tests/testdata/unstable_ffi_10.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_i16", [0, 0]);
+Deno.core.opSync("op_ffi_read_i16", 0n);

cli/tests/testdata/unstable_ffi_11.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_u32", [0, 0]);
+Deno.core.opSync("op_ffi_read_u32", 0n);

cli/tests/testdata/unstable_ffi_12.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_i32", [0, 0]);
+Deno.core.opSync("op_ffi_read_i32", 0n);

cli/tests/testdata/unstable_ffi_13.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_u64", [0, 0]);
+Deno.core.opSync("op_ffi_read_u64", 0n);

cli/tests/testdata/unstable_ffi_14.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_f32", [0, 0]);
+Deno.core.opSync("op_ffi_read_f32", 0n);

cli/tests/testdata/unstable_ffi_15.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_f64", [0, 0]);
+Deno.core.opSync("op_ffi_read_f64", 0n);

cli/tests/testdata/unstable_ffi_2.js

@@ -1,10 +1,5 @@
-Deno.core.opSync("op_ffi_call_ptr", {
-  pointer: [0, 0],
-  def: {
-    name: null,
-    parameters: [],
-    result: "void",
-  },
+Deno.core.opSync("op_ffi_call_ptr", 0n, {
+  name: null,
   parameters: [],
-  buffers: [],
-});
+  result: "void",
+}, []);

cli/tests/testdata/unstable_ffi_3.js

@@ -1,10 +1,5 @@
-Deno.core.opAsync("op_ffi_call_ptr_nonblocking", {
-  pointer: [0, 0],
-  def: {
-    name: null,
-    parameters: [],
-    result: "void",
-  },
+Deno.core.opAsync("op_ffi_call_ptr_nonblocking", 0n, {
+  name: null,
   parameters: [],
-  buffers: [],
-});
+  result: "void",
+}, []);

cli/tests/testdata/unstable_ffi_5.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_buf_copy_into", [[0, 0], new Uint8Array(0), 0]);
+Deno.core.opSync("op_ffi_buf_copy_into", 0n, new Uint8Array(0), 0);

cli/tests/testdata/unstable_ffi_6.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_cstr_read", [0, 0]);
+Deno.core.opSync("op_ffi_cstr_read", 0n);

cli/tests/testdata/unstable_ffi_7.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_u8", [0, 0]);
+Deno.core.opSync("op_ffi_read_u8", 0n);

cli/tests/testdata/unstable_ffi_8.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_i8", [0, 0]);
+Deno.core.opSync("op_ffi_read_i8", 0n);

cli/tests/testdata/unstable_ffi_9.js

@@ -1 +1 @@
-Deno.core.opSync("op_ffi_read_u16", [0, 0]);
+Deno.core.opSync("op_ffi_read_u16", 0n);