m2m-protocol 0.4.0

M2M Protocol - Intelligent machine-to-machine LLM communication with learned compression
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247

[package]
name = "m2m-protocol"
version = "0.4.0"
edition = "2021"
rust-version = "1.88"
license = "Apache-2.0"
description = "M2M Protocol - Intelligent machine-to-machine LLM communication with learned compression"
repository = "https://github.com/infernet-org/m2m-protocol"
keywords = ["llm", "compression", "m2m", "protocol", "ai"]
categories = ["compression", "web-programming", "science"]
readme = "README.md"
authors = ["M2M Protocol Contributors"]

[lib]
name = "m2m"
path = "src/lib.rs"

[[bin]]
name = "m2m"
path = "src/bin/m2m.rs"

[[bin]]
name = "benchmark"
path = "src/bin/benchmark.rs"

[[bin]]
name = "m2m-ai-test"
path = "src/bin/m2m_ai_test.rs"

[[bin]]
name = "agent-town"
path = "src/bin/agent_town.rs"
required-features = ["crypto"]

[dependencies]
# Serialization
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"

# Error handling
thiserror = "1.0"
anyhow = "1.0"

# Tokenizers
tiktoken-rs = "0.9"  # OpenAI BPE (cl100k, o200k)
tokenizers = { version = "0.21", default-features = false, features = ["onig"] }  # HuggingFace (Llama 3, etc.)

# Compile-time hash maps
phf = { version = "0.11", features = ["macros"] }

# Async runtime
tokio = { version = "1.0", features = ["rt-multi-thread", "macros", "net", "sync", "time", "io-util"] }

# HTTP server
axum = "0.7"
tower = { version = "0.4", features = ["util"] }
tower-http = { version = "0.5", features = ["cors", "trace"] }

# HTTP client
reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls", "stream"] }

# Streaming
futures = "0.3"

# CLI
clap = { version = "4", features = ["derive"] }

# Config
toml = "0.8"
dirs = "5.0"

# Logging
tracing = "0.1"
tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }

# === NEW: M2M Protocol Dependencies ===

# Compression codecs
brotli = "7.0"
flate2 = "1.0"  # zlib/gzip

# Integrity checking
crc32fast = "1.5"

# Tensor operations (for inference)
ndarray = "0.16"

# Model loading
safetensors = "0.4"

# UUID for session IDs
uuid = { version = "1.0", features = ["v4"] }

# Base64 encoding for wire format
base64 = "0.22"

# Byte manipulation
bytes = "1.0"

# Timestamps for benchmarks
chrono = { version = "0.4", features = ["serde"] }

# Regex for pattern matching (security)
regex = { version = "1.0", features = ["perf"] }
lazy_static = "1.4"

# Graph data structures for network topology
petgraph = "0.7"

# === QUIC Transport ===
# QUIC implementation (using quinn 0.10 for h3-quinn compatibility)
quinn = "0.10"
rustls = { version = "0.21", default-features = false, features = ["dangerous_configuration", "quic", "tls12"] }
rcgen = "0.12"  # Self-signed cert generation for dev
rustls-pemfile = "1.0"

# HTTP/3 layer (h3-quinn 0.0.5 requires h3 0.0.4)
h3 = "0.0.4"
h3-quinn = "0.0.5"

# Async streams for h3
http = "1.0"
http-body-util = "0.1"

# === Optional: Cryptographic Security ===
# Used for M2M wire format authentication and encryption
hkdf = { version = "0.12", optional = true }
sha2 = { version = "0.10", optional = true }
hmac = { version = "0.12", optional = true }
chacha20poly1305 = { version = "0.10", optional = true }
x25519-dalek = { version = "2.0", features = ["static_secrets"], optional = true }
rand = { version = "0.8", optional = true }
zeroize = { version = "1.8", features = ["zeroize_derive"], optional = true }

[dev-dependencies]
criterion = { version = "0.5", features = ["html_reports"] }
tokio-test = "0.4"
tempfile = "3.0"
hex-literal = "0.4"  # For RFC test vectors
rand_chacha = "0.3"  # Deterministic RNG for testing
dotenvy = "0.15"     # Load .env for integration tests
proptest = "1.5"     # Property-based testing

[build-dependencies]
phf_codegen = "0.11"

# [[bench]]
# name = "inference"
# harness = false

[profile.release]
opt-level = 3
lto = true
codegen-units = 1
strip = true
panic = "abort"

[profile.dev]
opt-level = 0
debug = true

