index.js

'use strict'

/*
 * adonis-cli
 *
 * (c) Harminder Virk <virk@adonisjs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
*/

const fs = require('fs')
const os = require('os')
const path = require('path')
const { Command } = require('../../../lib/ace')

const historyFile = path.join(os.homedir(), '/.adonis_repl_history')

/**
 * Start the repl server session
 *
 * @class Repl
 * @constructor
 */
class Repl extends Command {
  /**
   * The command signature used by ace
   *
   * @method signature
   *
   * @return {String}
   */
  static get signature () {
    return 'repl'
  }

  /**
   * The command description used by ace
   *
   * @method description
   *
   * @return {String}
   */
  static get description () {
    return 'Start a new repl session'
  }

  /**
   * Reads the history file
   *
   * @param  {Object} repl
   *
   * @private
   */
  _readHistoryFile (repl) {
    try {
      fs.statSync(historyFile)
    } catch (error) {
      fs.closeSync(fs.openSync(historyFile, 'w'))
    }

    repl.rli.history = fs.readFileSync(historyFile, 'utf-8').split('\n').reverse()
    repl.rli.history.shift()
    repl.rli.historyIndex = -1
  }

  /**
   * Save the history to the history file.
   *
   * @param {Object} repl
   *
   * @private
   */
  _addHistorySaveListener (repl) {
    const fd = fs.openSync(historyFile, 'a')
    repl.rli.addListener('line', (code) => {
      if (code && code !== '.history') {
        fs.write(fd, `${code}\n`, (error) => { if (error) console.log(error) })
        return
      }
      repl.rli.historyIndex++
      repl.rli.history.pop()
    })

    process.on('exit', function () {
      fs.closeSync(fd)
    })
  }

  /**
   * Method executed by ace to start the command line
   * repl
   *
   * @method handle
   *
   * @return {void}
   */
  async handle () {
    const awaitOutside = require('adonis-await-outside')
    const server = require('repl').start()

    if (typeof (global.use) === 'undefined') {
      this.info('You are running repl outside of Adonisjs app')
    } else {
      server.context.use = global.use
      server.context.make = global.make
    }

    this._readHistoryFile(server)
    this._addHistorySaveListener(server)
    awaitOutside.addAwaitOutsideToReplServer(server)
  }
}

module.exports = Repl