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 getVirtualFeeds($msg) {
  27                 global $link;
  28
  29                 $error_code = 0;
  30
  31                 $login_o = $msg->getParam(0);
  32                 $pass_o = $msg->getParam(1);
  33
  34                 $login = $login_o->scalarval();
  35                 $pass = $pass_o->scalarval();
  36
  37                 $user_id = authenticate_user($link, $login, $pass);
  38
  39                 $counters_ret = array();
  40
  41                 if (authenticate_user($link, $login, $pass)) {
  42
  43                         $counters = getLabelCounters($link, false, true);
  44
  45                         foreach (array_keys($counters) as $id) {
  46                                 $line_struct = new xmlrpcval(
  47                                         array(
  48                                                 "id" => new xmlrpcval($id, "int"),
  49                                                 "description" => new xmlrpcval($counters[$id]["description"]),
  50                                                 "counter" => new xmlrpcval($counters[$id]["counter"], "int")
  51                                         ),
  52                                         "struct");
  53
  54                                 array_push($counters_ret, $line_struct);
  55                         }
  56
  57                         $reply = new xmlrpcval($counters_ret, "array");
  58
  59                 } else {
  60                         $reply_msg = "Login failed.";
  61                         $error_code = 1;
  62                 }
  63
  64                 if ($error_code != 0) {
  65                         return new xmlrpcresp(0, $error_code, $reply_msg);
  66                 } else {
  67                         return new xmlrpcresp($reply);
  68                 }
  69
  70         }
  71
  72         function getCategories($msg) {
  73                 global $link;
  74
  75                 $login_o = $msg->getParam(0);
  76                 $pass_o = $msg->getParam(1);
  77
  78                 $login = $login_o->scalarval();
  79                 $pass = $pass_o->scalarval();
  80
  81                 $user_id = authenticate_user($link, $login, $pass);
  82
  83                 $error_code = 0;
  84
  85                 if (authenticate_user($link, $login, $pass)) {
  86
  87                         $result = db_query($link, "SELECT
  88                                         id, title FROM ttrss_feed_categories
  89                                 WHERE owner_uid = " .
  90                                 $_SESSION["uid"]);
  91
  92                         $feeds = array();
  93
  94                         while ($line = db_fetch_assoc($result)) {
  95
  96                                 $unread = getFeedUnread($link, $line["id"]);
  97
  98                                 $line_struct = new xmlrpcval(
  99                                         array(
 100                                                 "title" => new xmlrpcval($line["title"]),
 101                                                 "id" => new xmlrpcval($line["id"], "int")
 102                                         ),
 103                                         "struct");
 104
 105                                 array_push($feeds, $line_struct);
 106                         }
 107
 108                         $reply = new xmlrpcval($feeds, "array");
 109
 110                 } else {
 111                         $reply = "Login failed.";
 112                         $error_code = 1;
 113                 }
 114
 115                 if ($error_code != 0) {
 116                         return new xmlrpcresp(0, $error_code, $reply_msg);
 117                 } else {
 118                         return new xmlrpcresp($reply);
 119                 }
 120
 121         }
 122
 123         function getTotalUnread($msg) {
 124                 global $link;
 125
 126                 $error_code = 0;
 127
 128                 $login_o = $msg->getParam(0);
 129                 $pass_o = $msg->getParam(1);
 130
 131                 $login = $login_o->scalarval();
 132                 $pass = $pass_o->scalarval();
 133
 134                 $user_id = authenticate_user($link, $login, $pass);
 135
 136
 137                 if (authenticate_user($link, $login, $pass)) {
 138
 139                         $reply_msg = getGlobalUnread($link);
 140
 141                 } else {
 142                         $reply_msg = "Login failed.";
 143                         $error_code = 1;
 144                 }
 145
 146                 if ($error_code != 0) {
 147                         return new xmlrpcresp(0, $error_code, $reply_msg);
 148                 } else {
 149                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 150                 }
 151
 152         }
 153
 154         function getVersion() {
 155                 return new xmlrpcval(VERSION);
 156         }
 157
 158         function getSubscribedFeeds($msg) {
 159                 global $link;
 160
 161                 $login_o = $msg->getParam(0);
 162                 $pass_o = $msg->getParam(1);
 163
 164                 $login = $login_o->scalarval();
 165                 $pass = $pass_o->scalarval();
 166
 167                 $user_id = authenticate_user($link, $login, $pass);
 168
 169                 if (authenticate_user($link, $login, $pass)) {
 170
 171                         $result = db_query($link, "SELECT
 172                                 id, feed_url, cat_id, title, SUBSTRING(last_updated,1,19) AS last_updated
 173                                         FROM ttrss_feeds WHERE owner_uid = " .
 174                                 $_SESSION["uid"]);
 175
 176                         $feeds = array();
 177
 178                         while ($line = db_fetch_assoc($result)) {
 179
 180                                 $unread = getFeedUnread($link, $line["id"]);
 181
 182                                 $line_struct = new xmlrpcval(
 183                                         array(
 184                                                 "feed_url" => new xmlrpcval($line["feed_url"]),
 185                                                 "title" => new xmlrpcval($line["title"]),
 186                                                 "id" => new xmlrpcval($line["id"], "int"),
 187                                                 "unread" => new xmlrpcval($unread, "int"),
 188                                                 "category_id" => new xmlrpcval($line["cat_id"], "int"),
 189                                                 "last_updated" => new xmlrpcval(strtotime($line["last_updated"]), "int")
 190                                         ),
 191                                         "struct");
 192
 193                                 array_push($feeds, $line_struct);
 194                         }
 195
 196                         $reply = new xmlrpcval($feeds, "array");
 197
 198                 } else {
 199                         $reply = new xmlrpcval("Login failed.");
 200                 }
 201
 202                 return new xmlrpcresp($reply);
 203         }
 204
 205         function subscribeToFeed($msg) {
 206                 global $link;
 207
 208                 $error_code = 0;
 209
 210                 $login_o = $msg->getParam(0);
 211                 $pass_o = $msg->getParam(1);
 212                 $feed_url_o = $msg->getParam(2);
 213
 214                 $login = $login_o->scalarval();
 215                 $pass = $pass_o->scalarval();
 216                 $feed_url = $feed_url_o->scalarval();
 217
 218                 if (authenticate_user($link, $login, $pass)) {
 219                         if (subscribe_to_feed($link, $feed_url)) {
 220                                 $reply_msg = "Subscribed successfully.";
 221                         } else {
 222                                 $reply_msg = "Feed already exists in the database.";
 223                                 $error_code = 2;
 224                         }
 225                 } else {
 226                         $reply_msg = "Login failed.";
 227                         $error_code = 1;
 228                 }
 229
 230                 if ($error_code != 0) {
 231                         return new xmlrpcresp(0, $error_code, $reply_msg);
 232                 } else {
 233                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 234                 }
 235         }
 236
 237         function getFeedHeadlines($msg) {
 238                 global $link;
 239
 240                 $error_code = 0;
 241
 242                 $login_o = $msg->getParam(0);
 243                 $pass_o = $msg->getParam(1);
 244                 $feed_id_o = $msg->getParam(2);
 245                 $limit_o = $msg->getParam(3);
 246                 $filter_o = $msg->getParam(4);
 247
 248                 $login = $login_o->scalarval();
 249                 $pass = $pass_o->scalarval();
 250                 $feed_id = $feed_id_o->scalarval();
 251                 $limit = $limit_o->scalarval();
 252                 $filter = $filter_o->scalarval();
 253
 254                 if (authenticate_user($link, $login, $pass)) {
 255
 256                         if ($filter == 1) {
 257                                 $view_mode = "unread";
 258                         } else if ($filter == 2) {
 259                                 $view_mode = "marked";
 260                         }
 261
 262                         $cat_view = false;
 263                         $search = "";
 264                         $search_mode = "";
 265                         $match_on = "";
 266
 267                         $qfh_ret = queryFeedHeadlines($link, $feed_id, $limit,
 268                                 $view_mode, $cat_view, $search, $search_mode, $match_on);
 269
 270                         $result = $qfh_ret[0];
 271                         $feed_title = $qfh_ret[1];
 272
 273                         $articles = array();
 274
 275                         while ($line = db_fetch_assoc($result)) {
 276
 277                                 $headline_items =       array(
 278                                                 "id" => new xmlrpcval($line["id"], "int"),
 279                                                 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
 280                                                 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
 281                                                 "updated" => new xmlrpcval(strtotime($line["updated"]), "int"),
 282                                                 "title" => new xmlrpcval($line["title"])
 283                                         );
 284
 285                                 if ($feed_id < 0) {
 286                                         $headline_items["feed_id"] = new xmlrpcval($line["feed_id"], "int");
 287                                 }
 288
 289                                 $line_struct = new xmlrpcval($headline_items,
 290                                         "struct");
 291
 292                                 array_push($articles, $line_struct);
 293                         }
 294
 295                         $reply = new xmlrpcval(
 296                                 array(
 297                                         "title" => new xmlrpcval($feed_title),
 298                                         "headlines" => new xmlrpcval($articles, "array")
 299                                 ),
 300                                 "struct");
 301
 302                 } else {
 303                         $reply_msg = "Login failed.";
 304                         $error_code = 1;
 305                 }
 306
 307                 if ($error_code != 0) {
 308                         return new xmlrpcresp(0, $error_code, $reply_msg);
 309                 } else {
 310                         return new xmlrpcresp($reply);
 311                 }
 312
 313         }
 314
 315         function getArticle($msg) {
 316                 global $link;
 317
 318                 $error_code = 0;
 319
 320                 $login_o = $msg->getParam(0);
 321                 $pass_o = $msg->getParam(1);
 322                 $article_id_o = $msg->getParam(2);
 323
 324                 $login = $login_o->scalarval();
 325                 $pass = $pass_o->scalarval();
 326                 $article_id = $article_id_o->scalarval();
 327
 328                 if (authenticate_user($link, $login, $pass)) {
 329
 330                         $query = "SELECT title,link,content,feed_id,comments,int_id,
 331                                 marked,unread,
 332                                 SUBSTRING(updated,1,16) as updated,
 333                                 author
 334                                 FROM ttrss_entries,ttrss_user_entries
 335                                 WHERE   id = '$article_id' AND ref_id = id AND owner_uid = " . $_SESSION["uid"] ;
 336
 337                         $result = db_query($link, $query);
 338
 339                         if (db_num_rows($result) == 1) {
 340
 341                                 $line = db_fetch_assoc($result);
 342
 343                                 $reply = new xmlrpcval(
 344                                         array(
 345                                                 "title" => new xmlrpcval($line["title"]),
 346                                                 "link" => new xmlrpcval($line["link"]),
 347                                                 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
 348                                                 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
 349                                                 "comments" => new xmlrpcval($line["comments"]),
 350                                                 "author" => new xmlrpcval($line["author"]),
 351                                                 "updated" => new xmlrpcval(strtotime($line["updated"], "int")),
 352                                                 "content" => new xmlrpcval($line["content"])
 353                                         ),
 354                                         "struct");
 355
 356                         } else {
 357                                 $reply_msg = "Article not found.";
 358                                 $error_code = 2;
 359                         }
 360
 361                 } else {
 362                         $reply_msg = "Login failed.";
 363                         $error_code = 1;
 364                 }
 365
 366                 if ($error_code != 0) {
 367                         return new xmlrpcresp(0, $error_code, $reply_msg);
 368                 } else {
 369                         return new xmlrpcresp($reply);
 370                 }
 371         }
 372
 373         function setArticleMarked($msg) {
 374                 global $link;
 375
 376                 $error_code = 0;
 377
 378                 $login_o = $msg->getParam(0);
 379                 $pass_o = $msg->getParam(1);
 380                 $article_id_o = $msg->getParam(2);
 381                 $marked_o = $msg->getParam(3);
 382
 383                 $login = $login_o->scalarval();
 384                 $pass = $pass_o->scalarval();
 385                 $article_id = $article_id_o->scalarval();
 386                 $marked = $marked_o->scalarval();
 387
 388                 if (authenticate_user($link, $login, $pass)) {
 389
 390                         if ($marked == 0) {
 391                                 $query_strategy_part = "marked = false";
 392                         } else if ($marked == 1) {
 393                                 $query_strategy_part = "marked = true";
 394                         } else if ($marked == 2) {
 395                                 $query_strategy_part = "marked = NOT marked";
 396                         }
 397
 398                         $result = db_query($link, "UPDATE ttrss_user_entries SET
 399                                 $query_strategy_part WHERE ref_id = '$article_id' AND
 400                                 owner_uid = " . $_SESSION["uid"]);
 401
 402                         if (db_affected_rows($link, $result) == 1) {
 403                                 $reply_msg = "OK";
 404                         } else {
 405                                 $error_code = 2;
 406                                 $reply_msg = "Failed to update article.";
 407                         }
 408
 409                 } else {
 410                         $reply_msg = "Login failed.";
 411                         $error_code = 1;
 412                 }
 413
 414                 if ($error_code != 0) {
 415                         return new xmlrpcresp(0, $error_code, $reply_msg);
 416                 } else {
 417                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 418                 }
 419
 420         }
 421
 422         function setArticleRead($msg) {
 423                 global $link;
 424
 425                 $error_code = 0;
 426
 427                 $login_o = $msg->getParam(0);
 428                 $pass_o = $msg->getParam(1);
 429                 $article_id_o = $msg->getParam(2);
 430                 $read_o = $msg->getParam(3);
 431
 432                 $login = $login_o->scalarval();
 433                 $pass = $pass_o->scalarval();
 434                 $article_id = $article_id_o->scalarval();
 435                 $read = $read_o->scalarval();
 436
 437                 if (authenticate_user($link, $login, $pass)) {
 438
 439                         if ($read == 0) {
 440                                 $query_strategy_part = "unread = true";
 441                         } else if ($read == 1) {
 442                                 $query_strategy_part = "unread = false";
 443                         } else if ($read == 2) {
 444                                 $query_strategy_part = "unread = NOT unread";
 445                         }
 446
 447                         $result = db_query($link, "UPDATE ttrss_user_entries SET
 448                                 $query_strategy_part WHERE ref_id = '$article_id' AND
 449                                 owner_uid = " . $_SESSION["uid"]);
 450
 451                         if (db_affected_rows($link, $result) == 1) {
 452                                 $reply_msg = "OK";
 453                         } else {
 454                                 $error_code = 2;
 455                                 $reply_msg = "Failed to update article.";
 456                         }
 457
 458                 } else {
 459                         $reply_msg = "Login failed.";
 460                         $error_code = 1;
 461                 }
 462
 463                 if ($error_code != 0) {
 464                         return new xmlrpcresp(0, $error_code, $reply_msg);
 465                 } else {
 466                         return new xmlrpcresp(new xmlrpcval($reply_msg));
 467                 }
 468
 469         }
 470
 471         $subscribeToFeed_sig = array(array($xmlrpcString,
 472                 $xmlrpcString, $xmlrpcString, $xmlrpcString));
 473
 474         $getSubscribedFeeds_sig = array(array($xmlrpcString,
 475                 $xmlrpcString, $xmlrpcString));
 476
 477         $getFeedHeadlines_sig = array(array($xmlrpcString,
 478                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt, $xmlrpcInt));
 479
 480         $getArticle_sig = array(array($xmlrpcString,
 481                 $xmlrpcString, $xmlrpcString, $xmlrpcInt));
 482
 483         $setArticleMarked_sig = array(array($xmlrpcString,
 484                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
 485
 486         $setArticleUnread_sig = array(array($xmlrpcString,
 487                 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
 488
 489         $getVersion_sig = array(array($xmlrpcString));
 490
 491         $getTotalUnread_sig = array(array($xmlrpcInt, $xmlrpcString,
 492                 $xmlrpcString));
 493
 494         $getCategories_sig = array(array($xmlrpcString,
 495                 $xmlrpcString, $xmlrpcString));
 496
 497         $getVirtualFeeds_sig = array(array($xmlrpcInt, $xmlrpcString,
 498                 $xmlrpcString));
 499
 500         $s = new xmlrpc_server(
 501                         array(
 502                           "rss.getVirtualFeeds" => array("function" => "getVirtualFeeds",
 503                                         "signature" => $getVirtualFeeds_sig),
 504                           "rss.getCategories" => array("function" => "getCategories",
 505                                         "signature" => $getCategories_sig),
 506                           "rss.getTotalUnread" => array("function" => "getTotalUnread",
 507                                         "signature" => $getTotalUnread_sig),
 508                           "rss.getVersion" => array("function" => "getVersion",
 509                                         "signature" => $getVersion_sig),
 510                           "rss.setArticleRead" => array("function" => "setArticleRead",
 511                                         "signature" => $setArticleRead_sig),
 512                           "rss.setArticleMarked" => array("function" => "setArticleMarked",
 513                                         "signature" => $setArticleMarked_sig),
 514                           "rss.getArticle" => array("function" => "getArticle",
 515                                         "signature" => $getArticle_sig),
 516                           "rss.getFeedHeadlines" => array("function" => "getFeedHeadlines",
 517                                         "signature" => $getFeedHeadlines_sig),
 518                           "rss.getSubscribedFeeds" => array("function" => "getSubscribedFeeds",
 519                                         "signature" => $getSubscribedFeeds_sig),
 520                           "rss.subscribeToFeed" => array("function" => "subscribeToFeed",
 521                                         "signature" => $subscribeToFeed_sig)), 0
 522                         );
 523         $s->response_charset_encoding = "UTF-8";
 524         $s->service();
 525 ?>