hubot/src/response.js

'use strict'

class Response {
  // Public: Responses are sent to matching listeners. Messages know about the
  // content and user that made the original message, and how to reply back to
  // them.
  //
  // robot   - A Robot instance.
  // message - A Message instance.
  // match   - A Match object from the successful Regex match.
  constructor (robot, message, match) {
    this.robot = robot
    this.message = message
    this.match = match
    this.envelope = {
      room: this.message.room,
      user: this.message.user,
      message: this.message
    }
  }

  // Public: Posts a message back to the chat source
  //
  // strings - One or more strings to be posted. The order of these strings
  //           should be kept intact.
  //
  // Returns nothing.
  send (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['send', { plaintext: true }].concat(strings))
  }

  // Public: Posts an emote back to the chat source
  //
  // strings - One or more strings to be posted. The order of these strings
  //           should be kept intact.
  //
  // Returns nothing.
  emote (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['emote', { plaintext: true }].concat(strings))
  }

  // Public: Posts a message mentioning the current user.
  //
  // strings - One or more strings to be posted. The order of these strings
  //           should be kept intact.
  //
  // Returns nothing.
  reply (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['reply', { plaintext: true }].concat(strings))
  }

  // Public: Posts a topic changing message
  //
  // strings - One or more strings to set as the topic of the
  //           room the bot is in.
  //
  // Returns nothing.
  topic (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['topic', { plaintext: true }].concat(strings))
  }

  // Public: Play a sound in the chat source
  //
  // strings - One or more strings to be posted as sounds to play. The order of
  //           these strings should be kept intact.
  //
  // Returns nothing
  play (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['play'].concat(strings))
  }

  // Public: Posts a message in an unlogged room
  //
  // strings - One or more strings to be posted. The order of these strings
  //           should be kept intact.
  //
  // Returns nothing
  locked (/* ...strings */) {
    const strings = [].slice.call(arguments)
    this.runWithMiddleware.apply(this, ['locked', { plaintext: true }].concat(strings))
  }

  // Private: Call with a method for the given strings using response
  // middleware.
  runWithMiddleware (methodName, opts/* , ...strings */) {
    const self = this
    const strings = [].slice.call(arguments, 2)
    const copy = strings.slice(0)
    let callback

    if (typeof copy[copy.length - 1] === 'function') {
      callback = copy.pop()
    }

    const context = {
      response: this,
      strings: copy,
      method: methodName
    }

    if (opts.plaintext != null) {
      context.plaintext = true
    }

    function responseMiddlewareDone () {}
    function runAdapterSend (_, done) {
      const result = context.strings
      if (callback != null) {
        result.push(callback)
      }
      self.robot.adapter[methodName].apply(self.robot.adapter, [self.envelope].concat(result))
      done()
    }

    return this.robot.middleware.response.execute(context, runAdapterSend, responseMiddlewareDone)
  }

  // Public: Picks a random item from the given items.
  //
  // items - An Array of items.
  //
  // Returns a random item.
  random (items) {
    return items[Math.floor(Math.random() * items.length)]
  }

  // Public: Tell the message to stop dispatching to listeners
  //
  // Returns nothing.
  finish () {
    this.message.finish()
  }

  // Public: Creates a scoped http client with chainable methods for
  // modifying the request. This doesn't actually make a request though.
  // Once your request is assembled, you can call `get()`/`post()`/etc to
  // send the request.
  //
  // Returns a ScopedClient instance.
  http (url, options) {
    return this.robot.http(url, options)
  }
}

module.exports = Response