codysnider / tt-rss

classes/dbupdater.php

Indentation +79 added lines, -79 removed lines

@@ -2,84 +2,84 @@
 
 class DbUpdater {
 
-	private $pdo;
-	private $db_type;
-	private $need_version;
-
-	public function __construct($db_type, $need_version) {
-		$this->pdo = Db::pdo();
-		$this->db_type = $db_type;
-		$this->need_version = (int) $need_version;
-	}
-
-	public function getSchemaVersion() {
-		$row = $this->pdo->query("SELECT schema_version FROM ttrss_version")->fetch();
-		return (int) $row['schema_version'];
-	}
-
-	public function isUpdateRequired() {
-		return $this->getSchemaVersion() < $this->need_version;
-	}
-
-	public function getSchemaLines($version) {
-		$filename = "schema/versions/".$this->db_type."/$version.sql";
-
-		if (file_exists($filename)) {
-			return explode(";", preg_replace("/[\r\n]/", "", file_get_contents($filename)));
-		} else {
-			user_error("DB Updater: schema file for version $version is not found.");
-			return false;
-		}
-	}
-
-	public function performUpdateTo($version, $html_output = true) {
-		if ($this->getSchemaVersion() == $version - 1) {
-
-			$lines = $this->getSchemaLines($version);
-
-			if (is_array($lines)) {
-
-				$this->pdo->beginTransaction();
-
-				foreach ($lines as $line) {
-					if (strpos($line, "--") !== 0 && $line) {
-
-						if ($html_output) {
-													print "<pre>$line</pre>";
-						} else {
-													Debug::log("> $line");
-						}
-
-						try {
-							$this->pdo->query($line); // PDO returns errors as exceptions now
-						} catch (PDOException $e) {
-							if ($html_output) {
-								print "<div class='text-error'>Error: ".$e->getMessage()."</div>";
-							} else {
-								Debug::log("Error: ".$e->getMessage());
-							}
-
-							$this->pdo->rollBack();
-							return false;
-						}
-					}
-				}
-
-				$db_version = $this->getSchemaVersion();
-
-				if ($db_version == $version) {
-					$this->pdo->commit();
-					return true;
-				} else {
-					$this->pdo->rollBack();
-					return false;
-				}
-			} else {
-				return false;
-			}
-		} else {
-			return false;
-		}
-	}
+    private $pdo;
+    private $db_type;
+    private $need_version;
+
+    public function __construct($db_type, $need_version) {
+        $this->pdo = Db::pdo();
+        $this->db_type = $db_type;
+        $this->need_version = (int) $need_version;
+    }
+
+    public function getSchemaVersion() {
+        $row = $this->pdo->query("SELECT schema_version FROM ttrss_version")->fetch();
+        return (int) $row['schema_version'];
+    }
+
+    public function isUpdateRequired() {
+        return $this->getSchemaVersion() < $this->need_version;
+    }
+
+    public function getSchemaLines($version) {
+        $filename = "schema/versions/".$this->db_type."/$version.sql";
+
+        if (file_exists($filename)) {
+            return explode(";", preg_replace("/[\r\n]/", "", file_get_contents($filename)));
+        } else {
+            user_error("DB Updater: schema file for version $version is not found.");
+            return false;
+        }
+    }
+
+    public function performUpdateTo($version, $html_output = true) {
+        if ($this->getSchemaVersion() == $version - 1) {
+
+            $lines = $this->getSchemaLines($version);
+
+            if (is_array($lines)) {
+
+                $this->pdo->beginTransaction();
+
+                foreach ($lines as $line) {
+                    if (strpos($line, "--") !== 0 && $line) {
+
+                        if ($html_output) {
+                                                    print "<pre>$line</pre>";
+                        } else {
+                                                    Debug::log("> $line");
+                        }
+
+                        try {
+                            $this->pdo->query($line); // PDO returns errors as exceptions now
+                        } catch (PDOException $e) {
+                            if ($html_output) {
+                                print "<div class='text-error'>Error: ".$e->getMessage()."</div>";
+                            } else {
+                                Debug::log("Error: ".$e->getMessage());
+                            }
+
+                            $this->pdo->rollBack();
+                            return false;
+                        }
+                    }
+                }
+
+                $db_version = $this->getSchemaVersion();
+
+                if ($db_version == $version) {
+                    $this->pdo->commit();
+                    return true;
+                } else {
+                    $this->pdo->rollBack();
+                    return false;
+                }
+            } else {
+                return false;
+            }
+        } else {
+            return false;
+        }
+    }
 
 }

classes/digest.php

Indentation +133 added lines, -133 removed lines

