ContentPipe — AI 図文内容生産プラグイン

選題から発行までの全工程 AI 内容生産。各ステップで専属 AI と議論、調整、再実行できます。

トリガー条件

ユーザーが以下のいずれかを言及：

• 「記事を書いて」「選題」「コンテンツを生成」「content pipeline」「contentpipe」
• 「X についての公開記事を書いてほしい」
• 「今日のトレンドトピックは何」「コンテンツタスクを実行」

プラグインアーキテクチャ

┌──────────────────────────────────────────────────┐
│  OpenClaw Gateway                                 │
│  ├── AI ツール呼び出し (contentpipe_*)            │
│  ├── Discord 通知 (message tool)                  │
│  └── Cron 定時タスク                               │
├──────────────────────────────────────────────────┤
│  ContentPipe Service (Python, port 8765)          │
│  ├── REST API (/api/*)                            │
│  ├── Web コンソール (Jinja2 + HTMX + Tailwind)   │
│  ├── SSE リアルタイム配信                         │
│  └── Pipeline エンジン (7 ノード)                 │
├──────────────────────────────────────────────────┤
│  LLM Provider                                     │
│  ├── DashScope (qwen3.5-plus/flash)              │
│  ├── Anthropic (claude-sonnet-4-6)               │
│  └── OpenAI Codex (gpt-5.4)                      │
└──────────────────────────────────────────────────┘

クイックスタート

# 方法 1: 起動スクリプト
cd <PLUGIN_DIR>
./start.sh start

# 方法 2: 直接実行
cd <PLUGIN_DIR>/scripts
python3 -m uvicorn web.app:app --host 0.0.0.0 --port 8765

# 管理
./start.sh status    # ステータス確認
./start.sh stop      # 停止
./start.sh restart   # 再起動
./start.sh logs      # ログ表示

Web UI: http://localhost:8765

Pipeline フロー（7 ステップ）

scout → researcher → writer → director → image_gen → formatter → publisher

ノード	AI ロール	対話	説明
🔍 Scout	選題企画	✅	トレンド分析+ソーシャル検索、完全な Briefing を出力
📚 Researcher	深掘り調査	✅	ファクトチェック+証拠パッケージ、writer_packet を出力
✍️ Writer	唯一の著者パーソナリティ	✅	GPT 5.4 執筆/審査チャット → Extractor で reply/article を分離 → Sonnet 4.6 で内部ポリッシュ
🎬 Director	ビジュアルディレクター	✅	配図スキーム、画像アップロード/置換/削除に対応
🖼️ Image Gen	画像生成	⚙️	Pollinations.ai で自動生成
📐 Formatter	編集エンジン	✅	Markdown→WeChat HTML、図文を正確にマッチング
📤 Publisher	パブリッシャー	⚙️	WeChat/小紅書

Discord 統合

Pipeline イベントは #図文生成 チャネルに自動配信：

• ⏸️ ノードがレビュー待ち → Web UI リンク付き
• ✅ Pipeline 完了 → プレビューリンク付き
• ❌ 失敗 → エラー情報付き

AI ツール（会話中に利用可能）

ツール	説明	用法
contentpipe_create	タスク作成	「AI についての記事を書いて」
contentpipe_status	ステータス確認	「pipeline はどこまで進んだ」
contentpipe_list	タスク一覧	「最近のタスク一覧」
contentpipe_approve	レビュー承認	「次へ進んで」
contentpipe_chat	ノード チャット	「Writer に冒頭を変えるよう伝えて」

AI ツール実装

ユーザーが上記ツールをトリガーすると、HTTP で ローカル API を呼び出し：

# contentpipe_create
POST http://localhost:8765/api/runs
{"topic": "...", "platform": "wechat", "auto_approve": false}

# contentpipe_status
GET http://localhost:8765/api/runs/{run_id}

# contentpipe_list
GET http://localhost:8765/api/runs?limit=10

# contentpipe_approve
POST http://localhost:8765/api/runs/{run_id}/review
{"action": "approve"}

# contentpipe_chat
POST http://localhost:8765/api/runs/{run_id}/chat
{"message": "...", "node": "writer"}

モデル割り当て

ノード	モデル	理由
Scout	qwen3.5-plus	高速+構造化
Researcher	qwen3.5-plus	大量処理+理解力
Writer Main	gpt-5.4	唯一の著者パーソナリティ、執筆+審査チャット改稿
Writer Extractor	qwen3.5-flash	reply/article 分離、本文への説明文混入を回避
De-AI	sonnet-4-6	内部ポリッシュ、隠れた工程
Director	qwen3.5-plus	企画能力
インテント判定	qwen3.5-flash	軽量高速（構造化ノード）
YAML 同期	qwen3.5-flash	構造化高速

config/pipeline.yaml の llm_overrides で上書き可能。

プロジェクト構造

plugins/content-pipeline/
├── openclaw.plugin.yaml    # 🆕 プラグインマニフェスト
├── start.sh                # 🆕 起動スクリプト
├── SKILL.md                # スキルエントリーポイント（本ファイル）
├── README.md
├── config/
│   ├── pipeline.yaml       # モデル+プラットフォーム設定
│   ├── template-mapping.yaml
│   └── styles/*.yaml
├── prompts/                # 6 個の Agent プロンプト
├── templates/wechat/*.html # 6 個の編集テンプレート
├── docs/
│   └── ARCHITECTURE.md     # アーキテクチャドキュメント v0.7.0
├── scripts/
│   ├── nodes.py            # Pipeline ノード実装
│   ├── tools.py            # LLM 呼び出し+検索ツール
│   ├── formatter.py        # Markdown→HTML 編集
│   ├── publisher.py        # パブリッシャー
│   ├── hot_news.py         # トレンド集約
│   ├── env_loader.py       # API キー読み込み
│   ├── image_engines/      # 画像生成エンジン
│   └── web/
│       ├── app.py          # FastAPI メインアプリ
│       ├── notify.py       # 🆕 Discord 通知
│       ├── events.py       # SSE イベントバス
│       ├── run_manager.py  # Run ステータス管理
│       ├── routes/
│       │   ├── api.py      # REST API
│       │   ├── pages.py    # ページルート
│       │   └── sse.py      # SSE 配信
│       └── templates/      # 10 個の Web ページ
└── output/runs/            # 実行成果物

Web コンソール API

メソッド	パス	説明
GET	/api/health	🆕 ヘルスチェック
GET	/api/info	🆕 プラグイン情報
GET	/	ダッシュボード
POST	/api/runs	新規 Run 作成
POST	/api/runs/{id}/start	Pipeline 起動
GET	/runs/{id}/review	ノード対話ページ
POST	/api/runs/{id}/review	承認完了
POST	/api/runs/{id}/chat	AI チャット
GET	/api/runs/{id}/chat/history	チャット履歴
POST	/api/runs/{id}/nodes/{node}/rerun	ノード再実行
POST	/api/runs/{id}/images/upload	🆕 配図をアップロード/置換
DELETE	/api/runs/{id}/placements/{pid}	🆕 配図を削除
GET	/api/runs/{id}/article	記事を取得
POST	/api/runs/{id}/article	編集後の記事を保存
GET	/runs/{id}/preview	編集プレビュー
GET	/sse/{id}	SSE リアルタイムイベント

開発進度

フェーズ	コンテンツ	ステータス
1-8	基盤アーキテクチャ+全ノード実装+Web コンソール	✅
9	Scout 新スキーマ + Writer 3層消費	✅
10	ノード別セッション + メッセージ階層化	✅
11	リアルタイム同期（会話→YAML/記事）	✅
12	テンプレートマッチング+ダークモード対応	✅
13	図文正確マッチング	✅
14	Director 配図管理	✅
15	プラグイン化改造	✅ 🆕
16	Publisher 実発行	🔴
17	Cron 定時スケジューリング	🔴