<?php
/****************************************************************************
 ** Entity APIs
 ****************************************************************************/

/**
 * Implements hook_entity_info().
 *
 * @todo Add 'bundles' for different types of remote content.
 * @todo Add 'entity keys' => 'needs remote save' if remote saving required.
 * @todo Remove 'static cache' and 'field cache' settings after development.
 */
function siteshortname_entities_remote_entity_info() {
  $entities['siteshortname_entities_remote_event'] = array(

    // Core properties.
    'label' => t('Event'),
    'controller class' => 'RemoteEntityAPIDefaultController',
    'base table' => 'siteshortname_entities_remote_events',
    'uri callback' => 'entity_class_uri',
    'label callback' => 'remote_entity_entity_label',
    'fieldable' => FALSE,
    'entity keys' => array(
      'id' => 'eid',
      'label' => 'event_name',
    ),
    'view modes' => array(
      'full' => array(
        'label' => t('Full content'),
        'custom settings' => FALSE,
      ),
    ),
    'static cache' => FALSE,
    'field cache' => FALSE,

    // Entity API properties.
    'entity class' => 'SiteshortnameEvent',
    'module' => 'siteshortname_entities_remote',
    'metadata controller class' => 'RemoteEntityAPIDefaultMetadataController',
    'views controller class' => 'EntityDefaultViewsController',

    // Remote Entity API properties.
    'remote base table' => 'siteshortname_entities_remote_events',
    'remote entity keys' => array(
      'remote id' => 'event_id',
      'label' => 'event_name',
    ),
    'expiry' => array(
      // Number of seconds before a locally cached instance must be refreshed
      // from the remote source.
      'expiry time' => 600,
      // A boolean indicating whether or not to delete expired local entities
      // on cron.
      'purge' => FALSE,
    ),
  );

  // Get the property map data.
  $remote_properties = siteshortname_entities_remote_get_remote_properties();

  // Assign each map to its corresponding entity.
  foreach ($entities as $key => $einfo) {
    $entities[$key]['property map'] =
      drupal_map_assoc(array_keys($remote_properties[$key]));
  }

  // Return all of the entity information.
  return $entities;
}
?>

<?php
/**
 * Implements hook_entity_property_info_alter().
 *
 * This is needed to use wrappers to access the remote entity
 * data in the entity_data property of remote entities.
 *
 * @see: Page 107 of the Programming Drupal 7 Entities book.  The code below is
 *   a variation on it.
 * @todo: Remove whenever this gets added to the remote_entity module.
 */
function siteshortname_entities_remote_entity_property_info_alter(&$info) {

  // Set the entity types and get their properties.
  $entity_types = array(
    'siteshortname_entities_remote_event',
  );

  $remote_properties = siteshortname_entities_remote_get_remote_properties();

  // Assign the property data to each entity.
  foreach ($entity_types as $entity_type) {
    $properties = &$info[$entity_type]['properties'];
    $entity_data = &$properties['entity_data'];
    $pp = &$remote_properties[$entity_type];
    $entity_data['type'] = 'remote_entity_' . $entity_type;

    // Set the default getter callback for each property.
    foreach ($pp as $key => $pinfo) {
      $pp[$key]['getter callback'] = 'entity_property_verbatim_get';
    }

    // Assign the updated property info to the entity info.
    $entity_data['property info'] = $pp;
  }
}
?>

<?php
/**
 * Get remote property information for remote entities.
 *
 * @return
 *   An array of property information keyed by entity type.
 */
function siteshortname_entities_remote_get_remote_properties() {

  // Initialize a list of entity properties.
  $properties = array();

  // Define properties for the entity type.
  $properties['siteshortname_entities_remote_event'] = array(

    // Event information.
    'event_id' => array(
      'label' => 'Remote Event ID',
      'type' => 'integer',
      'description' => 'The remote attribute "id".',
      'views' => array(
        'filter' => 'siteshortname_entities_remote_views_handler_filter_event_id',
      ),
    ),
    'event_date' => array(
      'label' => 'Date',
      'type' => 'date',
      'description' => 'The remote attribute "date".',
      'views' => array(
        'filter' => 'siteshortname_entities_remote_views_handler_filter_event_date',
      ),
    ),
    'event_details' => array(
      'label' => 'Details',
      'type' => 'text',
      'description' => 'The remote attribute "details".',
    ),
  );

  // Return all of the defined property info.
  return $properties;
}
?>

