Compare commits
7 Commits
90a8efea71
...
885b9c7892
Author | SHA1 | Date |
---|---|---|
_ | 885b9c7892 | |
_ | 2930213398 | |
_ | 099e0fe884 | |
_ | 3df6f22a98 | |
_ | 4658bc0570 | |
_ | b104245c90 | |
_ | 76c6ace8a5 |
|
@ -6,6 +6,7 @@
|
||||||
/ptth_relay.toml
|
/ptth_relay.toml
|
||||||
/ptth_build_L6KLMVS6/
|
/ptth_build_L6KLMVS6/
|
||||||
/ptth_server_build_BIHWLQXQ/
|
/ptth_server_build_BIHWLQXQ/
|
||||||
|
/scope/untracked
|
||||||
/scraper-secret.txt
|
/scraper-secret.txt
|
||||||
/target
|
/target
|
||||||
|
|
||||||
|
|
|
@ -510,6 +510,15 @@ dependencies = [
|
||||||
"slab",
|
"slab",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "fxhash"
|
||||||
|
version = "0.2.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "c31b6d751ae2c7f11320402d34e41349dd1016f8d5d45e48c4312bc8625af50c"
|
||||||
|
dependencies = [
|
||||||
|
"byteorder",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "generic-array"
|
name = "generic-array"
|
||||||
version = "0.12.4"
|
version = "0.12.4"
|
||||||
|
@ -1241,8 +1250,8 @@ dependencies = [
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"hex",
|
"hex",
|
||||||
"ptth_file_server",
|
"ptth_file_server",
|
||||||
|
"ptth_quic",
|
||||||
"ptth_server",
|
"ptth_server",
|
||||||
"quic_demo",
|
|
||||||
"rand",
|
"rand",
|
||||||
"reqwest",
|
"reqwest",
|
||||||
"rusty_ulid",
|
"rusty_ulid",
|
||||||
|
@ -1252,6 +1261,27 @@ dependencies = [
|
||||||
"tracing-subscriber",
|
"tracing-subscriber",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "ptth_quic"
|
||||||
|
version = "0.1.0"
|
||||||
|
dependencies = [
|
||||||
|
"anyhow",
|
||||||
|
"base64",
|
||||||
|
"ctrlc",
|
||||||
|
"futures-util",
|
||||||
|
"hyper",
|
||||||
|
"quinn 0.8.5",
|
||||||
|
"rand",
|
||||||
|
"rcgen",
|
||||||
|
"reqwest",
|
||||||
|
"rmp-serde",
|
||||||
|
"rustls 0.20.4",
|
||||||
|
"structopt",
|
||||||
|
"tokio",
|
||||||
|
"tracing",
|
||||||
|
"tracing-subscriber",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ptth_quic_client_gui"
|
name = "ptth_quic_client_gui"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
|
@ -1259,8 +1289,8 @@ dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"blake3",
|
"blake3",
|
||||||
"fltk",
|
"fltk",
|
||||||
"quic_demo",
|
"ptth_quic",
|
||||||
"quinn",
|
"quinn 0.7.2",
|
||||||
"rand",
|
"rand",
|
||||||
"rand_chacha",
|
"rand_chacha",
|
||||||
"reqwest",
|
"reqwest",
|
||||||
|
@ -1379,26 +1409,6 @@ dependencies = [
|
||||||
"unicase",
|
"unicase",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "quic_demo"
|
|
||||||
version = "0.1.0"
|
|
||||||
dependencies = [
|
|
||||||
"anyhow",
|
|
||||||
"base64",
|
|
||||||
"ctrlc",
|
|
||||||
"futures-util",
|
|
||||||
"hyper",
|
|
||||||
"quinn",
|
|
||||||
"rand",
|
|
||||||
"rcgen",
|
|
||||||
"reqwest",
|
|
||||||
"rmp-serde",
|
|
||||||
"structopt",
|
|
||||||
"tokio",
|
|
||||||
"tracing",
|
|
||||||
"tracing-subscriber",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "quick-error"
|
name = "quick-error"
|
||||||
version = "2.0.1"
|
version = "2.0.1"
|
||||||
|
@ -1416,7 +1426,7 @@ dependencies = [
|
||||||
"lazy_static",
|
"lazy_static",
|
||||||
"libc",
|
"libc",
|
||||||
"mio 0.7.13",
|
"mio 0.7.13",
|
||||||
"quinn-proto",
|
"quinn-proto 0.7.3",
|
||||||
"rustls 0.19.1",
|
"rustls 0.19.1",
|
||||||
"socket2 0.3.19",
|
"socket2 0.3.19",
|
||||||
"thiserror",
|
"thiserror",
|
||||||
|
@ -1425,6 +1435,25 @@ dependencies = [
|
||||||
"webpki 0.21.4",
|
"webpki 0.21.4",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "quinn"
|
||||||
|
version = "0.8.5"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "5b435e71d9bfa0d8889927231970c51fb89c58fa63bffcab117c9c7a41e5ef8f"
|
||||||
|
dependencies = [
|
||||||
|
"bytes",
|
||||||
|
"futures-channel",
|
||||||
|
"futures-util",
|
||||||
|
"fxhash",
|
||||||
|
"quinn-proto 0.8.4",
|
||||||
|
"quinn-udp",
|
||||||
|
"rustls 0.20.4",
|
||||||
|
"thiserror",
|
||||||
|
"tokio",
|
||||||
|
"tracing",
|
||||||
|
"webpki 0.22.0",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "quinn-proto"
|
name = "quinn-proto"
|
||||||
version = "0.7.3"
|
version = "0.7.3"
|
||||||
|
@ -1436,7 +1465,7 @@ dependencies = [
|
||||||
"rand",
|
"rand",
|
||||||
"ring",
|
"ring",
|
||||||
"rustls 0.19.1",
|
"rustls 0.19.1",
|
||||||
"rustls-native-certs",
|
"rustls-native-certs 0.5.0",
|
||||||
"slab",
|
"slab",
|
||||||
"thiserror",
|
"thiserror",
|
||||||
"tinyvec",
|
"tinyvec",
|
||||||
|
@ -1444,6 +1473,40 @@ dependencies = [
|
||||||
"webpki 0.21.4",
|
"webpki 0.21.4",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "quinn-proto"
|
||||||
|
version = "0.8.4"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "3fce546b9688f767a57530652488420d419a8b1f44a478b451c3d1ab6d992a55"
|
||||||
|
dependencies = [
|
||||||
|
"bytes",
|
||||||
|
"fxhash",
|
||||||
|
"rand",
|
||||||
|
"ring",
|
||||||
|
"rustls 0.20.4",
|
||||||
|
"rustls-native-certs 0.6.2",
|
||||||
|
"rustls-pemfile 0.2.1",
|
||||||
|
"slab",
|
||||||
|
"thiserror",
|
||||||
|
"tinyvec",
|
||||||
|
"tracing",
|
||||||
|
"webpki 0.22.0",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "quinn-udp"
|
||||||
|
version = "0.1.3"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "9f832d8958db3e84d2ec93b5eb2272b45aa23cf7f8fe6e79f578896f4e6c231b"
|
||||||
|
dependencies = [
|
||||||
|
"futures-util",
|
||||||
|
"libc",
|
||||||
|
"quinn-proto 0.8.4",
|
||||||
|
"socket2 0.4.4",
|
||||||
|
"tokio",
|
||||||
|
"tracing",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "quote"
|
name = "quote"
|
||||||
version = "1.0.9"
|
version = "1.0.9"
|
||||||
|
@ -1575,7 +1638,7 @@ dependencies = [
|
||||||
"percent-encoding",
|
"percent-encoding",
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
"rustls 0.20.4",
|
"rustls 0.20.4",
|
||||||
"rustls-pemfile",
|
"rustls-pemfile 0.3.0",
|
||||||
"serde",
|
"serde",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
"serde_urlencoded",
|
"serde_urlencoded",
|
||||||
|
@ -1698,6 +1761,27 @@ dependencies = [
|
||||||
"security-framework",
|
"security-framework",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "rustls-native-certs"
|
||||||
|
version = "0.6.2"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "0167bac7a9f490495f3c33013e7722b53cb087ecbe082fb0c6387c96f634ea50"
|
||||||
|
dependencies = [
|
||||||
|
"openssl-probe",
|
||||||
|
"rustls-pemfile 1.0.1",
|
||||||
|
"schannel",
|
||||||
|
"security-framework",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "rustls-pemfile"
|
||||||
|
version = "0.2.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "5eebeaeb360c87bfb72e84abdb3447159c0eaececf1bef2aecd65a8be949d1c9"
|
||||||
|
dependencies = [
|
||||||
|
"base64",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "rustls-pemfile"
|
name = "rustls-pemfile"
|
||||||
version = "0.3.0"
|
version = "0.3.0"
|
||||||
|
@ -1707,6 +1791,15 @@ dependencies = [
|
||||||
"base64",
|
"base64",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "rustls-pemfile"
|
||||||
|
version = "1.0.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "0864aeff53f8c05aa08d86e5ef839d3dfcf07aeba2db32f12db0ef716e87bd55"
|
||||||
|
dependencies = [
|
||||||
|
"base64",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "rusty_ulid"
|
name = "rusty_ulid"
|
||||||
version = "0.10.1"
|
version = "0.10.1"
|
||||||
|
|
|
@ -46,6 +46,5 @@ chrono = {version = "0.4.19", features = ["serde"]}
|
||||||
|
|
||||||
members = [
|
members = [
|
||||||
"crates/*",
|
"crates/*",
|
||||||
"prototypes/*",
|
|
||||||
"tools/*",
|
"tools/*",
|
||||||
]
|
]
|
||||||
|
|
|
@ -20,7 +20,7 @@ cargo new --bin crates/ptth_server && \
|
||||||
cargo new --bin crates/ptth_file_server_bin && \
|
cargo new --bin crates/ptth_file_server_bin && \
|
||||||
cargo new --bin tools/ptth_tail && \
|
cargo new --bin tools/ptth_tail && \
|
||||||
cargo new --bin crates/debug_proxy && \
|
cargo new --bin crates/debug_proxy && \
|
||||||
cargo new --bin prototypes/quic_demo
|
cargo new --bin crates/ptth_quic
|
||||||
|
|
||||||
# copy over your manifests
|
# copy over your manifests
|
||||||
COPY ./Cargo.lock ./
|
COPY ./Cargo.lock ./
|
||||||
|
@ -28,7 +28,7 @@ COPY ./Cargo.toml ./
|
||||||
COPY ./crates/always_equal/Cargo.toml ./crates/always_equal/
|
COPY ./crates/always_equal/Cargo.toml ./crates/always_equal/
|
||||||
COPY ./crates/ptth_core/Cargo.toml ./crates/ptth_core/
|
COPY ./crates/ptth_core/Cargo.toml ./crates/ptth_core/
|
||||||
COPY ./crates/ptth_relay/Cargo.toml ./crates/ptth_relay/
|
COPY ./crates/ptth_relay/Cargo.toml ./crates/ptth_relay/
|
||||||
COPY ./prototypes/quic_demo/Cargo.toml ./prototypes/quic_demo/
|
COPY ./crates/ptth_quic/Cargo.toml ./crates/ptth_quic/
|
||||||
|
|
||||||
# this build step will cache your dependencies
|
# this build step will cache your dependencies
|
||||||
RUN cargo build --release -p ptth_relay
|
RUN cargo build --release -p ptth_relay
|
||||||
|
@ -39,7 +39,7 @@ src/*.rs \
|
||||||
crates/always_equal/src/*.rs \
|
crates/always_equal/src/*.rs \
|
||||||
crates/ptth_core/src/*.rs \
|
crates/ptth_core/src/*.rs \
|
||||||
crates/ptth_relay/src/*.rs \
|
crates/ptth_relay/src/*.rs \
|
||||||
prototypes/quic_demo/src/*.rs
|
crates/ptth_quic/src/*.rs
|
||||||
|
|
||||||
# Copy source tree
|
# Copy source tree
|
||||||
# Yes, I tried a few variations on the syntax. Dockerfiles are just rough.
|
# Yes, I tried a few variations on the syntax. Dockerfiles are just rough.
|
||||||
|
@ -49,7 +49,7 @@ COPY ./crates/always_equal ./crates/always_equal
|
||||||
COPY ./crates/ptth_core ./crates/ptth_core
|
COPY ./crates/ptth_core ./crates/ptth_core
|
||||||
COPY ./crates/ptth_relay ./crates/ptth_relay
|
COPY ./crates/ptth_relay ./crates/ptth_relay
|
||||||
COPY ./handlebars/ ./handlebars
|
COPY ./handlebars/ ./handlebars
|
||||||
COPY ./prototypes/quic_demo ./prototypes/quic_demo
|
COPY ./crates/ptth_quic ./crates/ptth_quic
|
||||||
|
|
||||||
# Bug in cargo's incremental build logic, triggered by
|
# Bug in cargo's incremental build logic, triggered by
|
||||||
# Docker doing something funny with mtimes? Maybe?
|
# Docker doing something funny with mtimes? Maybe?
|
||||||
|
|
|
@ -18,7 +18,7 @@ futures-util = "0.3.9"
|
||||||
hex = "0.4.3"
|
hex = "0.4.3"
|
||||||
ptth_file_server = { path = "../ptth_file_server_bin" }
|
ptth_file_server = { path = "../ptth_file_server_bin" }
|
||||||
ptth_server = { path = "../ptth_server" }
|
ptth_server = { path = "../ptth_server" }
|
||||||
quic_demo = { path = "../../prototypes/quic_demo" }
|
ptth_quic = { path = "../ptth_quic" }
|
||||||
rand = "0.8.4"
|
rand = "0.8.4"
|
||||||
rusty_ulid = "0.10.1"
|
rusty_ulid = "0.10.1"
|
||||||
sha2 = "0.9.8"
|
sha2 = "0.9.8"
|
||||||
|
|
|
@ -43,7 +43,7 @@ async fn main () -> anyhow::Result <()> {
|
||||||
shutdown_tx.send (true).expect ("Couldn't forward Ctrl+C signal");
|
shutdown_tx.send (true).expect ("Couldn't forward Ctrl+C signal");
|
||||||
})?;
|
})?;
|
||||||
tracing::trace! ("Set Ctrl+C handler");
|
tracing::trace! ("Set Ctrl+C handler");
|
||||||
quic_demo::executable_end_server::main (args, Some (shutdown_rx)).await?;
|
ptth_quic::executable_end_server::main (args, Some (shutdown_rx)).await?;
|
||||||
|
|
||||||
Ok (())
|
Ok (())
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
[package]
|
[package]
|
||||||
name = "quic_demo"
|
name = "ptth_quic"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
authors = ["Trish"]
|
authors = ["Trish"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
|
@ -14,10 +14,11 @@ ctrlc = "3.2.1"
|
||||||
# fltk = "1.1.1"
|
# fltk = "1.1.1"
|
||||||
futures-util = "0.3.9"
|
futures-util = "0.3.9"
|
||||||
hyper = { version = "0.14.4", features = ["http1", "server", "stream", "tcp"] }
|
hyper = { version = "0.14.4", features = ["http1", "server", "stream", "tcp"] }
|
||||||
quinn = "0.7.2"
|
quinn = "0.8.5"
|
||||||
rand = "0.8.4"
|
rand = "0.8.4"
|
||||||
rcgen = "0.8.11"
|
rcgen = "0.8.11"
|
||||||
rmp-serde = "0.15.5"
|
rmp-serde = "0.15.5"
|
||||||
|
rustls = "0.20.4"
|
||||||
structopt = "0.3.20"
|
structopt = "0.3.20"
|
||||||
tokio = { version = "1.8.1", features = ["full"] }
|
tokio = { version = "1.8.1", features = ["full"] }
|
||||||
tracing-subscriber = "0.2.16"
|
tracing-subscriber = "0.2.16"
|
|
@ -1,8 +1,8 @@
|
||||||
# https://whitfin.io/speeding-up-rust-docker-builds/
|
# https://whitfin.io/speeding-up-rust-docker-builds/
|
||||||
# TODO: https://stackoverflow.com/questions/57389547/how-to-define-the-context-for-a-docker-build-as-a-specific-commit-on-one-of-the
|
# TODO: https://stackoverflow.com/questions/57389547/how-to-define-the-context-for-a-docker-build-as-a-specific-commit-on-one-of-the
|
||||||
|
|
||||||
# rust:1.50-slim-buster
|
# rust:1.64-slim-buster
|
||||||
FROM rust@sha256:5dd85eb0c60bbdea14a6ecba1f6fe4a0f5c878bcf06d2cdfae0aff3a19ed4b10 as build
|
FROM rust@sha256:7da4fbd2dc7176746e8e5c371aeb0bbe742598c4906fa48cb2d87a4b89d50357 as build
|
||||||
|
|
||||||
WORKDIR /
|
WORKDIR /
|
||||||
ENV USER root
|
ENV USER root
|
||||||
|
@ -20,7 +20,7 @@ cargo new --bin crates/ptth_server && \
|
||||||
cargo new --bin crates/ptth_file_server_bin && \
|
cargo new --bin crates/ptth_file_server_bin && \
|
||||||
cargo new --bin tools/ptth_tail && \
|
cargo new --bin tools/ptth_tail && \
|
||||||
cargo new --bin crates/debug_proxy && \
|
cargo new --bin crates/debug_proxy && \
|
||||||
cargo new --bin prototypes/quic_demo
|
cargo new --bin crates/ptth_quic
|
||||||
|
|
||||||
# copy over your manifests
|
# copy over your manifests
|
||||||
COPY ./Cargo.lock ./
|
COPY ./Cargo.lock ./
|
||||||
|
@ -28,10 +28,10 @@ COPY ./Cargo.toml ./
|
||||||
COPY ./crates/always_equal/Cargo.toml ./crates/always_equal/
|
COPY ./crates/always_equal/Cargo.toml ./crates/always_equal/
|
||||||
COPY ./crates/ptth_core/Cargo.toml ./crates/ptth_core/
|
COPY ./crates/ptth_core/Cargo.toml ./crates/ptth_core/
|
||||||
COPY ./crates/ptth_relay/Cargo.toml ./crates/ptth_relay/
|
COPY ./crates/ptth_relay/Cargo.toml ./crates/ptth_relay/
|
||||||
COPY ./prototypes/quic_demo/Cargo.toml ./prototypes/quic_demo/
|
COPY ./crates/ptth_quic/Cargo.toml ./crates/ptth_quic/
|
||||||
|
|
||||||
# this build step will cache your dependencies
|
# this build step will cache your dependencies
|
||||||
RUN cargo build --release -p quic_demo
|
RUN cargo build --release -p ptth_quic
|
||||||
|
|
||||||
RUN \
|
RUN \
|
||||||
rm \
|
rm \
|
||||||
|
@ -39,7 +39,7 @@ src/*.rs \
|
||||||
crates/always_equal/src/*.rs \
|
crates/always_equal/src/*.rs \
|
||||||
crates/ptth_core/src/*.rs \
|
crates/ptth_core/src/*.rs \
|
||||||
crates/ptth_relay/src/*.rs \
|
crates/ptth_relay/src/*.rs \
|
||||||
prototypes/quic_demo/src/*.rs
|
crates/ptth_quic/src/*.rs
|
||||||
|
|
||||||
# Copy source tree
|
# Copy source tree
|
||||||
# Yes, I tried a few variations on the syntax. Dockerfiles are just rough.
|
# Yes, I tried a few variations on the syntax. Dockerfiles are just rough.
|
||||||
|
@ -49,7 +49,7 @@ COPY ./crates/always_equal ./crates/always_equal
|
||||||
COPY ./crates/ptth_core ./crates/ptth_core
|
COPY ./crates/ptth_core ./crates/ptth_core
|
||||||
COPY ./crates/ptth_relay ./crates/ptth_relay
|
COPY ./crates/ptth_relay ./crates/ptth_relay
|
||||||
COPY ./handlebars/ ./handlebars
|
COPY ./handlebars/ ./handlebars
|
||||||
COPY ./prototypes/quic_demo ./prototypes/quic_demo
|
COPY ./crates/ptth_quic ./crates/ptth_quic
|
||||||
|
|
||||||
# Bug in cargo's incremental build logic, triggered by
|
# Bug in cargo's incremental build logic, triggered by
|
||||||
# Docker doing something funny with mtimes? Maybe?
|
# Docker doing something funny with mtimes? Maybe?
|
||||||
|
@ -58,8 +58,8 @@ RUN touch crates/ptth_core/src/lib.rs
|
||||||
# build for release
|
# build for release
|
||||||
# gate only on ptth_relay tests for now
|
# gate only on ptth_relay tests for now
|
||||||
RUN \
|
RUN \
|
||||||
cargo build --release -p quic_demo --bin quic_demo_relay_server && \
|
cargo build --release -p ptth_quic --bin ptth_quic_relay_server && \
|
||||||
cargo test --release -p quic_demo --bin quic_demo_relay_server
|
cargo test --release -p ptth_quic --bin ptth_quic_relay_server
|
||||||
|
|
||||||
# debian:buster-slim
|
# debian:buster-slim
|
||||||
FROM debian@sha256:13f0764262a064b2dd9f8a828bbaab29bdb1a1a0ac6adc8610a0a5f37e514955
|
FROM debian@sha256:13f0764262a064b2dd9f8a828bbaab29bdb1a1a0ac6adc8610a0a5f37e514955
|
||||||
|
@ -73,11 +73,11 @@ RUN addgroup --gid 10001 ptth_user && adduser --system --uid 10000 --gid 10001 p
|
||||||
USER ptth_user
|
USER ptth_user
|
||||||
WORKDIR /home/ptth_user
|
WORKDIR /home/ptth_user
|
||||||
|
|
||||||
COPY --from=build /ptth/target/release/quic_demo_relay_server ./
|
COPY --from=build /ptth/target/release/ptth_quic_relay_server ./
|
||||||
|
|
||||||
ARG git_version
|
ARG git_version
|
||||||
RUN \
|
RUN \
|
||||||
echo -n "$git_version" > ./git_version.txt && \
|
echo -n "$git_version" > ./git_version.txt && \
|
||||||
ln -s quic_demo_relay_server app
|
ln -s ptth_quic_relay_server app
|
||||||
|
|
||||||
CMD ["/usr/bin/tini", "--", "./quic_demo_relay_server"]
|
CMD ["/usr/bin/tini", "--", "./ptth_quic_relay_server"]
|
|
@ -3,9 +3,9 @@
|
||||||
There are 5 processes, so you'll need 5 terminal windows or screen / tmux
|
There are 5 processes, so you'll need 5 terminal windows or screen / tmux
|
||||||
sessions. Run the processes in this order:
|
sessions. Run the processes in this order:
|
||||||
|
|
||||||
1. QUIC relay server: `RUST_LOG=quic_demo_relay_server=debug cargo run --bin quic_demo_relay_server`
|
1. QUIC relay server: `RUST_LOG=ptth_quic_relay_server=debug cargo run --bin ptth_quic_relay_server`
|
||||||
2. Server-side proxy: `RUST_LOG=quic_demo_end_server=debug cargo run --bin quic_demo_end_server`
|
2. Server-side proxy: `RUST_LOG=ptth_quic_end_server=debug cargo run --bin ptth_quic_end_server`
|
||||||
3. Client-side proxy: `RUST_LOG=quic_demo_client cargo run --bin quic_demo_client`
|
3. Client-side proxy: `RUST_LOG=ptth_quic_client cargo run --bin ptth_quic_client`
|
||||||
4. TCP end server: `nc -l -p 30382`
|
4. TCP end server: `nc -l -p 30382`
|
||||||
5. TCP end client: `nc 127.0.0.1 30381`
|
5. TCP end client: `nc 127.0.0.1 30381`
|
||||||
|
|
|
@ -1,4 +1,5 @@
|
||||||
#!/usr/bin/env bash
|
#!/usr/bin/env bash
|
||||||
|
# Run from `ptth/`
|
||||||
|
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
|
|
||||||
|
@ -8,14 +9,12 @@ DOCKER_TAG="ptth_quic:latest"
|
||||||
|
|
||||||
mkdir -p app_packages
|
mkdir -p app_packages
|
||||||
|
|
||||||
pushd ../../
|
git archive --format=tar "$GIT_COMMIT" | docker build -f crates/ptth_quic/Dockerfile -t "$DOCKER_TAG" --build-arg "git_version=$GIT_COMMIT" -
|
||||||
git archive --format=tar "$GIT_COMMIT" | sudo docker build -f prototypes/quic_demo/Dockerfile -t "$DOCKER_TAG" --build-arg "git_version=$GIT_COMMIT" -
|
|
||||||
popd
|
|
||||||
|
|
||||||
sudo docker run --rm "$DOCKER_TAG" \
|
docker run --rm "$DOCKER_TAG" \
|
||||||
tar -c \
|
tar -c \
|
||||||
app \
|
app \
|
||||||
quic_demo_relay_server \
|
ptth_quic_relay_server \
|
||||||
| gzip > "app_packages/ptth_quic_relay_$GIT_COMMIT_SHORT.tar.gz"
|
| gzip > "app_packages/ptth_quic_relay_$GIT_COMMIT_SHORT.tar.gz"
|
||||||
|
|
||||||
# sudo docker build -f app_package_Dockerfile -t ptth_app_host:latest .
|
# sudo docker build -f app_package_Dockerfile -t ptth_app_host:latest .
|
|
@ -4,7 +4,7 @@ use tokio::{
|
||||||
sync::watch,
|
sync::watch,
|
||||||
};
|
};
|
||||||
|
|
||||||
use quic_demo::{
|
use ptth_quic::{
|
||||||
client_proxy::{
|
client_proxy::{
|
||||||
ForwardingParams,
|
ForwardingParams,
|
||||||
forward_port,
|
forward_port,
|
||||||
|
@ -64,7 +64,7 @@ impl P2Client {
|
||||||
let quinn::NewConnection {
|
let quinn::NewConnection {
|
||||||
connection,
|
connection,
|
||||||
..
|
..
|
||||||
} = protocol::p2_connect_to_p3 (&self.endpoint, &conf.relay_addr, &conf.client_id).await?;
|
} = protocol::p2_connect_to_p3 (&self.endpoint, conf.relay_addr, &conf.client_id).await?;
|
||||||
|
|
||||||
let client_tcp_port = conf.client_tcp_port;
|
let client_tcp_port = conf.client_tcp_port;
|
||||||
|
|
|
@ -4,7 +4,7 @@ use std::{
|
||||||
|
|
||||||
use tokio::sync::watch;
|
use tokio::sync::watch;
|
||||||
|
|
||||||
use quic_demo::prelude::*;
|
use ptth_quic::prelude::*;
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main () -> anyhow::Result <()> {
|
async fn main () -> anyhow::Result <()> {
|
||||||
|
@ -19,5 +19,5 @@ async fn main () -> anyhow::Result <()> {
|
||||||
})?;
|
})?;
|
||||||
trace! ("Set Ctrl+C handler");
|
trace! ("Set Ctrl+C handler");
|
||||||
|
|
||||||
quic_demo::executable_end_server::main (&args, Some (shutdown_rx)).await
|
ptth_quic::executable_end_server::main (&args, Some (shutdown_rx)).await
|
||||||
}
|
}
|
|
@ -15,7 +15,7 @@ use tokio::{
|
||||||
sync::watch,
|
sync::watch,
|
||||||
};
|
};
|
||||||
|
|
||||||
use quic_demo::prelude::*;
|
use ptth_quic::prelude::*;
|
||||||
use protocol::PeerId;
|
use protocol::PeerId;
|
||||||
|
|
||||||
#[derive (Debug, StructOpt)]
|
#[derive (Debug, StructOpt)]
|
||||||
|
@ -75,7 +75,7 @@ async fn main () -> anyhow::Result <()> {
|
||||||
|
|
||||||
match handle_quic_connection (Arc::clone (&relay_state), conn).await {
|
match handle_quic_connection (Arc::clone (&relay_state), conn).await {
|
||||||
Ok (_) => (),
|
Ok (_) => (),
|
||||||
Err (e) => warn! ("handle_quic_connection {:?}", e),
|
Err (e) => warn! ("handle_quic_connection `{:?}`", e),
|
||||||
}
|
}
|
||||||
|
|
||||||
let active = relay_state.stats.quic.disconnect ();
|
let active = relay_state.stats.quic.disconnect ();
|
||||||
|
@ -320,13 +320,15 @@ async fn handle_quic_connection (
|
||||||
|
|
||||||
match peer {
|
match peer {
|
||||||
protocol::P3Peer::P2ClientProxy (peer) => {
|
protocol::P3Peer::P2ClientProxy (peer) => {
|
||||||
|
trace! ("Accepting connection from P2 client");
|
||||||
// TODO: Check authorization for P2 peers
|
// TODO: Check authorization for P2 peers
|
||||||
|
|
||||||
protocol::p3_authorize_p2_peer (&mut send).await?;
|
protocol::p3_authorize_p2_peer (&mut send).await?;
|
||||||
handle_p2_connection (relay_state, conn, peer).await?;
|
handle_p2_connection (relay_state, conn, peer).await?;
|
||||||
},
|
},
|
||||||
protocol::P3Peer::P4ServerProxy (peer) => {
|
protocol::P3Peer::P4ServerProxy (peer) => {
|
||||||
// TODO: Check authorization for P2 peers
|
trace! ("Accepting connection from P4 end server");
|
||||||
|
// TODO: Check authorization for P4 peers
|
||||||
|
|
||||||
protocol::p3_authorize_p4_peer (&mut send).await?;
|
protocol::p3_authorize_p4_peer (&mut send).await?;
|
||||||
handle_p4_connection (relay_state, conn, peer).await?;
|
handle_p4_connection (relay_state, conn, peer).await?;
|
|
@ -22,6 +22,7 @@ struct Opt {
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn main (args: &[OsString], shutdown_rx: Option <watch::Receiver <bool>>) -> anyhow::Result <()> {
|
pub async fn main (args: &[OsString], shutdown_rx: Option <watch::Receiver <bool>>) -> anyhow::Result <()> {
|
||||||
|
trace! ("executable_end_server::main");
|
||||||
let opt = Opt::from_iter (args);
|
let opt = Opt::from_iter (args);
|
||||||
let conf = opt.into_config ().await?;
|
let conf = opt.into_config ().await?;
|
||||||
|
|
||||||
|
@ -119,7 +120,7 @@ impl P4EndServer {
|
||||||
..
|
..
|
||||||
} = protocol::p4_connect_to_p3 (
|
} = protocol::p4_connect_to_p3 (
|
||||||
&self.endpoint,
|
&self.endpoint,
|
||||||
&self.conf.relay_addr,
|
self.conf.relay_addr,
|
||||||
&self.conf.id
|
&self.conf.id
|
||||||
).await?;
|
).await?;
|
||||||
|
|
|
@ -31,7 +31,7 @@ impl Command {
|
||||||
|
|
||||||
pub async fn p2_connect_to_p3 (
|
pub async fn p2_connect_to_p3 (
|
||||||
endpoint: &quinn::Endpoint,
|
endpoint: &quinn::Endpoint,
|
||||||
relay_addr: &std::net::SocketAddr,
|
relay_addr: std::net::SocketAddr,
|
||||||
client_id: &str,
|
client_id: &str,
|
||||||
) -> Result <quinn::NewConnection>
|
) -> Result <quinn::NewConnection>
|
||||||
{
|
{
|
||||||
|
@ -249,7 +249,7 @@ pub async fn p3_authorize_p2_to_p4_direc (
|
||||||
|
|
||||||
pub async fn p4_connect_to_p3 (
|
pub async fn p4_connect_to_p3 (
|
||||||
endpoint: &quinn::Endpoint,
|
endpoint: &quinn::Endpoint,
|
||||||
relay_addr: &std::net::SocketAddr,
|
relay_addr: std::net::SocketAddr,
|
||||||
server_id: &str,
|
server_id: &str,
|
||||||
) -> Result <quinn::NewConnection>
|
) -> Result <quinn::NewConnection>
|
||||||
{
|
{
|
|
@ -8,8 +8,8 @@ use std::{
|
||||||
};
|
};
|
||||||
|
|
||||||
use quinn::{
|
use quinn::{
|
||||||
Certificate, CertificateChain, ClientConfig, ClientConfigBuilder, Endpoint, Incoming,
|
ClientConfig, Endpoint, Incoming,
|
||||||
PrivateKey, ServerConfig, ServerConfigBuilder, TransportConfig,
|
ServerConfig, TransportConfig,
|
||||||
};
|
};
|
||||||
|
|
||||||
/// Constructs a QUIC endpoint configured for use a client only.
|
/// Constructs a QUIC endpoint configured for use a client only.
|
||||||
|
@ -28,9 +28,8 @@ pub fn make_client_endpoint(
|
||||||
|
|
||||||
client_cfg.transport = Arc::new (transport);
|
client_cfg.transport = Arc::new (transport);
|
||||||
|
|
||||||
let mut endpoint_builder = Endpoint::builder ();
|
let mut endpoint = Endpoint::client (bind_addr)?;
|
||||||
endpoint_builder.default_client_config (client_cfg);
|
endpoint.set_default_client_config (client_cfg);
|
||||||
let (endpoint, _incoming) = endpoint_builder.bind(&bind_addr)?;
|
|
||||||
Ok(endpoint)
|
Ok(endpoint)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -44,9 +43,7 @@ pub fn make_client_endpoint(
|
||||||
#[allow(unused)]
|
#[allow(unused)]
|
||||||
pub fn make_server_endpoint(bind_addr: SocketAddr) -> anyhow::Result<(Incoming, Vec<u8>)> {
|
pub fn make_server_endpoint(bind_addr: SocketAddr) -> anyhow::Result<(Incoming, Vec<u8>)> {
|
||||||
let (server_config, server_cert) = configure_server()?;
|
let (server_config, server_cert) = configure_server()?;
|
||||||
let mut endpoint_builder = Endpoint::builder();
|
let (_endpoint, incoming) = Endpoint::server (server_config, bind_addr)?;
|
||||||
endpoint_builder.listen(server_config);
|
|
||||||
let (_endpoint, incoming) = endpoint_builder.bind(&bind_addr)?;
|
|
||||||
Ok((incoming, server_cert))
|
Ok((incoming, server_cert))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -55,29 +52,28 @@ pub fn make_server_endpoint(bind_addr: SocketAddr) -> anyhow::Result<(Incoming,
|
||||||
/// ## Args
|
/// ## Args
|
||||||
///
|
///
|
||||||
/// - server_certs: a list of trusted certificates in DER format.
|
/// - server_certs: a list of trusted certificates in DER format.
|
||||||
fn configure_client(server_certs: &[&[u8]]) -> anyhow::Result<ClientConfig> {
|
fn configure_client (server_certs: &[&[u8]]) -> anyhow::Result<ClientConfig> {
|
||||||
let mut cfg_builder = ClientConfigBuilder::default();
|
let mut certs = rustls::RootCertStore::empty ();
|
||||||
for cert in server_certs {
|
for cert in server_certs {
|
||||||
cfg_builder.add_certificate_authority(Certificate::from_der(cert)?)?;
|
certs.add (&rustls::Certificate (cert.to_vec ()))?;
|
||||||
}
|
}
|
||||||
Ok(cfg_builder.build())
|
|
||||||
|
Ok (ClientConfig::with_root_certificates (certs))
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Returns default server configuration along with its certificate.
|
/// Returns default server configuration along with its certificate.
|
||||||
#[allow(clippy::field_reassign_with_default)] // https://github.com/rust-lang/rust-clippy/issues/6527
|
#[allow(clippy::field_reassign_with_default)] // https://github.com/rust-lang/rust-clippy/issues/6527
|
||||||
fn configure_server() -> anyhow::Result<(ServerConfig, Vec<u8>)> {
|
fn configure_server () -> anyhow::Result<(ServerConfig, Vec<u8>)> {
|
||||||
let cert = rcgen::generate_simple_self_signed(vec!["localhost".into()]).unwrap();
|
let cert = rcgen::generate_simple_self_signed(vec!["localhost".into()]).unwrap();
|
||||||
let cert_der = cert.serialize_der().unwrap();
|
let cert_der = cert.serialize_der().unwrap();
|
||||||
let priv_key = cert.serialize_private_key_der();
|
let priv_key = cert.serialize_private_key_der();
|
||||||
let priv_key = PrivateKey::from_der(&priv_key)?;
|
let priv_key = rustls::PrivateKey (priv_key);
|
||||||
|
let cert_chain = vec! [rustls::Certificate (cert_der.clone ())];
|
||||||
let mut transport_config = TransportConfig::default();
|
|
||||||
transport_config.max_concurrent_uni_streams(0).unwrap();
|
let mut server_config = ServerConfig::with_single_cert (cert_chain, priv_key)?;
|
||||||
let mut server_config = ServerConfig::default();
|
Arc::get_mut (&mut server_config.transport)
|
||||||
server_config.transport = Arc::new(transport_config);
|
.unwrap ()
|
||||||
let mut cfg_builder = ServerConfigBuilder::new(server_config);
|
.max_concurrent_uni_streams (0_u8.into ());
|
||||||
let cert = Certificate::from_der(&cert_der)?;
|
|
||||||
cfg_builder.certificate(CertificateChain::from_certs(vec![cert]), priv_key)?;
|
Ok ((server_config, cert_der))
|
||||||
|
|
||||||
Ok((cfg_builder.build(), cert_der))
|
|
||||||
}
|
}
|
|
@ -11,7 +11,7 @@ license = "AGPL-3.0"
|
||||||
anyhow = "1.0.38"
|
anyhow = "1.0.38"
|
||||||
blake3 = "1.0.0"
|
blake3 = "1.0.0"
|
||||||
fltk = "1.2.8"
|
fltk = "1.2.8"
|
||||||
quic_demo = { path = "../quic_demo" }
|
ptth_quic = { path = "../ptth_quic" }
|
||||||
quinn = "0.7.2"
|
quinn = "0.7.2"
|
||||||
rand = "0.8.4"
|
rand = "0.8.4"
|
||||||
rand_chacha = "0.3.1"
|
rand_chacha = "0.3.1"
|
|
@ -19,7 +19,7 @@ use rand::{
|
||||||
use structopt::StructOpt;
|
use structopt::StructOpt;
|
||||||
use tokio::runtime::Runtime;
|
use tokio::runtime::Runtime;
|
||||||
|
|
||||||
use quic_demo::{
|
use ptth_quic::{
|
||||||
client_proxy::*,
|
client_proxy::*,
|
||||||
prelude::*,
|
prelude::*,
|
||||||
protocol::PeerId,
|
protocol::PeerId,
|
|
@ -2,12 +2,12 @@
|
||||||
|
|
||||||
## Initial setup
|
## Initial setup
|
||||||
|
|
||||||
- Open 3 terminals in `prototypes/quic_demo`
|
- Open 3 terminals in `crates/ptth_quic`
|
||||||
- Use `export RUST_LOG=quic_demo_relay_server=debug` to enable debug logging
|
- Use `export RUST_LOG=ptth_quic_relay_server=debug` to enable debug logging
|
||||||
for the terminal that will run the relay server (P3)
|
for the terminal that will run the relay server (P3)
|
||||||
- Use `export RUST_LOG=quic_demo_end_server=debug` for the terminal that
|
- Use `export RUST_LOG=ptth_quic=debug` for the terminal that
|
||||||
will run the end server (P4)
|
will run the end server (P4)
|
||||||
- Use `export RUST_LOG=quic_demo_client=debug` for the terminal that
|
- Use `export RUST_LOG=ptth_quic_client=debug` for the terminal that
|
||||||
will run the client (P2)
|
will run the client (P2)
|
||||||
|
|
||||||
When the relay server is running, use curl to get the list of connected
|
When the relay server is running, use curl to get the list of connected
|
||||||
|
@ -15,10 +15,10 @@ end servers: `curl 127.0.0.1:4004`
|
||||||
|
|
||||||
## Test loop - Happy path
|
## Test loop - Happy path
|
||||||
|
|
||||||
- Start a relay `cargo run --bin quic_demo_relay_server`
|
- Start a relay `cargo run --bin ptth_quic_relay_server`
|
||||||
- Verify that the relay has no end servers connected
|
- Verify that the relay has no end servers connected
|
||||||
- Start an end server `cargo run --bin quic_demo_end_server -- --debug-echo`
|
- Start an end server `cargo run --bin ptth_quic_end_server -- --debug-echo`
|
||||||
- Verify that the end server connected
|
- Verify that the end server connected
|
||||||
- Start a client `cargo run --bin quic_demo_client`
|
- Start a client `cargo run --bin ptth_quic_client`
|
||||||
- Connect to the client and verify that the debug echo server is running
|
- Connect to the client and verify that the debug echo server is running
|
||||||
`nc 127.0.0.1 30381`
|
`nc 127.0.0.1 30381`
|
||||||
|
|
Loading…
Reference in New Issue