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