<?php
/****************************************************************************
 ** Drupal Core
 ****************************************************************************/

/**
 * Implements hook_menu().
 */
function siteshortname_entities_remote_menu() {
  $items = array();

  $items['event/%siteshortname_entities_remote_event'] = array(
    'title' => 'Remote Event',
    'page callback' => 'siteshortname_entities_remote_event_view',
    'page arguments' => array(1),
    'access arguments' => array('access content'),
  );

  return $items;
}

/**
 * Menu autoloader wildcard for path 'event/REMOTE_ID'.
 *
 * @see hook_menu() documentation.
 * @param $remote_id
 *   The remote ID of the record to load.
 * @return
 *   The loaded object, or FALSE on failure.
 */
function siteshortname_entities_remote_event_load($remote_id) {
  return remote_entity_load_by_remote_id('siteshortname_entities_remote_event', $remote_id);
}

/**
 * Page callback for path 'event/%remote_id'.
 *
 * @param $event
 *   The auto-loaded object.
 * @return
 *   The themed output for the event page.
 */
function siteshortname_entities_remote_event_view($event) {
  $fullname = $event->name;
  drupal_set_title($fullname);
  $event_output = theme('siteshortname_entities_remote_event', array(
    'event' => $event,
  ));
  return $event_output;
}

/**
 * Implements hook_theme().
 */
function siteshortname_entities_remote_theme() {
  return array(
    'siteshortname_entities_remote_event' => array(
      'variables' => array('event' => NULL),
      'file' => 'includes/siteshortname_entities_remote.theme.inc',
    ),
  );
}
?>

<?php
    'entity class' => 'SiteshortnameEvent',
?>

<?php
class SiteshortnameEvent extends Entity {
  /**
   * Override defaultUri().
   */
  protected function defaultUri() {
    return array('path' => 'event/' . $this->remote_id);
  }
} 
?>

<?php
/****************************************************************************
 ** Web Service Clients
 ****************************************************************************/

/**
 * Implements hook_clients_connection_type_info().
 */
function siteshortname_entities_remote_clients_connection_type_info() {
  return array(
    'our_rest' => array(
      'label'  => t('REST Data Services'),
      'description' => t('Connects to our data service using REST endpoints.'),
      'tests' => array(
        'event_retrieve_raw' => 'SiteshortnameEntitiesRemoteConnectionTestEventRetrieveRaw',
      ),
      'interfaces' => array(
        'ClientsRemoteEntityInterface',
      ),
    ),
  );
}

/**
 * Implements hook_clients_default_connections().
 */
function siteshortname_entities_remote_clients_default_connections() {

  $connections['my_rest_connection'] = new clients_connection_our_rest(array(
    'endpoint' => 'https://data.example.com',
    'configuration' => array(
      'username' => '',
      'password' => '',
    ),
    'label' => 'Our REST Service',
    'type' => 'our_rest',
  ), 'clients_connection');

  return $connections;
}

/**
 * Implements hook_clients_default_resources().
 */
function siteshortname_entities_remote_clients_default_resources() {
  $resources['siteshortname_entities_remote_event'] = new clients_resource_remote_entity(array(
    'component' => 'siteshortname_entities_remote_event',
    'connection' => 'my_rest_connection',
    'label' => 'Resource for remote events',
    'type' => 'remote_entity',
  ), 'clients_resource');

  return $resources;
}
?>

<?php
/**
 * Implementation of hook_schema().
 */
function siteshortname_entities_remote_schema() {
  $schema = array(
    'siteshortname_entities_remote_events' => remote_entity_schema_table('our remote event entity type'),
  );

  return $schema;
}
?>

