X-Git-Url: https://git.wh0rd.org/?a=blobdiff_plain;f=classes%2Fdigest.php;h=a61b6dfcaf75256fc6d278d9cede40c2a299937b;hb=50052fb78a3a9d1bb3fa488e7fd7b23125c38124;hp=75dda4984855884501c201ad8751555d15bdd970;hpb=09be7cdd73b20b5449678f352a2d710d4767e6b1;p=tt-rss.git diff --git a/classes/digest.php b/classes/digest.php index 75dda498..a61b6dfc 100644 --- a/classes/digest.php +++ b/classes/digest.php @@ -9,14 +9,12 @@ class Digest * @param integer $limit The maximum number of articles by digest. * @return boolean Return false if digests are not enabled. */ - static function send_headlines_digests($debug = false) { - - require_once 'classes/ttrssmailer.php'; + 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 - if ($debug) _debug("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'"; @@ -39,7 +37,7 @@ class Digest time() - $preferred_ts <= 7200 ) { - if ($debug) _debug("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); @@ -56,20 +54,26 @@ class Digest if ($headlines_count > 0) { - $mail = new ttrssMailer(); + $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]); - if (!$rc && $debug) _debug("ERROR: " . $mail->ErrorInfo); + //if (!$rc && $debug) Debug::log("ERROR: " . $mailer->lastError()); - if ($debug) _debug("RC=$rc"); + Debug::log("RC=$rc"); if ($rc && $do_catchup) { - if ($debug) _debug("Marking affected articles as read..."); + Debug::log("Marking affected articles as read..."); Article::catchupArticlesById($affected_ids, 0, $line["id"]); } } else { - if ($debug) _debug("No headlines"); + Debug::log("No headlines"); } $sth = $pdo->prepare("UPDATE ttrss_users SET last_digest_sent = NOW() @@ -80,7 +84,7 @@ class Digest } } - if ($debug) _debug("All done."); + Debug::log("All done."); } @@ -198,4 +202,4 @@ class Digest return array($tmp, $headlines_count, $affected_ids, $tmp_t); } -} \ No newline at end of file +}