PhabricatorBotDifferentialNotificationHandler.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	/**
	* @group irc
	*/
	final class PhabricatorBotDifferentialNotificationHandler
	extends PhabricatorBotHandler {

	private $skippedOldEvents;

	public function receiveMessage(PhabricatorBotMessage $message) {
	return;
	}

	public function runBackgroundTasks() {
	$iterator = new PhabricatorTimelineIterator('ircdiffx', array('difx'));
	$show = $this->getConfig('notification.actions');

	if (!$this->skippedOldEvents) {
	// Since we only want to post notifications about new events, skip
	// everything that's happened in the past when we start up so we'll
	// only process real-time events.
	foreach ($iterator as $event) {
	// Ignore all old events.
	}
	$this->skippedOldEvents = true;
	return;
	}

	foreach ($iterator as $event) {
	$data = $event->getData();
	if (!$data \|\| ($show !== null && !in_array($data['action'], $show))) {
	continue;
	}

	$actor_phid = $data['actor_phid'];
	$phids = array($actor_phid);
	$handles = id(new PhabricatorObjectHandleData($phids))->loadHandles();
	$verb = DifferentialAction::getActionPastTenseVerb($data['action']);

	$actor_name = $handles[$actor_phid]->getName();
	$message_body =
	"{$actor_name} {$verb} revision D".$data['revision_id'].".";

	$channels = $this->getConfig('notification.channels', array());
	foreach ($channels as $channel) {
	$this->writeMessage(
	id(new PhabricatorBotMessage())
	->setCommand('MESSAGE')
	->setTarget($channel)
	->setBody($message_body));
	}
	}
	}

	}