From 9469ef10b673fc4623ace5bb06ee104122a3678c Mon Sep 17 00:00:00 2001 From: netadmin Date: Thu, 22 Oct 2026 20:45:13 +0300 Subject: [PATCH] version a0.0.1 --- .gitignore | 3 + Cargo.lock | 1935 +++++++++++++++++++++++++++++++++++++ Cargo.toml | 23 + Cargo.toml.bak | 23 + src-bak/main.rs | 179 ++++ src-bak/mdns.rs | 60 ++ src-bak/models.rs | 123 +++ src-bak/p2p.rs | 81 ++ src-bak/static/index.html | 261 +++++ src-bak/tls.rs | 138 +++ src-bak/ui.rs | 165 ++++ src/discovery.rs | 113 +++ src/main.rs | 180 ++++ src/mdns.rs | 60 ++ src/models.rs | 119 +++ src/p2p.rs | 91 ++ src/static/index.html | 293 ++++++ src/tls.rs | 215 +++++ src/ui.rs | 219 +++++ 19 files changed, 4281 insertions(+) create mode 100644 .gitignore create mode 100644 Cargo.lock create mode 100644 Cargo.toml create mode 100644 Cargo.toml.bak create mode 100644 src-bak/main.rs create mode 100644 src-bak/mdns.rs create mode 100644 src-bak/models.rs create mode 100644 src-bak/p2p.rs create mode 100644 src-bak/static/index.html create mode 100644 src-bak/tls.rs create mode 100644 src-bak/ui.rs create mode 100644 src/discovery.rs create mode 100644 src/main.rs create mode 100644 src/mdns.rs create mode 100644 src/models.rs create mode 100644 src/p2p.rs create mode 100644 src/static/index.html create mode 100644 src/tls.rs create mode 100644 src/ui.rs diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..42b9d94 --- /dev/null +++ b/.gitignore @@ -0,0 +1,3 @@ +/target +/received_media +Cargo.lock diff --git a/Cargo.lock b/Cargo.lock new file mode 100644 index 0000000..1352532 --- /dev/null +++ b/Cargo.lock @@ -0,0 +1,1935 @@ +# This file is automatically @generated by Cargo. +# It is not intended for manual editing. +version = 4 + +[[package]] +name = "arc-swap" +version = "1.9.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c049c0be4daef0b145cb3555416b3b8ef5b7888a38aea1a3a155801fe7b0810b" +dependencies = [ + "rustversion", +] + +[[package]] +name = "async-trait" +version = "0.1.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "82f6aeea286b8eb4dd3431a1be1b59d290ace00f5bfd8e2a159bc2a05e2c1667" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "atomic-waker" +version = "1.1.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1505bd5d3d116872e7271a6d4e16d81d0c8570876c8de68093a09ac269d8aac0" + +[[package]] +name = "autocfg" +version = "1.5.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f2032f911046de80f0a198e0901378627c33f59ea0ac00e363d481118bd70a53" + +[[package]] +name = "aws-lc-rs" +version = "1.18.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "faac5829c2b74c28f830747e7818ccfb684261b5f48a1118b1e2a13d36dfab13" +dependencies = [ + "aws-lc-sys", + "zeroize", +] + +[[package]] +name = "aws-lc-sys" +version = "0.46.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f1622d8446a2d4b2ce0c7eefc73dd43a99779028d5ee5c2dd8073a658ba8a2bc" +dependencies = [ + "cc", + "cmake", + "dunce", + "fs_extra", + "pkg-config", +] + +[[package]] +name = "axum" +version = "0.7.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "edca88bc138befd0323b20752846e6587272d3b03b0343c8ea28a6f819e6e71f" +dependencies = [ + "async-trait", + "axum-core", + "bytes", + "futures-util", + "http", + "http-body", + "http-body-util", + "hyper", + "hyper-util", + "itoa", + "matchit", + "memchr", + "mime", + "percent-encoding", + "pin-project-lite", + "rustversion", + "serde", + "serde_json", + "serde_path_to_error", + "serde_urlencoded", + "sync_wrapper", + "tokio", + "tower", + "tower-layer", + "tower-service", + "tracing", +] + +[[package]] +name = "axum-core" +version = "0.4.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "09f2bd6146b97ae3359fa0cc6d6b376d9539582c7b4220f041a33ec24c226199" +dependencies = [ + "async-trait", + "bytes", + "futures-util", + "http", + "http-body", + "http-body-util", + "mime", + "pin-project-lite", + "rustversion", + "sync_wrapper", + "tower-layer", + "tower-service", + "tracing", +] + +[[package]] +name = "axum-server" +version = "0.7.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c1ab4a3ec9ea8a657c72d99a03a824af695bd0fb5ec639ccbd9cd3543b41a5f9" +dependencies = [ + "arc-swap", + "bytes", + "fs-err", + "http", + "http-body", + "hyper", + "hyper-util", + "pin-project-lite", + "rustls", + "rustls-pemfile", + "rustls-pki-types", + "tokio", + "tokio-rustls", + "tower-service", +] + +[[package]] +name = "base64" +version = "0.22.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6" + +[[package]] +name = "base64" +version = "0.23.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ac07cdecf99051d9a5238b80f35af32cdeba5b336e55d957b318b50137e18da5" + +[[package]] +name = "bitflags" +version = "2.13.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3ded4057c258ba199e2d26386d3af3780957ecaee6c4ef4041c6b4b8b97c0b06" + +[[package]] +name = "block-buffer" +version = "0.10.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3078c7629b62d3f0439517fa394996acacc5cbc91c5a20d8c658e77abd503a71" +dependencies = [ + "generic-array", +] + +[[package]] +name = "bumpalo" +version = "3.20.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "72f5acc6cb2ba439de613abc23857ec3d78374d8ed5ac84e9d11336e87da8649" + +[[package]] +name = "byteorder" +version = "1.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b" + +[[package]] +name = "bytes" +version = "1.12.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fc652a48c352aef3ea3aed32080501cf3ef6ed5da78602a020c991775b0aff04" + +[[package]] +name = "cc" +version = "1.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6651c9ed80effdc7db0ff72512157f901af5e3549e341e24b1dd4887d836d838" +dependencies = [ + "find-msvc-tools", + "jobserver", + "libc", + "shlex", +] + +[[package]] +name = "cfg-if" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4e7648175b45a9a48536d676f68d918270699102aa8dab5496df06904c914600" + +[[package]] +name = "cfg_aliases" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f079e83a288787bcd14a6aea84cee5c87a67c5a3e660c30f557a3d24761b3527" + +[[package]] +name = "chacha20" +version = "0.10.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "65c35e4b699c7e15ccbe7ee35c005e4fc0a278d22238a2857e6ce2dadeda1b06" +dependencies = [ + "cfg-if", + "cpufeatures 0.3.1", + "rand_core", +] + +[[package]] +name = "cmake" +version = "0.1.58" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c0f78a02292a74a88ac736019ab962ece0bc380e3f977bf72e376c5d78ff0678" +dependencies = [ + "cc", +] + +[[package]] +name = "cpufeatures" +version = "0.2.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "59ed5838eebb26a2bb2e58f6d5b5316989ae9d08bab10e0e6d103e656d1b0280" +dependencies = [ + "libc", +] + +[[package]] +name = "cpufeatures" +version = "0.3.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5ca28b0ae3115b884660db4118d803791fd6756b6e88f39c0f3f7859060d7566" +dependencies = [ + "libc", +] + +[[package]] +name = "crypto-common" +version = "0.1.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "78c8292055d1c1df0cce5d180393dc8cce0abec0a7102adb6c7b1eef6016d60a" +dependencies = [ + "generic-array", + "typenum", +] + +[[package]] +name = "darling" +version = "0.20.11" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fc7f46116c46ff9ab3eb1597a45688b6715c6e628b5c133e288e709a29bcb4ee" +dependencies = [ + "darling_core", + "darling_macro", +] + +[[package]] +name = "darling_core" +version = "0.20.11" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0d00b9596d185e565c2207a0b01f8bd1a135483d02d9b7b0a54b11da8d53412e" +dependencies = [ + "fnv", + "ident_case", + "proc-macro2", + "quote", + "strsim", + "syn 2.0.119", +] + +[[package]] +name = "darling_macro" +version = "0.20.11" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fc34b93ccb385b40dc71c6fceac4b2ad23662c7eeb248cf10d529b7e055b6ead" +dependencies = [ + "darling_core", + "quote", + "syn 2.0.119", +] + +[[package]] +name = "deranged" +version = "0.5.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9e9de72ce2ad1f90dc62fa25f0f430ef85eb4b0d8fa0be4f30373bc40a21d28e" + +[[package]] +name = "derive_builder" +version = "0.20.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "507dfb09ea8b7fa618fcf76e953f4f5e192547945816d5358edffe39f6f94947" +dependencies = [ + "derive_builder_macro", +] + +[[package]] +name = "derive_builder_core" +version = "0.20.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2d5bcf7b024d6835cfb3d473887cd966994907effbe9227e8c8219824d06c4e8" +dependencies = [ + "darling", + "proc-macro2", + "quote", + "syn 2.0.119", +] + +[[package]] +name = "derive_builder_macro" +version = "0.20.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ab63b0e2bf4d5928aff72e83a7dace85d7bba5fe12dcc3c5a572d78caffd3f3c" +dependencies = [ + "derive_builder_core", + "syn 2.0.119", +] + +[[package]] +name = "digest" +version = "0.10.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9ed9a281f7bc9b7576e61468ba615a66a5c8cfdff42420a70aa82701a3b1e292" +dependencies = [ + "block-buffer", + "crypto-common", +] + +[[package]] +name = "displaydoc" +version = "0.2.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c6232dd377dcc64799954cbd3a9bb882e9cdc1308ccd87b1c098f1fb2eaf82a8" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "dunce" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "92773504d58c093f6de2459af4af33faa518c13451eb8f2b5698ed3d36e7c813" + +[[package]] +name = "either" +version = "1.19.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0e9c71c2167ca323c882b99918929403426e2373ea17242ff5653e0d5e1058be" + +[[package]] +name = "equivalent" +version = "1.0.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "00d174d5400e5e8fd687ad1049e2f578285fa914201b1af7e8b112a4546bd826" + +[[package]] +name = "errno" +version = "0.3.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb" +dependencies = [ + "libc", + "windows-sys 0.61.2", +] + +[[package]] +name = "find-msvc-tools" +version = "0.1.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "aedcfb3409746eddb02b9e19ebda1c3394f759a152e48ee875a0844d1b955484" + +[[package]] +name = "fnv" +version = "1.0.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1" + +[[package]] +name = "form_urlencoded" +version = "1.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cb4cb245038516f5f85277875cdaa4f7d2c9a0fa0468de06ed190163b1581fcf" +dependencies = [ + "percent-encoding", +] + +[[package]] +name = "fs-err" +version = "3.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b5c95b673b8f6f7235229ae11c5642d81b04c2e64c1e2fb417bc0cf73ca45f29" +dependencies = [ + "autocfg", + "tokio", +] + +[[package]] +name = "fs_extra" +version = "1.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c" + +[[package]] +name = "futures-channel" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b1f9e3d69d39e4862ffed03ed071a76f9a13ba1d9109d355b0f0aa6b15e393c4" +dependencies = [ + "futures-core", +] + +[[package]] +name = "futures-core" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "92d699e522242e69e3003b94ecc1f960f3a5e015aa7c5d7486e65ad01dd94f5e" + +[[package]] +name = "futures-sink" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1944426bf7d03f1d14f708785e4b33efd750b36d48a157b836b3efc15ede8e1d" + +[[package]] +name = "futures-task" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cd417de3d1d015fc3bfd2b1ea46dfc7bab72ef86f1cc7cc9c78e728b34a6d1fd" + +[[package]] +name = "futures-util" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0d50a92467f8ba5dd6e3ee5d4bd04d73ab2e4e1c44474a0674821dfce14b79bc" +dependencies = [ + "futures-core", + "futures-task", + "pin-project-lite", + "slab", +] + +[[package]] +name = "generic-array" +version = "0.14.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "85649ca51fd72272d7821adaf274ad91c288277713d9c18820d8499a7ff69e9a" +dependencies = [ + "typenum", + "version_check", +] + +[[package]] +name = "getrandom" +version = "0.2.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ff2abc00be7fca6ebc474524697ae276ad847ad0a6b3faa4bcb027e9a4614ad0" +dependencies = [ + "cfg-if", + "js-sys", + "libc", + "wasi", + "wasm-bindgen", +] + +[[package]] +name = "getrandom" +version = "0.4.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "300e883d756b2e4ec94e02791f39b04b522276138852cfc41d9fb7e904106099" +dependencies = [ + "cfg-if", + "js-sys", + "libc", + "r-efi", + "rand_core", + "wasm-bindgen", +] + +[[package]] +name = "getset" +version = "0.1.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6cf442baaabe4213ce7d1239afc26c039180b6456da2cededa316ae2c8a77a77" +dependencies = [ + "proc-macro2", + "quote", + "syn 2.0.119", +] + +[[package]] +name = "h2" +version = "0.4.20" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7d29020232d6aa3fb1daca64c1127cf662cf97f254ae16c18c05b8ab635fc118" +dependencies = [ + "atomic-waker", + "bytes", + "fnv", + "futures-core", + "futures-sink", + "http", + "indexmap", + "slab", + "tokio", + "tokio-util", + "tracing", +] + +[[package]] +name = "hashbrown" +version = "0.17.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ed5909b6e89a2db4456e54cd5f673791d7eca6732202bbf2a9cc504fe2f9b84a" + +[[package]] +name = "hex" +version = "0.4.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7f24254aa9a54b5c858eaee2f5bccdb46aaf0e486a595ed5fd8f86ba55232a70" + +[[package]] +name = "http" +version = "1.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "918d3568bebf352712bc2ef3d46a8bcf1a75b373be6539de198e9105cbbf9ce0" +dependencies = [ + "bytes", + "itoa", +] + +[[package]] +name = "http-body" +version = "1.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ca2a8f2913ee65f60facd6a5905613afaa448497a0230cc41ce022d93290bc2c" +dependencies = [ + "bytes", + "http", +] + +[[package]] +name = "http-body-util" +version = "0.1.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "23169fe34a5fbcdd3f3862e78fb9b6fccd5f02a6dc6f732547005d45631ce71c" +dependencies = [ + "bytes", + "futures-core", + "http", + "http-body", + "pin-project-lite", +] + +[[package]] +name = "httparse" +version = "1.10.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87" + +[[package]] +name = "httpdate" +version = "1.0.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9" + +[[package]] +name = "hyper" +version = "1.12.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2c3e324da4c95177d6291d4c8730197c0d1822f8a9766814a4a44fa5ab797c9c" +dependencies = [ + "atomic-waker", + "bytes", + "futures-channel", + "futures-core", + "h2", + "http", + "http-body", + "httparse", + "httpdate", + "itoa", + "pin-project-lite", + "smallvec", + "tokio", + "want", +] + +[[package]] +name = "hyper-rustls" +version = "0.27.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dfa8e654703247911e29c23fbeaa261834bd9bb74efba2f9acddc37bfb127f53" +dependencies = [ + "http", + "hyper", + "hyper-util", + "rustls", + "tokio", + "tokio-rustls", + "tower-service", + "webpki-roots", +] + +[[package]] +name = "hyper-util" +version = "0.1.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ddc03d96684f9226b8a787cdb71488417b53ab5ea8fdb1dac946cb9431cc8bff" +dependencies = [ + "base64 0.23.1", + "bytes", + "futures-channel", + "futures-util", + "http", + "http-body", + "httparse", + "hyper", + "ipnet", + "libc", + "percent-encoding", + "pin-project-lite", + "socket2 0.6.5", + "tokio", + "tower-service", + "tracing", +] + +[[package]] +name = "icu_collections" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fa68d21081c4a05d5a901a1c62add574c77048b6a1c67be3b50ce0b60d4ca513" +dependencies = [ + "displaydoc", + "potential_utf", + "utf8_iter", + "yoke", + "zerofrom", + "zerovec", +] + +[[package]] +name = "icu_locale_core" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d56e28588da92eee5c3201a6eff33fabdd49b62269c8938d4ff050ce4d900deb" +dependencies = [ + "displaydoc", + "litemap", + "tinystr", + "writeable", + "zerovec", +] + +[[package]] +name = "icu_normalizer" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "12f9cf5f235641ed274641dd81c3f28d870e276763d0797aeeab72317b1c646f" +dependencies = [ + "icu_collections", + "icu_normalizer_data", + "icu_properties", + "icu_provider", + "smallvec", + "zerovec", +] + +[[package]] +name = "icu_normalizer_data" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1563da1ed3e0b3bf3d74c9b85917ac9c56464d2f57242270c09c9e752f8021a0" + +[[package]] +name = "icu_properties" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7e7ca276ad3145661a65914e6daf131ca5120cd3dcee8f8f3214b8875184a148" +dependencies = [ + "displaydoc", + "icu_collections", + "icu_locale_core", + "icu_properties_data", + "icu_provider", + "zerotrie", + "zerovec", +] + +[[package]] +name = "icu_properties_data" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e590f038c1464a96894fd6d10127e90a8be4509f56ff7ecef851b15cee0b7caa" + +[[package]] +name = "icu_provider" +version = "2.3.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d27bbb9d3abbefac45d55f647c9de1d44aafcd1186eb91879afef17c396c3e73" +dependencies = [ + "displaydoc", + "icu_locale_core", + "writeable", + "yoke", + "zerofrom", + "zerotrie", + "zerovec", +] + +[[package]] +name = "ident_case" +version = "1.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b9e0384b61958566e926dc50660321d12159025e767c18e043daf26b70104c39" + +[[package]] +name = "idna" +version = "1.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3b0875f23caa03898994f6ddc501886a45c7d3d62d04d2d90788d47be1b1e4de" +dependencies = [ + "idna_adapter", + "smallvec", + "utf8_iter", +] + +[[package]] +name = "idna_adapter" +version = "1.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cb68373c0d6620ef8105e855e7745e18b0d00d3bdb07fb532e434244cdb9a714" +dependencies = [ + "icu_normalizer", + "icu_properties", +] + +[[package]] +name = "indexmap" +version = "2.14.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cc4e190f5d26ca7051642629da2c52fc03bde85a03197c99408dcd291734c855" +dependencies = [ + "equivalent", + "hashbrown", +] + +[[package]] +name = "ipnet" +version = "2.12.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "791930b43c0d5973160d90a8f3894509f2b273430f5c5c73b668636d0287c5c0" + +[[package]] +name = "itoa" +version = "1.0.18" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8f42a60cbdf9a97f5d2305f08a87dc4e09308d1276d28c869c684d7777685682" + +[[package]] +name = "jobserver" +version = "0.1.35" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1c00acbd29eabad4a2392fa0e921c874934dbbf4194312ad20f04a0ed67a3cb3" +dependencies = [ + "getrandom 0.4.3", + "libc", +] + +[[package]] +name = "js-sys" +version = "0.3.106" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7883d941dae510fb2d978fc3fe018c71c9e2892fd38854de3e8b92c2e5ad9cc5" +dependencies = [ + "cfg-if", + "futures-util", + "wasm-bindgen", +] + +[[package]] +name = "libc" +version = "0.2.190" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ce5d3ddc6d3fa000eb1536d85e147bfe31aacaba692ed6a876f95cb7c855be78" + +[[package]] +name = "litemap" +version = "0.8.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "47d9d19d1d6efa0109d2f65ff4c85cddd50bd572e5a00127ab10987290bcefae" + +[[package]] +name = "local-ip-address" +version = "0.6.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "aa08fb2b1ec3ea84575e94b489d06d4ce0cbf052d12acd515838f50e3c3d63e3" +dependencies = [ + "libc", + "neli", + "windows-sys 0.61.2", +] + +[[package]] +name = "lock_api" +version = "0.4.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "224399e74b87b5f3557511d98dff8b14089b3dadafcab6bb93eab67d3aace965" +dependencies = [ + "scopeguard", +] + +[[package]] +name = "log" +version = "0.4.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f9f8bd3e56ce4dfc153cf470fffbfa98c7620958b312ca5c3a4b8d5181fd13c6" + +[[package]] +name = "lru-slab" +version = "0.1.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4050469837a6ff301cd14c1f8f24f88549e6d548f24f64e2148eb0f72cebc51f" + +[[package]] +name = "matchit" +version = "0.7.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0e7465ac9959cc2b1404e8e2367b43684a6d13790fe23056cc8c6c5a6b7bcb94" + +[[package]] +name = "memchr" +version = "2.8.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cf8baf1c55e62ffcace7a9f06f4bd9cd3f0c4beb022d3b367256b91b87513d98" + +[[package]] +name = "mime" +version = "0.3.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a" + +[[package]] +name = "mio" +version = "1.2.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1788edb87fdc09c7e26304471e2f5be8cdefb1b6930d6e3985fc02ff53bf86ee" +dependencies = [ + "libc", + "wasi", + "windows-sys 0.61.2", +] + +[[package]] +name = "neli" +version = "0.7.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "22f9786d56d972959e1408b6a93be6af13b9c1392036c5c1fafa08a1b0c6ee87" +dependencies = [ + "bitflags", + "byteorder", + "derive_builder", + "getset", + "libc", + "log", + "neli-proc-macros", + "parking_lot", +] + +[[package]] +name = "neli-proc-macros" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "05d8d08c6e98f20a62417478ebf7be8e1425ec9acecc6f63e22da633f6b71609" +dependencies = [ + "either", + "proc-macro2", + "quote", + "serde", + "syn 2.0.119", +] + +[[package]] +name = "num-conv" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "521739c6d2bac4aa25192232afe6841231376b2b26d4d9fae5ecf8ca5772e441" + +[[package]] +name = "once_cell" +version = "1.21.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9f7c3e4beb33f85d45ae3e3a1792185706c8e16d043238c593331cc7cd313b50" + +[[package]] +name = "parking_lot" +version = "0.12.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "93857453250e3077bd71ff98b6a65ea6621a19bb0f559a85248955ac12c45a1a" +dependencies = [ + "lock_api", + "parking_lot_core", +] + +[[package]] +name = "parking_lot_core" +version = "0.9.12" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2621685985a2ebf1c516881c026032ac7deafcda1a2c9b7850dc81e3dfcb64c1" +dependencies = [ + "cfg-if", + "libc", + "redox_syscall", + "smallvec", + "windows-link", +] + +[[package]] +name = "pem" +version = "3.0.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1d30c53c26bc5b31a98cd02d20f25a7c8567146caf63ed593a9d87b2775291be" +dependencies = [ + "base64 0.22.1", + "serde_core", +] + +[[package]] +name = "percent-encoding" +version = "2.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220" + +[[package]] +name = "pin-project-lite" +version = "0.2.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a89322df9ebe1c1578d689c92318e070967d1042b512afbe49518723f4e6d5cd" + +[[package]] +name = "pkg-config" +version = "0.3.34" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f6b464fbc74e149a392436b17d523f769e057cb6877f6a5c4618bc6f11800548" + +[[package]] +name = "potential_utf" +version = "0.1.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d83eb9bc6d8e5cf568e7a1101d60ee05e81ed50ea106026f3d18deeb046d7661" +dependencies = [ + "zerovec", +] + +[[package]] +name = "powerfmt" +version = "0.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4a6394b9e965e73d0a289ee54f589087e2c676aedf60885baf52c76b771e4958" + +[[package]] +name = "proc-macro2" +version = "1.0.107" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "985e7ec9bb745e6ce6535b544d84d6cd6f7ad8bd711c398938ae983b91a766d9" +dependencies = [ + "unicode-ident", +] + +[[package]] +name = "quinn" +version = "0.11.12" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4051e23e9185c255a7e33ef59cdbca87a22d359052eecd22fc6b901fb37d9d11" +dependencies = [ + "bytes", + "cfg_aliases", + "pin-project-lite", + "quinn-proto", + "quinn-udp", + "rustc-hash", + "rustls", + "socket2 0.6.5", + "thiserror", + "tokio", + "tracing", + "web-time", +] + +[[package]] +name = "quinn-proto" +version = "0.11.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0e750cca55fe4f0439a15d0bb529da9651e79993e8e72c61a899a36d462befbe" +dependencies = [ + "bytes", + "getrandom 0.4.3", + "lru-slab", + "rand", + "rand_pcg", + "ring", + "rustc-hash", + "rustls", + "rustls-pki-types", + "slab", + "thiserror", + "tinyvec", + "tracing", + "web-time", +] + +[[package]] +name = "quinn-udp" +version = "0.5.16" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "af66907df18639dcf4db56ca65490cabc4b27a97dbadd96f2926cca73298f016" +dependencies = [ + "cfg_aliases", + "libc", + "once_cell", + "socket2 0.6.5", + "tracing", + "windows-sys 0.61.2", +] + +[[package]] +name = "quote" +version = "1.0.47" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1fbf4db142a473a8d80c26bbf18454ed458bf8d26c8219c331daecfdbd079001" +dependencies = [ + "proc-macro2", +] + +[[package]] +name = "r-efi" +version = "6.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f8dcc9c7d52a811697d2151c701e0d08956f92b0e24136cf4cf27b57a6a0d9bf" + +[[package]] +name = "ramshare_ui" +version = "0.2.0" +dependencies = [ + "axum", + "axum-server", + "bytes", + "hex", + "local-ip-address", + "rcgen", + "reqwest", + "rustls", + "serde", + "serde_json", + "sha2", + "socket2 0.5.10", + "tokio", +] + +[[package]] +name = "rand" +version = "0.10.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "65c9fb96cbc91e3478eaae79a69fcd3f1ae4ad052e471fe6732fff548984b4af" +dependencies = [ + "chacha20", + "getrandom 0.4.3", + "rand_core", +] + +[[package]] +name = "rand_core" +version = "0.10.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "63b8176103e19a2643978565ca18b50549f6101881c443590420e4dc998a3c69" + +[[package]] +name = "rand_pcg" +version = "0.10.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "caa0f4137e1c0a72f4c651489402276c8e8e1cf081f3b0ba156d2cbeef09e86a" +dependencies = [ + "rand_core", +] + +[[package]] +name = "rcgen" +version = "0.13.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "75e669e5202259b5314d1ea5397316ad400819437857b90861765f24c4cf80a2" +dependencies = [ + "pem", + "ring", + "rustls-pki-types", + "time", + "yasna", +] + +[[package]] +name = "redox_syscall" +version = "0.5.18" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ed2bf2547551a7053d6fdfafda3f938979645c44812fbfcda098faae3f1a362d" +dependencies = [ + "bitflags", +] + +[[package]] +name = "reqwest" +version = "0.12.28" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "eddd3ca559203180a307f12d114c268abf583f59b03cb906fd0b3ff8646c1147" +dependencies = [ + "base64 0.22.1", + "bytes", + "futures-core", + "http", + "http-body", + "http-body-util", + "hyper", + "hyper-rustls", + "hyper-util", + "js-sys", + "log", + "percent-encoding", + "pin-project-lite", + "quinn", + "rustls", + "rustls-pki-types", + "serde", + "serde_json", + "serde_urlencoded", + "sync_wrapper", + "tokio", + "tokio-rustls", + "tower", + "tower-http", + "tower-service", + "url", + "wasm-bindgen", + "wasm-bindgen-futures", + "web-sys", + "webpki-roots", +] + +[[package]] +name = "ring" +version = "0.17.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a4689e6c2294d81e88dc6261c768b63bc4fcdb852be6d1352498b114f61383b7" +dependencies = [ + "cc", + "cfg-if", + "getrandom 0.2.17", + "libc", + "untrusted", + "windows-sys 0.52.0", +] + +[[package]] +name = "rustc-hash" +version = "2.1.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6b1e7f9a428571be2dc5bc0505c13fb6bf936822b894ec87abf8a08a4e51742d" + +[[package]] +name = "rustls" +version = "0.23.46" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "48e13bd8c0e9365c43cfa5c9e8f9ad49d3c8444926c9aac819e0e4dc503c8fdf" +dependencies = [ + "aws-lc-rs", + "once_cell", + "ring", + "rustls-pki-types", + "rustls-webpki", + "subtle", + "zeroize", +] + +[[package]] +name = "rustls-pemfile" +version = "2.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dce314e5fee3f39953d46bb63bb8a46d40c2f8fb7cc5a3b6cab2bde9721d6e50" +dependencies = [ + "rustls-pki-types", +] + +[[package]] +name = "rustls-pki-types" +version = "1.15.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2f4925028c7eb5d1fcdaf196971378ed9d2c1c4efc7dc5d011256f76c99c0a96" +dependencies = [ + "web-time", + "zeroize", +] + +[[package]] +name = "rustls-webpki" +version = "0.103.15" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f3c3cf1d8b1e7d4927e2d154c3fcb02979afb9939629c62cd9048d4f07b60ac2" +dependencies = [ + "aws-lc-rs", + "ring", + "rustls-pki-types", + "untrusted", +] + +[[package]] +name = "rustversion" +version = "1.0.23" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cf54715a573b99ac80df0bc206da022bcd442c974952c7b9720069370852e21f" + +[[package]] +name = "ryu" +version = "1.0.23" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9774ba4a74de5f7b1c1451ed6cd5285a32eddb5cccb8cc655a4e50009e06477f" + +[[package]] +name = "scopeguard" +version = "1.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49" + +[[package]] +name = "serde" +version = "1.0.229" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4148590afebada386688f18773da617792bf2ef03ffc1e4cbd2b1d45b023e0ba" +dependencies = [ + "serde_core", + "serde_derive", +] + +[[package]] +name = "serde_core" +version = "1.0.229" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "67dca2c9c51e58a4791a4b1ed58308b39c64224d349a935ab5039aa360942a48" +dependencies = [ + "serde_derive", +] + +[[package]] +name = "serde_derive" +version = "1.0.229" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e7a5d71263a5a7d47b41f6b3f06ba276f10cc18b0931f1799f710578e2309348" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "serde_json" +version = "1.0.154" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e7e9cc8b1b85264074fbcc02a88680c4096b1e47df8f739dceb03bf482f04bd6" +dependencies = [ + "itoa", + "memchr", + "serde", + "serde_core", + "zmij", +] + +[[package]] +name = "serde_path_to_error" +version = "0.1.20" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "10a9ff822e371bb5403e391ecd83e182e0e77ba7f6fe0160b795797109d1b457" +dependencies = [ + "itoa", + "serde", + "serde_core", +] + +[[package]] +name = "serde_urlencoded" +version = "0.7.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d3491c14715ca2294c4d6a88f15e84739788c1d030eed8c110436aafdaa2f3fd" +dependencies = [ + "form_urlencoded", + "itoa", + "ryu", + "serde", +] + +[[package]] +name = "sha2" +version = "0.10.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a7507d819769d01a365ab707794a4084392c824f54a7a6a7862f8c3d0892b283" +dependencies = [ + "cfg-if", + "cpufeatures 0.2.17", + "digest", +] + +[[package]] +name = "shlex" +version = "2.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f8fadd59c855ef2080decdef8ff161eb6661b86933c9d82e5ba29dc602a55aba" + +[[package]] +name = "signal-hook-registry" +version = "1.4.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c4db69cba1110affc0e9f7bcd48bbf87b3f4fc7c61fc9155afd4c469eb3d6c1b" +dependencies = [ + "errno", + "libc", +] + +[[package]] +name = "slab" +version = "0.4.12" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0c790de23124f9ab44544d7ac05d60440adc586479ce501c1d6d7da3cd8c9cf5" + +[[package]] +name = "smallvec" +version = "1.16.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5b3dc8af474f516a851ff4bd12db780f948b9250ad37211e4eec0bccea54e01b" + +[[package]] +name = "socket2" +version = "0.5.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e22376abed350d73dd1cd119b57ffccad95b4e585a7cda43e286245ce23c0678" +dependencies = [ + "libc", + "windows-sys 0.52.0", +] + +[[package]] +name = "socket2" +version = "0.6.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c3d1e2c7f27f8d4cb10542a02c49005dbd6e93095799d6f3be745fae9f8fedd4" +dependencies = [ + "libc", + "windows-sys 0.61.2", +] + +[[package]] +name = "stable_deref_trait" +version = "1.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6ce2be8dc25455e1f91df71bfa12ad37d7af1092ae736f3a6cd0e37bc7810596" + +[[package]] +name = "strsim" +version = "0.11.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f" + +[[package]] +name = "subtle" +version = "2.6.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292" + +[[package]] +name = "syn" +version = "2.0.119" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "872831b642d1a07999a962a351ed35b955ea2cfc8f3862091e2a240a84f17297" +dependencies = [ + "proc-macro2", + "quote", + "unicode-ident", +] + +[[package]] +name = "syn" +version = "3.0.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d78c8dee4c7bf0e14673097256fed6142ce9d3b85a408189d07482442145823b" +dependencies = [ + "proc-macro2", + "quote", + "unicode-ident", +] + +[[package]] +name = "sync_wrapper" +version = "1.0.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0bf256ce5efdfa370213c1dabab5935a12e49f2c58d15e9eac2870d3b4f27263" +dependencies = [ + "futures-core", +] + +[[package]] +name = "synstructure" +version = "0.14.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "901704edd0dfe137f1987838ee4f259e4e063c31371bdb423f7ae38ec6f77f02" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "thiserror" +version = "2.0.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "09e52cb86a36cede5cb101bf8908837b3e4c6e5e59fe7fd85c23fb56200d189e" +dependencies = [ + "thiserror-impl", +] + +[[package]] +name = "thiserror-impl" +version = "2.0.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fe5197923287db20a58125f0bc85c062f7f2c892de97b18c356f9efb14b28524" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "time" +version = "0.3.55" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cdb87b95ec50ddfa440816d227a17b2ccbdda963a316a727fda0fc4334f7d134" +dependencies = [ + "deranged", + "num-conv", + "powerfmt", + "serde_core", + "time-core", +] + +[[package]] +name = "time-core" +version = "0.1.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9e1c906769ad99c88eaa54e728060edef082f8e358ff32030cb7c7d315e81109" + +[[package]] +name = "tinystr" +version = "0.8.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b1e27c91459209c2986af3dcf603a5a74a4368754ce37414f59acc971167f643" +dependencies = [ + "displaydoc", + "zerovec", +] + +[[package]] +name = "tinyvec" +version = "1.13.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fd3ca314f692efd6c868f8408f53fe444634a845f96c028b97d35f6a1f79f0ee" + +[[package]] +name = "tokio" +version = "1.53.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ce3335fa71841cda333a58d7615b03901380ecf09d59b3296d21f8bbac0dde4e" +dependencies = [ + "bytes", + "libc", + "mio", + "parking_lot", + "pin-project-lite", + "signal-hook-registry", + "socket2 0.6.5", + "tokio-macros", + "windows-sys 0.61.2", +] + +[[package]] +name = "tokio-macros" +version = "2.7.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "78773a2a397f451582ce068015985c33193cf6dea8b74d2a639fe457b2f07b0e" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "tokio-rustls" +version = "0.26.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c9cc2678c2cdd569ef8215e2afd7954ada2ae20b4fdd2c5fe6139a3b02d105db" +dependencies = [ + "rustls", + "tokio", +] + +[[package]] +name = "tokio-util" +version = "0.7.20" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e464cf451ba96ebfc6f9b6542f17ee8b8956e33f1e40d9690624e59d7a7f8a4b" +dependencies = [ + "bytes", + "futures-core", + "futures-sink", + "libc", + "pin-project-lite", + "tokio", +] + +[[package]] +name = "tower" +version = "0.5.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ebe5ef63511595f1344e2d5cfa636d973292adc0eec1f0ad45fae9f0851ab1d4" +dependencies = [ + "futures-core", + "futures-util", + "pin-project-lite", + "sync_wrapper", + "tokio", + "tower-layer", + "tower-service", + "tracing", +] + +[[package]] +name = "tower-http" +version = "0.6.11" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4cfcf7e2740e6fc6d4d688b4ef00650406bb94adf4731e43c096c3a19fe40840" +dependencies = [ + "bitflags", + "bytes", + "futures-util", + "http", + "http-body", + "pin-project-lite", + "tower", + "tower-layer", + "tower-service", + "url", +] + +[[package]] +name = "tower-layer" +version = "0.3.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "121c2a6cda46980bb0fcd1647ffaf6cd3fc79a013de288782836f6df9c48780e" + +[[package]] +name = "tower-service" +version = "0.3.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8df9b6e13f2d32c91b9bd719c00d1958837bc7dec474d94952798cc8e69eeec3" + +[[package]] +name = "tracing" +version = "0.1.44" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "63e71662fa4b2a2c3a26f570f037eb95bb1f85397f3cd8076caed2f026a6d100" +dependencies = [ + "log", + "pin-project-lite", + "tracing-core", +] + +[[package]] +name = "tracing-core" +version = "0.1.36" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "db97caf9d906fbde555dd62fa95ddba9eecfd14cb388e4f491a66d74cd5fb79a" +dependencies = [ + "once_cell", +] + +[[package]] +name = "try-lock" +version = "0.2.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e421abadd41a4225275504ea4d6566923418b7f05506fbc9c0fe86ba7396114b" + +[[package]] +name = "typenum" +version = "1.20.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b6f5e870be6c3b371b77fe0ee0bafb859fa4964b4404c27de1d380043c4dda20" + +[[package]] +name = "unicode-ident" +version = "1.0.27" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a2c754d6c33795a1c324727428e5a7dedb5b06195f9890bdbcba760d3e246563" + +[[package]] +name = "untrusted" +version = "0.9.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8ecb6da28b8a351d773b68d5825ac39017e680750f980f3a1a85cd8dd28a47c1" + +[[package]] +name = "url" +version = "2.5.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ff67a8a4397373c3ef660812acab3268222035010ab8680ec4215f38ba3d0eed" +dependencies = [ + "form_urlencoded", + "idna", + "percent-encoding", + "serde", +] + +[[package]] +name = "utf8_iter" +version = "1.0.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be" + +[[package]] +name = "version_check" +version = "0.9.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0b928f33d975fc6ad9f86c8f283853ad26bdd5b10b7f1542aa2fa15e2289105a" + +[[package]] +name = "want" +version = "0.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ec4cdd0dd910afe868b7ef477227d8d538b46b3075031afee8a9f2acb0a2ed0b" +dependencies = [ + "try-lock", +] + +[[package]] +name = "wasi" +version = "0.11.1+wasi-snapshot-preview1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b" + +[[package]] +name = "wasm-bindgen" +version = "0.2.129" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9bb54f33acc68fd454578d9820b0bde1a1a3d17aa17bb7b6595806d02886d409" +dependencies = [ + "cfg-if", + "once_cell", + "rustversion", + "wasm-bindgen-macro", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-futures" +version = "0.4.79" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3cbab34de2d982e9b48e18d216d04c4a6f641066ff19ffb699980f591ee3610e" +dependencies = [ + "js-sys", + "tokio", + "wasm-bindgen", +] + +[[package]] +name = "wasm-bindgen-macro" +version = "0.2.129" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2e29d0c35b16e224a7eeb5cd2d25e3e1968fbd65604117b44d3b789d00ee8535" +dependencies = [ + "quote", + "wasm-bindgen-macro-support", +] + +[[package]] +name = "wasm-bindgen-macro-support" +version = "0.2.129" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6f501a8bc3719dba86ef8ae4728879c08001bea749eb1333ac5b91e040e2a6b7" +dependencies = [ + "bumpalo", + "proc-macro2", + "quote", + "syn 3.0.9", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-shared" +version = "0.2.129" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "23f0c9c52aa7cd7d77769a4cfe2a9adb1b331f489a41d912ce14513d5ab995c6" +dependencies = [ + "unicode-ident", +] + +[[package]] +name = "web-sys" +version = "0.3.106" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "88261b9deccee56594c11a3460c462c41f58d148598fe70ad77070126a68aba4" +dependencies = [ + "js-sys", + "wasm-bindgen", +] + +[[package]] +name = "web-time" +version = "1.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5a6580f308b1fad9207618087a65c04e7a10bc77e02c8e84e9b00dd4b12fa0bb" +dependencies = [ + "js-sys", + "wasm-bindgen", +] + +[[package]] +name = "webpki-roots" +version = "1.0.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7dcd9d09a39985f5344844e66b0c530a33843579125f23e21e9f0f220850f22a" +dependencies = [ + "rustls-pki-types", +] + +[[package]] +name = "windows-link" +version = "0.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5" + +[[package]] +name = "windows-sys" +version = "0.52.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "282be5f36a8ce781fad8c8ae18fa3f9beff57ec1b52cb3de0789201425d9a33d" +dependencies = [ + "windows-targets", +] + +[[package]] +name = "windows-sys" +version = "0.61.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ae137229bcbd6cdf0f7b80a31df61766145077ddf49416a728b02cb3921ff3fc" +dependencies = [ + "windows-link", +] + +[[package]] +name = "windows-targets" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9b724f72796e036ab90c1021d4780d4d3d648aca59e491e6b98e725b84e99973" +dependencies = [ + "windows_aarch64_gnullvm", + "windows_aarch64_msvc", + "windows_i686_gnu", + "windows_i686_gnullvm", + "windows_i686_msvc", + "windows_x86_64_gnu", + "windows_x86_64_gnullvm", + "windows_x86_64_msvc", +] + +[[package]] +name = "windows_aarch64_gnullvm" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "32a4622180e7a0ec044bb555404c800bc9fd9ec262ec147edd5989ccd0c02cd3" + +[[package]] +name = "windows_aarch64_msvc" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "09ec2a7bb152e2252b53fa7803150007879548bc709c039df7627cabbd05d469" + +[[package]] +name = "windows_i686_gnu" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8e9b5ad5ab802e97eb8e295ac6720e509ee4c243f69d781394014ebfe8bbfa0b" + +[[package]] +name = "windows_i686_gnullvm" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0eee52d38c090b3caa76c563b86c3a4bd71ef1a819287c19d586d7334ae8ed66" + +[[package]] +name = "windows_i686_msvc" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "240948bc05c5e7c6dabba28bf89d89ffce3e303022809e73deaefe4f6ec56c66" + +[[package]] +name = "windows_x86_64_gnu" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "147a5c80aabfbf0c7d901cb5895d1de30ef2907eb21fbbab29ca94c5b08b1a78" + +[[package]] +name = "windows_x86_64_gnullvm" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "24d5b23dc417412679681396f2b49f3de8c1473deb516bd34410872eff51ed0d" + +[[package]] +name = "windows_x86_64_msvc" +version = "0.52.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "589f6da84c646204747d1270a2a5661ea66ed1cced2631d546fdfb155959f9ec" + +[[package]] +name = "writeable" +version = "0.6.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3ad82d2a33cdc9674dc7465672f271e096168fcdbe0f799d9e6db8c5892679dc" + +[[package]] +name = "yasna" +version = "0.5.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e17bb3549cc1321ae1296b9cdc2698e2b6cb1992adfa19a8c72e5b7a738f44cd" +dependencies = [ + "time", +] + +[[package]] +name = "yoke" +version = "0.8.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "709fe23a0424b6a435d82152b1bd3fdfb0833487d5fa90d05d42762a9891fef5" +dependencies = [ + "stable_deref_trait", + "yoke-derive", + "zerofrom", +] + +[[package]] +name = "yoke-derive" +version = "0.8.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ec8ebde2db3681e8c9980cc27822030e68752690ddfa9473e739aeb4dbde6d71" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", + "synstructure", +] + +[[package]] +name = "zerofrom" +version = "0.1.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0ec05a11813ea801ff6d75110ad09cd0824ddba17dfe17128ea0d5f68e6c5272" +dependencies = [ + "zerofrom-derive", +] + +[[package]] +name = "zerofrom-derive" +version = "0.1.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f75b4683f6c7f45248d4d64056a24298c6281e0993356d7d1b4a1a962ef10d4a" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", + "synstructure", +] + +[[package]] +name = "zeroize" +version = "1.9.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e13084392c5e4bc371903e2935a5eaeed24905a7511356b883835e18a78f6879" + +[[package]] +name = "zerotrie" +version = "0.2.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4ea269c3bd32f0a32c321907a2ae912ba6f4649bb0fc764a15627e99a7095a3f" +dependencies = [ + "displaydoc", + "yoke", + "zerofrom", +] + +[[package]] +name = "zerovec" +version = "0.11.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "bb0464e17806c1d976d5cba29399c7f08e516e279e2ba493f63123b5fca67dd8" +dependencies = [ + "yoke", + "zerofrom", + "zerovec-derive", +] + +[[package]] +name = "zerovec-derive" +version = "0.11.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "34df6fc39dbd26ddc9c10e6a2984476e13acce22e64e4487636ef494369225da" +dependencies = [ + "proc-macro2", + "quote", + "syn 3.0.9", +] + +[[package]] +name = "zmij" +version = "1.0.23" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "29666d0abbfad1e3dc4dcf6144730dd3a3ab225bbbdac83319345b1b44ccfc1b" diff --git a/Cargo.toml b/Cargo.toml new file mode 100644 index 0000000..15e3d35 --- /dev/null +++ b/Cargo.toml @@ -0,0 +1,23 @@ +[package] +name = "ramshare_ui" +version = "0.2.0" +edition = "2021" + +[dependencies] +tokio = { version = "1.40", features = ["full"] } +axum = { version = "0.7" } +axum-server = { version = "0.7", features = ["tls-rustls"] } +bytes = "1.7" +socket2 = "0.5" + +reqwest = { version = "0.12", default-features = false, features = ["rustls-tls", "json"] } + +rcgen = "0.13" +rustls = { version = "0.23", default-features = false, features = ["ring", "std", "tls12"] } +sha2 = "0.10" +hex = "0.4" + +local-ip-address = "0.6" + +serde = { version = "1.0", features = ["derive"] } +serde_json = "1.0" diff --git a/Cargo.toml.bak b/Cargo.toml.bak new file mode 100644 index 0000000..3eb50b4 --- /dev/null +++ b/Cargo.toml.bak @@ -0,0 +1,23 @@ +[package] +name = "ramshare_ui" +version = "0.2.0" +edition = "2021" + +[dependencies] +tokio = { version = "1.40", features = ["full"] } +axum = { version = "0.7" } +axum-server = { version = "0.7", features = ["tls-rustls"] } +bytes = "1.7" + +reqwest = { version = "0.12", default-features = false, features = ["rustls-tls", "json"] } + +rcgen = "0.13" +rustls = { version = "0.23", default-features = false, features = ["ring", "std", "tls12"] } +sha2 = "0.10" +hex = "0.4" + +mdns-sd = "0.11" +local-ip-address = "0.6" + +serde = { version = "1.0", features = ["derive"] } +serde_json = "1.0" diff --git a/src-bak/main.rs b/src-bak/main.rs new file mode 100644 index 0000000..0022fe1 --- /dev/null +++ b/src-bak/main.rs @@ -0,0 +1,179 @@ +mod mdns; +mod models; +mod p2p; +mod tls; +mod ui; + +use axum::{ + extract::DefaultBodyLimit, + routing::{get, post}, + Router, +}; +use axum_server::tls_rustls::RustlsConfig; +use local_ip_address::local_ip; +use models::{AppState, MAX_PAYLOAD_SIZE, MAX_RAM_TEXTS, MEDIA_DIR}; +use std::{ + collections::{HashMap, VecDeque}, + net::SocketAddr, + sync::{Arc, RwLock}, +}; + +#[tokio::main] +async fn main() { + // 0. Регистрация глобального CryptoProvider (ring) для rustls 0.23+ + let _ = rustls::crypto::ring::default_provider().install_default(); + + let args: Vec = std::env::args().collect(); + + // Значения по умолчанию + let mut device_name = "My-Device".to_string(); + let mut p2p_port: u16 = 8443; + let mut ui_port: u16 = 8080; + let mut custom_ip: Option = None; + + // Парсинг как именованных флагов (--ip, --name), так и позиционных аргументов + let mut i = 1; + let mut positional_idx = 0; + while i < args.len() { + match args[i].as_str() { + "--ip" => { + if i + 1 < args.len() { + custom_ip = Some(args[i + 1].clone()); + i += 1; + } + } + "--name" => { + if i + 1 < args.len() { + device_name = args[i + 1].clone(); + i += 1; + } + } + "--p2p-port" => { + if i + 1 < args.len() { + if let Ok(p) = args[i + 1].parse() { + p2p_port = p; + } + i += 1; + } + } + "--ui-port" => { + if i + 1 < args.len() { + if let Ok(p) = args[i + 1].parse() { + ui_port = p; + } + i += 1; + } + } + arg if !arg.starts_with("--") => { + match positional_idx { + 0 => device_name = arg.to_string(), + 1 => { + if let Ok(p) = arg.parse() { + p2p_port = p; + } + } + 2 => { + if let Ok(p) = arg.parse() { + ui_port = p; + } + } + 3 => custom_ip = Some(arg.to_string()), + _ => {} + } + positional_idx += 1; + } + _ => {} + } + i += 1; + } + + // Определение адреса привязки (bind_ip) и сетевого IP для сертификата/mDNS + let (bind_ip, my_ip) = match custom_ip { + Some(ip) => { + if ip == "0.0.0.0" { + let detected = local_ip() + .map(|addr| addr.to_string()) + .unwrap_or_else(|_| "127.0.0.1".to_string()); + ("0.0.0.0".to_string(), detected) + } else { + (ip.clone(), ip) + } + } + None => { + let detected = local_ip().expect("Не удалось определить локальный IP").to_string(); + ("0.0.0.0".to_string(), detected) + } + }; + + tokio::fs::create_dir_all(MEDIA_DIR) + .await + .expect("Не удалось создать папку received_media на диске"); + + // 1. Генерация сертификата в ОЗУ под выбранный IP и настройка HTTPS-клиента + let (cert_der, key_der, my_fingerprint) = tls::generate_in_memory_cert(&my_ip); + let trusted_fingerprints = Arc::new(RwLock::new(HashMap::new())); + let http_client = tls::build_pinned_http_client(trusted_fingerprints.clone()); + + let state = Arc::new(AppState { + device_name: device_name.clone(), + my_ip: my_ip.clone(), + p2p_port, + my_fingerprint: my_fingerprint.clone(), + ram_texts: RwLock::new(VecDeque::with_capacity(MAX_RAM_TEXTS)), + disk_media: RwLock::new(VecDeque::new()), + peers: RwLock::new(HashMap::new()), + trusted_fingerprints, + http_client, + }); + + // 2. Запуск mDNS-обнаружения + mdns::start_mdns_service(state.clone()); + + // 3. Запуск внешнего P2P HTTPS-сервера на указанном IP + let tls_config = RustlsConfig::from_der(vec![cert_der], key_der) + .await + .expect("Ошибка конфигурации TLS"); + + let p2p_router = Router::new() + .route("/p2p/text", post(p2p::p2p_receive_text)) + .route("/p2p/media", post(p2p::p2p_receive_media)) + .layer(DefaultBodyLimit::max(MAX_PAYLOAD_SIZE)) + .with_state(state.clone()); + + let p2p_addr: SocketAddr = format!("{}:{}", bind_ip, p2p_port) + .parse() + .unwrap_or_else(|_| panic!("Некорректный IP или порт: {}:{}", bind_ip, p2p_port)); + + tokio::spawn(async move { + axum_server::bind_rustls(p2p_addr, tls_config) + .serve(p2p_router.into_make_service()) + .await + .expect("Ошибка P2P HTTPS-сервера"); + }); + + // 4. Запуск локального UI-сервера (127.0.0.1) + let ui_router = Router::new() + .route("/", get(ui::ui_index)) + .route("/ui/state", get(ui::ui_get_state)) + .route("/ui/trust", post(ui::ui_trust_peer)) + .route("/ui/clear-ram", post(ui::ui_clear_ram)) + .route("/ui/send-text", post(ui::ui_send_text)) + .route("/ui/send-media", post(ui::ui_send_media)) + .route("/ui/files/:filename", get(ui::ui_serve_saved_file)) + .layer(DefaultBodyLimit::max(MAX_PAYLOAD_SIZE)) + .with_state(state); + + let ui_addr: SocketAddr = format!("127.0.0.1:{}", ui_port).parse().unwrap(); + println!("=============================================================="); + println!(" Устройство: {}", device_name); + println!(" P2P сокет (порт открыт на): https://{}:{}", bind_ip, p2p_port); + println!(" Сетевой IP (mDNS / TLS SAN): {}", my_ip); + println!(" КОД СВЕРКИ СЕРТИФИКАТА (PIN): [ {} ]", &my_fingerprint[..8].to_uppercase()); + println!(" Папка для медиа на диске: ./{}/", MEDIA_DIR); + println!("--------------------------------------------------------------"); + println!(" ОТКРОЙТЕ ИНТЕРФЕЙС В БРАУЗЕРЕ: http://127.0.0.1:{}", ui_port); + println!("=============================================================="); + + let listener = tokio::net::TcpListener::bind(ui_addr).await.unwrap(); + axum::serve(listener, ui_router).await.unwrap(); +} diff --git a/src-bak/mdns.rs b/src-bak/mdns.rs new file mode 100644 index 0000000..b4904db --- /dev/null +++ b/src-bak/mdns.rs @@ -0,0 +1,60 @@ +use crate::models::{AppState, PeerNode, SERVICE_TYPE}; +use mdns_sd::{ServiceDaemon, ServiceEvent, ServiceInfo}; +use std::sync::Arc; + +pub fn start_mdns_service(state: Arc) { + let mdns = ServiceDaemon::new().expect("Не удалось запустить mDNS"); + + let instance_name = format!("{}_{}", state.device_name, &state.my_fingerprint[..6]); + let host_name = format!("{}.local.", instance_name); + let properties = [ + ("fp", state.my_fingerprint.as_str()), + ("name", state.device_name.as_str()), + ]; + + let service_info = ServiceInfo::new( + SERVICE_TYPE, + &instance_name, + &host_name, + &state.my_ip, + state.p2p_port, + &properties[..], + ) + .expect("Ошибка создания mDNS записи"); + + mdns.register(service_info).expect("Ошибка регистрации mDNS"); + + let receiver = mdns.browse(SERVICE_TYPE).expect("Ошибка mDNS browse"); + tokio::spawn(async move { + while let Ok(event) = receiver.recv_async().await { + if let ServiceEvent::ServiceResolved(info) = event { + let fp = info + .get_property_val_str("fp") + .unwrap_or_default() + .to_string(); + let name = info + .get_property_val_str("name") + .unwrap_or("Unknown") + .to_string(); + + if fp == state.my_fingerprint || fp.len() < 8 { + continue; + } + + if let Some(ip) = info.get_addresses().iter().next() { + let ip_str = ip.to_string(); + let pin_code = fp[..8].to_uppercase(); + let peer = PeerNode { + name, + ip: ip_str.clone(), + port: info.get_port(), + fingerprint: fp, + pin_code, + verified: false, + }; + state.peers.write().unwrap().insert(ip_str, peer); + } + } + } + }); +} diff --git a/src-bak/models.rs b/src-bak/models.rs new file mode 100644 index 0000000..2637011 --- /dev/null +++ b/src-bak/models.rs @@ -0,0 +1,123 @@ +use serde::{Deserialize, Serialize}; +use std::{ + collections::{HashMap, VecDeque}, + sync::{Arc, RwLock}, + time::{SystemTime, UNIX_EPOCH}, +}; + +/// Лимит одного передаваемого медиафайла (200 МБ) +pub const MAX_PAYLOAD_SIZE: usize = 200 * 1024 * 1024; +/// Максимум текстовых сообщений, хранимых в ОЗУ +pub const MAX_RAM_TEXTS: usize = 50; +/// Папка на диске для сохранения входящего медиаконтента +pub const MEDIA_DIR: &str = "received_media"; +/// Тип сервиса для обнаружения через mDNS +pub const SERVICE_TYPE: &str = "_ramshare._tcp.local."; + +/// Текстовое сообщение (хранится ТОЛЬКО в ОЗУ) +#[derive(Clone, Serialize, Deserialize)] +pub struct TextItem { + pub sender: String, + pub text: String, + pub timestamp: u64, +} + +/// Метаданные медиафайла (сам файл сохраняется НА ДИСК) +#[derive(Clone, Serialize, Deserialize)] +pub struct MediaItem { + pub sender: String, + pub filename: String, + pub saved_path: String, + pub mime: String, + pub size: usize, + pub timestamp: u64, +} + +/// Устройство в локальной сети, найденное через mDNS +#[derive(Clone, Serialize, Deserialize)] +pub struct PeerNode { + pub name: String, + pub ip: String, + pub port: u16, + pub fingerprint: String, + pub pin_code: String, + pub verified: bool, +} + +/// Глобальное состояние приложения +pub struct AppState { + pub device_name: String, + pub my_ip: String, + pub p2p_port: u16, + pub my_fingerprint: String, + pub ram_texts: RwLock>, + pub disk_media: RwLock>, + pub peers: RwLock>, + pub trusted_fingerprints: Arc>>, + pub http_client: reqwest::Client, +} + +#[derive(Serialize, Deserialize)] +pub struct IncomingTextPayload { + pub sender: String, + pub text: String, +} + +#[derive(Deserialize)] +pub struct UiSendTextRequest { + pub target_ip: String, + pub text: String, +} + +#[derive(Deserialize)] +pub struct UiTrustRequest { + pub target_ip: String, + pub trust: bool, +} + +pub fn now_sec() -> u64 { + SystemTime::now() + .duration_since(UNIX_EPOCH) + .unwrap_or_default() + .as_secs() +} + +/// Декодирование URL-encoded имени файла (для поддержки кириллицы и пробелов) +pub fn url_decode(input: &str) -> String { + let mut bytes = Vec::with_capacity(input.len()); + let mut chars = input.as_bytes().iter().copied(); + while let Some(b) = chars.next() { + if b == b'%' { + if let (Some(c1), Some(c2)) = (chars.next(), chars.next()) { + if let Ok(decoded) = u8::from_str_radix(&format!("{}{}", c1 as char, c2 as char), 16) + { + bytes.push(decoded); + continue; + } + } + } else if b == b'+' { + bytes.push(b' '); + } else { + bytes.push(b); + } + } + String::from_utf8_lossy(&bytes).into_owned() +} + +/// Защита от Path Traversal при сохранении медиа на диск +pub fn sanitize_filename(name: &str) -> String { + let decoded = url_decode(name); + let clean: String = decoded + .chars() + .map(|c| match c { + '/' | '\\' | ':' | '*' | '?' | '"' | '<' | '>' | '|' | '\0' => '_', + _ => c, + }) + .collect(); + let trimmed = clean.trim_matches('.').trim(); + if trimmed.is_empty() { + "media_file.bin".to_string() + } else { + trimmed.to_string() + } +} diff --git a/src-bak/p2p.rs b/src-bak/p2p.rs new file mode 100644 index 0000000..1727721 --- /dev/null +++ b/src-bak/p2p.rs @@ -0,0 +1,81 @@ +use crate::models::{ + now_sec, sanitize_filename, url_decode, AppState, IncomingTextPayload, MediaItem, TextItem, + MAX_RAM_TEXTS, MEDIA_DIR, +}; +use axum::{ + body::Bytes, + extract::State, + http::{header, HeaderMap, StatusCode}, + Json, +}; +use std::{path::PathBuf, sync::Arc}; + +/// Прием текста от другого устройства -> сохраняется СТРОГО В ОЗУ +pub async fn p2p_receive_text( + State(state): State>, + Json(payload): Json, +) -> StatusCode { + let mut ram_texts = state.ram_texts.write().unwrap(); + if ram_texts.len() >= MAX_RAM_TEXTS { + ram_texts.pop_back(); + } + ram_texts.push_front(TextItem { + sender: payload.sender, + text: payload.text, + timestamp: now_sec(), + }); + StatusCode::OK +} + +/// Прием медиаконтента от другого устройства -> сохраняется НА ДИСК +pub async fn p2p_receive_media( + State(state): State>, + headers: HeaderMap, + body: Bytes, +) -> Result { + let sender = headers + .get("X-Sender") + .and_then(|v| v.to_str().ok()) + .map(url_decode) + .unwrap_or_else(|| "Unknown".to_string()); + + let raw_filename = headers + .get("X-Filename") + .and_then(|v| v.to_str().ok()) + .unwrap_or("file.bin"); + + let mime = headers + .get(header::CONTENT_TYPE) + .and_then(|v| v.to_str().ok()) + .unwrap_or("application/octet-stream") + .to_string(); + + tokio::fs::create_dir_all(MEDIA_DIR) + .await + .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, e.to_string()))?; + + let safe_name = sanitize_filename(raw_filename); + let final_filename = format!("{}_{}", now_sec(), safe_name); + let file_path = PathBuf::from(MEDIA_DIR).join(&final_filename); + + tokio::fs::write(&file_path, &body) + .await + .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, e.to_string()))?; + + let abs_path = std::fs::canonicalize(&file_path) + .unwrap_or_else(|_| file_path.clone()) + .display() + .to_string(); + + let mut media_list = state.disk_media.write().unwrap(); + media_list.push_front(MediaItem { + sender, + filename: final_filename, + saved_path: abs_path, + mime, + size: body.len(), + timestamp: now_sec(), + }); + + Ok(StatusCode::OK) +} diff --git a/src-bak/static/index.html b/src-bak/static/index.html new file mode 100644 index 0000000..6c190f6 --- /dev/null +++ b/src-bak/static/index.html @@ -0,0 +1,261 @@ + + + + + +LAN Share — Текст в ОЗУ / Медиа на Диск + + + +
+
+
+
Загрузка...
+
+
+
+ Код сверки сертификата (PIN): + -------- +
+
+ +
+ +
+

