From a7e0a1f7de82bc8f0919c2ea61258a3ae09e4eba Mon Sep 17 00:00:00 2001 From: Michael Date: Mon, 30 Nov 2020 06:19:10 +0000 Subject: [PATCH] The maximum delay should be a day --- src/Protocol/Feed.php | 101 +++++++++++++++++++++--------------------- 1 file changed, 51 insertions(+), 50 deletions(-) diff --git a/src/Protocol/Feed.php b/src/Protocol/Feed.php index 6b46d7ac07..ed3598e641 100644 --- a/src/Protocol/Feed.php +++ b/src/Protocol/Feed.php @@ -107,55 +107,6 @@ class Feed } } - /** - * Get the poll interval for the given contact array - * - * @param array $contact - * @return int Poll interval in minutes - */ - public static function getPollInterval(array $contact) - { - if (in_array($contact['network'], [Protocol::MAIL, Protocol::FEED])) { - $ratings = [0, 3, 7, 8, 9, 10]; - if (DI::config()->get('system', 'adjust_poll_frequency') && ($contact['network'] == Protocol::FEED)) { - $rating = $contact['rating']; - } elseif (array_key_exists($contact['priority'], $ratings)) { - $rating = $ratings[$contact['priority']]; - } else { - $rating = -1; - } - } else { - // Check once a week per default for all other networks - $rating = 9; - } - - // Friendica and OStatus are checked once a day - if (in_array($contact['network'], [Protocol::DFRN, Protocol::OSTATUS])) { - $rating = 8; - } - - // Check archived contacts or contacts with unsupported protocols once a month - if ($contact['archive'] || in_array($contact['network'], [Protocol::ZOT, Protocol::PHANTOM])) { - $rating = 10; - } - - if ($rating < 0) { - return 0; - } - /* - * Based on $contact['priority'], should we poll this site now? Or later? - */ - - $min_poll_interval = max(1, DI::config()->get('system', 'min_poll_interval')); - - $poll_intervals = [$min_poll_interval, 15, 30, 60, 120, 180, 360, 720 ,1440, 10080, 43200]; - - //$poll_intervals = [$min_poll_interval . ' minute', '15 minute', '30 minute', - // '1 hour', '2 hour', '3 hour', '6 hour', '12 hour' ,'1 day', '1 week', '1 month']; - - return $poll_intervals[$rating]; - } - /** * Read a RSS/RDF/Atom feed and create an item entry for it * @@ -666,7 +617,8 @@ class Feed if (!empty($postings)) { $total = count($postings); if ($total > 1) { - $interval = self::getPollInterval($contact); + // Posts shouldn't be delayed more than a day + $interval = max(1440, self::getPollInterval($contact)); $delay = round(($interval * 60) / $total); Logger::notice('Got posting delay', ['delay' => $delay, 'interval' => $interval, 'items' => $total, 'cid' => $contact['id'], 'url' => $contact['url']]); } else { @@ -823,6 +775,55 @@ class Feed } } + /** + * Get the poll interval for the given contact array + * + * @param array $contact + * @return int Poll interval in minutes + */ + public static function getPollInterval(array $contact) + { + if (in_array($contact['network'], [Protocol::MAIL, Protocol::FEED])) { + $ratings = [0, 3, 7, 8, 9, 10]; + if (DI::config()->get('system', 'adjust_poll_frequency') && ($contact['network'] == Protocol::FEED)) { + $rating = $contact['rating']; + } elseif (array_key_exists($contact['priority'], $ratings)) { + $rating = $ratings[$contact['priority']]; + } else { + $rating = -1; + } + } else { + // Check once a week per default for all other networks + $rating = 9; + } + + // Friendica and OStatus are checked once a day + if (in_array($contact['network'], [Protocol::DFRN, Protocol::OSTATUS])) { + $rating = 8; + } + + // Check archived contacts or contacts with unsupported protocols once a month + if ($contact['archive'] || in_array($contact['network'], [Protocol::ZOT, Protocol::PHANTOM])) { + $rating = 10; + } + + if ($rating < 0) { + return 0; + } + /* + * Based on $contact['priority'], should we poll this site now? Or later? + */ + + $min_poll_interval = max(1, DI::config()->get('system', 'min_poll_interval')); + + $poll_intervals = [$min_poll_interval, 15, 30, 60, 120, 180, 360, 720 ,1440, 10080, 43200]; + + //$poll_intervals = [$min_poll_interval . ' minute', '15 minute', '30 minute', + // '1 hour', '2 hour', '3 hour', '6 hour', '12 hour' ,'1 day', '1 week', '1 month']; + + return $poll_intervals[$rating]; + } + /** * Convert a tag array to a tag string *