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
use crate::async_runtime::AsyncRuntime;
use crate::backup::BackupManager;
use crate::errors::Result;
use crate::key_derivation::derive_persistence_encryption_key;
use crate::logger::init_logger_once;
use crate::{build_async_auth, permanent_failure, sanitize_input, DB_FILENAME, LOGS_DIR};
use squirrel::RemoteBackupClient;
use std::path::Path;
use std::sync::Arc;

/// Performs a recovery procedure by fetching necessary data from remote storage.
/// It should and can only be called on a fresh install of the app, if the user wants to recover a previously created wallet.
/// If no existing wallet backup is found, returns an error.
pub fn recover_lightning_node(
    backend_url: String,
    seed: Vec<u8>,
    local_persistence_path: String,
    file_logging_level: Option<log::Level>,
) -> Result<()> {
    if let Some(level) = file_logging_level {
        init_logger_once(level, &Path::new(&local_persistence_path).join(LOGS_DIR))?;
    }

    let db_path = format!("{local_persistence_path}/{DB_FILENAME}");
    if Path::new(&db_path).exists() {
        permanent_failure!(
            "Trying to recover when existing wallet data is present in local persistence path"
        )
    }

    let strong_typed_seed = sanitize_input::strong_type_seed(&seed)?;
    let auth = Arc::new(build_async_auth(&strong_typed_seed, &backend_url)?);

    let backup_client = RemoteBackupClient::new(backend_url, auth);
    let backup_manager = BackupManager::new(
        backup_client,
        db_path,
        derive_persistence_encryption_key(&strong_typed_seed)?,
    );

    AsyncRuntime::new()?
        .handle()
        .block_on(backup_manager.recover())
}