Function TestContextAsync

context_test.go:972–1033

(t *testing.T)

}

func TestContextAsync(t *testing.T) {
	useStableOwnerHooksForLegacySubtests(t)

	rt := NewRuntime()
	defer rt.Close()
	ctx := rt.NewContext()
	defer ctx.Close()

	t.Run("EventLoop", func(t *testing.T) {
		result := ctx.Eval(`
            var executed = false;
            setTimeout(() => { executed = true; }, 10);
        `)
		defer result.Free()
		require.False(t, result.IsException())

		ctx.Loop()

		executedResult := ctx.Eval(`executed`)
		defer executedResult.Free()
		require.False(t, executedResult.IsException())
		require.True(t, executedResult.ToBool())
	})

	// Updated: Use Function + Promise instead of AsyncFunction
	t.Run("AwaitPromises", func(t *testing.T) {
		// Test successful promise using new Promise API
		asyncTestFn := ctx.NewFunction(func(ctx *Context, this *Value, args []*Value) *Value {
			return ctx.NewPromise(func(resolve, reject func(*Value)) {
				resolve(ctx.NewString("awaited result"))
			})
		})
		ctx.Globals().Set("asyncTest", asyncTestFn)

		promiseResult := ctx.Eval(`asyncTest()`)
		require.False(t, promiseResult.IsException())
		require.True(t, promiseResult.IsPromise())

		awaitedResult := ctx.Await(promiseResult)
		defer awaitedResult.Free()
		require.False(t, awaitedResult.IsException())
		require.EqualValues(t, "awaited result", awaitedResult.ToString())

		// Test rejected promise using new Promise API
		asyncRejectFn := ctx.NewFunction(func(ctx *Context, this *Value, args []*Value) *Value {
			return ctx.NewPromise(func(resolve, reject func(*Value)) {
				errorObj := ctx.NewError(errors.New("rejection reason"))
				defer errorObj.Free()
				reject(errorObj)
			})
		})
		ctx.Globals().Set("asyncReject", asyncRejectFn)

		rejectPromise := ctx.Eval(`asyncReject()`)
		require.False(t, rejectPromise.IsException())

		rejectedResult := ctx.Await(rejectPromise)
		defer rejectedResult.Free()