import { AMQPClient } from '../lib/mjs/amqp-client.js'

const log = (...args) => {
  const stack = new Error().stack.split('\n')
  const caller = stack[2].split(' ').pop().match(/(close\.js:\d+:\d+)/)[1]
  return console.log(new Date().toISOString(), ...args, `-${caller}`);
}

async function loopGetConnection() {
  let connectionAttempt = 0
  // eslint-disable-next-line no-constant-condition
  while (true) {
    log('Trying to connect', ++connectionAttempt)
    try {
      const amqp = new AMQPClient("amqp://localhost")
      await amqp.connect()
      return amqp
    } catch (err) {
      log('Failed to connect', err)
      await new Promise((resolve) => setTimeout(resolve, 50))
    }
  }
}

let conn = null
async function getConnection() {
  if (conn) {
    return conn
  }
  conn = await loopGetConnection()
  conn.logger = {
    debug: (...args) => log('debug', ...args),
    info: (...args) => log('info', ...args),
    warn: (...args) => log('warn', ...args),
    error: (...args) => log('error', ...args),
  }
  conn.onerror = (err) => {
    log(err);
    conn = null;
  }
  return conn;
}

process.on('uncaughtException', (err) => {
  log('uncaughtException', err)
  process.exit(1)
})

process.on('unhandledRejection', (err) => {
  log('unhandledRejection', err)
  process.exit(1)
})

process.on('exit', (code) => {
  log('exit', code)
  process.exit(code)
})

async function run() {
  {
    const conn = await getConnection()
    const ch = await conn.channel()
    await ch.queue('test', { autoDelete: true })
  }
  // eslint-disable-next-line no-constant-condition
  while (true) {
    const conn = await getConnection()
    const ch = await conn.channel()
    try {
      await ch.queue('test', { autoDelete: true })
      log('published a message');
    } catch (err) {
      log('Failed to publish', err)
    } finally {
      await ch.close()
    }
    await new Promise((resolve) => setTimeout(resolve, 1000))
  }
}
try {
  await run()
  log('Run exited normally unexpectedly') // should never happen
} catch (e) {
  log('Run exited unexpectedly', e)
}