firewatch 0.1.0-rc.3

Security alerts for Lightning nodes: checks your node against published advisories
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
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
//! `firewatch init`: find the operator's nodes, set up a read-only
//! connection to each, and write the config.
//!
//! LND needs nothing from the operator: its `readonly.macaroon` already
//! exists. Core Lightning needs one restricted rune, and creating a rune is a
//! change to the node, which Firewatch never makes, so `init` prints the
//! command and asks for the result.

use std::io::Write;
use std::os::unix::fs::{OpenOptionsExt, PermissionsExt};
use std::path::{Path, PathBuf};

use anyhow::{bail, Context, Result};
use firewatch_connectors::NodeConfig;

use crate::config;

const RUNE_RESTRICTIONS: &str = r#"'[["method=getinfo","method=listconfigs"]]'"#;
const RELAYS: [&str; 3] = [
    "wss://relay.damus.io",
    "wss://nos.lol",
    "wss://relay.primal.net",
];

pub async fn run(path: Option<PathBuf>, force: bool) -> Result<()> {
    let path = path.unwrap_or_else(config::default_path);
    if path.exists() && !force {
        bail!(
            "{} already exists. Pass --force to replace it, or --config to write somewhere else",
            path.display()
        );
    }
    let home = std::env::var_os("HOME")
        .map(PathBuf::from)
        .context("HOME isn't set")?;
    let mut ask = Prompt::stdin();

    println!("Firewatch setup.");
    println!("Firewatch only reads your node. It never needs a credential that can spend or change settings.\n");

    let lnd_dir = std::env::var_os("LND_DIR").map(PathBuf::from);
    let found = detect(&home, lnd_dir, &mut ask);
    if found.is_empty() {
        println!("No node found in the usual places (~/.lnd, ~/.lightning, Umbrel, Polar).");
    } else {
        println!("Found {} node(s):", found.len());
        for c in &found {
            println!("  - {}", c.label);
        }
        println!();
    }

    let http = firewatch_connectors::http_client();
    let mut nodes: Vec<String> = Vec::new();
    let mut names: Vec<String> = Vec::new();
    for candidate in found {
        if !ask.yes(&format!("Watch {}?", candidate.label), true) {
            continue;
        }
        let Some(toml) = candidate.into_toml(&mut ask) else {
            println!("  Skipped.\n");
            continue;
        };
        if keep_after_test(&toml, &http, &mut ask).await {
            names.push(node_name(&toml));
            nodes.push(toml);
        }
    }
    add_by_hand(&mut ask, &http, &mut nodes, &mut names).await;
    if nodes.is_empty() {
        bail!("no nodes to watch, so no config was written");
    }

    let dir = path
        .parent()
        .map(Path::to_path_buf)
        .unwrap_or_else(|| PathBuf::from("."));
    let npub = loop {
        let answer = ask.line(
            "\nYour Nostr npub, for encrypted alerts on your phone (Enter to skip). \
             On iPhone use Nostur; on Android, Amethyst or 0xchat:\n> ",
        );
        if answer.is_empty() {
            break None;
        }
        match firewatch_alerts::check_recipient(&answer) {
            Ok(()) => break Some(answer),
            Err(e) => println!("  {e}. Try again, or press Enter to skip."),
        }
    };

    let text = render(&nodes, npub.as_deref(), &dir.join("firewatch.nsec"));
    std::fs::create_dir_all(&dir).with_context(|| format!("creating {}", dir.display()))?;
    write_private(&path, &text)?;

    println!("\nWrote {} ({} node(s)).\n", path.display(), nodes.len());
    println!("Next:");
    println!("  firewatch check        # check your nodes once");
    if npub.is_some() {
        println!("  firewatch test-alert   # make sure alerts reach your phone; accept the first message request");
    }
    println!("  firewatch watch        # keep checking, alert on changes, dashboard at http://127.0.0.1:7070");
    Ok(())
}

/// Asks for nodes by hand until the operator says no. Stops at end of input:
/// "yes" is the default while there are no nodes, so it would ask forever.
async fn add_by_hand(
    ask: &mut Prompt,
    http: &reqwest::Client,
    nodes: &mut Vec<String>,
    names: &mut Vec<String>,
) {
    while ask.yes("Add a node by hand?", nodes.is_empty()) && !ask.ended() {
        let Some(toml) = manual(ask, names) else {
            continue;
        };
        if keep_after_test(&toml, http, ask).await {
            names.push(node_name(&toml));
            nodes.push(toml);
        }
    }
}

