Method PerformPoll

libraries/lib-cloud-audiocom/TaskExecutionService.cpp:173–246

}

void TaskExecutionService::PerformPoll()
{
   using namespace audacity::network_manager;

   try
   {
      auto& serviceConfig = GetServiceConfig();
      auto& oauthService = GetOAuthService();

      Request request(serviceConfig.GetTaskPollUrl());

      request.setHeader(
         common_headers::ContentType, common_content_types::ApplicationJson);
      request.setHeader(
         common_headers::Accept, common_content_types::ApplicationJson);

      SetCommonHeaders(request);
      SetOptionalHeaders(request);

      auto response = NetworkManager::GetInstance().doGet(request);

      bool responseReceived = false;
      std::string responseBody;
      int httpCode = 0;

      response->setRequestFinishedCallback(
         [&responseReceived, &responseBody, &httpCode](auto response)
         {
            httpCode = response->getHTTPCode();
            responseBody = response->template readAll<std::string>();
            responseReceived = true;
         });

      const int maxWaitSeconds = 30;
      for (int i = 0; i < maxWaitSeconds && !responseReceived && !mStopRequested; ++i)
      {
         std::this_thread::sleep_for(std::chrono::seconds(1));
      }

      if (!responseReceived || mStopRequested)
         return;

      if (httpCode != 200)
      {
         // Continue polling on error
         return;
      }

      auto pollResponse = sync::DeserializeAppTaskPollResponse(responseBody);
      if (!pollResponse)
      {
         // Continue polling on error
         return;
      }

      mPollIntervalSeconds = pollResponse->Polling.IntervalSeconds;
      mPollingDisabled = pollResponse->Polling.Stop;