aggregator.fetcher.inc

<?php


/**
 * @file
 * Fetcher functions for the aggregator module.
 */

/**
 * Implements hook_aggregator_fetch_info().
 */
function aggregator_aggregator_fetch_info() {
    return array(
        'title' => t('Default fetcher'),
        'description' => t('Downloads data from a URL using Drupal\'s HTTP request handler.'),
    );
}

/**
 * Implements hook_aggregator_fetch().
 */
function aggregator_aggregator_fetch($feed) {
    $feed->source_string = FALSE;
    // Generate conditional GET headers.
    $headers = array();
    if ($feed->etag) {
        $headers['If-None-Match'] = $feed->etag;
    }
    if ($feed->modified) {
        $headers['If-Modified-Since'] = gmdate(DATE_RFC7231, $feed->modified);
    }
    // Request feed.
    $result = drupal_http_request($feed->url, array(
        'headers' => $headers,
    ));
    // Process HTTP response code.
    switch ($result->code) {
        case 304:
            break;
        case 301:
            $feed->url = $result->redirect_url;
        // Do not break here.
        case 200:
        case 302:
        case 307:
            if (!isset($result->data)) {
                $result->data = '';
            }
            if (!isset($result->headers)) {
                $result->headers = array();
            }
            $feed->source_string = $result->data;
            $feed->http_headers = $result->headers;
            break;
        default:
            watchdog('aggregator', 'The feed from %site seems to be broken, due to "%error".', array(
                '%site' => $feed->title,
                '%error' => $result->code . ' ' . $result->error,
            ), WATCHDOG_WARNING);
            drupal_set_message(t('The feed from %site seems to be broken, because of error "%error".', array(
                '%site' => $feed->title,
                '%error' => $result->code . ' ' . $result->error,
            )));
    }
    return $feed->source_string === FALSE ? FALSE : TRUE;
}