Class NodeFsFile

fs/_node_fs_file.ts:11–217

 * The internal class to convert a Node file descriptor into a FsFile object.
 */
export class NodeFsFile implements FsFile {
  #nodeFs = getNodeFs();
  #nodeStream = getNodeStream();
  #nodeTty = getNodeTty();
  #nodeUtil = getNodeUtil();
  #nodeReadFd = this.#nodeUtil.promisify(this.#nodeFs.read);
  #nodeWriteFd = this.#nodeUtil.promisify(this.#nodeFs.write);

  #closed: boolean;
  #rid: number;
  #readableStream?: ReadableStream<Uint8Array>;
  #writableStream?: WritableStream<Uint8Array>;

  constructor(fd: number) {
    this.#rid = fd;
    this.#closed = false;
  }

  get readable(): ReadableStream<Uint8Array> {
    if (this.#readableStream == null) {
      const readStream = this.#nodeFs.createReadStream(null as unknown, {
        fd: this.#rid,
        autoClose: false,
      });
      this.#readableStream = this.#nodeStream.Readable.toWeb(readStream);
    }
    return this.#readableStream as ReadableStream;
  }

  get writable(): WritableStream<Uint8Array> {
    if (this.#writableStream == null) {
      const writeStream = this.#nodeFs.createWriteStream(null as unknown, {
        fd: this.#rid,
        autoClose: false,
      });
      this.#writableStream = this.#nodeStream.Writable.toWeb(writeStream);
    }
    return this.#writableStream as WritableStream;
  }

  [Symbol.dispose](): void {
    if (!this.#closed) {
      this.close();
    }
  }

  close(): void {
    this.#closed = true;
    this.#nodeFs.closeSync(this.#rid);
  }

  isTerminal(): boolean {
    return this.#nodeTty.isatty(this.#rid);
  }

  // deno-lint-ignore require-await no-unused-vars
  async lock(exclusive?: boolean): Promise<void> {
    throw new Error("Method not implemented");