better-testing

PhabricatorBotDifferentialNotificationHandler.php
View Options

			<?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));
			}
			}
			}

			}