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
|
use anyhow::{Context, Result};
use futures::join;
use nostr::nips::nip01::Coordinate;
use nostr_sdk::{Kind, ToBech32};
use relay::Relay;
use serial_test::serial;
use test_utils::{git::GitTestRepo, *};
static NOSTR_REMOTE_NAME: &str = "nostr";
fn get_nostr_remote_url() -> Result<String> {
let repo_event = generate_repo_ref_event();
let naddr = Coordinate {
kind: Kind::GitRepoAnnouncement,
public_key: repo_event.author(),
identifier: repo_event.identifier().unwrap().to_string(),
relays: vec![
"ws://localhost:8055".to_string(),
"ws://localhost:8056".to_string(),
],
}
.to_bech32()?;
Ok(format!("nostr://{naddr}"))
}
fn prep_git_repo() -> Result<GitTestRepo> {
let test_repo = GitTestRepo::without_repo_in_git_config();
let mut config = test_repo
.git_repo
.config()
.context("cannot open git config")?;
config.set_str("nostr.nsec", TEST_KEY_1_NSEC)?;
config.set_str("nostr.npub", TEST_KEY_1_NPUB)?;
test_repo.add_remote(NOSTR_REMOTE_NAME, &get_nostr_remote_url()?)?;
test_repo.populate()?;
Ok(test_repo)
}
fn cli_tester(git_repo: &GitTestRepo) -> CliTester {
CliTester::new_remote_helper_from_dir(&git_repo.dir, &get_nostr_remote_url().unwrap())
}
fn cli_tester_after_fetch(git_repo: &GitTestRepo) -> Result<CliTester> {
let mut p = cli_tester(git_repo);
p.expect("fetching updates...\r\n")?;
p.expect_eventually("updates")?; // some updates
p.expect_eventually("\r\n")?;
Ok(p)
}
mod initially_runs_fetch {
use relay::ListenerReqFunc;
use super::*;
async fn async_run_test() -> Result<()> {
let source_git_repo = prep_git_repo()?;
let source_git_url = format!("git://{}", source_git_repo.dir.to_str().unwrap());
let git_repo = prep_git_repo()?;
let events = vec![
generate_test_key_1_metadata_event("fred"),
generate_test_key_1_relay_list_event(),
generate_repo_ref_event_with_git_server(source_git_url),
];
let responder: ListenerReqFunc = &|relay, client_id, subscription_id, _| -> Result<()> {
relay.respond_events(client_id, &subscription_id, &events)?;
Ok(())
};
// fallback (51,52) user write (53, 55) repo (55, 56) blaster (57)
let (mut r51, mut r52, mut r53, mut r55, mut r56, mut r57) = (
Relay::new(8051, None, Some(&responder)),
Relay::new(8052, None, None),
Relay::new(8053, None, None),
Relay::new(8055, None, None),
Relay::new(8056, None, None),
Relay::new(8057, None, None),
);
// // check relay had the right number of events
let cli_tester_handle = std::thread::spawn(move || -> Result<()> {
let mut p = cli_tester_after_fetch(&git_repo)?;
p.exit()?;
for p in [51, 52, 53, 55, 56, 57] {
relay::shutdown_relay(8000 + p)?;
}
Ok(())
});
// launch relay
let _ = join!(
r51.listen_until_close(),
r52.listen_until_close(),
r53.listen_until_close(),
r55.listen_until_close(),
r56.listen_until_close(),
r57.listen_until_close(),
);
cli_tester_handle.join().unwrap()?;
Ok(())
}
#[tokio::test]
#[serial]
async fn runs_fetch_and_reports() -> Result<()> {
async_run_test().await
}
}
|