PhabricatorBotFlowdockProtocolAdapter.php
No OneTemporary
Actions

Size

2 KB

Referenced Files

None

Subscribers

None

PhabricatorBotFlowdockProtocolAdapter.php
View Options

	<?php

	final class PhabricatorBotFlowdockProtocolAdapter
	extends PhabricatorBotBaseStreamingProtocolAdapter {

	public function getServiceType() {
	return 'Flowdock';
	}

	protected function buildStreamingUrl($channel) {
	$organization = $this->getConfig('flowdock.organization');
	if (empty($organization)) {
	$this->getConfig('organization');
	}
	if (empty($organization)) {
	throw new Exception(
	'"flowdock.organization" configuration variable not set');
	}


	$ssl = $this->getConfig('ssl');

	$url = ($ssl) ? 'https://' : 'http://';
	$url .= "{$this->authtoken}@stream.flowdock.com";
	$url .= "/flows/{$organization}/{$channel}";
	return $url;
	}

	protected function processMessage($m_obj) {
	$command = null;
	switch ($m_obj['event']) {
	case 'message':
	$command = 'MESSAGE';
	break;
	default:
	// For now, ignore anything which we don't otherwise know about.
	break;
	}

	if ($command === null) {
	return false;
	}

	// TODO: These should be usernames, not user IDs.
	$sender = id(new PhabricatorBotUser())
	->setName($m_obj['user']);

	$target = id(new PhabricatorBotChannel())
	->setName($m_obj['flow']);

	return id(new PhabricatorBotMessage())
	->setCommand($command)
	->setSender($sender)
	->setTarget($target)
	->setBody($m_obj['content']);
	}

	public function writeMessage(PhabricatorBotMessage $message) {
	switch ($message->getCommand()) {
	case 'MESSAGE':
	$this->speak(
	$message->getBody(),
	$message->getTarget());
	break;
	}
	}

	private function speak(
	$body,
	PhabricatorBotTarget $flow) {
	// The $flow->getName() returns the flow's UUID,
	// as such, the Flowdock API does not require the organization
	// to be specified in the URI
	$this->performPost(
	'/messages',
	array(
	'flow' => $flow->getName(),
	'event' => 'message',
	'content' => $body,
	));
	}

	public function __destruct() {
	if ($this->readHandles) {
	foreach ($this->readHandles as $read_handle) {
	curl_multi_remove_handle($this->multiHandle, $read_handle);
	curl_close($read_handle);
	}
	}

	curl_multi_close($this->multiHandle);
	}
	}

File Metadata

Mime Type: text/x-php
Expires: Thu, Mar 27, 01:59 (1 w, 5 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1142420
Default Alt Text: PhabricatorBotFlowdockProtocolAdapter.php (2 KB)

PhabricatorBotFlowdockProtocolAdapter.phpNo OneTemporaryActions

PhabricatorBotFlowdockProtocolAdapter.phpView Options

File Metadata

Event Timeline

PhabricatorBotFlowdockProtocolAdapter.php
No OneTemporary
Actions

PhabricatorBotFlowdockProtocolAdapter.php
View Options