amagi 0.1.3

Rust SDK, CLI, and Web API service skeleton for multi-platform social web adapters.
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
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

//! Application runtime orchestration for CLI and server modes.

mod bilibili;
mod douyin;
mod kuaishou;
mod twitter;
mod xiaohongshu;

use tracing::info;

use crate::APP_NAME;
use crate::client::AmagiClient;
use crate::config::{AppConfig, CommandConfig, RunConfig, RunTask};
use crate::error::AppError;
use crate::output::Printer;
#[cfg(feature = "server")]
use crate::server;
use crate::telemetry;

/// Initialize shared services and execute the selected runtime command.
///
/// This function configures telemetry, constructs a [`Printer`], and dispatches
/// the resolved [`crate::config::CommandConfig`].
///
/// # Errors
///
/// Returns an error if startup output cannot be written or if the selected
/// command fails during execution.
pub async fn run(config: AppConfig) -> Result<(), AppError> {
    let AppConfig {
        command,
        output,
        logging,
        client,
    } = config;

    telemetry::try_init(logging).map_err(|error| {
        AppError::Io(std::io::Error::new(
            std::io::ErrorKind::Other,
            format!("failed to initialize telemetry: {error}"),
        ))
    })?;

    let printer = Printer::new(output);
    let client = AmagiClient::new(client);
    match command {
        CommandConfig::Run(run) => run_command(&printer, &client, &run).await,
        #[cfg(feature = "server")]
        CommandConfig::Serve(serve) => server::serve(serve, client, &printer).await,
    }
}

async fn run_command(
    printer: &Printer,
    client: &AmagiClient,
    config: &RunConfig,
) -> Result<(), AppError> {
    if matches!(config.task, RunTask::Ready) && !config.quiet {
        printer.print_banner(APP_NAME, env!("CARGO_PKG_VERSION"))?;
        printer.print_run_ready(APP_NAME, env!("CARGO_PKG_VERSION"))?;
    }

    match &config.task {
        RunTask::Ready => {
            info!(
                app = APP_NAME,
                mode = "cli",
                quiet = config.quiet,
                "cli workflow initialized"
            );
        }
        RunTask::Bilibili(task) => {
            bilibili::run_task(printer, client, task).await?;
        }
        RunTask::Douyin(task) => {
            douyin::run_task(printer, client, task).await?;
        }
        RunTask::Kuaishou(task) => {
            kuaishou::run_task(printer, client, task).await?;
        }
        RunTask::Twitter(task) => {
            twitter::run_task(printer, client, task).await?;
        }
        RunTask::Xiaohongshu(task) => {
            xiaohongshu::run_task(printer, client, task).await?;
        }
    }

    Ok(())
}