]> git.wh0rd.org - tt-rss.git/blame - xml-rpc.php
set redirect_base to https:// prefix when ENABLE_LOGIN_SSL is enabled (closes #71)
[tt-rss.git] / xml-rpc.php
CommitLineData
956c7629
AD
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
9e62a175
AD
26 function getTotalUnread($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
40 if (authenticate_user($link, $login, $pass)) {
41
42 $reply_msg = getGlobalUnread($link);
43
44 } else {
45 $reply_msg = "Login failed.";
46 $error_code = 1;
47 }
48
49 if ($error_code != 0) {
50 return new xmlrpcresp(0, $error_code, $reply_msg);
51 } else {
52 return new xmlrpcresp(new xmlrpcval($reply_msg));
53 }
54
55 }
56
a3c0ae7c
AD
57 function getVersion() {
58 return new xmlrpcval(VERSION);
59 }
60
7fb32341
AD
61 function getSubscribedFeeds($msg) {
62 global $link;
63
64 $login_o = $msg->getParam(0);
65 $pass_o = $msg->getParam(1);
66
67 $login = $login_o->scalarval();
68 $pass = $pass_o->scalarval();
69
70 $user_id = authenticate_user($link, $login, $pass);
71
72 if (authenticate_user($link, $login, $pass)) {
73
74 $result = db_query($link, "SELECT
75 id, feed_url, title, SUBSTRING(last_updated,1,19) AS last_updated
76 FROM ttrss_feeds WHERE owner_uid = " .
77 $_SESSION["uid"]);
956c7629 78
7fb32341
AD
79 $feeds = array();
80
81 while ($line = db_fetch_assoc($result)) {
e359d44b
AD
82
83 $unread = getFeedUnread($link, $line["id"]);
7fb32341
AD
84
85 $line_struct = new xmlrpcval(
86 array(
87 "feed_url" => new xmlrpcval($line["feed_url"]),
88 "title" => new xmlrpcval($line["title"]),
68d3cf5a 89 "id" => new xmlrpcval($line["id"], "int"),
e359d44b 90 "unread" => new xmlrpcval($unread, "int"),
68d3cf5a 91 "last_updated" => new xmlrpcval(strtotime($line["last_updated"]), "int")
7fb32341
AD
92 ),
93 "struct");
94
95 array_push($feeds, $line_struct);
96 }
97
98 $reply = new xmlrpcval($feeds, "array");
99
100 } else {
101 $reply = new xmlrpcval("Login failed.");
102 }
103
104 return new xmlrpcresp($reply);
105 }
106
107 function subscribeToFeed($msg) {
956c7629
AD
108 global $link;
109
68d3cf5a
AD
110 $error_code = 0;
111
956c7629
AD
112 $login_o = $msg->getParam(0);
113 $pass_o = $msg->getParam(1);
114 $feed_url_o = $msg->getParam(2);
115
116 $login = $login_o->scalarval();
117 $pass = $pass_o->scalarval();
118 $feed_url = $feed_url_o->scalarval();
956c7629
AD
119
120 if (authenticate_user($link, $login, $pass)) {
121 if (subscribe_to_feed($link, $feed_url)) {
122 $reply_msg = "Subscribed successfully.";
123 } else {
124 $reply_msg = "Feed already exists in the database.";
68d3cf5a 125 $error_code = 2;
956c7629
AD
126 }
127 } else {
128 $reply_msg = "Login failed.";
68d3cf5a
AD
129 $error_code = 1;
130 }
131
132 if ($error_code != 0) {
133 return new xmlrpcresp(0, $error_code, $reply_msg);
134 } else {
135 return new xmlrpcresp(new xmlrpcval($reply_msg));
136 }
137 }
138
139 function getFeedHeadlines($msg) {
140 global $link;
141
142 $error_code = 0;
143
144 $login_o = $msg->getParam(0);
145 $pass_o = $msg->getParam(1);
146 $feed_id_o = $msg->getParam(2);
147 $limit_o = $msg->getParam(3);
148 $filter_o = $msg->getParam(4);
149
150 $login = $login_o->scalarval();
151 $pass = $pass_o->scalarval();
152 $feed_id = $feed_id_o->scalarval();
153 $limit = $limit_o->scalarval();
154 $filter = $filter_o->scalarval();
155
156 if (authenticate_user($link, $login, $pass)) {
157
158 if ($limit > 0) {
159 $limit_query_part = "LIMIT $limit";
160 }
161
162 if ($filter == 1) {
163 $query_strategy_part = "unread = true";
164 } else if ($filter == 2) {
165 $query_strategy_part = "marked = true";
166 } else {
167 $query_strategy_part = "ttrss_entries.id > 0";
168 }
169
170 $query = "SELECT
171 ttrss_entries.id,ttrss_entries.title,
172 SUBSTRING(updated,1,16) as updated,
173 unread,feed_id,marked,link,last_read,
174 SUBSTRING(last_read,1,19) as last_read_noms,
175 SUBSTRING(updated,1,19) as updated_noms
176 FROM
177 ttrss_entries,ttrss_user_entries,ttrss_feeds
178 WHERE
179 ttrss_feeds.id = '$feed_id' AND
180 ttrss_user_entries.feed_id = ttrss_feeds.id AND
181 ttrss_user_entries.ref_id = ttrss_entries.id AND
182 ttrss_user_entries.owner_uid = '".$_SESSION["uid"]."' AND
183 $query_strategy_part ORDER BY updated
184 $limit_query_part";
185
186 $result = db_query($link, $query);
187
188 $articles = array();
189
190 while ($line = db_fetch_assoc($result)) {
191
192
193 $line_struct = new xmlrpcval(
194 array(
195 "id" => new xmlrpcval($line["id"], "int"),
196 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
197 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
198 "updated" => new xmlrpcval(strtotime($line["updated"]), "int"),
199 "title" => new xmlrpcval($line["title"])
200 ),
201 "struct");
202
203 array_push($articles, $line_struct);
204
205 }
206
207 $reply = new xmlrpcval($articles, "array");
208
209 } else {
210 $reply_msg = "Login failed.";
211 $error_code = 1;
212 }
213
214 if ($error_code != 0) {
215 return new xmlrpcresp(0, $error_code, $reply_msg);
216 } else {
217 return new xmlrpcresp($reply);
956c7629 218 }
68d3cf5a
AD
219
220 }
221
222 function getArticle($msg) {
223 global $link;
224
225 $error_code = 0;
226
227 $login_o = $msg->getParam(0);
228 $pass_o = $msg->getParam(1);
229 $article_id_o = $msg->getParam(2);
230
231 $login = $login_o->scalarval();
232 $pass = $pass_o->scalarval();
233 $article_id = $article_id_o->scalarval();
234
235 if (authenticate_user($link, $login, $pass)) {
236
237 $query = "SELECT title,link,content,feed_id,comments,int_id,
238 marked,unread,
239 SUBSTRING(updated,1,16) as updated,
240 author
241 FROM ttrss_entries,ttrss_user_entries
242 WHERE id = '$article_id' AND ref_id = id AND owner_uid = " . $_SESSION["uid"] ;
243
244 $result = db_query($link, $query);
245
246 if (db_num_rows($result) == 1) {
247
248 $line = db_fetch_assoc($result);
249
250 $reply = new xmlrpcval(
251 array(
252 "title" => new xmlrpcval($line["title"]),
253 "link" => new xmlrpcval($line["link"]),
254 "unread" => new xmlrpcval(sql_bool_to_bool($line["unread"]), "boolean"),
255 "marked" => new xmlrpcval(sql_bool_to_bool($line["marked"]), "boolean"),
256 "comments" => new xmlrpcval($line["comments"]),
257 "author" => new xmlrpcval($line["author"]),
258 "updated" => new xmlrpcval(strtotime($line["updated"], "int")),
259 "content" => new xmlrpcval($line["content"])
260 ),
261 "struct");
262
263 } else {
264 $reply_msg = "Article not found.";
265 $error_code = 2;
266 }
956c7629 267
68d3cf5a
AD
268 } else {
269 $reply_msg = "Login failed.";
270 $error_code = 1;
271 }
272
273 if ($error_code != 0) {
274 return new xmlrpcresp(0, $error_code, $reply_msg);
275 } else {
276 return new xmlrpcresp($reply);
277 }
278 }
279
280 function setArticleMarked($msg) {
281 global $link;
282
283 $error_code = 0;
284
285 $login_o = $msg->getParam(0);
286 $pass_o = $msg->getParam(1);
287 $article_id_o = $msg->getParam(2);
288 $marked_o = $msg->getParam(3);
289
290 $login = $login_o->scalarval();
291 $pass = $pass_o->scalarval();
292 $article_id = $article_id_o->scalarval();
293 $marked = $marked_o->scalarval();
294
295 if (authenticate_user($link, $login, $pass)) {
296
297 if ($marked == 0) {
298 $query_strategy_part = "marked = false";
299 } else if ($marked == 1) {
300 $query_strategy_part = "marked = true";
301 } else if ($marked == 2) {
302 $query_strategy_part = "marked = NOT marked";
303 }
304
305 $result = db_query($link, "UPDATE ttrss_user_entries SET
306 $query_strategy_part WHERE ref_id = '$article_id' AND
307 owner_uid = " . $_SESSION["uid"]);
308
309 if (db_affected_rows($link, $result) == 1) {
310 $reply_msg = "OK";
311 } else {
312 $error_code = 2;
313 $reply_msg = "Failed to update article.";
314 }
315
316 } else {
317 $reply_msg = "Login failed.";
318 $error_code = 1;
319 }
320
321 if ($error_code != 0) {
322 return new xmlrpcresp(0, $error_code, $reply_msg);
323 } else {
324 return new xmlrpcresp(new xmlrpcval($reply_msg));
325 }
326
327 }
328
329 function setArticleRead($msg) {
330 global $link;
331
332 $error_code = 0;
333
334 $login_o = $msg->getParam(0);
335 $pass_o = $msg->getParam(1);
336 $article_id_o = $msg->getParam(2);
337 $read_o = $msg->getParam(3);
338
339 $login = $login_o->scalarval();
340 $pass = $pass_o->scalarval();
341 $article_id = $article_id_o->scalarval();
342 $read = $read_o->scalarval();
343
344 if (authenticate_user($link, $login, $pass)) {
345
346 if ($read == 0) {
347 $query_strategy_part = "unread = true";
348 } else if ($read == 1) {
349 $query_strategy_part = "unread = false";
350 } else if ($read == 2) {
351 $query_strategy_part = "unread = NOT unread";
352 }
353
354 $result = db_query($link, "UPDATE ttrss_user_entries SET
355 $query_strategy_part WHERE ref_id = '$article_id' AND
356 owner_uid = " . $_SESSION["uid"]);
357
358 if (db_affected_rows($link, $result) == 1) {
359 $reply_msg = "OK";
360 } else {
361 $error_code = 2;
362 $reply_msg = "Failed to update article.";
363 }
364
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(new xmlrpcval($reply_msg));
374 }
375
956c7629
AD
376 }
377
378 $subscribeToFeed_sig = array(array($xmlrpcString,
379 $xmlrpcString, $xmlrpcString, $xmlrpcString));
7fb32341
AD
380
381 $getSubscribedFeeds_sig = array(array($xmlrpcString,
382 $xmlrpcString, $xmlrpcString));
383
68d3cf5a
AD
384 $getFeedHeadlines_sig = array(array($xmlrpcString,
385 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt, $xmlrpcInt));
386
387 $getArticle_sig = array(array($xmlrpcString,
388 $xmlrpcString, $xmlrpcString, $xmlrpcInt));
389
390 $setArticleMarked_sig = array(array($xmlrpcString,
391 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
392
393 $setArticleUnread_sig = array(array($xmlrpcString,
394 $xmlrpcString, $xmlrpcString, $xmlrpcInt, $xmlrpcInt));
395
a3c0ae7c 396 $getVersion_sig = array(array($xmlrpcString));
9e62a175
AD
397
398 $getTotalUnread_sig = array(array($xmlrpcInt, $xmlrpcString,
399 $xmlrpcString));
a3c0ae7c 400
956c7629
AD
401 $s = new xmlrpc_server(
402 array(
9e62a175
AD
403 "rss.getTotalUnread" => array("function" => "getTotalUnread",
404 "signature" => $getTotalUnread_sig),
a3c0ae7c
AD
405 "rss.getVersion" => array("function" => "getVersion",
406 "signature" => $getVersion_sig),
68d3cf5a
AD
407 "rss.setArticleRead" => array("function" => "setArticleRead",
408 "signature" => $setArticleRead_sig),
409 "rss.setArticleMarked" => array("function" => "setArticleMarked",
410 "signature" => $setArticleMarked_sig),
411 "rss.getArticle" => array("function" => "getArticle",
412 "signature" => $getArticle_sig),
413 "rss.getFeedHeadlines" => array("function" => "getFeedHeadlines",
414 "signature" => $getFeedHeadlines_sig),
7fb32341
AD
415 "rss.getSubscribedFeeds" => array("function" => "getSubscribedFeeds",
416 "signature" => $getSubscribedFeeds_sig),
956c7629 417 "rss.subscribeToFeed" => array("function" => "subscribeToFeed",
e359d44b 418 "signature" => $subscribeToFeed_sig)), 0
956c7629 419 );
e359d44b
AD
420 $s->response_charset_encoding = "UTF-8";
421 $s->service();
956c7629 422?>