/// Writes the config so only this user can read it: it holds runes.
/// `mode` only applies when the file is created, so a file that `--force`
/// replaces is set to 0600 too, before anything is written to it.
fn write_private(path: &Path, text: &str) -> Result<()> {
    let mut file = std::fs::OpenOptions::new()
        .write(true)
        .create(true)
        .truncate(true)
        .mode(0o600)
        .open(path)
        .with_context(|| format!("writing {}", path.display()))?;
    file.set_permissions(std::fs::Permissions::from_mode(0o600))
        .with_context(|| format!("making {} private", path.display()))?;
    file.write_all(text.as_bytes())
        .with_context(|| format!("writing {}", path.display()))
}

/// A node found on this machine, before the operator has confirmed it.
struct Candidate {
    label: String,
    name: String,
    kind: Kind,
}

enum Kind {
    Lnd {
        url: String,
        macaroon: PathBuf,
        tls_cert: PathBuf,
        /// Whether the REST address is known (Polar) or a default to confirm.
        url_known: bool,
    },
    Cln {
        url: String,
        url_known: bool,
        tls_cert: Option<PathBuf>,
        /// How to create the restricted rune on this node.
        rune_command: String,
    },
}

impl Candidate {
    /// The node's `[[nodes]]` block, after asking for whatever detection
    /// couldn't know. `None` if the operator gave up on it.
    fn into_toml(self, ask: &mut Prompt) -> Option<String> {
        match self.kind {
            Kind::Lnd {
                url,
                macaroon,
                tls_cert,
                url_known,
            } => {
                let url = if url_known {
                    url
                } else {
                    ask.default("  LND REST address", &url)
                };
                Some(lnd_toml(&self.name, &url, &macaroon, Some(&tls_cert)))
            }
            Kind::Cln {
                url,
                url_known,
                tls_cert,
                rune_command,
            } => {
                let url = if url_known {
                    url
                } else {
                    ask.default("  clnrest address", &url)
                };
                println!("  Firewatch needs a rune that can only read. Create one by running:\n");
                println!("    {rune_command}\n");
                let rune = ask.secret(
                    "  Paste the \"rune\" value it prints (Enter to skip this node):\n  > ",
                );
                let rune = rune.trim_matches('"').to_string();
                (!rune.is_empty()).then(|| cln_toml(&self.name, &url, &rune, tls_cert.as_deref()))
            }
        }
    }
}

/// Everything Firewatch can find on this machine.
fn detect(home: &Path, lnd_dir: Option<PathBuf>, ask: &mut Prompt) -> Vec<Candidate> {
    let mut found = Vec::new();

    // LND in its usual data folders. The REST port is the default unless the
    // operator says otherwise.
    let lnd_dirs = [
        lnd_dir,
        Some(home.join(".lnd")),
        Some(home.join("umbrel/app-data/lightning/data/lnd")),
    ];
    let mut seen = Vec::new();
    for dir in lnd_dirs.into_iter().flatten() {
        // LND_DIR is often ~/.lnd itself, or a link to it.
        let real = dir.canonicalize().unwrap_or_else(|_| dir.clone());
        if seen.contains(&real) || !dir.join("tls.cert").is_file() {
            continue;
        }
        seen.push(real);
        for network in ["mainnet", "testnet", "testnet4", "signet", "regtest"] {
            let macaroon = dir.join(format!("data/chain/bitcoin/{network}/readonly.macaroon"));
            if macaroon.is_file() {
                found.push(Candidate {
                    label: format!("LND ({network}) in {}", dir.display()),
                    name: format!("lnd-{network}"),
                    kind: Kind::Lnd {
                        url: "https://127.0.0.1:8080".into(),
                        macaroon,
                        tls_cert: dir.join("tls.cert"),
                        url_known: false,
                    },
                });
            }
        }
    }

    // Core Lightning in ~/.lightning: clnrest has no default port, so ask.
    for network in ["bitcoin", "testnet", "testnet4", "signet", "regtest"] {
        let dir = home.join(".lightning").join(network);
        if !dir.join("lightning-rpc").exists() {
            continue;
        }
        let server_pem = dir.join("server.pem");
        let https = server_pem.is_file();
        found.push(Candidate {
            label: format!("Core Lightning ({network}) in {}", dir.display()),
            name: format!("cln-{network}"),
            kind: Kind::Cln {
                url: format!("{}://127.0.0.1:3010", if https { "https" } else { "http" }),
                url_known: false,
                tls_cert: https.then_some(server_pem),
                rune_command: format!(
                    "lightning-cli --network={network} createrune restrictions={RUNE_RESTRICTIONS}"
                ),
            },
        });
    }

    found.extend(polar(home, ask));
    unique_names(&mut found);
    found
}

