systemprompt_cli/commands/core/content/
delete_source.rs

1use super::types::DeleteSourceOutput;
2use crate::cli_settings::CliConfig;
3use crate::interactive::require_confirmation;
4use crate::shared::CommandOutput;
5use anyhow::Result;
6use clap::Args;
7use systemprompt_content::ContentRepository;
8use systemprompt_identifiers::SourceId;
9use systemprompt_logging::CliService;
10use systemprompt_runtime::AppContext;
11
12#[derive(Debug, Args)]
13pub struct DeleteSourceArgs {
14    #[arg(value_name = "SOURCE_ID", help = "Source ID")]
15    pub source: String,
16
17    #[arg(short = 'y', long, help = "Skip confirmation")]
18    pub yes: bool,
19}
20
21pub async fn execute(args: DeleteSourceArgs, config: &CliConfig) -> Result<CommandOutput> {
22    if config.is_interactive() && !args.yes {
23        CliService::warning(&format!(
24            "This will permanently delete ALL content from source: {}",
25            args.source
26        ));
27    }
28
29    require_confirmation("Are you sure you want to continue?", args.yes, config)?;
30
31    let ctx = AppContext::new().await?;
32    let repo = ContentRepository::new(ctx.db_pool())?;
33
34    let source = SourceId::new(args.source.clone());
35    let deleted_count = repo.delete_by_source(&source).await?;
36
37    let output = DeleteSourceOutput {
38        deleted_count,
39        source_id: source,
40    };
41
42    Ok(CommandOutput::card_value("Source Content Deleted", &output))
43}

systemprompt_cli/commands/core/content/delete_source.rs

systemprompt_cli/commands/core/content/
delete_source.rs