[features]
default = []
# Cryptographic security for M2M wire format (HMAC, AEAD, key exchange)
crypto = ["dep:hkdf", "dep:sha2", "dep:hmac", "dep:chacha20poly1305", "dep:x25519-dalek", "dep:rand", "dep:zeroize"]

# =============================================================================
# Lints Configuration
# =============================================================================

[lints.rust]
# Safety
unsafe_code = "warn"
# Documentation
missing_docs = "warn"
# Allow unknown lints for cross-version compatibility (lint names change between Rust versions)
unknown_lints = "allow"

[lints.clippy]
# Pedantic (enable selectively) - set lowest priority
pedantic = { level = "warn", priority = -1 }

# Allow common pedantic exceptions
module_name_repetitions = "allow"
must_use_candidate = "allow"
missing_errors_doc = "allow"
comparison_chain = "allow"         # if chains are sometimes clearer
double_ended_iterator_last = "allow" # .last() is more readable than .next_back()
manual_div_ceil = "allow"          # Manual div_ceil is compatible with older Rust
missing_panics_doc = "allow"
doc_markdown = "allow"
similar_names = "allow"
too_many_lines = "allow"
struct_excessive_bools = "allow"
unreadable_literal = "allow"           # Context lengths like 128000 are fine
needless_raw_string_hashes = "allow"   # Raw strings with # are clearer
cast_possible_truncation = "allow"     # usize to f64 is intentional for stats
cast_precision_loss = "allow"          # usize to f64 is intentional for stats
cast_lossless = "allow"                # u8 to u32 is fine
unnecessary_wraps = "allow"            # Result<T> for consistency
redundant_closure_for_method_calls = "allow"  # Clearer in some contexts
only_used_in_recursion = "allow"       # False positives with &self in recursive fns
self_only_used_in_recursion = "allow"  # Same lint, renamed in Rust 1.92+
manual_repeat_n = "allow"              # repeat().take() is clearer than repeat_n() for MSRV compat
unused_self = "allow"                  # Preparation for future use
manual_let_else = "allow"              # match is sometimes clearer
return_self_not_must_use = "allow"     # Builder pattern methods
uninlined_format_args = "allow"        # Explicit variables in format! is clearer
manual_strip = "allow"                 # Manual prefix stripping can be clearer
option_if_let_else = "allow"           # match is sometimes clearer
map_unwrap_or = "allow"                # map().unwrap_or() is readable
if_not_else = "allow"                  # != in conditions is fine
match_same_arms = "allow"              # Sometimes intentional for clarity
assigning_clones = "allow"             # Explicit clone assignment is clear
format_push_string = "allow"           # format! append is fine for readability
fn_params_excessive_bools = "allow"    # Sometimes needed for config
struct_field_names = "allow"           # Same postfix can be clear (e.g., tokens)
useless_vec = "allow"                  # vec![] for consistency
single_char_pattern = "allow"          # String patterns can be clearer
trivially_copy_pass_by_ref = "allow"   # Consistency in API design
single_match = "allow"                 # match for clarity
manual_is_power_of_two = "allow"       # Manual check can be clearer
manual_map = "allow"                   # Explicit is sometimes clearer
ref_option = "allow"                   # Option reference patterns are fine
cast_sign_loss = "allow"               # usize to i64 is intentional
io_other_error = "allow"               # std::io::Error::new() is fine
ignored_unit_patterns = "allow"        # Ignore patterns are fine
manual_saturating_arithmetic = "allow" # Manual checks can be clearer
implicit_clone = "allow"               # to_string() on &str is fine
to_string_trait_impl = "allow"         # to_string() impl is fine
significant_drop_tightening = "allow"  # Drop order sometimes matters
inefficient_to_string = "allow"        # &&str.to_string() is fine for clarity
needless_pass_by_value = "allow"       # Pass by value for consistency
checked_conversions = "allow"          # Manual checks can be clearer
single_match_else = "allow"            # match with else can be clearer
cast_possible_wrap = "allow"           # usize to i64 is intentional
manual_range_contains = "allow"        # Manual checks can be clearer
implicit_saturating_sub = "allow"      # Manual arithmetic is fine
non_std_lazy_statics = "allow"         # lazy_static! is fine, LazyLock migration not urgent

# Cargo
multiple_crate_versions = "allow"      # Common in large dependency trees

[lints.rustdoc]
# Documentation quality
broken_intra_doc_links = "warn"
private_intra_doc_links = "warn"