<?php
/**
 * Entity controller extending RemoteEntityAPIDefaultController
 *
 * For most of our cases the default controller is fine, but we can use
 * this one for entities we don't want stored locally.  Override the save
 * behaviour and do not keep a local cached copy.
 */
class SiteshortnameEntitiesRemoteNoLocalAPIController extends RemoteEntityAPIDefaultController {

  /**
   * Don't actually save anything.
   */
  public function save($entity, DatabaseTransaction $transaction = NULL) {
    $entity->eid = uniqid();
  }
}
?>

<?php
/**
 * @file
 * Contains the clients_connection_our_rest class.
 */

/**
 * Set up a client connection to our REST services.
 *
 *  @todo Make private functions private once development is done.
 */
class clients_connection_our_rest extends clients_connection_base
  implements ClientsConnectionAdminUIInterface, ClientsRemoteEntityInterface {

}
?>

<?php
  /**************************************************************************
   * ClientsRemoteEntityInterface implementations.
   **************************************************************************/

  /**
   * Load a remote entity.
   *
   * @param $entity_type
   *   The entity type to load.
   * @param $id
   *   The (remote) ID of the entity.
   *
   * @return
   *  An entity object.
   */
  function remote_entity_load($entity_type, $id) {
    $query = $this->getRemoteEntityQuery('select');
    $query->base($entity_type);
    $query->entityCondition('entity_id', $id);
    $result = $query->execute();

    // There's only one. Same pattern as entity_load_single().
    return reset($result);
  }

  /**
   * Provide a map of remote property types to Drupal types.
   *
   * Roughly analogous to _entity_metadata_convert_schema_type().
   *
   * @return
   *   An array whose keys are remote property types as used as types for fields
   *   in hook_remote_entity_query_table_info(), and whose values are types
   *   recognized by the Entity Metadata API (as listed in the documentation for
   *   hook_entity_property_info()).
   *   If a remote property type is not listed here, it will be mapped to 'text'
   *   by default.
   */
  function entity_property_type_map() {
    return array(
      'EntityCollection' => 'list<string>',
    );
  }

  /**
   * Get a new RemoteEntityQuery object appropriate for the connection.
   *
   * @param $query_type
   *  (optional) The type of the query. Defaults to 'select'.
   *
   * @return
   *  A remote query object of the type appropriate to the query type.
   */
  function getRemoteEntityQuery($query_type = 'select') {
    switch ($query_type) {
      case 'select':
        return new OurRestRemoteSelectQuery($this);
      case 'insert':
        return new OurRestRemoteInsertQuery($this);
      case 'update':
        return new OurRestRemoteUpdateQuery($this);
    }
  }
?>

<?php
  /**************************************************************************
   * clients_connection_base overrides
   **************************************************************************/

  /**
   * Call a remote method with an array of parameters.
   *
   * This is intended for internal use from callMethod() and
   * clients_connection_call().
   * If you need to call a method on given connection object, use callMethod
   * which has a nicer form.
   *
   * Subclasses do not necessarily have to override this method if their
   * connection type does not make sense with this.
   *
   * @param $method
   *  The name of the remote method to call.
   * @param $method_params
   *  An array of parameters to passed to the remote method.
   *
   * @return
   *  Whatever is returned from the remote site.
   *
   * @throws Exception on error from the remote site.
   *  It's up to subclasses to implement this, as the test for an error and
   *  the way to get information about it varies according to service type.
   */
  function callMethodArray($method, $method_params = array()) {

    switch ($method) {
      case 'makeRequest':

        // Set the parameters.
        $resource_path = $method_params[0];
        $http_method = $method_params[1];
        $data = isset($method_params[2]) ? $method_params[2] : array();

        // Make the request.
        $results = $this->makeRequest($resource_path, $http_method, $data);
        break;
    }

    return $results;
  }
?>

