12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.import { AsyncLocalStorage, AsyncResource } from "./async_hooks.ts";import { assert, assertEquals } from "../testing/asserts.ts";
Deno.test(async function foo() {  const asyncLocalStorage = new AsyncLocalStorage();
  const out: string[] = [];  function logWithId(msg: string) {    const id = asyncLocalStorage.getStore();    out.push(`${id !== undefined ? id : "-"}: ${msg}`);  }
  async function exec() {    logWithId("start");    await new Promise((resolve) => setTimeout(resolve, 100));    logWithId("finish");  }
  for (const foo of [1, 2, 3]) {    asyncLocalStorage.run(foo, exec);  }
  await new Promise((resolve) => setTimeout(resolve, 500));
  assertEquals(out, [    "1: start",    "2: start",    "3: start",    "1: finish",    "2: finish",    "3: finish",  ]);});
Deno.test(async function bar() {  let differentScopeDone = false;  const als = new AsyncLocalStorage();  const ac = new AbortController();  const server = Deno.serve(() => {    const differentScope = als.run(123, () =>      AsyncResource.bind(() => {        differentScopeDone = true;      }));    return als.run("Hello World", async () => {      // differentScope is attached to a different async context, so      // it will see a different value for als.getStore() (123)      setTimeout(differentScope, 5);      // Some simulated async delay.      await new Promise((res) => setTimeout(res, 10));      return new Response(als.getStore()); // "Hello World"    });  }, {    signal: ac.signal,    port: 4000,  });
  const res = await fetch("http://localhost:4000");  assertEquals(await res.text(), "Hello World");  ac.abort();  await server;  assert(differentScopeDone);});