HEX
Server: LiteSpeed
System: Linux houston.panomity.com 6.8.0-100-generic #100-Ubuntu SMP PREEMPT_DYNAMIC Tue Jan 13 16:40:06 UTC 2026 x86_64
User: nudepix (1011)
PHP: 7.4.33
Disabled: pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare,
Upload Files
File: //opt/LC/node_modules/avvio/test/plugin-loaded-so-far.test.js
'use strict'

const { test } = require('tap')
const fastq = require('fastq')
const boot = require('..')
const { Plugin } = require('../lib/plugin')

test('loadedSoFar resolves a Promise, if plugin.loaded is set to true', async (t) => {
  t.plan(1)
  const app = boot({})

  const plugin = new Plugin(fastq(app, app._loadPluginNextTick, 1), function (instance, opts, done) {
    done()
  }, false, 0)

  plugin.loaded = true

  await t.resolves(plugin.loadedSoFar())
})

test('loadedSoFar resolves a Promise, if plugin was loaded by avvio', async (t) => {
  t.plan(2)
  const app = boot({})

  const plugin = new Plugin(fastq(app, app._loadPluginNextTick, 1), function (instance, opts, done) {
    done()
  }, false, 0)

  app._loadPlugin(plugin, function (err) {
    t.equal(err, undefined)
  })

  await app.ready()

  await t.resolves(plugin.loadedSoFar())
})

test('loadedSoFar resolves a Promise, if .after() has no error', async t => {
  t.plan(1)
  const app = boot()

  app.after = function (callback) {
    callback(null, () => {})
  }

  const plugin = new Plugin(fastq(app, app._loadPluginNextTick, 1), function (instance, opts, done) {
    done()
  }, false, 0)

  app._loadPlugin(plugin, function () {})

  await t.resolves(plugin.loadedSoFar())
})

test('loadedSoFar rejects a Promise, if .after() has an error', async t => {
  t.plan(1)
  const app = boot()

  app.after = function (fn) {
    fn(new Error('ArbitraryError'), () => {})
  }

  const plugin = new Plugin(fastq(app, app._loadPluginNextTick, 1), function (instance, opts, done) {
    done()
  }, false, 0)

  app._loadPlugin(plugin, function () {})

  await t.rejects(plugin.loadedSoFar(), new Error('ArbitraryError'))
})

test('loadedSoFar resolves a Promise, if Plugin is attached to avvio after it the Plugin was instantiated', async t => {
  t.plan(1)

  const plugin = new Plugin(fastq(null, null, 1), function (instance, opts, done) {
    done()
  }, false, 0)

  const promise = plugin.loadedSoFar()

  plugin.server = boot()
  plugin.emit('start')
  await t.resolves(promise)
})