Article::create_published_article()

Complexity

Conditions	18
Paths	208

Size

Total Lines	138
Code Lines	70

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public static function create_published_article($title, $url, $content, $labels_str,
            $owner_uid) {

        $guid = 'SHA1:'.sha1("ttshared:".$url.$owner_uid); // include owner_uid to prevent global GUID clash

        if (!$content) {
            $pluginhost = new PluginHost();
            $pluginhost->load_all(PluginHost::KIND_ALL, $owner_uid);
            $pluginhost->load_data();

            foreach ($pluginhost->get_hooks(PluginHost::HOOK_GET_FULL_TEXT) as $p) {
                $extracted_content = $p->hook_get_full_text($url);

                if ($extracted_content) {
                    $content = $extracted_content;
                    break;
                }
            }
        }

        $content_hash = sha1($content);

        if ($labels_str != "") {
            $labels = explode(",", $labels_str);
        } else {
            $labels = array();
        }

        $rc = false;

        if (!$title) {
            $title = $url;
        }
        if (!$title && !$url) {
            return false;
        }

        if (filter_var($url, FILTER_VALIDATE_URL) === false) {
            return false;
        }

        $pdo = Db::pdo();

        $pdo->beginTransaction();

        // only check for our user data here, others might have shared this with different content etc
        $sth = $pdo->prepare("SELECT id FROM ttrss_entries, ttrss_user_entries WHERE
			guid = ? AND ref_id = id AND owner_uid = ? LIMIT 1");
        $sth->execute([$guid, $owner_uid]);

        if ($row = $sth->fetch()) {
            $ref_id = $row['id'];

            $sth = $pdo->prepare("SELECT int_id FROM ttrss_user_entries WHERE
				ref_id = ? AND owner_uid = ? LIMIT 1");
            $sth->execute([$ref_id, $owner_uid]);

            if ($row = $sth->fetch()) {
                $int_id = $row['int_id'];

                $sth = $pdo->prepare("UPDATE ttrss_entries SET
					content = ?, content_hash = ? WHERE id = ?");
                $sth->execute([$content, $content_hash, $ref_id]);

                if (DB_TYPE == "pgsql") {

The constant DB_TYPE was not found. Maybe you did not declare it correctly or list all dependencies?

                    $sth = $pdo->prepare("UPDATE ttrss_entries
					SET tsvector_combined = to_tsvector( :ts_content)
					WHERE id = :id");
                    $params = [
                        ":ts_content" => mb_substr(strip_tags($content), 0, 900000),
                        ":id" => $ref_id];
                    $sth->execute($params);
                }

                $sth = $pdo->prepare("UPDATE ttrss_user_entries SET published = true,
						last_published = NOW() WHERE
						int_id = ? AND owner_uid = ?");
                $sth->execute([$int_id, $owner_uid]);

            } else {

                $sth = $pdo->prepare("INSERT INTO ttrss_user_entries
					(ref_id, uuid, feed_id, orig_feed_id, owner_uid, published, tag_cache, label_cache,
						last_read, note, unread, last_published)
					VALUES
					(?, '', NULL, NULL, ?, true, '', '', NOW(), '', false, NOW())");
                $sth->execute([$ref_id, $owner_uid]);
            }

            if (count($labels) != 0) {
                foreach ($labels as $label) {
                    Labels::add_article($ref_id, trim($label), $owner_uid);
                }
            }

            $rc = true;

        } else {
            $sth = $pdo->prepare("INSERT INTO ttrss_entries
				(title, guid, link, updated, content, content_hash, date_entered, date_updated)
				VALUES
				(?, ?, ?, NOW(), ?, ?, NOW(), NOW())");
            $sth->execute([$title, $guid, $url, $content, $content_hash]);

            $sth = $pdo->prepare("SELECT id FROM ttrss_entries WHERE guid = ?");
            $sth->execute([$guid]);

            if ($row = $sth->fetch()) {
                $ref_id = $row["id"];
                if (DB_TYPE == "pgsql") {
                    $sth = $pdo->prepare("UPDATE ttrss_entries
					SET tsvector_combined = to_tsvector( :ts_content)
					WHERE id = :id");
                    $params = [
                        ":ts_content" => mb_substr(strip_tags($content), 0, 900000),
                        ":id" => $ref_id];
                    $sth->execute($params);
                }
                $sth = $pdo->prepare("INSERT INTO ttrss_user_entries
					(ref_id, uuid, feed_id, orig_feed_id, owner_uid, published, tag_cache, label_cache,
						last_read, note, unread, last_published)
					VALUES
					(?, '', NULL, NULL, ?, true, '', '', NOW(), '', false, NOW())");
                $sth->execute([$ref_id, $owner_uid]);

                if (count($labels) != 0) {
                    foreach ($labels as $label) {
                        Labels::add_article($ref_id, trim($label), $owner_uid);
                    }
                }

                $rc = true;
            }
        }

        $pdo->commit();

        return $rc;
    }