SampleHelper.php

  // OLD CODE
  // Wait for one minute for data source operation status to be IDLE
  // Database operation (add/remove records) is asynchronous
  public function waitForIdle($dataSourceId)
  {
    $end = time() + 60; // up to one minute
    while (time() < $end)
    {
      try
      {
        $datasource = $this->get($dataSourceId);
        if ($datasource[0]->operationStatus != "IDLE")
        {
          sleep(2);
        }
        else
        {
          break;
        }
      }
      catch (Exception $e)
      {
        // ok
      }
    }
  }
  
  // New
  /**
   * Wait up to one minute for data source operation status to be IDLE
   * Database operation (add/remove records) is asynchronous
   *
   * @param InternalDataSourceId $datasourceId a data source object containing the id
   * @return void
   */
  public function waitForIdle(InternalDataSourceId $dataSourceId)
  {
    $endTime = time() + 60; // up to one minute
    while ($this->getDataSourceOperationStatus($dataSourceId) != "IDLE")
    {
      if (time() < $endTime)
      {
        break;
      }
      sleep(2);
    }
  }

  /**
   * Gets status of a internal datasource in StrongView
   *
   * @param InternalDataSourceId $datasourceId a data source object containing the id
   * @throws Exception
   * @return string
   */
  public function getDataSourceOperationStatus(InternalDataSourceId $dataSourceId) {
    try
    {
      $datasource = $this->get($dataSourceId);
      return $datasource[0]->operationStatus;
    } 
    catch (Exception $e)
    {
      throw new Exception($e->getMessage(), 1);
    }
  }