Differential D15703 Diff 37833 src/applications/notification/client/PhabricatorNotificationClient.php

Changeset View

Standalone View

src/applications/notification/client/PhabricatorNotificationClient.php

	<?php			<?php

	final class PhabricatorNotificationClient extends Phobject {			final class PhabricatorNotificationClient extends Phobject {

	const EXPECT_VERSION = 7;			public static function tryAnyConnection() {
				$servers = PhabricatorNotificationServerRef::getEnabledAdminServers();

	public static function getServerStatus() {			if (!$servers) {
	$uri = PhabricatorEnv::getEnvConfig('notification.server-uri');			return;
	$uri = id(new PhutilURI($uri))
	->setPath('/status/')
	->setQueryParam('instance', self::getInstance());

	// We always use HTTP to connect to the server itself: it's simpler and
	// there's no meaningful security benefit to securing this link today.
	// Force the protocol to HTTP in case users have set it to something else.
	$uri->setProtocol('http');

	list($body) = id(new HTTPSFuture($uri))
	->setTimeout(3)
	->resolvex();

	$status = phutil_json_decode($body);
	if (!is_array($status)) {
	throw new Exception(
	pht(
	'Expected JSON response from notification server, received: %s',
	$body));
	}			}

	return $status;			foreach ($servers as $server) {
				$server->loadServerStatus();
				return;
	}			}

	public static function tryToPostMessage(array $data) {
	if (!PhabricatorEnv::getEnvConfig('notification.enabled')) {
	return;			return;
	}			}

				public static function tryToPostMessage(array $data) {
				$servers = PhabricatorNotificationServerRef::getEnabledAdminServers();
				foreach ($servers as $server) {
	try {			try {
	self::postMessage($data);			$server->postMessage($data);
				return;
	} catch (Exception $ex) {			} catch (Exception $ex) {
	// Just ignore any issues here.			// Just ignore any issues here.
	phlog($ex);
	}			}
	}			}

	private static function postMessage(array $data) {
	$server_uri = PhabricatorEnv::getEnvConfig('notification.server-uri');
	$server_uri = id(new PhutilURI($server_uri))
	->setPath('/')
	->setQueryParam('instance', self::getInstance());

	id(new HTTPSFuture($server_uri, json_encode($data)))
	->setMethod('POST')
	->setTimeout(1)
	->resolvex();
	}

	private static function getInstance() {
	$client_uri = PhabricatorEnv::getEnvConfig('notification.client-uri');
	return id(new PhutilURI($client_uri))->getPath();
	}			}

	}			}