/// Gives each candidate its own name: two LND folders on one network would
/// both be `lnd-mainnet`, and `watch` keeps each node's state by name.
fn unique_names(found: &mut [Candidate]) {
    let mut used: Vec<String> = Vec::new();
    for c in found.iter_mut() {
        let base = c.name.clone();
        let mut n = 2;
        while used.contains(&c.name) {
            c.name = format!("{base}-{n}");
            n += 1;
        }
        used.push(c.name.clone());
    }
}

/// Nodes in a Polar network, with their real ports. Polar serves clnrest over
/// plain HTTP on localhost.
fn polar(home: &Path, ask: &mut Prompt) -> Vec<Candidate> {
    let polar = home.join(".polar/networks");
    let Ok(text) = std::fs::read_to_string(polar.join("networks.json")) else {
        return vec![];
    };
    let Ok(json) = serde_json::from_str::<serde_json::Value>(&text) else {
        return vec![];
    };
    let networks: Vec<&serde_json::Value> = json["networks"]
        .as_array()
        .map(|n| {
            n.iter()
                .filter(|n| {
                    n["nodes"]["lightning"]
                        .as_array()
                        .is_some_and(|l| !l.is_empty())
                })
                .collect()
        })
        .unwrap_or_default();
    let network = match networks.as_slice() {
        [] => return vec![],
        [only] => *only,
        many => {
            println!("Polar networks with Lightning nodes:");
            for (i, n) in many.iter().enumerate() {
                println!("  {}. {}", i + 1, n["name"].as_str().unwrap_or("?").trim());
            }
            let pick = ask.default("Which one? (number, or 0 for none)", "1");
            match pick.parse::<usize>() {
                Ok(i) if (1..=many.len()).contains(&i) => many[i - 1],
                _ => return vec![],
            }
        }
    };
    let id = network["id"].as_u64().unwrap_or_default();
    let net_name = network["name"].as_str().unwrap_or("Polar").trim();
    let volumes = polar.join(id.to_string()).join("volumes");

    let mut found = Vec::new();
    for node in network["nodes"]["lightning"]
        .as_array()
        .into_iter()
        .flatten()
    {
        let (Some(name), Some(rest)) = (node["name"].as_str(), node["ports"]["rest"].as_u64())
        else {
            continue;
        };
        let label = format!("{name} (Polar \"{net_name}\", port {rest})");
        match node["implementation"].as_str() {
            Some("LND") => {
                let dir = volumes.join("lnd").join(name);
                found.push(Candidate {
                    label,
                    name: name.into(),
                    kind: Kind::Lnd {
                        url: format!("https://127.0.0.1:{rest}"),
                        macaroon: dir.join("data/chain/bitcoin/regtest/readonly.macaroon"),
                        tls_cert: dir.join("tls.cert"),
                        url_known: true,
                    },
                });
            }
            Some("c-lightning") => found.push(Candidate {
                label,
                name: name.into(),
                kind: Kind::Cln {
                    url: format!("http://127.0.0.1:{rest}"),
                    url_known: true,
                    tls_cert: None,
                    rune_command: format!(
                        "docker exec polar-n{id}-{name} lightning-cli --lightning-dir=/home/clightning/.lightning --network=regtest createrune restrictions={RUNE_RESTRICTIONS}"
                    ),
                },
            }),
            _ => {}
        }
    }
    found
}

