/// <reference types="bun" /> import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import { PtyAdapter } from "../Services/PTY.ts";import type { PtyAdapterShape, PtyExitEvent, PtyProcess } from "../Services/PTY.ts"; class BunPtyProcess implements PtyProcess {  private readonly dataListeners = new Set<(data: string) => void>();  private readonly exitListeners = new Set<(event: PtyExitEvent) => void>();  private readonly decoder = new TextDecoder();  private readonly process: Bun.Subprocess;  private didExit = false;   constructor(process: Bun.Subprocess) {    this.process = process;    void this.process.exited      .then((exitCode) => {        this.emitExit({          exitCode: Number.isInteger(exitCode) ? exitCode : 0,          signal: typeof this.process.signalCode === "number" ? this.process.signalCode : null,        });      })      .catch(() => {        this.emitExit({ exitCode: 1, signal: null });      });  }   get pid(): number {    return this.process.pid;  }   write(data: string): void {    if (!this.process.terminal) {      throw new Error("Bun PTY terminal handle is unavailable");    }    this.process.terminal.write(data);  }   resize(cols: number, rows: number): void {    if (!this.process.terminal?.resize) {      throw new Error("Bun PTY resize is unavailable");    }    this.process.terminal.resize(cols, rows);  }   kill(signal?: string): void {    if (!signal) {      this.process.kill();      return;    }    this.process.kill(signal as NodeJS.Signals);  }   onData(callback: (data: string) => void): () => void {    this.dataListeners.add(callback);    return () => {      this.dataListeners.delete(callback);    };  }   onExit(callback: (event: PtyExitEvent) => void): () => void {    this.exitListeners.add(callback);    return () => {      this.exitListeners.delete(callback);    };  }   emitData(data: Uint8Array): void {    if (this.didExit) return;    const text = this.decoder.decode(data, { stream: true });    if (text.length === 0) return;    for (const listener of this.dataListeners) {      listener(text);    }  }   private emitExit(event: PtyExitEvent): void {    if (this.didExit) return;    this.didExit = true;     const remainder = this.decoder.decode();    if (remainder.length > 0) {      for (const listener of this.dataListeners) {        listener(remainder);      }    }     for (const listener of this.exitListeners) {      listener(event);    }  }} export const layer = Layer.effect(  PtyAdapter,  Effect.gen(function* () {    if (process.platform === "win32") {      return yield* Effect.die(        "Bun PTY terminal support is unavailable on Windows. Please use Node.js (e.g. by running `npx t3`) instead.",      );    }    return {      spawn: (input) =>        Effect.sync(() => {          let processHandle: BunPtyProcess | null = null;          const command = [input.shell, ...(input.args ?? [])];          const subprocess = Bun.spawn(command, {            cwd: input.cwd,            env: input.env,            terminal: {              cols: input.cols,              rows: input.rows,              data: (_terminal, data) => {                processHandle?.emitData(data);              },            },          });          processHandle = new BunPtyProcess(subprocess);          return processHandle;        }),    } satisfies PtyAdapterShape;  }),);