adding embedded hubot

.meteor/packages

@@ -19,6 +19,7 @@ reactive-var
 service-configuration
 
 chrismbeckett:toastr
+dispatch:kernel
 francocatena:status
 iframely:oembed
 iron:router
@@ -43,6 +44,7 @@ rocketchat:autolinker
 rocketchat:emojione
 rocketchat:file
 rocketchat:highlight
+rocketchat:hubot
 rocketchat:lib
 rocketchat:markdown
 rocketchat:me
@@ -54,4 +56,3 @@ tmeasday:errors
 todda00:friendly-slugs
 underscorestring:underscore.string
 yasaricli:slugify
-dispatch:kernel

.meteor/versions

@@ -96,6 +96,7 @@ rocketchat:autolinker@0.0.1
 rocketchat:emojione@0.0.1
 rocketchat:file@0.0.1
 rocketchat:highlight@0.0.1
+rocketchat:hubot@0.0.1
 rocketchat:lib@0.0.1
 rocketchat:markdown@0.0.1
 rocketchat:me@0.0.1

packages/rocketchat-file/package.js

@@ -5,22 +5,22 @@ Package.describe({
 	git: ''
 });
 
-Npm.depends({
-	'mkdirp': '0.3.5',
-	'gridfs-stream': '0.5.3',
-	'gm' :'1.18.1'
-});
-
 Package.onUse(function(api) {
 	api.versionsFrom('1.0');
 
-	api.use('coffeescript');
+	api.use(['coffeescript']);
 
-	api.addFiles('file.server.coffee', 'server');
+	api.addFiles('file.server.coffee', ['server']);
 
 	api.export(['RocketChatFile'], ['server']);
 });
 
+Npm.depends({
+	'mkdirp': '0.3.5',
+	'gridfs-stream': '0.5.3',
+	'gm': '1.18.1'
+});
+
 Package.onTest(function(api) {
 
 });

packages/rocketchat-hubot/hubot.coffee

@@ -0,0 +1,4 @@
+CoffeeScript = Npm.require('coffee-script')
+CoffeeScript.register()
+
+Hubot = Npm.require('hubot')

packages/rocketchat-hubot/hubot.coffee.new

