import { RandomString } from './random-string';
import { createWriteStream } from 'fs';

const noop = (_: string, callback?: () => void) => {
  if (callback) {
    callback();
  }
};

export let audit = noop;

export async function openAuditLog(path: string) {
  const uniqueId = RandomString().padEnd(11, ' ');
  const stream = createWriteStream(path, { flags: 'a' });
  const writeToStream: typeof audit = (message, callback) => {
    const formattedMessage = `${new Date().toISOString()} ${uniqueId} ${message}\n`;
    stream.write(formattedMessage, callback);
  };
  await new Promise<void>((resolve, reject) => {
    stream.on('error', (err) => {
      audit = noop;
      reject(err);
    });
    stream.on('open', (_) => {
      resolve();
    });
    writeToStream('open');
  });
  audit = writeToStream;
}