/// A node the operator describes by hand.
fn manual(ask: &mut Prompt, taken: &[String]) -> Option<String> {
    let kind = ask
        .default("  Implementation: lnd or cln", "lnd")
        .to_lowercase();
    let mut name = ask.default("  A name for it", &format!("my-{kind}"));
    while name.is_empty() || taken.contains(&name) {
        if ask.ended() {
            return None;
        }
        name = if name.is_empty() {
            ask.line("  The node needs a name: ")
        } else {
            ask.line(&format!("  \"{name}\" is taken. Another name: "))
        };
    }
    match kind.as_str() {
        "lnd" => {
            let url = ask.default("  REST address", "https://127.0.0.1:8080");
            let macaroon = ask.line("  Path to readonly.macaroon: ");
            let cert = ask.line("  Path to tls.cert: ");
            (!macaroon.is_empty()).then(|| {
                lnd_toml(
                    &name,
                    &url,
                    &expand(&macaroon),
                    (!cert.is_empty()).then(|| expand(&cert)).as_deref(),
                )
            })
        }
        "cln" => {
            let url = ask.default("  clnrest address", "http://127.0.0.1:3010");
            let cert = if url.starts_with("https") {
                let c = ask.line(
                    "  Path to clnrest's server.pem (Enter if it has a trusted certificate): ",
                );
                (!c.is_empty()).then(|| expand(&c))
            } else {
                None
            };
            println!("  Create a read-only rune on the node with:\n\n    lightning-cli createrune restrictions={RUNE_RESTRICTIONS}\n");
            let rune = ask.secret("  Paste the rune: ");
            let rune = rune.trim_matches('"').to_string();
            (!rune.is_empty()).then(|| cln_toml(&name, &url, &rune, cert.as_deref()))
        }
        _ => {
            println!("  Firewatch reads lnd and cln nodes.");
            None
        }
    }
}

/// Tries the node once. A node that fails can still be kept, e.g. one that
/// is down right now.
async fn keep_after_test(toml: &str, http: &reqwest::Client, ask: &mut Prompt) -> bool {
    let node = match parse_node(toml) {
        Ok(node) => node,
        Err(e) => {
            println!("  {e}");
            return false;
        }
    };
    match firewatch_connectors::fetch(&node, http).await {
        Ok(info) => {
            println!(
                "  Connected: {} {}, read-only.\n",
                node.implementation(),
                info.version
            );
            true
        }
        Err(e) => {
            println!("  Couldn't read it: {e}");
            ask.yes("  Keep it anyway?", false)
        }
    }
}

fn parse_node(block: &str) -> Result<NodeConfig> {
    #[derive(serde::Deserialize)]
    struct One {
        nodes: Vec<NodeConfig>,
    }
    let one: One = toml::from_str(block).context("building the node's config")?;
    one.nodes.into_iter().next().context("no node in the block")
}

fn node_name(block: &str) -> String {
    parse_node(block)
        .map(|n| n.name().to_string())
        .unwrap_or_default()
}

fn lnd_toml(name: &str, url: &str, macaroon: &Path, tls_cert: Option<&Path>) -> String {
    let mut s = format!(
        "[[nodes]]\nkind = \"lnd\"\nname = {}\nurl = {}\nmacaroon_file = {}\n",
        quote(name),
        quote(url),
        quote(&macaroon.to_string_lossy())
    );
    if let Some(cert) = tls_cert {
        s.push_str(&format!("tls_cert = {}\n", quote(&cert.to_string_lossy())));
    }
    s
}

fn cln_toml(name: &str, url: &str, rune: &str, tls_cert: Option<&Path>) -> String {
    let mut s = format!(
        "[[nodes]]\nkind = \"cln\"\nname = {}\nurl = {}\nrune = {}\n",
        quote(name),
        quote(url),
        quote(rune)
    );
    if let Some(cert) = tls_cert {
        s.push_str(&format!("tls_cert = {}\n", quote(&cert.to_string_lossy())));
    }
    s
}

/// The whole config file.
fn render(nodes: &[String], npub: Option<&str>, secret_key_file: &Path) -> String {
    let mut s = String::from(
        "# Written by `firewatch init`. Edit freely: see firewatch.example.toml in\n\
         # the repo for every option. Holds runes, so keep it private.\n\n\
         [watch]\ninterval_secs = 30\nlisten = \"127.0.0.1:7070\"\n",
    );
    if let Some(npub) = npub {
        s.push_str(&format!(
            "\n[alerts.nostr]\nrecipient = {}\nsecret_key_file = {}\nrelays = [{}]\n",
            quote(npub.trim()),
            quote(&secret_key_file.to_string_lossy()),
            RELAYS.map(quote).join(", ")
        ));
    }
    for node in nodes {
        s.push('\n');
        s.push_str(node);
    }
    s
}

