()
| 234 | |
| 235 | #[tokio::test] |
| 236 | async fn rejects_unsupported_version() { |
| 237 | let server = TestServer::start().await; |
| 238 | let mut bytes = drain_backup(&server, TENANT).await.expect("BACKUP"); |
| 239 | bytes[4] = 99; // version byte in header |
| 240 | let err = push_restore(&server, TENANT, bytes, false) |
| 241 | .await |
| 242 | .unwrap_err(); |
| 243 | let msg = err.to_lowercase(); |
| 244 | assert!( |
| 245 | msg.contains("unsupported") |
| 246 | && (msg.contains("envelope version") || msg.contains("backup version")), |
| 247 | "expected version rejection, got: {err}" |
| 248 | ); |
| 249 | } |
| 250 | |
| 251 | // Touching the import to keep wire stream type used. |
| 252 | #[allow(dead_code)] |
nothing calls this directly
no test coverage detected