|
|
|
@ -1541,6 +1541,12 @@ get "/feed/subscriptions" do |env|
|
|
|
|
|
offset = (page - 1) * max_results
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
if preferences.sort == "published - reverse"
|
|
|
|
|
sort = ""
|
|
|
|
|
else
|
|
|
|
|
sort = "DESC"
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
notifications = PG_DB.query_one("SELECT notifications FROM users WHERE email = $1", user.email,
|
|
|
|
|
as: Array(String))
|
|
|
|
|
view_name = "subscriptions_#{sha256(user.email)[0..7]}"
|
|
|
|
@ -1549,7 +1555,7 @@ get "/feed/subscriptions" do |env|
|
|
|
|
|
args = arg_array(notifications)
|
|
|
|
|
|
|
|
|
|
notifications = PG_DB.query_all("SELECT * FROM channel_videos WHERE id IN (#{args})
|
|
|
|
|
ORDER BY published DESC", notifications, as: ChannelVideo)
|
|
|
|
|
ORDER BY published #{sort}", notifications, as: ChannelVideo)
|
|
|
|
|
videos = [] of ChannelVideo
|
|
|
|
|
|
|
|
|
|
notifications.sort_by! { |video| video.published }.reverse!
|
|
|
|
@ -1574,11 +1580,11 @@ get "/feed/subscriptions" do |env|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM #{view_name} WHERE \
|
|
|
|
|
id NOT IN (#{watched}) ORDER BY ucid, published DESC",
|
|
|
|
|
id NOT IN (#{watched}) ORDER BY published, ucid #{sort}",
|
|
|
|
|
user.watched, as: ChannelVideo)
|
|
|
|
|
else
|
|
|
|
|
videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM #{view_name} \
|
|
|
|
|
ORDER BY ucid, published DESC", as: ChannelVideo)
|
|
|
|
|
ORDER BY published, ucid #{sort}", as: ChannelVideo)
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
videos.sort_by! { |video| video.published }.reverse!
|
|
|
|
@ -1591,11 +1597,11 @@ get "/feed/subscriptions" do |env|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
videos = PG_DB.query_all("SELECT * FROM #{view_name} WHERE \
|
|
|
|
|
id NOT IN (#{watched}) LIMIT $1 OFFSET $2",
|
|
|
|
|
id NOT IN (#{watched}) ORDER BY published #{sort} LIMIT $1 OFFSET $2",
|
|
|
|
|
[limit, offset] + user.watched, as: ChannelVideo)
|
|
|
|
|
else
|
|
|
|
|
videos = PG_DB.query_all("SELECT * FROM #{view_name} \
|
|
|
|
|
ORDER BY published DESC LIMIT $1 OFFSET $2", limit, offset, as: ChannelVideo)
|
|
|
|
|
ORDER BY published #{sort} LIMIT $1 OFFSET $2", limit, offset, as: ChannelVideo)
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
@ -1746,14 +1752,20 @@ get "/feed/private" do |env|
|
|
|
|
|
latest_only ||= 0
|
|
|
|
|
latest_only = latest_only == 1
|
|
|
|
|
|
|
|
|
|
if user.preferences.sort == "published - reverse"
|
|
|
|
|
sort = ""
|
|
|
|
|
else
|
|
|
|
|
sort = "DESC"
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
view_name = "subscriptions_#{sha256(user.email)[0..7]}"
|
|
|
|
|
|
|
|
|
|
if latest_only
|
|
|
|
|
videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM #{view_name} ORDER BY ucid, published DESC", as: ChannelVideo)
|
|
|
|
|
videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM #{view_name} ORDER BY ucid, published #{sort}", as: ChannelVideo)
|
|
|
|
|
videos.sort_by! { |video| video.published }.reverse!
|
|
|
|
|
else
|
|
|
|
|
videos = PG_DB.query_all("SELECT * FROM #{view_name} \
|
|
|
|
|
ORDER BY published DESC LIMIT $1 OFFSET $2", limit, offset, as: ChannelVideo)
|
|
|
|
|
ORDER BY published #{sort} LIMIT $1 OFFSET $2", limit, offset, as: ChannelVideo)
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
sort = env.params.query["sort"]?
|
|
|
|
|