MCPcopy Create free account
hub / github.com/It4innovations/hyperqueue / test_store_load

Function test_store_load

crates/hyperqueue/src/common/serverdir.rs:308–338  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

306
307 #[test]
308 fn test_store_load() {
309 let record = FullAccessRecord::new(
310 ConnectAccessRecordPart {
311 host: "foo".into(),
312 port: 42,
313 secret_key: Some(Arc::new(generate_key())),
314 },
315 ConnectAccessRecordPart {
316 host: "bar".into(),
317 port: 42,
318 secret_key: Some(Arc::new(generate_key())),
319 },
320 "testHQ".into(),
321 );
322 let path = TempDir::with_prefix("foo")
323 .unwrap()
324 .keep()
325 .join("access.json");
326 store_access_record(&record, path.clone()).unwrap();
327 let loaded = load_worker_access_file(&path).unwrap();
328 assert_eq!(loaded.version, record.version);
329 assert_eq!(loaded.worker.host, record.worker_host());
330 assert_eq!(loaded.worker.port, record.worker_port());
331 assert_eq!(loaded.worker.secret_key.as_ref(), record.worker_key());
332
333 let loaded = load_client_access_file(&path).unwrap();
334 assert_eq!(loaded.version, record.version);
335 assert_eq!(loaded.client.host, record.client_host());
336 assert_eq!(loaded.client.port, record.client_port());
337 assert_eq!(loaded.client.secret_key.as_ref(), record.client_key());
338 }
339
340 #[test]
341 fn test_server_dir_start_at_one() {

Callers

nothing calls this directly

Calls 6

store_access_recordFunction · 0.85
load_worker_access_fileFunction · 0.85
load_client_access_fileFunction · 0.85
intoMethod · 0.80
generate_keyFunction · 0.50
cloneMethod · 0.45

Tested by

no test coverage detected