feat: add sleep support

Author: miro-cl

packages/cre-sdk-javy-plugin/dist/javy-chainlink-sdk.plugin.wasm

@@ -13,6 +13,8 @@ use rand_chacha::ChaCha8Rng;
 use std::collections::HashMap;
 use std::env;
 use std::sync::{Mutex, OnceLock};
+use std::thread;
+use std::time::Duration;
 
 static CURRENT_MODE: Mutex<i32> = Mutex::new(0);
 static RANDOM_GENERATORS: OnceLock<Mutex<HashMap<i32, ChaCha8Rng>>> = OnceLock::new();
@@ -322,6 +324,15 @@ pub fn modify_runtime(runtime: Runtime) -> Runtime {
                 Ok(milliseconds as f64)
             }),
         );
+
+        extend_wasm_exports(
+            &ctx,
+            "sleep",
+            Func::from(|_ctx: Ctx<'_>, ms: u64| -> Result<(), Error> {
+                thread::sleep(Duration::from_millis(ms));
+                Ok(())
+            }),
+        );
     });
 
     runtime

packages/cre-sdk-javy-plugin/src/javy_chainlink_sdk/src/lib.rs

@@ -73,6 +73,9 @@ function createRuntimeHelpersMock(overrides: Partial<RuntimeHelpers> = {}): Runt
 		now: mock(() => {
 			throw new Error('Method not implemented: now')
 		}),
+		sleep: mock(() => {
+			throw new Error('Method not implemented: sleep')
+		}),
 		log: mock(() => {}),
 	}
 
@@ -357,6 +360,31 @@ describe('test now converts to date', () => {
 	})
 })
 
+describe('test sleep delegates to helpers', () => {
+	test('sleep calls helpers.sleep with the provided milliseconds', () => {
+		const sleepMock = mock(() => {})
+		const helpers = createRuntimeHelpersMock({
+			sleep: sleepMock,
+		})
+
+		const runtime = new RuntimeImpl<unknown>({}, 1, helpers, anyMaxSize)
+		runtime.sleep(500)
+		expect(sleepMock).toHaveBeenCalledTimes(1)
+		expect(sleepMock).toHaveBeenCalledWith(500)
+	})
+
+	test('sleep passes zero milliseconds to helpers.sleep', () => {
+		const sleepMock = mock(() => {})
+		const helpers = createRuntimeHelpersMock({
+			sleep: sleepMock,
+		})
+
+		const runtime = new RuntimeImpl<unknown>({}, 1, helpers, anyMaxSize)
+		runtime.sleep(0)
+		expect(sleepMock).toHaveBeenCalledWith(0)
+	})
+})
+
 describe('test getSecret', () => {
 	test('successfully gets secret with SecretRequest (proto message)', () => {
 		const secretRequest = create(SecretRequestSchema, {

packages/cre-sdk/src/sdk/impl/runtime-impl.test.ts

@@ -207,6 +207,10 @@ export class BaseRuntimeImpl<C> implements BaseRuntime<C> {
 		return new Date(this.helpers.now())
 	}
 
+	sleep(ms: number): void {
+		this.helpers.sleep(ms)
+	}
+
 	log(message: string): void {
 		this.helpers.log(message)
 	}
@@ -461,6 +465,9 @@ export interface RuntimeHelpers {
 	/** Returns current time in milliseconds since Unix epoch. */
 	now(): number
 
+	/** Sleeps for the specified duration. */
+	sleep(ms: number): void
+
 	/** Logs a message to the host environment. */
 	log(message: string): void
 }

packages/cre-sdk/src/sdk/impl/runtime-impl.ts

@@ -71,6 +71,22 @@ describe('TestRuntime / helper layer', () => {
 		expect(rt.now().getTime()).toBe(fixed)
 	})
 
+	test('sleep() completes without throwing', () => {
+		const rt = newTestRuntime()
+		expect(() => rt.sleep(100)).not.toThrow()
+	})
+
+	test('sleep() with zero milliseconds completes without throwing', () => {
+		const rt = newTestRuntime()
+		expect(() => rt.sleep(0)).not.toThrow()
+	})
+
+	test('sleep() returns undefined (no-op in test runtime)', () => {
+		const rt = newTestRuntime()
+		const result = rt.sleep(250)
+		expect(result).toBeUndefined()
+	})
+
 	test('helper call returns false for unregistered capability', () => {
 		const rt = newTestRuntime()
 		const cap = new BasicActionCapability()

packages/cre-sdk/src/sdk/testutils/test-runtime.test.ts

@@ -217,6 +217,10 @@ function createTestRuntimeHelpers(
 		return state.timeProvider ? state.timeProvider() : Date.now()
 	}
 
+	function sleep(ms: number): void {
+		return
+	}
+
 	return {
 		call(request: Parameters<RuntimeHelpers['call']>[0]): boolean {
 			const handler = registry.get(request.id)
@@ -320,6 +324,8 @@ function createTestRuntimeHelpers(
 
 		now,
 
+		sleep,
+
 		log(message: string): void {
 			testWriter.log(message)
 		},

packages/cre-sdk/src/sdk/testutils/test-runtime.ts

@@ -82,6 +82,12 @@ declare global {
 	 */
 	function now(): number
 
+	/**
+	 * Sleeps for the specified duration.
+	 * @param ms - Duration in milliseconds
+	 */
+	function sleep(ms: number): void
+
 	/**
 	 * Console API available in the QuickJS runtime
 	 */

packages/cre-sdk/src/sdk/types/global.d.ts

@@ -10,6 +10,7 @@ exports[`JS host bindings contract 1`] = `
   "log",
   "now",
   "sendResponse",
+  "sleep",
   "switchModes",
   "versionV2",
 ]

packages/cre-sdk/src/sdk/wasm/__snapshots__/host-bindings-contract.test.ts.snap

@@ -28,6 +28,7 @@ export const globalHostBindingsSchema = z.object({
 		.returns(z.union([z.instanceof(Uint8Array), z.custom<Uint8Array<ArrayBufferLike>>()])),
 	getWasiArgs: z.function().args().returns(z.string()),
 	now: z.function().args().returns(z.number()),
+	sleep: z.function().args(z.number()).returns(z.void()),
 })
 
 type GlobalHostBindingsMap = z.infer<typeof globalHostBindingsSchema>

packages/cre-sdk/src/sdk/wasm/host-bindings.ts

@@ -104,6 +104,9 @@ const proxyHostBindings = {
 	now: () => {
 		throw new Error('now called unexpectedly in test')
 	},
+	sleep: () => {
+		throw new Error('sleep called unexpectedly in test')
+	},
 }
 
 Object.assign(globalThis, proxyHostBindings)