'use strict';

const fs = require('node:fs/promises');
const timers = require('timers/promises');
const { Console } = require('node:console');

class RefCount {
  #resource = null;
  #dispose = null;
  #context = null;
  #count = 0;

  constructor(create, dispose) {
    this.#dispose = dispose;
    return this.#init(create);
  }

  async #init(create) {
    const { resource, context } = await create();
    this.#resource = resource;
    this.#context = context;
    return this;
  }

  use() {
    console.log('👉 Use');
    this.#count++;
    const disposable = Object.create(this.#resource);
    disposable[Symbol.asyncDispose] = async () => {
      console.log('👉 Dispose');
      this.#count--;
      if (this.#count > 0) return;
      await this.#dispose(this.#resource, this.#context);
      this.#resource = null;
      this.#context = null;
    };
    return disposable;
  }
}

const main = async () => {
  const logger = await new RefCount(
    async () => {
      const file = 'output.log';
      const fd = await fs.open(file, 'a');
      const stream = fd.createWriteStream(file, { flush: true });
      const resource = new Console({ stdout: stream });
      console.log(`👉 Open: ${file}`);
      return { resource, context: { file, fd } };
    },
    async (resource, context) => {
      console.log(`👉 Close: ${context.file}`);
      await context.fd.close();
    },
  );
  let ref3 = null;
  {
    // Block 0
    await using console = logger.use();
    console.log('Log 0');
    {
      // Block 1
      await using console = logger.use();
      console.log('Log 1');
    }
    {
      // Block 2
      await using console = logger.use();
      console.log('Log 2');
      ref3 = console;
    }
    await timers.setTimeout(1000);
  }
  // Block 3
  ref3.log('Log 3');
  return ref3;
};

main().then((ref4) => {
  console.log('After main');
  ref4.log('Log 4');
});