ETCollection.class.php

<?php
/**
 * ETCollection
 *
 * @package ExactTargetAPI
 * @author  Henning Glatter-Gotz
 */
class ETCollection
{
  protected $data = array();

  public function __construct()
  {}

  /**
   * Process the soap result and throw an exception if something went wrong
   *
   * @param type $result
   */
  protected function evaluateResult($result)
  {
    ETCore::evaluateSoapResult($result);
  }

  public function count()
  {
    return count($this->data);
  }

  public function getFirst()
  {
    return reset($this->data);
  }

  public function getLast()
  {
    return end($this->data);
  }

  public function getData()
  {
    return $this->data;
  }

  public function toArray()
  {
    $data = array();

    foreach ($this->data as $record)
    {
      $data[] = $record->toArray();
    }

    return $data;
  }

  public function add($obj)
  {
    foreach ($this->data as $val)
    {
      if ($val === $obj)
      {
        return false;
      }
    }

    $this->data[] = $obj;

    return true;
  }

  public function getIterator()
  {
    $data = $this->data;

    return new ArrayIterator($data);
  }

  /**
   * save
   *
   * Save the collection to the backend (SOAP API)
   *
   * @access public
   * @return void
   */
  public function save()
  {
    $data = array();
    $result = null;

    if (count($this->data) === 0)
    {
      return true;
    }

    try
    {
      foreach ($this->data as $rec)
      {
        $data[] = $rec->toSoapVarForSave();
      }

      $result = ETCore::upsert($data);
      ETCore::evaluateSoapResult($result);

      return true;
    }
    catch (Exception $e)
    {
      throw new ETException(__METHOD__ . ':' . __LINE__ . '|' . $e->getMessage().'|'.print_r($result, true));
    }
  }

  /**
   * Delete all records from this collection.
   */
  public function delete()
  {
    $data = array();

    if (count($this->data) === 0)
    {
      return true;
    }

    try
    {
      foreach ($this->data as $rec)
      {
        $data[] = $rec->toSoapVarForDelete();
      }

      $result = ETCore::delete($data);
      ETCore::evaluateSoapResult($result);

      return true;
    }
    catch (Exception $e)
    {
      throw new ETException(__METHOD__ . ':' . __LINE__ . '|' . $e->getMessage());
    }
  }
}