better-testing

PhabricatorNotificationClient.php
View Options

			<?php

			final class PhabricatorNotificationClient {

			const EXPECT_VERSION = 7;

			public static function getServerStatus() {
			$uri = PhabricatorEnv::getEnvConfig('notification.server-uri');
			$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;
			}

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

			try {
			self::postMessage($data);
			} catch (Exception $ex) {
			// 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();
			}

			}