Update again

Author: slinkydeveloper

packages/restate-sdk-cloudflare-workers/patches/vm/sdk_shared_core_wasm_bindings.d.ts

@@ -5,6 +5,7 @@
 */
 export function start(): void;
 /**
+* This will set the log level of the overall log subscriber.
 * @param {LogLevel} level
 */
 export function set_log_level(level: LogLevel): void;
@@ -22,6 +23,8 @@ export interface WasmFailure {
     message: string;
 }
 
+export type WasmSendHandle = number;
+
 export interface WasmExponentialRetryConfig {
     initial_interval: number | undefined;
     factor: number;
@@ -35,7 +38,7 @@ export interface WasmAwakeable {
     handle: number;
 }
 
-export type WasmAsyncResultValue = "NotReady" | "Empty" | { Success: Uint8Array } | { Failure: WasmFailure } | { StateKeys: string[] } | { CombinatorResult: WasmAsyncResultHandle[] };
+export type WasmAsyncResultValue = "NotReady" | "Empty" | { Success: Uint8Array } | { Failure: WasmFailure } | { StateKeys: string[] } | { InvocationId: string } | { CombinatorResult: WasmAsyncResultHandle[] };
 
 export type WasmRunEnterResult = { ExecutedWithSuccess: Uint8Array } | { ExecutedWithFailure: WasmFailure } | "NotExecuted";
 
@@ -103,8 +106,10 @@ export class WasmVM {
   free(): void;
 /**
 * @param {(WasmHeader)[]} headers
+* @param {LogLevel} log_level
+* @param {number} logger_id
 */
-  constructor(headers: (WasmHeader)[]);
+  constructor(headers: (WasmHeader)[], log_level: LogLevel, logger_id: number);
 /**
 * @returns {WasmResponseHead}
 */
@@ -172,18 +177,21 @@ export class WasmVM {
 * @param {string} service
 * @param {string} handler
 * @param {Uint8Array} buffer
-* @param {string | undefined} [key]
+* @param {string | undefined} key
+* @param {(WasmHeader)[]} headers
 * @returns {number}
 */
-  sys_call(service: string, handler: string, buffer: Uint8Array, key?: string): number;
+  sys_call(service: string, handler: string, buffer: Uint8Array, key: string | undefined, headers: (WasmHeader)[]): number;
 /**
 * @param {string} service
 * @param {string} handler
 * @param {Uint8Array} buffer
-* @param {string | undefined} [key]
+* @param {string | undefined} key
+* @param {(WasmHeader)[]} headers
 * @param {bigint | undefined} [delay]
+* @returns {WasmSendHandle}
 */
-  sys_send(service: string, handler: string, buffer: Uint8Array, key?: string, delay?: bigint): void;
+  sys_send(service: string, handler: string, buffer: Uint8Array, key: string | undefined, headers: (WasmHeader)[], delay?: bigint): WasmSendHandle;
 /**
 * @returns {WasmAwakeable}
 */

packages/restate-sdk-cloudflare-workers/patches/vm/sdk_shared_core_wasm_bindings_bg.js

@@ -197,7 +197,12 @@ export function start() {
     wasm.start();
 }
 
+function getArrayU8FromWasm0(ptr, len) {
+    ptr = ptr >>> 0;
+    return getUint8ArrayMemory0().subarray(ptr / 1, ptr / 1 + len);
+}
 /**
+* This will set the log level of the overall log subscriber.
 * @param {LogLevel} level
 */
 export function set_log_level(level) {
@@ -568,13 +573,15 @@ export class WasmVM {
     }
     /**
     * @param {(WasmHeader)[]} headers
+    * @param {LogLevel} log_level
+    * @param {number} logger_id
     */
-    constructor(headers) {
+    constructor(headers, log_level, logger_id) {
         try {
             const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
             const ptr0 = passArrayJsValueToWasm0(headers, wasm.__wbindgen_malloc);
             const len0 = WASM_VECTOR_LEN;
-            wasm.wasmvm_new(retptr, ptr0, len0);
+            wasm.wasmvm_new(retptr, ptr0, len0, log_level, logger_id);
             var r0 = getDataViewMemory0().getInt32(retptr + 4 * 0, true);
             var r1 = getDataViewMemory0().getInt32(retptr + 4 * 1, true);
             var r2 = getDataViewMemory0().getInt32(retptr + 4 * 2, true);
@@ -801,10 +808,11 @@ export class WasmVM {
     * @param {string} service
     * @param {string} handler
     * @param {Uint8Array} buffer
-    * @param {string | undefined} [key]
+    * @param {string | undefined} key
+    * @param {(WasmHeader)[]} headers
     * @returns {number}
     */
-    sys_call(service, handler, buffer, key) {
+    sys_call(service, handler, buffer, key, headers) {
         try {
             const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
             const ptr0 = passStringToWasm0(service, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
@@ -813,7 +821,9 @@ export class WasmVM {
             const len1 = WASM_VECTOR_LEN;
             var ptr2 = isLikeNone(key) ? 0 : passStringToWasm0(key, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
             var len2 = WASM_VECTOR_LEN;
-            wasm.wasmvm_sys_call(retptr, this.__wbg_ptr, ptr0, len0, ptr1, len1, addHeapObject(buffer), ptr2, len2);
+            const ptr3 = passArrayJsValueToWasm0(headers, wasm.__wbindgen_malloc);
+            const len3 = WASM_VECTOR_LEN;
+            wasm.wasmvm_sys_call(retptr, this.__wbg_ptr, ptr0, len0, ptr1, len1, addHeapObject(buffer), ptr2, len2, ptr3, len3);
             var r0 = getDataViewMemory0().getInt32(retptr + 4 * 0, true);
             var r1 = getDataViewMemory0().getInt32(retptr + 4 * 1, true);
             var r2 = getDataViewMemory0().getInt32(retptr + 4 * 2, true);
@@ -829,10 +839,12 @@ export class WasmVM {
     * @param {string} service
     * @param {string} handler
     * @param {Uint8Array} buffer
-    * @param {string | undefined} [key]
+    * @param {string | undefined} key
+    * @param {(WasmHeader)[]} headers
     * @param {bigint | undefined} [delay]
+    * @returns {WasmSendHandle}
     */
-    sys_send(service, handler, buffer, key, delay) {
+    sys_send(service, handler, buffer, key, headers, delay) {
         try {
             const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
             const ptr0 = passStringToWasm0(service, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
@@ -841,12 +853,16 @@ export class WasmVM {
             const len1 = WASM_VECTOR_LEN;
             var ptr2 = isLikeNone(key) ? 0 : passStringToWasm0(key, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
             var len2 = WASM_VECTOR_LEN;
-            wasm.wasmvm_sys_send(retptr, this.__wbg_ptr, ptr0, len0, ptr1, len1, addHeapObject(buffer), ptr2, len2, !isLikeNone(delay), isLikeNone(delay) ? BigInt(0) : delay);
+            const ptr3 = passArrayJsValueToWasm0(headers, wasm.__wbindgen_malloc);
+            const len3 = WASM_VECTOR_LEN;
+            wasm.wasmvm_sys_send(retptr, this.__wbg_ptr, ptr0, len0, ptr1, len1, addHeapObject(buffer), ptr2, len2, ptr3, len3, !isLikeNone(delay), isLikeNone(delay) ? BigInt(0) : delay);
             var r0 = getDataViewMemory0().getInt32(retptr + 4 * 0, true);
             var r1 = getDataViewMemory0().getInt32(retptr + 4 * 1, true);
-            if (r1) {
-                throw takeObject(r0);
+            var r2 = getDataViewMemory0().getInt32(retptr + 4 * 2, true);
+            if (r2) {
+                throw takeObject(r1);
             }
+            return takeObject(r0);
         } finally {
             wasm.__wbindgen_add_to_stack_pointer(16);
         }
@@ -1229,8 +1245,8 @@ export class WasmVM {
     }
 }
 
-export function __wbg_vmlog_13455a06b760bbc0(arg0, arg1, arg2) {
-    vm_log(arg0, getStringFromWasm0(arg1, arg2));
+export function __wbg_vmlog_13455a06b760bbc0(arg0, arg1, arg2, arg3, arg4) {
+    vm_log(arg0, getArrayU8FromWasm0(arg1, arg2), arg3 === 0 ? undefined : arg4 >>> 0);
 };
 
 export function __wbindgen_object_drop_ref(arg0) {

packages/restate-sdk-cloudflare-workers/patches/vm/sdk_shared_core_wasm_bindings_bg.wasm

@@ -14,7 +14,7 @@ export function __wbg_wasminput_free(a: number, b: number): void;
 export function __wbg_get_wasminput_headers(a: number, b: number): void;
 export function __wbg_get_wasminput_input(a: number): number;
 export function __wbg_wasmvm_free(a: number, b: number): void;
-export function wasmvm_new(a: number, b: number, c: number): void;
+export function wasmvm_new(a: number, b: number, c: number, d: number, e: number): void;
 export function wasmvm_get_response_head(a: number): number;
 export function wasmvm_notify_input(a: number, b: number, c: number): void;
 export function wasmvm_notify_input_closed(a: number): void;
@@ -30,8 +30,8 @@ export function wasmvm_sys_set_state(a: number, b: number, c: number, d: number,
 export function wasmvm_sys_clear_state(a: number, b: number, c: number, d: number): void;
 export function wasmvm_sys_clear_all_state(a: number, b: number): void;
 export function wasmvm_sys_sleep(a: number, b: number, c: number): void;
-export function wasmvm_sys_call(a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number): void;
-export function wasmvm_sys_send(a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number, j: number, k: number): void;
+export function wasmvm_sys_call(a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number, j: number, k: number): void;
+export function wasmvm_sys_send(a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number, j: number, k: number, l: number, m: number): void;
 export function wasmvm_sys_awakeable(a: number, b: number): void;
 export function wasmvm_sys_complete_awakeable_success(a: number, b: number, c: number, d: number, e: number): void;
 export function wasmvm_sys_complete_awakeable_failure(a: number, b: number, c: number, d: number, e: number): void;

packages/restate-sdk-cloudflare-workers/patches/vm/sdk_shared_core_wasm_bindings_bg.wasm.d.ts

@@ -5,6 +5,7 @@
  */
 export function start(): void;
 /**
+ * This will set the log level of the overall log subscriber.
  * @param {LogLevel} level
  */
 export function set_log_level(level: LogLevel): void;
@@ -115,8 +116,10 @@ export class WasmVM {
   free(): void;
   /**
    * @param {(WasmHeader)[]} headers
+   * @param {LogLevel} log_level
+   * @param {number} logger_id
    */
-  constructor(headers: WasmHeader[]);
+  constructor(headers: WasmHeader[], log_level: LogLevel, logger_id: number);
   /**
    * @returns {WasmResponseHead}
    */

packages/restate-sdk/src/endpoint/handlers/vm/sdk_shared_core_wasm_bindings.d.ts

@@ -12,7 +12,7 @@ default = ["console_error_panic_hook"]
 
 [dependencies]
 wasm-bindgen = "0.2.84"
-restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "3c342c43e91514aaa20c7ee42295162842b223ab", features = ["request_identity"] }
+restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "0a45d53317a6e28e4c081802dff3bc2dfa111e03", features = ["request_identity"] }
 console_error_panic_hook = { version = "0.1.7", optional = true }
 serde = { version = "1.0.210", features = ["derive"] }
 serde-wasm-bindgen = "0.6.5"

packages/restate-sdk/src/endpoint/handlers/vm/sdk_shared_core_wasm_bindings.js

@@ -434,9 +434,6 @@ impl WasmVM {
                 Some(Value::CombinatorResult(handles)) => WasmAsyncResultValue::CombinatorResult(
                     handles.into_iter().map(Into::into).collect(),
                 ),
-                _ => {
-                    panic!("Unsupported yet")
-                }
             },
         )
     }
@@ -507,8 +504,9 @@ impl WasmVM {
                 service,
                 handler,
                 key,
-            idempotency_key: None,
-                    headers: headers.into_iter().map(Header::from).collect(),},
+                idempotency_key: None,
+                headers: headers.into_iter().map(Header::from).collect(),
+            },
             buffer.to_vec().into()
         ))
         .map(Into::into)
@@ -526,18 +524,19 @@ impl WasmVM {
         delay: Option<u64>,
     ) -> Result<WasmSendHandle, WasmFailure> {
         use_log_dispatcher!(self, |vm| CoreVM::sys_send(
-                Target {
-                    service,
-                    handler,
-                    key,
-                    idempotency_key: None,
-                    headers: headers.into_iter().map(Header::from).collect(),
-                },
-                buffer.to_vec().into(),
-                delay.map(|delay| duration_since_unix_epoch() + Duration::from_millis(delay)),
-            ))
-            .map(Into::into)
-            .map_err(Into::into)
+            vm,
+            Target {
+                service,
+                handler,
+                key,
+                idempotency_key: None,
+                headers: headers.into_iter().map(Header::from).collect(),
+            },
+            buffer.to_vec().into(),
+            delay.map(|delay| now_since_unix_epoch() + Duration::from_millis(delay)),
+        ))
+        .map(Into::into)
+        .map_err(Into::into)
     }
 
     pub fn sys_awakeable(&mut self) -> Result<WasmAwakeable, WasmFailure> {