1. Устройства в сети (mDNS) TLS Pinning

+
+
Поиск устройств...
+
+
+ +
+

2. Отправка данных

+ + + + + + +
+ + +
+ +
+

+ Входящий текст ТОЛЬКО В ОЗУ + +

+
+
+ +
+

Входящие медиафайлы НА ДИСКЕ (./received_media)

+
+
+
+ + + + diff --git a/src-bak/tls.rs b/src-bak/tls.rs new file mode 100644 index 0000000..ffa8c02 --- /dev/null +++ b/src-bak/tls.rs @@ -0,0 +1,138 @@ +use rcgen::{generate_simple_self_signed, CertifiedKey}; +use rustls::{ + client::danger::{HandshakeSignatureValid, ServerCertVerified, ServerCertVerifier}, + crypto::{verify_tls12_signature, verify_tls13_signature, CryptoProvider}, + pki_types::{CertificateDer, ServerName, UnixTime}, + ClientConfig, DigitallySignedStruct, Error as TlsError, SignatureScheme, +}; +use sha2::{Digest, Sha256}; +use std::{ + collections::HashMap, + sync::{Arc, RwLock}, + time::Duration, +}; + +#[derive(Debug)] +pub struct PinnedCertVerifier { + trusted_fingerprints: Arc>>, + provider: Arc, +} + +impl PinnedCertVerifier { + pub fn new(trusted_fingerprints: Arc>>) -> Self { + Self { + trusted_fingerprints, + provider: Arc::new(rustls::crypto::ring::default_provider()), + } + } + + fn cert_fingerprint(cert: &CertificateDer<'_>) -> String { + let mut hasher = Sha256::new(); + hasher.update(cert.as_ref()); + hex::encode(hasher.finalize()) + } +} + +impl ServerCertVerifier for PinnedCertVerifier { + fn verify_server_cert( + &self, + end_entity: &CertificateDer<'_>, + _intermediates: &[CertificateDer<'_>], + server_name: &ServerName<'_>, + _ocsp_response: &[u8], + _now: UnixTime, + ) -> Result { + let actual_fp = Self::cert_fingerprint(end_entity); + let host = match server_name { + ServerName::DnsName(name) => name.as_ref().to_string(), + ServerName::IpAddress(ip) => std::net::IpAddr::from(*ip).to_string(), + _ => return Err(TlsError::General("Неподдерживаемое имя узла".into())), + }; + + let trusted = self.trusted_fingerprints.read().unwrap(); + match trusted.get(&host) { + Some(expected_fp) if expected_fp.eq_ignore_ascii_case(&actual_fp) => { + Ok(ServerCertVerified::assertion()) + } + Some(_) => Err(TlsError::General(format!( + "ВНИМАНИЕ: Сертификат узла {} не совпадает с заверенным!", + host + ))), + None => Err(TlsError::General(format!( + "Узел {} не заверен! Нажмите «Заверить» в списке устройств.", + host + ))), + } + } + + fn verify_tls12_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls12_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn verify_tls13_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls13_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn supported_verify_schemes(&self) -> Vec { + self.provider + .signature_verification_algorithms + .supported_schemes() + } +} + +/// Генерирует самоподписанный сертификат и приватный ключ в ОЗУ +pub fn generate_in_memory_cert(ip: &str) -> (Vec, Vec, String) { + let san = vec!["localhost".to_string(), ip.to_string()]; + let CertifiedKey { cert, key_pair } = + generate_simple_self_signed(san).expect("Ошибка генерации сертификата"); + + let cert_der = cert.der().to_vec(); + let key_der = key_pair.serialize_der(); + + let mut hasher = Sha256::new(); + hasher.update(&cert_der); + let fingerprint = hex::encode(hasher.finalize()); + + (cert_der, key_der, fingerprint) +} + +/// Создает преднастроенный HTTPS-клиент с кастомным верификатором +pub fn build_pinned_http_client( + trusted_fingerprints: Arc>>, +) -> reqwest::Client { + let verifier = Arc::new(PinnedCertVerifier::new(trusted_fingerprints)); + let rustls_client_config = ClientConfig::builder_with_provider(Arc::new( + rustls::crypto::ring::default_provider(), + )) + .with_safe_default_protocol_versions() + .unwrap() + .dangerous() + .with_custom_certificate_verifier(verifier) + .with_no_client_auth(); + + reqwest::Client::builder() + .use_preconfigured_tls(rustls_client_config) + .timeout(Duration::from_secs(30)) + .build() + .expect("Ошибка создания HTTPS-клиента") +} diff --git a/src-bak/ui.rs b/src-bak/ui.rs new file mode 100644 index 0000000..2c76b14 --- /dev/null +++ b/src-bak/ui.rs @@ -0,0 +1,165 @@ +use crate::models::{ + sanitize_filename, AppState, IncomingTextPayload, MediaItem, PeerNode, TextItem, + UiSendTextRequest, UiTrustRequest, MEDIA_DIR, +}; +use axum::{ + body::Bytes, + extract::{Path, State}, + http::{header, HeaderMap, StatusCode}, + response::{Html, IntoResponse}, + Json, +}; +use std::{path::PathBuf, sync::Arc}; + +/// Вшиваем внешний файл src/static/index.html в бинарник на этапе компиляции +const INDEX_HTML: &str = include_str!("static/index.html"); + +pub async fn ui_index() -> Html<&'static str> { + Html(INDEX_HTML) +} + +pub async fn ui_get_state(State(state): State>) -> Json { + let trusted_map = state.trusted_fingerprints.read().unwrap(); + let mut peers_list: Vec = state + .peers + .read() + .unwrap() + .values() + .cloned() + .map(|mut p| { + p.verified = trusted_map + .get(&p.ip) + .map(|fp| fp.eq_ignore_ascii_case(&p.fingerprint)) + .unwrap_or(false); + p + }) + .collect(); + peers_list.sort_by(|a, b| a.name.cmp(&b.name)); + + let texts: Vec = state.ram_texts.read().unwrap().iter().cloned().collect(); + let media: Vec = state.disk_media.read().unwrap().iter().cloned().collect(); + + Json(serde_json::json!({ + "device_name": state.device_name, + "my_ip": state.my_ip, + "p2p_port": state.p2p_port, + "my_fingerprint": state.my_fingerprint, + "my_pin": state.my_fingerprint[..8].to_uppercase(), + "peers": peers_list, + "texts": texts, + "media": media + })) +} + +pub async fn ui_trust_peer( + State(state): State>, + Json(req): Json, +) -> Result { + let peers = state.peers.read().unwrap(); + let peer = peers + .get(&req.target_ip) + .ok_or((StatusCode::NOT_FOUND, "Узел не найден".to_string()))?; + + let mut trusted = state.trusted_fingerprints.write().unwrap(); + if req.trust { + trusted.insert(peer.ip.clone(), peer.fingerprint.clone()); + } else { + trusted.remove(&peer.ip); + } + Ok(StatusCode::OK) +} + +pub async fn ui_clear_ram(State(state): State>) -> StatusCode { + state.ram_texts.write().unwrap().clear(); + StatusCode::OK +} + +pub async fn ui_send_text( + State(state): State>, + Json(req): Json, +) -> Result { + let port = state + .peers + .read() + .unwrap() + .get(&req.target_ip) + .map(|p| p.port) + .unwrap_or(state.p2p_port); + + let url = format!("https://{}:{}/p2p/text", req.target_ip, port); + let payload = IncomingTextPayload { + sender: state.device_name.clone(), + text: req.text, + }; + + let resp = state + .http_client + .post(&url) + .json(&payload) + .send() + .await + .map_err(|e| (StatusCode::BAD_GATEWAY, format!("Ошибка TLS/Сети: {}", e)))?; + + if resp.status().is_success() { + Ok(StatusCode::OK) + } else { + Err((resp.status(), "Удаленный узел отклонил запрос".to_string())) + } +} + +pub async fn ui_send_media( + State(state): State>, + headers: HeaderMap, + body: Bytes, +) -> Result { + let target_ip = headers + .get("X-Target-Ip") + .and_then(|v| v.to_str().ok()) + .ok_or((StatusCode::BAD_REQUEST, "Не указан IP получателя".to_string()))?; + + let filename = headers + .get("X-Filename") + .and_then(|v| v.to_str().ok()) + .unwrap_or("file.bin"); + + let mime = headers + .get(header::CONTENT_TYPE) + .and_then(|v| v.to_str().ok()) + .unwrap_or("application/octet-stream"); + + let port = state + .peers + .read() + .unwrap() + .get(target_ip) + .map(|p| p.port) + .unwrap_or(state.p2p_port); + + let url = format!("https://{}:{}/p2p/media", target_ip, port); + + let resp = state + .http_client + .post(&url) + .header("X-Sender", &state.device_name) + .header("X-Filename", filename) + .header(header::CONTENT_TYPE, mime) + .body(body) + .send() + .await + .map_err(|e| (StatusCode::BAD_GATEWAY, format!("Ошибка TLS/Сети: {}", e)))?; + + if resp.status().is_success() { + Ok(StatusCode::OK) + } else { + Err((resp.status(), "Удаленный узел отклонил медиафайл".to_string())) + } +} + +pub async fn ui_serve_saved_file(Path(filename): Path) -> impl IntoResponse { + let safe_name = sanitize_filename(&filename); + let path = PathBuf::from(MEDIA_DIR).join(&safe_name); + match tokio::fs::read(&path).await { + Ok(bytes) => (StatusCode::OK, bytes).into_response(), + Err(_) => (StatusCode::NOT_FOUND, "Файл не найден на диске").into_response(), + } +} diff --git a/src/discovery.rs b/src/discovery.rs new file mode 100644 index 0000000..3a62bd8 --- /dev/null +++ b/src/discovery.rs @@ -0,0 +1,113 @@ +use crate::models::{AppState, PeerNode}; +use serde::{Deserialize, Serialize}; +use socket2::{Domain, Protocol, Socket, Type}; +use std::{net::SocketAddr, sync::Arc, time::Duration}; +use tokio::net::UdpSocket; + +const BROADCAST_PORT: u16 = 5354; +const BROADCAST_TARGET: &str = "255.255.255.255:5354"; + +#[derive(Serialize, Deserialize)] +struct BeaconPayload { + name: String, + port: u16, + fingerprint: String, +} + +pub fn start_discovery(state: Arc) { + // 1. Поток передачи маяка (Broadcast Transmitter) + let send_state = state.clone(); + tokio::spawn(async move { + let sender = match UdpSocket::bind("0.0.0.0:0").await { + Ok(s) => s, + Err(e) => { + eprintln!("[UDP Beacon] Не удалось открыть сокет отправки: {}", e); + return; + } + }; + let _ = sender.set_broadcast(true); + + loop { + let payload = BeaconPayload { + name: send_state.device_name.clone(), + port: send_state.p2p_port, + fingerprint: send_state.my_fingerprint.clone(), + }; + + if let Ok(data) = serde_json::to_vec(&payload) { + let _ = sender.send_to(&data, BROADCAST_TARGET).await; + } + tokio::time::sleep(Duration::from_secs(2)).await; + } + }); + + // 2. Поток прослушивания маяков (Broadcast Receiver) + tokio::spawn(async move { + let bind_addr: SocketAddr = format!("0.0.0.0:{}", BROADCAST_PORT).parse().unwrap(); + let socket = Socket::new(Domain::IPV4, Type::DGRAM, Some(Protocol::UDP)) + .expect("Ошибка создания UDP сокета"); + + // Кроссплатформенное разрешение повторного использования порта + let _ = socket.set_reuse_address(true); + let _ = socket.set_broadcast(true); + let _ = socket.set_nonblocking(true); + + if let Err(e) = socket.bind(&bind_addr.into()) { + eprintln!( + "[UDP Beacon] Порт {} занят. Фоновое автообнаружение ограничено: {}", + BROADCAST_PORT, e + ); + return; + } + + let std_socket: std::net::UdpSocket = socket.into(); + let receiver = match UdpSocket::from_std(std_socket) { + Ok(s) => s, + Err(e) => { + eprintln!("[UDP Beacon] Ошибка tokio::UdpSocket: {}", e); + return; + } + }; + + let mut buf = [0u8; 1500]; + loop { + match receiver.recv_from(&mut buf).await { + Ok((len, remote_addr)) => { + if let Ok(beacon) = serde_json::from_slice::(&buf[..len]) { + // Игнорируем собственный маяк + if beacon.fingerprint == state.my_fingerprint || beacon.fingerprint.len() < 8 { + continue; + } + + let ip_str = remote_addr.ip().to_string(); + let pin_code = beacon.fingerprint[..8].to_uppercase(); + + let mut peers = state.peers.write().unwrap(); + let is_verified = state + .trusted_fingerprints + .read() + .unwrap() + .get(&ip_str) + .map(|trusted_fp| trusted_fp.eq_ignore_ascii_case(&beacon.fingerprint)) + .unwrap_or(false); + + peers.insert( + ip_str.clone(), + PeerNode { + name: beacon.name, + ip: ip_str, + port: beacon.port, + fingerprint: beacon.fingerprint, + pin_code, + verified: is_verified, + }, + ); + } + } + Err(_) => { + tokio::time::sleep(Duration::from_millis(100)).await; + } + } + } + }); +} diff --git a/src/main.rs b/src/main.rs new file mode 100644 index 0000000..cf2fc78 --- /dev/null +++ b/src/main.rs @@ -0,0 +1,180 @@ +mod discovery; +mod models; +mod p2p; +mod tls; +mod ui; + +use axum::{ + extract::DefaultBodyLimit, + routing::{get, post}, + Router, +}; +use axum_server::tls_rustls::RustlsConfig; +use local_ip_address::local_ip; +use models::{AppState, MAX_PAYLOAD_SIZE, MAX_RAM_TEXTS, MEDIA_DIR}; +use std::{ + collections::{HashMap, VecDeque}, + net::SocketAddr, + sync::{Arc, RwLock}, +}; + +#[tokio::main] +async fn main() { + // 0. Регистрация глобального CryptoProvider (ring) для rustls 0.23+ + let _ = rustls::crypto::ring::default_provider().install_default(); + + let args: Vec = std::env::args().collect(); + + let mut device_name = "My-Device".to_string(); + let mut p2p_port: u16 = 8443; + let mut ui_port: u16 = 8080; + let mut custom_ip: Option = None; + + let mut i = 1; + let mut positional_idx = 0; + while i < args.len() { + match args[i].as_str() { + "--ip" => { + if i + 1 < args.len() { + custom_ip = Some(args[i + 1].clone()); + i += 1; + } + } + "--name" => { + if i + 1 < args.len() { + device_name = args[i + 1].clone(); + i += 1; + } + } + "--p2p-port" => { + if i + 1 < args.len() { + if let Ok(p) = args[i + 1].parse() { + p2p_port = p; + } + i += 1; + } + } + "--ui-port" => { + if i + 1 < args.len() { + if let Ok(p) = args[i + 1].parse() { + ui_port = p; + } + i += 1; + } + } + arg if !arg.starts_with("--") => { + match positional_idx { + 0 => device_name = arg.to_string(), + 1 => { + if let Ok(p) = arg.parse() { + p2p_port = p; + } + } + 2 => { + if let Ok(p) = arg.parse() { + ui_port = p; + } + } + 3 => custom_ip = Some(arg.to_string()), + _ => {} + } + positional_idx += 1; + } + _ => {} + } + i += 1; + } + + let (bind_ip, my_ip) = match custom_ip { + Some(ip) => { + if ip == "0.0.0.0" { + let detected = local_ip() + .map(|addr| addr.to_string()) + .unwrap_or_else(|_| "127.0.0.1".to_string()); + ("0.0.0.0".to_string(), detected) + } else { + (ip.clone(), ip) + } + } + None => { + let detected = local_ip().expect("Не удалось определить локальный IP").to_string(); + ("0.0.0.0".to_string(), detected) + } + }; + + tokio::fs::create_dir_all(MEDIA_DIR) + .await + .expect("Не удалось создать папку received_media на диске"); + + // 1. Генерация сертификата в ОЗУ под выбранный IP и настройка HTTPS-клиентов + let (cert_der, key_der, my_fingerprint) = tls::generate_in_memory_cert(&my_ip); + let trusted_fingerprints = Arc::new(RwLock::new(HashMap::new())); + let http_client = tls::build_pinned_http_client(trusted_fingerprints.clone()); + let probe_client = tls::build_probe_http_client(); + + let state = Arc::new(AppState { + device_name: device_name.clone(), + my_ip: my_ip.clone(), + p2p_port, + my_fingerprint: my_fingerprint.clone(), + ram_texts: RwLock::new(VecDeque::with_capacity(MAX_RAM_TEXTS)), + disk_media: RwLock::new(VecDeque::new()), + peers: RwLock::new(HashMap::new()), + trusted_fingerprints, + http_client, + probe_client, + }); + + // 2. Запуск широковещательного UDP-маяка на порт 5354 + discovery::start_discovery(state.clone()); + + // 3. Запуск внешнего P2P HTTPS-сервера + let tls_config = RustlsConfig::from_der(vec![cert_der], key_der) + .await + .expect("Ошибка конфигурации TLS"); + + let p2p_router = Router::new() + .route("/p2p/info", get(p2p::p2p_info)) + .route("/p2p/text", post(p2p::p2p_receive_text)) + .route("/p2p/media", post(p2p::p2p_receive_media)) + .layer(DefaultBodyLimit::max(MAX_PAYLOAD_SIZE)) + .with_state(state.clone()); + + let p2p_addr: SocketAddr = format!("{}:{}", bind_ip, p2p_port) + .parse() + .unwrap_or_else(|_| panic!("Некорректный сокет: {}:{}", bind_ip, p2p_port)); + + tokio::spawn(async move { + axum_server::bind_rustls(p2p_addr, tls_config) + .serve(p2p_router.into_make_service()) + .await + .expect("Ошибка P2P HTTPS-сервера"); + }); + + // 4. Запуск локального UI-сервера (127.0.0.1) + let ui_router = Router::new() + .route("/", get(ui::ui_index)) + .route("/ui/state", get(ui::ui_get_state)) + .route("/ui/manual-peer", post(ui::ui_add_manual_peer)) + .route("/ui/trust", post(ui::ui_trust_peer)) + .route("/ui/clear-ram", post(ui::ui_clear_ram)) + .route("/ui/send-text", post(ui::ui_send_text)) + .route("/ui/send-media", post(ui::ui_send_media)) + .route("/ui/files/:filename", get(ui::ui_serve_saved_file)) + .layer(DefaultBodyLimit::max(MAX_PAYLOAD_SIZE)) + .with_state(state); + + let ui_addr: SocketAddr = format!("127.0.0.1:{}", ui_port).parse().unwrap(); + println!("=============================================================="); + println!(" Устройство: {}", device_name); + println!(" P2P сокет (HTTPS): https://{}:{}", bind_ip, p2p_port); + println!(" Маяк обнаружения (UDP): 255.255.255.255:5354"); + println!(" КОД СВЕРКИ СЕРТИФИКАТА (PIN): [ {} ]", &my_fingerprint[..8].to_uppercase()); + println!(" Хранилище медиа: ./{}/", MEDIA_DIR); + println!("--------------------------------------------------------------"); + println!(" ОТКРОЙТЕ ИНТЕРФЕЙС В БРАУЗЕРЕ: http://127.0.0.1:{}", ui_port); + println!("=============================================================="); + + let listener = tokio::net::TcpListener::bind(ui_addr).await.unwrap(); + axum::serve(listener, ui_router).await.unwrap(); +} diff --git a/src/mdns.rs b/src/mdns.rs new file mode 100644 index 0000000..b4904db --- /dev/null +++ b/src/mdns.rs @@ -0,0 +1,60 @@ +use crate::models::{AppState, PeerNode, SERVICE_TYPE}; +use mdns_sd::{ServiceDaemon, ServiceEvent, ServiceInfo}; +use std::sync::Arc; + +pub fn start_mdns_service(state: Arc) { + let mdns = ServiceDaemon::new().expect("Не удалось запустить mDNS"); + + let instance_name = format!("{}_{}", state.device_name, &state.my_fingerprint[..6]); + let host_name = format!("{}.local.", instance_name); + let properties = [ + ("fp", state.my_fingerprint.as_str()), + ("name", state.device_name.as_str()), + ]; + + let service_info = ServiceInfo::new( + SERVICE_TYPE, + &instance_name, + &host_name, + &state.my_ip, + state.p2p_port, + &properties[..], + ) + .expect("Ошибка создания mDNS записи"); + + mdns.register(service_info).expect("Ошибка регистрации mDNS"); + + let receiver = mdns.browse(SERVICE_TYPE).expect("Ошибка mDNS browse"); + tokio::spawn(async move { + while let Ok(event) = receiver.recv_async().await { + if let ServiceEvent::ServiceResolved(info) = event { + let fp = info + .get_property_val_str("fp") + .unwrap_or_default() + .to_string(); + let name = info + .get_property_val_str("name") + .unwrap_or("Unknown") + .to_string(); + + if fp == state.my_fingerprint || fp.len() < 8 { + continue; + } + + if let Some(ip) = info.get_addresses().iter().next() { + let ip_str = ip.to_string(); + let pin_code = fp[..8].to_uppercase(); + let peer = PeerNode { + name, + ip: ip_str.clone(), + port: info.get_port(), + fingerprint: fp, + pin_code, + verified: false, + }; + state.peers.write().unwrap().insert(ip_str, peer); + } + } + } + }); +} diff --git a/src/models.rs b/src/models.rs new file mode 100644 index 0000000..6bfcb0a --- /dev/null +++ b/src/models.rs @@ -0,0 +1,119 @@ +use serde::{Deserialize, Serialize}; +use std::{ + collections::{HashMap, VecDeque}, + sync::{Arc, RwLock}, + time::{SystemTime, UNIX_EPOCH}, +}; + +pub const MAX_PAYLOAD_SIZE: usize = 200 * 1024 * 1024; +pub const MAX_RAM_TEXTS: usize = 50; +pub const MEDIA_DIR: &str = "received_media"; + +#[derive(Clone, Serialize, Deserialize)] +pub struct TextItem { + pub sender: String, + pub text: String, + pub timestamp: u64, +} + +#[derive(Clone, Serialize, Deserialize)] +pub struct MediaItem { + pub sender: String, + pub filename: String, + pub saved_path: String, + pub mime: String, + pub size: usize, + pub timestamp: u64, +} + +#[derive(Clone, Serialize, Deserialize)] +pub struct PeerNode { + pub name: String, + pub ip: String, + pub port: u16, + pub fingerprint: String, + pub pin_code: String, + pub verified: bool, +} + +pub struct AppState { + pub device_name: String, + pub my_ip: String, + pub p2p_port: u16, + pub my_fingerprint: String, + pub ram_texts: RwLock>, + pub disk_media: RwLock>, + pub peers: RwLock>, + pub trusted_fingerprints: Arc>>, + pub http_client: reqwest::Client, + pub probe_client: reqwest::Client, +} + +#[derive(Serialize, Deserialize)] +pub struct IncomingTextPayload { + pub sender: String, + pub text: String, +} + +#[derive(Deserialize)] +pub struct UiSendTextRequest { + pub target_ip: String, + pub text: String, +} + +#[derive(Deserialize)] +pub struct UiTrustRequest { + pub target_ip: String, + pub trust: bool, +} + +#[derive(Deserialize)] +pub struct UiManualPeerRequest { + pub ip: String, + pub port: Option, +} + +pub fn now_sec() -> u64 { + SystemTime::now() + .duration_since(UNIX_EPOCH) + .unwrap_or_default() + .as_secs() +} + +pub fn url_decode(input: &str) -> String { + let mut bytes = Vec::with_capacity(input.len()); + let mut chars = input.as_bytes().iter().copied(); + while let Some(b) = chars.next() { + if b == b'%' { + if let (Some(c1), Some(c2)) = (chars.next(), chars.next()) { + if let Ok(decoded) = u8::from_str_radix(&format!("{}{}", c1 as char, c2 as char), 16) + { + bytes.push(decoded); + continue; + } + } + } else if b == b'+' { + bytes.push(b' '); + } else { + bytes.push(b); + } + } + String::from_utf8_lossy(&bytes).into_owned() +} + +pub fn sanitize_filename(name: &str) -> String { + let decoded = url_decode(name); + let clean: String = decoded + .chars() + .map(|c| match c { + '/' | '\\' | ':' | '*' | '?' | '"' | '<' | '>' | '|' | '\0' => '_', + _ => c, + }) + .collect(); + let trimmed = clean.trim_matches('.').trim(); + if trimmed.is_empty() { + "media_file.bin".to_string() + } else { + trimmed.to_string() + } +} diff --git a/src/p2p.rs b/src/p2p.rs new file mode 100644 index 0000000..5b0f294 --- /dev/null +++ b/src/p2p.rs @@ -0,0 +1,91 @@ +use crate::models::{ + now_sec, sanitize_filename, url_decode, AppState, IncomingTextPayload, MediaItem, TextItem, + MAX_RAM_TEXTS, MEDIA_DIR, +}; +use axum::{ + body::Bytes, + extract::State, + http::{header, HeaderMap, StatusCode}, + Json, +}; +use std::{path::PathBuf, sync::Arc}; + +/// Информационный эндпоинт для прямого зондирования узла +pub async fn p2p_info(State(state): State>) -> Json { + Json(serde_json::json!({ + "name": state.device_name, + "port": state.p2p_port, + "fingerprint": state.my_fingerprint, + "pin": state.my_fingerprint[..8].to_uppercase() + })) +} + +/// Прием текста -> СТРОГО В ОЗУ +pub async fn p2p_receive_text( + State(state): State>, + Json(payload): Json, +) -> StatusCode { + let mut ram_texts = state.ram_texts.write().unwrap(); + if ram_texts.len() >= MAX_RAM_TEXTS { + ram_texts.pop_back(); + } + ram_texts.push_front(TextItem { + sender: payload.sender, + text: payload.text, + timestamp: now_sec(), + }); + StatusCode::OK +} + +/// Прием медиаконтента -> НА ДИСК +pub async fn p2p_receive_media( + State(state): State>, + headers: HeaderMap, + body: Bytes, +) -> Result { + let sender = headers + .get("X-Sender") + .and_then(|v| v.to_str().ok()) + .map(url_decode) + .unwrap_or_else(|| "Unknown".to_string()); + + let raw_filename = headers + .get("X-Filename") + .and_then(|v| v.to_str().ok()) + .unwrap_or("file.bin"); + + let mime = headers + .get(header::CONTENT_TYPE) + .and_then(|v| v.to_str().ok()) + .unwrap_or("application/octet-stream") + .to_string(); + + tokio::fs::create_dir_all(MEDIA_DIR) + .await + .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, e.to_string()))?; + + let safe_name = sanitize_filename(raw_filename); + let final_filename = format!("{}_{}", now_sec(), safe_name); + let file_path = PathBuf::from(MEDIA_DIR).join(&final_filename); + + tokio::fs::write(&file_path, &body) + .await + .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, e.to_string()))?; + + let abs_path = std::fs::canonicalize(&file_path) + .unwrap_or_else(|_| file_path.clone()) + .display() + .to_string(); + + let mut media_list = state.disk_media.write().unwrap(); + media_list.push_front(MediaItem { + sender, + filename: final_filename, + saved_path: abs_path, + mime, + size: body.len(), + timestamp: now_sec(), + }); + + Ok(StatusCode::OK) +} diff --git a/src/static/index.html b/src/static/index.html new file mode 100644 index 0000000..a06b377 --- /dev/null +++ b/src/static/index.html @@ -0,0 +1,293 @@ + + + + + +LAN Share — Текст в ОЗУ / Медиа на Диск + + + +
+
+
+
Загрузка...
+
+
+
+ Код сверки сертификата (PIN): + -------- +
+
+ +
+ + +
+

