watchso 0.1.0

Hot reload Solana programs
Documentation 
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

mod anchor;
mod native;
mod seahorse;

use std::{path::Path, sync::Arc};

use miette::IntoDiagnostic;
use tokio::fs;
use watchso::{
    constants::{dirname, filename},
    error::WatchError,
    framework::WatchableFramework,
};

use self::{anchor::Anchor, native::Native, seahorse::Seahorse};

/// Get a [`WatchableFramework`] from the given path.
///
/// Returns [WatchError::InvalidProgramDirectory] error if the given path is not a valid Solana
/// program directory.
pub async fn get_framework_from_path<P: AsRef<Path>>(
    origin: P,
) -> miette::Result<Arc<dyn WatchableFramework>> {
    let mut item_names = vec![];

    let mut dir = fs::read_dir(&origin).await.into_diagnostic()?;
    while let Some(entry) = dir.next_entry().await.into_diagnostic()? {
        item_names.push(entry.file_name());
    }

    let item_names = item_names
        .iter()
        .filter_map(|item| item.to_str())
        .collect::<Vec<_>>();

    if item_names.contains(&dirname::PROGRAMS_PY) {
        return Ok(Arc::new(Seahorse::new(origin)));
    }
    if item_names.contains(&filename::ANCHOR_TOML) {
        return Ok(Arc::new(Anchor::new(origin)));
    }
    if item_names.contains(&filename::CARGO_TOML) {
        return Ok(Arc::new(Native::new(origin)));
    }

    Err(WatchError::InvalidProgramDirectory(origin.as_ref().into()))?
}