connectedheartbeat.inc in Heartbeat 6.4

File

modules/friendlist_activity/connectedheartbeat.inc

<?php

/**
 * @file
 *   Relational heartbeat activity access object
 */
heartbeat_include('HeartbeatAccess');

/**
 * Class ConnectedHeartbeat
 * Concrete class to prepare messages for the current user
 * and all of his/her relations.
 *
 */
class ConnectedHeartbeat extends HeartbeatAccess {

  /**
   * proctected fuinction whoIsActor
   *   Add the heartbeat relations for the stream's active user.
   */
  protected function whoIsActor($account = NULL) {
    parent::whoIsActor($account);
    $this->stream->heartbeat_relations = heartbeat_get_related_uids($this->stream->uid);
  }

  /**
   * Override dressupMessages to change the query.
   * @see HeartbeatAccess::dressUpMessages().
   */
  public function dressUpMessages(HeartbeatParser $heartbeat) {
    if (!empty($this->stream->heartbeat_relations)) {

      // filter activity for related users and activity that was addressed to the current user.
      $sql = " AND ((ua.uid in( %s ) AND ua.access >= 0) OR (ua.uid_target = %d AND ua.nid <> 0))";
      $heartbeat->raw_messages = $this
        ->resultSql($sql, array(
        implode(',', $this->stream->heartbeat_relations),
        $this->stream->uid,
      ));
    }
    else {
      $heartbeat->raw_messages = array();
    }
    return $heartbeat;
  }

  /**
   * Function to add a part of a sql to a query built by views UI
   *
   * @param object $view The view handler object by reference to add our part to the query
   */
  public function addViewQuery(&$view) {

    // Make the sql limited to the access
    $field = "{$view->table_alias}.{$view->real_field}";
    if (!empty($this->stream->heartbeat_relations)) {
      $view->query
        ->set_where_group('OR', 'orgroup');
      $sql = "{$field} in( " . implode(',', $this->stream->heartbeat_relations) . " ) AND {$view->table_alias}.access >= 0 ";
      $view->query
        ->add_where('orgroup', $sql);
      $sql = "{$view->table_alias}.uid_target = %d AND {$view->table_alias}.nid <> 0";
      $view->query
        ->add_where('orgroup', $sql, $this->_uid);
    }
    else {
      $view->query
        ->add_where('deny', "{$view->table_alias}.access < 0");
    }
  }

}

Classes

Name	Description
ConnectedHeartbeat	Class ConnectedHeartbeat Concrete class to prepare messages for the current user and all of his/her relations.