1. Устройства в сети UDP Broadcast

+ +
+ + +
+ +
+
Поиск устройств через маяк 255.255.255.255:5354...
+
+
+ + +
+

2. Отправка данных

+ + + + + + +
+ + +
+ + +
+

+ Входящий текст ТОЛЬКО В ОЗУ + +

+
+
+ + +
+

Входящие медиафайлы НА ДИСКЕ (./received_media)

+
+
+
+ + + + diff --git a/src/tls.rs b/src/tls.rs new file mode 100644 index 0000000..3c4e708 --- /dev/null +++ b/src/tls.rs @@ -0,0 +1,215 @@ +use rcgen::{generate_simple_self_signed, CertifiedKey}; +use rustls::{ + client::danger::{HandshakeSignatureValid, ServerCertVerified, ServerCertVerifier}, + crypto::{verify_tls12_signature, verify_tls13_signature, CryptoProvider}, + pki_types::{CertificateDer, ServerName, UnixTime}, + ClientConfig, DigitallySignedStruct, Error as TlsError, SignatureScheme, +}; +use sha2::{Digest, Sha256}; +use std::{ + collections::HashMap, + sync::{Arc, RwLock}, + time::Duration, +}; + +#[derive(Debug)] +pub struct PinnedCertVerifier { + trusted_fingerprints: Arc>>, + provider: Arc, +} + +impl PinnedCertVerifier { + pub fn new(trusted_fingerprints: Arc>>) -> Self { + Self { + trusted_fingerprints, + provider: Arc::new(rustls::crypto::ring::default_provider()), + } + } + + fn cert_fingerprint(cert: &CertificateDer<'_>) -> String { + let mut hasher = Sha256::new(); + hasher.update(cert.as_ref()); + hex::encode(hasher.finalize()) + } +} + +impl ServerCertVerifier for PinnedCertVerifier { + fn verify_server_cert( + &self, + end_entity: &CertificateDer<'_>, + _intermediates: &[CertificateDer<'_>], + server_name: &ServerName<'_>, + _ocsp_response: &[u8], + _now: UnixTime, + ) -> Result { + let actual_fp = Self::cert_fingerprint(end_entity); + let host = match server_name { + ServerName::DnsName(name) => name.as_ref().to_string(), + ServerName::IpAddress(ip) => std::net::IpAddr::from(*ip).to_string(), + _ => return Err(TlsError::General("Неподдерживаемое имя узла".into())), + }; + + let trusted = self.trusted_fingerprints.read().unwrap(); + match trusted.get(&host) { + Some(expected_fp) if expected_fp.eq_ignore_ascii_case(&actual_fp) => { + Ok(ServerCertVerified::assertion()) + } + Some(_) => Err(TlsError::General(format!( + "ВНИМАНИЕ: Сертификат узла {} не совпадает с заверенным!", + host + ))), + None => Err(TlsError::General(format!( + "Узел {} не заверен! Нажмите «Заверить» в списке устройств.", + host + ))), + } + } + + fn verify_tls12_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls12_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn verify_tls13_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls13_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn supported_verify_schemes(&self) -> Vec { + self.provider + .signature_verification_algorithms + .supported_schemes() + } +} + +/// Верификатор, используемый исключительно для зондирования узла при ручном добавлении по IP +#[derive(Debug)] +pub struct AnyCertVerifier { + provider: Arc, +} + +impl AnyCertVerifier { + pub fn new() -> Self { + Self { + provider: Arc::new(rustls::crypto::ring::default_provider()), + } + } +} + +impl ServerCertVerifier for AnyCertVerifier { + fn verify_server_cert( + &self, + _end_entity: &CertificateDer<'_>, + _intermediates: &[CertificateDer<'_>], + _server_name: &ServerName<'_>, + _ocsp_response: &[u8], + _now: UnixTime, + ) -> Result { + Ok(ServerCertVerified::assertion()) + } + + fn verify_tls12_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls12_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn verify_tls13_signature( + &self, + message: &[u8], + cert: &CertificateDer<'_>, + dss: &DigitallySignedStruct, + ) -> Result { + verify_tls13_signature( + message, + cert, + dss, + &self.provider.signature_verification_algorithms, + ) + } + + fn supported_verify_schemes(&self) -> Vec { + self.provider + .signature_verification_algorithms + .supported_schemes() + } +} + +pub fn generate_in_memory_cert(ip: &str) -> (Vec, Vec, String) { + let san = vec!["localhost".to_string(), ip.to_string()]; + let CertifiedKey { cert, key_pair } = + generate_simple_self_signed(san).expect("Ошибка генерации сертификата"); + + let cert_der = cert.der().to_vec(); + let key_der = key_pair.serialize_der(); + + let mut hasher = Sha256::new(); + hasher.update(&cert_der); + let fingerprint = hex::encode(hasher.finalize()); + + (cert_der, key_der, fingerprint) +} + +pub fn build_pinned_http_client( + trusted_fingerprints: Arc>>, +) -> reqwest::Client { + let verifier = Arc::new(PinnedCertVerifier::new(trusted_fingerprints)); + let rustls_client_config = ClientConfig::builder_with_provider(Arc::new( + rustls::crypto::ring::default_provider(), + )) + .with_safe_default_protocol_versions() + .unwrap() + .dangerous() + .with_custom_certificate_verifier(verifier) + .with_no_client_auth(); + + reqwest::Client::builder() + .use_preconfigured_tls(rustls_client_config) + .timeout(Duration::from_secs(30)) + .build() + .expect("Ошибка создания HTTPS-клиента") +} + +pub fn build_probe_http_client() -> reqwest::Client { + let verifier = Arc::new(AnyCertVerifier::new()); + let rustls_client_config = ClientConfig::builder_with_provider(Arc::new( + rustls::crypto::ring::default_provider(), + )) + .with_safe_default_protocol_versions() + .unwrap() + .dangerous() + .with_custom_certificate_verifier(verifier) + .with_no_client_auth(); + + reqwest::Client::builder() + .use_preconfigured_tls(rustls_client_config) + .timeout(Duration::from_secs(4)) + .build() + .expect("Ошибка создания probe-клиента") +} diff --git a/src/ui.rs b/src/ui.rs new file mode 100644 index 0000000..2462074 --- /dev/null +++ b/src/ui.rs @@ -0,0 +1,219 @@ +use crate::models::{ + sanitize_filename, AppState, IncomingTextPayload, MediaItem, PeerNode, TextItem, + UiManualPeerRequest, UiSendTextRequest, UiTrustRequest, MEDIA_DIR, +}; +use axum::{ + body::Bytes, + extract::{Path, State}, + http::{header, HeaderMap, StatusCode}, + response::{Html, IntoResponse}, + Json, +}; +use std::{path::PathBuf, sync::Arc}; + +const INDEX_HTML: &str = include_str!("static/index.html"); + +pub async fn ui_index() -> Html<&'static str> { + Html(INDEX_HTML) +} + +pub async fn ui_get_state(State(state): State>) -> Json { + let trusted_map = state.trusted_fingerprints.read().unwrap(); + let mut peers_list: Vec = state + .peers + .read() + .unwrap() + .values() + .cloned() + .map(|mut p| { + p.verified = trusted_map + .get(&p.ip) + .map(|fp| fp.eq_ignore_ascii_case(&p.fingerprint)) + .unwrap_or(false); + p + }) + .collect(); + peers_list.sort_by(|a, b| a.name.cmp(&b.name)); + + let texts: Vec = state.ram_texts.read().unwrap().iter().cloned().collect(); + let media: Vec = state.disk_media.read().unwrap().iter().cloned().collect(); + + Json(serde_json::json!({ + "device_name": state.device_name, + "my_ip": state.my_ip, + "p2p_port": state.p2p_port, + "my_fingerprint": state.my_fingerprint, + "my_pin": state.my_fingerprint[..8].to_uppercase(), + "peers": peers_list, + "texts": texts, + "media": media + })) +} + +pub async fn ui_add_manual_peer( + State(state): State>, + Json(req): Json, +) -> Result { + let ip = req.ip.trim().to_string(); + let port = req.port.unwrap_or(8443); + + let url = format!("https://{}:{}/p2p/info", ip, port); + let resp = state + .probe_client + .get(&url) + .send() + .await + .map_err(|e| (StatusCode::BAD_REQUEST, format!("Узел недоступен: {}", e)))?; + + if !resp.status().is_success() { + return Err((StatusCode::BAD_GATEWAY, "Узел вернул ошибку".into())); + } + + let info: serde_json::Value = resp + .json() + .await + .map_err(|_| (StatusCode::BAD_GATEWAY, "Неверный ответ узла".into()))?; + + let name = info["name"].as_str().unwrap_or("Manual-Node").to_string(); + let fingerprint = info["fingerprint"].as_str().unwrap_or("").to_string(); + + if fingerprint.is_empty() { + return Err((StatusCode::BAD_GATEWAY, "Отсутствует отпечаток узла".into())); + } + + let pin_code = fingerprint[..8].to_uppercase(); + let is_verified = state + .trusted_fingerprints + .read() + .unwrap() + .get(&ip) + .map(|fp| fp.eq_ignore_ascii_case(&fingerprint)) + .unwrap_or(false); + + state.peers.write().unwrap().insert( + ip.clone(), + PeerNode { + name, + ip, + port, + fingerprint, + pin_code, + verified: is_verified, + }, + ); + + Ok(StatusCode::OK) +} + +pub async fn ui_trust_peer( + State(state): State>, + Json(req): Json, +) -> Result { + let peers = state.peers.read().unwrap(); + let peer = peers + .get(&req.target_ip) + .ok_or((StatusCode::NOT_FOUND, "Узел не найден".to_string()))?; + + let mut trusted = state.trusted_fingerprints.write().unwrap(); + if req.trust { + trusted.insert(peer.ip.clone(), peer.fingerprint.clone()); + } else { + trusted.remove(&peer.ip); + } + Ok(StatusCode::OK) +} + +pub async fn ui_clear_ram(State(state): State>) -> StatusCode { + state.ram_texts.write().unwrap().clear(); + StatusCode::OK +} + +pub async fn ui_send_text( + State(state): State>, + Json(req): Json, +) -> Result { + let port = state + .peers + .read() + .unwrap() + .get(&req.target_ip) + .map(|p| p.port) + .unwrap_or(state.p2p_port); + + let url = format!("https://{}:{}/p2p/text", req.target_ip, port); + let payload = IncomingTextPayload { + sender: state.device_name.clone(), + text: req.text, + }; + + let resp = state + .http_client + .post(&url) + .json(&payload) + .send() + .await + .map_err(|e| (StatusCode::BAD_GATEWAY, format!("Ошибка TLS/Сети: {}", e)))?; + + if resp.status().is_success() { + Ok(StatusCode::OK) + } else { + Err((resp.status(), "Удаленный узел отклонил запрос".to_string())) + } +} + +pub async fn ui_send_media( + State(state): State>, + headers: HeaderMap, + body: Bytes, +) -> Result { + let target_ip = headers + .get("X-Target-Ip") + .and_then(|v| v.to_str().ok()) + .ok_or((StatusCode::BAD_REQUEST, "Не указан IP получателя".to_string()))?; + + let filename = headers + .get("X-Filename") + .and_then(|v| v.to_str().ok()) + .unwrap_or("file.bin"); + + let mime = headers + .get(header::CONTENT_TYPE) + .and_then(|v| v.to_str().ok()) + .unwrap_or("application/octet-stream"); + + let port = state + .peers + .read() + .unwrap() + .get(target_ip) + .map(|p| p.port) + .unwrap_or(state.p2p_port); + + let url = format!("https://{}:{}/p2p/media", target_ip, port); + + let resp = state + .http_client + .post(&url) + .header("X-Sender", &state.device_name) + .header("X-Filename", filename) + .header(header::CONTENT_TYPE, mime) + .body(body) + .send() + .await + .map_err(|e| (StatusCode::BAD_GATEWAY, format!("Ошибка TLS/Сети: {}", e)))?; + + if resp.status().is_success() { + Ok(StatusCode::OK) + } else { + Err((resp.status(), "Удаленный узел отклонил медиафайл".to_string())) + } +} + +pub async fn ui_serve_saved_file(Path(filename): Path) -> impl IntoResponse { + let safe_name = sanitize_filename(&filename); + let path = PathBuf::from(MEDIA_DIR).join(&safe_name); + match tokio::fs::read(&path).await { + Ok(bytes) => (StatusCode::OK, bytes).into_response(), + Err(_) => (StatusCode::NOT_FOUND, "Файл не найден на диске").into_response(), + } +}