[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;
	}

	if (DB_TYPE == "pgsql") {
		pg_query("set client_encoding = 'utf-8'");
		pg_set_client_encoding("UNICODE");
	} else {
		if (defined('MYSQL_CHARSET') && MYSQL_CHARSET) {
			db_query($link, "SET NAMES " . MYSQL_CHARSET);
//			db_query($link, "SET CHARACTER SET " . MYSQL_CHARSET);
		}
	}

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