<?php
  /**************************************************************************
   * Local methods
   **************************************************************************/

  /**
   * Make a REST request.
   *
   * Originally from clients_connection_drupal_services_rest_7->makeRequest().
   * Examples:
   * Retrieve an event:
   *  makeRequest('event?eventId=ID', 'GET');
   * Update a node:
   *  makeRequest('node/NID', 'POST', $data);
   *
   * @param $resource_path
   *  The path of the resource. Eg, 'node', 'node/1', etc.
   * @param $http_method
   *  The HTTP method. One of 'GET', 'POST', 'PUT', 'DELETE'. For an explanation
   *  of how the HTTP method affects the resource request, see the Services
   *  documentation at http://drupal.org/node/783254.
   * @param $data = array()
   *  (Optional) An array of data to pass to the request.
   * @param boolean $data_as_headers
   *   Data will be sent in the headers if this is set to TRUE.
   *
   * @return
   *  The data from the request response.
   *
   *  @todo Update the first two test classes to not assume a SimpleXMLElement.
   */
  function makeRequest($resource_path, $http_method, $data = array(), $data_as_headers = FALSE) {

    // Tap into this function's cache if there is one.
    $request_cache_map = &drupal_static(__FUNCTION__);

    // Set the options.
    $options = array(
      'headers' => $this->getHeaders(),  // Define if you need it.
      'method'  => $http_method,
      'data'    => $data,
    );

    // If cached, we have already issued this request during this page request so
    // just use the cached value.
    $request_path = $this->endpoint . $context_path . '/' . $resource_path;

    // Either get the data from the cache or send a request for it.
    if (isset($request_cache_map[$request_path])) {
      // Use the cached copy.
      $response = $request_cache_map[$request_path];
    } else {
      // Not cached yet so fire off the request.
      $response = drupal_http_request($request_path, $options);

      // And then cache to avoid duplicate calls within the page request.
      $request_cache_map[$request_path] = $response;
    }

    // Handle any errors and then return the response.
    $this->handleRestError($request_path, $response);
    return $response;
  }

  /**
   * Common helper for reacting to an error from a REST call.
   *
   * Originally from clients_connection_drupal_services_rest_7->handleRestError().
   * Gets the error from the response, logs the error message,
   * and throws an exception, which should be caught by the module making use
   * of the Clients connection API.
   *
   * @param $response
   *  The REST response data, decoded.
   *
   * @throws Exception
   */
  function handleRestError($request, $response) {

    // Report and throw an error if we get anything unexpected.
    if (!in_array($response->code, array(200, 201, 202, 204, 404))) {

      // Report error to the logs.
      watchdog('clients', 'Error with REST request (@req). Error was code @code with error "@error" and message "@message".', array(
        '@req'      => $request,
        '@code'     => $response->code,
        '@error'    => $response->error,
        '@message'  => isset($response->status_message) ? $response->status_message : '(no message)',
      ), WATCHDOG_ERROR);

      // Throw an error with which callers must deal.
      throw new Exception(t("Clients connection error, got message '@message'.", array(
        '@message' => isset($response->status_message) ? $response->status_message : $response->error,
      )), $response->code);
    }
  }
?>

<?php
/**
 * @file
 * Contains the OurRestRemoteSelectQuery class.
 */

/**
 * Select query for our remote data.
 *
 * @todo Make vars protected once no longer developing.
 */
class OurRestRemoteSelectQuery extends RemoteEntityQuery {

  /**
   * Determines whether the query is RetrieveMultiple or Retrieve.
   *
   * The query is Multiple by default, until an ID condition causes it to be
   * single.
   */
  public $retrieve_multiple = TRUE;

  /**
   * An array of conditions on the query. These are grouped by the table they
   * are on.
   */
  public $conditions = array();

  /**
   * The from date filter for event searches
   */
  public $from_date = NULL;

  /**
   * The to date filter for event searches
   */
  public $to_date = NULL;

  /**
   * The user id.
   */
  public $user_id = NULL;

  /**
   * Constructor to generically set up the user id condition if
   * there is a current user.
   *
   * @param $connection
   */
  function __construct($connection) {
    parent::__construct($connection);
    if (user_is_logged_in()) {
      global $user;
      $this->useridCondition($user->name);
    }
  }
}
?>

