Query DB for timestamps after current id

This commit is contained in:
broquemonsieur 2023-08-05 17:42:10 -07:00
parent 472a2d7e76
commit 510d85c045
4 changed files with 27 additions and 17 deletions

View File

@ -200,19 +200,12 @@ if (!video_data.params.listen && video_data.vr && video_data.params.vr_mode) {
// Add markers // Add markers
if (video_data.params.video_start > 0 || video_data.params.video_end > 0) { if (video_data.params.video_start > 0 || video_data.params.video_end > 0) {
var markers = [{ time: video_data.params.video_start, text: 'Start' }]; var markers = [{ time: video_data.params.video_start, text: 'Start' }];
if (video_data.starting_timestamp_seconds) {
markers = [{ time: video_data.starting_timestamp_seconds, text: 'Start' }];
}
if (!video_data.ending_timestamp_seconds) { if (video_data.params.video_end < 0) {
if (video_data.params.video_end < 0) { markers.push({ time: video_data.length_seconds - 0.5, text: 'End' });
markers.push({ time: video_data.length_seconds - 0.5, text: 'End' });
} else {
markers.push({ time: video_data.params.video_end, text: 'End' });
}
} else { } else {
markers.push({ time: video_data.ending_timestamp_seconds, text: 'End' }); markers.push({ time: video_data.params.video_end, text: 'End' });
} }
player.markers({ player.markers({
onMarkerReached: function (marker) { onMarkerReached: function (marker) {

View File

@ -111,6 +111,7 @@ function get_compilation(compid) {
compid_url = '/api/v1/compilations/' + compid + compid_url = '/api/v1/compilations/' + compid +
'?index=' + video_data.index + '?index=' + video_data.index +
'&continuation=' + video_data.id + '&continuation=' + video_data.id +
//'&t=' + video_data.video_data.starting_timestamp_seconds +
'&format=html&hl=' + video_data.preferences.locale; '&format=html&hl=' + video_data.preferences.locale;
console.log("Send "+compid_url); console.log("Send "+compid_url);
@ -138,6 +139,7 @@ function get_compilation(compid) {
url.searchParams.set('speed', video_data.params.speed); url.searchParams.set('speed', video_data.params.speed);
if (video_data.params.local !== video_data.preferences.local) if (video_data.params.local !== video_data.preferences.local)
url.searchParams.set('local', video_data.params.local); url.searchParams.set('local', video_data.params.local);
url.searchParams.set('t',video_data.starting_timestamp_seconds);
location.assign(url.pathname + url.search); location.assign(url.pathname + url.search);
}); });

View File

@ -128,7 +128,7 @@ module Invidious::Database::Compilations
LIMIT 1 LIMIT 1
SQL SQL
PG_DB.query_one?(request, id, as: String) PG_DB.query_one?(request, id, as: Array(Int64))
end end
# ------------------- # -------------------

View File

@ -45,11 +45,26 @@ module Invidious::Routes::Watch
elsif env.params.query["list"]?.try &.starts_with? "IVCMP" elsif env.params.query["list"]?.try &.starts_with? "IVCMP"
compid = env.params.query["list"]?.try &.gsub(/[^a-zA-Z0-9_-]/, "") compid = env.params.query["list"]?.try &.gsub(/[^a-zA-Z0-9_-]/, "")
if (!compid.nil?) if (!compid.nil?)
timestamps = Invidious::Database::CompilationVideos.select_timestamps(compid, id) index=Invidious::Database::CompilationVideos.select_index(compid,id)
if (!timestamps.nil?) indices_array=Invidious::Database::Compilations.select_index_array(compid)
starting_timestamp_seconds=timestamps[0] if (!indices_array.nil?)
ending_timestamp_seconds=timestamps[1] position_of_index=indices_array.index(index)
end if (!position_of_index.nil? && position_of_index != indices_array.size - 1)
next_index=indices_array[position_of_index+1]
else
next_index=indices_array[0]
end
if (!next_index.nil?)
next_id=Invidious::Database::CompilationVideos.select_id_from_index(next_index)
if (!next_id.nil?)
timestamps = Invidious::Database::CompilationVideos.select_timestamps(compid, next_id)
if (!timestamps.nil?)
starting_timestamp_seconds=timestamps[0]
ending_timestamp_seconds=timestamps[1]
end
end
end
end
end end
continuation = process_continuation(env.params.query, compid, id) continuation = process_continuation(env.params.query, compid, id)
end end