mirrors/invidious
1
0
Fork 0
mirror of https://github.com/iv-org/invidious.git synced 2025-08-13 16:18:29 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fix channel refresh job

Browse Source
This commit is contained in:
syeopite 2021-04-06 02:23:02 -07:00
parent 9188d7c52b
commit 84cc2dfe48
No known key found for this signature in database
GPG Key ID: 6FA616E5A5294A82
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/invidious/channels.cr
View File

@ -283,6 +283,10 @@ def fetch_channel(ucid, db, pull_all_videos = true, locale = nil)
views: views,
})
# I don't understand enough about the database to do anything. Thus:
reduced_video_list = {video_id, title, published, Time.utc, ucid, author,
length_seconds, live_now, premiere_timestamp, views}
LOGGER.trace("fetch_channel: #{ucid} : video #{video_id} : Updating or inserting video")
# We don't include the 'premiere_timestamp' here because channel pages don't include them,
@ -290,7 +294,7 @@ def fetch_channel(ucid, db, pull_all_videos = true, locale = nil)
was_insert = db.query_one("INSERT INTO channel_videos VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) \
ON CONFLICT (id) DO UPDATE SET title = $2, published = $3, \
updated = $4, ucid = $5, author = $6, length_seconds = $7, \
live_now = $8, views = $10 returning (xmax=0) as was_insert", *video.to_tuple, as: Bool)
live_now = $8, views = $10 returning (xmax=0) as was_insert", *reduced_video_list, as: Bool)
if was_insert
LOGGER.trace("fetch_channel: #{ucid} : video #{video_id} : Inserted, updating subscriptions")