<?php
  /**
   * Add a condition to the query.
   *
   * Originally based on the entityCondition() method in EntityFieldQuery, but
   * largely from USDARemoteSelectQuery (Programming Drupal 7 Entities) and
   * MSDynamicsSoapSelectQuery.
   *
   * @param $name
   *  The name of the entity property.
   */
  function entityCondition($name, $value, $operator = NULL) {

    // We only support the entity ID for now.
    if ($name == 'entity_id') {

      // Get the remote field name of the entity ID.
      $field = $this->entity_info['remote entity keys']['remote id'];

      // Set the remote ID field to the passed value.
      $this->conditions[$this->remote_base][] = array(
        'field' => $field,
        'value' => $value,
        'operator' => $operator,
      );

      // Record that we'll only be retrieving a single item.
      if (is_null($operator) || ($operator == '=')) {
        $this->retrieve_multiple = FALSE;
      }
    }
    else {

      // Report an invalid entity condition.
      $this->throwException(
        'OURRESTREMOTESELECTQUERY_INVALID_ENTITY_CONDITION',
        'The query object can only accept the \'entity_id\' condition.'
      );
    }
  }

  /**
   * Add a condition to the query, using local property keys.
   *
   * Based on MSDynamicsSoapSelectQuery::propertyCondition().
   *
   * @param $property_name
   *  A local property. Ie, a key in the $entity_info 'property map' array.
   */
  function propertyCondition($property_name, $value, $operator = NULL) {

    // Make sure the entity base has been set up.
    if (!isset($this->entity_info)) {
      $this->throwException(
        'OURRESTREMOTESELECTQUERY_ENTITY_BASE_NOT_SET',
        'The query object was not set with an entity type.'
      );
    }

    // Make sure that the provided property is valid.
    if (!isset($this->entity_info['property map'][$property_name])) {
      $this->throwException(
        'OURRESTREMOTESELECTQUERY_INVALID_PROPERY',
        'The query object cannot set a non-existent property.'
      );
    }

    // Adding a field condition (probably) automatically makes this a multiple.
    // TODO: figure this out for sure!
    $this->retrieve_multiple = TRUE;

    // Use the property map to determine the remote field name.
    $remote_field_name = $this->entity_info['property map'][$property_name];

    // Set the condition for use during execution.
    $this->conditions[$this->remote_base][] = array(
      'field' => $remote_field_name,
      'value' => $value,
      'operator' => $operator,
    );
  }

  /**
   * Add a user id condition to the query.
   *
   * @param $user_id
   *   The user to search for appointments.
   */
  function useridCondition($user_id) {
    $this->user_id = $user_id;
  }
?>

<?php
  /**
   * Run the query and return a result.
   *
   * @return
   *  Remote entity objects as retrieved from the remote connection.
   */
  function execute() {

    // If there are any validation errors, don't perform a search.
    if (form_set_error()) {
      return array();
    }

    $querystring = array();

    $path = variable_get($this->base_entity_type . '_resource_name', '');

    // Iterate through all of the conditions and add them to the query.
    if (isset($this->conditions[$this->remote_base])) {
      foreach ($this->conditions[$this->remote_base] as $condition) {
        switch ($condition['field']) {
          case 'event_id':
            $querystring['eventId'] = $condition['value'];
            break;
          case 'login_id':
            $querystring['userId'] = $condition['value'];
            break;
        }
      }
    }

    // "From date" parameter.
    if (isset($this->from_date)) {
      $querystring['startDate'] = $this->from_date;
    }

    // "To date" parameter.
    if (isset($this->to_date)) {
      $querystring['endDate'] = $this->to_date;
    }

    // Add user id based filter if present.
    if (isset($this->user_id)) {
      $querystring['userId'] = $this->user_id;
    }

    // Assemble all of the query parameters.
    if (count($querystring)) {
      $path .= '?' . drupal_http_build_query($querystring);
    }

    // Make the request.
    try {
      $response = $this->connection->makeRequest($path, 'GET');
    } catch (Exception $e) {
      if ($e->getCode() == OUR_REST_LOGIN_REQUIRED_NO_SESSION) {
        drupal_set_message($e->getMessage());
        drupal_goto('user/login', array('query' => drupal_get_destination()));
      }
      elseif ($e->getCode() == OUR_REST_LOGIN_REQUIRED_TOKEN_EXPIRED) {

        // Logout
        global $user;
        module_invoke_all('user_logout', $user);
        session_destroy();

        // Redirect
        drupal_set_message($e->getMessage());
        drupal_goto('user/login', array('query' => drupal_get_destination()));
      }
    }

    switch($this->base_entity_type) {
      case 'siteshortname_entities_remote_event' :
        $entities = $this->parseEventResponse($response);
        break;
    }

    // Return the list of results.
    return $entities;
  }
