PhabricatorBotLogHandler.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	/**
	* Logs chatter.
	*
	* @group irc
	*/
	final class PhabricatorBotLogHandler extends PhabricatorBotHandler {

	private $futures = array();

	public function receiveMessage(PhabricatorBotMessage $message) {

	switch ($message->getCommand()) {
	case 'MESSAGE':
	$reply_to = $message->getReplyTo();
	if (!$reply_to) {
	break;
	}
	if (!$message->isPublic()) {
	// Don't log private messages, although maybe we should for debugging?
	break;
	}

	$logs = array(
	array(
	'channel' => $reply_to,
	'type' => 'mesg',
	'epoch' => time(),
	'author' => $message->getSender(),
	'message' => $message->getBody(),
	),
	);

	$this->futures[] = $this->getConduit()->callMethod(
	'chatlog.record',
	array(
	'logs' => $logs,
	));

	$prompts = array(
	'/where is the (chat)?log\?/i',
	'/where am i\?/i',
	'/what year is (this\|it)\?/i',
	);

	$tell = false;
	foreach ($prompts as $prompt) {
	if (preg_match($prompt, $message->getBody())) {
	$tell = true;
	break;
	}
	}

	if ($tell) {
	$response = $this->getURI(
	'/chatlog/channel/'.phutil_escape_uri($reply_to).'/');

	$this->replyTo($message, $response);
	}

	break;
	}
	}

	public function runBackgroundTasks() {
	foreach ($this->futures as $key => $future) {
	try {
	if ($future->isReady()) {
	unset($this->futures[$key]);
	}
	} catch (Exception $ex) {
	unset($this->futures[$key]);
	phlog($ex);
	}
	}
	}

	}