mirror of
https://gitea.invidious.io/iv-org/lsquic.cr
synced 2024-08-15 00:43:31 +00:00
Update to latest version of lsquic
This commit is contained in:
parent
a6033ff7df
commit
392a57aa8f
5 changed files with 132 additions and 126 deletions
|
@ -1,9 +1,9 @@
|
||||||
name: lsquic
|
name: lsquic
|
||||||
version: 0.1.8
|
version: 0.1.9
|
||||||
|
|
||||||
authors:
|
authors:
|
||||||
- Omar Roth <omarroth@protonmail.com>
|
- Omar Roth <omarroth@protonmail.com>
|
||||||
|
|
||||||
crystal: 0.32.0
|
crystal: 0.34.0
|
||||||
|
|
||||||
license: MIT
|
license: MIT
|
||||||
|
|
|
@ -11,6 +11,8 @@ module QUIC
|
||||||
end
|
end
|
||||||
|
|
||||||
class Client
|
class Client
|
||||||
|
REQUIRED_HEADERS = {":method", ":scheme", ":path", ":authority"}
|
||||||
|
|
||||||
def self.stream_readf(stream_if_ctx : Void*, buf : UInt8*, buf_len : LibC::SizeT, fin : LibC::Int)
|
def self.stream_readf(stream_if_ctx : Void*, buf : UInt8*, buf_len : LibC::SizeT, fin : LibC::Int)
|
||||||
stream_ctx = Box(StreamCtx).unbox(stream_if_ctx)
|
stream_ctx = Box(StreamCtx).unbox(stream_if_ctx)
|
||||||
stream_ctx.io.write Slice.new(buf, buf_len)
|
stream_ctx.io.write Slice.new(buf, buf_len)
|
||||||
|
@ -30,9 +32,7 @@ module QUIC
|
||||||
.try { |c| LibLsquic.conn_get_ctx(c) }
|
.try { |c| LibLsquic.conn_get_ctx(c) }
|
||||||
.try { |c| Box(StreamCtx).unbox(c) }
|
.try { |c| Box(StreamCtx).unbox(c) }
|
||||||
|
|
||||||
if LibLsquic.stream_is_pushed(s) != 0
|
return Box.box(stream_ctx) if LibLsquic.stream_is_pushed(s) != 0
|
||||||
return Box.box(stream_ctx)
|
|
||||||
end
|
|
||||||
|
|
||||||
LibLsquic.stream_wantwrite(s, 1)
|
LibLsquic.stream_wantwrite(s, 1)
|
||||||
Box.box(stream_ctx)
|
Box.box(stream_ctx)
|
||||||
|
@ -40,32 +40,21 @@ module QUIC
|
||||||
|
|
||||||
def self.on_write(s : LibLsquic::StreamT, stream_if_ctx : Void*)
|
def self.on_write(s : LibLsquic::StreamT, stream_if_ctx : Void*)
|
||||||
stream_ctx = Box(StreamCtx).unbox(stream_if_ctx)
|
stream_ctx = Box(StreamCtx).unbox(stream_if_ctx)
|
||||||
|
request_headers = stream_ctx.request.headers
|
||||||
|
|
||||||
headers = [] of LibLsquic::HttpHeader
|
headers = [] of LibLsquic::LsxpackHeader
|
||||||
(stream_ctx.request.headers.to_a.sort_by { |k, v| {":authority", ":path", ":scheme", ":method"}.index(k) || -1 }).reverse.each do |tuple|
|
REQUIRED_HEADERS.each do |name|
|
||||||
name, values = tuple
|
value = stream_ctx.request.headers[name]
|
||||||
|
headers << LibLsquic::LsxpackHeader.new(name_ptr: name, name_len: name.bytesize, buf: value, val_len: value.bytesize)
|
||||||
|
end
|
||||||
|
|
||||||
|
request_headers.each do |name, values|
|
||||||
name = name.downcase
|
name = name.downcase
|
||||||
|
next if REQUIRED_HEADERS.includes? name
|
||||||
values.each do |value|
|
headers << LibLsquic::LsxpackHeader.new(name_ptr: name, name_len: name.bytesize, buf: values[0], val_len: values[0].bytesize)
|
||||||
name_vec = LibLsquic::Iovec.new
|
|
||||||
name_vec.iov_base = name.to_slice
|
|
||||||
name_vec.iov_len = name.bytesize
|
|
||||||
|
|
||||||
value_vec = LibLsquic::Iovec.new
|
|
||||||
value_vec.iov_base = value.to_slice
|
|
||||||
value_vec.iov_len = value.bytesize
|
|
||||||
|
|
||||||
header = LibLsquic::HttpHeader.new
|
|
||||||
header.name = name_vec
|
|
||||||
header.value = value_vec
|
|
||||||
|
|
||||||
headers << header
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|
||||||
http_headers = LibLsquic::HttpHeaders.new
|
http_headers = LibLsquic::HttpHeaders.new(count: headers.size, headers: headers.to_unsafe)
|
||||||
http_headers.count = headers.size
|
|
||||||
http_headers.headers = headers.to_unsafe
|
|
||||||
|
|
||||||
raise "Could not send headers" if LibLsquic.stream_send_headers(s, pointerof(http_headers), stream_ctx.request.body ? 0 : 1) != 0
|
raise "Could not send headers" if LibLsquic.stream_send_headers(s, pointerof(http_headers), stream_ctx.request.body ? 0 : 1) != 0
|
||||||
|
|
||||||
|
@ -194,7 +183,16 @@ module QUIC
|
||||||
hostname = host.starts_with?('[') && host.ends_with?(']') ? host[1..-2] : host
|
hostname = host.starts_with?('[') && host.ends_with?(']') ? host[1..-2] : host
|
||||||
@engine_open = true
|
@engine_open = true
|
||||||
|
|
||||||
conn = LibLsquic.engine_connect(engine, LibLsquic::Version::Lsqver046, socket.local_address, socket.remote_address, Box.box(socket), nil, hostname, 0, nil, 0, nil, 0)
|
conn = LibLsquic.engine_connect(
|
||||||
|
engine,
|
||||||
|
LibLsquic::Version::Lsqver050,
|
||||||
|
socket.local_address,
|
||||||
|
socket.remote_address,
|
||||||
|
Box.box(socket), nil,
|
||||||
|
hostname, 0,
|
||||||
|
nil, 0,
|
||||||
|
nil, 0
|
||||||
|
)
|
||||||
spawn do
|
spawn do
|
||||||
while stream_ctx = @stream_channel.receive
|
while stream_ctx = @stream_channel.receive
|
||||||
LibLsquic.conn_set_ctx(conn, Box.box(stream_ctx))
|
LibLsquic.conn_set_ctx(conn, Box.box(stream_ctx))
|
||||||
|
|
BIN
src/lsquic/ext/liblsquic.a
Normal file
BIN
src/lsquic/ext/liblsquic.a
Normal file
Binary file not shown.
|
@ -1,4 +1,4 @@
|
||||||
@[Link(ldflags: "#{__DIR__}/ext/liblsquic.a -lz")]
|
@[Link(ldflags: "#{__DIR__}/ext/liblsquic.a")]
|
||||||
lib LibLsquic
|
lib LibLsquic
|
||||||
MAX_CID_LEN = 20
|
MAX_CID_LEN = 20
|
||||||
QQUIC_CID_LEN = 8
|
QQUIC_CID_LEN = 8
|
||||||
|
@ -63,12 +63,10 @@ lib LibLsquic
|
||||||
alias UintFast8T = UInt8
|
alias UintFast8T = UInt8
|
||||||
|
|
||||||
union CidUCid
|
union CidUCid
|
||||||
buf : Uint8T[20]
|
buf : LibC::UInt8T[20]
|
||||||
id : Uint64T
|
id : LibC::UInt64T
|
||||||
end
|
end
|
||||||
|
|
||||||
alias Uint8T = UInt8
|
|
||||||
alias Uint64T = LibC::ULong
|
|
||||||
alias Engine = Void
|
alias Engine = Void
|
||||||
alias Conn = Void
|
alias Conn = Void
|
||||||
alias ConnCtx = Void
|
alias ConnCtx = Void
|
||||||
|
@ -77,16 +75,27 @@ lib LibLsquic
|
||||||
|
|
||||||
struct HttpHeaders
|
struct HttpHeaders
|
||||||
count : LibC::Int
|
count : LibC::Int
|
||||||
headers : HttpHeader*
|
headers : LsxpackHeader*
|
||||||
end
|
end
|
||||||
|
|
||||||
struct HttpHeader
|
struct LsxpackHeader
|
||||||
name : Iovec
|
buf : LibC::Char*
|
||||||
value : Iovec
|
name_ptr : LibC::Char*
|
||||||
|
name_hash : LibC::UInt32T
|
||||||
|
nameval_hash : LibC::UInt32T
|
||||||
|
name_offset : LibC::UInt16T
|
||||||
|
name_len : LibC::UInt16T
|
||||||
|
val_offset : LibC::UInt16T
|
||||||
|
val_len : LibC::UInt16T
|
||||||
|
chain_next_idx : LibC::UInt16T
|
||||||
|
hpack_index : LibC::UInt8T
|
||||||
|
qpack_index : LibC::UInt8T
|
||||||
|
app_index : LibC::UInt8T
|
||||||
|
flags : LibC::UInt8T
|
||||||
|
indexed_type : LibC::UInt8T
|
||||||
|
dec_overhead : LibC::UInt8T
|
||||||
end
|
end
|
||||||
|
|
||||||
type HttpHeaderT = HttpHeader
|
|
||||||
|
|
||||||
struct Iovec
|
struct Iovec
|
||||||
iov_base : UInt8*
|
iov_base : UInt8*
|
||||||
iov_len : LibC::SizeT
|
iov_len : LibC::SizeT
|
||||||
|
@ -126,12 +135,11 @@ lib LibLsquic
|
||||||
es_silent_close : LibC::Int
|
es_silent_close : LibC::Int
|
||||||
es_max_header_list_size : LibC::UInt
|
es_max_header_list_size : LibC::UInt
|
||||||
es_ua : LibC::Char*
|
es_ua : LibC::Char*
|
||||||
es_sttl : Uint64T
|
es_sttl : LibC::UInt64T
|
||||||
es_pdmd : Uint32T
|
es_pdmd : LibC::UInt32T
|
||||||
es_aead : Uint32T
|
es_aead : LibC::UInt32T
|
||||||
es_kexs : Uint32T
|
es_kexs : LibC::UInt32T
|
||||||
es_max_inchoate : LibC::UInt
|
es_max_inchoate : LibC::UInt
|
||||||
es_support_srej : LibC::Int
|
|
||||||
es_support_push : LibC::Int
|
es_support_push : LibC::Int
|
||||||
es_support_tcid0 : LibC::Int
|
es_support_tcid0 : LibC::Int
|
||||||
es_support_nstp : LibC::Int
|
es_support_nstp : LibC::Int
|
||||||
|
@ -159,9 +167,13 @@ lib LibLsquic
|
||||||
es_ecn : LibC::Int
|
es_ecn : LibC::Int
|
||||||
es_allow_migration : LibC::Int
|
es_allow_migration : LibC::Int
|
||||||
es_cc_algo : LibC::UInt
|
es_cc_algo : LibC::UInt
|
||||||
|
es_ql_bits : LibC::Int
|
||||||
|
es_spin : LibC::Int
|
||||||
|
es_delayed_acks : LibC::Int
|
||||||
|
es_timestamps : LibC::Int
|
||||||
|
es_max_packet_size_rx : LibC::UInt16T
|
||||||
end
|
end
|
||||||
|
|
||||||
alias Uint32T = LibC::UInt
|
|
||||||
fun engine_init_settings = lsquic_engine_init_settings(x0 : EngineSettings*, engine_flags : LibC::UInt)
|
fun engine_init_settings = lsquic_engine_init_settings(x0 : EngineSettings*, engine_flags : LibC::UInt)
|
||||||
fun engine_check_settings = lsquic_engine_check_settings(settings : EngineSettings*, engine_flags : LibC::UInt, err_buf : LibC::Char*, err_buf_sz : LibC::SizeT) : LibC::Int
|
fun engine_check_settings = lsquic_engine_check_settings(settings : EngineSettings*, engine_flags : LibC::UInt, err_buf : LibC::Char*, err_buf_sz : LibC::SizeT) : LibC::Int
|
||||||
|
|
||||||
|
@ -189,25 +201,17 @@ lib LibLsquic
|
||||||
end
|
end
|
||||||
|
|
||||||
struct HsetIf
|
struct HsetIf
|
||||||
hsi_create_header_set : (Void*, LibC::Int -> Void*)
|
hsi_create_header_set : (Void*, StreamT, LibC::Int -> Void*)
|
||||||
hsi_process_header : (Void*, LibC::UInt, LibC::Char*, LibC::UInt, LibC::Char*, LibC::UInt -> HeaderStatus)
|
hsi_prepare_decode : (Void*, LsxpackHeader*, LibC::SizeT -> LsxpackHeader*)
|
||||||
|
hsi_process_header : (Void*, LsxpackHeader* -> LibC::Int)
|
||||||
hsi_discard_header_set : (Void* -> Void)
|
hsi_discard_header_set : (Void* -> Void)
|
||||||
|
hsi_flags : HsiFlag
|
||||||
end
|
end
|
||||||
|
|
||||||
enum HeaderStatus
|
enum HsiFlag
|
||||||
HdrOk = 0
|
HsiHttp1X = 2
|
||||||
HdrErrDuplicatePsdoHdr = 1
|
HsiHashName = 4
|
||||||
HdrErrIncomplReqPsdoHdr = 2
|
HsiHashNameval = 8
|
||||||
HdrErrUnnecReqPsdoHdr = 3
|
|
||||||
HdrErrBadReqHeader = 4
|
|
||||||
HdrErrIncomplRespPsdoHdr = 5
|
|
||||||
HdrErrUnnecRespPsdoHdr = 6
|
|
||||||
HdrErrUnknownPsdoHdr = 7
|
|
||||||
HdrErrUppercaseHeader = 8
|
|
||||||
HdrErrMisplacedPsdoHdr = 9
|
|
||||||
HdrErrMissingPsdoHdr = 10
|
|
||||||
HdrErrHeadersTooLarge = 11
|
|
||||||
HdrErrNomem = 12
|
|
||||||
end
|
end
|
||||||
|
|
||||||
struct KeylogIf
|
struct KeylogIf
|
||||||
|
@ -239,27 +243,31 @@ lib LibLsquic
|
||||||
ea_hsi_ctx : Void*
|
ea_hsi_ctx : Void*
|
||||||
ea_keylog_if : KeylogIf*
|
ea_keylog_if : KeylogIf*
|
||||||
ea_keylog_ctx : Void*
|
ea_keylog_ctx : Void*
|
||||||
|
ea_alpn : LibC::Char*
|
||||||
end
|
end
|
||||||
|
|
||||||
alias PacketsOutF = (Void*, OutSpec*, LibC::UInt -> LibC::Int)
|
alias PacketsOutF = (Void*, OutSpec*, LibC::UInt -> LibC::Int)
|
||||||
alias SslCtxSt = Void
|
alias SslCtxSt = Void
|
||||||
alias LookupCertF = (Void*, LibC::Sockaddr*, LibC::Char* -> SslCtxSt*)
|
alias Sockaddr = LibC::Sockaddr
|
||||||
|
alias LookupCertF = (Void*, Sockaddr*, LibC::Char* -> SslCtxSt*)
|
||||||
type CidT = Cid
|
type CidT = Cid
|
||||||
alias CidsUpdateF = (Void*, Void**, CidT*, LibC::UInt -> Void)
|
alias CidsUpdateF = (Void*, Void**, CidT*, LibC::UInt -> Void)
|
||||||
alias StackStX509 = Void
|
alias StackStX509 = Void
|
||||||
fun engine_new = lsquic_engine_new(engine_flags : LibC::UInt, x1 : EngineApi*) : EngineT
|
fun engine_new = lsquic_engine_new(engine_flags : LibC::UInt, api : EngineApi*) : EngineT
|
||||||
type EngineT = Void*
|
type EngineT = Void*
|
||||||
fun engine_connect = lsquic_engine_connect(x0 : EngineT, x1 : Version, local_sa : LibC::Sockaddr*, peer_sa : LibC::Sockaddr*, peer_ctx : Void*, conn_ctx : Void*, hostname : LibC::Char*, max_packet_size : LibC::UShort, zero_rtt : UInt8*, zero_rtt_len : LibC::SizeT, token : UInt8*, token_sz : LibC::SizeT) : ConnT
|
fun engine_connect = lsquic_engine_connect(x0 : EngineT, x1 : Version, local_sa : Sockaddr*, peer_sa : Sockaddr*, peer_ctx : Void*, conn_ctx : Void*, hostname : LibC::Char*, max_packet_size : LibC::UShort, zero_rtt : UInt8*, zero_rtt_len : LibC::SizeT, token : UInt8*, token_sz : LibC::SizeT) : ConnT
|
||||||
|
|
||||||
enum Version
|
enum Version
|
||||||
Lsqver039 = 0
|
Lsqver043 = 0
|
||||||
Lsqver043 = 1
|
Lsqver046 = 1
|
||||||
Lsqver046 = 2
|
Lsqver050 = 2
|
||||||
LsqverId23 = 3
|
LsqverId25 = 3
|
||||||
LsqverId24 = 4
|
LsqverId27 = 4
|
||||||
LsqverVerneg = 5
|
LsqverVerneg = 5
|
||||||
NLsqver = 6
|
NLsqver = 6
|
||||||
end
|
end
|
||||||
fun engine_packet_in = lsquic_engine_packet_in(x0 : EngineT, packet_in_data : UInt8*, packet_in_size : LibC::SizeT, sa_local : LibC::Sockaddr*, sa_peer : LibC::Sockaddr*, peer_ctx : Void*, ecn : LibC::Int) : LibC::Int
|
|
||||||
|
fun engine_packet_in = lsquic_engine_packet_in(x0 : EngineT, packet_in_data : UInt8*, packet_in_size : LibC::SizeT, sa_local : Sockaddr*, sa_peer : Sockaddr*, peer_ctx : Void*, ecn : LibC::Int) : LibC::Int
|
||||||
fun engine_process_conns = lsquic_engine_process_conns(engine : EngineT)
|
fun engine_process_conns = lsquic_engine_process_conns(engine : EngineT)
|
||||||
fun engine_has_unsent_packets = lsquic_engine_has_unsent_packets(engine : EngineT) : LibC::Int
|
fun engine_has_unsent_packets = lsquic_engine_has_unsent_packets(engine : EngineT) : LibC::Int
|
||||||
fun engine_send_unsent_packets = lsquic_engine_send_unsent_packets(engine : EngineT)
|
fun engine_send_unsent_packets = lsquic_engine_send_unsent_packets(engine : EngineT)
|
||||||
|
@ -271,13 +279,12 @@ lib LibLsquic
|
||||||
fun conn_going_away = lsquic_conn_going_away(x0 : ConnT)
|
fun conn_going_away = lsquic_conn_going_away(x0 : ConnT)
|
||||||
fun conn_close = lsquic_conn_close(x0 : ConnT)
|
fun conn_close = lsquic_conn_close(x0 : ConnT)
|
||||||
fun stream_wantread = lsquic_stream_wantread(s : StreamT, is_want : LibC::Int) : LibC::Int
|
fun stream_wantread = lsquic_stream_wantread(s : StreamT, is_want : LibC::Int) : LibC::Int
|
||||||
fun stream_read = lsquic_stream_read(s : StreamT, buf : Void*, len : LibC::SizeT) : SsizeT
|
fun stream_read = lsquic_stream_read(s : StreamT, buf : Void*, len : LibC::SizeT) : LibC::SizeT
|
||||||
alias SsizeT = LibC::Long
|
fun stream_readv = lsquic_stream_readv(s : StreamT, vec : Iovec*, iovcnt : LibC::Int) : LibC::SizeT
|
||||||
fun stream_readv = lsquic_stream_readv(s : StreamT, x1 : Iovec*, iovcnt : LibC::Int) : SsizeT
|
fun stream_readf = lsquic_stream_readf(s : StreamT, readf : (Void*, UInt8*, LibC::SizeT, LibC::Int -> LibC::SizeT), ctx : Void*) : LibC::SizeT
|
||||||
fun stream_readf = lsquic_stream_readf(s : StreamT, readf : (Void*, UInt8*, LibC::SizeT, LibC::Int -> LibC::SizeT), ctx : Void*) : SsizeT
|
|
||||||
fun stream_wantwrite = lsquic_stream_wantwrite(s : StreamT, is_want : LibC::Int) : LibC::Int
|
fun stream_wantwrite = lsquic_stream_wantwrite(s : StreamT, is_want : LibC::Int) : LibC::Int
|
||||||
fun stream_write = lsquic_stream_write(s : StreamT, buf : Void*, len : LibC::SizeT) : SsizeT
|
fun stream_write = lsquic_stream_write(s : StreamT, buf : Void*, len : LibC::SizeT) : LibC::SizeT
|
||||||
fun stream_writev = lsquic_stream_writev(s : StreamT, vec : Iovec*, count : LibC::Int) : SsizeT
|
fun stream_writev = lsquic_stream_writev(s : StreamT, vec : Iovec*, count : LibC::Int) : LibC::SizeT
|
||||||
|
|
||||||
struct Reader
|
struct Reader
|
||||||
lsqr_read : (Void*, Void*, LibC::SizeT -> LibC::SizeT)
|
lsqr_read : (Void*, Void*, LibC::SizeT -> LibC::SizeT)
|
||||||
|
@ -285,18 +292,17 @@ lib LibLsquic
|
||||||
lsqr_ctx : Void*
|
lsqr_ctx : Void*
|
||||||
end
|
end
|
||||||
|
|
||||||
fun stream_writef = lsquic_stream_writef(x0 : StreamT, x1 : Reader*) : SsizeT
|
fun stream_writef = lsquic_stream_writef(x0 : StreamT, x1 : Reader*) : LibC::SizeT
|
||||||
fun stream_flush = lsquic_stream_flush(s : StreamT) : LibC::Int
|
fun stream_flush = lsquic_stream_flush(s : StreamT) : LibC::Int
|
||||||
fun stream_send_headers = lsquic_stream_send_headers(s : StreamT, h : HttpHeaders*, eos : LibC::Int) : LibC::Int
|
fun stream_send_headers = lsquic_stream_send_headers(s : StreamT, headers : HttpHeaders*, eos : LibC::Int) : LibC::Int
|
||||||
type HttpHeadersT = HttpHeaders
|
|
||||||
fun stream_get_hset = lsquic_stream_get_hset(x0 : StreamT) : Void*
|
fun stream_get_hset = lsquic_stream_get_hset(x0 : StreamT) : Void*
|
||||||
fun conn_push_stream = lsquic_conn_push_stream(c : ConnT, hdr_set : Void*, s : StreamT, url : Iovec*, authority : Iovec*, headers : HttpHeaders*) : LibC::Int
|
fun conn_push_stream = lsquic_conn_push_stream(c : ConnT, hdr_set : Void*, s : StreamT, headers : HttpHeaders*) : LibC::Int
|
||||||
fun conn_is_push_enabled = lsquic_conn_is_push_enabled(x0 : ConnT) : LibC::Int
|
fun conn_is_push_enabled = lsquic_conn_is_push_enabled(x0 : ConnT) : LibC::Int
|
||||||
fun stream_shutdown = lsquic_stream_shutdown(s : StreamT, how : LibC::Int) : LibC::Int
|
fun stream_shutdown = lsquic_stream_shutdown(s : StreamT, how : LibC::Int) : LibC::Int
|
||||||
fun stream_close = lsquic_stream_close(s : StreamT) : LibC::Int
|
fun stream_close = lsquic_stream_close(s : StreamT) : LibC::Int
|
||||||
fun conn_get_server_cert_chain = lsquic_conn_get_server_cert_chain(x0 : ConnT) : StackStX509*
|
fun conn_get_server_cert_chain = lsquic_conn_get_server_cert_chain(x0 : ConnT) : StackStX509*
|
||||||
fun stream_id = lsquic_stream_id(s : StreamT) : StreamIdT
|
fun stream_id = lsquic_stream_id(s : StreamT) : StreamIdT
|
||||||
alias StreamIdT = Uint64T
|
alias StreamIdT = LibC::UInt64T
|
||||||
fun stream_get_ctx = lsquic_stream_get_ctx(s : StreamT) : Void*
|
fun stream_get_ctx = lsquic_stream_get_ctx(s : StreamT) : Void*
|
||||||
fun stream_is_pushed = lsquic_stream_is_pushed(s : StreamT) : LibC::Int
|
fun stream_is_pushed = lsquic_stream_is_pushed(s : StreamT) : LibC::Int
|
||||||
fun stream_is_rejected = lsquic_stream_is_rejected(s : StreamT) : LibC::Int
|
fun stream_is_rejected = lsquic_stream_is_rejected(s : StreamT) : LibC::Int
|
||||||
|
@ -305,16 +311,16 @@ lib LibLsquic
|
||||||
fun stream_priority = lsquic_stream_priority(s : StreamT) : LibC::UInt
|
fun stream_priority = lsquic_stream_priority(s : StreamT) : LibC::UInt
|
||||||
fun stream_set_priority = lsquic_stream_set_priority(s : StreamT, priority : LibC::UInt) : LibC::Int
|
fun stream_set_priority = lsquic_stream_set_priority(s : StreamT, priority : LibC::UInt) : LibC::Int
|
||||||
fun stream_conn = lsquic_stream_conn(s : StreamT) : ConnT
|
fun stream_conn = lsquic_stream_conn(s : StreamT) : ConnT
|
||||||
fun conn_get_stream_by_id = lsquic_conn_get_stream_by_id(c : ConnT, stream_id : StreamIdT) : StreamT
|
|
||||||
fun conn_id = lsquic_conn_id(c : ConnT) : CidT*
|
fun conn_id = lsquic_conn_id(c : ConnT) : CidT*
|
||||||
fun conn_get_engine = lsquic_conn_get_engine(c : ConnT) : EngineT
|
fun conn_get_engine = lsquic_conn_get_engine(c : ConnT) : EngineT
|
||||||
fun conn_get_sockaddr = lsquic_conn_get_sockaddr(c : ConnT, local : LibC::Sockaddr**, peer : LibC::Sockaddr**) : LibC::Int
|
fun conn_get_sockaddr = lsquic_conn_get_sockaddr(c : ConnT, local : Sockaddr**, peer : Sockaddr**) : LibC::Int
|
||||||
|
|
||||||
struct LoggerIf
|
struct LoggerIf
|
||||||
log_buf : (Void*, LibC::Char*, LibC::SizeT -> LibC::Int)
|
log_buf : (Void*, LibC::Char*, LibC::SizeT -> LibC::Int)
|
||||||
end
|
end
|
||||||
|
|
||||||
fun logger_init = lsquic_logger_init(x0 : LoggerIf*, logger_ctx : Void*, x2 : LoggerTimestampStyle)
|
fun logger_init = lsquic_logger_init(x0 : LoggerIf*, logger_ctx : Void*, x2 : LoggerTimestampStyle)
|
||||||
|
|
||||||
enum LoggerTimestampStyle
|
enum LoggerTimestampStyle
|
||||||
LltsNone = 0
|
LltsNone = 0
|
||||||
LltsHhmmssms = 1
|
LltsHhmmssms = 1
|
||||||
|
@ -324,6 +330,7 @@ lib LibLsquic
|
||||||
LltsYyyymmddHhmmssus = 5
|
LltsYyyymmddHhmmssus = 5
|
||||||
NLlts = 6
|
NLlts = 6
|
||||||
end
|
end
|
||||||
|
|
||||||
fun set_log_level = lsquic_set_log_level(log_level : LibC::Char*) : LibC::Int
|
fun set_log_level = lsquic_set_log_level(log_level : LibC::Char*) : LibC::Int
|
||||||
fun logger_lopt = lsquic_logger_lopt(optarg : LibC::Char*) : LibC::Int
|
fun logger_lopt = lsquic_logger_lopt(optarg : LibC::Char*) : LibC::Int
|
||||||
fun engine_quic_versions = lsquic_engine_quic_versions(x0 : EngineT) : LibC::UInt
|
fun engine_quic_versions = lsquic_engine_quic_versions(x0 : EngineT) : LibC::UInt
|
||||||
|
@ -337,15 +344,14 @@ lib LibLsquic
|
||||||
LsqCryQuic = 0
|
LsqCryQuic = 0
|
||||||
LsqCryTlSv13 = 1
|
LsqCryTlSv13 = 1
|
||||||
end
|
end
|
||||||
|
|
||||||
fun conn_crypto_cipher = lsquic_conn_crypto_cipher(c : ConnT) : LibC::Char*
|
fun conn_crypto_cipher = lsquic_conn_crypto_cipher(c : ConnT) : LibC::Char*
|
||||||
fun str2ver = lsquic_str2ver(str : LibC::Char*, len : LibC::SizeT) : Version
|
fun str2ver = lsquic_str2ver(str : LibC::Char*, len : LibC::SizeT) : Version
|
||||||
fun alpn2ver = lsquic_alpn2ver(alpn : LibC::Char*, len : LibC::SizeT) : Version
|
fun alpn2ver = lsquic_alpn2ver(alpn : LibC::Char*, len : LibC::SizeT) : Version
|
||||||
fun engine_cooldown = lsquic_engine_cooldown(x0 : EngineT)
|
fun engine_cooldown = lsquic_engine_cooldown(x0 : EngineT)
|
||||||
fun hsk_getssl = lsquic_hsk_getssl(conn : ConnT) : SslSt*
|
|
||||||
alias SslSt = Void
|
|
||||||
fun conn_get_ctx = lsquic_conn_get_ctx(x0 : ConnT) : Void*
|
fun conn_get_ctx = lsquic_conn_get_ctx(x0 : ConnT) : Void*
|
||||||
fun conn_set_ctx = lsquic_conn_set_ctx(x0 : ConnT, x1 : Void*)
|
fun conn_set_ctx = lsquic_conn_set_ctx(x0 : ConnT, x1 : Void*)
|
||||||
fun conn_get_peer_ctx = lsquic_conn_get_peer_ctx(x0 : ConnT, local_sa : LibC::Sockaddr*) : Void*
|
fun conn_get_peer_ctx = lsquic_conn_get_peer_ctx(x0 : ConnT, local_sa : Sockaddr*) : Void*
|
||||||
fun conn_abort = lsquic_conn_abort(x0 : ConnT)
|
fun conn_abort = lsquic_conn_abort(x0 : ConnT)
|
||||||
fun get_alt_svc_versions = lsquic_get_alt_svc_versions(versions : LibC::UInt) : LibC::Char*
|
fun get_alt_svc_versions = lsquic_get_alt_svc_versions(versions : LibC::UInt) : LibC::Char*
|
||||||
fun get_h3_alpns = lsquic_get_h3_alpns(versions : LibC::UInt) : LibC::Char**
|
fun get_h3_alpns = lsquic_get_h3_alpns(versions : LibC::UInt) : LibC::Char**
|
||||||
|
@ -354,6 +360,7 @@ lib LibLsquic
|
||||||
fun engine_earliest_adv_tick = lsquic_engine_earliest_adv_tick(engine : EngineT, diff : LibC::Int*) : LibC::Int
|
fun engine_earliest_adv_tick = lsquic_engine_earliest_adv_tick(engine : EngineT, diff : LibC::Int*) : LibC::Int
|
||||||
fun engine_count_attq = lsquic_engine_count_attq(engine : EngineT, from_now : LibC::Int) : LibC::UInt
|
fun engine_count_attq = lsquic_engine_count_attq(engine : EngineT, from_now : LibC::Int) : LibC::UInt
|
||||||
fun conn_status = lsquic_conn_status(x0 : ConnT, errbuf : LibC::Char*, bufsz : LibC::SizeT) : ConnStatus
|
fun conn_status = lsquic_conn_status(x0 : ConnT, errbuf : LibC::Char*, bufsz : LibC::SizeT) : ConnStatus
|
||||||
|
|
||||||
enum ConnStatus
|
enum ConnStatus
|
||||||
LsconnStHskInProgress = 0
|
LsconnStHskInProgress = 0
|
||||||
LsconnStConnected = 1
|
LsconnStConnected = 1
|
||||||
|
@ -366,5 +373,6 @@ lib LibLsquic
|
||||||
LsconnStClosed = 8
|
LsconnStClosed = 8
|
||||||
LsconnStPeerGoingAway = 9
|
LsconnStPeerGoingAway = 9
|
||||||
end
|
end
|
||||||
|
|
||||||
$ver2str : LibC::Char*[6]
|
$ver2str : LibC::Char*[6]
|
||||||
end
|
end
|
||||||
|
|
|
@ -1,6 +1,5 @@
|
||||||
require "openssl"
|
require "openssl"
|
||||||
|
|
||||||
@[Link(ldflags: "#{__DIR__}/ext/liblsquic.a #{__DIR__}/ext/libcrypto.a")]
|
|
||||||
lib LibCrypto
|
lib LibCrypto
|
||||||
fun evp_ripemd160 = EVP_sha1 : EVP_MD
|
fun evp_ripemd160 = EVP_sha1 : EVP_MD
|
||||||
fun sk_free = sk_free(st : Void*)
|
fun sk_free = sk_free(st : Void*)
|
||||||
|
@ -12,8 +11,9 @@ lib LibCrypto
|
||||||
fun err_load_crypto_strings = rand : LibC::Int
|
fun err_load_crypto_strings = rand : LibC::Int
|
||||||
end
|
end
|
||||||
|
|
||||||
@[Link(ldflags: "#{__DIR__}/ext/libssl.a")]
|
|
||||||
lib LibSSL
|
lib LibSSL
|
||||||
|
{% ssl_version = "1.1.0" %}
|
||||||
|
|
||||||
fun ssl_set_tlsext_host_name = SSL_set_tlsext_host_name(handle : SSL, name : Char*) : Long
|
fun ssl_set_tlsext_host_name = SSL_set_tlsext_host_name(handle : SSL, name : Char*) : Long
|
||||||
fun ssl_ctx_set_tmp_ecdh = SSL_CTX_set_tmp_ecdh(ctx : SSLContext, parg : Void*) : ULong
|
fun ssl_ctx_set_tmp_ecdh = SSL_CTX_set_tmp_ecdh(ctx : SSLContext, parg : Void*) : ULong
|
||||||
fun ssl_ctx_get_mode = SSL_CTX_get_mode(ctx : SSLContext) : ULong
|
fun ssl_ctx_get_mode = SSL_CTX_get_mode(ctx : SSLContext) : ULong
|
||||||
|
@ -27,43 +27,6 @@ lib LibSSL
|
||||||
fun ssl_load_error_strings = rand : LibC::Int
|
fun ssl_load_error_strings = rand : LibC::Int
|
||||||
end
|
end
|
||||||
|
|
||||||
abstract class OpenSSL::SSL::Context
|
|
||||||
def set_tmp_ecdh_key(curve = LibCrypto::NID_X9_62_prime256v1)
|
|
||||||
key = LibCrypto.ec_key_new_by_curve_name(curve)
|
|
||||||
raise OpenSSL::Error.new("ec_key_new_by_curve_name") if key.null?
|
|
||||||
LibSSL.ssl_ctx_set_tmp_ecdh(@handle, key)
|
|
||||||
LibCrypto.ec_key_free(key)
|
|
||||||
end
|
|
||||||
|
|
||||||
# Returns the current modes set on the TLS context.
|
|
||||||
def modes
|
|
||||||
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_get_mode(@handle)
|
|
||||||
end
|
|
||||||
|
|
||||||
# Adds modes to the TLS context.
|
|
||||||
def add_modes(mode : OpenSSL::SSL::Modes)
|
|
||||||
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_set_mode(@handle, mode)
|
|
||||||
end
|
|
||||||
|
|
||||||
# Removes modes from the TLS context.
|
|
||||||
def remove_modes(mode : OpenSSL::SSL::Modes)
|
|
||||||
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_clear_mode(@handle, mode)
|
|
||||||
end
|
|
||||||
|
|
||||||
# Returns the current options set on the TLS context.
|
|
||||||
def options
|
|
||||||
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_get_options(@handle)
|
|
||||||
end
|
|
||||||
|
|
||||||
def add_options(options : OpenSSL::SSL::Options)
|
|
||||||
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_set_options(@handle, options)
|
|
||||||
end
|
|
||||||
|
|
||||||
def remove_options(options : OpenSSL::SSL::Options)
|
|
||||||
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_clear_options(@handle, options)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
struct OpenSSL::BIO
|
struct OpenSSL::BIO
|
||||||
CRYSTAL_BIO_BORING = begin
|
CRYSTAL_BIO_BORING = begin
|
||||||
bwrite = LibCrypto::BioMethodWriteOld.new do |bio, data, len|
|
bwrite = LibCrypto::BioMethodWriteOld.new do |bio, data, len|
|
||||||
|
@ -163,6 +126,43 @@ struct OpenSSL::BIO
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
abstract class OpenSSL::SSL::Context
|
||||||
|
def set_tmp_ecdh_key(curve = LibCrypto::NID_X9_62_prime256v1)
|
||||||
|
key = LibCrypto.ec_key_new_by_curve_name(curve)
|
||||||
|
raise OpenSSL::Error.new("ec_key_new_by_curve_name") if key.null?
|
||||||
|
LibSSL.ssl_ctx_set_tmp_ecdh(@handle, key)
|
||||||
|
LibCrypto.ec_key_free(key)
|
||||||
|
end
|
||||||
|
|
||||||
|
# Returns the current modes set on the TLS context.
|
||||||
|
def modes
|
||||||
|
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_get_mode(@handle)
|
||||||
|
end
|
||||||
|
|
||||||
|
# Adds modes to the TLS context.
|
||||||
|
def add_modes(mode : OpenSSL::SSL::Modes)
|
||||||
|
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_set_mode(@handle, mode)
|
||||||
|
end
|
||||||
|
|
||||||
|
# Removes modes from the TLS context.
|
||||||
|
def remove_modes(mode : OpenSSL::SSL::Modes)
|
||||||
|
OpenSSL::SSL::Modes.new LibSSL.ssl_ctx_clear_mode(@handle, mode)
|
||||||
|
end
|
||||||
|
|
||||||
|
# Returns the current options set on the TLS context.
|
||||||
|
def options
|
||||||
|
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_get_options(@handle)
|
||||||
|
end
|
||||||
|
|
||||||
|
def add_options(options : OpenSSL::SSL::Options)
|
||||||
|
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_set_options(@handle, options)
|
||||||
|
end
|
||||||
|
|
||||||
|
def remove_options(options : OpenSSL::SSL::Options)
|
||||||
|
OpenSSL::SSL::Options.new LibSSL.ssl_ctx_clear_options(@handle, options)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
abstract class OpenSSL::SSL::Socket < IO
|
abstract class OpenSSL::SSL::Socket < IO
|
||||||
class Client < Socket
|
class Client < Socket
|
||||||
def initialize(io, context : Context::Client = Context::Client.new, sync_close : Bool = false, hostname : String? = nil)
|
def initialize(io, context : Context::Client = Context::Client.new, sync_close : Bool = false, hostname : String? = nil)
|
||||||
|
|
Loading…
Reference in a new issue