@@ -0,0 +1,187 @@
+hubot = Npm.require('hubot')
+
+Hubot = hubot;
+
+# Start a hubot, connected to our chat room.
+'use strict'
+model = share.model # import
+
+# Log messages?
+DEBUG = true
+
+# Monkey-patch Hubot to support private messages
+Hubot.Response::priv = (strings...) ->
+	@robot.adapter.priv @envelope, strings...
+
+# More monkey-patching
+Hubot.Robot::loadAdapter = -> # disable
+
+# grrrr, Meteor.bindEnvironment doesn't preserve `this` apparently
+bind = (f) ->
+	g = Meteor.bindEnvironment (self, args...) -> f.apply(self, args)
+	(args...) -> g @, args...
+
+class Robot extends Hubot.Robot
+	constructor: (args...) ->
+		super args...
+		@hear = bind @hear
+		@respond = bind @respond
+		@enter = bind @enter
+		@leave = bind @leave
+		@topic = bind @topic
+		@error = bind @error
+		@catchAll = bind @catchAll
+	loadAdapter: -> false
+	hear:    (regex, callback) -> super regex, Meteor.bindEnvironment callback
+	respond: (regex, callback) -> super regex, Meteor.bindEnvironment callback
+	enter: (callback) -> super Meteor.bindEnvironment(callback)
+	leave: (callback) -> super Meteor.bindEnvironment(callback)
+	topic: (callback) -> super Meteor.bindEnvironment(callback)
+	error: (callback) -> super Meteor.bindEnvironment(callback)
+	catchAll: (callback) -> super Meteor.bindEnvironment(callback)
+
+sendHelper = Meteor.bindEnvironment (robot, envelope, strings, map) ->
+	# be present in the room
+	try
+		Meteor.call 'setPresence',
+			nick: 'codexbot'
+			room_name: envelope.room
+			present: true
+			foreground: true
+	while strings.length > 0
+		string = strings.shift()
+		if typeof(string) == 'function'
+			string()
+		else
+			try
+				map(string)
+			catch err
+				console.error "Hubot error: #{err}" if DEBUG
+				robot.logger.error "Blackboard send error: #{err}"
+
+class BlackboardAdapter extends Hubot.Adapter
+	# Public: Raw method for sending data back to the chat source. Extend this.
+	#
+	# envelope - A Object with message, room and user details.
+	# strings  - One or more Strings for each message to send.
+	#
+	# Returns nothing.
+	send: (envelope, strings...) ->
+		sendHelper @robot, envelope, strings, (string) =>
+			console.log "send #{envelope.room}: #{string} (#{envelope.user.id})" if DEBUG
+			return @priv envelope, string if envelope.message.private
+			Meteor.call "newMessage",
+				nick: "codexbot"
+				body: string
+				room_name: envelope.room
+
+	# Public: Raw method for sending emote data back to the chat source.
+	#
+	# envelope - A Object with message, room and user details.
+	# strings  - One or more Strings for each message to send.
+	#
+	# Returns nothing.
+	emote: (envelope, strings...) ->
+		sendHelper @robot, envelope, strings, (string) =>
+			console.log "emote #{envelope.room}: #{string} (#{envelope.user.id})" if DEBUG
+			return @priv envelope, "*** #{string} ***" if envelope.message.private
+			Meteor.call "newMessage",
+				nick: "codexbot"
+				body: string
+				room_name: envelope.room
+				action: true
+
+	# Priv: our extension -- send a PM to user
+	priv: (envelope, strings...) ->
+		sendHelper @robot, envelope, strings, (string) ->
+			console.log "priv #{envelope.room}: #{string} (#{envelope.user.id})" if DEBUG
+			Meteor.call "newMessage",
+				nick: "codexbot"
+				to: "#{envelope.user.id}"
+				body: string
+				room_name: envelope.room
+
+	# Public: Raw method for building a reply and sending it back to the chat
+	# source. Extend this.
+	#
+	# envelope - A Object with message, room and user details.
+	# strings  - One or more Strings for each reply to send.
+	#
+	# Returns nothing.
+	reply: (envelope, strings...) ->
+		if envelope.message.private
+			@priv envelope, strings...
+		else
+			@send envelope, strings.map((str) -> "#{envelope.user.id}: #{str}")...
+
+	# Public: Raw method for setting a topic on the chat source. Extend this.
+	#
+	# envelope - A Object with message, room and user details.
+	# strings  - One more more Strings to set as the topic.
+	#
+	# Returns nothing.
+	topic: (envelope, strings...) ->
+
+	# Public: Raw method for playing a sound in the chat source. Extend this.
+	#
+	# envelope - A Object with message, room and user details.
+	# strings  - One or more strings for each play message to send.
+	#
+	# Returns nothing
+	play: (envelope, strings...) ->
+
+	# Public: Raw method for invoking the bot to run. Extend this.
+	#
+	# Returns nothing.
+	run: ->
+
+	# Public: Raw method for shutting the bot down. Extend this.
+	#
+	# Returns nothing.
+	close: ->
+
+Meteor.startup ->
+	robot = new Robot null, null, false, Meteor.settings?.botname ? 'codexbot'
+	robot.alias = 'bot'
+	adapter = robot.adapter = new BlackboardAdapter robot
+	# what's (the regexp for) my name?
+	robot.respond /(?:)/, -> false
+	mynameRE = robot.listeners.pop().regex
+	# register scripts
+	HubotScripts(robot)
+	Object.keys(share.hubot).forEach (scriptName) ->
+		console.log "Loading hubot script: #{scriptName}"
+		share.hubot[scriptName](robot)
+	# register our nick
+	n = Meteor.call 'newNick', {name: 'codexbot'}
+	Meteor.call 'setTag', {type:'nicks', object:n._id, name:'Gravatar', value:'codex@printf.net', who:n.canon}
+	# register our presence in general chat
+	keepalive = -> Meteor.call 'setPresence',
+		nick: 'codexbot'
+		room_name: 'general/0'
+		present: true
+		foreground: true
+	keepalive()
+	Meteor.setInterval keepalive, 30*1000 # every 30s refresh presence
+	# listen to the chat room, ignoring messages sent before we startup
+	startup = true
+	model.Messages.find({}).observe
+		added: (msg) ->
+			return if startup
+			return if msg.nick is "codexbot" or msg.nick is ""
+			return if msg.system or msg.action or msg.oplog or msg.bodyIsHtml
+			console.log "Received from #{msg.nick} in #{msg.room_name}: #{msg.body}"\
+				if DEBUG
+			user = new Hubot.User(msg.nick, room: msg.room_name)
+			tm = new Hubot.TextMessage(user, msg.body, msg._id)
+			tm.private = msg.to?
+			# if private, ensure it's treated as a direct address
+			if tm.private and not mynameRE.test(tm.text)
+				tm.text = "#{robot.name} #{tm.text}"
+			adapter.receive tm
+	startup = false
+	Meteor.call "newMessage",
+		nick: "codexbot"
+		body: 'wakes up'
+		room_name: 'general/0'
+		action: true

packages/rocketchat-hubot/package.js

@@ -0,0 +1,23 @@
+Package.describe({
+	name: 'rocketchat:hubot',
+	version: '0.0.1',
+	summary: 'Package hubot for Meteor server',
+	git: ''
+});
+
+Package.onUse(function(api) {
+	api.versionsFrom('1.0');
+
+	api.use(['coffeescript']);
+
+	api.addFiles('hubot.coffee', ['server']);
+
+	api.export('Hubot', ['server']);
+});
+
+Npm.depends({
+	"coffee-script": "1.9.3",
+	"hubot": "2.13.1"
+});
+
+Package.onTest(function(api) {});