fn quote(s: &str) -> String {
    toml::Value::String(s.to_string()).to_string()
}

/// `~/x` to an absolute path, since the config can't expand `~`.
fn expand(path: &str) -> PathBuf {
    match (path.strip_prefix("~/"), std::env::var_os("HOME")) {
        (Some(rest), Some(home)) => PathBuf::from(home).join(rest),
        _ => PathBuf::from(path),
    }
}

/// Reads answers one line at a time, as they're typed. At end of input every
/// question takes its default, and loops check `ended` so `init` can't hang
/// when stdin isn't a terminal.
struct Prompt {
    lines: Box<dyn Iterator<Item = String>>,
    ended: bool,
}

impl Prompt {
    fn stdin() -> Self {
        // Lazy: collecting the lines first would wait for Ctrl-D before the
        // first question is shown.
        Prompt::new(std::io::stdin().lines().map_while(Result::ok))
    }

    fn new(lines: impl Iterator<Item = String> + 'static) -> Self {
        Prompt {
            lines: Box::new(lines),
            ended: false,
        }
    }

    /// Whether input has run out.
    fn ended(&self) -> bool {
        self.ended
    }

    fn line(&mut self, prompt: &str) -> String {
        self.read(prompt, true)
    }

    /// Like `line`, but never repeats the answer back: for runes.
    fn secret(&mut self, prompt: &str) -> String {
        self.read(prompt, false)
    }

    fn read(&mut self, prompt: &str, echo: bool) -> String {
        print!("{prompt}");
        std::io::stdout().flush().ok();
        let answer = match self.lines.next() {
            Some(line) => line.trim().to_string(),
            None => {
                self.ended = true;
                String::new()
            }
        };
        // A terminal already shows what was typed; piped answers don't.
        if !std::io::IsTerminal::is_terminal(&std::io::stdin()) {
            println!("{}", if echo { answer.as_str() } else { "(hidden)" });
        }
        answer
    }

    fn default(&mut self, prompt: &str, default: &str) -> String {
        let answer = self.line(&format!("{prompt} [{default}]: "));
        if answer.is_empty() {
            default.to_string()
        } else {
            answer
        }
    }

