fixes for first_id stuff

This commit is contained in:
Andrew Dolgov 2015-07-12 17:55:35 +03:00
parent ec57104d6e
commit 48fefe2f6b
5 changed files with 44 additions and 46 deletions

View File

@ -205,7 +205,7 @@ class API extends Handler {
$force_update = sql_bool_to_bool($_REQUEST["force_update"]); $force_update = sql_bool_to_bool($_REQUEST["force_update"]);
$has_sandbox = sql_bool_to_bool($_REQUEST["has_sandbox"]); $has_sandbox = sql_bool_to_bool($_REQUEST["has_sandbox"]);
$excerpt_length = (int)$this->dbh->escape_string($_REQUEST["excerpt_length"]); $excerpt_length = (int)$this->dbh->escape_string($_REQUEST["excerpt_length"]);
$check_top_id = (int)$this->dbh->escape_string($_REQUEST["check_top_id"]); $check_first_id = (int)$this->dbh->escape_string($_REQUEST["check_first_id"]);
$include_header = sql_bool_to_bool($_REQUEST["include_header"]); $include_header = sql_bool_to_bool($_REQUEST["include_header"]);
$_SESSION['hasSandbox'] = $has_sandbox; $_SESSION['hasSandbox'] = $has_sandbox;
@ -230,7 +230,7 @@ class API extends Handler {
list($headlines, $headlines_header) = $this->api_get_headlines($feed_id, $limit, $offset, list($headlines, $headlines_header) = $this->api_get_headlines($feed_id, $limit, $offset,
$filter, $is_cat, $show_excerpt, $show_content, $view_mode, $override_order, $filter, $is_cat, $show_excerpt, $show_content, $view_mode, $override_order,
$include_attachments, $since_id, $search, $include_attachments, $since_id, $search,
$include_nested, $sanitize_content, $force_update, $excerpt_length, $check_top_id); $include_nested, $sanitize_content, $force_update, $excerpt_length, $check_first_id);
if ($include_header) { if ($include_header) {
$this->wrap(self::STATUS_OK, array($headlines_header, $headlines)); $this->wrap(self::STATUS_OK, array($headlines_header, $headlines));
@ -644,7 +644,7 @@ class API extends Handler {
$filter, $is_cat, $show_excerpt, $show_content, $view_mode, $order, $filter, $is_cat, $show_excerpt, $show_content, $view_mode, $order,
$include_attachments, $since_id, $include_attachments, $since_id,
$search = "", $include_nested = false, $sanitize_content = true, $search = "", $include_nested = false, $sanitize_content = true,
$force_update = false, $excerpt_length = 100, $check_top_id = false) { $force_update = false, $excerpt_length = 100, $check_first_id = false) {
if ($force_update && $feed_id > 0 && is_numeric($feed_id)) { if ($force_update && $feed_id > 0 && is_numeric($feed_id)) {
// Update the feed if required with some basic flood control // Update the feed if required with some basic flood control
@ -686,18 +686,20 @@ class API extends Handler {
"offset" => $offset, "offset" => $offset,
"since_id" => $since_id, "since_id" => $since_id,
"include_children" => $include_nested, "include_children" => $include_nested,
"check_top_id" => $check_top_id "check_first_id" => $check_first_id
); );
$qfh_ret = queryFeedHeadlines($params); $qfh_ret = queryFeedHeadlines($params);
$result = $qfh_ret[0]; $result = $qfh_ret[0];
$feed_title = $qfh_ret[1]; $feed_title = $qfh_ret[1];
$first_id = $qfh_ret[6];
$headlines = array(); $headlines = array();
$headlines_header = array( $headlines_header = array(
'id' => $feed_id, 'id' => $feed_id,
'first_id' => $first_id,
'is_cat' => $is_cat); 'is_cat' => $is_cat);
if (!is_numeric($result)) { if (!is_numeric($result)) {
@ -789,7 +791,7 @@ class API extends Handler {
array_push($headlines, $headline_row); array_push($headlines, $headline_row);
} }
} else if (is_numeric($result) && $result == -1) { } else if (is_numeric($result) && $result == -1) {
$headlines_header['top_id_changed'] = true; $headlines_header['first_id_changed'] = true;
} }
return array($headlines, $headlines_header); return array($headlines, $headlines_header);

View File

@ -148,7 +148,7 @@ class Feeds extends Handler_Protected {
private function format_headlines_list($feed, $method, $view_mode, $limit, $cat_view, private function format_headlines_list($feed, $method, $view_mode, $limit, $cat_view,
$next_unread_feed, $offset, $vgr_last_feed = false, $next_unread_feed, $offset, $vgr_last_feed = false,
$override_order = false, $include_children = false, $check_top_id = false) { $override_order = false, $include_children = false, $check_first_id = false) {
$disable_cache = false; $disable_cache = false;
@ -250,7 +250,7 @@ class Feeds extends Handler_Protected {
"override_order" => $override_order, "override_order" => $override_order,
"offset" => $offset, "offset" => $offset,
"include_children" => $include_children, "include_children" => $include_children,
"check_top_id" => $check_top_id "check_first_id" => $check_first_id
); );
$qfh_ret = queryFeedHeadlines($params); $qfh_ret = queryFeedHeadlines($params);
@ -267,6 +267,7 @@ class Feeds extends Handler_Protected {
$last_updated = strpos($qfh_ret[4], '1970-') === FALSE ? $last_updated = strpos($qfh_ret[4], '1970-') === FALSE ?
make_local_datetime($qfh_ret[4], false) : __("Never"); make_local_datetime($qfh_ret[4], false) : __("Never");
$highlight_words = $qfh_ret[5]; $highlight_words = $qfh_ret[5];
$reply['first_id'] = $qfh_ret[6];
$vgroup_last_feed = $vgr_last_feed; $vgroup_last_feed = $vgr_last_feed;
@ -801,7 +802,7 @@ class Feeds extends Handler_Protected {
} }
} else if (is_numeric($result) && $result == -1) { } else if (is_numeric($result) && $result == -1) {
$reply['content'] = ''; $reply['content'] = '';
$reply['top_id_changed'] = true; $reply['first_id_changed'] = true;
} }
if ($_REQUEST["debug"]) $timing_info = print_checkpoint("H2", $timing_info); if ($_REQUEST["debug"]) $timing_info = print_checkpoint("H2", $timing_info);
@ -832,7 +833,7 @@ class Feeds extends Handler_Protected {
@$offset = $this->dbh->escape_string($_REQUEST["skip"]); @$offset = $this->dbh->escape_string($_REQUEST["skip"]);
@$vgroup_last_feed = $this->dbh->escape_string($_REQUEST["vgrlf"]); @$vgroup_last_feed = $this->dbh->escape_string($_REQUEST["vgrlf"]);
$order_by = $this->dbh->escape_string($_REQUEST["order_by"]); $order_by = $this->dbh->escape_string($_REQUEST["order_by"]);
$check_top_id = $this->dbh->escape_string($_REQUEST["topid"]); $check_first_id = $this->dbh->escape_string($_REQUEST["fid"]);
if (is_numeric($feed)) $feed = (int) $feed; if (is_numeric($feed)) $feed = (int) $feed;
@ -905,7 +906,7 @@ class Feeds extends Handler_Protected {
$ret = $this->format_headlines_list($feed, $method, $ret = $this->format_headlines_list($feed, $method,
$view_mode, $limit, $cat_view, $next_unread_feed, $offset, $view_mode, $limit, $cat_view, $next_unread_feed, $offset,
$vgroup_last_feed, $override_order, true, $check_top_id); $vgroup_last_feed, $override_order, true, $check_first_id);
//$topmost_article_ids = $ret[0]; //$topmost_article_ids = $ret[0];
$headlines_count = $ret[1]; $headlines_count = $ret[1];

View File

@ -444,7 +444,7 @@
$override_strategy = isset($params["override_strategy"]) ? $params["override_strategy"] : false; $override_strategy = isset($params["override_strategy"]) ? $params["override_strategy"] : false;
$override_vfeed = isset($params["override_vfeed"]) ? $params["override_vfeed"] : false; $override_vfeed = isset($params["override_vfeed"]) ? $params["override_vfeed"] : false;
$start_ts = isset($params["start_ts"]) ? $params["start_ts"] : false; $start_ts = isset($params["start_ts"]) ? $params["start_ts"] : false;
$check_top_id = isset($params["check_top_id"]) ? $params["check_top_id"] : false; $check_first_id = isset($params["check_first_id"]) ? $params["check_first_id"] : false;
$ext_tables_part = ""; $ext_tables_part = "";
$query_strategy_part = ""; $query_strategy_part = "";
@ -729,28 +729,26 @@
$start_ts_query_part = ""; $start_ts_query_part = "";
} }
$first_id = false;
// if previous topmost article id changed that means our current pagination is no longer valid // if previous topmost article id changed that means our current pagination is no longer valid
if ($check_top_id) { $query = "SELECT DISTINCT
$query = "SELECT DISTINCT date_entered,
date_entered, guid,
guid, ttrss_entries.id,
ttrss_entries.id, ttrss_entries.title,
ttrss_entries.title, updated,
updated, score
score FROM
FROM $from_qpart
$from_qpart WHERE
WHERE $feed_check_qpart
$feed_check_qpart ttrss_user_entries.ref_id = ttrss_entries.id AND
ttrss_user_entries.ref_id = ttrss_entries.id AND ttrss_user_entries.owner_uid = '$owner_uid' AND
ttrss_user_entries.owner_uid = '$owner_uid' AND $search_query_part
$search_query_part $start_ts_query_part
$start_ts_query_part $filter_query_part
$filter_query_part $since_id_part
$view_query_part $query_strategy_part ORDER BY $order_by LIMIT 1";
$since_id_part
$query_strategy_part ORDER BY $order_by LIMIT 1";
if ($_REQUEST["debug"]) { if ($_REQUEST["debug"]) {
print $query; print $query;
@ -758,15 +756,12 @@
$result = db_query($query); $result = db_query($query);
if ($result) { if ($result) {
$current_top_id = db_fetch_result($result, 0, "id"); $first_id = (int) db_fetch_result($result, 0, "id");
if ($current_top_id != $check_top_id) { if ($offset > 0 && $check_first_id && $first_id != $check_first_id) {
// top changed, bail out return array(-1, $feed_title, $feed_site_url, $last_error, $last_updated, $search_words, $first_id);
return array(-1, $feed_title, $feed_site_url, $last_error, $last_updated, $search_words);
} }
} }
}
$query = "SELECT DISTINCT $query = "SELECT DISTINCT
date_entered, date_entered,
@ -851,7 +846,7 @@
$result = db_query($query); $result = db_query($query);
} }
return array($result, $feed_title, $feed_site_url, $last_error, $last_updated, $search_words); return array($result, $feed_title, $feed_site_url, $last_error, $last_updated, $search_words, $first_id);
} }

View File

@ -100,10 +100,8 @@ function viewfeed(feed, method, is_cat, offset, background, infscroll_req, can_w
} }
if (offset > 0) { if (offset > 0) {
var firstRow = $$('div[id*="RROW-"]').first(); if (current_first_id) {
query = query + "&fid=" + param_escape(current_first_id);
if (firstRow) {
query = query + "&topid=" + param_escape(parseInt(firstRow.id.replace("RROW-", "")));
} }
} }

View File

@ -13,6 +13,7 @@ var catchup_timeout_id = false;
var cids_requested = []; var cids_requested = [];
var loaded_article_ids = []; var loaded_article_ids = [];
var _last_headlines_update = 0; var _last_headlines_update = 0;
var current_first_id = 0;
var has_storage = 'sessionStorage' in window && window['sessionStorage'] !== null; var has_storage = 'sessionStorage' in window && window['sessionStorage'] !== null;
@ -77,6 +78,7 @@ function headlines_callback2(transport, offset, background, infscroll_req) {
_infscroll_disable = 0; _infscroll_disable = 0;
} }
current_first_id = reply['headlines']['first_id'];
var counters = reply['counters']; var counters = reply['counters'];
var articles = reply['articles']; var articles = reply['articles'];
//var runtime_info = reply['runtime-info']; //var runtime_info = reply['runtime-info'];
@ -183,13 +185,13 @@ function headlines_callback2(transport, offset, background, infscroll_req) {
} else { } else {
console.log("no new headlines received"); console.log("no new headlines received");
var top_id_changed = reply['headlines']['top_id_changed']; var first_id_changed = reply['headlines']['first_id_changed'];
console.log("top id changed:" + top_id_changed); console.log("first id changed:" + first_id_changed);
var hsp = $("headlines-spacer"); var hsp = $("headlines-spacer");
if (hsp) { if (hsp) {
if (top_id_changed) { if (first_id_changed) {
hsp.innerHTML = "<a href='#' onclick='viewCurrentFeed()'>" + hsp.innerHTML = "<a href='#' onclick='viewCurrentFeed()'>" +
__("New articles found, reload feed to continue.") + "</a>"; __("New articles found, reload feed to continue.") + "</a>";
} else { } else {