oxyde_cloud_deploy/
deploy.rs

1use cargo_leptos::config::Opts;
2use oxyde_cloud_client::{Client, ReqwestJsonError, UploadFileError};
3use oxyde_cloud_common::config::CloudConfig;
4use std::env::VarError;
5use std::ffi::OsStr;
6use std::fs::read_dir;
7use std::path::{Path, PathBuf};
8use thiserror::Error;
9use walkdir::WalkDir;
10
11#[derive(Debug, Error)]
12pub enum Error {
13    #[error("Build error: {0}")]
14    Build(#[from] anyhow::Error),
15
16    #[error("IO error: {0}")]
17    Io(#[from] std::io::Error),
18
19    #[error("Check Name error: {0}")]
20    CheckName(#[from] ReqwestJsonError),
21
22    #[error("Upload error: {0}")]
23    Upload(#[from] UploadFileError),
24
25    #[error("Deployment done error: {0}")]
26    Done(#[from] reqwest::Error),
27
28    #[error("Error reading variable `LEPTOS_CLOUD_API_KEY`: {0}")]
29    ApiKeyEnv(#[from] VarError),
30
31    #[error("Config loading error: {0}")]
32    Config(#[from] oxyde_cloud_common::config::Error),
33}
34
35pub async fn deploy_with_config_file(
36    config: &PathBuf,
37    cargo_leptos_opts: Opts,
38) -> Result<(), Error> {
39    let config = CloudConfig::load(&config).await?;
40    deploy(&config, cargo_leptos_opts).await?;
41    Ok(())
42}
43
44pub async fn deploy(config: &CloudConfig, cargo_leptos_opts: Opts) -> Result<(), Error> {
45    crate::build::build(cargo_leptos_opts.clone()).await?;
46
47    let target_dir = "target";
48    let server_bin_dir = if cargo_leptos_opts.release {
49        "release"
50    } else {
51        "debug"
52    };
53    let frontend_dir = "site";
54
55    let api_key = std::env::var("LEPTOS_CLOUD_API_KEY")?;
56    let client = Client::new(api_key.clone());
57
58    let frontend_path = Path::new(target_dir).join(frontend_dir);
59    let server_path = Path::new(target_dir).join(server_bin_dir);
60
61    let mut files = recursive_files_from_dir(frontend_path);
62    files.append(&mut server_files(server_path)?);
63
64    log::debug!(target:"cargo_leptos", "Found files: {:#?}", files);
65
66    log::info!(target:"cargo_leptos", "Deploying app {}", config.app.slug);
67
68    if let Err(err) = deploy_inner(config, client, &mut files).await {
69        log::error!(target:"cargo_leptos", "Deploy failed: {:?}", err);
70        return Err(err);
71    }
72
73    log::info!(target:"cargo_leptos", "Deployed app to {}", config.deployed_url());
74
75    Ok(())
76}
77
78async fn deploy_inner(
79    config: &CloudConfig,
80    client: Client,
81    files: &mut Vec<PathBuf>,
82) -> Result<(), Error> {
83    for file in files {
84        log::debug!(target:"cargo_leptos", "Uploading {}...", file.display());
85        client.clone().upload_file(&config.app.slug, file).await?;
86    }
87
88    log::debug!(target:"cargo_leptos", "Deploying app...");
89    client.upload_done(config).await?;
90
91    Ok(())
92}
93
94fn recursive_files_from_dir(dir: impl AsRef<Path>) -> Vec<PathBuf> {
95    WalkDir::new(dir)
96        .into_iter()
97        .filter_map(|e| e.ok().map(|e| e.into_path()))
98        .filter_map(|e| if e.is_file() { Some(e) } else { None })
99        .collect()
100}
101
102fn server_files(dir: impl AsRef<Path>) -> std::io::Result<Vec<PathBuf>> {
103    Ok(read_dir(dir)?
104        .filter_map(|d| {
105            d.ok().and_then(|e| {
106                let path = e.path();
107                if path.is_file() && path.extension() != Some(OsStr::new("d")) {
108                    Some(path)
109                } else {
110                    None
111                }
112            })
113        })
114        .collect())
115}
oxyde_cloud_deploy/deploy.rs

oxyde_cloud_deploy/
deploy.rs
