diff options
| author | Omar Roth <omarroth@hotmail.com> | 2018-03-25 22:18:29 -0500 |
|---|---|---|
| committer | Omar Roth <omarroth@hotmail.com> | 2018-03-25 22:18:29 -0500 |
| commit | edfe1eefe83d4c520d1b4aaffbc59627914fefc9 (patch) | |
| tree | ac5a39b62f35a7a355b881c0c12fe6e03821d5a0 /src/helpers.cr | |
| parent | 252f1c0af36748ac368ca791aad0d5a7f94b6d21 (diff) | |
| download | invidious-edfe1eefe83d4c520d1b4aaffbc59627914fefc9.tar.gz invidious-edfe1eefe83d4c520d1b4aaffbc59627914fefc9.tar.bz2 invidious-edfe1eefe83d4c520d1b4aaffbc59627914fefc9.zip | |
Add channel refresh
Diffstat (limited to 'src/helpers.cr')
| -rw-r--r-- | src/helpers.cr | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/helpers.cr b/src/helpers.cr index cd11baab..16e50ccd 100644 --- a/src/helpers.cr +++ b/src/helpers.cr @@ -489,11 +489,12 @@ def get_channel(id, client, db) if db.query_one?("SELECT EXISTS (SELECT true FROM channels WHERE id = $1)", id, as: Bool) channel = db.query_one("SELECT * FROM channels WHERE id = $1", id, as: InvidiousChannel) - if Time.now - channel.updated > 1.hours - db.exec("DELETE FROM channels * WHERE id = $1", id) + if Time.now - channel.updated > 1.minutes channel = fetch_channel(id, client) - args = arg_array(channel.to_a) - db.exec("INSERT INTO channels VALUES (#{args})", channel.to_a) + channel_array = channel.to_a[1..-1] + args = arg_array(channel_array) + + db.exec("UPDATE channels SET (rss,updated,author) = (#{args}) WHERE id = '#{channel.id}'", channel_array) end else channel = fetch_channel(id, client) |