@@ -2,126 +2,126 @@ 
 class Digest
 {
 
-	/**
-	 * Send by mail a digest of last articles.
-	 *
-	 * @param mixed $link The database connection.
-	 * @param integer $limit The maximum number of articles by digest.
-	 * @return boolean Return false if digests are not enabled.
-	 */
-	public static function send_headlines_digests() {
+    /**
+     * Send by mail a digest of last articles.
+     *
+     * @param mixed $link The database connection.
+     * @param integer $limit The maximum number of articles by digest.
+     * @return boolean Return false if digests are not enabled.
+     */
+    public static function send_headlines_digests() {
 
-		$user_limit = 15; // amount of users to process (e.g. emails to send out)
-		$limit = 1000; // maximum amount of headlines to include
+        $user_limit = 15; // amount of users to process (e.g. emails to send out)
+        $limit = 1000; // maximum amount of headlines to include
 
-		Debug::log("Sending digests, batch of max $user_limit users, headline limit = $limit");
+        Debug::log("Sending digests, batch of max $user_limit users, headline limit = $limit");
 
-		if (DB_TYPE == "pgsql") {
-			$interval_qpart = "last_digest_sent < NOW() - INTERVAL '1 days'";
-		} else if (DB_TYPE == "mysql") {
-			$interval_qpart = "last_digest_sent < DATE_SUB(NOW(), INTERVAL 1 DAY)";
-		}
+        if (DB_TYPE == "pgsql") {
+            $interval_qpart = "last_digest_sent < NOW() - INTERVAL '1 days'";
+        } else if (DB_TYPE == "mysql") {
+            $interval_qpart = "last_digest_sent < DATE_SUB(NOW(), INTERVAL 1 DAY)";
+        }
 
-		$pdo = Db::pdo();
+        $pdo = Db::pdo();
 
-		$res = $pdo->query("SELECT id,email FROM ttrss_users
+        $res = $pdo->query("SELECT id,email FROM ttrss_users
 				WHERE email != '' AND (last_digest_sent IS NULL OR $interval_qpart)");
 
-		while ($line = $res->fetch()) {
+        while ($line = $res->fetch()) {
 
-			if (@get_pref('DIGEST_ENABLE', $line['id'], false)) {
-				$preferred_ts = strtotime(get_pref('DIGEST_PREFERRED_TIME', $line['id'], '00:00'));
+            if (@get_pref('DIGEST_ENABLE', $line['id'], false)) {
+                $preferred_ts = strtotime(get_pref('DIGEST_PREFERRED_TIME', $line['id'], '00:00'));
 
-				// try to send digests within 2 hours of preferred time
-				if ($preferred_ts && time() >= $preferred_ts &&
-					time() - $preferred_ts <= 7200
-				) {
+                // try to send digests within 2 hours of preferred time
+                if ($preferred_ts && time() >= $preferred_ts &&
+                    time() - $preferred_ts <= 7200
+                ) {
 
-					Debug::log("Sending digest for UID:".$line['id']." - ".$line["email"]);
+                    Debug::log("Sending digest for UID:".$line['id']." - ".$line["email"]);
 
-					$do_catchup = get_pref('DIGEST_CATCHUP', $line['id'], false);
+                    $do_catchup = get_pref('DIGEST_CATCHUP', $line['id'], false);
 
-					global $tz_offset;
+                    global $tz_offset;
 
-					// reset tz_offset global to prevent tz cache clash between users
-					$tz_offset = -1;
+                    // reset tz_offset global to prevent tz cache clash between users
+                    $tz_offset = -1;
 
-					$tuple = Digest::prepare_headlines_digest($line["id"], 1, $limit);
-					$digest = $tuple[0];
-					$headlines_count = $tuple[1];
-					$affected_ids = $tuple[2];
-					$digest_text = $tuple[3];
+                    $tuple = Digest::prepare_headlines_digest($line["id"], 1, $limit);
+                    $digest = $tuple[0];
+                    $headlines_count = $tuple[1];
+                    $affected_ids = $tuple[2];
+                    $digest_text = $tuple[3];
 
-					if ($headlines_count > 0) {
+                    if ($headlines_count > 0) {
 
-						$mailer = new Mailer();
+                        $mailer = new Mailer();
 
-						//$rc = $mail->quickMail($line["email"], $line["login"], DIGEST_SUBJECT, $digest, $digest_text);
+                        //$rc = $mail->quickMail($line["email"], $line["login"], DIGEST_SUBJECT, $digest, $digest_text);
 
-						$rc = $mailer->mail(["to_name" => $line["login"],
-							"to_address" => $line["email"],
-							"subject" => DIGEST_SUBJECT,
-							"message" => $digest_text,
-							"message_html" => $digest]);
+                        $rc = $mailer->mail(["to_name" => $line["login"],
+                            "to_address" => $line["email"],
+                            "subject" => DIGEST_SUBJECT,
+                            "message" => $digest_text,
+                            "message_html" => $digest]);
 
-						//if (!$rc && $debug) Debug::log("ERROR: " . $mailer->lastError());
+                        //if (!$rc && $debug) Debug::log("ERROR: " . $mailer->lastError());
 
-						Debug::log("RC=$rc");
+                        Debug::log("RC=$rc");
 
-						if ($rc && $do_catchup) {
-							Debug::log("Marking affected articles as read...");
-							Article::catchupArticlesById($affected_ids, 0, $line["id"]);
-						}
-					} else {
-						Debug::log("No headlines");
-					}
+                        if ($rc && $do_catchup) {
+                            Debug::log("Marking affected articles as read...");
+                            Article::catchupArticlesById($affected_ids, 0, $line["id"]);
+                        }
+                    } else {
+                        Debug::log("No headlines");
+                    }
 
-					$sth = $pdo->prepare("UPDATE ttrss_users SET last_digest_sent = NOW()
+                    $sth = $pdo->prepare("UPDATE ttrss_users SET last_digest_sent = NOW()
 						WHERE id = ?");
-					$sth->execute([$line["id"]]);
+                    $sth->execute([$line["id"]]);
 
-				}
-			}
-		}
+                }
+            }
+        }
 
-		Debug::log("All done.");
+        Debug::log("All done.");
 
-	}
+    }
 
-	public static function prepare_headlines_digest($user_id, $days = 1, $limit = 1000) {
+    public static function prepare_headlines_digest($user_id, $days = 1, $limit = 1000) {
 
-		require_once "lib/MiniTemplator.class.php";
+        require_once "lib/MiniTemplator.class.php";
 
-		$tpl = new MiniTemplator;
-		$tpl_t = new MiniTemplator;
+        $tpl = new MiniTemplator;
+        $tpl_t = new MiniTemplator;
 
-		$tpl->readTemplateFromFile("templates/digest_template_html.txt");
-		$tpl_t->readTemplateFromFile("templates/digest_template.txt");
+        $tpl->readTemplateFromFile("templates/digest_template_html.txt");
+        $tpl_t->readTemplateFromFile("templates/digest_template.txt");
 
-		$user_tz_string = get_pref('USER_TIMEZONE', $user_id);
-		$local_ts = convert_timestamp(time(), 'UTC', $user_tz_string);
+        $user_tz_string = get_pref('USER_TIMEZONE', $user_id);
+        $local_ts = convert_timestamp(time(), 'UTC', $user_tz_string);
 
-		$tpl->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
-		$tpl->setVariable('CUR_TIME', date('G:i', $local_ts));
-		$tpl->setVariable('TTRSS_HOST', SELF_URL_PATH);
+        $tpl->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
+        $tpl->setVariable('CUR_TIME', date('G:i', $local_ts));
+        $tpl->setVariable('TTRSS_HOST', SELF_URL_PATH);
 
-		$tpl_t->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
-		$tpl_t->setVariable('CUR_TIME', date('G:i', $local_ts));
-		$tpl_t->setVariable('TTRSS_HOST', SELF_URL_PATH);
+        $tpl_t->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
+        $tpl_t->setVariable('CUR_TIME', date('G:i', $local_ts));
+        $tpl_t->setVariable('TTRSS_HOST', SELF_URL_PATH);
 
-		$affected_ids = array();
+        $affected_ids = array();
 
-		$days = (int) $days;
+        $days = (int) $days;
 
-		if (DB_TYPE == "pgsql") {
-			$interval_qpart = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'";
-		} else if (DB_TYPE == "mysql") {
-			$interval_qpart = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)";
-		}
+        if (DB_TYPE == "pgsql") {
+            $interval_qpart = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'";
+        } else if (DB_TYPE == "mysql") {
+            $interval_qpart = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)";
+        }
 
-		$pdo = Db::pdo();
+        $pdo = Db::pdo();
 
-		$sth = $pdo->prepare("SELECT ttrss_entries.title,
+        $sth = $pdo->prepare("SELECT ttrss_entries.title,
 				ttrss_feeds.title AS feed_title,
 				COALESCE(ttrss_feed_categories.title, '" . __('Uncategorized')."') AS cat_title,
 				date_updated,
@@ -143,76 +143,76 @@ 
 				AND score >= 0
 			ORDER BY ttrss_feed_categories.title, ttrss_feeds.title, score DESC, date_updated DESC
 			LIMIT :limit");
-		$sth->bindParam(':user_id', intval($user_id, 10), PDO::PARAM_INT);
-		$sth->bindParam(':limit', intval($limit, 10), PDO::PARAM_INT);
-		$sth->execute();
+        $sth->bindParam(':user_id', intval($user_id, 10), PDO::PARAM_INT);
+        $sth->bindParam(':limit', intval($limit, 10), PDO::PARAM_INT);
+        $sth->execute();
 
-		$headlines_count = 0;
-		$headlines = array();
+        $headlines_count = 0;
+        $headlines = array();
 
-		while ($line = $sth->fetch()) {
-			array_push($headlines, $line);
-			$headlines_count++;
-		}
+        while ($line = $sth->fetch()) {
+            array_push($headlines, $line);
+            $headlines_count++;
+        }
 
-		for ($i = 0; $i < sizeof($headlines); $i++) {
+        for ($i = 0; $i < sizeof($headlines); $i++) {
 
-			$line = $headlines[$i];
+            $line = $headlines[$i];
 
-			array_push($affected_ids, $line["ref_id"]);
+            array_push($affected_ids, $line["ref_id"]);
 
-			$updated = make_local_datetime($line['last_updated'], false,
-				$user_id);
+            $updated = make_local_datetime($line['last_updated'], false,
+                $user_id);
 
-			if (get_pref('ENABLE_FEED_CATS', $user_id)) {
-				$line['feed_title'] = $line['cat_title']." / ".$line['feed_title'];
-			}
+            if (get_pref('ENABLE_FEED_CATS', $user_id)) {
+                $line['feed_title'] = $line['cat_title']." / ".$line['feed_title'];
+            }
 
-			$article_labels = Article::get_article_labels($line["ref_id"], $user_id);
-			$article_labels_formatted = "";
+            $article_labels = Article::get_article_labels($line["ref_id"], $user_id);
+            $article_labels_formatted = "";
 
-			if (is_array($article_labels) && count($article_labels) > 0) {
-				$article_labels_formatted = implode(", ", array_map(function($a) {
-					return $a[1];
-				}, $article_labels));
-			}
+            if (is_array($article_labels) && count($article_labels) > 0) {
+                $article_labels_formatted = implode(", ", array_map(function($a) {
+                    return $a[1];
+                }, $article_labels));
+            }
 
-			$tpl->setVariable('FEED_TITLE', $line["feed_title"]);
-			$tpl->setVariable('ARTICLE_TITLE', $line["title"]);
-			$tpl->setVariable('ARTICLE_LINK', $line["link"]);
-			$tpl->setVariable('ARTICLE_UPDATED', $updated);
-			$tpl->setVariable('ARTICLE_EXCERPT',
-				truncate_string(strip_tags($line["content"]), 300));
+            $tpl->setVariable('FEED_TITLE', $line["feed_title"]);
+            $tpl->setVariable('ARTICLE_TITLE', $line["title"]);
+            $tpl->setVariable('ARTICLE_LINK', $line["link"]);
+            $tpl->setVariable('ARTICLE_UPDATED', $updated);
+            $tpl->setVariable('ARTICLE_EXCERPT',
+                truncate_string(strip_tags($line["content"]), 300));
 //			$tpl->setVariable('ARTICLE_CONTENT',
 //				strip_tags($article_content));
-			$tpl->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
+            $tpl->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
 
-			$tpl->addBlock('article');
+            $tpl->addBlock('article');
 
-			$tpl_t->setVariable('FEED_TITLE', $line["feed_title"]);
-			$tpl_t->setVariable('ARTICLE_TITLE', $line["title"]);
-			$tpl_t->setVariable('ARTICLE_LINK', $line["link"]);
-			$tpl_t->setVariable('ARTICLE_UPDATED', $updated);
-			$tpl_t->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
-			$tpl_t->setVariable('ARTICLE_EXCERPT',
-				truncate_string(strip_tags($line["content"]), 300, "..."), true);
+            $tpl_t->setVariable('FEED_TITLE', $line["feed_title"]);
+            $tpl_t->setVariable('ARTICLE_TITLE', $line["title"]);
+            $tpl_t->setVariable('ARTICLE_LINK', $line["link"]);
+            $tpl_t->setVariable('ARTICLE_UPDATED', $updated);
+            $tpl_t->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
+            $tpl_t->setVariable('ARTICLE_EXCERPT',
+                truncate_string(strip_tags($line["content"]), 300, "..."), true);
 
-			$tpl_t->addBlock('article');
+            $tpl_t->addBlock('article');
 
-			if ($headlines[$i]['feed_title'] != $headlines[$i + 1]['feed_title']) {
-				$tpl->addBlock('feed');
-				$tpl_t->addBlock('feed');
-			}
+            if ($headlines[$i]['feed_title'] != $headlines[$i + 1]['feed_title']) {
+                $tpl->addBlock('feed');
+                $tpl_t->addBlock('feed');
+            }
 
-		}
+        }
 
-		$tpl->addBlock('digest');
-		$tpl->generateOutputToString($tmp);
+        $tpl->addBlock('digest');
+        $tpl->generateOutputToString($tmp);
 
-		$tpl_t->addBlock('digest');
-		$tpl_t->generateOutputToString($tmp_t);
+        $tpl_t->addBlock('digest');
+        $tpl_t->generateOutputToString($tmp_t);
 
-		return array($tmp, $headlines_count, $affected_ids, $tmp_t);
-	}
+        return array($tmp, $headlines_count, $affected_ids, $tmp_t);
+    }
 
 }

classes/db/mysqli.php

Indentation +84 added lines, -84 removed lines

@@ -1,88 +1,88 @@
 <?php
 class Db_Mysqli implements IDb {
-	private $link;
-	private $last_error;
-
-	public function connect($host, $user, $pass, $db, $port) {
-		if ($port) {
-					$this->link = mysqli_connect($host, $user, $pass, $db, $port);
-		} else {
-					$this->link = mysqli_connect($host, $user, $pass, $db);
-		}
-
-		if ($this->link) {
-			$this->init();
-
-			return $this->link;
-		} else {
-			print("Unable to connect to database (as $user to $host, database $db): ".mysqli_connect_error());
-			exit(102);
-		}
-	}
-
-	public function escape_string($s, $strip_tags = true) {
-		if ($strip_tags) {
-		    $s = strip_tags($s);
-		}
-
-		return mysqli_real_escape_string($this->link, $s);
-	}
-
-	public function query($query, $die_on_error = true) {
-		$result = @mysqli_query($this->link, $query);
-		if (!$result) {
-			$this->last_error = @mysqli_error($this->link);
-
-			@mysqli_query($this->link, "ROLLBACK");
-			user_error("query $query failed: ".($this->link ? $this->last_error : "No connection"),
-				$die_on_error ? E_USER_ERROR : E_USER_WARNING);
-		}
-
-		return $result;
-	}
-
-	public function fetch_assoc($result) {
-		return mysqli_fetch_assoc($result);
-	}
-
-
-	public function num_rows($result) {
-		return mysqli_num_rows($result);
-	}
-
-	public function fetch_result($result, $row, $param) {
-		if (mysqli_data_seek($result, $row)) {
-			$line = mysqli_fetch_assoc($result);
-			return $line[$param];
-		} else {
-			return false;
-		}
-	}
-
-	public function close() {
-		return mysqli_close($this->link);
-	}
-
-	public function affected_rows($result) {
-		return mysqli_affected_rows($this->link);
-	}
-
-	public function last_error() {
-		return mysqli_error($this->link);
-	}
-
-	public function last_query_error() {
-		return $this->last_error;
-	}
-
-	public function init() {
-		$this->query("SET time_zone = '+0:0'");
-
-		if (defined('MYSQL_CHARSET') && MYSQL_CHARSET) {
-			mysqli_set_charset($this->link, MYSQL_CHARSET);
-		}
-
-		return true;
-	}
+    private $link;
+    private $last_error;
+
+    public function connect($host, $user, $pass, $db, $port) {
+        if ($port) {
+                    $this->link = mysqli_connect($host, $user, $pass, $db, $port);
+        } else {
+                    $this->link = mysqli_connect($host, $user, $pass, $db);
+        }
+
+        if ($this->link) {
+            $this->init();
+
+            return $this->link;
+        } else {
+            print("Unable to connect to database (as $user to $host, database $db): ".mysqli_connect_error());
+            exit(102);
+        }
+    }
+
+    public function escape_string($s, $strip_tags = true) {
+        if ($strip_tags) {
+            $s = strip_tags($s);
+        }
+
+        return mysqli_real_escape_string($this->link, $s);
+    }
+
+    public function query($query, $die_on_error = true) {
+        $result = @mysqli_query($this->link, $query);
+        if (!$result) {
+            $this->last_error = @mysqli_error($this->link);
+
+            @mysqli_query($this->link, "ROLLBACK");
+            user_error("query $query failed: ".($this->link ? $this->last_error : "No connection"),
+                $die_on_error ? E_USER_ERROR : E_USER_WARNING);
+        }
+
+        return $result;
+    }
+
+    public function fetch_assoc($result) {
+        return mysqli_fetch_assoc($result);
+    }
+
+
+    public function num_rows($result) {
+        return mysqli_num_rows($result);
+    }
+
+    public function fetch_result($result, $row, $param) {
+        if (mysqli_data_seek($result, $row)) {
+            $line = mysqli_fetch_assoc($result);
+            return $line[$param];
+        } else {
+            return false;
+        }
+    }
+
+    public function close() {
+        return mysqli_close($this->link);
+    }
+
+    public function affected_rows($result) {
+        return mysqli_affected_rows($this->link);
+    }
+
+    public function last_error() {
+        return mysqli_error($this->link);
+    }
+
+    public function last_query_error() {
+        return $this->last_error;
+    }
+
+    public function init() {
+        $this->query("SET time_zone = '+0:0'");
+
+        if (defined('MYSQL_CHARSET') && MYSQL_CHARSET) {
+            mysqli_set_charset($this->link, MYSQL_CHARSET);
+        }
+
+        return true;
+    }
 
 }

classes/db/pgsql.php

Indentation +67 added lines, -67 removed lines

@@ -1,93 +1,93 @@
 <?php
 class Db_Pgsql implements IDb {
-	private $link;
-	private $last_error;
+    private $link;
+    private $last_error;
 
-	public function connect($host, $user, $pass, $db, $port) {
-		$string = "dbname=$db user=$user";
+    public function connect($host, $user, $pass, $db, $port) {
+        $string = "dbname=$db user=$user";
 
-		if ($pass) {
-			$string .= " password=$pass";
-		}
+        if ($pass) {
+            $string .= " password=$pass";
+        }
 
-		if ($host) {
-			$string .= " host=$host";
-		}
+        if ($host) {
+            $string .= " host=$host";
+        }
 
-		if (is_numeric($port) && $port > 0) {
-			$string = "$string port=".$port;
-		}
+        if (is_numeric($port) && $port > 0) {
+            $string = "$string port=".$port;
+        }
 
-		$this->link = pg_connect($string);
+        $this->link = pg_connect($string);
 
-		if (!$this->link) {
-			print("Unable to connect to database (as $user to $host, database $db):".pg_last_error());
-			exit(102);
-		}
+        if (!$this->link) {
+            print("Unable to connect to database (as $user to $host, database $db):".pg_last_error());
+            exit(102);
+        }
 
-		$this->init();
+        $this->init();
 
-		return $this->link;
-	}
+        return $this->link;
+    }
 
-	public function escape_string($s, $strip_tags = true) {
-		if ($strip_tags) {
-		    $s = strip_tags($s);
-		}
+    public function escape_string($s, $strip_tags = true) {
+        if ($strip_tags) {
+            $s = strip_tags($s);
+        }
 
-		return pg_escape_string($s);
-	}
+        return pg_escape_string($s);
+    }
 
-	public function query($query, $die_on_error = true) {
-		$result = @pg_query($this->link, $query);
+    public function query($query, $die_on_error = true) {
+        $result = @pg_query($this->link, $query);
 
-		if (!$result) {
-			$this->last_error = @pg_last_error($this->link);
+        if (!$result) {
+            $this->last_error = @pg_last_error($this->link);
 
-			@pg_query($this->link, "ROLLBACK");
-			$query = htmlspecialchars($query); // just in case
-			user_error("query $query failed: ".($this->link ? $this->last_error : "No connection"),
-				$die_on_error ? E_USER_ERROR : E_USER_WARNING);
-		}
-		return $result;
-	}
+            @pg_query($this->link, "ROLLBACK");
+            $query = htmlspecialchars($query); // just in case
+            user_error("query $query failed: ".($this->link ? $this->last_error : "No connection"),
+                $die_on_error ? E_USER_ERROR : E_USER_WARNING);
+        }
+        return $result;
+    }
 
-	public function fetch_assoc($result) {
-		return pg_fetch_assoc($result);
-	}
+    public function fetch_assoc($result) {
+        return pg_fetch_assoc($result);
+    }
 
 
-	public function num_rows($result) {
-		return pg_num_rows($result);
-	}
+    public function num_rows($result) {
+        return pg_num_rows($result);
+    }
 
-	public function fetch_result($result, $row, $param) {
-		return pg_fetch_result($result, $row, $param);
-	}
+    public function fetch_result($result, $row, $param) {
+        return pg_fetch_result($result, $row, $param);
+    }
 
-	public function close() {
-		return pg_close($this->link);
-	}
+    public function close() {
+        return pg_close($this->link);
+    }
 
-	public function affected_rows($result) {
-		return pg_affected_rows($result);
-	}
+    public function affected_rows($result) {
+        return pg_affected_rows($result);
+    }
 
-	public function last_error() {
-		return pg_last_error($this->link);
-	}
+    public function last_error() {
+        return pg_last_error($this->link);
+    }
 
-	public function last_query_error() {
-		return $this->last_error;
-	}
+    public function last_query_error() {
+        return $this->last_error;
+    }
 
-	public function init() {
-		$this->query("set client_encoding = 'UTF-8'");
-		pg_set_client_encoding("UNICODE");
-		$this->query("set datestyle = 'ISO, european'");
-		$this->query("set TIME ZONE 0");
-		$this->query("set cpu_tuple_cost = 0.5");
+    public function init() {
+        $this->query("set client_encoding = 'UTF-8'");
+        pg_set_client_encoding("UNICODE");
+        $this->query("set datestyle = 'ISO, european'");
+        $this->query("set TIME ZONE 0");
+        $this->query("set cpu_tuple_cost = 0.5");
 
-		return true;
-	}
+        return true;
+    }
 }

classes/db/prefs.php

Indentation +137 added lines, -137 removed lines

@@ -1,35 +1,35 @@ 
 <?php
 class Db_Prefs {
-	private $pdo;
-	private static $instance;
-	private $cache;
+    private $pdo;
+    private static $instance;
+    private $cache;
 
-	public function __construct() {
-		$this->pdo = Db::pdo();
-		$this->cache = array();
+    public function __construct() {
+        $this->pdo = Db::pdo();
+        $this->cache = array();
 
-		if ($_SESSION["uid"]) {
-		    $this->cache();
-		}
-	}
+        if ($_SESSION["uid"]) {
+            $this->cache();
+        }
+    }
 
-	public static function get() {
-		if (self::$instance == null) {
-					self::$instance = new self();
-		}
+    public static function get() {
+        if (self::$instance == null) {
+                    self::$instance = new self();
+        }
 
-		return self::$instance;
-	}
+        return self::$instance;
+    }
 
-	public function cache() {
-		$user_id = $_SESSION["uid"];
-		@$profile = $_SESSION["profile"];
+    public function cache() {
+        $user_id = $_SESSION["uid"];
+        @$profile = $_SESSION["profile"];
 
-		if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
-		    $profile = null;
-		}
+        if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
+            $profile = null;
+        }
 
-		$sth = $this->pdo->prepare("SELECT
+        $sth = $this->pdo->prepare("SELECT
 			value,ttrss_prefs_types.type_name as type_name,ttrss_prefs.pref_name AS pref_name
 			FROM
 				ttrss_user_prefs,ttrss_prefs,ttrss_prefs_types
@@ -40,37 +40,37 @@ 
 				owner_uid = :uid AND
 				ttrss_user_prefs.pref_name = ttrss_prefs.pref_name");
 
-		$sth->execute([":profile" => $profile, ":uid" => $user_id]);
+        $sth->execute([":profile" => $profile, ":uid" => $user_id]);
 
-		while ($line = $sth->fetch()) {
-			if ($user_id == $_SESSION["uid"]) {
-				$pref_name = $line["pref_name"];
+        while ($line = $sth->fetch()) {
+            if ($user_id == $_SESSION["uid"]) {
+                $pref_name = $line["pref_name"];
 
-				$this->cache[$pref_name]["type"] = $line["type_name"];
-				$this->cache[$pref_name]["value"] = $line["value"];
-			}
-		}
-	}
+                $this->cache[$pref_name]["type"] = $line["type_name"];
+                $this->cache[$pref_name]["value"] = $line["value"];
+            }
+        }
+    }
 
-	public function read($pref_name, $user_id = false, $die_on_error = false) {
+    public function read($pref_name, $user_id = false, $die_on_error = false) {
 
-		if (!$user_id) {
-			$user_id = $_SESSION["uid"];
-			@$profile = $_SESSION["profile"];
-		} else {
-			$profile = false;
-		}
+        if (!$user_id) {
+            $user_id = $_SESSION["uid"];
+            @$profile = $_SESSION["profile"];
+        } else {
+            $profile = false;
+        }
 
-		if ($user_id == $_SESSION['uid'] && isset($this->cache[$pref_name])) {
-			$tuple = $this->cache[$pref_name];
-			return $this->convert($tuple["value"], $tuple["type"]);
-		}
+        if ($user_id == $_SESSION['uid'] && isset($this->cache[$pref_name])) {
+            $tuple = $this->cache[$pref_name];
+            return $this->convert($tuple["value"], $tuple["type"]);
+        }
 
-		if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
-		    $profile = null;
-		}
+        if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
+            $profile = null;
+        }
 
-		$sth = $this->pdo->prepare("SELECT
+        $sth = $this->pdo->prepare("SELECT
 			value,ttrss_prefs_types.type_name as type_name
 			FROM
 				ttrss_user_prefs,ttrss_prefs,ttrss_prefs_types
@@ -80,101 +80,101 @@ 
 				ttrss_prefs_types.id = type_id AND
 				owner_uid = :uid AND
 				ttrss_user_prefs.pref_name = ttrss_prefs.pref_name");
-		$sth->execute([":uid" => $user_id, ":profile" => $profile, ":pref_name" => $pref_name]);
-
-		if ($row = $sth->fetch()) {
-			$value = $row["value"];
-			$type_name = $row["type_name"];
-
-			if ($user_id == $_SESSION["uid"]) {
-				$this->cache[$pref_name]["type"] = $type_name;
-				$this->cache[$pref_name]["value"] = $value;
-			}
-
-			return $this->convert($value, $type_name);
-
-		} else if ($die_on_error) {
-			user_error("Fatal error, unknown preferences key: $pref_name (owner: $user_id)", E_USER_ERROR);
-			return null;
-		} else {
-			return null;
-		}
-	}
-
-	public function convert($value, $type_name) {
-		if ($type_name == "bool") {
-			return $value == "true";
-		} else if ($type_name == "integer") {
-			return (int) $value;
-		} else {
-			return $value;
-		}
-	}
-
-	public function write($pref_name, $value, $user_id = false, $strip_tags = true) {
-		if ($strip_tags) {
-		    $value = strip_tags($value);
-		}
-
-		if (!$user_id) {
-			$user_id = $_SESSION["uid"];
-			@$profile = $_SESSION["profile"];
-		} else {
-			$profile = null;
-		}
-
-		if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
-		    $profile = null;
-		}
-
-		$type_name = "";
-		$current_value = "";
-
-		if (isset($this->cache[$pref_name])) {
-			$type_name = $this->cache[$pref_name]["type"];
-			$current_value = $this->cache[$pref_name]["value"];
-		}
-
-		if (!$type_name) {
-			$sth = $this->pdo->prepare("SELECT type_name
+        $sth->execute([":uid" => $user_id, ":profile" => $profile, ":pref_name" => $pref_name]);
+
+        if ($row = $sth->fetch()) {
+            $value = $row["value"];
+            $type_name = $row["type_name"];
+
+            if ($user_id == $_SESSION["uid"]) {
+                $this->cache[$pref_name]["type"] = $type_name;
+                $this->cache[$pref_name]["value"] = $value;
+            }
+
+            return $this->convert($value, $type_name);
+
+        } else if ($die_on_error) {
+            user_error("Fatal error, unknown preferences key: $pref_name (owner: $user_id)", E_USER_ERROR);
+            return null;
+        } else {
+            return null;
+        }
+    }
+
+    public function convert($value, $type_name) {
+        if ($type_name == "bool") {
+            return $value == "true";
+        } else if ($type_name == "integer") {
+            return (int) $value;
+        } else {
+            return $value;
+        }
+    }
+
+    public function write($pref_name, $value, $user_id = false, $strip_tags = true) {
+        if ($strip_tags) {
+            $value = strip_tags($value);
+        }
+
+        if (!$user_id) {
+            $user_id = $_SESSION["uid"];
+            @$profile = $_SESSION["profile"];
+        } else {
+            $profile = null;
+        }
+
+        if (!is_numeric($profile) || !$profile || get_schema_version() < 63) {
+            $profile = null;
+        }
+
+        $type_name = "";
+        $current_value = "";
+
+        if (isset($this->cache[$pref_name])) {
+            $type_name = $this->cache[$pref_name]["type"];
+            $current_value = $this->cache[$pref_name]["value"];
+        }
+
+        if (!$type_name) {
+            $sth = $this->pdo->prepare("SELECT type_name
 				FROM ttrss_prefs,ttrss_prefs_types
 				WHERE pref_name = ? AND type_id = ttrss_prefs_types.id");
-			$sth->execute([$pref_name]);
-
-			if ($row = $sth->fetch()) {
-							$type_name = $row["type_name"];
-			}
-
-		} else if ($current_value == $value) {
-			return;
-		}
-
-		if ($type_name) {
-			if ($type_name == "bool") {
-				if ($value == "1" || $value == "true") {
-					$value = "true";
-				} else {
-					$value = "false";
-				}
-			} else if ($type_name == "integer") {
-				$value = (int) $value;
-			}
-
-			if ($pref_name == 'USER_TIMEZONE' && $value == '') {
-				$value = 'UTC';
-			}
-
-			$sth = $this->pdo->prepare("UPDATE ttrss_user_prefs SET
+            $sth->execute([$pref_name]);
+
+            if ($row = $sth->fetch()) {
+                            $type_name = $row["type_name"];
+            }
+
+        } else if ($current_value == $value) {
+            return;
+        }
+
+        if ($type_name) {
+            if ($type_name == "bool") {
+                if ($value == "1" || $value == "true") {
+                    $value = "true";
+                } else {
+                    $value = "false";
+                }
+            } else if ($type_name == "integer") {
+                $value = (int) $value;
+            }
+
+            if ($pref_name == 'USER_TIMEZONE' && $value == '') {
+                $value = 'UTC';
+            }
+
+            $sth = $this->pdo->prepare("UPDATE ttrss_user_prefs SET
 				value = :value WHERE pref_name = :pref_name
 					AND (profile = :profile OR (:profile IS NULL AND profile IS NULL))
 					AND owner_uid = :uid");
 
-			$sth->execute([":pref_name" => $pref_name, ":value" => $value, ":uid" => $user_id, ":profile" => $profile]);
+            $sth->execute([":pref_name" => $pref_name, ":value" => $value, ":uid" => $user_id, ":profile" => $profile]);
 
-			if ($user_id == $_SESSION["uid"]) {
-				$this->cache[$pref_name]["type"] = $type_name;
-				$this->cache[$pref_name]["value"] = $value;
-			}
-		}
-	}
+            if ($user_id == $_SESSION["uid"]) {
+                $this->cache[$pref_name]["type"] = $type_name;
+                $this->cache[$pref_name]["value"] = $value;
+            }
+        }
+    }
 }

classes/api.php

Indentation +769 added lines, -769 removed lines

@@ -1,148 +1,148 @@ 
 <?php
 class API extends Handler {
 
-	const API_LEVEL  = 14;
-
-	const STATUS_OK  = 0;
-	const STATUS_ERR = 1;
-
-	private $seq;
-
-	public static function param_to_bool($p) {
-		return $p && ($p !== "f" && $p !== "false");
-	}
-
-	public function before($method) {
-		if (parent::before($method)) {
-			header("Content-Type: text/json");
-
-			if (!$_SESSION["uid"] && $method != "login" && $method != "isloggedin") {
-				$this->wrap(self::STATUS_ERR, array("error" => 'NOT_LOGGED_IN'));
-				return false;
-			}
-
-			if ($_SESSION["uid"] && $method != "logout" && !get_pref('ENABLE_API_ACCESS')) {
-				$this->wrap(self::STATUS_ERR, array("error" => 'API_DISABLED'));
-				return false;
-			}
-
-			$this->seq = (int) clean($_REQUEST['seq']);
-
-			return true;
-		}
-		return false;
-	}
-
-	public function wrap($status, $reply) {
-		print json_encode(array("seq" => $this->seq,
-			"status" => $status,
-			"content" => $reply));
-	}
-
-	public function getVersion() {
-		$rv = array("version" => VERSION);
-		$this->wrap(self::STATUS_OK, $rv);
-	}
-
-	public function getApiLevel() {
-		$rv = array("level" => self::API_LEVEL);
-		$this->wrap(self::STATUS_OK, $rv);
-	}
-
-	public function login() {
-		@session_destroy();
-		@session_start();
-
-		$login = clean($_REQUEST["user"]);
-		$password = clean($_REQUEST["password"]);
-		$password_base64 = base64_decode(clean($_REQUEST["password"]));
-
-		if (SINGLE_USER_MODE) {
-		    $login = "admin";
-		}
-
-		$sth = $this->pdo->prepare("SELECT id FROM ttrss_users WHERE login = ?");
-		$sth->execute([$login]);
-
-		if ($row = $sth->fetch()) {
-			$uid = $row["id"];
-		} else {
-			$uid = 0;
-		}
-
-		if (!$uid) {
-			$this->wrap(self::STATUS_ERR, array("error" => "LOGIN_ERROR"));
-			return;
-		}
-
-		if (get_pref("ENABLE_API_ACCESS", $uid)) {
-			if (authenticate_user($login, $password, false, Auth_Base::AUTH_SERVICE_API)) {               // try login with normal password
-				$this->wrap(self::STATUS_OK, array("session_id" => session_id(),
-					"api_level" => self::API_LEVEL));
-			} else if (authenticate_user($login, $password_base64, false, Auth_Base::AUTH_SERVICE_API)) { // else try with base64_decoded password
-				$this->wrap(self::STATUS_OK, array("session_id" => session_id(),
-					"api_level" => self::API_LEVEL));
-			} else {                                                         // else we are not logged in
-				user_error("Failed login attempt for $login from {$_SERVER['REMOTE_ADDR']}", E_USER_WARNING);
-				$this->wrap(self::STATUS_ERR, array("error" => "LOGIN_ERROR"));
-			}
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => "API_DISABLED"));
-		}
-
-	}
-
-	public function logout() {
-		logout_user();
-		$this->wrap(self::STATUS_OK, array("status" => "OK"));
-	}
-
-	public function isLoggedIn() {
-		$this->wrap(self::STATUS_OK, array("status" => $_SESSION["uid"] != ''));
-	}
-
-	public function getUnread() {
-		$feed_id = clean($_REQUEST["feed_id"]);
-		$is_cat = clean($_REQUEST["is_cat"]);
-
-		if ($feed_id) {
-			$this->wrap(self::STATUS_OK, array("unread" => getFeedUnread($feed_id, $is_cat)));
-		} else {
-			$this->wrap(self::STATUS_OK, array("unread" => Feeds::getGlobalUnread()));
-		}
-	}
-
-	/* Method added for ttrss-reader for Android */
-	public function getCounters() {
-		$this->wrap(self::STATUS_OK, Counters::getAllCounters());
-	}
-
-	public function getFeeds() {
-		$cat_id = clean($_REQUEST["cat_id"]);
-		$unread_only = API::param_to_bool(clean($_REQUEST["unread_only"]));
-		$limit = (int) clean($_REQUEST["limit"]);
-		$offset = (int) clean($_REQUEST["offset"]);
-		$include_nested = API::param_to_bool(clean($_REQUEST["include_nested"]));
-
-		$feeds = $this->api_get_feeds($cat_id, $unread_only, $limit, $offset, $include_nested);
-
-		$this->wrap(self::STATUS_OK, $feeds);
-	}
-
-	public function getCategories() {
-		$unread_only = API::param_to_bool(clean($_REQUEST["unread_only"]));
-		$enable_nested = API::param_to_bool(clean($_REQUEST["enable_nested"]));
-		$include_empty = API::param_to_bool(clean($_REQUEST['include_empty']));
-
-		// TODO do not return empty categories, return Uncategorized and standard virtual cats
-
-		if ($enable_nested) {
-					$nested_qpart = "parent_cat IS NULL";
-		} else {
-					$nested_qpart = "true";
-		}
-
-		$sth = $this->pdo->prepare("SELECT
+    const API_LEVEL  = 14;
+
+    const STATUS_OK  = 0;
+    const STATUS_ERR = 1;
+
+    private $seq;
+
+    public static function param_to_bool($p) {
+        return $p && ($p !== "f" && $p !== "false");
+    }
+
+    public function before($method) {
+        if (parent::before($method)) {
+            header("Content-Type: text/json");
+
+            if (!$_SESSION["uid"] && $method != "login" && $method != "isloggedin") {
+                $this->wrap(self::STATUS_ERR, array("error" => 'NOT_LOGGED_IN'));
+                return false;
+            }
+
+            if ($_SESSION["uid"] && $method != "logout" && !get_pref('ENABLE_API_ACCESS')) {
+                $this->wrap(self::STATUS_ERR, array("error" => 'API_DISABLED'));
+                return false;
+            }
+
+            $this->seq = (int) clean($_REQUEST['seq']);
+
+            return true;
+        }
+        return false;
+    }
+
+    public function wrap($status, $reply) {
+        print json_encode(array("seq" => $this->seq,
+            "status" => $status,
+            "content" => $reply));
+    }
+
+    public function getVersion() {
+        $rv = array("version" => VERSION);
+        $this->wrap(self::STATUS_OK, $rv);
+    }
+
+    public function getApiLevel() {
+        $rv = array("level" => self::API_LEVEL);
+        $this->wrap(self::STATUS_OK, $rv);
+    }
+
+    public function login() {
+        @session_destroy();
+        @session_start();
+
+        $login = clean($_REQUEST["user"]);
+        $password = clean($_REQUEST["password"]);
+        $password_base64 = base64_decode(clean($_REQUEST["password"]));
+
+        if (SINGLE_USER_MODE) {
+            $login = "admin";
+        }
+
+        $sth = $this->pdo->prepare("SELECT id FROM ttrss_users WHERE login = ?");
+        $sth->execute([$login]);
+
+        if ($row = $sth->fetch()) {
+            $uid = $row["id"];
+        } else {
+            $uid = 0;
+        }
+
+        if (!$uid) {
+            $this->wrap(self::STATUS_ERR, array("error" => "LOGIN_ERROR"));
+            return;
+        }
+
+        if (get_pref("ENABLE_API_ACCESS", $uid)) {
+            if (authenticate_user($login, $password, false, Auth_Base::AUTH_SERVICE_API)) {               // try login with normal password
+                $this->wrap(self::STATUS_OK, array("session_id" => session_id(),
+                    "api_level" => self::API_LEVEL));
+            } else if (authenticate_user($login, $password_base64, false, Auth_Base::AUTH_SERVICE_API)) { // else try with base64_decoded password
+                $this->wrap(self::STATUS_OK, array("session_id" => session_id(),
+                    "api_level" => self::API_LEVEL));
+            } else {                                                         // else we are not logged in
+                user_error("Failed login attempt for $login from {$_SERVER['REMOTE_ADDR']}", E_USER_WARNING);
+                $this->wrap(self::STATUS_ERR, array("error" => "LOGIN_ERROR"));
+            }
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => "API_DISABLED"));
+        }
+
+    }
+
+    public function logout() {
+        logout_user();
+        $this->wrap(self::STATUS_OK, array("status" => "OK"));
+    }
+
+    public function isLoggedIn() {
+        $this->wrap(self::STATUS_OK, array("status" => $_SESSION["uid"] != ''));
+    }
+
+    public function getUnread() {
+        $feed_id = clean($_REQUEST["feed_id"]);
+        $is_cat = clean($_REQUEST["is_cat"]);
+
+        if ($feed_id) {
+            $this->wrap(self::STATUS_OK, array("unread" => getFeedUnread($feed_id, $is_cat)));
+        } else {
+            $this->wrap(self::STATUS_OK, array("unread" => Feeds::getGlobalUnread()));
+        }
+    }
+
+    /* Method added for ttrss-reader for Android */
+    public function getCounters() {
+        $this->wrap(self::STATUS_OK, Counters::getAllCounters());
+    }
+
+    public function getFeeds() {
+        $cat_id = clean($_REQUEST["cat_id"]);
+        $unread_only = API::param_to_bool(clean($_REQUEST["unread_only"]));
+        $limit = (int) clean($_REQUEST["limit"]);
+        $offset = (int) clean($_REQUEST["offset"]);
+        $include_nested = API::param_to_bool(clean($_REQUEST["include_nested"]));
+
+        $feeds = $this->api_get_feeds($cat_id, $unread_only, $limit, $offset, $include_nested);
+
+        $this->wrap(self::STATUS_OK, $feeds);
+    }
+
+    public function getCategories() {
+        $unread_only = API::param_to_bool(clean($_REQUEST["unread_only"]));
+        $enable_nested = API::param_to_bool(clean($_REQUEST["enable_nested"]));
+        $include_empty = API::param_to_bool(clean($_REQUEST['include_empty']));
+
+        // TODO do not return empty categories, return Uncategorized and standard virtual cats
+
+        if ($enable_nested) {
+                    $nested_qpart = "parent_cat IS NULL";
+        } else {
+                    $nested_qpart = "true";
+        }
+
+        $sth = $this->pdo->prepare("SELECT
 				id, title, order_id, (SELECT COUNT(id) FROM
 				ttrss_feeds WHERE
 				ttrss_feed_categories.id IS NOT NULL AND cat_id = ttrss_feed_categories.id) AS num_feeds,
@@ -151,191 +151,191 @@ 
 				c2.parent_cat = ttrss_feed_categories.id) AS num_cats
 			FROM ttrss_feed_categories
 			WHERE $nested_qpart AND owner_uid = ?");
-		$sth->execute([$_SESSION['uid']]);
-
-		$cats = array();
-
-		while ($line = $sth->fetch()) {
-			if ($include_empty || $line["num_feeds"] > 0 || $line["num_cats"] > 0) {
-				$unread = getFeedUnread($line["id"], true);
-
-				if ($enable_nested) {
-									$unread += Feeds::getCategoryChildrenUnread($line["id"]);
-				}
-
-				if ($unread || !$unread_only) {
-					array_push($cats, array("id" => $line["id"],
-						"title" => $line["title"],
-						"unread" => $unread,
-						"order_id" => (int) $line["order_id"],
-					));
-				}
-			}
-		}
-
-		foreach (array(-2, -1, 0) as $cat_id) {
-			if ($include_empty || !$this->isCategoryEmpty($cat_id)) {
-				$unread = getFeedUnread($cat_id, true);
-
-				if ($unread || !$unread_only) {
-					array_push($cats, array("id" => $cat_id,
-						"title" => Feeds::getCategoryTitle($cat_id),
-						"unread" => $unread));
-				}
-			}
-		}
-
-		$this->wrap(self::STATUS_OK, $cats);
-	}
-
-	public function getHeadlines() {
-		$feed_id = clean($_REQUEST["feed_id"]);
-		if ($feed_id !== "") {
-
-			if (is_numeric($feed_id)) $feed_id = (int) $feed_id;
-
-			$limit = (int) clean($_REQUEST["limit"]);
-
-			if (!$limit || $limit >= 200) $limit = 200;
-
-			$offset = (int) clean($_REQUEST["skip"]);
-			$filter = clean($_REQUEST["filter"]);
-			$is_cat = API::param_to_bool(clean($_REQUEST["is_cat"]));
-			$show_excerpt = API::param_to_bool(clean($_REQUEST["show_excerpt"]));
-			$show_content = API::param_to_bool(clean($_REQUEST["show_content"]));
-			/* all_articles, unread, adaptive, marked, updated */
-			$view_mode = clean($_REQUEST["view_mode"]);
-			$include_attachments = API::param_to_bool(clean($_REQUEST["include_attachments"]));
-			$since_id = (int) clean($_REQUEST["since_id"]);
-			$include_nested = API::param_to_bool(clean($_REQUEST["include_nested"]));
-			$sanitize_content = !isset($_REQUEST["sanitize"]) ||
-				API::param_to_bool($_REQUEST["sanitize"]);
-			$force_update = API::param_to_bool(clean($_REQUEST["force_update"]));
-			$has_sandbox = API::param_to_bool(clean($_REQUEST["has_sandbox"]));
-			$excerpt_length = (int) clean($_REQUEST["excerpt_length"]);
-			$check_first_id = (int) clean($_REQUEST["check_first_id"]);
-			$include_header = API::param_to_bool(clean($_REQUEST["include_header"]));
-
-			$_SESSION['hasSandbox'] = $has_sandbox;
-
-			$skip_first_id_check = false;
-
-			$override_order = false;
-			switch (clean($_REQUEST["order_by"])) {
-				case "title":
-					$override_order = "ttrss_entries.title, date_entered, updated";
-					break;
-				case "date_reverse":
-					$override_order = "score DESC, date_entered, updated";
-					$skip_first_id_check = true;
-					break;
-				case "feed_dates":
-					$override_order = "updated DESC";
-					break;
-			}
-
-			/* do not rely on params below */
-
-			$search = clean($_REQUEST["search"]);
-
-			list($headlines, $headlines_header) = $this->api_get_headlines($feed_id, $limit, $offset,
-				$filter, $is_cat, $show_excerpt, $show_content, $view_mode, $override_order,
-				$include_attachments, $since_id, $search,
-				$include_nested, $sanitize_content, $force_update, $excerpt_length, $check_first_id, $skip_first_id_check);
-
-			if ($include_header) {
-				$this->wrap(self::STATUS_OK, array($headlines_header, $headlines));
-			} else {
-				$this->wrap(self::STATUS_OK, $headlines);
-			}
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
-		}
-	}
-
-	public function updateArticle() {
-		$article_ids = explode(",", clean($_REQUEST["article_ids"]));
-		$mode = (int) clean($_REQUEST["mode"]);
-		$data = clean($_REQUEST["data"]);
-		$field_raw = (int) clean($_REQUEST["field"]);
-
-		$field = "";
-		$set_to = "";
-
-		switch ($field_raw) {
-			case 0:
-				$field = "marked";
-				$additional_fields = ",last_marked = NOW()";
-				break;
-			case 1:
-				$field = "published";
-				$additional_fields = ",last_published = NOW()";
-				break;
-			case 2:
-				$field = "unread";
-				$additional_fields = ",last_read = NOW()";
-				break;
-			case 3:
-				$field = "note";
-		};
-
-		switch ($mode) {
-			case 1:
-				$set_to = "true";
-				break;
-			case 0:
-				$set_to = "false";
-				break;
-			case 2:
-				$set_to = "not $field";
-				break;
-		}
-
-		if ($field == "note") {
-		    $set_to = $this->pdo->quote($data);
-		}
-
-		if ($field && $set_to && count($article_ids) > 0) {
-
-			$article_qmarks = arr_qmarks($article_ids);
-
-			$sth = $this->pdo->prepare("UPDATE ttrss_user_entries SET
+        $sth->execute([$_SESSION['uid']]);
+
+        $cats = array();
+
+        while ($line = $sth->fetch()) {
+            if ($include_empty || $line["num_feeds"] > 0 || $line["num_cats"] > 0) {
+                $unread = getFeedUnread($line["id"], true);
+
+                if ($enable_nested) {
+                                    $unread += Feeds::getCategoryChildrenUnread($line["id"]);
+                }
+
+                if ($unread || !$unread_only) {
+                    array_push($cats, array("id" => $line["id"],
+                        "title" => $line["title"],
+                        "unread" => $unread,
+                        "order_id" => (int) $line["order_id"],
+                    ));
+                }
+            }
+        }
+
+        foreach (array(-2, -1, 0) as $cat_id) {
+            if ($include_empty || !$this->isCategoryEmpty($cat_id)) {
+                $unread = getFeedUnread($cat_id, true);
+
+                if ($unread || !$unread_only) {
+                    array_push($cats, array("id" => $cat_id,
+                        "title" => Feeds::getCategoryTitle($cat_id),
+                        "unread" => $unread));
+                }
+            }
+        }
+
+        $this->wrap(self::STATUS_OK, $cats);
+    }
+
+    public function getHeadlines() {
+        $feed_id = clean($_REQUEST["feed_id"]);
+        if ($feed_id !== "") {
+
+            if (is_numeric($feed_id)) $feed_id = (int) $feed_id;
+
+            $limit = (int) clean($_REQUEST["limit"]);
+
+            if (!$limit || $limit >= 200) $limit = 200;
+
+            $offset = (int) clean($_REQUEST["skip"]);
+            $filter = clean($_REQUEST["filter"]);
+            $is_cat = API::param_to_bool(clean($_REQUEST["is_cat"]));
+            $show_excerpt = API::param_to_bool(clean($_REQUEST["show_excerpt"]));
+            $show_content = API::param_to_bool(clean($_REQUEST["show_content"]));
+            /* all_articles, unread, adaptive, marked, updated */
+            $view_mode = clean($_REQUEST["view_mode"]);
+            $include_attachments = API::param_to_bool(clean($_REQUEST["include_attachments"]));
+            $since_id = (int) clean($_REQUEST["since_id"]);
+            $include_nested = API::param_to_bool(clean($_REQUEST["include_nested"]));
+            $sanitize_content = !isset($_REQUEST["sanitize"]) ||
+                API::param_to_bool($_REQUEST["sanitize"]);
+            $force_update = API::param_to_bool(clean($_REQUEST["force_update"]));
+            $has_sandbox = API::param_to_bool(clean($_REQUEST["has_sandbox"]));
+            $excerpt_length = (int) clean($_REQUEST["excerpt_length"]);
+            $check_first_id = (int) clean($_REQUEST["check_first_id"]);
+            $include_header = API::param_to_bool(clean($_REQUEST["include_header"]));
+
+            $_SESSION['hasSandbox'] = $has_sandbox;
+
+            $skip_first_id_check = false;
+
+            $override_order = false;
+            switch (clean($_REQUEST["order_by"])) {
+                case "title":
+                    $override_order = "ttrss_entries.title, date_entered, updated";
+                    break;
+                case "date_reverse":
+                    $override_order = "score DESC, date_entered, updated";
+                    $skip_first_id_check = true;
+                    break;
+                case "feed_dates":
+                    $override_order = "updated DESC";
+                    break;
+            }
+
+            /* do not rely on params below */
+
+            $search = clean($_REQUEST["search"]);
+
+            list($headlines, $headlines_header) = $this->api_get_headlines($feed_id, $limit, $offset,
+                $filter, $is_cat, $show_excerpt, $show_content, $view_mode, $override_order,
+                $include_attachments, $since_id, $search,
+                $include_nested, $sanitize_content, $force_update, $excerpt_length, $check_first_id, $skip_first_id_check);
+
+            if ($include_header) {
+                $this->wrap(self::STATUS_OK, array($headlines_header, $headlines));
+            } else {
+                $this->wrap(self::STATUS_OK, $headlines);
+            }
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
+        }
+    }
+
+    public function updateArticle() {
+        $article_ids = explode(",", clean($_REQUEST["article_ids"]));
+        $mode = (int) clean($_REQUEST["mode"]);
+        $data = clean($_REQUEST["data"]);
+        $field_raw = (int) clean($_REQUEST["field"]);
+
+        $field = "";
+        $set_to = "";
+
+        switch ($field_raw) {
+            case 0:
+                $field = "marked";
+                $additional_fields = ",last_marked = NOW()";
+                break;
+            case 1:
+                $field = "published";
+                $additional_fields = ",last_published = NOW()";
+                break;
+            case 2:
+                $field = "unread";
+                $additional_fields = ",last_read = NOW()";
+                break;
+            case 3:
+                $field = "note";
+        };
+
+        switch ($mode) {
+            case 1:
+                $set_to = "true";
+                break;
+            case 0:
+                $set_to = "false";
+                break;
+            case 2:
+                $set_to = "not $field";
+                break;
+        }
+
+        if ($field == "note") {
+            $set_to = $this->pdo->quote($data);
+        }
+
+        if ($field && $set_to && count($article_ids) > 0) {
+
+            $article_qmarks = arr_qmarks($article_ids);
+
+            $sth = $this->pdo->prepare("UPDATE ttrss_user_entries SET
 				$field = $set_to $additional_fields
 				WHERE ref_id IN ($article_qmarks) AND owner_uid = ?");
-			$sth->execute(array_merge($article_ids, [$_SESSION['uid']]));
+            $sth->execute(array_merge($article_ids, [$_SESSION['uid']]));
 
-			$num_updated = $sth->rowCount();
+            $num_updated = $sth->rowCount();
 
-			if ($num_updated > 0 && $field == "unread") {
-				$sth = $this->pdo->prepare("SELECT DISTINCT feed_id FROM ttrss_user_entries
+            if ($num_updated > 0 && $field == "unread") {
+                $sth = $this->pdo->prepare("SELECT DISTINCT feed_id FROM ttrss_user_entries
 					WHERE ref_id IN ($article_qmarks)");
-				$sth->execute($article_ids);
+                $sth->execute($article_ids);
 
-				while ($line = $sth->fetch()) {
-					CCache::update($line["feed_id"], $_SESSION["uid"]);
-				}
-			}
+                while ($line = $sth->fetch()) {
+                    CCache::update($line["feed_id"], $_SESSION["uid"]);
+                }
+            }
 
-			$this->wrap(self::STATUS_OK, array("status" => "OK",
-				"updated" => $num_updated));
+            $this->wrap(self::STATUS_OK, array("status" => "OK",
+                "updated" => $num_updated));
 
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
-		}
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
+        }
 
-	}
+    }
 
-	public function getArticle() {
+    public function getArticle() {
 
-		$article_ids = explode(",", clean($_REQUEST["article_id"]));
-		$sanitize_content = !isset($_REQUEST["sanitize"]) ||
-			API::param_to_bool($_REQUEST["sanitize"]);
+        $article_ids = explode(",", clean($_REQUEST["article_id"]));
+        $sanitize_content = !isset($_REQUEST["sanitize"]) ||
+            API::param_to_bool($_REQUEST["sanitize"]);
 
-		if ($article_ids) {
+        if ($article_ids) {
 
-			$article_qmarks = arr_qmarks($article_ids);
+            $article_qmarks = arr_qmarks($article_ids);
 
-			$sth = $this->pdo->prepare("SELECT id,guid,title,link,content,feed_id,comments,int_id,
+            $sth = $this->pdo->prepare("SELECT id,guid,title,link,content,feed_id,comments,int_id,
 				marked,unread,published,score,note,lang,
 				".SUBSTRING_FOR_DATE."(updated,1,16) as updated,
 				author,(SELECT title FROM ttrss_feeds WHERE id = feed_id) AS feed_title,
@@ -344,567 +344,567 @@ 
 				FROM ttrss_entries,ttrss_user_entries
 				WHERE id IN ($article_qmarks) AND ref_id = id AND owner_uid = ?");
 
-			$sth->execute(array_merge($article_ids, [$_SESSION['uid']]));
-
-			$articles = array();
-
-			while ($line = $sth->fetch()) {
-
-				$attachments = Article::get_article_enclosures($line['id']);
-
-				$article = array(
-					"id" => $line["id"],
-					"guid" => $line["guid"],
-					"title" => $line["title"],
-					"link" => $line["link"],
-					"labels" => Article::get_article_labels($line['id']),
-					"unread" => API::param_to_bool($line["unread"]),
-					"marked" => API::param_to_bool($line["marked"]),
-					"published" => API::param_to_bool($line["published"]),
-					"comments" => $line["comments"],
-					"author" => $line["author"],
-					"updated" => (int) strtotime($line["updated"]),
-					"feed_id" => $line["feed_id"],
-					"attachments" => $attachments,
-					"score" => (int) $line["score"],
-					"feed_title" => $line["feed_title"],
-					"note" => $line["note"],
-					"lang" => $line["lang"]
-				);
-
-				if ($sanitize_content) {
-					$article["content"] = sanitize(
-						$line["content"],
-						API::param_to_bool($line['hide_images']),
-						false, $line["site_url"], false, $line["id"]);
-				} else {
-					$article["content"] = $line["content"];
-				}
-
-				foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_RENDER_ARTICLE_API) as $p) {
-					$article = $p->hook_render_article_api(array("article" => $article));
-				}
-
-				$article['content'] = DiskCache::rewriteUrls($article['content']);
-
-				array_push($articles, $article);
-
-			}
-
-			$this->wrap(self::STATUS_OK, $articles);
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
-		}
-	}
-
-	public function getConfig() {
-		$config = array(
-			"icons_dir" => ICONS_DIR,
-			"icons_url" => ICONS_URL);
-
-		$config["daemon_is_running"] = file_is_locked("update_daemon.lock");
-
-		$sth = $this->pdo->prepare("SELECT COUNT(*) AS cf FROM
+            $sth->execute(array_merge($article_ids, [$_SESSION['uid']]));
+
+            $articles = array();
+
+            while ($line = $sth->fetch()) {
+
+                $attachments = Article::get_article_enclosures($line['id']);
+
+                $article = array(
+                    "id" => $line["id"],
+                    "guid" => $line["guid"],
+                    "title" => $line["title"],
+                    "link" => $line["link"],
+                    "labels" => Article::get_article_labels($line['id']),
+                    "unread" => API::param_to_bool($line["unread"]),
+                    "marked" => API::param_to_bool($line["marked"]),
+                    "published" => API::param_to_bool($line["published"]),
+                    "comments" => $line["comments"],
+                    "author" => $line["author"],
+                    "updated" => (int) strtotime($line["updated"]),
+                    "feed_id" => $line["feed_id"],
+                    "attachments" => $attachments,
+                    "score" => (int) $line["score"],
+                    "feed_title" => $line["feed_title"],
+                    "note" => $line["note"],
+                    "lang" => $line["lang"]
+                );
+
+                if ($sanitize_content) {
+                    $article["content"] = sanitize(
+                        $line["content"],
+                        API::param_to_bool($line['hide_images']),
+                        false, $line["site_url"], false, $line["id"]);
+                } else {
+                    $article["content"] = $line["content"];
+                }
+
+                foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_RENDER_ARTICLE_API) as $p) {
+                    $article = $p->hook_render_article_api(array("article" => $article));
+                }
+
+                $article['content'] = DiskCache::rewriteUrls($article['content']);
+
+                array_push($articles, $article);
+
+            }
+
+            $this->wrap(self::STATUS_OK, $articles);
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
+        }
+    }
+
+    public function getConfig() {
+        $config = array(
+            "icons_dir" => ICONS_DIR,
+            "icons_url" => ICONS_URL);
+
+        $config["daemon_is_running"] = file_is_locked("update_daemon.lock");
+
+        $sth = $this->pdo->prepare("SELECT COUNT(*) AS cf FROM
 			ttrss_feeds WHERE owner_uid = ?");
-		$sth->execute([$_SESSION['uid']]);
-		$row = $sth->fetch();
+        $sth->execute([$_SESSION['uid']]);
+        $row = $sth->fetch();
 
-		$config["num_feeds"] = $row["cf"];
+        $config["num_feeds"] = $row["cf"];
 
-		$this->wrap(self::STATUS_OK, $config);
-	}
+        $this->wrap(self::STATUS_OK, $config);
+    }
 
-	public function updateFeed() {
-		$feed_id = (int) clean($_REQUEST["feed_id"]);
+    public function updateFeed() {
+        $feed_id = (int) clean($_REQUEST["feed_id"]);
 
-		if (!ini_get("open_basedir")) {
-			RSSUtils::update_rss_feed($feed_id);
-		}
+        if (!ini_get("open_basedir")) {
+            RSSUtils::update_rss_feed($feed_id);
+        }
 
-		$this->wrap(self::STATUS_OK, array("status" => "OK"));
-	}
+        $this->wrap(self::STATUS_OK, array("status" => "OK"));
+    }
 
-	public function catchupFeed() {
-		$feed_id = clean($_REQUEST["feed_id"]);
-		$is_cat = clean($_REQUEST["is_cat"]);
+    public function catchupFeed() {
+        $feed_id = clean($_REQUEST["feed_id"]);
+        $is_cat = clean($_REQUEST["is_cat"]);
 
-		Feeds::catchup_feed($feed_id, $is_cat);
+        Feeds::catchup_feed($feed_id, $is_cat);
 
-		$this->wrap(self::STATUS_OK, array("status" => "OK"));
-	}
+        $this->wrap(self::STATUS_OK, array("status" => "OK"));
+    }
 
-	public function getPref() {
-		$pref_name = clean($_REQUEST["pref_name"]);
+    public function getPref() {
+        $pref_name = clean($_REQUEST["pref_name"]);
 
-		$this->wrap(self::STATUS_OK, array("value" => get_pref($pref_name)));
-	}
+        $this->wrap(self::STATUS_OK, array("value" => get_pref($pref_name)));
+    }
 
-	public function getLabels() {
-		$article_id = (int) clean($_REQUEST['article_id']);
+    public function getLabels() {
+        $article_id = (int) clean($_REQUEST['article_id']);
 
-		$rv = array();
+        $rv = array();
 
-		$sth = $this->pdo->prepare("SELECT id, caption, fg_color, bg_color
+        $sth = $this->pdo->prepare("SELECT id, caption, fg_color, bg_color
 			FROM ttrss_labels2
 			WHERE owner_uid = ? ORDER BY caption");
-		$sth->execute([$_SESSION['uid']]);
+        $sth->execute([$_SESSION['uid']]);
 
-		if ($article_id) {
-					$article_labels = Article::get_article_labels($article_id);
-		} else {
-					$article_labels = array();
-		}
+        if ($article_id) {
+                    $article_labels = Article::get_article_labels($article_id);
+        } else {
+                    $article_labels = array();
+        }
 
-		while ($line = $sth->fetch()) {
+        while ($line = $sth->fetch()) {
 
-			$checked = false;
-			foreach ($article_labels as $al) {
-				if (Labels::feed_to_label_id($al[0]) == $line['id']) {
-					$checked = true;
-					break;
-				}
-			}
+            $checked = false;
+            foreach ($article_labels as $al) {
+                if (Labels::feed_to_label_id($al[0]) == $line['id']) {
+                    $checked = true;
+                    break;
+                }
+            }
 
-			array_push($rv, array(
-				"id" => (int) Labels::label_to_feed_id($line['id']),
-				"caption" => $line['caption'],
-				"fg_color" => $line['fg_color'],
-				"bg_color" => $line['bg_color'],
-				"checked" => $checked));
-		}
+            array_push($rv, array(
+                "id" => (int) Labels::label_to_feed_id($line['id']),
+                "caption" => $line['caption'],
+                "fg_color" => $line['fg_color'],
+                "bg_color" => $line['bg_color'],
+                "checked" => $checked));
+        }
 
-		$this->wrap(self::STATUS_OK, $rv);
-	}
+        $this->wrap(self::STATUS_OK, $rv);
+    }
 
-	public function setArticleLabel() {
+    public function setArticleLabel() {
 
-		$article_ids = explode(",", clean($_REQUEST["article_ids"]));
-		$label_id = (int) clean($_REQUEST['label_id']);
-		$assign = API::param_to_bool(clean($_REQUEST['assign']));
+        $article_ids = explode(",", clean($_REQUEST["article_ids"]));
+        $label_id = (int) clean($_REQUEST['label_id']);
+        $assign = API::param_to_bool(clean($_REQUEST['assign']));
 
-		$label = Labels::find_caption(Labels::feed_to_label_id($label_id), $_SESSION["uid"]);
+        $label = Labels::find_caption(Labels::feed_to_label_id($label_id), $_SESSION["uid"]);
 
-		$num_updated = 0;
+        $num_updated = 0;
 
-		if ($label) {
+        if ($label) {
 
-			foreach ($article_ids as $id) {
+            foreach ($article_ids as $id) {
 
-				if ($assign) {
-									Labels::add_article($id, $label, $_SESSION["uid"]);
-				} else {
-									Labels::remove_article($id, $label, $_SESSION["uid"]);
-				}
+                if ($assign) {
+                                    Labels::add_article($id, $label, $_SESSION["uid"]);
+                } else {
+                                    Labels::remove_article($id, $label, $_SESSION["uid"]);
+                }
 
-				++$num_updated;
+                ++$num_updated;
 
-			}
-		}
+            }
+        }
 
-		$this->wrap(self::STATUS_OK, array("status" => "OK",
-			"updated" => $num_updated));
+        $this->wrap(self::STATUS_OK, array("status" => "OK",
+            "updated" => $num_updated));
 
-	}
+    }
 
-	public function index($method) {
-		$plugin = PluginHost::getInstance()->get_api_method(strtolower($method));
+    public function index($method) {
+        $plugin = PluginHost::getInstance()->get_api_method(strtolower($method));
 
-		if ($plugin && method_exists($plugin, $method)) {
-			$reply = $plugin->$method();
+        if ($plugin && method_exists($plugin, $method)) {
+            $reply = $plugin->$method();
 
-			$this->wrap($reply[0], $reply[1]);
+            $this->wrap($reply[0], $reply[1]);
 
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'UNKNOWN_METHOD', "method" => $method));
-		}
-	}
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'UNKNOWN_METHOD', "method" => $method));
+        }
+    }
 
-	public function shareToPublished() {
-		$title = strip_tags(clean($_REQUEST["title"]));
-		$url = strip_tags(clean($_REQUEST["url"]));
-		$content = strip_tags(clean($_REQUEST["content"]));
+    public function shareToPublished() {
+        $title = strip_tags(clean($_REQUEST["title"]));
+        $url = strip_tags(clean($_REQUEST["url"]));
+        $content = strip_tags(clean($_REQUEST["content"]));
 
-		if (Article::create_published_article($title, $url, $content, "", $_SESSION["uid"])) {
-			$this->wrap(self::STATUS_OK, array("status" => 'OK'));
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'Publishing failed'));
-		}
-	}
+        if (Article::create_published_article($title, $url, $content, "", $_SESSION["uid"])) {
+            $this->wrap(self::STATUS_OK, array("status" => 'OK'));
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'Publishing failed'));
+        }
+    }
 
-	public static function api_get_feeds($cat_id, $unread_only, $limit, $offset, $include_nested = false) {
+    public static function api_get_feeds($cat_id, $unread_only, $limit, $offset, $include_nested = false) {
 
-			$feeds = array();
+            $feeds = array();
 
-			$pdo = Db::pdo();
+            $pdo = Db::pdo();
 
-			$limit = (int) $limit;
-			$offset = (int) $offset;
-			$cat_id = (int) $cat_id;
+            $limit = (int) $limit;
+            $offset = (int) $offset;
+            $cat_id = (int) $cat_id;
 
-			/* Labels */
+            /* Labels */
 
-			/* API only: -4 All feeds, including virtual feeds */
-			if ($cat_id == -4 || $cat_id == -2) {
-				$counters = Counters::getLabelCounters(true);
+            /* API only: -4 All feeds, including virtual feeds */
+            if ($cat_id == -4 || $cat_id == -2) {
+                $counters = Counters::getLabelCounters(true);
 
-				foreach (array_values($counters) as $cv) {
+                foreach (array_values($counters) as $cv) {
 
-					$unread = $cv["counter"];
+                    $unread = $cv["counter"];
 
-					if ($unread || !$unread_only) {
+                    if ($unread || !$unread_only) {
 
-						$row = array(
-								"id" => (int) $cv["id"],
-								"title" => $cv["description"],
-								"unread" => $cv["counter"],
-								"cat_id" => -2,
-							);
+                        $row = array(
+                                "id" => (int) $cv["id"],
+                                "title" => $cv["description"],
+                                "unread" => $cv["counter"],
+                                "cat_id" => -2,
+                            );
 
-						array_push($feeds, $row);
-					}
-				}
-			}
+                        array_push($feeds, $row);
+                    }
+                }
+            }
 
-			/* Virtual feeds */
+            /* Virtual feeds */
 
-			if ($cat_id == -4 || $cat_id == -1) {
-				foreach (array(-1, -2, -3, -4, -6, 0) as $i) {
-					$unread = getFeedUnread($i);
+            if ($cat_id == -4 || $cat_id == -1) {
+                foreach (array(-1, -2, -3, -4, -6, 0) as $i) {
+                    $unread = getFeedUnread($i);
 
-					if ($unread || !$unread_only) {
-						$title = Feeds::getFeedTitle($i);
+                    if ($unread || !$unread_only) {
+                        $title = Feeds::getFeedTitle($i);
 
-						$row = array(
-								"id" => $i,
-								"title" => $title,
-								"unread" => $unread,
-								"cat_id" => -1,
-							);
-						array_push($feeds, $row);
-					}
+                        $row = array(
+                                "id" => $i,
+                                "title" => $title,
+                                "unread" => $unread,
+                                "cat_id" => -1,
+                            );
+                        array_push($feeds, $row);
+                    }
 
-				}
-			}
+                }
+            }
 
-			/* Child cats */
+            /* Child cats */
 
-			if ($include_nested && $cat_id) {
-				$sth = $pdo->prepare("SELECT
+            if ($include_nested && $cat_id) {
+                $sth = $pdo->prepare("SELECT
 					id, title, order_id FROM ttrss_feed_categories
 					WHERE parent_cat = ? AND owner_uid = ? ORDER BY order_id, title");
 
-				$sth->execute([$cat_id, $_SESSION['uid']]);
+                $sth->execute([$cat_id, $_SESSION['uid']]);
 
-				while ($line = $sth->fetch()) {
-					$unread = getFeedUnread($line["id"], true) +
-						Feeds::getCategoryChildrenUnread($line["id"]);
+                while ($line = $sth->fetch()) {
+                    $unread = getFeedUnread($line["id"], true) +
+                        Feeds::getCategoryChildrenUnread($line["id"]);
 
-					if ($unread || !$unread_only) {
-						$row = array(
-								"id" => (int) $line["id"],
-								"title" => $line["title"],
-								"unread" => $unread,
-								"is_cat" => true,
+                    if ($unread || !$unread_only) {
+                        $row = array(
+                                "id" => (int) $line["id"],
+                                "title" => $line["title"],
+                                "unread" => $unread,
+                                "is_cat" => true,
                                 "order_id" => (int) $line["order_id"]
-							);
-						array_push($feeds, $row);
-					}
-				}
-			}
-
-			/* Real feeds */
-
-			if ($limit) {
-				$limit_qpart = "limit $limit OFFSET $offset";
-			} else {
-				$limit_qpart = "";
-			}
-
-			/* API only: -3 All feeds, excluding virtual feeds (e.g. Labels and such) */
-			if ($cat_id == -4 || $cat_id == -3) {
-				$sth = $pdo->prepare("SELECT
+                            );
+                        array_push($feeds, $row);
+                    }
+                }
+            }
+
+            /* Real feeds */
+
+            if ($limit) {
+                $limit_qpart = "limit $limit OFFSET $offset";
+            } else {
+                $limit_qpart = "";
+            }
+
+            /* API only: -3 All feeds, excluding virtual feeds (e.g. Labels and such) */
+            if ($cat_id == -4 || $cat_id == -3) {
+                $sth = $pdo->prepare("SELECT
 					id, feed_url, cat_id, title, order_id, ".
-						SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
+                        SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
 						FROM ttrss_feeds WHERE owner_uid = ?
 						ORDER BY order_id, title " . $limit_qpart);
-				$sth->execute([$_SESSION['uid']]);
+                $sth->execute([$_SESSION['uid']]);
 
-			} else {
+            } else {
 
-				$sth = $pdo->prepare("SELECT
+                $sth = $pdo->prepare("SELECT
 					id, feed_url, cat_id, title, order_id, ".
-						SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
+                        SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
 						FROM ttrss_feeds WHERE
 						(cat_id = :cat OR (:cat = 0 AND cat_id IS NULL))
 						AND owner_uid = :uid
 						ORDER BY order_id, title " . $limit_qpart);
-				$sth->execute([":uid" => $_SESSION['uid'], ":cat" => $cat_id]);
-			}
+                $sth->execute([":uid" => $_SESSION['uid'], ":cat" => $cat_id]);
+            }
 
-			while ($line = $sth->fetch()) {
+            while ($line = $sth->fetch()) {
 
-				$unread = getFeedUnread($line["id"]);
+                $unread = getFeedUnread($line["id"]);
 
-				$has_icon = Feeds::feedHasIcon($line['id']);
+                $has_icon = Feeds::feedHasIcon($line['id']);
 
-				if ($unread || !$unread_only) {
+                if ($unread || !$unread_only) {
 
-					$row = array(
-							"feed_url" => $line["feed_url"],
-							"title" => $line["title"],
-							"id" => (int) $line["id"],
-							"unread" => (int) $unread,
-							"has_icon" => $has_icon,
-							"cat_id" => (int) $line["cat_id"],
-							"last_updated" => (int) strtotime($line["last_updated"]),
-							"order_id" => (int) $line["order_id"],
-						);
+                    $row = array(
+                            "feed_url" => $line["feed_url"],
+                            "title" => $line["title"],
+                            "id" => (int) $line["id"],
+                            "unread" => (int) $unread,
+                            "has_icon" => $has_icon,
+                            "cat_id" => (int) $line["cat_id"],
+                            "last_updated" => (int) strtotime($line["last_updated"]),
+                            "order_id" => (int) $line["order_id"],
+                        );
 
-					array_push($feeds, $row);
-				}
-			}
+                    array_push($feeds, $row);
+                }
+            }
 
-		return $feeds;
-	}
+        return $feeds;
+    }
 
-	/**
-	 * @SuppressWarnings(PHPMD.UnusedFormalParameter)
-	 */
-	public static function api_get_headlines($feed_id, $limit, $offset,
-				$filter, $is_cat, $show_excerpt, $show_content, $view_mode, $order,
-				$include_attachments, $since_id,
-				$search = "", $include_nested = false, $sanitize_content = true,
-				$force_update = false, $excerpt_length = 100, $check_first_id = false, $skip_first_id_check = false) {
+    /**
+     * @SuppressWarnings(PHPMD.UnusedFormalParameter)
+     */
+    public static function api_get_headlines($feed_id, $limit, $offset,
+                $filter, $is_cat, $show_excerpt, $show_content, $view_mode, $order,
+                $include_attachments, $since_id,
+                $search = "", $include_nested = false, $sanitize_content = true,
+                $force_update = false, $excerpt_length = 100, $check_first_id = false, $skip_first_id_check = false) {
 
-			$pdo = Db::pdo();
+            $pdo = Db::pdo();
 
-			if ($force_update && $feed_id > 0 && is_numeric($feed_id)) {
-				// Update the feed if required with some basic flood control
+            if ($force_update && $feed_id > 0 && is_numeric($feed_id)) {
+                // Update the feed if required with some basic flood control
 
-				$sth = $pdo->prepare(
-					"SELECT cache_images,".SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
+                $sth = $pdo->prepare(
+                    "SELECT cache_images,".SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
 						FROM ttrss_feeds WHERE id = ?");
-				$sth->execute([$feed_id]);
+                $sth->execute([$feed_id]);
 
-				if ($row = $sth->fetch()) {
-					$last_updated = strtotime($row["last_updated"]);
-					$cache_images = API::param_to_bool($row["cache_images"]);
+                if ($row = $sth->fetch()) {
+                    $last_updated = strtotime($row["last_updated"]);
+                    $cache_images = API::param_to_bool($row["cache_images"]);
 
-					if (!$cache_images && time() - $last_updated > 120) {
-						RSSUtils::update_rss_feed($feed_id, true);
-					} else {
-						$sth = $pdo->prepare("UPDATE ttrss_feeds SET last_updated = '1970-01-01', last_update_started = '1970-01-01'
+                    if (!$cache_images && time() - $last_updated > 120) {
+                        RSSUtils::update_rss_feed($feed_id, true);
+                    } else {
+                        $sth = $pdo->prepare("UPDATE ttrss_feeds SET last_updated = '1970-01-01', last_update_started = '1970-01-01'
 							WHERE id = ?");
-						$sth->execute([$feed_id]);
-					}
-				}
-			}
-
-			$params = array(
-				"feed" => $feed_id,
-				"limit" => $limit,
-				"view_mode" => $view_mode,
-				"cat_view" => $is_cat,
-				"search" => $search,
-				"override_order" => $order,
-				"offset" => $offset,
-				"since_id" => $since_id,
-				"include_children" => $include_nested,
-				"check_first_id" => $check_first_id,
-				"skip_first_id_check" => $skip_first_id_check
-			);
-
-			$qfh_ret = Feeds::queryFeedHeadlines($params);
-
-			$result = $qfh_ret[0];
-			$feed_title = $qfh_ret[1];
-			$first_id = $qfh_ret[6];
-
-			$headlines = array();
-
-			$headlines_header = array(
-				'id' => $feed_id,
-				'first_id' => $first_id,
-				'is_cat' => $is_cat);
-
-			if (!is_numeric($result)) {
-				while ($line = $result->fetch()) {
-					$line["content_preview"] = truncate_string(strip_tags($line["content"]), $excerpt_length);
-					foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_QUERY_HEADLINES) as $p) {
-						$line = $p->hook_query_headlines($line, $excerpt_length, true);
-					}
-
-					$is_updated = ($line["last_read"] == "" &&
-						($line["unread"] != "t" && $line["unread"] != "1"));
-
-					$tags = explode(",", $line["tag_cache"]);
-
-					$label_cache = $line["label_cache"];
-					$labels = false;
-
-					if ($label_cache) {
-						$label_cache = json_decode($label_cache, true);
-
-						if ($label_cache) {
-							if ($label_cache["no-labels"] == 1) {
-															$labels = array();
-							} else {
-															$labels = $label_cache;
-							}
-						}
-					}
-
-					if (!is_array($labels)) {
-					    $labels = Article::get_article_labels($line["id"]);
-					}
-
-					$headline_row = array(
-						"id" => (int) $line["id"],
-						"guid" => $line["guid"],
-						"unread" => API::param_to_bool($line["unread"]),
-						"marked" => API::param_to_bool($line["marked"]),
-						"published" => API::param_to_bool($line["published"]),
-						"updated" => (int) strtotime($line["updated"]),
-						"is_updated" => $is_updated,
-						"title" => $line["title"],
-						"link" => $line["link"],
-						"feed_id" => $line["feed_id"] ? $line['feed_id'] : 0,
-						"tags" => $tags,
-					);
-
-					$enclosures = Article::get_article_enclosures($line['id']);
-
-					if ($include_attachments) {
-											$headline_row['attachments'] = $enclosures;
-					}
-
-					if ($show_excerpt) {
-											$headline_row["excerpt"] = $line["content_preview"];
-					}
-
-					if ($show_content) {
-
-						if ($sanitize_content) {
-							$headline_row["content"] = sanitize(
-								$line["content"],
-								API::param_to_bool($line['hide_images']),
-								false, $line["site_url"], false, $line["id"]);
-						} else {
-							$headline_row["content"] = $line["content"];
-						}
-					}
-
-					// unify label output to ease parsing
-					if ($labels["no-labels"] == 1) {
-					    $labels = array();
-					}
-
-					$headline_row["labels"] = $labels;
-
-					$headline_row["feed_title"] = $line["feed_title"] ? $line["feed_title"] : $feed_title;
-
-					$headline_row["comments_count"] = (int) $line["num_comments"];
-					$headline_row["comments_link"] = $line["comments"];
-
-					$headline_row["always_display_attachments"] = API::param_to_bool($line["always_display_enclosures"]);
+                        $sth->execute([$feed_id]);
+                    }
+                }
+            }
+
+            $params = array(
+                "feed" => $feed_id,
+                "limit" => $limit,
+                "view_mode" => $view_mode,
+                "cat_view" => $is_cat,
+                "search" => $search,
+                "override_order" => $order,
+                "offset" => $offset,
+                "since_id" => $since_id,
+                "include_children" => $include_nested,
+                "check_first_id" => $check_first_id,
+                "skip_first_id_check" => $skip_first_id_check
+            );
+
+            $qfh_ret = Feeds::queryFeedHeadlines($params);
+
+            $result = $qfh_ret[0];
+            $feed_title = $qfh_ret[1];
+            $first_id = $qfh_ret[6];
+
+            $headlines = array();
+
+            $headlines_header = array(
+                'id' => $feed_id,
+                'first_id' => $first_id,
+                'is_cat' => $is_cat);
+
+            if (!is_numeric($result)) {
+                while ($line = $result->fetch()) {
+                    $line["content_preview"] = truncate_string(strip_tags($line["content"]), $excerpt_length);
+                    foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_QUERY_HEADLINES) as $p) {
+                        $line = $p->hook_query_headlines($line, $excerpt_length, true);
+                    }
+
+                    $is_updated = ($line["last_read"] == "" &&
+                        ($line["unread"] != "t" && $line["unread"] != "1"));
+
+                    $tags = explode(",", $line["tag_cache"]);
+
+                    $label_cache = $line["label_cache"];
+                    $labels = false;
+
+                    if ($label_cache) {
+                        $label_cache = json_decode($label_cache, true);
+
+                        if ($label_cache) {
+                            if ($label_cache["no-labels"] == 1) {
+                                                            $labels = array();
+                            } else {
+                                                            $labels = $label_cache;
+                            }
+                        }
+                    }
+
+                    if (!is_array($labels)) {
+                        $labels = Article::get_article_labels($line["id"]);
+                    }
+
+                    $headline_row = array(
+                        "id" => (int) $line["id"],
+                        "guid" => $line["guid"],
+                        "unread" => API::param_to_bool($line["unread"]),
+                        "marked" => API::param_to_bool($line["marked"]),
+                        "published" => API::param_to_bool($line["published"]),
+                        "updated" => (int) strtotime($line["updated"]),
+                        "is_updated" => $is_updated,
+                        "title" => $line["title"],
+                        "link" => $line["link"],
+                        "feed_id" => $line["feed_id"] ? $line['feed_id'] : 0,
+                        "tags" => $tags,
+                    );
+
+                    $enclosures = Article::get_article_enclosures($line['id']);
+
+                    if ($include_attachments) {
+                                            $headline_row['attachments'] = $enclosures;
+                    }
+
+                    if ($show_excerpt) {
+                                            $headline_row["excerpt"] = $line["content_preview"];
+                    }
+
+                    if ($show_content) {
+
+                        if ($sanitize_content) {
+                            $headline_row["content"] = sanitize(
+                                $line["content"],
+                                API::param_to_bool($line['hide_images']),
+                                false, $line["site_url"], false, $line["id"]);
+                        } else {
+                            $headline_row["content"] = $line["content"];
+                        }
+                    }
+
+                    // unify label output to ease parsing
+                    if ($labels["no-labels"] == 1) {
+                        $labels = array();
+                    }
+
+                    $headline_row["labels"] = $labels;
+
+                    $headline_row["feed_title"] = $line["feed_title"] ? $line["feed_title"] : $feed_title;
+
+                    $headline_row["comments_count"] = (int) $line["num_comments"];
+                    $headline_row["comments_link"] = $line["comments"];
+
+                    $headline_row["always_display_attachments"] = API::param_to_bool($line["always_display_enclosures"]);
 
-					$headline_row["author"] = $line["author"];
+                    $headline_row["author"] = $line["author"];
 
-					$headline_row["score"] = (int) $line["score"];
-					$headline_row["note"] = $line["note"];
-					$headline_row["lang"] = $line["lang"];
+                    $headline_row["score"] = (int) $line["score"];
+                    $headline_row["note"] = $line["note"];
+                    $headline_row["lang"] = $line["lang"];
 
-					foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_RENDER_ARTICLE_API) as $p) {
-						$headline_row = $p->hook_render_article_api(array("headline" => $headline_row));
-					}
+                    foreach (PluginHost::getInstance()->get_hooks(PluginHost::HOOK_RENDER_ARTICLE_API) as $p) {
+                        $headline_row = $p->hook_render_article_api(array("headline" => $headline_row));
+                    }
 
-					$headline_row["content"] = DiskCache::rewriteUrls($headline_row['content']);
+                    $headline_row["content"] = DiskCache::rewriteUrls($headline_row['content']);
 
-					list ($flavor_image, $flavor_stream) = Article::get_article_image($enclosures, $line["content"], $line["site_url"]);
+                    list ($flavor_image, $flavor_stream) = Article::get_article_image($enclosures, $line["content"], $line["site_url"]);
 
-					$headline_row["flavor_image"] = $flavor_image;
-					$headline_row["flavor_stream"] = $flavor_stream;
+                    $headline_row["flavor_image"] = $flavor_image;
+                    $headline_row["flavor_stream"] = $flavor_stream;
 
-					array_push($headlines, $headline_row);
-				}
-			} else if (is_numeric($result) && $result == -1) {
-				$headlines_header['first_id_changed'] = true;
-			}
+                    array_push($headlines, $headline_row);
+                }
+            } else if (is_numeric($result) && $result == -1) {
+                $headlines_header['first_id_changed'] = true;
+            }
 
-			return array($headlines, $headlines_header);
-	}
+            return array($headlines, $headlines_header);
+    }
 
-	public function unsubscribeFeed() {
-		$feed_id = (int) clean($_REQUEST["feed_id"]);
+    public function unsubscribeFeed() {
+        $feed_id = (int) clean($_REQUEST["feed_id"]);
 
-		$sth = $this->pdo->prepare("SELECT id FROM ttrss_feeds WHERE
+        $sth = $this->pdo->prepare("SELECT id FROM ttrss_feeds WHERE
 			id = ? AND owner_uid = ?");
-		$sth->execute([$feed_id, $_SESSION['uid']]);
-
-		if ($sth->fetch()) {
-			Pref_Feeds::remove_feed($feed_id, $_SESSION["uid"]);
-			$this->wrap(self::STATUS_OK, array("status" => "OK"));
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => "FEED_NOT_FOUND"));
-		}
-	}
-
-	public function subscribeToFeed() {
-		$feed_url = clean($_REQUEST["feed_url"]);
-		$category_id = (int) clean($_REQUEST["category_id"]);
-		$login = clean($_REQUEST["login"]);
-		$password = clean($_REQUEST["password"]);
-
-		if ($feed_url) {
-			$rc = Feeds::subscribe_to_feed($feed_url, $category_id, $login, $password);
-
-			$this->wrap(self::STATUS_OK, array("status" => $rc));
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
-		}
-	}
-
-	public function getFeedTree() {
-		$include_empty = API::param_to_bool(clean($_REQUEST['include_empty']));
-
-		$pf = new Pref_Feeds($_REQUEST);
-
-		$_REQUEST['mode'] = 2;
-		$_REQUEST['force_show_empty'] = $include_empty;
-
-		if ($pf) {
-			$data = $pf->makefeedtree();
-			$this->wrap(self::STATUS_OK, array("categories" => $data));
-		} else {
-			$this->wrap(self::STATUS_ERR, array("error" =>
-				'UNABLE_TO_INSTANTIATE_OBJECT'));
-		}
-
-	}
-
-	// only works for labels or uncategorized for the time being
-	private function isCategoryEmpty($id) {
-
-		if ($id == -2) {
-			$sth = $this->pdo->prepare("SELECT COUNT(id) AS count FROM ttrss_labels2
+        $sth->execute([$feed_id, $_SESSION['uid']]);
+
+        if ($sth->fetch()) {
+            Pref_Feeds::remove_feed($feed_id, $_SESSION["uid"]);
+            $this->wrap(self::STATUS_OK, array("status" => "OK"));
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => "FEED_NOT_FOUND"));
+        }
+    }
+
+    public function subscribeToFeed() {
+        $feed_url = clean($_REQUEST["feed_url"]);
+        $category_id = (int) clean($_REQUEST["category_id"]);
+        $login = clean($_REQUEST["login"]);
+        $password = clean($_REQUEST["password"]);
+
+        if ($feed_url) {
+            $rc = Feeds::subscribe_to_feed($feed_url, $category_id, $login, $password);
+
+            $this->wrap(self::STATUS_OK, array("status" => $rc));
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" => 'INCORRECT_USAGE'));
+        }
+    }
+
+    public function getFeedTree() {
+        $include_empty = API::param_to_bool(clean($_REQUEST['include_empty']));
+
+        $pf = new Pref_Feeds($_REQUEST);
+
+        $_REQUEST['mode'] = 2;
+        $_REQUEST['force_show_empty'] = $include_empty;
+
+        if ($pf) {
+            $data = $pf->makefeedtree();
+            $this->wrap(self::STATUS_OK, array("categories" => $data));
+        } else {
+            $this->wrap(self::STATUS_ERR, array("error" =>
+                'UNABLE_TO_INSTANTIATE_OBJECT'));
+        }
+
+    }
+
+    // only works for labels or uncategorized for the time being
+    private function isCategoryEmpty($id) {
+
+        if ($id == -2) {
+            $sth = $this->pdo->prepare("SELECT COUNT(id) AS count FROM ttrss_labels2
 				WHERE owner_uid = ?");
-			$sth->execute([$_SESSION['uid']]);
-			$row = $sth->fetch();
+            $sth->execute([$_SESSION['uid']]);
+            $row = $sth->fetch();
 
-			return $row["count"] == 0;
+            return $row["count"] == 0;
 
-		} else if ($id == 0) {
-			$sth = $this->pdo->prepare("SELECT COUNT(id) AS count FROM ttrss_feeds
+        } else if ($id == 0) {
+            $sth = $this->pdo->prepare("SELECT COUNT(id) AS count FROM ttrss_feeds
 				WHERE cat_id IS NULL AND owner_uid = ?");
-			$sth->execute([$_SESSION['uid']]);
-			$row = $sth->fetch();
+            $sth->execute([$_SESSION['uid']]);
+            $row = $sth->fetch();
 
-			return $row["count"] == 0;
+            return $row["count"] == 0;
 
-		}
+        }
 
-		return false;
-	}
+        return false;
+    }
 
 
 }

Switch Indentation +33 added lines, -33 removed lines

@@ -222,16 +222,16 @@ 
 
 			$override_order = false;
 			switch (clean($_REQUEST["order_by"])) {
-				case "title":
-					$override_order = "ttrss_entries.title, date_entered, updated";
-					break;
-				case "date_reverse":
-					$override_order = "score DESC, date_entered, updated";
-					$skip_first_id_check = true;
-					break;
-				case "feed_dates":
-					$override_order = "updated DESC";
-					break;
+			case "title":
+				$override_order = "ttrss_entries.title, date_entered, updated";
+				break;
+			case "date_reverse":
+				$override_order = "score DESC, date_entered, updated";
+				$skip_first_id_check = true;
+				break;
+			case "feed_dates":
+				$override_order = "updated DESC";
+				break;
 			}
 
 			/* do not rely on params below */
@@ -263,32 +263,32 @@ 
 		$set_to = "";
 
 		switch ($field_raw) {
-			case 0:
-				$field = "marked";
-				$additional_fields = ",last_marked = NOW()";
-				break;
-			case 1:
-				$field = "published";
-				$additional_fields = ",last_published = NOW()";
-				break;
-			case 2:
-				$field = "unread";
-				$additional_fields = ",last_read = NOW()";
-				break;
-			case 3:
-				$field = "note";
+		case 0:
+			$field = "marked";
+			$additional_fields = ",last_marked = NOW()";
+			break;
+		case 1:
+			$field = "published";
+			$additional_fields = ",last_published = NOW()";
+			break;
+		case 2:
+			$field = "unread";
+			$additional_fields = ",last_read = NOW()";
+			break;
+		case 3:
+			$field = "note";
 		};
 
 		switch ($mode) {
-			case 1:
-				$set_to = "true";
-				break;
-			case 0:
-				$set_to = "false";
-				break;
-			case 2:
-				$set_to = "not $field";
-				break;
+		case 1:
+			$set_to = "true";
+			break;
+		case 0:
+			$set_to = "false";
+			break;
+		case 2:
+			$set_to = "not $field";
+			break;
 		}
 
 		if ($field == "note") {

Braces +6 added lines, -2 removed lines

@@ -192,11 +192,15 @@
 		$feed_id = clean($_REQUEST["feed_id"]);
 		if ($feed_id !== "") {
 
-			if (is_numeric($feed_id)) $feed_id = (int) $feed_id;
+			if (is_numeric($feed_id)) {
+			    $feed_id = (int) $feed_id;
+			}
 
 			$limit = (int) clean($_REQUEST["limit"]);
 
-			if (!$limit || $limit >= 200) $limit = 200;
+			if (!$limit || $limit >= 200) {
+			    $limit = 200;
+			}
 
 			$offset = (int) clean($_REQUEST["skip"]);
 			$filter = clean($_REQUEST["filter"]);

install/index.php

Indentation +263 added lines, -263 removed lines

@@ -1,28 +1,28 @@ 
 <?php
-	function stylesheet_tag($filename, $id = false) {
-		$timestamp = filemtime($filename);
+    function stylesheet_tag($filename, $id = false) {
+        $timestamp = filemtime($filename);
 
-		$id_part = $id ? "id=\"$id\"" : "";
+        $id_part = $id ? "id=\"$id\"" : "";
 
-		return "<link rel=\"stylesheet\" $id_part type=\"text/css\" href=\"$filename?$timestamp\"/>\n";
-	}
+        return "<link rel=\"stylesheet\" $id_part type=\"text/css\" href=\"$filename?$timestamp\"/>\n";
+    }
 
-	function javascript_tag($filename) {
-		$query = "";
+    function javascript_tag($filename) {
+        $query = "";
 
-		if (!(strpos($filename, "?") === false)) {
-			$query = substr($filename, strpos($filename, "?") + 1);
-			$filename = substr($filename, 0, strpos($filename, "?"));
-		}
+        if (!(strpos($filename, "?") === false)) {
+            $query = substr($filename, strpos($filename, "?") + 1);
+            $filename = substr($filename, 0, strpos($filename, "?"));
+        }
 
-		$timestamp = filemtime($filename);
+        $timestamp = filemtime($filename);
 
-		if ($query) {
-		    $timestamp .= "&$query";
-		}
+        if ($query) {
+            $timestamp .= "&$query";
+        }
 
-		return "<script type=\"text/javascript\" charset=\"utf-8\" src=\"$filename?$timestamp\"></script>\n";
-	}
+        return "<script type=\"text/javascript\" charset=\"utf-8\" src=\"$filename?$timestamp\"></script>\n";
+    }
 ?>
 <!DOCTYPE html>
 <html>
@@ -33,11 +33,11 @@ 
 		textarea { font-size : 12px; }
 	</style>
 	<?php
-		echo stylesheet_tag("../css/default.css");
-		echo javascript_tag("../lib/prototype.js");
-		echo javascript_tag("../lib/dojo/dojo.js");
-		echo javascript_tag("../lib/dojo/tt-rss-layer.js");
-	?>
+        echo stylesheet_tag("../css/default.css");
+        echo javascript_tag("../lib/prototype.js");
+        echo javascript_tag("../lib/dojo/dojo.js");
+        echo javascript_tag("../lib/dojo/tt-rss-layer.js");
+    ?>
 </head>
 <body class="flat ttrss_utility installer">
 
@@ -52,149 +52,149 @@ 
 
 <?php
 
-	// could be needed because of existing config.php
-	function define_default($param, $value) {
-		//
-	}
+    // could be needed because of existing config.php
+    function define_default($param, $value) {
+        //
+    }
 
-	function make_password($length = 12) {
-		$password = "";
-		$possible = "0123456789abcdfghjkmnpqrstvwxyzABCDFGHJKMNPQRSTVWXYZ*%+^";
+    function make_password($length = 12) {
+        $password = "";
+        $possible = "0123456789abcdfghjkmnpqrstvwxyzABCDFGHJKMNPQRSTVWXYZ*%+^";
 
-		$i = 0;
+        $i = 0;
 
-		while ($i < $length) {
+        while ($i < $length) {
 
-			try {
-				$idx = function_exists("random_int") ? random_int(0, strlen($possible) - 1) : mt_rand(0, strlen($possible) - 1);
-			} catch (Exception $e) {
-				$idx = mt_rand(0, strlen($possible) - 1);
-			}
+            try {
+                $idx = function_exists("random_int") ? random_int(0, strlen($possible) - 1) : mt_rand(0, strlen($possible) - 1);
+            } catch (Exception $e) {
+                $idx = mt_rand(0, strlen($possible) - 1);
+            }
 
-			$char = substr($possible, $idx, 1);
+            $char = substr($possible, $idx, 1);
 
-			if (!strstr($password, $char)) {
-				$password .= $char;
-				$i++;
-			}
-		}
+            if (!strstr($password, $char)) {
+                $password .= $char;
+                $i++;
+            }
+        }
 
-		return $password;
-	}
+        return $password;
+    }
 
 
-	function sanity_check($db_type) {
-		$errors = array();
+    function sanity_check($db_type) {
+        $errors = array();
 
-		if (version_compare(PHP_VERSION, '5.6.0', '<')) {
-			array_push($errors, "PHP version 5.6.0 or newer required. You're using ".PHP_VERSION.".");
-		}
+        if (version_compare(PHP_VERSION, '5.6.0', '<')) {
+            array_push($errors, "PHP version 5.6.0 or newer required. You're using ".PHP_VERSION.".");
+        }
 
-		if (!function_exists("curl_init") && !ini_get("allow_url_fopen")) {
-			array_push($errors, "PHP configuration option allow_url_fopen is disabled, and CURL functions are not present. Either enable allow_url_fopen or install PHP extension for CURL.");
-		}
+        if (!function_exists("curl_init") && !ini_get("allow_url_fopen")) {
+            array_push($errors, "PHP configuration option allow_url_fopen is disabled, and CURL functions are not present. Either enable allow_url_fopen or install PHP extension for CURL.");
+        }
 
-		if (!function_exists("json_encode")) {
-			array_push($errors, "PHP support for JSON is required, but was not found.");
-		}
+        if (!function_exists("json_encode")) {
+            array_push($errors, "PHP support for JSON is required, but was not found.");
+        }
 
-		if (!class_exists("PDO")) {
-			array_push($errors, "PHP support for PDO is required but was not found.");
-		}
+        if (!class_exists("PDO")) {
+            array_push($errors, "PHP support for PDO is required but was not found.");
+        }
 
-		if (!function_exists("mb_strlen")) {
-			array_push($errors, "PHP support for mbstring functions is required but was not found.");
-		}
+        if (!function_exists("mb_strlen")) {
+            array_push($errors, "PHP support for mbstring functions is required but was not found.");
+        }
 
-		if (!function_exists("hash")) {
-			array_push($errors, "PHP support for hash() function is required but was not found.");
-		}
+        if (!function_exists("hash")) {
+            array_push($errors, "PHP support for hash() function is required but was not found.");
+        }
 
-		if (!function_exists("iconv")) {
-			array_push($errors, "PHP support for iconv is required to handle multiple charsets.");
-		}
+        if (!function_exists("iconv")) {
+            array_push($errors, "PHP support for iconv is required to handle multiple charsets.");
+        }
 
-		if (ini_get("safe_mode")) {
-			array_push($errors, "PHP safe mode setting is obsolete and not supported by tt-rss.");
-		}
+        if (ini_get("safe_mode")) {
+            array_push($errors, "PHP safe mode setting is obsolete and not supported by tt-rss.");
+        }
 
-		if (!class_exists("DOMDocument")) {
-			array_push($errors, "PHP support for DOMDocument is required, but was not found.");
-		}
+        if (!class_exists("DOMDocument")) {
+            array_push($errors, "PHP support for DOMDocument is required, but was not found.");
+        }
 
-		return $errors;
-	}
+        return $errors;
+    }
 
-	function print_error($msg) {
-		print "<div class='alert alert-error'>$msg</div>";
-	}
+    function print_error($msg) {
+        print "<div class='alert alert-error'>$msg</div>";
+    }
 
-	function print_notice($msg) {
-		print "<div class=\"alert alert-info\">$msg</div>";
-	}
+    function print_notice($msg) {
+        print "<div class=\"alert alert-info\">$msg</div>";
+    }
 
-	function pdo_connect($host, $user, $pass, $db, $type, $port = false) {
+    function pdo_connect($host, $user, $pass, $db, $type, $port = false) {
 
-		$db_port = $port ? ';port='.$port : '';
-		$db_host = $host ? ';host='.$host : '';
+        $db_port = $port ? ';port='.$port : '';
+        $db_host = $host ? ';host='.$host : '';
 
-		try {
-			$pdo = new PDO($type.':dbname='.$db.$db_host.$db_port,
-				$user,
-				$pass);
+        try {
+            $pdo = new PDO($type.':dbname='.$db.$db_host.$db_port,
+                $user,
+                $pass);
 
-			return $pdo;
-		} catch (Exception $e) {
-		    print "<div class='alert alert-danger'>".$e->getMessage()."</div>";
-		    return null;
+            return $pdo;
+        } catch (Exception $e) {
+            print "<div class='alert alert-danger'>".$e->getMessage()."</div>";
+            return null;
         }
-	}
-
-	function make_config($DB_TYPE, $DB_HOST, $DB_USER, $DB_NAME, $DB_PASS,
-			$DB_PORT, $SELF_URL_PATH) {
-
-		$data = explode("\n", file_get_contents("../config.php-dist"));
-
-		$rv = "";
-
-		$finished = false;
-
-		foreach ($data as $line) {
-			if (preg_match("/define\('DB_TYPE'/", $line)) {
-				$rv .= "\tdefine('DB_TYPE', '$DB_TYPE');\n";
-			} else if (preg_match("/define\('DB_HOST'/", $line)) {
-				$rv .= "\tdefine('DB_HOST', '$DB_HOST');\n";
-			} else if (preg_match("/define\('DB_USER'/", $line)) {
-				$rv .= "\tdefine('DB_USER', '$DB_USER');\n";
-			} else if (preg_match("/define\('DB_NAME'/", $line)) {
-				$rv .= "\tdefine('DB_NAME', '$DB_NAME');\n";
-			} else if (preg_match("/define\('DB_PASS'/", $line)) {
-				$rv .= "\tdefine('DB_PASS', '$DB_PASS');\n";
-			} else if (preg_match("/define\('DB_PORT'/", $line)) {
-				$rv .= "\tdefine('DB_PORT', '$DB_PORT');\n";
-			} else if (preg_match("/define\('SELF_URL_PATH'/", $line)) {
-				$rv .= "\tdefine('SELF_URL_PATH', '$SELF_URL_PATH');\n";
-			} else if (!$finished) {
-				$rv .= "$line\n";
-			}
-
-			if (preg_match("/\?\>/", $line)) {
-				$finished = true;
-			}
-		}
-
-		return $rv;
-	}
-
-	function is_server_https() {
-		return (!empty($_SERVER['HTTPS']) && ($_SERVER['HTTPS'] != 'off')) || (!empty($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https');
-	}
-
-	function make_self_url_path() {
-		$url_path = (is_server_https() ? 'https://' : 'http://').$_SERVER["HTTP_HOST"].parse_url($_SERVER["REQUEST_URI"], PHP_URL_PATH);
-
-		return $url_path;
-	}
+    }
+
+    function make_config($DB_TYPE, $DB_HOST, $DB_USER, $DB_NAME, $DB_PASS,
+            $DB_PORT, $SELF_URL_PATH) {
+
+        $data = explode("\n", file_get_contents("../config.php-dist"));
+
+        $rv = "";
+
+        $finished = false;
+
+        foreach ($data as $line) {
+            if (preg_match("/define\('DB_TYPE'/", $line)) {
+                $rv .= "\tdefine('DB_TYPE', '$DB_TYPE');\n";
+            } else if (preg_match("/define\('DB_HOST'/", $line)) {
+                $rv .= "\tdefine('DB_HOST', '$DB_HOST');\n";
+            } else if (preg_match("/define\('DB_USER'/", $line)) {
+                $rv .= "\tdefine('DB_USER', '$DB_USER');\n";
+            } else if (preg_match("/define\('DB_NAME'/", $line)) {
+                $rv .= "\tdefine('DB_NAME', '$DB_NAME');\n";
+            } else if (preg_match("/define\('DB_PASS'/", $line)) {
+                $rv .= "\tdefine('DB_PASS', '$DB_PASS');\n";
+            } else if (preg_match("/define\('DB_PORT'/", $line)) {
+                $rv .= "\tdefine('DB_PORT', '$DB_PORT');\n";
+            } else if (preg_match("/define\('SELF_URL_PATH'/", $line)) {
+                $rv .= "\tdefine('SELF_URL_PATH', '$SELF_URL_PATH');\n";
+            } else if (!$finished) {
+                $rv .= "$line\n";
+            }
+
+            if (preg_match("/\?\>/", $line)) {
+                $finished = true;
+            }
+        }
+
+        return $rv;
+    }
+
+    function is_server_https() {
+        return (!empty($_SERVER['HTTPS']) && ($_SERVER['HTTPS'] != 'off')) || (!empty($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https');
+    }
+
+    function make_self_url_path() {
+        $url_path = (is_server_https() ? 'https://' : 'http://').$_SERVER["HTTP_HOST"].parse_url($_SERVER["REQUEST_URI"], PHP_URL_PATH);
+
+        return $url_path;
+    }
 
 ?>
 
@@ -204,32 +204,32 @@ 
 
 <?php
 
-	if (file_exists("../config.php")) {
-		require "../config.php";
+    if (file_exists("../config.php")) {
+        require "../config.php";
 
-		if (!defined('_INSTALLER_IGNORE_CONFIG_CHECK')) {
-			print_error("Error: config.php already exists in tt-rss directory; aborting.");
+        if (!defined('_INSTALLER_IGNORE_CONFIG_CHECK')) {
+            print_error("Error: config.php already exists in tt-rss directory; aborting.");
 
-			print "<form method='GET' action='../index.php'>
+            print "<form method='GET' action='../index.php'>
 				<button type='submit' dojoType='dijit.form.Button' class='alt-primary'>Return to Tiny Tiny RSS</button>
 				</form>";
-			exit;
-		}
-	}
-
-	@$op = $_REQUEST['op'];
-
-	@$DB_HOST = strip_tags($_POST['DB_HOST']);
-	@$DB_TYPE = strip_tags($_POST['DB_TYPE']);
-	@$DB_USER = strip_tags($_POST['DB_USER']);
-	@$DB_NAME = strip_tags($_POST['DB_NAME']);
-	@$DB_PASS = strip_tags($_POST['DB_PASS']);
-	@$DB_PORT = strip_tags($_POST['DB_PORT']);
-	@$SELF_URL_PATH = strip_tags($_POST['SELF_URL_PATH']);
-
-	if (!$SELF_URL_PATH) {
-		$SELF_URL_PATH = preg_replace("/\/install\/$/", "/", make_self_url_path());
-	}
+            exit;
+        }
+    }
+
+    @$op = $_REQUEST['op'];
+
+    @$DB_HOST = strip_tags($_POST['DB_HOST']);
+    @$DB_TYPE = strip_tags($_POST['DB_TYPE']);
+    @$DB_USER = strip_tags($_POST['DB_USER']);
+    @$DB_NAME = strip_tags($_POST['DB_NAME']);
+    @$DB_PASS = strip_tags($_POST['DB_PASS']);
+    @$DB_PORT = strip_tags($_POST['DB_PORT']);
+    @$SELF_URL_PATH = strip_tags($_POST['SELF_URL_PATH']);
+
+    if (!$SELF_URL_PATH) {
+        $SELF_URL_PATH = preg_replace("/\/install\/$/", "/", make_self_url_path());
+    }
 ?>
 
 <form action="" method="post">
@@ -238,9 +238,9 @@ 
 	<h2>Database settings</h2>
 
 	<?php
-		$issel_pgsql = $DB_TYPE == "pgsql" ? "selected='selected'" : "";
-		$issel_mysql = $DB_TYPE == "mysql" ? "selected='selected'" : "";
-	?>
+        $issel_pgsql = $DB_TYPE == "pgsql" ? "selected='selected'" : "";
+        $issel_mysql = $DB_TYPE == "mysql" ? "selected='selected'" : "";
+    ?>
 
 	<fieldset>
 		<label>Database type:</label>
@@ -294,87 +294,87 @@ 
 	<h2>Checking configuration</h2>
 
 	<?php
-		$errors = sanity_check($DB_TYPE);
+        $errors = sanity_check($DB_TYPE);
 
-		if (count($errors) > 0) {
-			print "<p>Some configuration tests failed. Please correct them before continuing.</p>";
+        if (count($errors) > 0) {
+            print "<p>Some configuration tests failed. Please correct them before continuing.</p>";
 
-			print "<ul>";
+            print "<ul>";
 
-			foreach ($errors as $error) {
-				print "<li style='color : red'>$error</li>";
-			}
+            foreach ($errors as $error) {
+                print "<li style='color : red'>$error</li>";
+            }
 
-			print "</ul>";
+            print "</ul>";
 
-			exit;
-		}
+            exit;
+        }
 
-		$notices = array();
+        $notices = array();
 
-		if (!function_exists("curl_init")) {
-			array_push($notices, "It is highly recommended to enable support for CURL in PHP.");
-		}
+        if (!function_exists("curl_init")) {
+            array_push($notices, "It is highly recommended to enable support for CURL in PHP.");
+        }
 
-		if (function_exists("curl_init") && ini_get("open_basedir")) {
-			array_push($notices, "CURL and open_basedir combination breaks support for HTTP redirects. See the FAQ for more information.");
-		}
+        if (function_exists("curl_init") && ini_get("open_basedir")) {
+            array_push($notices, "CURL and open_basedir combination breaks support for HTTP redirects. See the FAQ for more information.");
+        }
 
-		if (!function_exists("idn_to_ascii")) {
-			array_push($notices, "PHP support for Internationalization Functions is required to handle Internationalized Domain Names.");
-		}
+        if (!function_exists("idn_to_ascii")) {
+            array_push($notices, "PHP support for Internationalization Functions is required to handle Internationalized Domain Names.");
+        }
 
         if ($DB_TYPE == "mysql" && !function_exists("mysqli_connect")) {
             array_push($notices, "PHP extension for MySQL (mysqli) is missing. This may prevent legacy plugins from working.");
         }
 
         if ($DB_TYPE == "pgsql" && !function_exists("pg_connect")) {
-			array_push($notices, "PHP extension for PostgreSQL is missing. This may prevent legacy plugins from working.");
+            array_push($notices, "PHP extension for PostgreSQL is missing. This may prevent legacy plugins from working.");
         }
 
-		if (count($notices) > 0) {
-			print_notice("Configuration check succeeded with minor problems:");
+        if (count($notices) > 0) {
+            print_notice("Configuration check succeeded with minor problems:");
 
-			print "<ul>";
+            print "<ul>";
 
-			foreach ($notices as $notice) {
-				print "<li>$notice</li>";
-			}
+            foreach ($notices as $notice) {
+                print "<li>$notice</li>";
+            }
 
-			print "</ul>";
-		} else {
-			print_notice("Configuration check succeeded.");
-		}
+            print "</ul>";
+        } else {
+            print_notice("Configuration check succeeded.");
+        }
 
-	?>
+    ?>
 
 	<h2>Checking database</h2>
 
 	<?php
-		$pdo = pdo_connect($DB_HOST, $DB_USER, $DB_PASS, $DB_NAME, $DB_TYPE, $DB_PORT);
+        $pdo = pdo_connect($DB_HOST, $DB_USER, $DB_PASS, $DB_NAME, $DB_TYPE, $DB_PORT);
 
-		if (!$pdo) {
-			print_error("Unable to connect to database using specified parameters (driver: $DB_TYPE).");
-			exit;
-		}
+        if (!$pdo) {
+            print_error("Unable to connect to database using specified parameters (driver: $DB_TYPE).");
+            exit;
+        }
 
-		print_notice("Database test succeeded.");
-	?>
+        print_notice("Database test succeeded.");
+    ?>
 
 	<h2>Initialize database</h2>
 
 	<p>Before you can start using tt-rss, database needs to be initialized. Click on the button below to do that now.</p>
 
 	<?php
-		$res = $pdo->query("SELECT true FROM ttrss_feeds");
+        $res = $pdo->query("SELECT true FROM ttrss_feeds");
 
-		if ($res && $res->fetch()) {
-			print_error("Some tt-rss data already exists in this database. If you continue with database initialization your current data <b>WILL BE LOST</b>.");
-			$need_confirm = true;
-		} else {
-			$need_confirm = false;
-		}
-	?>
+        if ($res && $res->fetch()) {
+            print_error("Some tt-rss data already exists in this database. If you continue with database initialization your current data <b>WILL BE LOST</b>.");
+            $need_confirm = true;
+        } else {
+            $need_confirm = false;
+        }
+    ?>
 
 	<table><tr><td>
 	<form method="post">
@@ -417,44 +417,44 @@ 
 
 	<?php
 
-		} else if ($op == 'installschema' || $op == 'skipschema') {
+        } else if ($op == 'installschema' || $op == 'skipschema') {
 
-			$pdo = pdo_connect($DB_HOST, $DB_USER, $DB_PASS, $DB_NAME, $DB_TYPE, $DB_PORT);
+            $pdo = pdo_connect($DB_HOST, $DB_USER, $DB_PASS, $DB_NAME, $DB_TYPE, $DB_PORT);
 
-			if (!$pdo) {
-				print_error("Unable to connect to database using specified parameters.");
-				exit;
-			}
+            if (!$pdo) {
+                print_error("Unable to connect to database using specified parameters.");
+                exit;
+            }
 
-			if ($op == 'installschema') {
+            if ($op == 'installschema') {
 
-				print "<h2>Initializing database...</h2>";
+                print "<h2>Initializing database...</h2>";
 
-				$lines = explode(";", preg_replace("/[\r\n]/", "",
+                $lines = explode(";", preg_replace("/[\r\n]/", "",
                     file_get_contents("../schema/ttrss_schema_".basename($DB_TYPE).".sql")));
 
-				foreach ($lines as $line) {
-					if (strpos($line, "--") !== 0 && $line) {
-						$res = $pdo->query($line);
+                foreach ($lines as $line) {
+                    if (strpos($line, "--") !== 0 && $line) {
+                        $res = $pdo->query($line);
 
-						if (!$res) {
-							print_notice("Query: $line");
-							print_error("Error: ".implode(", ", $pdo->errorInfo()));
+                        if (!$res) {
+                            print_notice("Query: $line");
+                            print_error("Error: ".implode(", ", $pdo->errorInfo()));
                         }
-					}
-				}
+                    }
+                }
 
-				print_notice("Database initialization completed.");
+                print_notice("Database initialization completed.");
 
-			} else {
-				print_notice("Database initialization skipped.");
-			}
+            } else {
+                print_notice("Database initialization skipped.");
+            }
 
-			print "<h2>Generated configuration file</h2>";
+            print "<h2>Generated configuration file</h2>";
 
-			print "<p>Copy following text and save as <code>config.php</code> in tt-rss main directory. It is suggested to read through the file to the end in case you need any options changed fom default values.</p>";
+            print "<p>Copy following text and save as <code>config.php</code> in tt-rss main directory. It is suggested to read through the file to the end in case you need any options changed fom default values.</p>";
 
-			print "<p>After copying the file, you will be able to login with default username and password combination: <code>admin</code> and <code>password</code>. Don't forget to change the password immediately!</p>"; ?>
+            print "<p>After copying the file, you will be able to login with default username and password combination: <code>admin</code> and <code>password</code>. Don't forget to change the password immediately!</p>"; ?>
 
 			<form action="" method="post">
 				<input type="hidden" name="op" value="saveconfig">
@@ -466,9 +466,9 @@ 
 				<input type="hidden" name="DB_TYPE" value="<?php echo $DB_TYPE ?>"/>
 				<input type="hidden" name="SELF_URL_PATH" value="<?php echo $SELF_URL_PATH ?>"/>
 			<?php print "<textarea rows='20' style='width : 100%'>";
-			echo make_config($DB_TYPE, $DB_HOST, $DB_USER, $DB_NAME, $DB_PASS,
-				$DB_PORT, $SELF_URL_PATH);
-			print "</textarea>"; ?>
+            echo make_config($DB_TYPE, $DB_HOST, $DB_USER, $DB_NAME, $DB_PASS,
+                $DB_PORT, $SELF_URL_PATH);
+            print "</textarea>"; ?>
 
 			<hr/>
 
@@ -478,40 +478,40 @@ 
 				<p><button type="submit" dojoType='dijit.form.Button' class='alt-primary'>Save configuration</button></p>
 				</form>
 			<?php } else {
-				print_error("Unfortunately, parent directory is not writable, so we're unable to save config.php automatically.");
-			}
+                print_error("Unfortunately, parent directory is not writable, so we're unable to save config.php automatically.");
+            }
 
-		   print_notice("You can generate the file again by changing the form above.");
+            print_notice("You can generate the file again by changing the form above.");
 
-		} else if ($op == "saveconfig") {
+        } else if ($op == "saveconfig") {
 
-			print "<h2>Saving configuration file to parent directory...</h2>";
+            print "<h2>Saving configuration file to parent directory...</h2>";
 
-			if (!file_exists("../config.php")) {
+            if (!file_exists("../config.php")) {
 
-				$fp = fopen("../config.php", "w");
+                $fp = fopen("../config.php", "w");
 
-				if ($fp) {
-					$written = fwrite($fp, make_config($DB_TYPE, $DB_HOST,
-						$DB_USER, $DB_NAME, $DB_PASS,
-						$DB_PORT, $SELF_URL_PATH));
+                if ($fp) {
+                    $written = fwrite($fp, make_config($DB_TYPE, $DB_HOST,
+                        $DB_USER, $DB_NAME, $DB_PASS,
+                        $DB_PORT, $SELF_URL_PATH));
 
-					if ($written > 0) {
-						print_notice("Successfully saved config.php. You can try <a href=\"..\">loading tt-rss now</a>.");
+                    if ($written > 0) {
+                        print_notice("Successfully saved config.php. You can try <a href=\"..\">loading tt-rss now</a>.");
 
-					} else {
-						print_notice("Unable to write into config.php in tt-rss directory.");
-					}
+                    } else {
+                        print_notice("Unable to write into config.php in tt-rss directory.");
+                    }
 
-					fclose($fp);
-				} else {
-					print_error("Unable to open config.php in tt-rss directory for writing.");
-				}
-			} else {
-				print_error("config.php already present in tt-rss directory, refusing to overwrite.");
-			}
-		}
-	?>
+                    fclose($fp);
+                } else {
+                    print_error("Unable to open config.php in tt-rss directory for writing.");
+                }
+            } else {
+                print_error("config.php already present in tt-rss directory, refusing to overwrite.");
+            }
+        }
+    ?>
 
 </div>
 

opml.php

Indentation +26 added lines, -26 removed lines

@@ -1,37 +1,37 @@
 <?php
-	set_include_path(dirname(__FILE__)."/include".PATH_SEPARATOR.
-		get_include_path());
+    set_include_path(dirname(__FILE__)."/include".PATH_SEPARATOR.
+        get_include_path());
 
-	require_once "autoload.php";
-	require_once "functions.php";
-	require_once "sessions.php";
-	require_once "sanity_check.php";
-	require_once "config.php";
-	require_once "db.php";
-	require_once "db-prefs.php";
+    require_once "autoload.php";
+    require_once "functions.php";
+    require_once "sessions.php";
+    require_once "sanity_check.php";
+    require_once "config.php";
+    require_once "db.php";
+    require_once "db-prefs.php";
 
-	if (!init_plugins()) {
-	    return;
-	}
+    if (!init_plugins()) {
+        return;
+    }
 
-	$op = $_REQUEST['op'];
+    $op = $_REQUEST['op'];
 
-	if ($op == "publish") {
-		$key = $_REQUEST["key"];
-		$pdo = Db::pdo();
+    if ($op == "publish") {
+        $key = $_REQUEST["key"];
+        $pdo = Db::pdo();
 
-		$sth = $pdo->prepare("SELECT owner_uid
+        $sth = $pdo->prepare("SELECT owner_uid
 				FROM ttrss_access_keys WHERE
 				access_key = ? AND feed_id = 'OPML:Publish'");
-		$sth->execute([$key]);
+        $sth->execute([$key]);
 
-		if ($row = $sth->fetch()) {
-			$owner_uid = $row['owner_uid'];
+        if ($row = $sth->fetch()) {
+            $owner_uid = $row['owner_uid'];
 
-			$opml = new Opml($_REQUEST);
-			$opml->opml_export("", $owner_uid, true, false);
+            $opml = new Opml($_REQUEST);
+            $opml->opml_export("", $owner_uid, true, false);
 
-		} else {
-			print "<error>User not found</error>";
-		}
-	}
+        } else {
+            print "<error>User not found</error>";
+        }
+    }

include/colors.php

Braces +19 added lines, -15 removed lines

@@ -262,12 +262,20 @@ 
         $del_G = ((($var_Max - $var_G) / 6) + ($del_Max / 2)) / $del_Max;
         $del_B = ((($var_Max - $var_B) / 6) + ($del_Max / 2)) / $del_Max;
 
-        if ($var_R == $var_Max) $h = $del_B - $del_G;
-        else if ($var_G == $var_Max) $h = (1 / 3) + $del_R - $del_B;
-        else if ($var_B == $var_Max) $h = (2 / 3) + $del_G - $del_R;
+        if ($var_R == $var_Max) {
+            $h = $del_B - $del_G;
+        } else if ($var_G == $var_Max) {
+            $h = (1 / 3) + $del_R - $del_B;
+        } else if ($var_B == $var_Max) {
+            $h = (2 / 3) + $del_G - $del_R;
+        }
 
-        if ($h < 0) $h++;
-        if ($h > 1) $h--;
+        if ($h < 0) {
+            $h++;
+        }
+        if ($h > 1) {
+            $h--;
+        }
     }
 
     return array($h, $s, $v);
@@ -287,12 +295,7 @@ 
         $var_2 = $v * (1 - $s * ($var_H - $var_i));
         $var_3 = $v * (1 - $s * (1 - ($var_H - $var_i)));
 
-        if ($var_i == 0) { $var_R = $v; $var_G = $var_3; $var_B = $var_1; }
-        else if ($var_i == 1) { $var_R = $var_2; $var_G = $v; $var_B = $var_1; }
-        else if ($var_i == 2) { $var_R = $var_1; $var_G = $v; $var_B = $var_3; }
-        else if ($var_i == 3) { $var_R = $var_1; $var_G = $var_2; $var_B = $v; }
-        else if ($var_i == 4) { $var_R = $var_3; $var_G = $var_1; $var_B = $v; }
-        else { $var_R = $v; $var_G = $var_1; $var_B = $var_2; }
+        if ($var_i == 0) { $var_R = $v; $var_G = $var_3; $var_B = $var_1; } else if ($var_i == 1) { $var_R = $var_2; $var_G = $v; $var_B = $var_1; } else if ($var_i == 2) { $var_R = $var_1; $var_G = $v; $var_B = $var_3; } else if ($var_i == 3) { $var_R = $var_1; $var_G = $var_2; $var_B = $v; } else if ($var_i == 4) { $var_R = $var_3; $var_G = $var_1; $var_B = $v; } else { $var_R = $v; $var_G = $var_1; $var_B = $var_2; }
 
         $r = $var_R * 255;
         $g = $var_G * 255;
@@ -315,10 +318,11 @@ 
             $ico = new floIcon();
             @$ico->readICO($imageFile);
 
-            if (count($ico->images) == 0)
-                return false;
-            else
-                $img = @$ico->images[count($ico->images) - 1]->getImageResource();
+            if (count($ico->images) == 0) {
+                            return false;
+            } else {
+                            $img = @$ico->images[count($ico->images) - 1]->getImageResource();
+            }
 
         } else {
             return false;