diff --git a/modules/aggregator.module b/modules/aggregator.module index 355b7769194..8545ad000c1 100644 --- a/modules/aggregator.module +++ b/modules/aggregator.module @@ -52,6 +52,11 @@ function import_block() { return $blocks; } +function import_remove($feed) { + db_query("DELETE FROM item WHERE fid = '$feed[fid]'"); + return "feed '$feed[title]' reset."; +} + function import_update($feed) { // open socket: @@ -65,11 +70,13 @@ function import_update($feed) { if (strstr($data, "200 OK")) { - eregi("", $data, $data); + eregi("", $data, $data); + + // print "
". htmlentities($data[0]) ."
"; foreach (explode("", $data[0]) as $item) { - $l = eregi("(.*)", $item, $link); $t = eregi("(.*)", $item, $title); + $l = eregi("(.*)", $item, $link); $a = eregi("(.*)", $item, $author); $d = eregi("(.*)", $item, $description); @@ -84,6 +91,8 @@ function import_update($feed) { watchdog("error", "failed to syndicate from '$feed[title]'"); } } + + return "feed '$feed[title]' updated."; } function import_save_item($edit) { @@ -185,9 +194,9 @@ function import_view_feed() { $output .= "

Feed overview

"; $output .= "\n"; - $output .= " \n"; + $output .= " \n"; while ($feed = db_fetch_object($result)) { - $output .= " \n"; + $output .= " \n"; } $output .= "
titleattributesitemslast updatenext updateoperations
titleattributesitemslast updatenext updateoperations
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">update items
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">remove itemsfid\">update items
\n"; @@ -243,8 +252,12 @@ function import_admin() { else print import_form_feed(import_get_feed($id)); break; + case "remove": + print status(import_remove(import_get_feed($id))); + print import_view_feed(); + break; case "update": - print import_update(import_get_feed($id)); + print status(import_update(import_get_feed($id))); print import_view_feed(); break; case "Save attributes": diff --git a/modules/aggregator/aggregator.module b/modules/aggregator/aggregator.module index 355b7769194..8545ad000c1 100644 --- a/modules/aggregator/aggregator.module +++ b/modules/aggregator/aggregator.module @@ -52,6 +52,11 @@ function import_block() { return $blocks; } +function import_remove($feed) { + db_query("DELETE FROM item WHERE fid = '$feed[fid]'"); + return "feed '$feed[title]' reset."; +} + function import_update($feed) { // open socket: @@ -65,11 +70,13 @@ function import_update($feed) { if (strstr($data, "200 OK")) { - eregi("", $data, $data); + eregi("", $data, $data); + + // print "
". htmlentities($data[0]) ."
"; foreach (explode("", $data[0]) as $item) { - $l = eregi("(.*)", $item, $link); $t = eregi("(.*)", $item, $title); + $l = eregi("(.*)", $item, $link); $a = eregi("(.*)", $item, $author); $d = eregi("(.*)", $item, $description); @@ -84,6 +91,8 @@ function import_update($feed) { watchdog("error", "failed to syndicate from '$feed[title]'"); } } + + return "feed '$feed[title]' updated."; } function import_save_item($edit) { @@ -185,9 +194,9 @@ function import_view_feed() { $output .= "

Feed overview

"; $output .= "\n"; - $output .= " \n"; + $output .= " \n"; while ($feed = db_fetch_object($result)) { - $output .= " \n"; + $output .= " \n"; } $output .= "
titleattributesitemslast updatenext updateoperations
titleattributesitemslast updatenext updateoperations
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">update items
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">remove itemsfid\">update items
\n"; @@ -243,8 +252,12 @@ function import_admin() { else print import_form_feed(import_get_feed($id)); break; + case "remove": + print status(import_remove(import_get_feed($id))); + print import_view_feed(); + break; case "update": - print import_update(import_get_feed($id)); + print status(import_update(import_get_feed($id))); print import_view_feed(); break; case "Save attributes": diff --git a/modules/import.module b/modules/import.module index 355b7769194..8545ad000c1 100644 --- a/modules/import.module +++ b/modules/import.module @@ -52,6 +52,11 @@ function import_block() { return $blocks; } +function import_remove($feed) { + db_query("DELETE FROM item WHERE fid = '$feed[fid]'"); + return "feed '$feed[title]' reset."; +} + function import_update($feed) { // open socket: @@ -65,11 +70,13 @@ function import_update($feed) { if (strstr($data, "200 OK")) { - eregi("", $data, $data); + eregi("", $data, $data); + + // print "
". htmlentities($data[0]) ."
"; foreach (explode("", $data[0]) as $item) { - $l = eregi("(.*)", $item, $link); $t = eregi("(.*)", $item, $title); + $l = eregi("(.*)", $item, $link); $a = eregi("(.*)", $item, $author); $d = eregi("(.*)", $item, $description); @@ -84,6 +91,8 @@ function import_update($feed) { watchdog("error", "failed to syndicate from '$feed[title]'"); } } + + return "feed '$feed[title]' updated."; } function import_save_item($edit) { @@ -185,9 +194,9 @@ function import_view_feed() { $output .= "

Feed overview

"; $output .= "\n"; - $output .= " \n"; + $output .= " \n"; while ($feed = db_fetch_object($result)) { - $output .= " \n"; + $output .= " \n"; } $output .= "
titleattributesitemslast updatenext updateoperations
titleattributesitemslast updatenext updateoperations
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">update items
". check_output($feed->title) ."". check_output($feed->attribute) ."". format_plural($feed->items, "item", "items") ."". ($feed->timestamp ? format_interval(time() - $feed->timestamp) ." ago" : "never") ."". ($feed->timestamp ? format_interval($feed->timestamp + $feed->refresh - time()) ." left" : "never") ."fid\">edit feedfid\">remove itemsfid\">update items
\n"; @@ -243,8 +252,12 @@ function import_admin() { else print import_form_feed(import_get_feed($id)); break; + case "remove": + print status(import_remove(import_get_feed($id))); + print import_view_feed(); + break; case "update": - print import_update(import_get_feed($id)); + print status(import_update(import_get_feed($id))); print import_view_feed(); break; case "Save attributes":