mirror of https://tt-rss.org/git/tt-rss.git
532 lines
13 KiB
PHP
532 lines
13 KiB
PHP
<?php
|
|
require "xmlrpc/lib/xmlrpc.inc";
|
|
require "xmlrpc/lib/xmlrpcs.inc";
|
|
|
|
require_once "sanity_check.php";
|
|
require_once "config.php";
|
|
|
|
require_once "db.php";
|
|
require_once "db-prefs.php";
|
|
require_once "functions.php";
|
|
|
|
$link = db_connect(DB_HOST, DB_USER, DB_PASS, DB_NAME);
|
|
|
|
if (!$link) {
|
|
if (DB_TYPE == "mysql") {
|
|
print mysql_error();
|
|
}
|
|
// PG seems to display its own errors just fine by default.
|
|
return;
|
|
}
|
|
|
|
if (DB_TYPE == "pgsql") {
|
|
pg_query("set client_encoding = 'utf-8'");
|
|
}
|
|
|
|
function getVirtualFeeds($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
|
|
$user_id = authenticate_user($link, $login, $pass);
|
|
|
|
$counters_ret = array();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
$counters = getLabelCounters($link, false, true);
|
|
|
|
foreach (array_keys($counters) as $id) {
|
|
$line_struct = new xmlrpcval(
|
|
array(
|
|
"id" => new xmlrpcval($id, "int"),
|
|
"title" => new xmlrpcval($counters[$id]["description"]),
|
|
"unread" => new xmlrpcval($counters[$id]["counter"], "int")
|
|
),
|
|
"struct");
|
|
|
|
array_push($counters_ret, $line_struct);
|
|
}
|
|
|
|
$reply = new xmlrpcval($counters_ret, "array");
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp($reply);
|
|
}
|
|
|
|
}
|
|
|
|
function getCategories($msg) {
|
|
global $link;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
|
|
$user_id = authenticate_user($link, $login, $pass);
|
|
|
|
$error_code = 0;
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
$result = db_query($link, "SELECT
|
|
id, title FROM ttrss_feed_categories
|
|
WHERE owner_uid = " .
|
|
$_SESSION["uid"]);
|
|
|
|
$feeds = array();
|
|
|
|
while ($line = db_fetch_assoc($result)) {
|
|
|
|
$unread = getFeedUnread($link, $line["id"]);
|
|
|
|
$line_struct = new xmlrpcval(
|
|
array(
|
|
"title" => new xmlrpcval($line["title"]),
|
|
"id" => new xmlrpcval($line["id"], "int")
|
|
),
|
|
"struct");
|
|
|
|
array_push($feeds, $line_struct);
|
|
}
|
|
|
|
$reply = new xmlrpcval($feeds, "array");
|
|
|
|
} else {
|
|
$reply = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp($reply);
|
|
}
|
|
|
|
}
|
|
|
|
function getTotalUnread($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
|
|
$user_id = authenticate_user($link, $login, $pass);
|
|
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
$reply_msg = getGlobalUnread($link);
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp(new xmlrpcval($reply_msg));
|
|
}
|
|
|
|
}
|
|
|
|
function getVersion() {
|
|
return new xmlrpcval(VERSION);
|
|
}
|
|
|
|
function getSubscribedFeeds($msg) {
|
|
global $link;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
|
|
$user_id = authenticate_user($link, $login, $pass);
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
$result = db_query($link, "SELECT
|
|
id, feed_url, cat_id, title, SUBSTRING(last_updated,1,19) AS last_updated
|
|
FROM ttrss_feeds WHERE owner_uid = " .
|
|
$_SESSION["uid"]);
|
|
|
|
$feeds = array();
|
|
|
|
while ($line = db_fetch_assoc($result)) {
|
|
|
|
$unread = getFeedUnread($link, $line["id"]);
|
|
|
|
$line_struct = new xmlrpcval(
|
|
array(
|
|
"feed_url" => new xmlrpcval($line["feed_url"]),
|
|
"title" => new xmlrpcval($line["title"]),
|
|
"id" => new xmlrpcval($line["id"], "int"),
|
|
"unread" => new xmlrpcval($unread, "int"),
|
|
"cat_id" => new xmlrpcval($line["cat_id"], "int"),
|
|
"last_updated" => new xmlrpcval(strtotime($line["last_updated"]), "int")
|
|
),
|
|
"struct");
|
|
|
|
array_push($feeds, $line_struct);
|
|
}
|
|
|
|
$reply = new xmlrpcval($feeds, "array");
|
|
|
|
} else {
|
|
$reply = new xmlrpcval("Login failed.");
|
|
}
|
|
|
|
return new xmlrpcresp($reply);
|
|
}
|
|
|
|
function subscribeToFeed($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
$feed_url_o = $msg->getParam(2);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
$feed_url = $feed_url_o->scalarval();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
if (subscribe_to_feed($link, $feed_url)) {
|
|
$reply_msg = "Subscribed successfully.";
|
|
} else {
|
|
$reply_msg = "Feed already exists in the database.";
|
|
$error_code = 2;
|
|
}
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp(new xmlrpcval($reply_msg));
|
|
}
|
|
}
|
|
|
|
function getFeedHeadlines($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
$feed_id_o = $msg->getParam(2);
|
|
$limit_o = $msg->getParam(3);
|
|
$filter_o = $msg->getParam(4);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
$feed_id = $feed_id_o->scalarval();
|
|
$limit = $limit_o->scalarval();
|
|
$filter = $filter_o->scalarval();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
if ($filter == 1) {
|
|
$view_mode = "unread";
|
|
} else if ($filter == 2) {
|
|
$view_mode = "marked";
|
|
} else if ($filter == 3) {
|
|
$view_mode = "adaptive";
|
|
}
|
|
|
|
$cat_view = false;
|
|
$search = "";
|
|
$search_mode = "";
|
|
$match_on = "";
|
|
|
|
$qfh_ret = queryFeedHeadlines($link, $feed_id, $limit,
|
|
$view_mode, $cat_view, $search, $search_mode, $match_on);
|
|
|
|
$result = $qfh_ret[0];
|
|
$feed_title = $qfh_ret[1];
|
|
|
|
$articles = array();
|
|
|
|
while ($line = db_fetch_assoc($result)) {
|
|
|
|
$is_updated = ($line["last_read"] == "" && ($line["unread"] != "t" && $line["unread"] != "1"));
|
|
|
|
$headline_items = array(
|
|
"id" => new xmlrpcval($line["id"], "int"),
|
|
"unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
|
|
"marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
|
|
"updated" => new xmlrpcval(strtotime($line["updated"]), "int"),
|
|
"is_updated" => new xmlrpcval($is_updated, "boolean"),
|
|
|
|
"title" => new xmlrpcval($line["title"])
|
|
);
|
|
|
|
if ($feed_id < 0) {
|
|
$headline_items["feed_id"] = new xmlrpcval($line["feed_id"], "int");
|
|
}
|
|
|
|
$line_struct = new xmlrpcval($headline_items,
|
|
"struct");
|
|
|
|
array_push($articles, $line_struct);
|
|
}
|
|
|
|
$reply = new xmlrpcval(
|
|
array(
|
|
"title" => new xmlrpcval($feed_title),
|
|
"headlines" => new xmlrpcval($articles, "array")
|
|
),
|
|
"struct");
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp($reply);
|
|
}
|
|
|
|
}
|
|
|
|
function getArticle($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
$article_id_o = $msg->getParam(2);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
$article_id = $article_id_o->scalarval();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
$query = "SELECT title,link,content,feed_id,comments,int_id,
|
|
marked,unread,
|
|
SUBSTRING(updated,1,16) as updated,
|
|
author
|
|
FROM ttrss_entries,ttrss_user_entries
|
|
WHERE id = '$article_id' AND ref_id = id AND owner_uid = " . $_SESSION["uid"] ;
|
|
|
|
$result = db_query($link, $query);
|
|
|
|
if (db_num_rows($result) == 1) {
|
|
|
|
$line = db_fetch_assoc($result);
|
|
|
|
$reply = new xmlrpcval(
|
|
array(
|
|
"title" => new xmlrpcval($line["title"]),
|
|
"link" => new xmlrpcval($line["link"]),
|
|
"unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
|
|
"marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
|
|
"comments" => new xmlrpcval($line["comments"]),
|
|
"author" => new xmlrpcval($line["author"]),
|
|
"updated" => new xmlrpcval(strtotime($line["updated"], "int")),
|
|
"content" => new xmlrpcval($line["content"])
|
|
),
|
|
"struct");
|
|
|
|
} else {
|
|
$reply_msg = "Article not found.";
|
|
$error_code = 2;
|
|
}
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp($reply);
|
|
}
|
|
}
|
|
|
|
function setArticleMarked($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
$article_id_o = $msg->getParam(2);
|
|
$marked_o = $msg->getParam(3);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
$article_id = $article_id_o->scalarval();
|
|
$marked = $marked_o->scalarval();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
if ($marked == 0) {
|
|
$query_strategy_part = "marked = false";
|
|
} else if ($marked == 1) {
|
|
$query_strategy_part = "marked = true";
|
|
} else if ($marked == 2) {
|
|
$query_strategy_part = "marked = NOT marked";
|
|
}
|
|
|
|
$result = db_query($link, "UPDATE ttrss_user_entries SET
|
|
$query_strategy_part WHERE ref_id = '$article_id' AND
|
|
owner_uid = " . $_SESSION["uid"]);
|
|
|
|
if (db_affected_rows($link, $result) == 1) {
|
|
$reply_msg = "OK";
|
|
} else {
|
|
$error_code = 2;
|
|
$reply_msg = "Failed to update article.";
|
|
}
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp(new xmlrpcval($reply_msg));
|
|
}
|
|
|
|
}
|
|
|
|
function setArticleRead($msg) {
|
|
global $link;
|
|
|
|
$error_code = 0;
|
|
|
|
$login_o = $msg->getParam(0);
|
|
$pass_o = $msg->getParam(1);
|
|
$article_id_o = $msg->getParam(2);
|
|
$read_o = $msg->getParam(3);
|
|
|
|
$login = $login_o->scalarval();
|
|
$pass = $pass_o->scalarval();
|
|
$article_id = $article_id_o->scalarval();
|
|
$read = $read_o->scalarval();
|
|
|
|
if (authenticate_user($link, $login, $pass)) {
|
|
|
|
if ($read == 0) {
|
|
$query_strategy_part = "unread = true";
|
|
} else if ($read == 1) {
|
|
$query_strategy_part = "unread = false";
|
|
} else if ($read == 2) {
|
|
$query_strategy_part = "unread = NOT unread";
|
|
}
|
|
|
|
$result = db_query($link, "UPDATE ttrss_user_entries SET
|
|
$query_strategy_part WHERE ref_id = '$article_id' AND
|
|
owner_uid = " . $_SESSION["uid"]);
|
|
|
|
if (db_affected_rows($link, $result) == 1) {
|
|
$reply_msg = "OK";
|
|
} else {
|
|
$error_code = 2;
|
|
$reply_msg = "Failed to update article.";
|
|
}
|
|
|
|
} else {
|
|
$reply_msg = "Login failed.";
|
|
$error_code = 1;
|
|
}
|
|
|
|
if ($error_code != 0) {
|
|
return new xmlrpcresp(0, $error_code, $reply_msg);
|
|
} else {
|
|
return new xmlrpcresp(new xmlrpcval($reply_msg));
|
|
}
|
|
|
|
}
|
|
|
|
$subscribeToFeed_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString, $xmlrpcString));
|
|
|
|
$getSubscribedFeeds_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString));
|
|
|
|
$getFeedHeadlines_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt, $xmlrpcInt));
|
|
|
|
$getArticle_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString, $xmlrpcInt));
|
|
|
|
$setArticleMarked_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
|
|
|
|
$setArticleUnread_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
|
|
|
|
$getVersion_sig = array(array($xmlrpcString));
|
|
|
|
$getTotalUnread_sig = array(array($xmlrpcInt, $xmlrpcString,
|
|
$xmlrpcString));
|
|
|
|
$getCategories_sig = array(array($xmlrpcString,
|
|
$xmlrpcString, $xmlrpcString));
|
|
|
|
$getVirtualFeeds_sig = array(array($xmlrpcInt, $xmlrpcString,
|
|
$xmlrpcString));
|
|
|
|
$s = new xmlrpc_server(
|
|
array(
|
|
"rss.getVirtualFeeds" => array("function" => "getVirtualFeeds",
|
|
"signature" => $getVirtualFeeds_sig),
|
|
"rss.getCategories" => array("function" => "getCategories",
|
|
"signature" => $getCategories_sig),
|
|
"rss.getTotalUnread" => array("function" => "getTotalUnread",
|
|
"signature" => $getTotalUnread_sig),
|
|
"rss.getVersion" => array("function" => "getVersion",
|
|
"signature" => $getVersion_sig),
|
|
"rss.setArticleRead" => array("function" => "setArticleRead",
|
|
"signature" => $setArticleRead_sig),
|
|
"rss.setArticleMarked" => array("function" => "setArticleMarked",
|
|
"signature" => $setArticleMarked_sig),
|
|
"rss.getArticle" => array("function" => "getArticle",
|
|
"signature" => $getArticle_sig),
|
|
"rss.getFeedHeadlines" => array("function" => "getFeedHeadlines",
|
|
"signature" => $getFeedHeadlines_sig),
|
|
"rss.getSubscribedFeeds" => array("function" => "getSubscribedFeeds",
|
|
"signature" => $getSubscribedFeeds_sig),
|
|
"rss.subscribeToFeed" => array("function" => "subscribeToFeed",
|
|
"signature" => $subscribeToFeed_sig)), 0
|
|
);
|
|
$s->response_charset_encoding = "UTF-8";
|
|
$s->service();
|
|
?>
|