+ print "<mode value=\"$mode\"/>";
+ print "</rpc-reply>";
+
+ return;
+ }
+
+
+ if ($subop == "massSubscribe") {
+
+ $ids = split(",", db_escape_string($_REQUEST["ids"]));
+ $mode = $_REQUEST["mode"];
+
+ $subscribed = array();
+
+ foreach ($ids as $id) {
+
+ if ($mode == 1) {
+ $result = db_query($link, "SELECT feed_url,title FROM ttrss_feeds
+ WHERE id = '$id'");
+ } else if ($mode == 2) {
+ $result = db_query($link, "SELECT * FROM ttrss_archived_feeds
+ WHERE id = '$id' AND owner_uid = " . $_SESSION["uid"]);
+ $orig_id = db_escape_string(db_fetch_result($result, 0, "id"));
+ $site_url = db_escape_string(db_fetch_result($result, 0, "site_url"));
+ }
+
+ $feed_url = db_escape_string(db_fetch_result($result, 0, "feed_url"));
+ $title = db_escape_string(db_fetch_result($result, 0, "title"));
+
+ $title_orig = db_fetch_result($result, 0, "title");
+
+ $result = db_query($link, "SELECT id FROM ttrss_feeds WHERE
+ feed_url = '$feed_url' AND owner_uid = " . $_SESSION["uid"]);
+
+ if (db_num_rows($result) == 0) {
+ if ($mode == 1) {
+ $result = db_query($link,
+ "INSERT INTO ttrss_feeds (owner_uid,feed_url,title,cat_id)
+ VALUES ('".$_SESSION["uid"]."', '$feed_url', '$title', NULL)");
+ } else if ($mode == 2) {
+ $result = db_query($link,
+ "INSERT INTO ttrss_feeds (id,owner_uid,feed_url,title,cat_id,site_url)
+ VALUES ('$orig_id','".$_SESSION["uid"]."', '$feed_url', '$title', NULL, '$site_url')");
+ }
+ array_push($subscribed, $title_orig);
+ }
+ }
+
+ $num_feeds = count($subscribed);
+
+ print "<rpc-reply>";
+ print "<num-feeds value='$num_feeds'/>";
+ print "</rpc-reply>";
+
+ return;
+ }
+
+ if ($subop == "download") {
+ $stage = (int) $_REQUEST["stage"];
+ $cidt = (int)db_escape_string($_REQUEST["cidt"]);
+ $cidb = (int)db_escape_string($_REQUEST["cidb"]);
+ $sync = db_escape_string($_REQUEST["sync"]);
+ //$amount = (int) $_REQUEST["amount"];
+ //$unread_only = db_escape_string($_REQUEST["unread_only"]);
+ //if (!$amount) $amount = 50;
+
+ /* Amount is not used by the frontend offline.js anymore, it goes by
+ * date_qpart below + cidb/cidt IDs */
+
+ $amount = 2000;
+ $unread_only = true;
+
+ print "<rpc-reply>";
+
+ $sync = split(";", $sync);
+
+ print "<sync>";
+
+ if (count($sync) > 0) {
+ if (strtotime($sync[0])) {
+ $last_online = db_escape_string($sync[0]);
+
+ print "<sync-point><![CDATA[$last_online]]></sync-point>";
+
+ for ($i = 1; $i < count($sync); $i++) {
+ $e = split(",", $sync[$i]);
+
+ if (count($e) == 3) {
+
+ $id = (int) $e[0];
+ $unread = bool_to_sql_bool((bool) $e[1]);
+ $marked = (bool)$e[2];
+
+ if ($marked) {
+ $marked = bool_to_sql_bool($marked);
+ $marked_qpart = "marked = $marked,";
+ }
+
+ $query = "UPDATE ttrss_user_entries SET
+ $marked_qpart
+ unread = $unread,
+ last_read = '$last_online'
+ WHERE ref_id = '$id' AND
+ (last_read IS NULL OR last_read < '$last_online') AND
+ owner_uid = ".$_SESSION["uid"];
+
+ $result = db_query($link, $query);
+
+ print "<sync-ok id=\"$id\"/>";
+
+ }
+ }
+
+ /* Maybe we need to further update local DB for this client */
+
+ $query = "SELECT ref_id,unread,marked FROM ttrss_user_entries
+ WHERE last_read >= '$last_online' AND
+ owner_uid = ".$_SESSION["uid"] . " LIMIT 1000";
+
+ $result = db_query($link, $query);
+
+ while ($line = db_fetch_assoc($result)) {
+ $unread = (int) sql_bool_to_bool($line["unread"]);
+ $marked = (int) sql_bool_to_bool($line["marked"]);
+
+ print "<sync-ok unread=\"$unread\" marked=\"$marked\"
+ id=\"".$line["ref_id"]."\"/>";
+ }
+
+ }
+ }
+
+ print "</sync>";
+
+ if ($stage == 0) {
+ print "<feeds>";
+
+ $result = db_query($link, "SELECT id, title, cat_id FROM
+ ttrss_feeds WHERE owner_uid = ".$_SESSION["uid"]);
+
+ while ($line = db_fetch_assoc($result)) {
+
+ $has_icon = (int) feed_has_icon($line["id"]);
+
+ print "<feed has_icon=\"$has_icon\"
+ cat_id=\"".(int)$line["cat_id"]."\" id=\"".$line["id"]."\"><![CDATA[";
+ print $line["title"];
+ print "]]></feed>";
+ }
+
+ print "</feeds>";
+
+ print "<feed-categories>";
+
+ $result = db_query($link, "SELECT id, title, collapsed FROM
+ ttrss_feed_categories WHERE owner_uid = ".$_SESSION["uid"]);
+
+ print "<category id=\"0\" collapsed=\"".
+ (int)get_pref($link, "_COLLAPSED_UNCAT")."\"><![CDATA[";
+ print __("Uncategorized");
+ print "]]></category>";
+
+ print "<category id=\"-1\" collapsed=\"".
+ (int)get_pref($link, "_COLLAPSED_SPECIAL")."\"><![CDATA[";
+ print __("Special");
+ print "]]></category>";
+
+ print "<category id=\"-2\" collapsed=\"".
+ (int)get_pref($link, "_COLLAPSED_LABELS")."\"><![CDATA[";
+ print __("Labels");
+ print "]]></category>";
+
+ while ($line = db_fetch_assoc($result)) {
+ print "<category
+ id=\"".$line["id"]."\"
+ collapsed=\"".(int)sql_bool_to_bool($line["collapsed"])."\"><![CDATA[";
+ print $line["title"];
+ print "]]></category>";
+ }
+
+ print "</feed-categories>";
+
+ print "<labels>";
+
+ $result = db_query($link, "SELECT * FROM
+ ttrss_labels2 WHERE owner_uid = ".$_SESSION["uid"]);
+
+ while ($line = db_fetch_assoc($result)) {
+ print "<label
+ id=\"".$line["id"]."\"
+ fg_color=\"".$line["fg_color"]."\"
+ bg_color=\"".$line["bg_color"]."\"
+ ><![CDATA[";
+ print $line["caption"];
+ print "]]></label>";
+ }
+
+
+ print "</labels>";
+
+ }
+
+ if ($stage > 0) {
+ print "<articles>";
+
+ $limit = 10;
+ $skip = $limit*($stage-1);
+
+ print "<limit value=\"$limit\"/>";
+
+ if ($amount > 0) $amount -= $skip;
+
+ if ($amount > 0) {
+
+ $limit = min($limit, $amount);
+
+ if ($unread_only) {
+ $unread_qpart = "(unread = true OR marked = true) AND ";
+ }
+
+ if ($cidt && $cidb) {
+ $cid_qpart = "(ttrss_entries.id > $cidt OR ttrss_entries.id < $cidb) AND ";
+ }
+
+ if (DB_TYPE == "pgsql") {
+ $date_qpart = "updated >= NOW() - INTERVAL '1 week' AND";
+ } else {
+ $date_qpart = "updated >= DATE_SUB(NOW(), INTERVAL 1 WEEK) AND";
+ }
+
+ $result = db_query($link,
+ "SELECT DISTINCT ttrss_entries.id,ttrss_entries.title,
+ guid,link,comments,
+ feed_id,content,updated,unread,marked FROM
+ ttrss_user_entries,ttrss_entries,ttrss_feeds
+ WHERE $unread_qpart $cid_qpart $date_qpart
+ ttrss_feeds.id = feed_id AND
+ ref_id = ttrss_entries.id AND
+ ttrss_user_entries.owner_uid = ".$_SESSION["uid"]."
+ ORDER BY updated DESC LIMIT $limit OFFSET $skip");
+
+ if (function_exists('json_encode')) {
+
+ while ($line = db_fetch_assoc($result)) {
+ print "<article><![CDATA[";
+
+ $line["marked"] = (int)sql_bool_to_bool($line["marked"]);
+ $line["unread"] = (int)sql_bool_to_bool($line["unread"]);
+
+ $line["labels"] = get_article_labels($link, $line["id"]);
+
+// too slow :(
+// $line["tags"] = format_tags_string(
+// get_article_tags($link, $line["id"]), $line["id"]);
+
+ print json_encode($line);
+ print "]]></article>";
+ }
+ }
+
+ }
+
+ print "</articles>";
+
+ }
+
+ print "</rpc-reply>";
+
+ return;
+ }
+
+ if ($subop == "digest-get-contents") {
+ $article_id = db_escape_string($_REQUEST['article_id']);
+
+ $result = db_query($link, "SELECT content
+ FROM ttrss_entries, ttrss_user_entries
+ WHERE id = '$article_id' AND ref_id = id AND owner_uid = ".$_SESSION['uid']);
+
+ print "<rpc-reply>";
+
+ print "<article id=\"$article_id\"><![CDATA[";
+
+ $content = sanitize_rss($link, db_fetch_result($result, 0, "content"));
+
+ print $content;
+
+ print "]]></article>";
+
+ print "</rpc-reply>";
+
+ return;
+ }
+
+ if ($subop == "digest-update") {
+ $feed_id = db_escape_string($_REQUEST['feed_id']);
+ $offset = db_escape_string($_REQUEST['offset']);
+ $seq = db_escape_string($_REQUEST['seq']);
+
+ if (!$feed_id) $feed_id = -4;
+ if (!$offset) $offset = 0;
+ print "<rpc-reply>";
+
+ print "<seq>$seq</seq>";
+
+ $headlines = api_get_headlines($link, $feed_id, 10, $offset,
+ '', ($feed_id == -4), true, false, "unread", "updated DESC");
+
+ //function api_get_headlines($link, $feed_id, $limit, $offset,
+ // $filter, $is_cat, $show_excerpt, $show_content, $view_mode) {
+
+ print "<headlines-title><![CDATA[" . getFeedTitle($link, $feed_id) .
+ "]]></headlines-title>";
+
+ print "<headlines><![CDATA[" . json_encode($headlines) . "]]></headlines>";
+
+ print "</rpc-reply>";
+ return;
+ }
+
+ if ($subop == "digest-init") {
+ print "<rpc-reply>";
+
+ $tmp_feeds = api_get_feeds($link, false, true, false, 0);
+ $feeds = array();
+
+ foreach ($tmp_feeds as $f) {
+ if ($f['id'] > 0 || $f['id'] == -4) array_push($feeds, $f);
+ }
+
+ print "<feeds><![CDATA[" . json_encode($feeds) . "]]></feeds>";
+
+ print "</rpc-reply>";
+ return;
+ }
+
+ if ($subop == "catchupFeed") {
+
+ $feed_id = db_escape_string($_REQUEST['feed_id']);
+ $is_cat = db_escape_string($_REQUEST['is_cat']);
+
+ print "<rpc-reply>";
+
+ catchup_feed($link, $feed_id, $is_cat);
+