VeritableValor/invidious
1
0
Fork 0
mirror of https://github.com/iv-org/invidious.git synced 2026-08-17 13:30:53 -05:00
Code Issues Packages Projects Releases Wiki Activity

Preserve channel video publication times

Browse Source
This commit is contained in:
leeweisa3-maker 2026-08-12 23:19:22 +08:00
parent fc52b5fd8b
commit 867f4fce82
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/invidious/channels/channels.cr
View File

@ -192,7 +192,9 @@ def fetch_channel(ucid, pull_all_videos : Bool)
# We don't include the 'premiere_timestamp' here because channel pages don't include them, # We don't include the 'premiere_timestamp' here because channel pages don't include them,
# meaning the above timestamp is always null # meaning the above timestamp is always null
was_insert = Invidious::Database::ChannelVideos.insert(video) # InnerTube provides relative publication labels. Once persisted, keep the
# existing timestamp so a later refresh cannot shift it forward.
was_insert = Invidious::Database::ChannelVideos.insert(video, update_published: false)
if was_insert if was_insert
LOGGER.trace("fetch_channel: #{ucid} : video #{channel_video.id} : Inserted, updating subscriptions") LOGGER.trace("fetch_channel: #{ucid} : video #{channel_video.id} : Inserted, updating subscriptions")
@ -226,7 +228,7 @@ def fetch_channel(ucid, pull_all_videos : Bool)
# We are notified of Red videos elsewhere (PubSub), which includes a correct published date, # We are notified of Red videos elsewhere (PubSub), which includes a correct published date,
# so since they don't provide a published date here we can safely ignore them. # so since they don't provide a published date here we can safely ignore them.
if Time.utc - video.published > 1.minute if Time.utc - video.published > 1.minute
was_insert = Invidious::Database::ChannelVideos.insert(video) was_insert = Invidious::Database::ChannelVideos.insert(video, update_published: false)
if was_insert if was_insert
NOTIFICATION_CHANNEL.send(VideoNotification.from_video(video)) NOTIFICATION_CHANNEL.send(VideoNotification.from_video(video))
end end

6
src/invidious/database/channels.cr
View File

@ -98,18 +98,20 @@ module Invidious::Database::ChannelVideos
# ------------------- # -------------------
# This function returns the status of the query (i.e: success?) # This function returns the status of the query (i.e: success?)
def insert(video : ChannelVideo, with_premiere_timestamp : Bool = false) : Bool def insert(video : ChannelVideo, with_premiere_timestamp : Bool = false, update_published : Bool = true) : Bool
if with_premiere_timestamp if with_premiere_timestamp
last_items = "premiere_timestamp = $9, views = $10" last_items = "premiere_timestamp = $9, views = $10"
else else
last_items = "views = $10" last_items = "views = $10"
end end
published_item = update_published ? "published = $3," : ""
request = <<-SQL request = <<-SQL
INSERT INTO channel_videos INSERT INTO channel_videos
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
ON CONFLICT (id) DO UPDATE ON CONFLICT (id) DO UPDATE
SET title = $2, published = $3, updated = $4, ucid = $5, SET title = $2, #{published_item} updated = $4, ucid = $5,
author = $6, length_seconds = $7, live_now = $8, #{last_items} author = $6, length_seconds = $7, live_now = $8, #{last_items}
RETURNING (xmax=0) AS was_insert RETURNING (xmax=0) AS was_insert
SQL SQL