PhabricatorNotificationClient.php
No OneTemporary
Actions

Subscribers

None

File Metadata

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

	}