'),
'#description' => t('The list of tags which are allowed in feeds, i.e., which will not be removed by Drupal.')
);
$form['aggregator_summary_items1'] = array(
'#type' => 'select', '#title' => t('Items shown in categories pages') ,
'#default_value' => variable_get('aggregator_summary_summary_items', 3), '#options' => $items,
'#description' => t('The number of items which will be shown with each feed or category in the feed and category summary pages.')
);
$form['aggregator_summary_clear'] = array(
'#type' => 'select', '#title' => t('Discard news items older than'),
'#default_value' => variable_get('aggregator_summary_clear', 9676800), '#options' => $period,
'#description' => t('Older news items will be automatically discarded. Requires crontab.')
);
return system_settings_form($form);
}
/**
* Implementation of hook_perm().
*/
function aggregator_summary_perm()
{
return array('administer news feeds', 'access news feeds');
}
/**
* Implementation of hook_cron().
*
* Checks news feeds for updates once their refresh interval has elapsed.
*/
function aggregator_summary_cron()
{
$result = db_query('SELECT * FROM {aggregator_summary_feed} WHERE checked + refresh < %d', time());
while ($feed = db_fetch_array($result))
{
aggregator_summary_refresh($feed);
}
}
/**
* Implementation of hook_block().
*
* Generates blocks for the latest news items in each category and feed.
*/
function aggregator_summary_block($op = 'list', $delta = 0, $edit = array())
{
if (user_access('access news feeds'))
{
if ($op == 'list')
{
$result = db_query('SELECT cid, title FROM {aggregator_summary_category} ORDER BY title');
while ($category = db_fetch_object($result))
{
$block['category-'. $category->cid]['info'] = t('!title category latest items', array('!title' => $category->title));
}
$result = db_query('SELECT fid, title FROM {aggregator_summary_feed} ORDER BY fid');
while ($feed = db_fetch_object($result)) {
$block['feed-'. $feed->fid]['info'] = t('!title feed latest items', array('!title' => $feed->title));
}
}
else if ($op == 'configure')
{
list($type, $id) = explode('-', $delta);
if ($type == 'category')
{
$value = db_result(db_query('SELECT block FROM {aggregator_summary_category} WHERE cid = %d', $id));
}
else
{
$value = db_result(db_query('SELECT block FROM {aggregator_summary_feed} WHERE fid = %d', $id));
}
$form['block'] = array('#type' => 'select', '#title' => t('Number of news items in block'), '#default_value' => $value, '#options' => drupal_map_assoc(array(2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20)));
return $form;
}
else if ($op == 'save')
{
list($type, $id) = explode('-', $delta);
if ($type == 'category')
{
$value = db_query('UPDATE {aggregator_summary_category} SET block = %d WHERE cid = %d', $edit['block'], $id);
}
else
{
$value = db_query('UPDATE {aggregator_summary_feed} SET block = %d WHERE fid = %d', $edit['block'], $id);
}
}
else if ($op == 'view')
{
list($type, $id) = explode('-', $delta);
switch ($type)
{
case 'feed':
if ($feed = db_fetch_object(db_query('SELECT fid, title, block FROM {aggregator_summary_feed} WHERE fid = %d', $id)))
{
$block['subject'] = check_plain($feed->title);
$result = db_query_range('SELECT * FROM {aggregator_summary_item} WHERE fid = %d ORDER BY timestamp DESC, iid DESC', $feed->fid, 0, $feed->block);
$read_more = ''. l(t('more'), 'aggregator_summary/sources/'. $feed->fid, array('title' => t("View this feed's recent news."))) .'
';
}
break;
case 'category':
if ($category = db_fetch_object(db_query('SELECT cid, title, block FROM {aggregator_summary_category} WHERE cid = %d', $id)))
{
$block['subject'] = check_plain($category->title);
$result = db_query_range('SELECT i.* FROM {aggregator_summary_category_item} ci LEFT JOIN {aggregator_summary_item} i ON ci.iid = i.iid WHERE ci.cid = %d ORDER BY i.timestamp DESC, i.iid DESC', $category->cid, 0, $category->block);
$read_more = ''. l(t('more'), 'aggregator_summary/categories/'. $category->cid, array('title' => t("View this category's recent news."))) .'
';
}
break;
}
$items = array();
while ($item = db_fetch_object($result))
{
$items[] = theme('aggregator_summary_block_item', $item);
}
// Only display the block if there are items to show.
if (count($items) > 0)
{
$block['content'] = theme('item_list', $items) . $read_more;
}
}
return $block;
}
}
/**
* Generate a form to add/edit/delete aggregator categories.
*/
function aggregator_summary_form_category($edit = array())
{
$form['title'] = array('#type' => 'textfield',
'#title' => t('Title'),
'#default_value' => $edit['title'],
'#maxlength' => 64,
'#required' => TRUE,
);
$form['item_perpage'] = array('#type' => 'textfield',
'#title' => t('No of feeds per page'),
'#default_value' => $edit['item_perpage'],
'#maxlength' => 64,
'#required' => TRUE,
);
$form['description'] = array('#type' => 'textarea',
'#title' => t('Description'),
'#default_value' => $edit['description'],
);
$form['submit'] = array('#type' => 'submit', '#value' => t('Submit'));
if ($edit['cid'])
{
$form['delete'] = array('#type' => 'submit', '#value' => t('Delete'));
$form['cid'] = array('#type' => 'hidden', '#value' => $edit['cid']);
}
return $form;
}
/**
* Validate aggregator_summary_form_feed form submissions.
*/
function aggregator_summary_form_category_validate($form_id, $form_values)
{
if ($form_values['op'] == t('Submit'))
{
// Check for duplicate titles
if (isset($form_values['cid']))
{
$category = db_fetch_object(db_query("SELECT cid FROM {aggregator_summary_category} WHERE title = '%s' AND cid != %d", $form_values['title'], $form_values['cid']));
}
else
{
$category = db_fetch_object(db_query("SELECT cid FROM {aggregator_summary_category} WHERE title = '%s'", $form_values['title']));
}
if ($category)
{
form_set_error('title', t('A category named %category already exists. Please enter a unique title.', array('%category' => $form_values['title'])));
}
}
}
/**
* Process aggregator_summary_form_category form submissions.
* @todo Add delete confirmation dialog.
*/
function aggregator_summary_form_category_submit($form_id, $form_values) {
if ($_POST['op'] == t('Delete')) {
$title = $form_values['title'];
// Unset the title:
unset($form_values['title']);
}
aggregator_summary_save_category($form_values);
menu_rebuild();
if (isset($form_values['cid'])) {
if (isset($form_values['title'])) {
drupal_set_message(t('The category %category has been updated.', array('%category' => theme('placeholder', $form_values['title']))));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
else {
return 'aggregator_summary/categories/'. $form_values['cid'];
}
}
else {
watchdog('aggregator', t('Category %category deleted.', array('%category' => theme('placeholder', $title))));
drupal_set_message(t('The category %category has been deleted.', array('%category' => theme('placeholder', $title))));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
else {
return 'aggregator_summary/categories/';
}
}
}
else {
watchdog('aggregator', t('Category %category added.', array('%category' => theme('placeholder', $form_values['title']))), WATCHDOG_NOTICE, l(t('view'), 'admin/content/aggregator_summary'));
drupal_set_message(t('The category %category has been added.', array('%category' => theme('placeholder', $form_values['title']))));
}}
/**
* Add/edit/delete aggregator categories.
*/
function aggregator_summary_save_category($edit) {
if ($edit['cid'] && $edit['title']) {
db_query("UPDATE {aggregator_summary_category} SET title = '%s', item_perpage = %d, description = '%s' WHERE cid = %d", $edit['title'], $edit['item_perpage'],$edit['description'], $edit['cid']);
}
else if ($edit['cid']) {
db_query('DELETE FROM {aggregator_summary_category} WHERE cid = %d', $edit['cid']);
}
else if ($edit['title']) {
// A single unique id for bundles and feeds, to use in blocks
$next_id = db_next_id('{aggregator_summary_category}_cid');
db_query("INSERT INTO {aggregator_summary_category} (cid, title,item_perpage, description, block) VALUES (%d, '%s', %d , '%s', 5)", $next_id, $edit['title'],$edit['item_perpage'], $edit['description']);
}
}
/**
* Generate a form to add/edit feed sources.
*/
function aggregator_summary_form_feed($edit = array()) {
$period = drupal_map_assoc(array(900, 1800, 3600, 7200, 10800, 21600, 32400, 43200, 64800, 86400, 172800, 259200, 604800, 1209600, 2419200), 'format_interval');
if ($edit['refresh'] == '') {
$edit['refresh'] = 3600;
}
$form['title'] = array('#type' => 'textfield',
'#title' => t('Title'),
'#default_value' => $edit['title'],
'#maxlength' => 255,
'#description' => t('The name of the feed; typically the name of the web site you syndicate content from.'),
'#required' => TRUE,
);
$form['url'] = array('#type' => 'textfield',
'#title' => t('URL'),
'#default_value' => $edit['url'],
'#maxlength' => 255,
'#description' => t('The fully-qualified URL of the feed.'),
'#required' => TRUE,
);
$form['refresh'] = array('#type' => 'select',
'#title' => t('Update interval'),
'#default_value' => $edit['refresh'],
'#options' => $period,
'#description' => t('The refresh interval indicating how often you want to update this feed. Requires crontab.'),
);
// Handling of categories:
$options = array();
$values = array();
$categories = db_query('SELECT c.cid, c.title, f.fid FROM {aggregator_summary_category} c LEFT JOIN {aggregator_summary_category_feed} f ON c.cid = f.cid AND f.fid = %d ORDER BY title', $edit['fid']);
while ($category = db_fetch_object($categories)) {
$options[$category->cid] = check_plain($category->title);
if ($category->fid) $values[] = $category->cid;
}
if ($options) {
$form['category'] = array('#type' => 'checkboxes',
'#title' => t('Categorize news items'),
'#default_value' => $values,
'#options' => $options,
'#description' => t('New items in this feed will be automatically filed in the checked categories as they are received.'),
);
}
$form['submit'] = array('#type' => 'submit', '#value' => t('Submit'));
if ($edit['fid']) {
$form['delete'] = array('#type' => 'submit', '#value' => t('Delete'));
$form['fid'] = array('#type' => 'hidden', '#value' => $edit['fid']);
}
return $form;
}
/**
* Validate aggregator_summary_form_feed form submissions.
*/
function aggregator_summary_form_feed_validate($form_id, $form_values) {
if ($form_values['op'] == t('Submit')) {
// Check for duplicate titles
if (isset($form_values['fid'])) {
$result = db_query("SELECT title, url FROM {aggregator_summary_feed} WHERE (title = '%s' OR url='%s') AND fid != %d", $form_values['title'], $form_values['url'], $form_values['fid']);
}
else {
$result = db_query("SELECT title, url FROM {aggregator_summary_feed} WHERE title = '%s' OR url='%s'", $form_values['title'], $form_values['url']);
}
while ($feed = db_fetch_object($result)) {
if (strcasecmp($feed->title, $form_values['title']) == 0) {
form_set_error('title', t('A feed named %feed already exists. Please enter a unique title.', array('%feed' => $form_values['title'])));
}
if (strcasecmp($feed->url, $form_values['url']) == 0) {
form_set_error('url', t('A feed with this URL %url already exists. Please enter a unique URL.', array('%url' => $form_values['url'])));
}
}
}
}
/**
* Process aggregator_summary_form_feed form submissions.
* @todo Add delete confirmation dialog.
*/
function aggregator_summary_form_feed_submit($form_id, $form_values) {
if ($form_values['op'] == t('Delete')) {
$title = $form_values['title'];
// Unset the title:
unset($form_values['title']);
}
aggregator_summary_save_feed($form_values);
menu_rebuild();
if (isset($form_values['fid'])) {
if (isset($form_values['title'])) {
drupal_set_message(t('The feed %feed has been updated.', array('%feed' => $form_values['title'])));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
else {
return 'aggregator_summary/sources/'. $form_values['fid'];
}
}
else {
watchdog('aggregator', t('Feed %feed deleted.', array('%feed' => $title)));
drupal_set_message(t('The feed %feed has been deleted.', array('%feed' => $title)));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
else {
return 'aggregator_summary/sources/';
}
}
}
else {
watchdog('aggregator', t('Feed %feed added.', array('%feed' => $form_values['title'])), WATCHDOG_NOTICE, l(t('view'), 'admin/content/aggregator_summary'));
drupal_set_message(t('The feed %feed has been added.', array('%feed' => $form_values['title'])));
}
}
/**
* Add/edit/delete an aggregator feed.
*/
function aggregator_summary_save_feed($edit) {
if ($edit['fid']) {
// An existing feed is being modified, delete the category listings.
db_query('DELETE FROM {aggregator_summary_category_feed} WHERE fid = %d', $edit['fid']);
}
if ($edit['fid'] && $edit['title']) {
db_query("UPDATE {aggregator_summary_feed} SET title = '%s', url = '%s', refresh = %d WHERE fid = %d", $edit['title'], $edit['url'], $edit['refresh'], $edit['fid']);
}
else if ($edit['fid']) {
$result = db_query('SELECT iid FROM {aggregator_summary_item} WHERE fid = %d', $edit['fid']);
while ($item = db_fetch_object($result)) {
$items[] = "iid = $item->iid";
}
if ($items) {
db_query('DELETE FROM {aggregator_summary_category_item} WHERE '. implode(' OR ', $items));
}
db_query('DELETE FROM {aggregator_summary_feed} WHERE fid = %d', $edit['fid']);
db_query('DELETE FROM {aggregator_summary_item} WHERE fid = %d', $edit['fid']);
}
else if ($edit['title']) {
// A single unique id for bundles and feeds, to use in blocks.
$edit['fid'] = db_next_id('{aggregator_summary_feed}_fid');
db_query("INSERT INTO {aggregator_summary_feed} (fid, title, url, refresh, block) VALUES (%d, '%s', '%s', %d, 5)", $edit['fid'], $edit['title'], $edit['url'], $edit['refresh']);
}
if ($edit['title']) {
// The feed is being saved, save the categories as well.
if ($edit['category']) {
foreach ($edit['category'] as $cid => $value) {
if ($value) {
db_query('INSERT INTO {aggregator_summary_category_feed} (fid, cid) VALUES (%d, %d)', $edit['fid'], $cid);
}
}
}
}
}
function aggregator_summary_remove($feed) {
$result = db_query('SELECT iid FROM {aggregator_summary_item} WHERE fid = %d', $feed['fid']);
while ($item = db_fetch_object($result)) {
$items[] = "iid = $item->iid";
}
if ($items) {
db_query('DELETE FROM {aggregator_summary_category_item} WHERE '. implode(' OR ', $items));
}
db_query('DELETE FROM {aggregator_summary_item} WHERE fid = %d', $feed['fid']);
db_query("UPDATE {aggregator_summary_feed} SET checked = 0, etag = '', modified = 0 WHERE fid = %d", $feed['fid']);
drupal_set_message(t('The news items from %site have been removed.', array('%site' => $feed['title'])));
}
/**
* Call-back function used by the XML parser.
*/
function aggregator_summary_element_start($parser, $name, $attributes) {
global $item, $element, $tag, $items, $channel;
switch ($name) {
case 'IMAGE':
case 'TEXTINPUT':
case 'CONTENT':
case 'SUMMARY':
case 'TAGLINE':
case 'SUBTITLE':
case 'LOGO':
case 'INFO':
$element = $name;
break;
case 'ID':
if ($element != 'ITEM') {
$element = $name;
}
case 'LINK':
if ($attributes['REL'] == 'alternate') {
if ($element == 'ITEM') {
$items[$item]['LINK'] = $attributes['HREF'];
}
else {
$channel['LINK'] = $attributes['HREF'];
}
}
break;
case 'ITEM':
$element = $name;
$item += 1;
break;
case 'ENTRY':
$element = 'ITEM';
$item += 1;
break;
}
$tag = $name;
}
/**
* Call-back function used by the XML parser.
*/
function aggregator_summary_element_end($parser, $name) {
global $element;
switch ($name) {
case 'IMAGE':
case 'TEXTINPUT':
case 'ITEM':
case 'ENTRY':
case 'CONTENT':
case 'INFO':
$element = '';
break;
case 'ID':
if ($element == 'ID') {
$element = '';
}
}
}
/**
* Call-back function used by the XML parser.
*/
function aggregator_summary_element_data($parser, $data) {
global $channel, $element, $items, $item, $image, $tag;
switch ($element) {
case 'ITEM':
$items[$item][$tag] .= $data;
break;
case 'IMAGE':
case 'LOGO':
$image[$tag] .= $data;
break;
case 'LINK':
if ($data) {
$items[$item][$tag] .= $data;
}
break;
case 'CONTENT':
$items[$item]['CONTENT'] .= $data;
break;
case 'SUMMARY':
$items[$item]['SUMMARY'] .= $data;
break;
case 'TAGLINE':
case 'SUBTITLE':
$channel['DESCRIPTION'] .= $data;
break;
case 'INFO':
case 'ID':
case 'TEXTINPUT':
// The sub-element is not supported. However, we must recognize
// it or its contents will end up in the item array.
break;
default:
$channel[$tag] .= $data;
}
}
/**
* Checks a news feed for new items.
*/
function aggregator_summary_refresh($feed) {
global $channel, $image;
// Generate conditional GET headers.
$headers = array();
if ($feed['etag']) {
$headers['If-None-Match'] = $feed['etag'];
}
if ($feed['modified']) {
$headers['If-Modified-Since'] = gmdate('D, d M Y H:i:s', $feed['modified']) .' GMT';
}
// Request feed.
$result = drupal_http_request($feed['url'], $headers);
// Process HTTP response code.
switch ($result->code) {
case 304:
db_query('UPDATE {aggregator_summary_feed} SET checked = %d WHERE fid = %d', time(), $feed['fid']);
drupal_set_message(t('There is no new syndicated content from %site.', array('%site' => $feed['title'])));
break;
case 301:
$feed['url'] = $result->redirect_url;
watchdog('aggregator', t('Updated URL for feed %title to %url.', array('%title' => $feed['title'], '%url' => $feed['url'])));
case 200:
case 302:
case 307:
// Filter the input data:
if (aggregator_summary_parse_feed($result->data, $feed)) {
if ($result->headers['Last-Modified']) {
$modified = strtotime($result->headers['Last-Modified']);
}
/*
** Prepare the channel data:
*/
foreach ($channel as $key => $value) {
$channel[$key] = trim($value);
}
/*
** Prepare the image data (if any):
*/
foreach ($image as $key => $value) {
$image[$key] = trim($value);
}
if ($image['LINK'] && $image['URL'] && $image['TITLE']) {
// Note, we should really use theme_image() here but that only works with local images it won't work with images fetched with a URL unless PHP version > 5
$image = '!['. check_plain($image['TITLE']) .']('. check_url($image['URL']) .')
';
}
else {
$image = NULL;
}
/*
** Update the feed data:
*/
db_query("UPDATE {aggregator_summary_feed} SET url = '%s', checked = %d, link = '%s', description = '%s', image = '%s', etag = '%s', modified = %d WHERE fid = %d", $feed['url'], time(), $channel['LINK'], $channel['DESCRIPTION'], $image, $result->headers['ETag'], $modified, $feed['fid']);
/*
** Clear the cache:
*/
cache_clear_all();
watchdog('aggregator', t('There is new syndicated content from %site.', array('%site' => $feed['title'])));
drupal_set_message(t('There is new syndicated content from %site.', array('%site' => $feed['title'])));
}
break;
default:
watchdog('aggregator', t('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)));
}
}
/**
* Parse the W3C date/time format, a subset of ISO 8601. PHP date parsing
* functions do not handle this format.
* See http://www.w3.org/TR/NOTE-datetime for more information.
* Originally from MagpieRSS (http://magpierss.sourceforge.net/).
*
* @param $date_str A string with a potentially W3C DTF date.
* @return A timestamp if parsed successfully or -1 if not.
*/
function aggregator_summary_parse_w3cdtf($date_str) {
if (preg_match('/(\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2})(:(\d{2}))?(?:([-+])(\d{2}):?(\d{2})|(Z))?/', $date_str, $match)) {
list($year, $month, $day, $hours, $minutes, $seconds) = array($match[1], $match[2], $match[3], $match[4], $match[5], $match[6]);
// calc epoch for current date assuming GMT
$epoch = gmmktime($hours, $minutes, $seconds, $month, $day, $year);
if ($match[10] != 'Z') { // Z is zulu time, aka GMT
list($tz_mod, $tz_hour, $tz_min) = array($match[8], $match[9], $match[10]);
// zero out the variables
if (!$tz_hour) {
$tz_hour = 0;
}
if (!$tz_min) {
$tz_min = 0;
}
$offset_secs = (($tz_hour * 60) + $tz_min) * 60;
// is timezone ahead of GMT? then subtract offset
if ($tz_mod == '+') {
$offset_secs *= -1;
}
$epoch += $offset_secs;
}
return $epoch;
}
else {
return FALSE;
}
}
function aggregator_summary_parse_feed(&$data, $feed) {
global $items, $image, $channel;
// Unset the global variables before we use them:
unset($GLOBALS['element'], $GLOBALS['item'], $GLOBALS['tag']);
$items = array();
$image = array();
$channel = array();
// parse the data:
$xml_parser = drupal_xml_parser_create($data);
xml_set_element_handler($xml_parser, 'aggregator_summary_element_start', 'aggregator_summary_element_end');
xml_set_character_data_handler($xml_parser, 'aggregator_summary_element_data');
if (!xml_parse($xml_parser, $data, 1)) {
watchdog('aggregator', t('The feed from %site seems to be broken, due to an error "%error" on line %line.', array('%site' => $feed['title'], '%error' => xml_error_string(xml_get_error_code($xml_parser)), '%line' => xml_get_current_line_number($xml_parser))), WATCHDOG_WARNING);
drupal_set_message(t('The feed from %site seems to be broken, because of error "%error" on line %line.', array('%site' => $feed['title'], '%error' => xml_error_string(xml_get_error_code($xml_parser)), '%line' => xml_get_current_line_number($xml_parser))), 'error');
return 0;
}
xml_parser_free($xml_parser);
/*
** We reverse the array such that we store the first item last,
** and the last item first. In the database, the newest item
** should be at the top.
*/
$items = array_reverse($items);
// Initialize variables
$title = $link = $author = $description = $guid = NULL;
foreach ($items as $item) {
unset($title, $link, $author, $description, $guid);
// Prepare the item:
foreach ($item as $key => $value) {
$item[$key] = trim($value);
}
/*
** Resolve the item's title. If no title is found, we use
** up to 40 characters of the description ending at a word
** boundary but not splitting potential entities.
*/
if ($item['TITLE']) {
$title = $item['TITLE'];
}
else {
$title = preg_replace('/^(.*)[^\w;&].*?$/', "\\1", truncate_utf8($item['DESCRIPTION'], 40));
}
/*
** Resolve the items link.
*/
if ($item['LINK']) {
$link = $item['LINK'];
}
else {
$link = $feed['link'];
}
if ($item['GUID']) {
$guid = $item['GUID'];
}
/**
* Atom feeds have a CONTENT and/or SUMMARY tag instead of a DESCRIPTION tag
*/
if ($item['CONTENT:ENCODED']) {
$item['DESCRIPTION'] = $item['CONTENT:ENCODED'];
}
else if ($item['SUMMARY']) {
$item['DESCRIPTION'] = $item['SUMMARY'];
}
else if ($item['CONTENT']) {
$item['DESCRIPTION'] = $item['CONTENT'];
}
/*
** Try to resolve and parse the item's publication date. If no
** date is found, we use the current date instead.
*/
if ($item['PUBDATE']) $date = $item['PUBDATE']; // RSS 2.0
else if ($item['DC:DATE']) $date = $item['DC:DATE']; // Dublin core
else if ($item['DCTERMS:ISSUED']) $date = $item['DCTERMS:ISSUED']; // Dublin core
else if ($item['DCTERMS:CREATED']) $date = $item['DCTERMS:CREATED']; // Dublin core
else if ($item['DCTERMS:MODIFIED']) $date = $item['DCTERMS:MODIFIED']; // Dublin core
else if ($item['ISSUED']) $date = $item['ISSUED']; // Atom XML
else if ($item['CREATED']) $date = $item['CREATED']; // Atom XML
else if ($item['MODIFIED']) $date = $item['MODIFIED']; // Atom XML
else if ($item['PUBLISHED']) $date = $item['PUBLISHED']; // Atom XML
else if ($item['UPDATED']) $date = $item['UPDATED']; // Atom XML
else $date = 'now';
$timestamp = strtotime($date); // As of PHP 5.1.0, strtotime returns FALSE on failure instead of -1.
if ($timestamp <= 0) {
$timestamp = aggregator_summary_parse_w3cdtf($date); // Returns FALSE on failure
if (!$timestamp) {
$timestamp = time(); // better than nothing
}
}
/*
** Save this item. Try to avoid duplicate entries as much as
** possible. If we find a duplicate entry, we resolve it and
** pass along it's ID such that we can update it if needed.
*/
if ($guid) {
$entry = db_fetch_object(db_query("SELECT iid FROM {aggregator_summary_item} WHERE fid = %d AND guid = '%s'", $feed['fid'], $guid));
}
else if ($link && $link != $feed['link'] && $link != $feed['url']) {
$entry = db_fetch_object(db_query("SELECT iid FROM {aggregator_summary_item} WHERE fid = %d AND link = '%s'", $feed['fid'], $link));
}
else {
$entry = db_fetch_object(db_query("SELECT iid FROM {aggregator_summary_item} WHERE fid = %d AND title = '%s'", $feed['fid'], $title));
}
aggregator_summary_save_item(array('iid' => $entry->iid, 'fid' => $feed['fid'], 'timestamp' => $timestamp, 'title' => $title, 'link' => $link, 'author' => $item['AUTHOR'], 'description' => $item['DESCRIPTION'], 'guid' => $guid));
}
/*
** Remove all items that are older than flush item timer:
*/
$age = time() - variable_get('aggregator_summary_clear', 9676800);
$result = db_query('SELECT iid FROM {aggregator_summary_item} WHERE fid = %d AND timestamp < %d', $feed['fid'], $age);
if (db_num_rows($result)) {
$items = array();
while ($item = db_fetch_object($result)) {
$items[] = $item->iid;
}
db_query('DELETE FROM {aggregator_summary_category_item} WHERE iid IN ('. implode(', ', $items) .')');
db_query('DELETE FROM {aggregator_summary_item} WHERE fid = %d AND timestamp < %d', $feed['fid'], $age);
}
return 1;
}
function aggregator_summary_save_item($edit) {
if ($edit['iid'] && $edit['title']) {
db_query("UPDATE {aggregator_summary_item} SET title = '%s', link = '%s', author = '%s', description = '%s', guid = '%s', timestamp = %d WHERE iid = %d", $edit['title'], $edit['link'], $edit['author'], $edit['description'], $edit['iid'], $edit['timestamp'], $edit['gid']);
}
else if ($edit['iid']) {
db_query('DELETE FROM {aggregator_summary_item} WHERE iid = %d', $edit['iid']);
db_query('DELETE FROM {aggregator_summary_category_item} WHERE iid = %d', $edit['iid']);
}
else if ($edit['title'] && $edit['link']) {
$edit['iid'] = db_next_id('{aggregator_summary_item}_iid');
db_query("INSERT INTO {aggregator_summary_item} (iid, fid, title, link, author, description, timestamp, guid) VALUES (%d, %d, '%s', '%s', '%s', '%s', %d, '%s')", $edit['iid'], $edit['fid'], $edit['title'], $edit['link'], $edit['author'], $edit['description'], $edit['timestamp'], $edit['guid']);
// file the items in the categories indicated by the feed
$categories = db_query('SELECT cid FROM {aggregator_summary_category_feed} WHERE fid = %d', $edit['fid']);
while ($category = db_fetch_object($categories)) {
db_query('INSERT INTO {aggregator_summary_category_item} (cid, iid) VALUES (%d, %d)', $category->cid, $edit['iid']);
}
}
}
function aggregator_summary_get_feed($fid) {
return db_fetch_array(db_query('SELECT * FROM {aggregator_summary_feed} WHERE fid = %d', $fid));
}
function aggregator_summary_get_item($iid) {
return db_fetch_array(db_query('SELECT * FROM {aggregator_summary_item} WHERE iid = %d', $iid));
}
function aggregator_summary_get_category($cid) {
return db_fetch_array(db_query('SELECT * FROM {aggregator_summary_category} WHERE cid = %d', $cid));
}
function aggregator_summary_view()
{
$result = db_query('SELECT f.*, COUNT(i.iid) AS items FROM {aggregator_summary_feed} f LEFT JOIN {aggregator_summary_item} i ON f.fid = i.fid GROUP BY f.fid, f.title, f.url, f.refresh, f.checked, f.link, f.description, f.etag, f.modified, f.image, f.block ORDER BY f.title');
$output = ''. t('Feed overview') .'
';
$header = array(t('Title'), t('Items'), t('Last update'), t('Next update'), array('data' => t('Operations'), 'colspan' => '4'));
$rows = array();
while ($feed = db_fetch_object($result))
{
$rows[] = array(l($feed->title, "aggregator_summary/sources/$feed->fid"), format_plural($feed->items, '1 item', '@count items'), ($feed->checked ? t('@time ago', array('@time' => format_interval(time() - $feed->checked))) : t('never')), ($feed->checked ? t('%time left', array('%time' => format_interval($feed->checked + $feed->refresh - time()))) : t('never')), l(t('edit'), "admin/content/aggregator_summary/edit/feed/$feed->fid"), l(t('remove items'), "admin/content/aggregator_summary/remove/$feed->fid"), l(t('update items'), "admin/content/aggregator_summary/update/$feed->fid"),l(t('edit items'), "admin/content/aggregator_summary/edit/items/$feed->fid"));
}
$output .= theme('table', $header, $rows);
$result = db_query('SELECT c.cid, c.title, count(ci.iid) as items FROM {aggregator_summary_category} c LEFT JOIN {aggregator_summary_category_item} ci ON c.cid = ci.cid GROUP BY c.cid, c.title ORDER BY title');
$output .= ''. t('Category overview') .'
';
$header = array(t('Title'), t('Items'), t('Operations'));
$rows = array();
while ($category = db_fetch_object($result))
{
$rows[] = array(l($category->title, "aggregator_summary/categories/$category->cid"), format_plural($category->items, '1 item', '@count items'), l(t('edit'), "admin/content/aggregator_summary/edit/category/$category->cid"));
}
$output .= theme('table', $header, $rows);
$result = db_query('SELECT s.sid, s.sname as section FROM {aggregator_summary_section} s ORDER BY s.sname');
$output .= ''. t('Section overview') .'
';
$header = array(t('Name'), t('Operations'));
$rows = array();
while ($section = db_fetch_object($result))
{
$rows[] = array(t($section->section), l(t('edit'), "admin/content/aggregator_summary/edit/section/$section->sid"));
}
$output .= theme('table', $header, $rows);
return $output;
}
/**
* Menu callback; removes all items from a feed, then redirects to the overview page.
*/
function aggregator_summary_admin_remove_feed($feed) {
aggregator_summary_remove(aggregator_summary_get_feed($feed));
drupal_goto('admin/content/aggregator_summary');
}
/**
* Menu callback; refreshes a feed, then redirects to the overview page.
*/
function aggregator_summary_admin_refresh_feed($feed) {
aggregator_summary_refresh(aggregator_summary_get_feed($feed));
drupal_goto('admin/content/aggregator_summary');
}
/**
* Menu callback; displays the aggregator administration page.
*/
function aggregator_summary_admin_overview() {
return aggregator_summary_view();
}
/**
* Menu callback; displays the most recent items gathered from any feed.
*/
function aggregator_summary_page_last() {
drupal_add_feed(url('aggregator_summary/rss'), variable_get('site_name', 'Drupal') . ' ' . t('aggregator'));
return _aggregator_summary_page_list('SELECT i.*, f.title AS ftitle, f.link AS flink FROM {aggregator_summary_item} i INNER JOIN {aggregator_summary_feed} f ON i.fid = f.fid ORDER BY i.timestamp DESC, i.iid DESC', arg(1));
}
/**
* Menu callback; displays all the items captured from a particular feed.
*/
function aggregator_summary_page_source() {
$feed = db_fetch_object(db_query('SELECT * FROM {aggregator_summary_feed} WHERE fid = %d', arg(2)));
$info = theme('aggregator_summary_feed', $feed);
return _aggregator_summary_page_list('SELECT * FROM {aggregator_summary_item} WHERE fid = '. $feed->fid .' ORDER BY timestamp DESC, iid DESC', arg(3), $info);
}
/**
* Menu callback; displays all the items aggregated in a particular category.
*/
function aggregator_summary_page_category() {
$category = db_fetch_object(db_query('SELECT cid, title FROM {aggregator_summary_category} WHERE cid = %d', arg(2)));
drupal_add_feed(url('aggregator_summary/rss/'. arg(2)), variable_get('site_name', 'Drupal') . ' ' . t('aggregator - @title', array('@title' => $category->title)));
return _aggregator_summary_page_list('SELECT i.*, f.title AS ftitle, f.link AS flink FROM {aggregator_summary_category_item} c LEFT JOIN {aggregator_summary_item} i ON c.iid = i.iid LEFT JOIN {aggregator_summary_feed} f ON i.fid = f.fid WHERE cid = '. $category->cid .' ORDER BY timestamp DESC, iid DESC', arg(3));
}
function aggregator_summary_page_list($sql, $header, $categorize) {
$form['#base'] = 'aggregator_summary_page_list';
$form['header'] = array('#value' => $header);
$result = pager_query($sql, 20);
$categories = array();
$done = FALSE;
$form['items'] = array();
$form['categories'] = array('#tree' => TRUE);
while ($item = db_fetch_object($result)) {
$form['categories'][$item->iid] = array();
if ($categorize) {
$categories_result = db_query('SELECT c.cid, c.title, ci.iid FROM {aggregator_summary_category} c LEFT JOIN {aggregator_summary_category_item} ci ON c.cid = ci.cid AND ci.iid = %d', $item->iid);
$selected = array();
while ($category = db_fetch_object($categories_result)) {
if (!$done) {
$categories[$category->cid] = check_plain($category->title);
}
if ($category->iid) {
$selected[] = $category->cid;
}
}
$done = TRUE;
$form['categories'][$item->iid] = array(
'#type' => variable_get('aggregator_summary_category_selector', 'checkboxes'),
'#default_value' => $selected, '#options' => $categories,
'#size' => 10, '#multiple' => TRUE
);
}
}
$form['submit'] = array('#type' => 'submit', '#value' => t('Save categories'));
$form['pager'] = array('#value' => theme('pager', NULL, 20, 0));
return $form;
}
/**
* Prints an aggregator page listing a number of feed items. Various
* menu callbacks use this function to print their feeds.
*/
function _aggregator_summary_page_list($sql, $op, $header = '') {
global $base_url;
$categorize = (user_access('administer news feeds') && ($op == 'categorize'));
$secs_agg = db_query('select * from {aggregator_summary_section}');
$output = '';
$output.= '
';
$scnt=0;
$farr=array();
while($secs=db_fetch_object($secs_agg))
{
$output.= "- ".$secs->sname."";
$catid = array();
$items = db_query('select * from {aggregator_summary_category_section} where sid='.$secs->sid);
while($item = db_fetch_object($items))
{
$catid[] = $item->cid;
}
if(count($catid)>0)
{
$items_agg = db_query('select * from aggregator_summary_category where cid IN('.implode(',',$catid).')');
$output.= "";
}
$output.= "
";
}
$output.= "
";
$output .= ' ';
$output .= $header;
if(arg(1)=="")
{
$limit = variable_get('items_per', 10);
}
else
{
$cid = arg(2);
$sql = db_query("select * from aggregator_summary_category where cid=$cid");
$rs = db_fetch_array($sql);
$limit = $rs['item_perpage'];
}
$output .= theme('aggregator_summary_page_item',$limit);
$output.='
';
$form['pager'] = array('#value' => theme('pager', NULL, 20, 0));
$output .= $form['pager']['#value'];
$output .= $form['feed_icon']['#value'];
return $output;
}
function theme_aggregator_summary_page_list($form) {
$output = '';
$output .= drupal_render($form['header']);
$rows = array();
if ($form['items']) {
foreach (element_children($form['items']) as $key) {
if (is_array($form['items'][$key])) {
$rows[] = array(drupal_render($form['items'][$key]), array('data' => drupal_render($form['categories'][$key]), 'class' => 'categorize-item'),l('Edit Item','admin/content/aggregator_summary/item/edit/'.$key));
$rows[] = array(drupal_render($form['items'][$key]), array('data' => drupal_render($form['category'][$key]), 'class' => 'categorize-item','colspan'=>'2'));
}
}
}
$output .= theme('table', array('', t('Categorize'),''), $rows);
$output .= drupal_render($form['submit']);
$output .= '
';
$output .= drupal_render($form);
return $output;
}
function aggregator_summary_page_list_validate($form_id, &$form) {
if (!user_access('administer news feeds')) {
form_error($form, t('You are not allowed to categorize this feed item.'));
}
}
function aggregator_summary_page_list_submit($form_id, $form_values) {
foreach ($form_values['categories'] as $iid => $selection) {
db_query('DELETE FROM {aggregator_summary_category_item} WHERE iid = %d', $iid);
foreach ($selection as $cid) {
if ($cid) {
db_query('INSERT INTO {aggregator_summary_category_item} (cid, iid) VALUES (%d, %d)', $cid, $iid);
}
}
}
$flag=0;
foreach($form_values as $id=>$value)
{
if(!is_array($value))
{
if($value==1)
{
$flag=1;
db_query('DELETE FROM {aggregator_summary_item} where iid = %d',$id);
db_query('DELETE FROM {aggregator_summary_category_item} where iid= %d',$id);
}
}
}
drupal_set_message(t('The categories have been saved.'));
if($flag==1)
{
drupal_set_message(t('The items have been delete.'));
}
}
/**
* Menu callback; generate an RSS 0.92 feed of aggregator items or categories.
*/
function aggregator_summary_page_rss() {
// arg(2) is the passed cid, only select for that category
$result = NULL;
if (arg(2)) {
$category = db_fetch_object(db_query('SELECT cid, title FROM {aggregator_summary_category} WHERE cid = %d', arg(2)));
$url = '/categories/' . $category->cid;
$title = ' ' . t('in category') . ' ' . $category->title;
$sql = 'SELECT i.*, f.title AS ftitle, f.link AS flink FROM {aggregator_summary_category_item} c LEFT JOIN {aggregator_summary_item} i ON c.iid = i.iid LEFT JOIN {aggregator_summary_feed} f ON i.fid = f.fid WHERE cid = %d ORDER BY timestamp DESC, iid DESC';
$result = db_query_range($sql, $category->cid, 0, variable_get('feed_default_items', 10));
}
// or, get the default aggregator items
else {
$sql = 'SELECT i.*, f.title AS ftitle, f.link AS flink FROM {aggregator_summary_item} i INNER JOIN {aggregator_summary_feed} f ON i.fid = f.fid ORDER BY i.timestamp DESC, i.iid DESC';
$result = db_query_range($sql, 0, variable_get('feed_default_items', 10));
}
while ($item = db_fetch_object($result)) {
switch (variable_get('feed_item_length', 'teaser')) {
case 'teaser':
$teaser = node_teaser($item->description);
if ($teaser != $item->description) {
$teaser .= ''. t('read more') ."
\n";
}
$item->description = $teaser;
break;
case 'title':
$item->description = '';
break;
}
$items .= format_rss_item($item->ftitle . ': ' . $item->title, $item->link, $item->description, array('pubDate' => date('r', $item->timestamp)));
}
$output .= "\n";
$output .= "\n";
$output .= format_rss_channel(variable_get('site_name', 'Drupal') . ' ' . t('aggregator'), url('aggregator' . $url, NULL, NULL, TRUE), variable_get('site_name', 'Drupal') . ' - ' . t('aggregated feeds') . $title, $items, 'en');
$output .= "\n";
drupal_set_header('Content-Type: application/rss+xml; charset=utf-8');
print $output;
}
/**
* Menu callback; generates an OPML representation of all feeds.
*/
function aggregator_summary_page_opml($cid = NULL) {
if ($cid) {
$result = db_query('SELECT f.title, f.url FROM {aggregator_summary_feed} f LEFT JOIN {aggregator_summary_category_feed} c on f.fid = c.fid WHERE c.cid = %d ORDER BY title', $cid);
}
else {
$result = db_query('SELECT * FROM {aggregator_summary_feed} ORDER BY title');
}
$output = "\n";
$output .= "\n";
$output .= "\n";
$output .= ''. check_plain(variable_get('site_name', 'Drupal')) ."\n";
$output .= ''. gmdate('r') ."\n";
$output .= "\n";
$output .= "\n";
while ($feed = db_fetch_object($result)) {
$output .= '\n";
}
$output .= "\n";
$output .= "\n";
drupal_set_header('Content-Type: text/xml; charset=utf-8');
print $output;
}
/**
* Menu callback; displays all the categories used by the aggregator.
*/
function aggregator_summary_page_categories() {
$result = db_query('SELECT c.cid, c.title, c.description FROM {aggregator_summary_category} c LEFT JOIN {aggregator_summary_category_item} ci ON c.cid = ci.cid LEFT JOIN {aggregator_summary_item} i ON ci.iid = i.iid GROUP BY c.cid, c.title, c.description');
$output = "\n";
while ($category = db_fetch_object($result)) {
$output .= '
'. check_plain($category->title) ."
\n";
if (variable_get('aggregator_summary_items1', 3)) {
$list = array();
$items = db_query_range('SELECT i.title, i.timestamp, i.link, f.title as feed_title, f.link as feed_link FROM {aggregator_summary_category_item} ci LEFT JOIN {aggregator_summary_item} i ON i.iid = ci.iid LEFT JOIN {aggregator_summary_feed} f ON i.fid = f.fid WHERE ci.cid = %d ORDER BY i.timestamp DESC', $category->cid, 0, variable_get('aggregator_summary_items1', 3));
while ($item = db_fetch_object($items)) {
$list[] = theme('aggregator_summary_item1', $item);
}
$output .= theme('item_list', $list);
}
$link['categories'] = array(
'title' => t('More'),
'href' => 'aggregator_summary/categories/'. $category->cid
);
$output .= '
'. theme('links', $link) ."
\n";
}
$output .= '
';
$output .= theme('feed_icon', $feed->url) ."\n";
$output .= $feed->image;
$output .= '
'. aggregator_summary_filter_xss($feed->description) ."
\n";
$output .= '
'. t('URL:') .' '. l($feed->link, $feed->link, array(), NULL, NULL, TRUE) ."
\n";
if ($feed->checked) {
$updated = t('@time ago', array('@time' => format_interval(time() - $feed->checked)));
}
else {
$updated = t('never');
}
if (user_access('administer news feeds')) {
$updated = l($updated, 'admin/content/aggregator_summary');
}
$output .= '
'. t('Updated:') . " $updated
";
$output .= "
'. l($image, 'node/add/blog', array('title' => t('Comment on this news item in your personal blog.'), 'class' => 'blog-it'), "iid=$item->iid", NULL, FALSE, TRUE) .'
';
}
}
// Display the external link to the item.
$output .= ''. check_plain($item->title) ."\n";
return $output;
}
/**
* Return a themed item heading for summary pages located at "aggregator_summary/sources"
* and "aggregator_summary/categories".
*
* @param $item The item object from the aggregator module.
* @return A string containing the output.
*
* @ingroup themeable
*/
function theme_aggregator_summary_item1($item) {
global $base_url;
$itemid = $item->iid;
$r = db_query("select * from {aggregator_summary_item} where iid=$itemid");
$row = db_fetch_object($r);
$path = base_path() . drupal_get_path('module', 'aggregator_summary') .'/';
if(arg(1)=='sources' && is_numeric(arg(2)))
{
$output=' | '. check_plain($item->title) .' |
| '.$row->description.' |
|
';
}
else
{
$output=' | '. check_plain($item->title) .' | |
|
';
}
return $output."\n";
}
/**
* Format an individual feed item for display on the aggregator page.
*
* @ingroup themeable
*/
function theme_aggregator_summary_page_item($item) {
global $base_path;
$feedarr = array();
$sourceid = arg(2);
if(arg(1) == 'categories')
{
$feedc = 0;
$sql = 'SELECT * FROM {aggregator_summary_category_feed} WHERE cid='.$sourceid.'';
$feed_list_res = pager_query($sql, $item);
if(db_num_rows($feed_list_res) > 0)
{
while($feed_list=db_fetch_object($feed_list_res))
{
$feedarr[$feedc++]=$feed_list->fid;
}
$output = list_feeds_items($feedarr);
}else
{
$output.=' No feeds for this category.';
}
}
if(arg(1)=='sources')
{
$feedc=0;
$sql = 'SELECT * FROM {aggregator_summary_feed} WHERE fid='.$sourceid.'';
$feed_list_res = db_query($sql);
if(db_num_rows($feed_list_res) > 0)
{
while($feed_list=db_fetch_object($feed_list_res))
{
$feedarr[$feedc++]=$feed_list->fid;
}
$output = list_sources_listing($feedarr);
}else
{
$output.=' No feeds for this category.';
}
}
if(arg(1)=='')
{
$feedc = 0;
$sql = 'SELECT * FROM {aggregator_summary_feed}';
$feed_list_res = pager_query($sql, $item);
if(db_num_rows($feed_list_res) > 0)
{
while($feed_list = db_fetch_object($feed_list_res))
{
$feedarr[$feedc++] = $feed_list->fid;
}
$output = list_feeds_items($feedarr);
}
}
return $output;
}
/**
* Safely render HTML content, as allowed.
*/
function aggregator_summary_filter_xss($value) {
return filter_xss($value, preg_split('/\s+|<|>/', variable_get("aggregator_summary_allowed_html_tags", '
-
-
-
'), -1, PREG_SPLIT_NO_EMPTY));
}
/**
* Helper function for drupal_map_assoc.
*/
function _aggregator_summary_items1($count) {
return format_plural($count, '1 item', '@count items');
}
function aggregator_summary_get_section($sid) {
return db_fetch_array(db_query('SELECT * FROM {aggregator_summary_section} WHERE sid = %d', $sid));
}
function aggregator_summary_form_section($edit = array())
{
$form['sname'] = array('#type' => 'textfield',
'#title' => t('Section Name'),
'#default_value' => $edit['sname'],
'#maxlength' => 64,
'#description' => t('The name of the Section.'),
'#required' => TRUE,
);
// Handling of categories:
$options = array();
$values = array();
$categories = db_query('SELECT c.cid, c.title, s.sid FROM {aggregator_summary_category} c LEFT JOIN {aggregator_summary_category_section} s ON c.cid = s.cid AND s.sid = %d ORDER BY title', $edit['sid']);
while ($category = db_fetch_object($categories)) {
$options[$category->cid] = $category->title;
if ($category->sid) $values[] = check_plain($category->cid);
}
if ($options) {
$form['category'] = array('#type' => 'checkboxes',
'#title' => t('Categorize Section'),
'#default_value' => $values,
'#options' => $options,
'#description' => t(' check the categories you want to assign to this section'),
);
}
$form['submit'] = array('#type' => 'submit', '#value' =>t('Submit'));
if ($edit['sid']) {
$form['delete'] = array('#type' => 'submit', '#value' =>t('Delete'));
$form['sid'] = array('#type' => 'hidden', '#value' => $edit['sid']);
}
return $form;
}
function aggregator_summary_form_section_validate($form_id, $form_values) {
if ($_POST['op'] == t('Submit')) {
// Check for duplicate titles
if (isset($form_values['sid'])) {
$result = db_query("SELECT sname FROM {aggregator_summary_section} WHERE (sname = '%s' ) AND sid != %d", $form_values['sname'], $form_values['sid']);
}
else {
$result = db_query("SELECT sname FROM {aggregator_summary_section} WHERE sname = '%s' ", $form_values['sname']);
}
while ($section = db_fetch_object($result)) {
if (strcasecmp($section->sname, $form_values['sname']) == 0) {
form_set_error('title', t('A section named %section already exists. Please enter a unique name.', array('%section' => theme('placeholder', $form_values['sname']))));
}
}
}
}
function aggregator_summary_form_section_submit($form_id, $form_values) {
if ($_POST['op'] == t('Delete')) {
$sname = $form_values['sname'];
// Unset the title:
unset($form_values['sname']);
}
aggregator_summary_save_section($form_values);
menu_rebuild();
if (isset($form_values['sid'])) {
if (isset($form_values['sname'])) {
drupal_set_message(t('The section %section has been updated.', array('%section' => theme('placeholder', $form_values['sname']))));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
}
else {
watchdog('aggregator', t('Section %section deleted.', array('%section' => theme('placeholder', $sname))));
drupal_set_message(t('The section %section has been deleted.', array('%feed' => theme('placeholder', $sname))));
if (arg(0) == 'admin') {
return 'admin/content/aggregator_summary/';
}
}
}
else {
watchdog('aggregator', t('section %section added.', array('%section' => theme('placeholder', $form_values['sname']))), WATCHDOG_NOTICE, l(t('view'), 'admin/aggregator_summary'));
drupal_set_message(t('The section %section has been added.', array('%section' => theme('placeholder', $form_values['sname']))));
}
}
function aggregator_summary_save_section($edit)
{
if ($edit['sid'])
{
db_query('DELETE FROM {aggregator_summary_category_section} WHERE sid = %d', $edit['sid']);
}
if ($edit['sid'] && $edit['sname'])
{
db_query("UPDATE {aggregator_summary_section} SET sname = '%s' WHERE sid = %d",$edit['sname'], $edit['sid']);
}
else if ($edit['sid']) {
db_query('DELETE FROM {aggregator_summary_section} WHERE sid = %d', $edit['sid']);
db_query('DELETE FROM {aggregator_summary_category_section} WHERE sid = %d', $edit['sid']);
}
else if ($edit['sname']) {
$edit['sid'] = db_next_id('{aggregator_summary_section}_sid');
db_query("INSERT INTO {aggregator_summary_section} (sid, sname) VALUES (%d, '%s')", $edit['sid'], $edit['sname']);
}
if ($edit['sname']) {
// The section is being saved, save the categories as well.
if ($edit['category']) {
foreach ($edit['category'] as $cid => $value) {
if ($value) {
db_query('INSERT INTO {aggregator_summary_category_section} (sid, cid) VALUES (%d, %d)', $edit['sid'], $cid);
}
}
}
}
}
function aggregator_summary_form_general($edit = array())
{
$item=variable_get('items_per',10);
$form['items_per'] = array('#type' => 'textfield',
'#title' => t('Feeds Limit on Front'),
'#default_value' => $item,
'#maxlength' => 64,
'#description' => t('# of sections showing on the news aggregator front page.'),
'#required' => TRUE,
);
$form['submit'] = array('#type' => 'submit', '#value' =>t('Submit'));
return $form;
}
function aggregator_summary_form_general_submit($form_id, $form_values)
{
if (isset($form_values['items_per']))
{
variable_set('items_per', $form_values['items_per']);
drupal_set_message(t('The general settings has been updated.'));
if (arg(0) == 'admin')
{
return 'admin/content/aggregator_summary/';
}
}
}
function list_feeds_items($feedarr)
{
global $base_path;
$output = '';
$output ='';
$cc=1;
for($oo=0;$oofid, 0, variable_get('aggregator_summary_items1', 8));
if(db_num_rows($items) > 0)
{
$output.='
';
$output.= '|
'.check_plain($feed->title).'
|
';
}
}
// Most recent items:
$list = array();
if(db_num_rows($items) > 0)
{
$count=0;
while ($item = db_fetch_object($items))
{
$midoutput = theme('aggregator_summary_item1', $item);
$output.= $midoutput;
$count++;
}
$attributes = array('class'=>'more123');
$output .="| | ".l(t('More'),'aggregator_summary/sources/'.$feed->fid,$attributes)." | | ";
$output .= ' | | | ';
if($cc % 3 == 0 && $cc !=0)
{
$output .= '
| |
';
}
$cc++;
}
}
}
return $output;
}
function list_sources_listing($feedarr)
{
global $base_path;
$output='';
$categories = array();
$catidtoshow = $categories_id;
for($oo=0;$oo'.check_plain($feed->title).'';
$list = array();
$output.='';
$output.='
';
$items = db_query('SELECT i.iid,i.title, i.timestamp, i.link FROM {aggregator_summary_item} i WHERE i.fid = %d ORDER BY i.timestamp DESC', $feed->fid);
while ($item = db_fetch_object($items))
{
$output .= theme('aggregator_summary_item1', $item);
}
$output.='
';
$output .= drupal_render($form['header']);
$output.= '
'.$item->title.'
';
$output.= $item->description;
$output .= drupal_render($form['submit']);
$output .= '';
$output .= drupal_render($form);
return $output;
}
function aggregator_summary_page_items1_submit($form_id, $form_values) {
foreach ($form_values as $iid => $selection) {
db_query('DELETE FROM {aggregator_summary_category_item} WHERE iid = %d', $iid);
if(is_array($selection))
{
foreach ($selection as $cid)
{
if ($cid) {
db_query('INSERT INTO {aggregator_summary_category_item} (cid, iid) VALUES (%d, %d)', $cid, $iid);
}
}
}
}
drupal_set_message(t('The categories have been saved.'));
}
function aggregator_summary_form_item($edit=array())
{
$form['title'] = array('#type' => 'textfield',
'#title' => t('Title'),
'#default_value' => $edit['title'],
'#maxlength' => 255,
'#description' => t('The name of the feed item.'),
'#required' => TRUE,
);
$form['description'] = array('#type' => 'textarea',
'#title' => t('Description'),
'#default_value' => $edit['description'],
'#maxlength' => 255,
'#description' => t('Description of the item.'),
'#required' => TRUE,
);
$form['submit'] = array('#type' => 'submit', '#value' => t('Submit'));
$form['iid'] = array('#type' => 'hidden', '#value' => $edit['iid']);
return $form;
}
function aggregator_summary_form_item_submit($form_id, $form_values)
{
if ($form_values['iid'] && $form_values['title'])
{
db_query("UPDATE {aggregator_summary_item} SET title = '%s', description = '%s' WHERE iid = %d", $form_values['title'], $form_values['description'], $form_values['iid']);
}
drupal_set_message(t('The Item %item has been updated.', array('%item' => $form_values['title'])));
watchdog('aggregator', t('Item %item Updated.', array('%item' => $form_values['title'])), WATCHDOG_NOTICE, l(t('view'), 'admin/content/aggregator_summary'));
if (arg(0) == 'admin')
{
return 'admin/content/aggregator_summary/';
}
}