Changeset View
Changeset View
Standalone View
Standalone View
src/applications/feed/worker/FeedPublisherHTTPWorker.php
Show All 20 Lines | $post_data = array( | ||||
'storyID' => $data->getID(), | 'storyID' => $data->getID(), | ||||
'storyType' => $data->getStoryType(), | 'storyType' => $data->getStoryType(), | ||||
'storyData' => $data->getStoryData(), | 'storyData' => $data->getStoryData(), | ||||
'storyAuthorPHID' => $data->getAuthorPHID(), | 'storyAuthorPHID' => $data->getAuthorPHID(), | ||||
'storyText' => $story->renderText(), | 'storyText' => $story->renderText(), | ||||
'epoch' => $data->getEpoch(), | '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)) | id(new HTTPSFuture($uri, $post_data)) | ||||
->setMethod('POST') | ->setMethod('POST') | ||||
->setTimeout(30) | ->setTimeout(30) | ||||
->resolvex(); | ->resolvex(); | ||||
} | } | ||||
public function getWaitBeforeRetry(PhabricatorWorkerTask $task) { | public function getWaitBeforeRetry(PhabricatorWorkerTask $task) { | ||||
return max($task->getFailureCount(), 1) * 60; | return max($task->getFailureCount(), 1) * 60; | ||||
} | } | ||||
} | } |