xml-rpc.php

   1 <?
   2         require "xmlrpc/lib/xmlrpc.inc";
   3         require "xmlrpc/lib/xmlrpcs.inc";
   4
   5         require_once "sanity_check.php";
   6         require_once "config.php";
   7
   8         require_once "db.php";
   9         require_once "db-prefs.php";
  10         require_once "functions.php";
  11
  12         $link = db_connect(DB_HOST, DB_USER, DB_PASS, DB_NAME);
  13
  14         if (!$link) {
  15                 if (DB_TYPE == "mysql") {
  16                         print mysql_error();
  17                 }
  18                 // PG seems to display its own errors just fine by default.
  19                 return;
  20         }
  21
  22         if (DB_TYPE == "pgsql") {
  23                 pg_query("set client_encoding = 'utf-8'");
  24         }
  25
  26         function getSubscribedFeeds($msg) {
  27                 global $link;
  28
  29                 $login_o = $msg->getParam(0);
  30                 $pass_o = $msg->getParam(1);
  31
  32                 $login = $login_o->scalarval();
  33                 $pass = $pass_o->scalarval();
  34
  35                 $user_id = authenticate_user($link, $login, $pass);
  36
  37                 if (authenticate_user($link, $login, $pass)) {
  38
  39                         $result = db_query($link, "SELECT
  40                                 id, feed_url, title, SUBSTRING(last_updated,1,19) AS last_updated
  41                                         FROM ttrss_feeds WHERE owner_uid = " .
  42                                 $_SESSION["uid"]);
  43
  44                         $feeds = array();
  45
  46                         while ($line = db_fetch_assoc($result)) {
  47
  48                                 $unread = getFeedUnread($link, $line["id"]);
  49
  50                                 $line_struct = new xmlrpcval(
  51                                         array(
  52                                                 "feed_url" => new xmlrpcval($line["feed_url"]),
  53                                                 "title" => new xmlrpcval($line["title"]),
  54                                                 "id" => new xmlrpcval($line["id"], "int"),
  55                                                 "unread" => new xmlrpcval($unread, "int"),
  56                                                 "last_updated" => new xmlrpcval(strtotime($line["last_updated"]), "int")
  57                                         ),
  58                                         "struct");
  59
  60                                 array_push($feeds, $line_struct);
  61                         }
  62
  63                         $reply = new xmlrpcval($feeds, "array");
  64
  65                 } else {
  66                         $reply = new xmlrpcval("Login failed.");
  67                 }
  68
  69                 return new xmlrpcresp($reply);
  70         }
  71
  72         function subscribeToFeed($msg) {
  73                 global $link;
  74
  75                 $error_code = 0;
  76
  77                 $login_o = $msg->getParam(0);
  78                 $pass_o = $msg->getParam(1);
  79                 $feed_url_o = $msg->getParam(2);
  80
  81                 $login = $login_o->scalarval();
  82                 $pass = $pass_o->scalarval();
  83                 $feed_url = $feed_url_o->scalarval();
  84
  85                 if (authenticate_user($link, $login, $pass)) {
  86                         if (subscribe_to_feed($link, $feed_url)) {
  87                                 $reply_msg = "Subscribed successfully.";
  88                         } else {
  89                                 $reply_msg = "Feed already exists in the database.";
  90                                 $error_code = 2;
  91                         }
  92                 } else {
  93                         $reply_msg = "Login failed.";
  94                         $error_code = 1;
  95                 }
  96
  97                 if ($error_code != 0) {
  98                         return new xmlrpcresp(0, $error_code, $reply_msg);
  99                 } else {
 100                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 101                 }
 102         }
 103
 104         function getFeedHeadlines($msg) {
 105                 global $link;
 106
 107                 $error_code = 0;
 108
 109                 $login_o = $msg->getParam(0);
 110                 $pass_o = $msg->getParam(1);
 111                 $feed_id_o = $msg->getParam(2);
 112                 $limit_o = $msg->getParam(3);
 113                 $filter_o = $msg->getParam(4);
 114
 115                 $login = $login_o->scalarval();
 116                 $pass = $pass_o->scalarval();
 117                 $feed_id = $feed_id_o->scalarval();
 118                 $limit = $limit_o->scalarval();
 119                 $filter = $filter_o->scalarval();
 120
 121                 if (authenticate_user($link, $login, $pass)) {
 122
 123                         if ($limit > 0) {
 124                                 $limit_query_part = "LIMIT $limit";
 125                         }
 126
 127                         if ($filter == 1) {
 128                                 $query_strategy_part = "unread = true";
 129                         } else if ($filter == 2) {
 130                                 $query_strategy_part = "marked = true";
 131                         } else {
 132                                 $query_strategy_part = "ttrss_entries.id > 0";
 133                         }
 134
 135                         $query = "SELECT
 136                                         ttrss_entries.id,ttrss_entries.title,
 137                                         SUBSTRING(updated,1,16) as updated,
 138                                         unread,feed_id,marked,link,last_read,
 139                                         SUBSTRING(last_read,1,19) as last_read_noms,
 140                                         SUBSTRING(updated,1,19) as updated_noms
 141                                 FROM
 142                                         ttrss_entries,ttrss_user_entries,ttrss_feeds
 143                                 WHERE
 144                                 ttrss_feeds.id = '$feed_id' AND
 145                                 ttrss_user_entries.feed_id = ttrss_feeds.id AND
 146                                 ttrss_user_entries.ref_id = ttrss_entries.id AND
 147                                 ttrss_user_entries.owner_uid = '".$_SESSION["uid"]."' AND
 148                                 $query_strategy_part ORDER BY updated
 149                                 $limit_query_part";
 150
 151                         $result = db_query($link, $query);
 152
 153                         $articles = array();
 154
 155                         while ($line = db_fetch_assoc($result)) {
 156
 157
 158                                 $line_struct = new xmlrpcval(
 159                                         array(
 160                                                 "id" => new xmlrpcval($line["id"], "int"),
 161                                                 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
 162                                                 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
 163                                                 "updated" => new xmlrpcval(strtotime($line["updated"]), "int"),
 164                                                 "title" => new xmlrpcval($line["title"])
 165                                         ),
 166                                         "struct");
 167
 168                                 array_push($articles, $line_struct);
 169
 170                         }
 171
 172                         $reply = new xmlrpcval($articles, "array");
 173
 174                 } else {
 175                         $reply_msg = "Login failed.";
 176                         $error_code = 1;
 177                 }
 178
 179                 if ($error_code != 0) {
 180                         return new xmlrpcresp(0, $error_code, $reply_msg);
 181                 } else {
 182                         return new xmlrpcresp($reply);
 183                 }
 184
 185         }
 186
 187         function getArticle($msg) {
 188                 global $link;
 189
 190                 $error_code = 0;
 191
 192                 $login_o = $msg->getParam(0);
 193                 $pass_o = $msg->getParam(1);
 194                 $article_id_o = $msg->getParam(2);
 195
 196                 $login = $login_o->scalarval();
 197                 $pass = $pass_o->scalarval();
 198                 $article_id = $article_id_o->scalarval();
 199
 200                 if (authenticate_user($link, $login, $pass)) {
 201
 202                         $query = "SELECT title,link,content,feed_id,comments,int_id,
 203                                 marked,unread,
 204                                 SUBSTRING(updated,1,16) as updated,
 205                                 author
 206                                 FROM ttrss_entries,ttrss_user_entries
 207                                 WHERE   id = '$article_id' AND ref_id = id AND owner_uid = " . $_SESSION["uid"] ;
 208
 209                         $result = db_query($link, $query);
 210
 211                         if (db_num_rows($result) == 1) {
 212
 213                                 $line = db_fetch_assoc($result);
 214
 215                                 $reply = new xmlrpcval(
 216                                         array(
 217                                                 "title" => new xmlrpcval($line["title"]),
 218                                                 "link" => new xmlrpcval($line["link"]),
 219                                                 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
 220                                                 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
 221                                                 "comments" => new xmlrpcval($line["comments"]),
 222                                                 "author" => new xmlrpcval($line["author"]),
 223                                                 "updated" => new xmlrpcval(strtotime($line["updated"], "int")),
 224                                                 "content" => new xmlrpcval($line["content"])
 225                                         ),
 226                                         "struct");
 227
 228                         } else {
 229                                 $reply_msg = "Article not found.";
 230                                 $error_code = 2;
 231                         }
 232
 233                 } else {
 234                         $reply_msg = "Login failed.";
 235                         $error_code = 1;
 236                 }
 237
 238                 if ($error_code != 0) {
 239                         return new xmlrpcresp(0, $error_code, $reply_msg);
 240                 } else {
 241                         return new xmlrpcresp($reply);
 242                 }
 243         }
 244
 245         function setArticleMarked($msg) {
 246                 global $link;
 247
 248                 $error_code = 0;
 249
 250                 $login_o = $msg->getParam(0);
 251                 $pass_o = $msg->getParam(1);
 252                 $article_id_o = $msg->getParam(2);
 253                 $marked_o = $msg->getParam(3);
 254
 255                 $login = $login_o->scalarval();
 256                 $pass = $pass_o->scalarval();
 257                 $article_id = $article_id_o->scalarval();
 258                 $marked = $marked_o->scalarval();
 259
 260                 if (authenticate_user($link, $login, $pass)) {
 261
 262                         if ($marked == 0) {
 263                                 $query_strategy_part = "marked = false";
 264                         } else if ($marked == 1) {
 265                                 $query_strategy_part = "marked = true";
 266                         } else if ($marked == 2) {
 267                                 $query_strategy_part = "marked = NOT marked";
 268                         }
 269
 270                         $result = db_query($link, "UPDATE ttrss_user_entries SET
 271                                 $query_strategy_part WHERE ref_id = '$article_id' AND
 272                                 owner_uid = " . $_SESSION["uid"]);
 273
 274                         if (db_affected_rows($link, $result) == 1) {
 275                                 $reply_msg = "OK";
 276                         } else {
 277                                 $error_code = 2;
 278                                 $reply_msg = "Failed to update article.";
 279                         }
 280
 281                 } else {
 282                         $reply_msg = "Login failed.";
 283                         $error_code = 1;
 284                 }
 285
 286                 if ($error_code != 0) {
 287                         return new xmlrpcresp(0, $error_code, $reply_msg);
 288                 } else {
 289                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 290                 }
 291
 292         }
 293
 294         function setArticleRead($msg) {
 295                 global $link;
 296
 297                 $error_code = 0;
 298
 299                 $login_o = $msg->getParam(0);
 300                 $pass_o = $msg->getParam(1);
 301                 $article_id_o = $msg->getParam(2);
 302                 $read_o = $msg->getParam(3);
 303
 304                 $login = $login_o->scalarval();
 305                 $pass = $pass_o->scalarval();
 306                 $article_id = $article_id_o->scalarval();
 307                 $read = $read_o->scalarval();
 308
 309                 if (authenticate_user($link, $login, $pass)) {
 310
 311                         if ($read == 0) {
 312                                 $query_strategy_part = "unread = true";
 313                         } else if ($read == 1) {
 314                                 $query_strategy_part = "unread = false";
 315                         } else if ($read == 2) {
 316                                 $query_strategy_part = "unread = NOT unread";
 317                         }
 318
 319                         $result = db_query($link, "UPDATE ttrss_user_entries SET
 320                                 $query_strategy_part WHERE ref_id = '$article_id' AND
 321                                 owner_uid = " . $_SESSION["uid"]);
 322
 323                         if (db_affected_rows($link, $result) == 1) {
 324                                 $reply_msg = "OK";
 325                         } else {
 326                                 $error_code = 2;
 327                                 $reply_msg = "Failed to update article.";
 328                         }
 329
 330                 } else {
 331                         $reply_msg = "Login failed.";
 332                         $error_code = 1;
 333                 }
 334
 335                 if ($error_code != 0) {
 336                         return new xmlrpcresp(0, $error_code, $reply_msg);
 337                 } else {
 338                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 339                 }
 340
 341         }
 342
 343         $subscribeToFeed_sig = array(array($xmlrpcString,
 344                 $xmlrpcString, $xmlrpcString, $xmlrpcString));
 345
 346         $getSubscribedFeeds_sig = array(array($xmlrpcString,
 347                 $xmlrpcString, $xmlrpcString));
 348
 349         $getFeedHeadlines_sig = array(array($xmlrpcString,
 350                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt, $xmlrpcInt));
 351
 352         $getArticle_sig = array(array($xmlrpcString,
 353                 $xmlrpcString, $xmlrpcString, $xmlrpcInt));
 354
 355         $setArticleMarked_sig = array(array($xmlrpcString,
 356                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
 357
 358         $setArticleUnread_sig = array(array($xmlrpcString,
 359                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
 360
 361         $s = new xmlrpc_server(
 362                         array(
 363                           "rss.setArticleRead" => array("function" => "setArticleRead",
 364                                         "signature" => $setArticleRead_sig),
 365                           "rss.setArticleMarked" => array("function" => "setArticleMarked",
 366                                         "signature" => $setArticleMarked_sig),
 367                           "rss.getArticle" => array("function" => "getArticle",
 368                                         "signature" => $getArticle_sig),
 369                           "rss.getFeedHeadlines" => array("function" => "getFeedHeadlines",
 370                                         "signature" => $getFeedHeadlines_sig),
 371                           "rss.getSubscribedFeeds" => array("function" => "getSubscribedFeeds",
 372                                         "signature" => $getSubscribedFeeds_sig),
 373                           "rss.subscribeToFeed" => array("function" => "subscribeToFeed",
 374                                         "signature" => $subscribeToFeed_sig)), 0
 375                         );
 376         $s->response_charset_encoding = "UTF-8";
 377         $s->service();
 378 ?>