[tt-rss.git] / xml-rpc.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;
	}

	init_connection($link);

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