| 1 |
|
| 2 |
|
| 3 |
|
| 4 |
|
| 5 |
|
| 6 |
|
| 7 |
|
| 8 |
|
| 9 |
|
| 10 |
|
| 11 |
|
| 12 |
function aggregator_aggregator_fetch_info() {
|
| 13 |
|
| 14 |
'title' => t('Default fetcher'),
|
| 15 |
'description' => t('Downloads data from a URL using Drupal\'s HTTP request handler.'),
|
| 16 |
);
|
| 17 |
}
|
| 18 |
|
| 19 |
|
| 20 |
|
| 21 |
|
| 22 |
function aggregator_aggregator_fetch($feed) {
|
| 23 |
$feed->source_string = FALSE;
|
| 24 |
|
| 25 |
|
| 26 |
$headers = array();
|
| 27 |
if ($feed->etag) {
|
| 28 |
$headers['If-None-Match'] = $feed->etag;
|
| 29 |
}
|
| 30 |
if ($feed->modified) {
|
| 31 |
$headers['If-Modified-Since'] = gmdate('D, d M Y H:i:s', $feed->modified) . ' GMT';
|
| 32 |
}
|
| 33 |
|
| 34 |
|
| 35 |
$result = drupal_http_request($feed->url, array('headers' => $headers));
|
| 36 |
|
| 37 |
|
| 38 |
|
| 39 |
switch ($result->code) {
|
| 40 |
case 304:
|
| 41 |
db_update('aggregator_feed')
|
| 42 |
->fields(array('checked' => REQUEST_TIME))
|
| 43 |
->condition('fid', $feed->fid)
|
| 44 |
->execute();
|
| 45 |
drupal_set_message(t('There is no new syndicated content from %site.', array('%site' => $feed->title)));
|
| 46 |
break;
|
| 47 |
case 301:
|
| 48 |
$feed->url = $result->redirect_url;
|
| 49 |
$feed->redirected = TRUE;
|
| 50 |
|
| 51 |
case 200:
|
| 52 |
case 302:
|
| 53 |
case 307:
|
| 54 |
|
| 55 |
|
| 56 |
|
| 57 |
if (!isset($result->data)) {
|
| 58 |
$result->data = '';
|
| 59 |
}
|
| 60 |
if (!isset($result->headers)) {
|
| 61 |
$result->headers = array();
|
| 62 |
}
|
| 63 |
$md5 = md5($result->data);
|
| 64 |
if ($feed->hash == $md5) {
|
| 65 |
db_update('aggregator_feed')
|
| 66 |
->condition('fid', $feed->fid)
|
| 67 |
->fields(array('checked' => REQUEST_TIME))
|
| 68 |
->execute();
|
| 69 |
drupal_set_message(t('There is no new syndicated content from %site.', array('%site' => $feed->title)));
|
| 70 |
break;
|
| 71 |
}
|
| 72 |
|
| 73 |
$feed->source_string = $result->data;
|
| 74 |
$feed->http_headers = $result->headers;
|
| 75 |
break;
|
| 76 |
default:
|
| 77 |
watchdog('aggregator', 'The feed from %site seems to be broken, due to "%error".', array('%site' => $feed->title, '%error' => $result->code . ' ' . $result->error), WATCHDOG_WARNING);
|
| 78 |
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)));
|
| 79 |
}
|
| 80 |
}
|
| 81 |
|