Mirrored_Repos/invidious
1
0
Fork 0
mirror of https://github.com/iv-org/invidious.git synced 2024-11-21 21:17:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Misc: Sync crystal overrides with current stdlib

Browse Source
This commit is contained in:
Samantaz Fox 2024-07-03 21:13:29 +02:00
parent 325561e755
commit 63a729998b
No known key found for this signature in database
GPG Key ID: F42821059186176E
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/invidious/helpers/crystal_class_overrides.cr
View File

@ -3,9 +3,9 @@
# IPv6 addresses. # IPv6 addresses.
# #
class TCPSocket class TCPSocket
def initialize(host : String, port, dns_timeout = nil, connect_timeout = nil, family = Socket::Family::UNSPEC) def initialize(host, port, dns_timeout = nil, connect_timeout = nil, blocking = false, family = Socket::Family::UNSPEC)
Addrinfo.tcp(host, port, timeout: dns_timeout, family: family) do |addrinfo| Addrinfo.tcp(host, port, timeout: dns_timeout, family: family) do |addrinfo|
super(addrinfo.family, addrinfo.type, addrinfo.protocol) super(addrinfo.family, addrinfo.type, addrinfo.protocol, blocking)
connect(addrinfo, timeout: connect_timeout) do |error| connect(addrinfo, timeout: connect_timeout) do |error|
close close
error error
@ -26,7 +26,7 @@ class HTTP::Client
end end
hostname = @host.starts_with?('[') && @host.ends_with?(']') ? @host[1..-2] : @host hostname = @host.starts_with?('[') && @host.ends_with?(']') ? @host[1..-2] : @host
io = TCPSocket.new hostname, @port, @dns_timeout, @connect_timeout, @family io = TCPSocket.new hostname, @port, @dns_timeout, @connect_timeout, family: @family
io.read_timeout = @read_timeout if @read_timeout io.read_timeout = @read_timeout if @read_timeout
io.write_timeout = @write_timeout if @write_timeout io.write_timeout = @write_timeout if @write_timeout
io.sync = false io.sync = false
@ -35,7 +35,7 @@ class HTTP::Client
if tls = @tls if tls = @tls
tcp_socket = io tcp_socket = io
begin begin
io = OpenSSL::SSL::Socket::Client.new(tcp_socket, context: tls, sync_close: true, hostname: @host) io = OpenSSL::SSL::Socket::Client.new(tcp_socket, context: tls, sync_close: true, hostname: @host.rchop('.'))
rescue exc rescue exc
# don't leak the TCP socket when the SSL connection failed # don't leak the TCP socket when the SSL connection failed
tcp_socket.close tcp_socket.close