PHP ждет ответа на изменение статуса

Question

Я пытаюсь реализовать SkyScanner API ...

Мне нужно позвонить:

"http://partners.api.skyscanner.net/apiservices/pricing/uk1/v1.0/
    {SessionKey}?apiKey={apiKey}
    &pageIndex=0
    &pageSize=10"

, поэтому я пишу:

$res1 = $client1->get('http://partners.api.skyscanner.net/apiservices/pricing/uk2/v1.0/'.$session_id.'?apikey=APIKEY&pageIndex=0&pageSize=10"');

 $res1 = json_decode($res1->getBody()->getContents(), true);
$res1 = collect($res1);

и мне нужноожидать ответа на изменение состояния с UpdatePending на UpdateCompleted

Документы API:

Продолжайте запрашивать страницу 0, пока не получите UpdatesComplete с pageIndex = 0 через полсекундыс интервалом в одну секунду. Как только вы получите UpdatesComplete, вы можете запросить любую страницу и размер страницы.

Пока статус UPDATESPENDING, вам следует запрашивать только страницу 0, поскольку содержимое каждой страницы может изменяться до тех пор, пока не будут выполнены обновления.

Как ждать ответа на изменение статуса ...

Я пытаюсь:

while ($res1['Status'] == 'UpdatesPending') {
    echo 'waiting';
}

dd($res1);

но нет конца ...

Как сделатьждать ответа на изменение статуса?

Answer 1

Вам нужно создать цикл do / while, чтобы проверить статус и выйти из него при изменении статуса:

do{

    $res1 = $client1->get('http://partners.api.skyscanner.net/apiservices/pricing/uk2/v1.0/'.$session_id.'?apikey=APIKEY&pageIndex=0&pageSize=10"');

    $res1 = json_decode($res1->getBody()->getContents(), true);
    $res1 = collect($res1);
    if($res1['Status'] == 'UpdatesPending') echo "waiting...<br />\n";
    sleep(5); // Make it sleep 5 seconds so as to not spam the server
while($res1['Status'] == 'UpdatesPending');

echo "Done!";

Обратите внимание, что вы не получите никакой реальной обратной связи, пока весь процесс не будетзаконченным.

Answer 2

Если вы используете guzzle в качестве PHP HTTP-клиента, то вам просто нужно определить решатель повторных попыток и таймер повторных попыток

public function retryDecider() 
{
  return function ($retries, Request $request, Response $response = null, RequestException $exception = null) 
  {
    // maximum retries is three times
    if ($retries >= 3) {
      return false; 
    }

    if ($response) {
      $content = $response->getBody()->getContents();
      $res1 = json_decode($content, true);
      $res1 = collect($res1);

      // maybe you need to change this one to 'substr' or regex or something else
      if ($res1['Status'] == 'UpdatesComplete') {
        return false;
      }

    }

    return true; // we will request again
  };
}

public function retryDelay()
{
    return function ($numberOfRetries) {
        return 1000; // 1 second
    };
}

и использовать эту функцию определения и задержки

$handlerStack = HandlerStack::create(new CurlHandler());
$handlerStack->push(Middleware::retry($this->retryDecider(), $this->retryDelay()));
$client = new Client(array('handler' => $handlerStack));

и получите ответ

$url = 'http://partners.api.skyscanner.net/apiservices/pricing/uk2/v1.0/'.$session_id.'?apikey=APIKEY&pageIndex=0&pageSize=10"';
$response = $client->request('GET', $url)->getBody()->getContents();

Вы можете расшифровать последний $response, чтобы решить, хотите ли вы сделать.

При таком подходе вы можете решить, какой ответ является действительным, и повторить запрос столько раз, сколько захотите.

Answer 3

вы можете повторить 'waiting' перед вашим кодом, тогда это будет завершено completed в другой строке

echo 'waiting...';
$res1 = $client1->get('http://partners.api.skyscanner.net/apiservices/pricing/uk2/v1.0/'.$session_id.'?apikey=APIKEY&pageIndex=0&pageSize=10"');

$res1 = json_decode($res1->getBody()->getContents(), true);
$res1 = collect($res1);
echo 'completed';