2 require "xmlrpc/lib/xmlrpc.inc";
3 require "xmlrpc/lib/xmlrpcs.inc";
5 require_once "sanity_check.php";
6 require_once "config.php";
9 require_once "db-prefs.php";
10 require_once "functions.php";
12 $link = db_connect(DB_HOST
, DB_USER
, DB_PASS
, DB_NAME
);
15 if (DB_TYPE
== "mysql") {
18 // PG seems to display its own errors just fine by default.
22 if (DB_TYPE
== "pgsql") {
23 pg_query("set client_encoding = 'utf-8'");
26 function getCategories($msg) {
29 $login_o = $msg->getParam(0);
30 $pass_o = $msg->getParam(1);
32 $login = $login_o->scalarval();
33 $pass = $pass_o->scalarval();
35 $user_id = authenticate_user($link, $login, $pass);
39 if (authenticate_user($link, $login, $pass)) {
41 $result = db_query($link, "SELECT
42 id, title FROM ttrss_feed_categories
48 while ($line = db_fetch_assoc($result)) {
50 $unread = getFeedUnread($link, $line["id"]);
52 $line_struct = new xmlrpcval(
54 "title" => new xmlrpcval($line["title"]),
55 "id" => new xmlrpcval($line["id"], "int")
59 array_push($feeds, $line_struct);
62 $reply = new xmlrpcval($feeds, "array");
65 $reply = "Login failed.";
69 if ($error_code != 0) {
70 return new xmlrpcresp(0, $error_code, $reply_msg);
72 return new xmlrpcresp($reply);
77 function getTotalUnread($msg) {
82 $login_o = $msg->getParam(0);
83 $pass_o = $msg->getParam(1);
85 $login = $login_o->scalarval();
86 $pass = $pass_o->scalarval();
88 $user_id = authenticate_user($link, $login, $pass);
91 if (authenticate_user($link, $login, $pass)) {
93 $reply_msg = getGlobalUnread($link);
96 $reply_msg = "Login failed.";
100 if ($error_code != 0) {
101 return new xmlrpcresp(0, $error_code, $reply_msg);
103 return new xmlrpcresp(new xmlrpcval($reply_msg));
108 function getVersion() {
109 return new xmlrpcval(VERSION
);
112 function getSubscribedFeeds($msg) {
115 $login_o = $msg->getParam(0);
116 $pass_o = $msg->getParam(1);
118 $login = $login_o->scalarval();
119 $pass = $pass_o->scalarval();
121 $user_id = authenticate_user($link, $login, $pass);
123 if (authenticate_user($link, $login, $pass)) {
125 $result = db_query($link, "SELECT
126 id, feed_url, cat_id, title, SUBSTRING(last_updated,1,19) AS last_updated
127 FROM ttrss_feeds WHERE owner_uid = " .
132 while ($line = db_fetch_assoc($result)) {
134 $unread = getFeedUnread($link, $line["id"]);
136 $line_struct = new xmlrpcval(
138 "feed_url" => new xmlrpcval($line["feed_url"]),
139 "title" => new xmlrpcval($line["title"]),
140 "id" => new xmlrpcval($line["id"], "int"),
141 "unread" => new xmlrpcval($unread, "int"),
142 "category_id" => new xmlrpcval($line["cat_id"], "int"),
143 "last_updated" => new xmlrpcval(strtotime($line["last_updated"]), "int")
147 array_push($feeds, $line_struct);
150 $reply = new xmlrpcval($feeds, "array");
153 $reply = new xmlrpcval("Login failed.");
156 return new xmlrpcresp($reply);
159 function subscribeToFeed($msg) {
164 $login_o = $msg->getParam(0);
165 $pass_o = $msg->getParam(1);
166 $feed_url_o = $msg->getParam(2);
168 $login = $login_o->scalarval();
169 $pass = $pass_o->scalarval();
170 $feed_url = $feed_url_o->scalarval();
172 if (authenticate_user($link, $login, $pass)) {
173 if (subscribe_to_feed($link, $feed_url)) {
174 $reply_msg = "Subscribed successfully.";
176 $reply_msg = "Feed already exists in the database.";
180 $reply_msg = "Login failed.";
184 if ($error_code != 0) {
185 return new xmlrpcresp(0, $error_code, $reply_msg);
187 return new xmlrpcresp(new xmlrpcval($reply_msg));
191 function getFeedHeadlines($msg) {
196 $login_o = $msg->getParam(0);
197 $pass_o = $msg->getParam(1);
198 $feed_id_o = $msg->getParam(2);
199 $limit_o = $msg->getParam(3);
200 $filter_o = $msg->getParam(4);
202 $login = $login_o->scalarval();
203 $pass = $pass_o->scalarval();
204 $feed_id = $feed_id_o->scalarval();
205 $limit = $limit_o->scalarval();
206 $filter = $filter_o->scalarval();
208 if (authenticate_user($link, $login, $pass)) {
211 $limit_query_part = "LIMIT $limit";
215 $query_strategy_part = "unread = true";
216 } else if ($filter == 2) {
217 $query_strategy_part = "marked = true";
219 $query_strategy_part = "ttrss_entries.id > 0";
223 ttrss_entries.id,ttrss_entries.title,
224 SUBSTRING(updated,1,16) as updated,
225 unread,feed_id,marked,link,last_read,
226 SUBSTRING(last_read,1,19) as last_read_noms,
227 SUBSTRING(updated,1,19) as updated_noms
229 ttrss_entries,ttrss_user_entries,ttrss_feeds
231 ttrss_feeds.id = '$feed_id' AND
232 ttrss_user_entries.feed_id = ttrss_feeds.id AND
233 ttrss_user_entries.ref_id = ttrss_entries.id AND
234 ttrss_user_entries.owner_uid = '".$_SESSION["uid"]."' AND
235 $query_strategy_part ORDER BY updated
238 $result = db_query($link, $query);
242 while ($line = db_fetch_assoc($result)) {
245 $line_struct = new xmlrpcval(
247 "id" => new xmlrpcval($line["id"], "int"),
248 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
249 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
250 "updated" => new xmlrpcval(strtotime($line["updated"]), "int"),
251 "title" => new xmlrpcval($line["title"])
255 array_push($articles, $line_struct);
259 $reply = new xmlrpcval($articles, "array");
262 $reply_msg = "Login failed.";
266 if ($error_code != 0) {
267 return new xmlrpcresp(0, $error_code, $reply_msg);
269 return new xmlrpcresp($reply);
274 function getArticle($msg) {
279 $login_o = $msg->getParam(0);
280 $pass_o = $msg->getParam(1);
281 $article_id_o = $msg->getParam(2);
283 $login = $login_o->scalarval();
284 $pass = $pass_o->scalarval();
285 $article_id = $article_id_o->scalarval();
287 if (authenticate_user($link, $login, $pass)) {
289 $query = "SELECT title,link,content,feed_id,comments,int_id,
291 SUBSTRING(updated,1,16) as updated,
293 FROM ttrss_entries,ttrss_user_entries
294 WHERE id = '$article_id' AND ref_id = id AND owner_uid = " . $_SESSION["uid"] ;
296 $result = db_query($link, $query);
298 if (db_num_rows($result) == 1) {
300 $line = db_fetch_assoc($result);
302 $reply = new xmlrpcval(
304 "title" => new xmlrpcval($line["title"]),
305 "link" => new xmlrpcval($line["link"]),
306 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
307 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
308 "comments" => new xmlrpcval($line["comments"]),
309 "author" => new xmlrpcval($line["author"]),
310 "updated" => new xmlrpcval(strtotime($line["updated"], "int")),
311 "content" => new xmlrpcval($line["content"])
316 $reply_msg = "Article not found.";
321 $reply_msg = "Login failed.";
325 if ($error_code != 0) {
326 return new xmlrpcresp(0, $error_code, $reply_msg);
328 return new xmlrpcresp($reply);
332 function setArticleMarked($msg) {
337 $login_o = $msg->getParam(0);
338 $pass_o = $msg->getParam(1);
339 $article_id_o = $msg->getParam(2);
340 $marked_o = $msg->getParam(3);
342 $login = $login_o->scalarval();
343 $pass = $pass_o->scalarval();
344 $article_id = $article_id_o->scalarval();
345 $marked = $marked_o->scalarval();
347 if (authenticate_user($link, $login, $pass)) {
350 $query_strategy_part = "marked = false";
351 } else if ($marked == 1) {
352 $query_strategy_part = "marked = true";
353 } else if ($marked == 2) {
354 $query_strategy_part = "marked = NOT marked";
357 $result = db_query($link, "UPDATE ttrss_user_entries SET
358 $query_strategy_part WHERE ref_id = '$article_id' AND
359 owner_uid = " . $_SESSION["uid"]);
361 if (db_affected_rows($link, $result) == 1) {
365 $reply_msg = "Failed to update article.";
369 $reply_msg = "Login failed.";
373 if ($error_code != 0) {
374 return new xmlrpcresp(0, $error_code, $reply_msg);
376 return new xmlrpcresp(new xmlrpcval($reply_msg));
381 function setArticleRead($msg) {
386 $login_o = $msg->getParam(0);
387 $pass_o = $msg->getParam(1);
388 $article_id_o = $msg->getParam(2);
389 $read_o = $msg->getParam(3);
391 $login = $login_o->scalarval();
392 $pass = $pass_o->scalarval();
393 $article_id = $article_id_o->scalarval();
394 $read = $read_o->scalarval();
396 if (authenticate_user($link, $login, $pass)) {
399 $query_strategy_part = "unread = true";
400 } else if ($read == 1) {
401 $query_strategy_part = "unread = false";
402 } else if ($read == 2) {
403 $query_strategy_part = "unread = NOT unread";
406 $result = db_query($link, "UPDATE ttrss_user_entries SET
407 $query_strategy_part WHERE ref_id = '$article_id' AND
408 owner_uid = " . $_SESSION["uid"]);
410 if (db_affected_rows($link, $result) == 1) {
414 $reply_msg = "Failed to update article.";
418 $reply_msg = "Login failed.";
422 if ($error_code != 0) {
423 return new xmlrpcresp(0, $error_code, $reply_msg);
425 return new xmlrpcresp(new xmlrpcval($reply_msg));
430 $subscribeToFeed_sig = array(array($xmlrpcString,
431 $xmlrpcString, $xmlrpcString, $xmlrpcString));
433 $getSubscribedFeeds_sig = array(array($xmlrpcString,
434 $xmlrpcString, $xmlrpcString));
436 $getFeedHeadlines_sig = array(array($xmlrpcString,
437 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt, $xmlrpcInt));
439 $getArticle_sig = array(array($xmlrpcString,
440 $xmlrpcString, $xmlrpcString, $xmlrpcInt));
442 $setArticleMarked_sig = array(array($xmlrpcString,
443 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
445 $setArticleUnread_sig = array(array($xmlrpcString,
446 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
448 $getVersion_sig = array(array($xmlrpcString));
450 $getTotalUnread_sig = array(array($xmlrpcInt, $xmlrpcString,
453 $getCategories_sig = array(array($xmlrpcString,
454 $xmlrpcString, $xmlrpcString));
456 $s = new xmlrpc_server(
458 "rss.getCategories" => array("function" => "getCategories",
459 "signature" => $getCategories_sig),
460 "rss.getTotalUnread" => array("function" => "getTotalUnread",
461 "signature" => $getTotalUnread_sig),
462 "rss.getVersion" => array("function" => "getVersion",
463 "signature" => $getVersion_sig),
464 "rss.setArticleRead" => array("function" => "setArticleRead",
465 "signature" => $setArticleRead_sig),
466 "rss.setArticleMarked" => array("function" => "setArticleMarked",
467 "signature" => $setArticleMarked_sig),
468 "rss.getArticle" => array("function" => "getArticle",
469 "signature" => $getArticle_sig),
470 "rss.getFeedHeadlines" => array("function" => "getFeedHeadlines",
471 "signature" => $getFeedHeadlines_sig),
472 "rss.getSubscribedFeeds" => array("function" => "getSubscribedFeeds",
473 "signature" => $getSubscribedFeeds_sig),
474 "rss.subscribeToFeed" => array("function" => "subscribeToFeed",
475 "signature" => $subscribeToFeed_sig)), 0
477 $s->response_charset_encoding
= "UTF-8";