YGGverse/ggemini
1
0
Fork 0
mirror of https://github.com/YGGverse/ggemini.git synced 2026-03-31 17:15:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add guest certificates validation

Browse source
This commit is contained in:
yggverse 2024-11-27 19:56:36 +02:00
parent c61164e666
commit b1b35e059b
1 changed files with 21 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/client.rs
View file

@ -12,10 +12,11 @@ pub use error::Error;
pub use response::Response; pub use response::Response;
use gio::{ use gio::{
prelude::{IOStreamExt, OutputStreamExt, SocketClientExt}, prelude::{IOStreamExt, OutputStreamExt, SocketClientExt, TlsConnectionExt},
Cancellable, SocketClient, SocketProtocol, TlsCertificate, Cancellable, SocketClient, SocketClientEvent, SocketProtocol, TlsCertificate,
TlsClientConnection,
}; };
use glib::{Bytes, Priority, Uri}; use glib::{object::Cast, Bytes, Priority, Uri};
pub const DEFAULT_TIMEOUT: u32 = 10; pub const DEFAULT_TIMEOUT: u32 = 10;
@ -28,11 +29,28 @@ impl Client {
/// Create new `Self` /// Create new `Self`
pub fn new() -> Self { pub fn new() -> Self {
// Init new socket
let socket = SocketClient::new(); let socket = SocketClient::new();
// Setup initial configuration for Gemini Protocol
socket.set_protocol(SocketProtocol::Tcp); socket.set_protocol(SocketProtocol::Tcp);
socket.set_timeout(DEFAULT_TIMEOUT); socket.set_timeout(DEFAULT_TIMEOUT);
// Connect events
socket.connect_event(move |_, event, _, stream| {
// This condition have effect only for guest TLS connections
// * for user certificates validation, use `Connection` impl
if event == SocketClientEvent::TlsHandshaking {
// Begin guest certificate validation
stream
.unwrap()
.dynamic_cast_ref::<TlsClientConnection>()
.unwrap()
.connect_accept_certificate(|_, _, _| true); // @TODO
}
});
// Done
Self { socket } Self { socket }
} }