'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');

});