oxipage 0.5.0

Oxipage CLI — 블로그/프로젝트/링크/사이트 관리 커맨드라인 도구 (doc/04)
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use crate::output::Output;
use clap::Subcommand;
use oxipage_ext_blog::model::{BlogPatch, BlogPostInput};
use oxipage_ext_blog::repo;

#[derive(Subcommand, Debug, Clone)]
pub enum BlogCommand {
    /// 새 초안 생성 (doc/04 §4.3 초안 우선 원칙: add/new는 초안만).
    New {
        title: String,
        #[arg(long, default_value = "ko")]
        lang: String,
        #[arg(long, help = "본문 마크다운 파일. 미지정 시 빈 본문")]
        file: Option<std::path::PathBuf>,
        #[arg(long = "tag")]
        tags: Vec<String>,
        #[arg(long, help = "즉시 발행 (초안 우선 원칙 위반 — 명시적 승인)")]
        publish: bool,
    },
    /// 초안 발행 (별도 승인 단계).
    Publish { slug: String },
    /// 목록 (기본: 발행본만. --draft로 초안만).
    List {
        #[arg(long)]
        draft: bool,
        #[arg(long)]
        lang: Option<String>,
    },
    /// 단건 조회.
    Show { slug: String },
    /// 수정 (title/body/tags).
    Edit {
        slug: String,
        #[arg(long)]
        title: Option<String>,
        #[arg(long, help = "본문 마크다운 파일")]
        file: Option<std::path::PathBuf>,
        #[arg(long = "tag")]
        tags: Vec<String>,
    },
    /// 삭제.
    Rm { slug: String },
}

pub(crate) async fn blog(c: BlogCommand, out: &Output) -> anyhow::Result<()> {
    let data_dir = super::resolve_data_dir()?;
    let pool = oxipage_core::db::connect(&data_dir.join("oxipage.db")).await?;

    match c {
        BlogCommand::New {
            title,
            lang,
            file,
            tags,
            publish,
        } => {
            let body = match file {
                Some(p) => std::fs::read_to_string(p)?,
                None => String::new(),
            };
            let input = BlogPostInput {
                title,
                body,
                lang,
                tags,
                translation_group_id: None,
                slug: None,
            };
            let slug_base = repo::slugify(&input.title);
            let resolved_slug = repo::ensure_unique_slug(&pool, &slug_base).await?;
            let post = repo::create(&pool, &input, &resolved_slug).await?;
            if publish {
                let published = repo::publish(&pool, &post.slug).await?;
                out.data(serde_json::to_value(&published)?, "published")
            } else {
                out.data(serde_json::to_value(&post)?, "draft created")
            }
        }
        BlogCommand::Publish { slug } => {
            let post = repo::publish(&pool, &slug).await?;
            out.data(serde_json::to_value(&post)?, "published")
        }
        BlogCommand::List { draft, lang } => {
            let posts = repo::list(&pool, draft, lang.as_deref(), 200).await?;
            out.data(serde_json::to_value(&posts)?, "posts")
        }
        BlogCommand::Show { slug } => {
            let post = repo::find_by_slug(&pool, &slug)
                .await?
                .ok_or_else(|| anyhow::anyhow!("post not found: {slug}"))?;
            out.data(serde_json::to_value(&post)?, "post")
        }
        BlogCommand::Edit {
            slug,
            title,
            file,
            tags,
        } => {
            let body = match file {
                Some(p) => Some(std::fs::read_to_string(p)?),
                None => None,
            };
            let tags_opt = if tags.is_empty() { None } else { Some(tags) };
            let patch = BlogPatch {
                title,
                body,
                lang: None,
                tags: tags_opt,
            };
            let post = repo::update(&pool, &slug, &patch)
                .await?
                .ok_or_else(|| anyhow::anyhow!("post not found: {slug}"))?;
            out.data(serde_json::to_value(&post)?, "updated")
        }
        BlogCommand::Rm { slug } => {
            let removed = repo::delete(&pool, &slug).await?;
            if removed {
                out.ok(format!("deleted: {slug}"))
            } else {
                anyhow::bail!("post not found: {slug}")
            }
        }
    }
}