?>

<?php
  /**
   * Helper for execute() which parses the JSON response for event entities.
   *
   * May also set the $total_record_count property on the query, if applicable.
   *
   * @param $response
   *  The JSON/XML/whatever response from the REST server.
   *
   * @return
   *  An list of entity objects, keyed numerically.
   *  An empty array is returned if the response contains no entities.
   *
   * @throws
   *  Exception if a fault is received when the REST call was made.
   */
  function parseEventResponse($response) {

    // Fetch the list of events.
    if ($response->code == 404) {
      // No data was returned so let's provide an empty list.
      $events = array();
    }
    else /* we have response data */ {

      // Convert the JSON (assuming that's what we're getting) into a PHP array.
      // Do any unmarshalling to convert the response data into a PHP array.
      $events = json_decode($response->data, TRUE);
    }

    // Initialize an empty list of entities for returning.
    $entities = array();

    // Iterate through each event.
    foreach ($events as $event) {
      $entities[] = (object) array(

        // Set event information.
        'event_id' => isset($event['id']) ? $event['id'] : NULL,
        'event_name' => isset($event['name']) ? $event['name'] : NULL,
        'event_date' => isset($event['date']) ? $event['date'] : NULL,
      );
    }

    // Return the newly-created list of entities.
    return $entities;
  }
?>

<?php
  /**
   * Throw an exception when there's a problem.
   *
   * @param string $code
   *   The error code.
   *
   * @param string $message
   *   A user-friendly message describing the problem.
   *
   * @throws Exception
   */
  function throwException($code, $message) {

    // Report error to the logs.
    watchdog('siteshortname_entities_remote', 'ERROR: OurRestRemoteSelectQuery: "@code", "@message".', array(
      '@code' => $code,
      '@message' => $message,
    ));

    // Throw an error with which callers must deal.
   throw new Exception(t("OurRestRemoteSelectQuery error, got message '@message'.", array(
      '@message' => $message,
    )), $code);
  }
?>

<?php
  /**
   * Build the query from an EntityFieldQuery object.
   *
   * To have our query work with Views using the EntityFieldQuery Views module,
   * which assumes EntityFieldQuery query objects, it's necessary to convert
   * from the EFQ so that we may execute this one instead.
   *
   * @param $efq
   *   The built-up EntityFieldQuery object.
   *
   * @return
   *   The current object.  Helpful for chaining methods.
   */
  function buildFromEFQ($efq) {

    // Copy all of the conditions.
    foreach ($efq->propertyConditions as $condition) {

      // Handle various conditions in different ways.
      switch ($condition['column']) {

        // Get the from date.
        case 'from_date' :
          $from_date = $condition['value'];
          // Convert the date to the correct format for the REST service
          $result = $from_date->format('Y/m/d');
          // The above format() can return FALSE in some cases, so add a check
          if ( $result ) {
            $this->from_date = $result;
          }
          break;

        // Get the to date.
        case 'to_date':
          $to_date = $condition['value'];
          // Convert the date to the correct format for the REST service
          $result = $to_date->format('Y/m/d');
          // The above format() can return FALSE in some cases, so add a check
          if ( $result ) {
            $this->to_date = $result;
          }
          break;

        // Get the user ID.
        case 'user_id':
          $this->user_id = $condition['value'];
          break;

        default:
          $this->conditions[$this->remote_base][] = array(
            'field' => $condition['column'],
            'value' => $condition['value'],
            'operator' => isset($condition['operator']) ? $condition['operator'] : NULL,
          );
          break;
      }
    }

    return $this;
  }
?>