CiviCRM Contact and Drupal Search API

/**
 * Implements hook_search_api_alter_callback_info().
 */
function sample_module_search_api_alter_callback_info() {
  $callbacks = array();
 
  $callbacks['my_filter_name'] = array(
    'name' => t('Sample index filter process'),
    'description' => t('My entry into the index process so I can customize the items being indexed.'),
    'class' => 'SampleSearchApiIndexFilter',
    // We need this thing to run before others. Set it to a very low weight.
    'weight' => -50,
  );
 
  return $callbacks;
}

class SampleSearchApiIndexFilter extends SearchApiAbstractAlterCallback {
 
  /**
   * {@inheritdoc}
   */
  public function supportsIndex(SearchApiIndex $index) {
    return $this->isCiviContactIndex($index);
  }
 
  /**
   * {@inheritdoc}
   */
  public function alterItems(array &$items) {
    // Make sure we're running on the supported type of indexes.
    if (!$this->supportsIndex($this->index)) {
      return;
    }
 
    // $index_fields = $this->index->getFields(); /* Not needed in example. */
 
    foreach ($items as $id => $item) {
      // Super important! We need to index data on teh $item->civicrm_user
      // object but for some reason, it never gets populated
      $item->civicrm_user = self::getUserAccount($item->contact_id);
    }
  }
 
  /**
   * {@inheritdoc}
   */
  public function configurationForm() {
    return parent::configurationForm();
  }
 
  /**
   * {@inheritdoc}
   */
  public function configurationFormSubmit(array $form, array &$values, array &$form_state) {
    return parent::configurationFormSubmit($form, $values, $form_state);
  }
 
  /**
   * Detects whether the $index is based on a CiviCRM Contact entity.
   *
   * @param \SearchApiIndex|NULL $index
   * @return bool
   */
  protected function isCiviContactIndex(SearchApiIndex $index = null) {
    $data_source = $index->datasource();
    return $data_source->getEntityType() == 'civicrm_contact';
  }
 
 
  static function getUserAccount($contact_id) {
    $uid = db_select('civicrm_uf_match', 'm')
      ->fields('m', array('uf_id'))
      ->condition('m.contact_id', $contact_id)
      ->execute()->fetchCol();
 
    if(!empty($uid)) {
      return user_load(reset($uid));
    }
 
    return null;
  }
}
 

files[] = SampleSearchApiIndexFilter.inc

drush cc all