]> git.wh0rd.org - tt-rss.git/blob - js/feedlist.js
request counters less times during startup, delay initial request in feedlist_init...
[tt-rss.git] / js / feedlist.js
1 var _infscroll_disable = 0;
2 var _infscroll_request_sent = 0;
3
4 var _search_query = false;
5 var _viewfeed_last = 0;
6 var _viewfeed_timeout = false;
7
8 var counters_last_request = 0;
9 var _counters_prev = [];
10
11 function resetCounterCache() {
12 _counters_prev = [];
13 }
14
15 function loadMoreHeadlines() {
16 console.log("loadMoreHeadlines");
17
18 var offset = 0;
19
20 var view_mode = document.forms["main_toolbar_form"].view_mode.value;
21 var unread_in_buffer = $$("#headlines-frame > div[id*=RROW][class*=Unread]").length;
22 var num_all = $$("#headlines-frame > div[id*=RROW]").length;
23 var num_unread = getFeedUnread(getActiveFeedId(), activeFeedIsCat());
24
25 // TODO implement marked & published
26
27 if (view_mode == "marked") {
28 console.warn("loadMoreHeadlines: marked is not implemented, falling back.");
29 offset = num_all;
30 } else if (view_mode == "published") {
31 console.warn("loadMoreHeadlines: published is not implemented, falling back.");
32 offset = num_all;
33 } else if (view_mode == "unread") {
34 offset = unread_in_buffer;
35 } else if (_search_query) {
36 offset = num_all;
37 } else if (view_mode == "adaptive" && !(getActiveFeedId() == -1 && !activeFeedIsCat())) {
38 // ^ starred feed shows both unread & read articles in adaptive mode
39 offset = num_unread > 0 ? unread_in_buffer : num_all;
40 } else {
41 offset = num_all;
42 }
43
44 console.log("offset: " + offset);
45
46 viewfeed({feed: getActiveFeedId(), is_cat: activeFeedIsCat(), offset: offset, infscroll_req: true});
47
48 }
49
50 function cleanup_memory(root) {
51 var dijits = dojo.query("[widgetid]", dijit.byId(root).domNode).map(dijit.byNode);
52
53 dijits.each(function (d) {
54 dojo.destroy(d.domNode);
55 });
56
57 $$("#" + root + " *").each(function (i) {
58 i.parentNode ? i.parentNode.removeChild(i) : true;
59 });
60 }
61
62 function viewfeed(params) {
63 var feed = params.feed;
64 var is_cat = params.is_cat;
65 var offset = params.offset;
66 var background = params.background;
67 var infscroll_req = params.infscroll_req;
68 var can_wait = params.can_wait;
69 var viewfeed_debug = params.viewfeed_debug;
70 var method = params.method;
71
72 if (is_cat == undefined)
73 is_cat = false;
74 else
75 is_cat = !!is_cat;
76
77 if (offset == undefined) offset = 0;
78 if (background == undefined) background = false;
79 if (infscroll_req == undefined) infscroll_req = false;
80
81 last_requested_article = 0;
82
83 if (feed != getActiveFeedId() || activeFeedIsCat() != is_cat) {
84 if (!background && _search_query) _search_query = false;
85 }
86
87 if (!background) {
88 _viewfeed_last = get_timestamp();
89
90 if (getActiveFeedId() != feed || !infscroll_req) {
91 setActiveArticleId(0);
92 _infscroll_disable = 0;
93
94 cleanup_memory("headlines-frame");
95 _headlines_scroll_offset = 0;
96 }
97
98 if (infscroll_req) {
99 var timestamp = get_timestamp();
100
101 if (_infscroll_request_sent && _infscroll_request_sent + 30 > timestamp) {
102 //console.log("infscroll request in progress, aborting");
103 return;
104 }
105
106 _infscroll_request_sent = timestamp;
107 }
108 }
109
110 Form.enable("main_toolbar_form");
111
112 var toolbar_query = Form.serialize("main_toolbar_form");
113
114 var query = "?op=feeds&method=view&feed=" + param_escape(feed) + "&" +
115 toolbar_query;
116
117 if (method) query += "&m=" + param_escape(method);
118
119 if (offset > 0) {
120 if (current_first_id) {
121 query = query + "&fid=" + param_escape(current_first_id);
122 }
123 }
124
125 if (!background) {
126 if (_search_query) {
127 force_nocache = true;
128 query = query + "&" + _search_query;
129 //_search_query = false;
130 }
131
132 if (offset != 0) {
133 query = query + "&skip=" + offset;
134
135 // to prevent duplicate feed titles when showing grouped vfeeds
136 if (vgroup_last_feed) {
137 query = query + "&vgrlf=" + param_escape(vgroup_last_feed);
138 }
139 } else {
140 if (!is_cat && feed == getActiveFeedId() && !params.method) {
141 query = query + "&m=ForceUpdate";
142 }
143 }
144
145 Form.enable("main_toolbar_form");
146
147 if (!setFeedExpandoIcon(feed, is_cat,
148 (is_cat) ? 'images/indicator_tiny.gif' : 'images/indicator_white.gif'))
149 notify_progress("Loading, please wait...", true);
150 }
151
152 query += "&cat=" + is_cat;
153
154 console.log(query);
155
156 if (can_wait && _viewfeed_timeout) {
157 setFeedExpandoIcon(getActiveFeedId(), activeFeedIsCat(), 'images/blank_icon.gif');
158 clearTimeout(_viewfeed_timeout);
159 }
160
161 setActiveFeedId(feed, is_cat);
162
163 if (viewfeed_debug) {
164 window.open("backend.php" + query + "&debug=1&csrf_token=" + getInitParam("csrf_token"));
165 }
166
167 timeout_ms = can_wait ? 250 : 0;
168 _viewfeed_timeout = setTimeout(function() {
169
170 new Ajax.Request("backend.php", {
171 parameters: query,
172 onComplete: function(transport) {
173 try {
174 setFeedExpandoIcon(feed, is_cat, 'images/blank_icon.gif');
175 headlines_callback2(transport, offset, background, infscroll_req);
176 PluginHost.run(PluginHost.HOOK_FEED_LOADED, [feed, is_cat]);
177 } catch (e) {
178 exception_error(e);
179 }
180 } });
181 }, timeout_ms); // Wait 250ms
182
183 }
184
185 function feedlist_init() {
186 console.log("in feedlist init");
187
188 loading_set_progress(50);
189
190 document.onkeydown = hotkey_handler;
191 setTimeout(hotkey_prefix_timeout, 5*1000);
192
193 if (!getActiveFeedId()) {
194 viewfeed({feed: -3});
195 } else {
196 viewfeed({feed: getActiveFeedId(), is_cat: activeFeedIsCat()});
197 }
198
199 hideOrShowFeeds(getInitParam("hide_read_feeds") == 1);
200
201 setTimeout(timeout, 250);
202 }
203
204
205 function request_counters(force) {
206 var date = new Date();
207 var timestamp = Math.round(date.getTime() / 1000);
208
209 if (force || timestamp - counters_last_request > 5) {
210 console.log("scheduling request of counters...");
211
212 counters_last_request = timestamp;
213
214 var query = "?op=rpc&method=getAllCounters&seq=" + next_seq();
215
216 if (!force)
217 query = query + "&last_article_id=" + getInitParam("last_article_id");
218
219 console.log(query);
220
221 new Ajax.Request("backend.php", {
222 parameters: query,
223 onComplete: function(transport) {
224 handle_rpc_json(transport);
225 } });
226
227 } else {
228 console.log("request_counters: rate limit reached: " + (timestamp - counters_last_request));
229 }
230 }
231
232 // NOTE: this implementation is incomplete
233 // for general objects but good enough for counters
234 // http://adripofjavascript.com/blog/drips/object-equality-in-javascript.html
235 function counter_is_equal(a, b) {
236 // Create arrays of property names
237 var aProps = Object.getOwnPropertyNames(a);
238 var bProps = Object.getOwnPropertyNames(b);
239
240 // If number of properties is different,
241 // objects are not equivalent
242 if (aProps.length != bProps.length) {
243 return false;
244 }
245
246 for (var i = 0; i < aProps.length; i++) {
247 var propName = aProps[i];
248
249 // If values of same property are not equal,
250 // objects are not equivalent
251 if (a[propName] !== b[propName]) {
252 return false;
253 }
254 }
255
256 // If we made it this far, objects
257 // are considered equivalent
258 return true;
259 }
260
261
262 function parse_counters(elems) {
263 for (var l = 0; l < elems.length; l++) {
264
265 if (_counters_prev[l] && counter_is_equal(elems[l], _counters_prev[l])) {
266 continue;
267 }
268
269 var id = elems[l].id;
270 var kind = elems[l].kind;
271 var ctr = parseInt(elems[l].counter);
272 var error = elems[l].error;
273 var has_img = elems[l].has_img;
274 var updated = elems[l].updated;
275 var auxctr = parseInt(elems[l].auxcounter);
276
277 if (id == "global-unread") {
278 global_unread = ctr;
279 updateTitle();
280 continue;
281 }
282
283 if (id == "subscribed-feeds") {
284 /* feeds_found = ctr; */
285 continue;
286 }
287
288 /*if (getFeedUnread(id, (kind == "cat")) != ctr ||
289 (kind == "cat")) {
290 }*/
291
292 setFeedUnread(id, (kind == "cat"), ctr);
293 setFeedValue(id, (kind == "cat"), 'auxcounter', auxctr);
294
295 if (kind != "cat") {
296 setFeedValue(id, false, 'error', error);
297 setFeedValue(id, false, 'updated', updated);
298
299 if (id > 0) {
300 if (has_img) {
301 setFeedIcon(id, false,
302 getInitParam("icons_url") + "/" + id + ".ico");
303 } else {
304 setFeedIcon(id, false, 'images/blank_icon.gif');
305 }
306 }
307 }
308 }
309
310 hideOrShowFeeds(getInitParam("hide_read_feeds") == 1);
311
312 _counters_prev = elems;
313 }
314
315 function getFeedUnread(feed, is_cat) {
316 try {
317 var tree = dijit.byId("feedTree");
318
319 if (tree && tree.model)
320 return tree.model.getFeedUnread(feed, is_cat);
321
322 } catch (e) {
323 //
324 }
325
326 return -1;
327 }
328
329 function getFeedCategory(feed) {
330 try {
331 var tree = dijit.byId("feedTree");
332
333 if (tree && tree.model)
334 return tree.getFeedCategory(feed);
335
336 } catch (e) {
337 //
338 }
339
340 return false;
341 }
342
343 function hideOrShowFeeds(hide) {
344 var tree = dijit.byId("feedTree");
345
346 if (tree)
347 return tree.hideRead(hide, getInitParam("hide_read_shows_special"));
348 }
349
350 function getFeedName(feed, is_cat) {
351
352 if (isNaN(feed)) return feed; // it's a tag
353
354 var tree = dijit.byId("feedTree");
355
356 if (tree && tree.model)
357 return tree.model.getFeedValue(feed, is_cat, 'name');
358 }
359
360 function getFeedValue(feed, is_cat, key) {
361 try {
362 var tree = dijit.byId("feedTree");
363
364 if (tree && tree.model)
365 return tree.model.getFeedValue(feed, is_cat, key);
366
367 } catch (e) {
368 //
369 }
370 return '';
371 }
372
373 function setFeedUnread(feed, is_cat, unread) {
374 var tree = dijit.byId("feedTree");
375
376 if (tree && tree.model)
377 return tree.model.setFeedUnread(feed, is_cat, unread);
378 }
379
380 function setFeedValue(feed, is_cat, key, value) {
381 try {
382 var tree = dijit.byId("feedTree");
383
384 if (tree && tree.model)
385 return tree.model.setFeedValue(feed, is_cat, key, value);
386
387 } catch (e) {
388 //
389 }
390 }
391
392 function selectFeed(feed, is_cat) {
393 var tree = dijit.byId("feedTree");
394
395 if (tree) return tree.selectFeed(feed, is_cat);
396 }
397
398 function setFeedIcon(feed, is_cat, src) {
399 var tree = dijit.byId("feedTree");
400
401 if (tree) return tree.setFeedIcon(feed, is_cat, src);
402 }
403
404 function setFeedExpandoIcon(feed, is_cat, src) {
405 var tree = dijit.byId("feedTree");
406
407 if (tree) return tree.setFeedExpandoIcon(feed, is_cat, src);
408
409 return false;
410 }
411
412 function getNextUnreadFeed(feed, is_cat) {
413 var tree = dijit.byId("feedTree");
414 var nuf = tree.model.getNextUnreadFeed(feed, is_cat);
415
416 if (nuf)
417 return tree.model.store.getValue(nuf, 'bare_id');
418 }
419
420 function catchupCurrentFeed(mode) {
421 catchupFeed(getActiveFeedId(), activeFeedIsCat(), mode);
422 }
423
424 function catchupFeedInGroup(id) {
425 var title = getFeedName(id);
426
427 var str = __("Mark all articles in %s as read?").replace("%s", title);
428
429 if (getInitParam("confirm_feed_catchup") != 1 || confirm(str)) {
430
431 var rows = $$("#headlines-frame > div[id*=RROW][data-orig-feed-id='"+id+"']");
432
433 if (rows.length > 0) {
434
435 rows.each(function (row) {
436 row.removeClassName("Unread");
437
438 if (row.getAttribute("data-article-id") != getActiveArticleId()) {
439 new Effect.Fade(row, {duration: 0.5});
440 }
441
442 });
443
444 var feedTitles = $$("#headlines-frame > div[class='cdmFeedTitle']");
445
446 for (var i = 0; i < feedTitles.length; i++) {
447 if (feedTitles[i].getAttribute("data-feed-id") == id) {
448
449 if (i < feedTitles.length - 1) {
450 new Effect.Fade(feedTitles[i], {duration: 0.5});
451 }
452
453 break;
454 }
455 }
456
457 updateFloatingTitle(true);
458 }
459
460 var catchup_query = "?op=rpc&method=catchupFeed&feed_id=" +
461 id + "&is_cat=false";
462
463 console.log(catchup_query);
464
465 notify_progress("Loading, please wait...", true);
466
467 new Ajax.Request("backend.php", {
468 parameters: catchup_query,
469 onComplete: function (transport) {
470 handle_rpc_json(transport);
471 }
472 } );
473
474 //return viewCurrentFeed('MarkAllReadGR:' + id);
475 }
476 }
477
478 function catchupFeed(feed, is_cat, mode) {
479 if (is_cat == undefined) is_cat = false;
480
481 var str = false;
482
483 switch (mode) {
484 case "1day":
485 str = __("Mark %w in %s older than 1 day as read?");
486 break;
487 case "1week":
488 str = __("Mark %w in %s older than 1 week as read?");
489 break;
490 case "2week":
491 str = __("Mark %w in %s older than 2 weeks as read?");
492 break;
493 default:
494 str = __("Mark %w in %s as read?");
495 }
496
497 var mark_what = last_search_query && last_search_query[0] ? __("search results") : __("all articles");
498 var fn = getFeedName(feed, is_cat);
499
500 str = str.replace("%s", fn)
501 .replace("%w", mark_what);
502
503 if (getInitParam("confirm_feed_catchup") == 1 && !confirm(str)) {
504 return;
505 }
506
507 var catchup_query = {op: 'rpc', method: 'catchupFeed', feed_id: feed,
508 is_cat: is_cat, mode: mode, search_query: last_search_query[0],
509 search_lang: last_search_query[1]};
510
511 console.log(catchup_query);
512
513 notify_progress("Loading, please wait...", true);
514
515 new Ajax.Request("backend.php", {
516 parameters: catchup_query,
517 onComplete: function(transport) {
518 handle_rpc_json(transport);
519
520 var show_next_feed = getInitParam("on_catchup_show_next_feed") == "1";
521
522 if (show_next_feed) {
523 var nuf = getNextUnreadFeed(feed, is_cat);
524
525 if (nuf) {
526 viewfeed({feed: nuf, is_cat: is_cat});
527 }
528 } else {
529 if (feed == getActiveFeedId() && is_cat == activeFeedIsCat()) {
530 viewCurrentFeed();
531 }
532 }
533
534 notify("");
535 } });
536
537 }
538
539 function decrementFeedCounter(feed, is_cat) {
540 var ctr = getFeedUnread(feed, is_cat);
541
542 if (ctr > 0) {
543 setFeedUnread(feed, is_cat, ctr - 1);
544 global_unread = global_unread - 1;
545 updateTitle();
546
547 if (!is_cat) {
548 var cat = parseInt(getFeedCategory(feed));
549
550 if (!isNaN(cat)) {
551 ctr = getFeedUnread(cat, true);
552
553 if (ctr > 0) {
554 setFeedUnread(cat, true, ctr - 1);
555 }
556 }
557 }
558 }
559
560 }
561
562