Weblabor

/**
 * Fetches the surrounding objects.
 */
function get_surrounding_objects($object, $range = 1) {
  $items = &drupal_static(__FUNCTION__, array());
  $surround = 10;
  $bid = intval($object->bid);
  $table = 'object_data';
  $cid_start = $table . '_start';
  $cid_end = $table . '_end';
  $cid = $table . '_item_' . $bid;
  if (!isset($items[$bid])) {
    // Check if the data is already cached and load it if necessary.
    if ($cache = cache_get($cid)) {
      $items[$bid] = $cache->data;
    }
    else {
      $items[$bid] = array(
        'before' => array(),
        'after' => array(),
      );

      // Get items before.
      $query = db_select($table, 'd');
      $result = $query->fields('d')->condition('d.bid', $bid, '<')->orderBy('d.bid', 'DESC')->range(0, $surround)->execute();
      foreach ($result as $item) {
        $items[$bid]['before'][$item->bid] = $item;
      }

      // Get items after.
      $query = db_select($table, 'd');
      $result = $query->fields('d')->condition('d.bid', $bid, '>')->orderBy('d.bid', 'ASC')->range(0, $surround)->execute();
      foreach ($result as $item) {
        $items[$bid]['after'][$item->bid] = $item;
      }

      // If we have less items before then needed, add items from the end.
      $needed_before = $surround - count($items[$bid]['before']);
      if ($needed_before > 0) {
        // Get items at end.
        $end = array();
        if ($cache = cache_get($cid_end)) {
          $end = $cache->data;
        }
        else {
          $query = db_select($table, 'd');
          $result = $query->fields('d')->orderBy('d.bid', 'DESC')->range(0, $surround)->execute();
          foreach ($result as $item) {
            $end[$item->bid] = $item;
          }
          array_reverse($end, TRUE);
          cache_set($cid_end, $end);
        }

        $items[$bid]['before'] += array_slice($end, -$needed_before, $needed_before, TRUE);
      }

      // If we have less items after then needed, add items from the start.
      $needed_after = $surround - count($items[$bid]['after']);
      if ($needed_after > 0) {
        // Get items at start.
        $start = array();
        if ($cache = cache_get($cid_start)) {
          $start = $cache->data;
        }
        else {
          $query = db_select($table, 'd');
          $result = $query->fields('d')->orderBy('d.bid', 'ASC')->range(0, $surround)->execute();
          foreach ($result as $item) {
            $start[$item->bid] = $item;
          }
          cache_set($cid_start, $start);
        }

        $items[$bid]['after'] += array_slice($start, 0, $needed_after, TRUE);
      }

      // Add the file info if present.
      foreach ($items[$bid] as $position => $elements) {
        foreach ($items[$bid][$position] as &$item) {
          if (!empty($item->fid)) {
            $item->image = file_load($item->fid);
          }
        }
      }

      // Store the items to cache.
      cache_set($cid, $items[$bid]);
    }
  }
  return array(
    'before' => array_slice($items[$bid]['before'], 0, $range, TRUE),
    'after' => array_slice($items[$bid]['after'], 0, $range, TRUE),
    'current' => $object,
  );
}