summaryrefslogtreecommitdiffstats
path: root/src/helpers.cr
diff options
context:
space:
mode:
authorOmar Roth <omarroth@hotmail.com>2018-04-28 09:22:06 -0500
committerOmar Roth <omarroth@hotmail.com>2018-04-28 09:32:05 -0500
commit92f78ff54135fd3f0723b7c434aab731cd41c1f7 (patch)
treeceab6afcf8d53df25c381b0fe724f7a5d7637736 /src/helpers.cr
parent8477579e0b353a0a85fba50812a5dda0127912bb (diff)
downloadinvidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.tar.gz
invidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.tar.bz2
invidious-92f78ff54135fd3f0723b7c434aab731cd41c1f7.zip
Remove client pool
Diffstat (limited to 'src/helpers.cr')
-rw-r--r--src/helpers.cr15
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