summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorOmar Roth <omarroth@hotmail.com>2019-03-29 10:03:13 -0500
committerOmar Roth <omarroth@hotmail.com>2019-03-29 10:03:13 -0500
commit0ae43e242fb6284d66f3e18249560cdcea225ef5 (patch)
treece624de0fa3da4222d429574738f41c45d270dd5 /src
parentbafd4f18601c4f112382571defa707e7b5448307 (diff)
downloadinvidious-0ae43e242fb6284d66f3e18249560cdcea225ef5.tar.gz
invidious-0ae43e242fb6284d66f3e18249560cdcea225ef5.tar.bz2
invidious-0ae43e242fb6284d66f3e18249560cdcea225ef5.zip
Fix pubsub job for newly added channels
Diffstat (limited to 'src')
-rw-r--r--src/invidious/jobs.cr2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/invidious/jobs.cr b/src/invidious/jobs.cr
index 54749f87..a217c1af 100644
--- a/src/invidious/jobs.cr
+++ b/src/invidious/jobs.cr
@@ -106,7 +106,7 @@ def subscribe_to_feeds(db, logger, key, config)
if config.use_pubsub_feeds
spawn do
loop do
- db.query_all("SELECT id FROM channels WHERE CURRENT_TIMESTAMP - subscribed > '4 days'") do |rs|
+ db.query_all("SELECT id FROM channels WHERE CURRENT_TIMESTAMP - subscribed > '4 days' OR subscribed IS NULL") do |rs|
rs.each do
ucid = rs.read(String)
response = subscribe_pubsub(ucid, key, config)