feeds/_add_cat: use ORM

1 files changed, 15 insertions, 28 deletions

diff --git a/classes/feeds.php b/classes/feeds.php
index 6f8ceeced..c67edbc51 100755
--- a/classes/feeds.php
+++ b/classes/feeds.php
@@ -1909,40 +1909,27 @@ class Feeds extends Handler_Protected {
 			$cat->delete();
 	}
 
-	static function _add_cat($feed_cat, $parent_cat_id = false, $order_id = 0) {
+	static function _add_cat(string $title, int $owner_uid, int $parent_cat = null, int $order_id = 0) {
 
-		if (!$feed_cat) return false;
-
-		$feed_cat = mb_substr($feed_cat, 0, 250);
-		if (!$parent_cat_id) $parent_cat_id = null;
-
-		$pdo = Db::pdo();
-		$tr_in_progress = false;
-
-		try {
-			$pdo->beginTransaction();
-		} catch (Exception $e) {
-			$tr_in_progress = true;
-		}
-
-		$sth = $pdo->prepare("SELECT id FROM ttrss_feed_categories
-				WHERE (parent_cat = :parent OR (:parent IS NULL AND parent_cat IS NULL))
-				AND title = :title AND owner_uid = :uid");
-		$sth->execute([':parent' => $parent_cat_id, ':title' => $feed_cat, ':uid' => $_SESSION['uid']]);
-
-		if (!$sth->fetch()) {
+		$cat = ORM::for_table('ttrss_feed_categories')
+			->where('owner_uid', $owner_uid)
+			->where('parent_cat', $parent_cat)
+			->where('title', $title)
+			->find_one();
 
-			$sth = $pdo->prepare("INSERT INTO ttrss_feed_categories (owner_uid,title,parent_cat,order_id)
-					VALUES (?, ?, ?, ?)");
-			$sth->execute([$_SESSION['uid'], $feed_cat, $parent_cat_id, (int)$order_id]);
+		if (!$cat) {
+			$cat = ORM::for_table('ttrss_feed_categories')->create();
 
-			if (!$tr_in_progress) $pdo->commit();
+			$cat->set([
+				'owner_uid' => $owner_uid,
+				'parent_cat' => $parent_cat,
+				'order_id' => $order_id,
+				'title' => $title,
+			]);
 
-			return true;
+			return $cat->save();
 		}
 
-		$pdo->commit();
-
 		return false;
 	}