diff options
| author | Omar Roth <omarroth@hotmail.com> | 2018-04-28 09:22:06 -0500 |
|---|---|---|
| committer | Omar Roth <omarroth@hotmail.com> | 2018-04-28 09:32:05 -0500 |
| commit | 92f78ff54135fd3f0723b7c434aab731cd41c1f7 (patch) | |
| tree | ceab6afcf8d53df25c381b0fe724f7a5d7637736 /src/helpers.cr | |
| parent | 8477579e0b353a0a85fba50812a5dda0127912bb (diff) | |
| download | invidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.tar.gz invidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.tar.bz2 invidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.zip | |
Remove client pool
Diffstat (limited to 'src/helpers.cr')
| -rw-r--r-- | src/helpers.cr | 15 |
1 files changed, 2 insertions, 13 deletions
diff --git a/src/helpers.cr b/src/helpers.cr index 20477241..1506a3dd 100644 --- a/src/helpers.cr +++ b/src/helpers.cr @@ -15,7 +15,6 @@ end class Config YAML.mapping({ - pool_size: Int32, threads: Int32, channel_threads: Int32, db: NamedTuple( @@ -178,14 +177,6 @@ def elapsed_text(elapsed) "#{(millis * 1000).round(2)}µs" end -def get_client(pool) - while pool.empty? - sleep rand(0..10).milliseconds - end - - return pool.shift -end - def fetch_video(id, client) info = client.get("/get_video_info?video_id=#{id}&el=detailpage&ps=default&eurl=&gl=US&hl=en").body html = client.get("/watch?v=#{id}&bpctr=#{Time.new.epoch + 2000}").body @@ -312,7 +303,7 @@ def decrypt_signature(a) return a.join("") end -def rank_videos(db, n, pool, filter) +def rank_videos(db, n, filter, url) top = [] of {Float64, String} db.query("SELECT id, wilson_score, published FROM videos WHERE views > 5000 ORDER BY published DESC LIMIT 1000") do |rs| @@ -339,15 +330,13 @@ def rank_videos(db, n, pool, filter) if language_list.size == n break else - client = get_client(pool) + client = make_client(url) begin video = get_video(id, client, db) rescue ex next end - pool << client - if video.language language = video.language else |
