No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/src/applications/feed/worker/FeedPublisherHTTPWorker.php b/src/applications/feed/worker/FeedPublisherHTTPWorker.php
	index 4742e52a29..27a869ddef 100644
	--- a/src/applications/feed/worker/FeedPublisherHTTPWorker.php
	+++ b/src/applications/feed/worker/FeedPublisherHTTPWorker.php
	@@ -1,39 +1,44 @@
	<?php

	final class FeedPublisherHTTPWorker extends FeedPushWorker {

	protected function doWork() {
	if (PhabricatorEnv::getEnvConfig('phabricator.silent')) {
	// Don't invoke hooks in silent mode.
	return;
	}

	$story = $this->loadFeedStory();
	$data = $story->getStoryData();

	$uri = idx($this->getTaskData(), 'uri');
	$valid_uris = PhabricatorEnv::getEnvConfig('feed.http-hooks');
	if (!in_array($uri, $valid_uris)) {
	throw new PhabricatorWorkerPermanentFailureException();
	}

	$post_data = array(
	'storyID' => $data->getID(),
	'storyType' => $data->getStoryType(),
	'storyData' => $data->getStoryData(),
	'storyAuthorPHID' => $data->getAuthorPHID(),
	'storyText' => $story->renderText(),
	'epoch' => $data->getEpoch(),
	);

	+ // NOTE: We're explicitly using "http_build_query()" here because the
	+ // "storyData" parameter may be a nested object with arbitrary nested
	+ // sub-objects.
	+ $post_data = http_build_query($post_data, '', '&');
	+
	id(new HTTPSFuture($uri, $post_data))
	->setMethod('POST')
	->setTimeout(30)
	->resolvex();
	}

	public function getWaitBeforeRetry(PhabricatorWorkerTask $task) {
	return max($task->getFailureCount(), 1) * 60;
	}

	}