Skip to content

Commit b559330

Browse files
committed
fix(radio: curl reqs): add timeouts to prevent blocking failures in the pload-pulling threads
1 parent 4c8f76f commit b559330

1 file changed

Lines changed: 7 additions & 3 deletions

File tree

radio.liq

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
# UNDERWRITING API not implemented
66
#def underwriting_request() =
77
# result = list.hd(default="", get_process_lines(
8-
# "curl -fsL #{playlist_api_url}/underwriting"))
8+
# "curl --max-time 10 -fsL #{playlist_api_url}/underwriting"))
99
# if result == "" then
1010
# []
1111
# else
@@ -15,10 +15,12 @@
1515

1616
def next_track_request() =
1717
result = list.hd(default="", process.read.lines(
18-
"curl -fsL #{playlist_api_url}/next_track"))
18+
"curl --max-time 10 -fsL #{playlist_api_url}/next_track"))
1919
if result == "" then
20+
log(label="next_track_request", "request returned contentless or timed out")
2021
[]
2122
else
23+
log(label="next_track_request", "#{result}")
2224
[request.create(result)]
2325
end
2426
end
@@ -31,10 +33,12 @@ end
3133

3234
def prerecorded_request() =
3335
result = list.hd(default="", process.read.lines(
34-
"curl -fsL #{playlist_api_url}/next_track?prerecorded=1"))
36+
"curl --max-time 10 -fsL #{playlist_api_url}/next_track?prerecorded=1"))
3537
if result == "" then
38+
log(label="prerecorded_request", "request returned contentless or timed out")
3639
[]
3740
else
41+
log(label="prerecorded_request", "#{result}")
3842
[request.create(result)]
3943
end
4044
end

0 commit comments

Comments
 (0)