    fn yes(&mut self, prompt: &str, default: bool) -> bool {
        let hint = if default { "Y/n" } else { "y/N" };
        match self
            .line(&format!("{prompt} [{hint}] "))
            .to_lowercase()
            .as_str()
        {
            "" => default,
            a => a.starts_with('y'),
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn scripted(answers: &[&str]) -> Prompt {
        let answers: Vec<String> = answers.iter().map(|s| s.to_string()).collect();
        Prompt::new(answers.into_iter())
    }

    fn temp_home(name: &str) -> PathBuf {
        let dir = std::env::temp_dir().join(format!("fw-init-{name}-{}", std::process::id()));
        let _ = std::fs::remove_dir_all(&dir);
        std::fs::create_dir_all(&dir).unwrap();
        dir
    }

    #[test]
    fn finds_lnd_in_its_default_folder() {
        let home = temp_home("lnd");
        let lnd = home.join(".lnd");
        std::fs::create_dir_all(lnd.join("data/chain/bitcoin/mainnet")).unwrap();
        std::fs::write(lnd.join("tls.cert"), "x").unwrap();
        std::fs::write(
            lnd.join("data/chain/bitcoin/mainnet/readonly.macaroon"),
            "x",
        )
        .unwrap();
        let found = detect(&home, None, &mut scripted(&[]));
        assert_eq!(found.len(), 1);
        assert_eq!(found[0].name, "lnd-mainnet");
        std::fs::remove_dir_all(home).unwrap();
    }

    #[test]
    fn finds_polar_nodes_with_their_ports() {
        let home = temp_home("polar");
        std::fs::create_dir_all(home.join(".polar/networks")).unwrap();
        std::fs::write(
            home.join(".polar/networks/networks.json"),
            r#"{"networks":[{"id":2,"name":"Demo","nodes":{"lightning":[
                {"name":"alice","implementation":"LND","ports":{"rest":8081}},
                {"name":"old-cln","implementation":"c-lightning","ports":{"rest":8182}}]}}]}"#,
        )
        .unwrap();
        let found = detect(&home, None, &mut scripted(&[]));
        assert_eq!(found.len(), 2);
        assert!(matches!(&found[0].kind, Kind::Lnd { url, .. } if url == "https://127.0.0.1:8081"));
        assert!(matches!(&found[1].kind, Kind::Cln { rune_command, .. }
            if rune_command.starts_with("docker exec polar-n2-old-cln lightning-cli")));
        std::fs::remove_dir_all(home).unwrap();
    }

    #[test]
    fn rendered_config_loads() {
        let nodes = [
            lnd_toml(
                "a",
                "https://127.0.0.1:8080",
                Path::new("/m"),
                Some(Path::new("/c")),
            ),
            cln_toml("b \"quoted\"", "http://127.0.0.1:3010", "abc=", None),
        ];
        let text = render(&nodes, Some("npub1x"), Path::new("/k/firewatch.nsec"));
        let config: config::Config = toml::from_str(&text).unwrap();
        assert_eq!(config.nodes.len(), 2);
        assert_eq!(config.nodes[1].name(), "b \"quoted\"");
        assert_eq!(config.alerts.nostr.unwrap().relays.len(), 3);
    }

    #[test]
    fn a_skipped_rune_skips_the_node() {
        let c = Candidate {
            label: "x".into(),
            name: "x".into(),
            kind: Kind::Cln {
                url: "http://127.0.0.1:1".into(),
                url_known: true,
                tls_cert: None,
                rune_command: "lightning-cli createrune".into(),
            },
        };
        assert!(c.into_toml(&mut scripted(&[""])).is_none());
    }

    #[tokio::test]
    async fn end_of_input_stops_adding_nodes() {
        let (mut nodes, mut names) = (Vec::new(), Vec::new());
        let http = firewatch_connectors::http_client();
        let done = tokio::time::timeout(
            std::time::Duration::from_secs(5),
            add_by_hand(&mut scripted(&[]), &http, &mut nodes, &mut names),
        )
        .await;
        assert!(done.is_ok(), "asked forever at end of input");
        assert!(nodes.is_empty());
    }

    #[test]
    fn a_taken_or_empty_name_is_asked_again() {
        let mut ask = scripted(&["lnd", "", "", "b", "", "/m", ""]);
        let toml = manual(&mut ask, &["my-lnd".into()]).unwrap();
        assert_eq!(node_name(&toml), "b");
        // At end of input the node is dropped, not given an empty name.
        assert!(manual(&mut scripted(&["lnd", ""]), &["my-lnd".into()]).is_none());
    }

    #[test]
    fn two_lnd_folders_get_their_own_names() {
        let home = temp_home("two-lnd");
        let other = home.join("other");
        for dir in [home.join(".lnd"), other.clone()] {
            std::fs::create_dir_all(dir.join("data/chain/bitcoin/mainnet")).unwrap();
            std::fs::write(dir.join("tls.cert"), "x").unwrap();
            std::fs::write(
                dir.join("data/chain/bitcoin/mainnet/readonly.macaroon"),
                "x",
            )
            .unwrap();
        }
        let found = detect(&home, Some(other), &mut scripted(&[]));
        let names: Vec<&str> = found.iter().map(|c| c.name.as_str()).collect();
        assert_eq!(names, ["lnd-mainnet", "lnd-mainnet-2"]);
        // LND_DIR pointing at ~/.lnd through a link is the same folder.
        let link = home.join("link");
        std::os::unix::fs::symlink(home.join(".lnd"), &link).unwrap();
        assert_eq!(detect(&home, Some(link), &mut scripted(&[])).len(), 1);
        std::fs::remove_dir_all(home).unwrap();
    }

    #[test]
    fn a_replaced_config_is_private() {
        let home = temp_home("force");
        let path = home.join("firewatch.toml");
        std::fs::write(&path, "old").unwrap();
        std::fs::set_permissions(&path, std::fs::Permissions::from_mode(0o644)).unwrap();
        write_private(&path, "new").unwrap();
        let mode = std::fs::metadata(&path).unwrap().permissions().mode();
        assert_eq!(mode & 0o777, 0o600);
        assert_eq!(std::fs::read_to_string(&path).unwrap(), "new");
        std::fs::remove_dir_all(home).unwrap();
    }
}