From 865ecc87963dc3b26e66296616eef2a1cc41ac3f Mon Sep 17 00:00:00 2001 From: Andrew Dolgov Date: Wed, 25 Oct 2023 12:55:09 +0300 Subject: move to psr-4 autoloader --- classes/digest.php | 209 ----------------------------------------------------- 1 file changed, 209 deletions(-) delete mode 100644 classes/digest.php (limited to 'classes/digest.php') diff --git a/classes/digest.php b/classes/digest.php deleted file mode 100644 index 27009530f..000000000 --- a/classes/digest.php +++ /dev/null @@ -1,209 +0,0 @@ -query("SELECT id,email FROM ttrss_users - WHERE email != '' AND (last_digest_sent IS NULL OR $interval_qpart)"); - - while ($line = $res->fetch()) { - - if (get_pref(Prefs::DIGEST_ENABLE, $line['id'])) { - $preferred_ts = strtotime(get_pref(Prefs::DIGEST_PREFERRED_TIME, $line['id']) ?? ''); - - // 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"]); - - $do_catchup = get_pref(Prefs::DIGEST_CATCHUP, $line['id']); - - global $tz_offset; - - // 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]; - - if ($headlines_count > 0) { - - $mailer = new Mailer(); - - //$rc = $mail->quickMail($line["email"], $line["login"], Config::get(Config::DIGEST_SUBJECT), $digest, $digest_text); - - $rc = $mailer->mail(["to_name" => $line["login"], - "to_address" => $line["email"], - "subject" => Config::get(Config::DIGEST_SUBJECT), - "message" => $digest_text, - "message_html" => $digest]); - - //if (!$rc && $debug) Debug::log("ERROR: " . $mailer->lastError()); - - Debug::log("RC=$rc"); - - if ($rc && $do_catchup) { - Debug::log("Marking affected articles as read..."); - Article::_catchup_by_id($affected_ids, Article::CATCHUP_MODE_MARK_AS_READ, $line["id"]); - } - } else { - Debug::log("No headlines"); - } - - $sth = $pdo->prepare("UPDATE ttrss_users SET last_digest_sent = NOW() - WHERE id = ?"); - $sth->execute([$line["id"]]); - - } - } - } - - $span->end(); - Debug::log("All done."); - } - - /** - * @return array{0: string, 1: int, 2: array, 3: string} - */ - static function prepare_headlines_digest(int $user_id, int $days = 1, int $limit = 1000) { - - $tpl = new Templator(); - $tpl_t = new Templator(); - - $tpl->readTemplateFromFile("digest_template_html.txt"); - $tpl_t->readTemplateFromFile("digest_template.txt"); - - $user_tz_string = get_pref(Prefs::USER_TIMEZONE, $user_id); - - if ($user_tz_string == 'Automatic') - $user_tz_string = 'GMT'; - - $local_ts = TimeHelper::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', Config::get_self_url()); - - $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', Config::get_self_url()); - - $affected_ids = array(); - - if (Config::get(Config::DB_TYPE) == "pgsql") { - $interval_qpart = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'"; - } else /* if (Config::get(Config::DB_TYPE) == "mysql") */ { - $interval_qpart = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)"; - } - - $pdo = Db::pdo(); - - $sth = $pdo->prepare("SELECT ttrss_entries.title, - ttrss_feeds.title AS feed_title, - COALESCE(ttrss_feed_categories.title, '" . __('Uncategorized') . "') AS cat_title, - date_updated, - ttrss_user_entries.ref_id, - link, - score, - content, - ".SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated - FROM - ttrss_user_entries,ttrss_entries,ttrss_feeds - LEFT JOIN - ttrss_feed_categories ON (cat_id = ttrss_feed_categories.id) - WHERE - ref_id = ttrss_entries.id AND feed_id = ttrss_feeds.id - AND include_in_digest = true - AND $interval_qpart - AND ttrss_user_entries.owner_uid = :user_id - AND unread = true - AND score >= 0 - ORDER BY ttrss_feed_categories.title, ttrss_feeds.title, score DESC, date_updated DESC - LIMIT " . (int)$limit); - $sth->execute([':user_id' => $user_id]); - - $headlines_count = 0; - $headlines = array(); - - while ($line = $sth->fetch()) { - array_push($headlines, $line); - $headlines_count++; - } - - for ($i = 0; $i < sizeof($headlines); $i++) { - - $line = $headlines[$i]; - - array_push($affected_ids, $line["ref_id"]); - - $updated = TimeHelper::make_local_datetime($line['last_updated'], false, - $user_id); - - if (get_pref(Prefs::ENABLE_FEED_CATS, $user_id)) { - $line['feed_title'] = $line['cat_title'] . " / " . $line['feed_title']; - } - - $article_labels = Article::_get_labels($line["ref_id"], $user_id); - $article_labels_formatted = ""; - - if (is_array($article_labels) && count($article_labels) > 0) { - $article_labels_formatted = implode(", ", array_map(fn($a) => $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('ARTICLE_CONTENT', -// strip_tags($article_content)); - $tpl->setVariable('ARTICLE_LABELS', $article_labels_formatted, true); - - $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->addBlock('article'); - - if ($headlines[$i]['feed_title'] != $headlines[$i + 1]['feed_title']) { - $tpl->addBlock('feed'); - $tpl_t->addBlock('feed'); - } - - } - - $tpl->addBlock('digest'); - $tpl->generateOutputToString($tmp); - - $tpl_t->addBlock('digest'); - $tpl_t->generateOutputToString($tmp_t); - - return array($tmp, $headlines_count, $affected_ids, $tmp_t); - } -} -- cgit v1.2.3