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