import * as NodeRuntime from "@effect/platform-node/NodeRuntime";import * as NodeServices from "@effect/platform-node/NodeServices";import path from "node:path"; import { Effect, FileSystem, Layer, Logger, ServiceMap } from "effect"; import { makeEventNdjsonLogger } from "../src/provider/Layers/EventNdjsonLogger.ts"; class LogDir extends ServiceMap.Service<LogDir, string>()("t3/scripts/logger-scope-repro/LogDir") {} const main = Effect.gen(function* () {  const logdir = yield* LogDir;  const providerLogPath = path.join(logdir, "provider");   yield* Effect.logInfo(`providerLogPath=${providerLogPath}`);   const providerLogger = yield* makeEventNdjsonLogger(providerLogPath, {    stream: "native",    batchWindowMs: 10,  });   yield* Effect.logInfo("before provider write");   if (providerLogger) {    yield* providerLogger.write(      {        kind: "probe",        message: "provider-only event",      },      "thread-123" as never,    );  }   yield* Effect.logInfo("after provider write");  yield* Effect.sleep("50 millis");   if (providerLogger) {    yield* providerLogger.close();  }  yield* Effect.logInfo("after provider close");   const fs = yield* FileSystem.FileSystem;  const logContents = yield* fs    .readDirectory(logdir, { recursive: true })    .pipe(      Effect.flatMap((entries) =>        Effect.all(entries.map((entry) => fs.readFileString(path.join(logdir, entry)))),      ),    );  yield* Effect.logInfo(`logContents=${logContents}`);}); Effect.gen(function* () {  const fs = yield* FileSystem.FileSystem;  const logdir = path.join(process.cwd(), "logtest");  yield* fs.makeDirectory(logdir);   const fileLogger = yield* Logger.formatSimple.pipe(    Logger.toFile(path.join(logdir, "global.log")),  );  const dualLogger = Logger.layer([fileLogger, Logger.consolePretty()]);   const mainLayer = Layer.mergeAll(dualLogger, Layer.succeed(LogDir, logdir));   yield* main.pipe(Effect.provide(mainLayer));}).pipe(Effect.scoped, Effect.provide(NodeServices.layer), NodeRuntime.runMain);