web_creator.py

#!/usr/bin/env python3
"""
aiseed web creator — ホームページ生成ツール

依存: Python のみ（Flet + claude-agent-sdk + requests）
認証: Claude Pro/Max（claude login）
Node.js 不要。ANTHROPIC_API_KEY 不要。

Usage:
    python web_creator.py
"""

import asyncio, json, os, shutil, threading, webbrowser, xml.etree.ElementTree as ET, re, html as html_mod
from pathlib import Path
from datetime import datetime
from typing import Any
import flet as ft
import requests

import digikam_bridge as dkb
from image_utils import (BASE_DIR, TEMPLATES_DIR, CONFIG_FILE, PROJECTS_DIR,
                         default_projects_dir,
                         load_json, save_json, list_templates, optimize_image)
from digikam_dialog import open_digikam_browser
from generators import generate_sitemap, generate_feed, sync_to_hub, generate_qr_codes
from cloudflare_r2 import upload_images_to_r2
from wordpress_import import import_wordpress_xml
from mcp_server import create_tools, build_system_prompt
from static_generator import render_site
from admin_dashboard import build_admin_tab


# ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
#  メインアプリ
# ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━

RECENT_FILE = BASE_DIR / "recent_projects.json"
MAX_RECENT = 20

def _load_recent():
    if RECENT_FILE.exists():
        try: return json.loads(RECENT_FILE.read_text("utf-8"))
        except Exception: pass
    return []

def _record_recent(proj_dir):
    """プロジェクトの保存・読込時に履歴を記録する"""
    entries = _load_recent()
    path_str = str(Path(proj_dir).resolve())
    now = datetime.now().strftime("%Y-%m-%d %H:%M")
    # 既存エントリを除去して先頭に追加
    entries = [e for e in entries if e.get("path") != path_str]
    entries.insert(0, {"path": path_str, "name": Path(proj_dir).name, "last_saved": now})
    entries = entries[:MAX_RECENT]
    RECENT_FILE.write_text(json.dumps(entries, ensure_ascii=False, indent=2), "utf-8")


async def main(page: ft.Page):
    page.title = "aiseed web creator"
    page.theme_mode = ft.ThemeMode.DARK
    page.bgcolor = "#141418"
    page.padding = 0
    page.window.width = 1100
    page.window.height = 800

    # ── State ──
    current_template = {"ref": None}  # mutable container
    current_project_dir = {"ref": None}
    data = {}
    config = load_json(CONFIG_FILE, {})
    is_building = False
    log_list = ft.ListView(expand=True, spacing=2, auto_scroll=True)
    content_area = ft.Column(expand=True)

    # デフォルトテンプレート構造（テンプレートなしプロジェクト用）
    DEFAULT_TPL = {
        "template_id": "_default", "template_name": "カスタム",
        "icon": "🌐",
        "theme": {"dark":"#141418","mid":"#1e1e2a","accent":"#6c8ee0","green":"#4a9",
                  "text":"#e0e0e0","text2":"#888","surface":"#1e1e2a","border":"#333"},
        "data_sections": [], "default_data": {},
        "default_pages": [{"filename": "index.html", "title": "トップ", "description": "メインページ"}],
        "site_styles": [], "color_themes": [], "system_prompt_context": "",
    }

    def C(key):
        t = current_template["ref"]
        if t and "theme" in t: return t["theme"].get(key, "#888")
        return DEFAULT_TPL["theme"].get(key, "#888")

    def add_log(text, color=None):
        log_list.controls.append(ft.Text(f"[{datetime.now():%H:%M:%S}] {text}", size=12,
            color=color or C("text2"), selectable=True))
        page.update()

    def _change_projects_dir(new_path):
        """PROJECTS_DIR を変更して config.json に保存する"""
        nonlocal config
        resolved = Path(new_path).expanduser().resolve()
        resolved.mkdir(parents=True, exist_ok=True)
        config["projects_dir"] = str(resolved)
        save_json(CONFIG_FILE, config)
        global PROJECTS_DIR
        PROJECTS_DIR = resolved

    # ━━━ Start screen ━━━
    def _build_projects_dir_setting():
        """プロジェクト保存先の表示・変更ウィジェットを返す"""
        dir_label = ft.Text(str(PROJECTS_DIR), size=12, color=C("text2"), selectable=True)

        async def _browse_dir(e):
            path = await ft.FilePicker().get_directory_path(
                dialog_title="プロジェクト保存先を変更",
                initial_directory=str(PROJECTS_DIR))
            if path:
                _change_projects_dir(path)
                dir_label.value = str(PROJECTS_DIR)
                show_start_screen()

        return ft.Column([
            ft.Text("プロジェクト保存先", size=14, weight=ft.FontWeight.W_600, color=C("text")),
            ft.Container(height=4),
            ft.Row([
                ft.Icon(ft.Icons.FOLDER, color=C("accent"), size=18),
                dir_label,
                ft.TextButton("変更...", on_click=_browse_dir,
                    style=ft.ButtonStyle(color=C("accent"))),
            ], spacing=8, vertical_alignment=ft.CrossAxisAlignment.CENTER),
        ], spacing=0)

    def show_start_screen():
        content_area.controls.clear()

        # ── 新規プロジェクト ──
        new_proj_name = ft.TextField(label="プロジェクト名",
            hint_text="例: my-cafe-site",
            border_color=C("border"), focused_border_color=C("accent"),
            bgcolor=C("surface"), text_style=ft.TextStyle(color=C("text"), size=14),
            label_style=ft.TextStyle(color=C("text2"), size=12), border_radius=8, expand=True)

        new_parent_label = ft.Text(str(PROJECTS_DIR), size=12, color=C("text2"))

        # 親フォルダ選択用の状態
        new_parent_dir = {"ref": PROJECTS_DIR}

        # FilePicker: 新規プロジェクトの親フォルダ選択
        async def _browse_new_parent(e):
            path = await ft.FilePicker().get_directory_path(
                dialog_title="作成先フォルダを選択",
                initial_directory=str(new_parent_dir["ref"]))
            if path:
                new_parent_dir["ref"] = Path(path)
                new_parent_label.value = str(path)
                page.update()

        def _create(e):
            name = new_proj_name.value.strip()
            if not name: return
            proj_dir = Path(new_parent_dir["ref"]) / name
            proj_dir.mkdir(parents=True, exist_ok=True)
            (proj_dir / "output").mkdir(exist_ok=True)
            d = {"pages": list(DEFAULT_TPL["default_pages"]),
                 "site": {"style": "", "color_theme": "", "extra_request": ""}}
            save_json(proj_dir / "site_data.json", d)
            load_project(proj_dir)

        # ── 既存プロジェクトを開く (FilePicker) ──
        async def _browse_open(e):
            path = await ft.FilePicker().get_directory_path(
                dialog_title="プロジェクトフォルダを選択",
                initial_directory=str(PROJECTS_DIR))
            if path:
                proj_dir = Path(path)
                if proj_dir.is_dir():
                    load_project(proj_dir)

        # ── 最近のプロジェクト（履歴ベース） ──
        recent_entries = _load_recent()
        existing = []
        for entry in recent_entries:
            p = Path(entry["path"])
            if not p.is_dir(): continue
            last_saved = entry.get("last_saved", "")
            def _open(e, path=p):
                load_project(path)
            existing.append(ft.Container(
                content=ft.Row([
                    ft.Icon(ft.Icons.FOLDER_OUTLINED, color=C("accent"), size=20),
                    ft.Column([
                        ft.Text(p.name, size=14, weight=ft.FontWeight.W_600, color=C("text")),
                        ft.Text(str(p), size=11, color=C("text2")),
                    ], spacing=2, expand=True),
                    ft.Text(last_saved, size=11, color=C("text2")),
                ], spacing=10),
                bgcolor=C("surface"), border_radius=8, padding=ft.Padding.all(14),
                border=ft.Border.all(1, C("border")), on_click=_open, ink=True,
            ))

        content_area.controls.append(ft.Container(
            content=ft.Column([
                ft.Container(height=40),
                ft.Text("aiseed web creator", size=28, weight=ft.FontWeight.W_700, color=C("text"),
                         text_align=ft.TextAlign.CENTER),
                ft.Container(height=32),

                # 新規プロジェクト
                ft.Text("新規プロジェクト", size=14, weight=ft.FontWeight.W_600, color=C("text")),
                ft.Container(height=8),
                new_proj_name,
                ft.Container(height=8),
                ft.Row([
                    ft.Text("作成先:", size=12, color=C("text2")),
                    new_parent_label,
                    ft.TextButton("変更...", on_click=_browse_new_parent,
                        style=ft.ButtonStyle(color=C("accent"))),
                ], spacing=8, vertical_alignment=ft.CrossAxisAlignment.CENTER),
                ft.Container(height=8),
                ft.Button(content=ft.Text("新規作成"), bgcolor=C("accent"),
                    color="white", height=44, on_click=_create),

                ft.Container(height=32),
                ft.Divider(color=C("border")),
                ft.Container(height=16),

                # 既存プロジェクトを開く
                ft.Text("プロジェクトを開く", size=14, weight=ft.FontWeight.W_600, color=C("text")),
                ft.Container(height=8),
                ft.Button(content=ft.Row([
                    ft.Icon(ft.Icons.FOLDER_OPEN, color=C("text"), size=18),
                    ft.Text("フォルダを選択...", color=C("text")),
                ], spacing=8), bgcolor=C("surface"), height=44, on_click=_browse_open,
                    style=ft.ButtonStyle(side=ft.BorderSide(1, C("border")))),

                # 既存プロジェクト一覧
                *([ ft.Container(height=16),
                    ft.Text("最近のプロジェクト", size=12, color=C("text2")),
                    ft.Container(height=8),
                    *existing ] if existing else []),

                # プロジェクト保存先の設定
                ft.Container(height=32),
                ft.Divider(color=C("border")),
                ft.Container(height=16),
                _build_projects_dir_setting(),
            ], horizontal_alignment=ft.CrossAxisAlignment.CENTER,
               scroll=ft.ScrollMode.AUTO, width=500),
            expand=True, padding=ft.Padding.all(40),
            alignment=ft.Alignment.TOP_CENTER,
        ))
        page.update()

    def _save_data():
        """site_data.json を保存し、最近のプロジェクト履歴を更新する"""
        proj_dir = current_project_dir["ref"]
        if proj_dir:
            _save_data()
            _record_recent(proj_dir)

    def load_project(proj_dir):
        nonlocal data, is_building
        current_project_dir["ref"] = proj_dir
        data_file = proj_dir / "site_data.json"
        data.clear()
        data.update(load_json(data_file, {}))
        _record_recent(proj_dir)

        # テンプレートがあれば読む、なければデフォルト
        tpl = None
        local_tpl = proj_dir / "template.json"
        if local_tpl.exists():
            tpl = load_json(local_tpl)
        else:
            tpl_id = data.get("_template_id", "")
            if tpl_id:
                for f in TEMPLATES_DIR.glob("*.json"):
                    t = json.loads(f.read_text("utf-8"))
                    if t.get("template_id") == tpl_id:
                        tpl = t; break
                if tpl:
                    save_json(local_tpl, tpl)
        if not tpl:
            tpl = dict(DEFAULT_TPL)
        current_template["ref"] = tpl
        is_building = False
        show_editor(proj_dir, tpl, initial_tab=1)

    # ━━━ Editor UI (dynamic from template) ━━━
    def show_editor(proj_dir, tpl, initial_tab=0):
        content_area.controls.clear()
        output_dir = proj_dir / "output"
        site_file = output_dir / "index.html"
        theme = tpl["theme"]

        def _field(lbl, val="", hint="", multiline=False, expand=False):
            return ft.TextField(label=lbl, value=val, hint_text=hint, multiline=multiline,
                min_lines=3 if multiline else 1, max_lines=6 if multiline else 1,
                border_color=theme["border"], focused_border_color=theme["accent"],
                label_style=ft.TextStyle(color=theme["text2"], size=12),
                text_style=ft.TextStyle(color=theme["text"], size=13),
                bgcolor=theme["surface"], border_radius=8,
                content_padding=ft.Padding.symmetric(horizontal=12, vertical=10), expand=expand)

        def _sec(title, controls):
            return ft.Container(content=ft.Column([
                ft.Text(title, size=13, weight=ft.FontWeight.W_700, color=theme["accent"]),
                ft.Divider(height=1, color=theme["border"]), *controls
            ], spacing=10), padding=ft.Padding.only(bottom=16))

        # ── Dynamic form generation ──
        field_refs = {}  # section_id -> {key: widget}
        list_containers = {}  # section_id -> ft.Column

        def _make_widget(f, val, theme, expand=False):
            """フィールド定義からウィジェットを生成（date/datetime/markdown対応）"""
            ftype = f.get("type", "")
            if ftype == "checkbox":
                return ft.Checkbox(label=f["label"], value=bool(val),
                    check_color=theme["accent"], active_color=theme["accent"])
            elif ftype == "date":
                # 日付フィールド: TextField + DatePicker
                tf = _field(f["label"], str(val) if val else "", f.get("hint","今日の日付"), expand=expand)
                def _pick_date(e, tf=tf):
                    def _on_pick(e2):
                        if e2.control.value:
                            tf.value = e2.control.value.strftime("%Y-%m-%d")
                            page.update()
                    dp = ft.DatePicker(on_change=_on_pick)
                    page.show_dialog(dp)
                    page.update()
                return ft.Row([tf, ft.IconButton(icon=ft.Icons.CALENDAR_MONTH,
                    icon_color=theme["accent"], icon_size=20, on_click=_pick_date)], spacing=4, expand=expand)
            elif ftype == "datetime":
                tf = _field(f["label"], str(val) if val else "", f.get("hint","2026-04-01 10:00"), expand=expand)
                def _pick_dt(e, tf=tf):
                    def _on_pick(e2):
                        if e2.control.value:
                            tf.value = e2.control.value.strftime("%Y-%m-%d") + " " + (tf.value.split(" ")[-1] if " " in tf.value else "10:00")
                            page.update()
                    dp = ft.DatePicker(on_change=_on_pick)
                    page.show_dialog(dp)
                    page.update()
                return ft.Row([tf, ft.IconButton(icon=ft.Icons.CALENDAR_MONTH,
                    icon_color=theme["accent"], icon_size=20, on_click=_pick_dt)], spacing=4, expand=expand)
            elif ftype == "image":
                # 画像フィールド: digiKam から選択 + プレビュー
                img_path_field = ft.TextField(value=str(val) if val else "", visible=False)
                img_preview = ft.Image(src=str(val) if val else "", width=160, height=120,
                    fit=ft.BoxFit.COVER, border_radius=8, visible=bool(val))
                img_label = ft.Text(
                    os.path.basename(str(val)) if val else "digiKam から選択",
                    size=11, color=theme["text2"], max_lines=1, overflow=ft.TextOverflow.ELLIPSIS)
                multiple = f.get("multiple", False)

                def _open_dk(e, ipf=img_path_field, ip=img_preview, il=img_label, mult=multiple):
                    def _on_dk_select(paths, dk_images):
                        if mult:
                            ipf.value = ",".join(paths)
                            ip.src = str(output_dir / paths[0])
                            ip.visible = True
                            il.value = f"{len(paths)}枚選択済み"
                            # 全画像のキャプションを保存
                            captions = [im.get("caption", "") for im in dk_images if im.get("caption")]
                            if captions:
                                ipf.data = captions
                        else:
                            ipf.value = paths[0]
                            ip.src = str(output_dir / paths[0])
                            ip.visible = True
                            il.value = os.path.basename(paths[0])
                            if dk_images and dk_images[0].get("caption"):
                                ipf.data = dk_images[0]["caption"]
                        page.update()
                    open_digikam_browser(page, theme, output_dir, mult, _on_dk_select)
                dk_btn = ft.IconButton(icon=ft.Icons.PHOTO_LIBRARY,
                    icon_color=theme["accent"], icon_size=24, tooltip="digiKam から選択",
                    on_click=_open_dk)
                def _clear_img(e, ipf=img_path_field, ip=img_preview, il=img_label):
                    ipf.value = ""; ip.visible = False; il.value = "digiKam から選択"; page.update()
                clear_btn = ft.IconButton(icon=ft.Icons.CLEAR, icon_color=theme["text2"],
                    icon_size=16, tooltip="クリア", on_click=_clear_img)
                return ft.Column([
                    ft.Text(f["label"], size=12, color=theme["text2"]),
                    img_preview,
                    ft.Row([dk_btn, il, clear_btn], spacing=4),
                    img_path_field,
                ], spacing=4, expand=expand)
            elif ftype == "markdown":
                # マークダウンエディタ: 大きめテキストエリア + プレビュートグル
                tf = ft.TextField(label=f["label"], value=str(val) if val else "",
                    hint_text=f.get("hint","マークダウン記法で記述できます"),
                    multiline=True, min_lines=8, max_lines=20,
                    border_color=theme["border"], focused_border_color=theme["accent"],
                    label_style=ft.TextStyle(color=theme["text2"], size=12),
                    text_style=ft.TextStyle(color=theme["text"], size=13, font_family="monospace"),
                    bgcolor=theme["surface"], border_radius=8,
                    content_padding=ft.Padding.symmetric(horizontal=12, vertical=10), expand=expand)
                md_preview = ft.Markdown(value="", selectable=True,
                    extension_set=ft.MarkdownExtensionSet.GITHUB_WEB, expand=expand)
                md_container = ft.Container(content=md_preview, bgcolor=theme["surface"],
                    border_radius=8, padding=ft.Padding.all(12), border=ft.Border.all(1, theme["border"]),
                    visible=False, expand=expand)
                def _toggle_preview(e, tf=tf, md_preview=md_preview, mc=md_container):
                    mc.visible = not mc.visible
                    if mc.visible:
                        md_preview.value = tf.value or "*プレビューする内容がありません*"
                    page.update()
                preview_btn = ft.TextButton(content=ft.Text("👁 プレビュー", size=11, color=theme["text2"]),
                    on_click=_toggle_preview)
                return ft.Column([ft.Row([ft.Text(f["label"], size=12, color=theme["text2"]), preview_btn],
                    alignment=ft.MainAxisAlignment.SPACE_BETWEEN), tf, md_container], spacing=4, expand=expand)
            elif "choices" in f:
                return ft.Dropdown(label=f["label"], value=str(val) if val else f["choices"][0],
                    options=[ft.dropdown.Option(c) for c in f["choices"]],
                    border_color=theme["border"], bgcolor=theme["surface"],
                    text_style=ft.TextStyle(color=theme["text"], size=13),
                    label_style=ft.TextStyle(color=theme["text2"], size=12),
                    width=250, border_radius=8)
            else:
                return _field(f["label"], str(val) if val else "", f.get("hint",""), f.get("multiline",False), expand=expand)

        def _get_widget_value(w):
            """ウィジェットから値を取得（Rowラップ等を考慮）"""
            if isinstance(w, ft.Row) and w.controls:
                # date/datetime: Row[TextField, IconButton]
                return w.controls[0].value if hasattr(w.controls[0], 'value') else ""
            elif isinstance(w, ft.Column) and len(w.controls) >= 2:
                # image: Column[Text, Image, Row, TextField(hidden)] — last control is hidden TextField
                last = w.controls[-1]
                if isinstance(last, ft.TextField) and not last.visible:
                    return last.value or ""
                # markdown: Column[Row, TextField, Container]
                return w.controls[1].value if hasattr(w.controls[1], 'value') else ""
            elif hasattr(w, 'value'):
                return w.value
            return ""

        # ── プラグインの data_sections をマージ ──
        all_sections = list(tpl.get("data_sections", []))
        plugins_dir = proj_dir / "plugins"
        _loaded_plugins = []
        if plugins_dir.exists():
            for pd in sorted(plugins_dir.iterdir()):
                pj = pd / "plugin.json"
                if pj.exists():
                    try:
                        pdata = json.loads(pj.read_text("utf-8"))
                        _loaded_plugins.append(pdata)
                        for ps in pdata.get("data_sections", []):
                            # 重複チェック
                            if not any(s["id"] == ps["id"] for s in all_sections):
                                all_sections.append(ps)
                    except Exception:
                        pass
        # グローバル plugins/ もチェック
        global_plugins_dir = BASE_DIR / "plugins"
        if global_plugins_dir.exists() and global_plugins_dir != plugins_dir:
            for pd in sorted(global_plugins_dir.iterdir()):
                pj = pd / "plugin.json"
                if pj.exists():
                    try:
                        pdata = json.loads(pj.read_text("utf-8"))
                        if not any(lp.get("plugin_id") == pdata.get("plugin_id") for lp in _loaded_plugins):
                            _loaded_plugins.append(pdata)
                            for ps in pdata.get("data_sections", []):
                                if not any(s["id"] == ps["id"] for s in all_sections):
                                    all_sections.append(ps)
                    except Exception:
                        pass

        sections_ui = []
        for sec in all_sections:
            sid = sec["id"]
            if sec["type"] == "fields":
                refs = {}
                controls = []
                for f in sec["fields"]:
                    k = f["key"]
                    val = data.get(sid, {}).get(k, f.get("default", ""))
                    w = _make_widget(f, val, theme)
                    refs[k] = w
                    controls.append(w)
                field_refs[sid] = refs
                sections_ui.append(_sec(sec["title"], controls))

            elif sec["type"] == "list":
                lc = ft.Column(spacing=6)
                list_containers[sid] = lc

                def _rebuild_list(sid=sid, lc=lc, sec=sec):
                    lc.controls.clear()
                    items = data.get(sid, [])
                    for i, item in enumerate(items):
                        idx = i
                        def _del(e, sid=sid, idx=idx):
                            data[sid].pop(idx)
                            _save_data()
                            _rebuild_list(sid, list_containers[sid], sec)
                            page.update()
                        def _edit(e, sid=sid, idx=idx, sec=sec):
                            _open_edit_dlg(sid, idx, sec)
                        title = item.get(sec.get("item_label_key","name"), "?")
                        sub_tpl = sec.get("item_subtitle_template","")
                        try: sub = sub_tpl.format(**{k: item.get(k,"") for k in [f["key"] for f in sec["fields"]]})
                        except: sub = ""
                        # 日付があれば表示
                        date_val = ""
                        for f in sec["fields"]:
                            if f.get("type") in ("date","datetime") and item.get(f["key"]):
                                date_val = f"📅 {item[f['key']]}  "
                                break
                        lc.controls.append(ft.Container(
                            content=ft.Row([ft.Column([
                                ft.Text(f"{date_val}{title}", size=13, weight=ft.FontWeight.W_600, color=theme["text"]),
                                ft.Text(sub, size=11, color=theme["text2"]),
                            ], expand=True, spacing=2),
                            ft.Row([
                                ft.IconButton(icon=ft.Icons.EDIT_OUTLINED, icon_color=theme["text2"], icon_size=16, on_click=_edit),
                                ft.IconButton(icon=ft.Icons.DELETE_OUTLINE, icon_color=theme["text2"], icon_size=16, on_click=_del),
                            ], spacing=0)]),
                            bgcolor=theme["surface"], border_radius=8, padding=ft.Padding.all(10),
                            border=ft.Border.all(1, theme["border"])))

                _rebuild_list()

                # 追加/編集ダイアログ生成
                def _make_item_dlg(sid, sec, lc, edit_idx=None):
                    """追加 or 編集ダイアログを生成"""
                    existing = data.get(sid, [])[edit_idx] if edit_idx is not None else {}
                    is_edit = edit_idx is not None
                    dlg_fields = {}
                    dlg_controls = []
                    for f in sec["fields"]:
                        val = existing.get(f["key"], f.get("default","")) if is_edit else ""
                        w = _make_widget(f, val, theme, expand=True)
                        dlg_fields[f["key"]] = w
                        dlg_controls.append(w)

                    def _save(e):
                        item = {}
                        for f in sec["fields"]:
                            item[f["key"]] = _get_widget_value(dlg_fields[f["key"]])
                        label_key = sec.get("item_label_key","name")
                        if not item.get(label_key,""): return
                        if is_edit:
                            data[sid][edit_idx] = item
                        else:
                            data.setdefault(sid, []).append(item)
                        _save_data()
                        _rebuild_list(sid, list_containers[sid], sec)
                        action = "更新" if is_edit else "追加"
                        add_log(f"✅ {action}: {item.get(label_key,'')}", theme["green"])
                        page.pop_dialog(); page.update()

                    title_text = f"{sec['title']}を{'編集' if is_edit else '追加'}"
                    h = min(len(sec["fields"])*65, 500)
                    # markdown フィールドがあればダイアログを大きく
                    if any(f.get("type")=="markdown" for f in sec["fields"]): h = min(h + 200, 600)

                    dlg = ft.AlertDialog(
                        title=ft.Text(title_text, size=16, weight=ft.FontWeight.W_600),
                        content=ft.Container(width=520, content=ft.Column(dlg_controls, spacing=10,
                            scroll=ft.ScrollMode.AUTO, height=h)),
                        actions=[
                            ft.TextButton(content=ft.Text("キャンセル"),
                                on_click=lambda e: (page.pop_dialog(), page.update())),
                            ft.Button(content=ft.Text("保存" if is_edit else "追加"),
                                bgcolor=theme["accent"], color="white", on_click=_save)])
                    return dlg

                def _open_add_dlg(e, sid=sid, sec=sec, lc=lc):
                    dlg = _make_item_dlg(sid, sec, lc)
                    page.show_dialog(dlg); page.update()

                def _open_edit_dlg(sid, idx, sec):
                    dlg = _make_item_dlg(sid, sec, list_containers[sid], edit_idx=idx)
                    page.show_dialog(dlg); page.update()

                # digiKam 一括インポートボタン（画像フィールドを持つリストのみ）
                has_photo_field = any(f.get("type") == "image" and not f.get("multiple") for f in sec["fields"])
                list_btns = [ft.Button(content=ft.Text(f"＋ {sec['title']}を追加"),
                    bgcolor=theme["surface"], color=theme["text"], on_click=_open_add_dlg)]

                if has_photo_field:
                    def _dk_bulk_import(e, sid=sid, sec=sec, lc=lc):
                        """digiKam から複数写真を選択し、各画像をリストアイテムとして一括追加"""
                        def _on_bulk_select(paths, dk_images):
                            # digiKam メタデータからギャラリーアイテムを自動生成
                            db_path_str = load_json(CONFIG_FILE, {}).get("digikam_db_path", "") or os.environ.get("DIGIKAM_DB_HINT", "")
                            db_path = dkb.find_digikam_db(db_path_str)
                            if db_path:
                                gallery_items = dkb.export_for_gallery(db_path, [im["id"] for im in dk_images])
                            else:
                                gallery_items = [{"caption": im.get("caption", im["name"]), "tags": ", ".join(im.get("tags", []))} for im in dk_images]
                            # パスを対応付けてデータに追加
                            photo_key = next((f["key"] for f in sec["fields"] if f.get("type") == "image" and not f.get("multiple")), "photo")
                            for i, path in enumerate(paths):
                                if i < len(gallery_items):
                                    item = gallery_items[i]
                                    item[photo_key] = path
                                    # _source_path と _image_id は内部用なので削除
                                    item.pop("_source_path", None)
                                    item.pop("_image_id", None)
                                else:
                                    item = {photo_key: path}
                                # sec のフィールドにないキーは除去
                                valid_keys = {f["key"] for f in sec["fields"]}
                                item = {k: v for k, v in item.items() if k in valid_keys}
                                data.setdefault(sid, []).append(item)
                            _save_data()
                            _rebuild_list(sid, list_containers[sid], sec)
                            add_log(f"📸 digiKam から {len(paths)}枚を一括インポート", theme["green"])
                            page.update()
                        open_digikam_browser(page, theme, output_dir, True, _on_bulk_select)

                    list_btns.append(ft.Button(
                        content=ft.Row([ft.Icon(ft.Icons.PHOTO_LIBRARY, size=16), ft.Text("digiKam 一括インポート")], spacing=4),
                        bgcolor=theme["accent"], color="white", on_click=_dk_bulk_import))

                # WordPress XML インポート（blog セクションのみ）
                if sid == "blog":
                    wp_xml_path = ft.TextField(label="WordPress XMLファイルパス", hint_text="例: /home/user/export.xml",
                        border_color=theme["border"], focused_border_color=theme["accent"],
                        bgcolor=theme["surface"], text_style=ft.TextStyle(color=theme["text"], size=13),
                        label_style=ft.TextStyle(color=theme["text2"], size=12), border_radius=8, expand=True)
                    def _wp_import(e, sid=sid, sec=sec, lc=lc, path_field=wp_xml_path):
                        xml_path = path_field.value.strip() if path_field.value else ""
                        if not xml_path: return
                        p = Path(xml_path).expanduser().resolve()
                        if not p.is_file():
                            add_log(f"⚠ ファイルが見つかりません: {p}", "#eab308"); return
                        try:
                            posts = import_wordpress_xml(str(p))
                            if not posts:
                                add_log("⚠ 記事が見つかりません", "#eab308"); return
                            existing = data.get(sid, [])
                            existing_slugs = {p.get("slug") for p in existing}
                            added = 0
                            for post in posts:
                                if post["slug"] not in existing_slugs:
                                    existing.append(post)
                                    added += 1
                            data[sid] = existing
                            _save_data()
                            _rebuild_list(sid, list_containers[sid], sec)
                            add_log(f"✅ WordPress インポート: {added}件追加（{len(posts)}件中）", theme["green"])
                        except Exception as ex:
                            add_log(f"❌ インポートエラー: {ex}", "#ef4444")
                        page.update()
                    list_btns.append(ft.Row([wp_xml_path,
                        ft.Button(
                            content=ft.Row([ft.Icon(ft.Icons.UPLOAD_FILE, size=16), ft.Text("WP インポート")], spacing=4),
                            bgcolor=theme["surface"], color=theme["text"], on_click=_wp_import)
                    ], spacing=8, expand=True))

                sections_ui.append(_sec(sec["title"], [lc, ft.Row(list_btns, spacing=8, wrap=True)]))

        # ── Pages UI ──
        page_cards = ft.Column(spacing=6)
        def _rebuild_pages():
            page_cards.controls.clear()
            for i, pg in enumerate(data.get("pages",[])):
                idx=i
                def _del_pg(e, idx=idx):
                    data["pages"].pop(idx); _save_data(); _rebuild_pages(); page.update()
                page_cards.controls.append(ft.Container(
                    content=ft.Row([
                        ft.Container(content=ft.Text(f"{i+1}",size=11,color=theme["text2"]),
                            width=24,height=24,border_radius=12,bgcolor=theme["border"],alignment=ft.Alignment.CENTER),
                        ft.Column([
                            ft.Text(f"{pg['title']}  ({pg['filename']})",size=13,weight=ft.FontWeight.W_600,color=theme["text"]),
                            ft.Text(pg.get("description",""),size=11,color=theme["text2"]),
                        ],expand=True,spacing=2),
                        ft.IconButton(icon=ft.Icons.DELETE_OUTLINE,icon_color=theme["text2"],icon_size=16,on_click=_del_pg),
                    ],spacing=8),bgcolor=theme["surface"],border_radius=8,
                    padding=ft.Padding.symmetric(horizontal=12,vertical=8),border=ft.Border.all(1,theme["border"])))
        _rebuild_pages()

        pg_fn=_field("ファイル名",hint="例: gallery.html"); pg_title=_field("タイトル"); pg_desc=_field("内容の説明")
        pg_dlg=ft.AlertDialog(title=ft.Text("ページ追加"),
            content=ft.Container(width=400,content=ft.Column([pg_fn,pg_title,pg_desc],spacing=10,height=200)),
            actions=[ft.TextButton(content=ft.Text("キャンセル"),on_click=lambda e:(page.pop_dialog(),page.update())),
                     ft.Button(content=ft.Text("追加"),bgcolor=theme["accent"],color="white",
                        on_click=lambda e:_add_page())])
        def _add_page():
            fn=pg_fn.value.strip(); t=pg_title.value.strip()
            if not fn or not t: return
            if not fn.endswith(".html"): fn+=".html"
            data.setdefault("pages",[]).append({"filename":fn,"title":t,"description":pg_desc.value})
            _save_data(); _rebuild_pages()
            pg_fn.value="";pg_title.value="";pg_desc.value=""; page.pop_dialog(); page.update()

        # ── Site settings ──
        st = data.get("site",{})
        s_url=_field("サイトURL",st.get("url",""),"例: https://example.com（サイトマップ・OGP生成に使用）",expand=True)
        s_style=ft.Dropdown(label="デザイン",value=st.get("style",""),
            options=[ft.dropdown.Option(s) for s in tpl.get("site_styles",["デフォルト"])],
            border_color=theme["border"],bgcolor=theme["surface"],text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),width=220,border_radius=8)
        s_color=ft.Dropdown(label="カラーテーマ",value=st.get("color_theme",""),
            options=[ft.dropdown.Option(c) for c in tpl.get("color_themes",["デフォルト"])],
            border_color=theme["border"],bgcolor=theme["surface"],text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),width=220,border_radius=8)
        s_extra=_field("追加リクエスト",st.get("extra_request",""),"自由にリクエスト",multiline=True)

        # ── WordPress Theme Browser ──
        wp_search=ft.TextField(label="WPテーマ検索",hint_text="例: farm, restaurant, business",
            border_color=theme["border"],focused_border_color=theme["accent"],
            bgcolor=theme["surface"],text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,expand=True,
            on_submit=lambda e:_search_wp_themes(e))
        wp_results=ft.Column(spacing=8)
        wp_selected_info=ft.Text(
            f"選択中: {data.get('wp_theme_ref',{}).get('name','なし')}" if data.get('wp_theme_ref') else "テーマ未選択（検索してデザイン参考を選べます）",
            size=12,color=theme["text2"])

        def _search_wp_themes(e):
            q=wp_search.value.strip()
            if not q: return
            wp_results.controls.clear()
            wp_results.controls.append(ft.Text("検索中...",size=12,color=theme["text2"]))
            page.update()
            def _fetch():
                try:
                    url=f"https://api.wordpress.org/themes/info/1.2/?action=query_themes&request[search]={q}&request[per_page]=12"
                    r=requests.get(url,timeout=15)
                    themes=r.json().get("themes",[]) if r.ok else []
                    wp_results.controls.clear()
                    if not themes:
                        wp_results.controls.append(ft.Text("テーマが見つかりませんでした",size=12,color=theme["text2"]))
                        page.update(); return
                    # グリッド表示
                    row_items=[]
                    for t in themes[:12]:
                        screenshot=t.get("screenshot_url","")
                        name=t.get("name","")
                        slug=t.get("slug","")
                        desc=t.get("description","")[:100]
                        tags=", ".join(list(t.get("tags",{}).values())[:5]) if isinstance(t.get("tags"),dict) else ""
                        def _select_theme(e, t=t):
                            ref={"name":t.get("name",""),"slug":t.get("slug",""),
                                 "screenshot_url":t.get("screenshot_url",""),
                                 "description":t.get("description","")[:300],
                                 "tags":list(t.get("tags",{}).values())[:10] if isinstance(t.get("tags"),dict) else [],
                                 "homepage":t.get("homepage",""),
                                 "preview_url":t.get("preview_url","")}
                            data["wp_theme_ref"]=ref
                            _save_data()
                            wp_selected_info.value=f"✅ 選択: {ref['name']}（Claudeがこのデザインを参考にします）"
                            wp_selected_info.color=theme["green"]
                            add_log(f"🎨 WPテーマ参照: {ref['name']}",theme["green"])
                            page.update()
                        card=ft.Container(
                            content=ft.Column([
                                ft.Image(src=screenshot,width=200,height=150,fit=ft.BoxFit.COVER,
                                    border_radius=ft.border_radius.only(top_left=8,top_right=8)) if screenshot else ft.Container(height=150,bgcolor=theme["border"]),
                                ft.Container(content=ft.Column([
                                    ft.Text(name,size=12,weight=ft.FontWeight.W_600,color=theme["text"],
                                        max_lines=1,overflow=ft.TextOverflow.ELLIPSIS),
                                    ft.Text(tags[:40] if tags else desc[:40],size=10,color=theme["text2"],
                                        max_lines=1,overflow=ft.TextOverflow.ELLIPSIS),
                                ],spacing=2),padding=ft.Padding.symmetric(horizontal=8,vertical=6)),
                            ],spacing=0),
                            width=210,border_radius=8,bgcolor=theme["surface"],
                            border=ft.Border.all(1,theme["border"]),
                            on_click=_select_theme,ink=True)
                        row_items.append(card)
                    wp_results.controls.append(ft.Row(row_items,wrap=True,spacing=10,run_spacing=10))
                except Exception as ex:
                    wp_results.controls.clear()
                    wp_results.controls.append(ft.Text(f"エラー: {ex}",size=12,color="#ef4444"))
                page.update()
            threading.Thread(target=_fetch,daemon=True).start()

        def _clear_wp_theme(e):
            data.pop("wp_theme_ref",None)
            _save_data()
            wp_selected_info.value="テーマ未選択"
            wp_selected_info.color=theme["text2"]
            page.update()

        # ── Save ──
        def save_data(e=None):
            for sid, refs in field_refs.items():
                sec_data = {}
                for k, w in refs.items():
                    sec_data[k] = _get_widget_value(w)
                data[sid] = sec_data
            data["site"] = {"url":s_url.value.strip(),"style":s_style.value,"color_theme":s_color.value,"extra_request":s_extra.value}
            _save_data()
            add_log("✅ 保存しました", theme["green"])
            sb = ft.SnackBar(content=ft.Text("保存しました"), bgcolor=theme["green"])
            page.overlay.append(sb); sb.open=True; page.update()

        # ── Data Tab ──
        tab_data = ft.Container(content=ft.Column([
            *sections_ui,
            _sec("ページ構成",[
                ft.Text("生成するHTMLページを自由に追加・削除",size=11,color=theme["text2"]),
                page_cards,
                ft.Button(content=ft.Text("＋ ページ追加"),bgcolor=theme["surface"],color=theme["text"],
                    on_click=lambda e:(page.show_dialog(pg_dlg),page.update()))]),
            _sec("デザイン参照（WordPressテーマ）",[
                ft.Text("世界中のデザイナーが作ったWPテーマからデザインの参考を選べます（WordPress自体は不要）",
                    size=11,color=theme["text2"]),
                wp_selected_info,
                ft.Row([wp_search,
                    ft.IconButton(icon=ft.Icons.SEARCH,icon_color=theme["accent"],on_click=_search_wp_themes),
                    ft.TextButton(content=ft.Text("クリア",size=11),on_click=_clear_wp_theme),
                ],spacing=4),
                wp_results]),
            _sec("サイト設定",[s_url,ft.Row([s_style,s_color],spacing=12),s_extra]),
            ft.Container(content=ft.Button(content=ft.Text("💾 保存"),
                bgcolor=theme["accent"],color="white",width=200,height=44,on_click=save_data),
                alignment=ft.Alignment.CENTER,padding=ft.Padding.symmetric(vertical=16)),
        ],spacing=6,scroll=ft.ScrollMode.AUTO),expand=True,padding=ft.Padding.all(20))

        # ── Build Tab ──
        chat_input=ft.TextField(hint_text="修正指示を入力...",border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),border_radius=8,expand=True,
            on_submit=lambda e:send_msg(e))
        build_prog=ft.ProgressBar(visible=False,color=theme["accent"],bgcolor=theme["border"])

        def _agent(prompt,initial=False,mode="direct"):
            nonlocal is_building
            async def _run():
                nonlocal is_building
                try:
                    from claude_agent_sdk import ClaudeSDKClient,ClaudeAgentOptions,AssistantMessage,ResultMessage,TextBlock,ToolUseBlock
                    srv=create_tools(proj_dir)
                    # プラグイン指示を system_prompt_context に追加
                    _ctx = tpl.get("system_prompt_context","")
                    for _plg in _loaded_plugins:
                        instr = _plg.get("instructions","")
                        if instr:
                            _ctx += f"\n\n## プラグイン: {_plg.get('plugin_name','')}\n{instr}"
                    sys_prompt=build_system_prompt(str(output_dir.resolve()),data.get("pages",[]),
                        _ctx, data.get("wp_theme_ref"),
                        site_url=data.get("site",{}).get("url",""),
                        seo_data=data.get("seo",{}),mode=mode)
                    opts=ClaudeAgentOptions(system_prompt=sys_prompt,
                        allowed_tools=["Read","Write","Edit","Bash",
                            "mcp__aiseed__get_site_data","mcp__aiseed__get_deploy_config",
                            "mcp__aiseed__save_deploy_config","mcp__aiseed__log_action"],
                        permission_mode="acceptEdits",mcp_servers={"aiseed":srv},
                        cwd=str(proj_dir),max_turns=40)
                    async with ClaudeSDKClient(options=opts) as client:
                        await client.query(prompt)
                        async for msg in client.receive_response():
                            if isinstance(msg,AssistantMessage):
                                for b in msg.content:
                                    if isinstance(b,TextBlock): add_log(f"Claude: {b.text}",theme["text"])
                                    elif isinstance(b,ToolUseBlock):
                                        l=b.name
                                        if b.name=="Write": l=f"Write → {b.input.get('file_path','')}"
                                        elif b.name=="Edit": l=f"Edit → {b.input.get('file_path','')}"
                                        elif b.name.startswith("mcp__aiseed__"): l="🔧 "+b.name.replace("mcp__aiseed__","")
                                        add_log(f"  ⚙ {l}",theme["text2"])
                            elif isinstance(msg,ResultMessage):
                                p=[]
                                if msg.total_cost_usd is not None: p.append(f"${msg.total_cost_usd:.4f}")
                                if msg.num_turns: p.append(f"{msg.num_turns}ターン")
                                if p: add_log(f"📊 {' / '.join(p)}",theme["text2"])
                    add_log("✅ 完了",theme["green"])
                    # サイトマップ・フィード自動生成
                    site_url=data.get("site",{}).get("url","")
                    if site_url:
                        generate_sitemap(output_dir,site_url,data.get("pages",[]),data.get("blog",[]))
                        add_log("📋 sitemap.xml / robots.txt 生成",theme["text2"])
                        generate_feed(output_dir,site_url,data)
                        add_log("📡 feed.json 生成",theme["text2"])
                except ImportError: add_log("❌ claude-agent-sdk未インストール","#ef4444")
                except Exception as ex: add_log(f"❌ {ex}","#ef4444")
                finally: is_building=False; build_prog.visible=False; page.update()
            asyncio.run(_run())

        def _build_prompt_direct():
            pages=data.get("pages",[])
            if not pages:
                pages=[{"filename":"index.html","title":"トップページ","description":"メインページ"}]
            pl=", ".join(f"{p.get('filename','index.html')}({p.get('title','無題')})" for p in pages)
            return f"サイトを複数ページで作成。\n1.get_site_dataでデータ取得（pages配列あり）\n2.css/style.css→Write\n3.以下をWrite: {pl}\n4.全ページ共通ナビ\n5.log_action\nデータが空欄の項目はプレースホルダーテキストで補完してください。\n生成後ページ構成を報告。"
        def _build_prompt_jinja2():
            pages=data.get("pages",[])
            if not pages:
                pages=[{"filename":"index.html","title":"トップページ","description":"メインページ"}]
            pl=", ".join(f"_templates/{p.get('filename','index.html')}.j2" for p in pages)
            md_files=", ".join(f"content/{p.get('filename','index.html').replace('.html','.md')}" for p in pages)
            return f"Jinja2テンプレートとサンプルMarkdownを生成。\n1.get_site_dataでデータ構造を確認\n2._templates/base.j2→Write（共通レイアウト）\n3.css/style.css→Write（静的CSSの場合）またはcss/style.css.j2\n4.以下をWrite: {pl}\n5.content/にサンプルMarkdown生成: {md_files}\n6.log_action\nデータが空欄の項目はプレースホルダーテキストで補完してください。\n生成後テンプレート構成とcontent/構成を報告。"

        # ── Claude 直接生成 ──
        def start_build(e):
            nonlocal is_building
            if is_building: return
            is_building=True;build_prog.visible=True;page.update();save_data()
            add_log("▶ サイト生成開始（Claude 直接生成）...",theme["accent"])
            threading.Thread(target=_agent,args=(_build_prompt_direct(),True,"direct"),daemon=True).start()
        def auto_build(e):
            nonlocal is_building
            if is_building: return
            is_building=True;build_prog.visible=True;page.update();save_data()
            add_log("▶ 自動ビルド開始（Claude 直接生成）...",theme["accent"])
            p=_build_prompt_direct()+"\n\nさらに:Readで全ページ品質チェック（リンク整合性、データ反映）。問題あればEdit。"
            threading.Thread(target=_agent,args=(p,True,"direct"),daemon=True).start()

        # ── 静的ジェネレータ ──
        def ssg_create_templates(e):
            nonlocal is_building
            if is_building: return
            is_building=True;build_prog.visible=True;page.update();save_data()
            add_log("▶ テンプレート生成開始（静的ジェネレータ）...",theme["accent"])
            threading.Thread(target=_agent,args=(_build_prompt_jinja2(),True,"jinja2"),daemon=True).start()
        def ssg_render(e):
            nonlocal is_building
            if is_building: return
            save_data()
            templates_dir=output_dir/"_templates"
            if not templates_dir.exists() or not list(templates_dir.rglob("*.j2")):
                add_log("テンプレート未生成。先に「テンプレート生成」を実行してください","#eab308");return
            is_building=True;build_prog.visible=True;page.update()
            add_log("▶ サイト生成開始（静的ジェネレータ）...","#d97706")
            def _run():
                nonlocal is_building
                try:
                    files=render_site(proj_dir,log_fn=lambda m:add_log(m,theme["text2"]))
                    add_log(f"{len(files)}ファイル生成完了",theme["green"])
                    site_url=data.get("site",{}).get("url","")
                    if site_url:
                        generate_sitemap(output_dir,site_url,data.get("pages",[]),data.get("blog",[]))
                        generate_feed(output_dir,site_url,data)
                        add_log("sitemap.xml / feed.json 更新",theme["text2"])
                except FileNotFoundError as ex:
                    add_log(f"{ex}","#eab308")
                except Exception as ex:
                    add_log(f"エラー: {ex}","#ef4444")
                finally:
                    is_building=False;build_prog.visible=False;page.update()
            threading.Thread(target=_run,daemon=True).start()

        # ── 共通 ──
        def send_msg(e):
            nonlocal is_building
            msg=chat_input.value.strip()
            if not msg or is_building: return
            chat_input.value="";is_building=True;build_prog.visible=True;page.update()
            add_log(f"あなた: {msg}",theme["accent"])
            threading.Thread(target=_agent,args=(msg,),daemon=True).start()
        def preview(e):
            if not site_file.exists(): add_log("⚠ サイト未生成","#eab308"); return
            import http.server,functools; port=8080
            def _s():
                h=functools.partial(http.server.SimpleHTTPRequestHandler,directory=str(output_dir))
                try: s=http.server.HTTPServer(("",port),h); add_log(f"🌐 http://localhost:{port}",theme["green"]); webbrowser.open(f"http://localhost:{port}"); s.serve_forever()
                except OSError: webbrowser.open(f"http://localhost:{port}"); add_log(f"🌐 http://localhost:{port}",theme["green"])
            threading.Thread(target=_s,daemon=True).start()

        # ── ビルドタブ UI ──
        direct_row = ft.Row([
            ft.Button(content=ft.Text("⚡ 生成"),bgcolor=theme["accent"],color="white",height=38,on_click=start_build),
            ft.Button(content=ft.Text("🔄 自動ビルド"),bgcolor=theme["green"],color="white",height=38,on_click=auto_build),
        ],spacing=8)
        ssg_row = ft.Row([
            ft.Button(content=ft.Text("⚡ テンプレート生成"),bgcolor=theme["accent"],color="white",height=38,on_click=ssg_create_templates),
            ft.Button(content=ft.Text("📋 サイト生成"),bgcolor="#d97706",color="white",height=38,
                tooltip="Jinja2テンプレートからサイトを生成（API不使用）",on_click=ssg_render),
        ],spacing=8)
        def _on_mode_change(e):
            is_ssg = e.control.value == "ssg"
            direct_row.visible = not is_ssg
            ssg_row.visible = is_ssg
            page.update()
        build_mode = ft.RadioGroup(
            value="direct",on_change=_on_mode_change,
            content=ft.Row([
                ft.Radio(value="direct",label="Claude 直接生成"),
                ft.Radio(value="ssg",label="静的ジェネレータ"),
            ],spacing=16))
        ssg_row.visible = False

        tab_build=ft.Container(content=ft.Column([
            ft.Container(content=ft.Column([
                build_mode,
                direct_row,
                ssg_row,
                ft.Row([ft.Button(content=ft.Text("👁 プレビュー"),bgcolor=theme["surface"],color=theme["text"],height=38,on_click=preview)]),
            ],spacing=8),padding=ft.Padding.only(bottom=8)),
            build_prog,
            ft.Container(content=log_list,bgcolor=theme["surface"],border_radius=8,
                border=ft.Border.all(1,theme["border"]),padding=ft.Padding.all(12),expand=True),
            ft.Row([chat_input,ft.IconButton(icon=ft.Icons.SEND,icon_color=theme["accent"],on_click=send_msg)],spacing=8),
        ],spacing=8),expand=True,padding=ft.Padding.all(20))

        # ── Deploy Tab ──
        proj_config=load_json(proj_dir/"config.json",{})
        d_result=ft.Text("",size=13,selectable=True)
        deploy_content=ft.Column(spacing=10)

        # -- Cloudflare fields --
        cf_proj=_field("サイト名（英数字・ハイフン）",proj_config.get("cf_project_name",""),"例: my-farm-site（公開URLになります）")
        cf_acct=_field("Account ID（32文字の英数字）",proj_config.get("cf_account_id",""),"上の手順でコピーした値を貼り付け")
        cf_r2_enable=ft.Checkbox(label="画像を R2 にバックアップする（推奨）",
            value=proj_config.get("cf_r2_enable",True),check_color="white",active_color=theme["accent"],
            label_style=ft.TextStyle(color=theme["text"],size=13))
        cf_r2_bucket=_field("R2 バケット名",proj_config.get("cf_r2_bucket",""),"空欄 = サイト名-images を自動使用")
        cf_token=ft.TextField(label="APIトークン",value=proj_config.get("cf_api_token",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))

        # -- SSH fields --
        ssh_host=_field("ホスト",proj_config.get("ssh_host",""),"例: example.com")
        ssh_port=_field("ポート",proj_config.get("ssh_port","22"),"22")
        ssh_user=_field("ユーザー名",proj_config.get("ssh_user",""),"例: webadmin")
        ssh_key=_field("秘密鍵パス",proj_config.get("ssh_key",""),"例: ~/.ssh/id_rsa（空=パスワード認証）")
        ssh_pass=ft.TextField(label="パスワード",value=proj_config.get("ssh_password",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))
        ssh_path=_field("リモートパス",proj_config.get("ssh_remote_path",""),"例: /var/www/html")
        # -- 画像バックアップ（SSH/FTP共通） --
        bk_methods=["Cloudflare R2（推奨）","別のSSHサーバー","別のFTPサーバー","バックアップしない"]
        saved_bk=proj_config.get("backup_method","Cloudflare R2（推奨）")
        bk_r2_acct=_field("Account ID",proj_config.get("bk_r2_account_id",""),"Cloudflare の Account ID")
        bk_r2_token=ft.TextField(label="APIトークン",value=proj_config.get("bk_r2_token",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))
        bk_r2_bucket=_field("R2 バケット名",proj_config.get("bk_r2_bucket",""),"空欄 = images-backup を自動使用")
        bk_ssh_host=_field("ホスト",proj_config.get("bk_ssh_host",""),"バックアップ先サーバー")
        bk_ssh_port=_field("ポート",proj_config.get("bk_ssh_port","22"),"22")
        bk_ssh_user=_field("ユーザー名",proj_config.get("bk_ssh_user",""),"")
        bk_ssh_key=_field("秘密鍵パス",proj_config.get("bk_ssh_key",""),"空欄=パスワード認証")
        bk_ssh_pass=ft.TextField(label="パスワード",value=proj_config.get("bk_ssh_password",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))
        bk_ssh_path=_field("リモートパス",proj_config.get("bk_ssh_path",""),"例: /home/user/image-backup")
        bk_ftp_host=_field("ホスト",proj_config.get("bk_ftp_host",""),"バックアップ先FTPサーバー")
        bk_ftp_port=_field("ポート",proj_config.get("bk_ftp_port","21"),"21")
        bk_ftp_user=_field("ユーザー名",proj_config.get("bk_ftp_user",""),"")
        bk_ftp_pass=ft.TextField(label="パスワード",value=proj_config.get("bk_ftp_password",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))
        bk_ftp_path=_field("リモートパス",proj_config.get("bk_ftp_path",""),"例: /backup/images")
        bk_ftp_tls=ft.Checkbox(label="FTPS (TLS)",value=proj_config.get("bk_ftp_tls",True),
            check_color="white",active_color=theme["accent"],
            label_style=ft.TextStyle(color=theme["text"],size=13))
        bk_detail=ft.Column(spacing=8)
        def _switch_bk(e=None):
            bk_detail.controls.clear()
            m=bk_method.value if hasattr(bk_method,'value') else saved_bk
            if "R2" in m:
                bk_detail.controls.extend([bk_r2_acct,bk_r2_token,bk_r2_bucket,
                    ft.Text("同じ Cloudflare アカウントなら Account ID と API トークンは\nデプロイ設定と同じ値を使えます。無料10GB。",size=11,color=theme["text2"])])
            elif "SSH" in m:
                bk_detail.controls.extend([bk_ssh_host,ft.Row([bk_ssh_port,bk_ssh_user],spacing=8),bk_ssh_key,bk_ssh_pass,bk_ssh_path])
            elif "FTP" in m:
                bk_detail.controls.extend([bk_ftp_host,ft.Row([bk_ftp_port,bk_ftp_user],spacing=8),bk_ftp_pass,bk_ftp_path,bk_ftp_tls])
            page.update()
        bk_method=ft.Dropdown(label="画像バックアップ先",value=saved_bk,
            options=[ft.DropdownOption(m) for m in bk_methods],
            border_color=theme["border"],focused_border_color=theme["accent"],
            bgcolor=theme["surface"],text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            on_select=_switch_bk)
        _switch_bk()
        bk_section=ft.Column([
            ft.Divider(color=theme["border"]),
            ft.Text("画像バックアップ",size=13,weight=ft.FontWeight.W_600,color=theme["text"]),
            ft.Text("デプロイ時に画像を別の場所に自動バックアップします。\n同じサーバーでは意味がないため、別のサービス／サーバーを指定してください。",
                size=12,color=theme["text2"]),
            bk_method,bk_detail,
        ],spacing=8)

        # -- FTP fields --
        ftp_host=_field("ホスト",proj_config.get("ftp_host",""),"例: ftp.example.com")
        ftp_port=_field("ポート",proj_config.get("ftp_port","21"),"21")
        ftp_user=_field("ユーザー名",proj_config.get("ftp_user",""),"")
        ftp_pass=ft.TextField(label="パスワード",value=proj_config.get("ftp_password",""),
            password=True,can_reveal_password=True,border_color=theme["border"],
            focused_border_color=theme["accent"],bgcolor=theme["surface"],
            text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12,vertical=10))
        ftp_path=_field("リモートパス",proj_config.get("ftp_remote_path",""),"例: /public_html")
        ftp_tls=ft.Checkbox(label="FTPS (TLS) を使用",value=proj_config.get("ftp_tls",True),
            check_color="white",active_color=theme["accent"],
            label_style=ft.TextStyle(color=theme["text"],size=13))

        def _save_backup_config():
            """バックアップ設定をconfig.jsonに保存"""
            pc=load_json(proj_dir/"config.json",{})
            m=bk_method.value
            pc["backup_method"]=m
            if "R2" in m:
                pc.update({"bk_r2_account_id":bk_r2_acct.value.strip(),"bk_r2_token":bk_r2_token.value,
                            "bk_r2_bucket":bk_r2_bucket.value.strip()})
            elif "SSH" in m:
                pc.update({"bk_ssh_host":bk_ssh_host.value.strip(),"bk_ssh_port":bk_ssh_port.value.strip() or "22",
                            "bk_ssh_user":bk_ssh_user.value.strip(),"bk_ssh_key":bk_ssh_key.value.strip(),
                            "bk_ssh_password":bk_ssh_pass.value,"bk_ssh_path":bk_ssh_path.value.strip()})
            elif "FTP" in m:
                pc.update({"bk_ftp_host":bk_ftp_host.value.strip(),"bk_ftp_port":bk_ftp_port.value.strip() or "21",
                            "bk_ftp_user":bk_ftp_user.value.strip(),"bk_ftp_password":bk_ftp_pass.value,
                            "bk_ftp_path":bk_ftp_path.value.strip(),"bk_ftp_tls":bk_ftp_tls.value})
            save_json(proj_dir/"config.json",pc)

        def _run_backup():
            """画像バックアップを実行。戻り値: メッセージ文字列"""
            m=bk_method.value
            if "バックアップしない" in m: return ""
            if not (output_dir/"images").exists(): return ""
            img_count=len([f for f in (output_dir/"images").rglob("*") if f.is_file()])
            if img_count==0: return ""
            d_result.value="⏳ 画像をバックアップ中...";page.update()
            if "R2" in m:
                acct=bk_r2_acct.value.strip();token=bk_r2_token.value;bkt=bk_r2_bucket.value.strip() or "images-backup"
                if not all([acct,token]):return "\n⚠ R2: Account ID/トークン未設定"
                def _log(msg):d_result.value=msg;page.update()
                cnt,_=upload_images_to_r2(output_dir,acct,token,bkt,_log)
                return f"\nR2 バックアップ: {cnt}枚" if cnt>0 else ""
            elif "SSH" in m:
                import subprocess
                h=bk_ssh_host.value.strip();p=bk_ssh_port.value.strip() or "22"
                u=bk_ssh_user.value.strip();k=bk_ssh_key.value.strip()
                pw=bk_ssh_pass.value;rp=bk_ssh_path.value.strip()
                if not all([h,u,rp]):return "\n⚠ SSH バックアップ: 接続情報未設定"
                base_cmd=["sshpass","-p",pw] if (not k and pw) else []
                key_arg=["-e",f"ssh -p {p} -i {k} -o StrictHostKeyChecking=no"] if k else ["-e",f"ssh -p {p} -o StrictHostKeyChecking=no"]
                mkdir_cmd=base_cmd+["ssh"]
                if k: mkdir_cmd+=["-i",k]
                mkdir_cmd+=["-p",p,"-o","StrictHostKeyChecking=no",f"{u}@{h}",f"mkdir -p {rp}"]
                subprocess.run(mkdir_cmd,capture_output=True,text=True,timeout=30)
                img_src=str(output_dir/"images")+"/"
                bk_cmd=base_cmd+["rsync","-avz"]+key_arg+[img_src,f"{u}@{h}:{rp}/"]
                r=subprocess.run(bk_cmd,capture_output=True,text=True,timeout=120)
                if r.returncode==0:return f"\nSSH バックアップ: {img_count}枚 → {u}@{h}:{rp}"
                return f"\n⚠ SSH バックアップ失敗: {r.stderr.strip()[:80]}"
            elif "FTP" in m:
                import ftplib
                h=bk_ftp_host.value.strip();p=int(bk_ftp_port.value.strip() or "21")
                u=bk_ftp_user.value.strip();pw=bk_ftp_pass.value
                rp=bk_ftp_path.value.strip();tls=bk_ftp_tls.value
                if not all([h,u,rp]):return "\n⚠ FTP バックアップ: 接続情報未設定"
                ftp=ftplib.FTP_TLS() if tls else ftplib.FTP()
                ftp.connect(h,p,timeout=30);ftp.login(u,pw)
                if tls: ftp.prot_p()
                def _mkdirs(path):
                    parts=path.strip("/").split("/");cur=""
                    for pp in parts:
                        cur+=f"/{pp}"
                        try:ftp.mkd(cur)
                        except ftplib.error_perm:pass
                _mkdirs(rp);cnt=0
                for fp in (output_dir/"images").rglob("*"):
                    if not fp.is_file():continue
                    rel=fp.relative_to(output_dir/"images").as_posix()
                    dest=f"{rp}/{rel}";parent="/".join(dest.split("/")[:-1])
                    if parent:_mkdirs(parent)
                    with open(fp,"rb") as f:ftp.storbinary(f"STOR {dest}",f)
                    cnt+=1
                ftp.quit()
                return f"\nFTP バックアップ: {cnt}枚 → {h}:{rp}" if cnt>0 else ""
            return ""

        def _deploy_cf():
            n=cf_proj.value.strip();acct=cf_acct.value.strip();token=cf_token.value.strip()
            if not all([n,acct,token]):
                d_result.value="⚠ 全て入力してください";d_result.color="#eab308";page.update();return
            if not site_file.exists():
                d_result.value="⚠ サイト未生成";d_result.color="#eab308";page.update();return
            r2_on=cf_r2_enable.value;r2_bkt=cf_r2_bucket.value.strip() or f"{n}-images"
            pc=load_json(proj_dir/"config.json",{})
            pc.update({"cf_project_name":n,"cf_account_id":acct,"cf_api_token":token,
                        "cf_r2_enable":r2_on,"cf_r2_bucket":r2_bkt})
            save_json(proj_dir/"config.json",pc)
            d_result.value="⏳ デプロイ中...";d_result.color=theme["text2"];page.update()
            def _r():
                try:
                    base=f"https://api.cloudflare.com/client/v4/accounts/{acct}/pages/projects"
                    headers={"Authorization":f"Bearer {token}"}
                    r=requests.get(f"{base}/{n}",headers=headers,timeout=30)
                    if r.status_code==404:
                        r2_resp=requests.post(base,headers={**headers,"Content-Type":"application/json"},
                            json={"name":n,"production_branch":"main"},timeout=30)
                        if not r2_resp.ok:
                            d_result.value=f"❌ {r2_resp.json().get('errors',[{}])[0].get('message','失敗')}";d_result.color="#ef4444";page.update();return
                    # R2 画像バックアップ
                    r2_msg=""
                    if r2_on and (output_dir/"images").exists():
                        d_result.value="⏳ 画像を R2 にバックアップ中...";page.update()
                        def _log(m): d_result.value=m;page.update()
                        img_count,_=upload_images_to_r2(output_dir,acct,token,r2_bkt,_log)
                        if img_count>0: r2_msg=f"\nR2 バックアップ: {img_count}枚"
                    # Pages デプロイ
                    d_result.value="⏳ サイトをデプロイ中...";page.update()
                    files={}
                    for fp in output_dir.rglob("*"):
                        if fp.is_file():
                            rel="/"+fp.relative_to(output_dir).as_posix()
                            files[rel]=(fp.name,fp.read_bytes(),"application/octet-stream")
                    r3=requests.post(f"{base}/{n}/deployments",headers=headers,files=files,timeout=120)
                    if r3.ok:
                        url=r3.json().get("result",{}).get("url",f"https://{n}.pages.dev")
                        d_result.value=f"✅ デプロイ成功！({len(files)}ファイル)\n{url}{r2_msg}";d_result.color=theme["green"]
                        _switch_cf_view(True)
                    else:
                        d_result.value=f"❌ {r3.json().get('errors',[{}])[0].get('message','失敗')}";d_result.color="#ef4444"
                except Exception as ex: d_result.value=f"❌ {ex}";d_result.color="#ef4444"
                page.update()
            threading.Thread(target=_r,daemon=True).start()

        def _deploy_ssh():
            host=ssh_host.value.strip();port=ssh_port.value.strip() or "22"
            user=ssh_user.value.strip();remote=ssh_path.value.strip()
            key_path=ssh_key.value.strip();password=ssh_pass.value
            if not all([host,user,remote]):
                d_result.value="⚠ ホスト・ユーザー名・リモートパスを入力してください";d_result.color="#eab308";page.update();return
            if not site_file.exists():
                d_result.value="⚠ サイト未生成";d_result.color="#eab308";page.update();return
            pc=load_json(proj_dir/"config.json",{})
            pc.update({"ssh_host":host,"ssh_port":port,"ssh_user":user,
                        "ssh_key":key_path,"ssh_password":password,"ssh_remote_path":remote})
            save_json(proj_dir/"config.json",pc);_save_backup_config()
            d_result.value="⏳ SSH デプロイ中...";d_result.color=theme["text2"];page.update()
            def _r():
                try:
                    import subprocess
                    src=str(output_dir)+"/"
                    key_arg=["-e",f"ssh -p {port} -i {key_path} -o StrictHostKeyChecking=no"] if key_path else ["-e",f"ssh -p {port} -o StrictHostKeyChecking=no"]
                    base_cmd=["sshpass","-p",password] if (not key_path and password) else []
                    cmd=base_cmd+["rsync","-avz","--delete"]+key_arg+[src,f"{user}@{host}:{remote}/"]
                    result=subprocess.run(cmd,capture_output=True,text=True,timeout=120)
                    if result.returncode!=0:
                        d_result.value=f"❌ rsync失敗:\n{result.stderr.strip()}";d_result.color="#ef4444";page.update();return
                    count=len([fp for fp in output_dir.rglob("*") if fp.is_file()])
                    bk_msg=_run_backup()
                    d_result.value=f"✅ SSH デプロイ成功！({count}ファイル)\n{user}@{host}:{remote}{bk_msg}";d_result.color=theme["green"]
                except FileNotFoundError:
                    d_result.value="❌ rsync が見つかりません（sudo apt install rsync）";d_result.color="#ef4444"
                except Exception as ex: d_result.value=f"❌ {ex}";d_result.color="#ef4444"
                page.update()
            threading.Thread(target=_r,daemon=True).start()

        def _deploy_ftp():
            host=ftp_host.value.strip();port=int(ftp_port.value.strip() or "21")
            user=ftp_user.value.strip();password=ftp_pass.value;remote=ftp_path.value.strip()
            use_tls=ftp_tls.value
            if not all([host,user,remote]):
                d_result.value="⚠ ホスト・ユーザー名・リモートパスを入力してください";d_result.color="#eab308";page.update();return
            if not site_file.exists():
                d_result.value="⚠ サイト未生成";d_result.color="#eab308";page.update();return
            pc=load_json(proj_dir/"config.json",{})
            pc.update({"ftp_host":host,"ftp_port":str(port),"ftp_user":user,
                        "ftp_password":password,"ftp_remote_path":remote,"ftp_tls":use_tls})
            save_json(proj_dir/"config.json",pc);_save_backup_config()
            d_result.value="⏳ FTP デプロイ中...";d_result.color=theme["text2"];page.update()
            def _r():
                try:
                    import ftplib
                    ftp=ftplib.FTP_TLS() if use_tls else ftplib.FTP()
                    ftp.connect(host,port,timeout=30)
                    ftp.login(user,password)
                    if use_tls: ftp.prot_p()
                    count=0
                    def _upload(local_dir,remote_base):
                        nonlocal count
                        for item in local_dir.iterdir():
                            rel=item.relative_to(output_dir).as_posix()
                            rpath=f"{remote_base}/{rel}"
                            if item.is_dir():
                                try: ftp.mkd(rpath)
                                except ftplib.error_perm: pass
                                _upload(item,remote_base)
                            else:
                                with open(item,"rb") as f:
                                    ftp.storbinary(f"STOR {rpath}",f)
                                count+=1
                    _upload(output_dir,remote.rstrip("/"))
                    ftp.quit()
                    bk_msg=_run_backup()
                    d_result.value=f"✅ FTP デプロイ成功！({count}ファイル)\n{host}:{remote}{bk_msg}";d_result.color=theme["green"]
                except Exception as ex: d_result.value=f"❌ {ex}";d_result.color="#ef4444"
                page.update()
            threading.Thread(target=_r,daemon=True).start()

        def _sync_hub_if_enabled():
            """デプロイ後、同意がある場合にハブへ同期"""
            pc = load_json(proj_dir / "config.json", {})
            if not pc.get("hub_sync_enabled"):
                return
            hub_url = pc.get("hub_url", "").strip()
            site_token = pc.get("hub_site_token", "").strip()
            if not hub_url or not site_token:
                return
            # feed.json を読み込んで送信
            feed_path = output_dir / "feed.json"
            if not feed_path.exists():
                site_url = data.get("site", {}).get("url", "")
                if site_url:
                    generate_feed(output_dir, site_url, data)
            if feed_path.exists():
                try:
                    feed = json.loads(feed_path.read_text("utf-8"))
                    ok, msg = sync_to_hub(feed, hub_url, site_token)
                    if ok:
                        add_log(f"📡 {msg}", theme["green"])
                    else:
                        add_log(f"📡 {msg}", "#eab308")
                except Exception as ex:
                    add_log(f"📡 ハブ同期エラー: {ex}", "#eab308")

        def deploy(e):
            method=deploy_method.value
            pc=load_json(proj_dir/"config.json",{})
            pc["deploy_method"]=method
            save_json(proj_dir/"config.json",pc)
            if "Cloudflare" in method: _deploy_cf()
            elif method=="SSH (rsync)": _deploy_ssh()
            elif method=="FTP / FTPS": _deploy_ftp()
            # デプロイ後にハブ同期
            threading.Thread(target=_sync_hub_if_enabled, daemon=True).start()

        # -- Method panels --
        # Cloudflare: セットアップガイド付き
        cf_has_config=all([proj_config.get("cf_account_id",""),proj_config.get("cf_api_token","")])
        def _step(num,title,desc,link_text="",link_url=""):
            items=[ft.Text(f"Step {num}",size=11,weight=ft.FontWeight.W_700,color=theme["accent"]),
                ft.Text(title,size=13,weight=ft.FontWeight.W_600,color=theme["text"]),
                ft.Text(desc,size=12,color=theme["text2"])]
            if link_text and link_url:
                items.append(ft.TextButton(content=ft.Row([ft.Icon(ft.Icons.OPEN_IN_NEW,size=14,color=theme["accent"]),
                    ft.Text(link_text,size=12,color=theme["accent"])],spacing=4),
                    url=link_url))
            return ft.Container(content=ft.Column(items,spacing=2),
                bgcolor=theme["dark"],border_radius=8,padding=ft.Padding.all(12),
                border=ft.Border.all(1,theme["border"]))
        cf_guide=ft.Column([
            ft.Text("初回セットアップ（5分で完了・無料）",size=14,weight=ft.FontWeight.W_700,color=theme["text"]),
            _step(1,"Cloudflare の無料アカウントを作成",
                "メールアドレスだけで登録できます。クレジットカード不要。",
                "Cloudflare に登録（無料）","https://dash.cloudflare.com/sign-up"),
            _step(2,"Account ID をコピー",
                "ログイン後、左メニュー「Workers & Pages」をクリック。\n"
                "ページ右側の「Account ID」（32文字の英数字）をコピーして\n"
                "下の欄に貼り付けてください。"),
            _step(3,"API トークンを作成",
                "右上のアイコン →「My Profile」→「API Tokens」→\n"
                "「Create Token」→「Edit Cloudflare Workers」テンプレートを選択\n"
                "→「Continue to summary」→「Create Token」\n"
                "表示されたトークンをコピーして下の欄に貼り付けてください。",
                "API Tokens ページを開く","https://dash.cloudflare.com/profile/api-tokens"),
            ft.Divider(color=theme["border"]),
            cf_proj,cf_acct,cf_token,
            ft.Divider(color=theme["border"]),
            ft.Text("画像バックアップ（R2）",size=13,weight=ft.FontWeight.W_600,color=theme["text"]),
            ft.Text("デプロイ時に画像を Cloudflare R2 に自動バックアップします。\n"
                "パソコンが壊れても画像が失われません。同じアカウントで無料（10GB）。",
                size=12,color=theme["text2"]),
            cf_r2_enable,cf_r2_bucket,
            ft.Divider(color=theme["border"]),
            ft.Text("一度設定すれば、次回からは「デプロイ」ボタンを押すだけです。\n"
                "公開URL: https://（サイト名）.pages.dev",size=11,color=theme["text2"]),
        ],spacing=8)
        cf_configured=ft.Column([
            ft.Row([ft.Icon(ft.Icons.CHECK_CIRCLE,color=theme["green"],size=20),
                ft.Text("設定済み — ボタンを押すだけで公開できます",size=13,weight=ft.FontWeight.W_600,color=theme["green"])],spacing=6),
            cf_proj,cf_acct,cf_token,cf_r2_enable,cf_r2_bucket,
            ft.TextButton(content=ft.Text("セットアップガイドを表示",size=11,color=theme["text2"]),
                on_click=lambda e:(_switch_cf_view(False),)),
        ],spacing=8)
        cf_view=ft.Column(spacing=0)
        def _switch_cf_view(configured):
            cf_view.controls.clear()
            cf_view.controls.append(cf_configured if configured else cf_guide)
            page.update()
        _switch_cf_view(cf_has_config)

        ssh_panel=ft.Column([ssh_host,ft.Row([ssh_port,ssh_user],spacing=8),ssh_key,ssh_pass,ssh_path,
            ft.Text("rsync を使用してファイルを転送します。秘密鍵またはパスワード認証（sshpass必要）に対応。",
                size=11,color=theme["text2"])],spacing=10)
        ftp_panel=ft.Column([ftp_host,ft.Row([ftp_port,ftp_user],spacing=8),ftp_pass,ftp_path,ftp_tls,
            ft.Text("Python標準ライブラリ ftplib を使用。追加インストール不要。",
                size=11,color=theme["text2"])],spacing=10)

        method_panels={"Cloudflare Pages（推奨・無料）":cf_view,"SSH (rsync)":ssh_panel,"FTP / FTPS":ftp_panel}
        saved_method=proj_config.get("deploy_method","Cloudflare Pages（推奨・無料）")

        def _switch_method(e=None):
            deploy_content.controls.clear()
            m=deploy_method.value if hasattr(deploy_method,'value') else saved_method
            deploy_content.controls.append(method_panels.get(m,cf_view))
            # SSH/FTPの場合のみバックアップセクション表示
            if "Cloudflare" not in m:
                deploy_content.controls.append(bk_section)
            page.update()

        deploy_method=ft.Dropdown(label="デプロイ方法",
            value=saved_method,
            options=[ft.DropdownOption(m) for m in ["Cloudflare Pages（推奨・無料）","SSH (rsync)","FTP / FTPS"]],
            border_color=theme["border"],focused_border_color=theme["accent"],
            bgcolor=theme["surface"],text_style=ft.TextStyle(color=theme["text"],size=13),
            label_style=ft.TextStyle(color=theme["text2"],size=12),border_radius=8,
            on_select=_switch_method)
        deploy_content.controls.append(method_panels.get(saved_method,cf_view))
        if "Cloudflare" not in saved_method:
            deploy_content.controls.append(bk_section)

        # ── digiKam 設定セクション ──
        _global_cfg = load_json(CONFIG_FILE, {})
        dk_db_field = _field("digiKam DB パス", _global_cfg.get("digikam_db_path", ""),
                             "例: /home/user/Pictures/digikam4.db")
        dk_status = ft.Text("", size=11, color=theme["text2"])
        # 現在の状態を表示
        _dk_found = dkb.find_digikam_db(_global_cfg.get("digikam_db_path", ""))
        if _dk_found and dkb.is_valid_db(_dk_found):
            _dk_stats = dkb.get_db_stats(_dk_found)
            dk_status.value = f"接続済み: {_dk_stats['images']}枚, {_dk_stats['albums']}アルバム, {_dk_stats['tags']}タグ"
            dk_status.color = theme["accent"]
        elif _global_cfg.get("digikam_db_path"):
            dk_status.value = "DB が見つからないか無効です"
            dk_status.color = "#e57373"
        else:
            # 自動検出を試みる
            _auto_dk = dkb.find_digikam_db()
            if _auto_dk:
                dk_db_field.value = str(_auto_dk)
                dk_status.value = "自動検出されました（保存ボタンで確定）"

        def _save_dk(e):
            gc = load_json(CONFIG_FILE, {})
            p = dk_db_field.value.strip()
            found = dkb.find_digikam_db(p)
            if found and dkb.is_valid_db(found):
                gc["digikam_db_path"] = str(found)
                save_json(CONFIG_FILE, gc)
                st = dkb.get_db_stats(found)
                dk_status.value = f"接続済み: {st['images']}枚, {st['albums']}アルバム, {st['tags']}タグ"
                dk_status.color = theme["accent"]
            elif p:
                dk_status.value = "有効な digiKam DB が見つかりません"
                dk_status.color = "#e57373"
            else:
                gc.pop("digikam_db_path", None)
                save_json(CONFIG_FILE, gc)
                dk_status.value = "未設定"
                dk_status.color = theme["text2"]
            page.update()

        dk_section = ft.Container(content=ft.Column([
            ft.Divider(color=theme["border"]),
            ft.Row([ft.Icon(ft.Icons.PHOTO_LIBRARY, color=theme["accent"], size=20),
                    ft.Text("digiKam 連携", size=13, weight=ft.FontWeight.W_600, color=theme["text"])], spacing=6),
            ft.Text("画像フィールドで digiKam ボタンから写真を選択できます。\n"
                     "digiKam のデータベースファイル（digikam4.db）のパスを指定してください。",
                     size=12, color=theme["text2"]),
            ft.Row([dk_db_field,
                    ft.Button(content=ft.Text("保存"), bgcolor=theme["accent"], color="white",
                              height=36, on_click=_save_dk)], spacing=8),
            dk_status,
        ], spacing=6), padding=ft.Padding.only(top=8))

        # ── QRコード生成セクション ──
        qr_preview = ft.Column(spacing=8)
        qr_status = ft.Text("", size=11, color=theme["text2"])

        def _generate_qr(e):
            site_url = data.get("site", {}).get("url", "").strip()
            if not site_url:
                qr_status.value = "サイトURLが未設定です（データタブで設定してください）"
                qr_status.color = "#e57373"
                page.update()
                return
            qr_status.value = "生成中..."
            qr_status.color = theme["text2"]
            page.update()

            site_name = data.get("site", {}).get("name", "")
            results = generate_qr_codes(output_dir, site_url, site_name)

            qr_preview.controls.clear()
            if not results:
                qr_status.value = "qrcode ライブラリが必要です: pip install qrcode"
                qr_status.color = "#e57373"
                page.update()
                return

            # プレビューカードを作成
            for fpath, label in results:
                is_svg = fpath.suffix == ".svg"
                card_content = [
                    ft.Text(label, size=12, weight=ft.FontWeight.W_600, color=theme["text"]),
                ]
                if not is_svg:
                    card_content.append(
                        ft.Image(src=str(fpath), width=120, height=120,
                                 fit=ft.BoxFit.CONTAIN, border_radius=4))
                else:
                    card_content.append(
                        ft.Container(
                            content=ft.Text("SVG", size=20, weight=ft.FontWeight.W_700,
                                            color=theme["text2"]),
                            width=120, height=120, bgcolor=theme["dark"],
                            border_radius=4, alignment=ft.Alignment.CENTER,
                            border=ft.Border.all(1, theme["border"])))
                card_content.append(
                    ft.Text(fpath.name, size=10, color=theme["text2"]))

                qr_preview.controls.append(ft.Container(
                    content=ft.Column(card_content, spacing=4,
                                      horizontal_alignment=ft.CrossAxisAlignment.CENTER),
                    bgcolor=theme["dark"], border_radius=8, padding=ft.Padding.all(12),
                    border=ft.Border.all(1, theme["border"]), width=160))

            qr_dir = output_dir / "qr"
            qr_status.value = f"{len(results)}個のQRコードを生成しました → {qr_dir}"
            qr_status.color = theme["accent"]
            add_log(f"QRコード生成: {site_url} → {len(results)}ファイル", theme["green"])
            page.update()

        def _open_qr_folder(e):
            qr_dir = output_dir / "qr"
            if qr_dir.exists():
                import subprocess, sys
                if sys.platform == "darwin":
                    subprocess.Popen(["open", str(qr_dir)])
                elif sys.platform == "win32":
                    subprocess.Popen(["explorer", str(qr_dir)])
                else:
                    subprocess.Popen(["xdg-open", str(qr_dir)])
            else:
                qr_status.value = "先にQRコードを生成してください"
                qr_status.color = "#e57373"
                page.update()

        # 既存のQRコードがあればプレビュー表示
        _qr_dir = output_dir / "qr"
        if _qr_dir.exists():
            _existing = sorted(_qr_dir.glob("qr-*"))
            if _existing:
                _labels = {"product": "商品ラベル用（小）", "price": "値札用（中）",
                           "flyer": "チラシ用（大）", "poster": "ポスター用（特大）",
                           "print": "印刷用SVG（任意サイズに拡大可）"}
                for fp in _existing:
                    key = fp.stem.replace("qr-", "")
                    label = _labels.get(key, fp.name)
                    is_svg = fp.suffix == ".svg"
                    card_items = [ft.Text(label, size=12, weight=ft.FontWeight.W_600, color=theme["text"])]
                    if not is_svg:
                        card_items.append(
                            ft.Image(src=str(fp), width=120, height=120,
                                     fit=ft.BoxFit.CONTAIN, border_radius=4))
                    else:
                        card_items.append(
                            ft.Container(
                                content=ft.Text("SVG", size=20, weight=ft.FontWeight.W_700,
                                                color=theme["text2"]),
                                width=120, height=120, bgcolor=theme["dark"],
                                border_radius=4, alignment=ft.Alignment.CENTER,
                                border=ft.Border.all(1, theme["border"])))
                    card_items.append(ft.Text(fp.name, size=10, color=theme["text2"]))
                    qr_preview.controls.append(ft.Container(
                        content=ft.Column(card_items, spacing=4,
                                          horizontal_alignment=ft.CrossAxisAlignment.CENTER),
                        bgcolor=theme["dark"], border_radius=8, padding=ft.Padding.all(12),
                        border=ft.Border.all(1, theme["border"]), width=160))
                qr_status.value = f"生成済み（{len(_existing)}ファイル）"
                qr_status.color = theme["accent"]

        qr_section = ft.Container(content=ft.Column([
            ft.Divider(color=theme["border"]),
            ft.Row([ft.Icon(ft.Icons.QR_CODE, color=theme["accent"], size=20),
                    ft.Text("QRコード生成", size=13, weight=ft.FontWeight.W_600, color=theme["text"])], spacing=6),
            ft.Text("サイトURLのQRコードを生成します。\n"
                     "商品ラベル・値札・チラシ・ポスターなど用途別のサイズで出力します。",
                     size=12, color=theme["text2"]),
            ft.Row([
                ft.Button(content=ft.Text("QRコード生成"), bgcolor=theme["accent"],
                          color="white", height=36, on_click=_generate_qr),
                ft.Button(content=ft.Text("フォルダを開く"), bgcolor=theme["surface"],
                          color=theme["text"], height=36, on_click=_open_qr_folder),
            ], spacing=8),
            qr_status,
            ft.Row(controls=[qr_preview], scroll=ft.ScrollMode.AUTO),
        ], spacing=6), padding=ft.Padding.only(top=8))

        # ── aiseed ハブ連携セクション ──
        hub_enable = ft.Checkbox(
            label="aiseed アプリでサイトを紹介してもらう",
            value=proj_config.get("hub_sync_enabled", False),
            check_color="white", active_color=theme["accent"],
            label_style=ft.TextStyle(color=theme["text"], size=13))
        hub_url_field = _field("ハブURL", proj_config.get("hub_url", "https://hub.aiseed.dev"),
                               "aiseed ハブサーバーのURL")
        hub_token_field = ft.TextField(
            label="サイトトークン", value=proj_config.get("hub_site_token", ""),
            hint_text="ハブ管理画面で発行されたトークンを貼り付け",
            password=True, can_reveal_password=True,
            border_color=theme["border"], focused_border_color=theme["accent"],
            bgcolor=theme["surface"], text_style=ft.TextStyle(color=theme["text"], size=13),
            label_style=ft.TextStyle(color=theme["text2"], size=12), border_radius=8,
            content_padding=ft.Padding.symmetric(horizontal=12, vertical=10))
        hub_status = ft.Text("", size=11, color=theme["text2"])
        hub_detail = ft.Column(spacing=8)

        def _toggle_hub(e):
            hub_detail.controls.clear()
            if hub_enable.value:
                hub_detail.controls.extend([hub_url_field, hub_token_field])
            page.update()

        hub_enable.on_change = _toggle_hub
        if hub_enable.value:
            hub_detail.controls.extend([hub_url_field, hub_token_field])

        def _save_hub(e):
            pc = load_json(proj_dir / "config.json", {})
            pc["hub_sync_enabled"] = hub_enable.value
            pc["hub_url"] = hub_url_field.value.strip()
            pc["hub_site_token"] = hub_token_field.value.strip()
            save_json(proj_dir / "config.json", pc)
            if hub_enable.value:
                hub_status.value = "保存しました。デプロイ時に aiseed へ情報が送られます。"
                hub_status.color = theme["accent"]
            else:
                hub_status.value = "紹介を停止しました"
                hub_status.color = theme["text2"]
            page.update()

        def _test_hub(e):
            hub_url = hub_url_field.value.strip()
            token = hub_token_field.value.strip()
            if not hub_url or not token:
                hub_status.value = "ハブURLとサイトトークンを入力してください"
                hub_status.color = "#e57373"
                page.update()
                return
            hub_status.value = "接続テスト中..."
            hub_status.color = theme["text2"]
            page.update()
            def _t():
                try:
                    r = requests.get(f"{hub_url.rstrip('/')}/api/v1/ping",
                                     headers={"Authorization": f"Bearer {token}"},
                                     timeout=10)
                    if r.ok:
                        hub_status.value = "接続OK"
                        hub_status.color = theme["green"]
                    else:
                        hub_status.value = f"接続エラー: {r.status_code}"
                        hub_status.color = "#e57373"
                except Exception as ex:
                    hub_status.value = f"接続エラー: {ex}"
                    hub_status.color = "#e57373"
                page.update()
            threading.Thread(target=_t, daemon=True).start()

        hub_section = ft.Container(content=ft.Column([
            ft.Divider(color=theme["border"]),
            ft.Row([ft.Icon(ft.Icons.STOREFRONT, color=theme["accent"], size=20),
                    ft.Text("aiseed で紹介", size=13, weight=ft.FontWeight.W_600,
                            color=theme["text"])], spacing=6),
            ft.Text("aiseed アプリであなたのサイトを紹介できます。\n"
                     "イベントや新着情報が aiseed の地域ページに掲載され、\n"
                     "お客さんがあなたのサイトを見つけやすくなります。",
                     size=12, color=theme["text2"]),
            ft.Container(content=ft.Column([
                ft.Text("紹介される情報:", size=11, weight=ft.FontWeight.W_600, color=theme["text"]),
                ft.Text("・イベント（いちご狩り体験、直売会 など）\n"
                         "・ブログ記事の新着情報\n"
                         "・お店・農園の基本情報",
                         size=11, color=theme["text2"]),
                ft.Text("※ いつでもやめられます。パスワード等は送信されません。",
                         size=11, color=theme["text2"], italic=True),
            ], spacing=4), bgcolor=theme["dark"], border_radius=8,
                padding=ft.Padding.all(12), border=ft.Border.all(1, theme["border"])),
            hub_enable,
            hub_detail,
            ft.Row([
                ft.Button(content=ft.Text("保存"), bgcolor=theme["accent"], color="white",
                          height=36, on_click=_save_hub),
                ft.Button(content=ft.Text("接続テスト"), bgcolor=theme["surface"],
                          color=theme["text"], height=36, on_click=_test_hub),
            ], spacing=8),
            hub_status,
        ], spacing=6), padding=ft.Padding.only(top=8))

        tab_deploy=ft.Container(content=ft.Column([
            ft.Container(content=ft.Column([
                ft.Row([ft.Icon(icon=ft.Icons.CLOUD_UPLOAD,color=theme["accent"],size=28),
                    ft.Text("サイトを公開する",size=18,weight=ft.FontWeight.W_700,color=theme["text"])],spacing=10),
                ft.Divider(color=theme["border"]),
                deploy_method,
                ft.Container(height=4),
                deploy_content,
                ft.Container(height=8),
                ft.Row([ft.Button(content=ft.Text("デプロイ"),bgcolor=theme["accent"],color="white",height=44,width=160,on_click=deploy),
                    ft.Button(content=ft.Text("HTMLを開く"),bgcolor=theme["surface"],color=theme["text"],height=44,
                        on_click=lambda e:webbrowser.open(f"http://localhost:8080") if site_file.exists() else None)],spacing=12),
                ft.Container(height=8),d_result,
                hub_section,
                qr_section,
                dk_section,
            ],spacing=10),bgcolor=theme["surface"],border_radius=12,padding=ft.Padding.all(24),
                border=ft.Border.all(1,theme["border"]),width=600),
        ],horizontal_alignment=ft.CrossAxisAlignment.CENTER,scroll=ft.ScrollMode.AUTO),expand=True,padding=ft.Padding.all(20))

        # ── 管理タブ ──
        tab_admin=build_admin_tab(page,theme,proj_dir,data,add_log)

        # ── Tabs ──
        tab_bar=ft.TabBar(
            tabs=[ft.Tab(label="📋 データ"),ft.Tab(label="⚡ ビルド"),ft.Tab(label="☁️ デプロイ"),ft.Tab(label="📊 管理")],
            label_color=theme["accent"],unselected_label_color=theme["text2"],
            indicator_color=theme["accent"],divider_color=theme["border"],
            label_padding=ft.Padding.symmetric(horizontal=16,vertical=8),
            label_text_style=ft.TextStyle(size=13,weight=ft.FontWeight.W_600))
        tab_view=ft.TabBarView(controls=[tab_data,tab_build,tab_deploy,tab_admin],expand=True)
        tabs=ft.Tabs(selected_index=initial_tab,animation_duration=200,
            content=ft.Column([tab_bar,tab_view],expand=True),length=4,expand=True)

        header=ft.Container(content=ft.Row([
            ft.Row([
                ft.Container(content=ft.Text(tpl.get("icon","📄"),size=20),width=40,height=40,
                    border_radius=10,bgcolor=theme["accent"],alignment=ft.Alignment.CENTER),
                ft.Column([ft.Text("aiseed web creator",size=14,weight=ft.FontWeight.W_700,color=theme["text"]),
                           ft.Text(proj_dir.name,size=11,color=theme["text2"])],spacing=0),
            ],spacing=10),
            ft.TextButton(content=ft.Text("← プロジェクト一覧"),on_click=lambda e:show_start_screen()),
        ],alignment=ft.MainAxisAlignment.SPACE_BETWEEN),
        bgcolor=theme["mid"],padding=ft.Padding.symmetric(horizontal=20,vertical=12),
        border=ft.Border.only(bottom=ft.BorderSide(1,theme["border"])))

        content_area.controls.clear()
        content_area.controls.append(ft.Column([header,tabs],expand=True,spacing=0))
        page.update()

    # ━━━ 初回セットアップウィザード ━━━
    def show_setup_wizard():
        default_path = str(default_projects_dir())
        path_label = ft.Text(default_path, size=13, color=C("text"), selectable=True)
        wizard_dir = {"ref": default_path}

        async def _browse_wizard(e):
            path = await ft.FilePicker().get_directory_path(
                dialog_title="プロジェクト保存先を選択",
                initial_directory=str(Path.home()))
            if path:
                wizard_dir["ref"] = path
                path_label.value = path
                page.update()

        def _finish(e):
            p = wizard_dir["ref"]
            if not p: return
            _change_projects_dir(p)
            show_start_screen()

        content_area.controls.clear()
        content_area.controls.append(ft.Container(
            content=ft.Column([
                ft.Container(height=60),
                ft.Text("aiseed web creator", size=28, weight=ft.FontWeight.W_700,
                         color=C("text"), text_align=ft.TextAlign.CENTER),
                ft.Container(height=8),
                ft.Text("初回セットアップ", size=18, weight=ft.FontWeight.W_600,
                         color=C("text"), text_align=ft.TextAlign.CENTER),
                ft.Container(height=16),
                ft.Text("生成したWebサイトの保存先を選んでください。\n"
                         "このフォルダをGitリポジトリにすれば、GitHubでサイトを管理できます。",
                         size=13, color=C("text2"), text_align=ft.TextAlign.CENTER),
                ft.Container(height=24),
                ft.Container(
                    content=ft.Row([
                        ft.Icon(ft.Icons.FOLDER, color=C("accent"), size=20),
                        path_label,
                    ], spacing=10, expand=True),
                    bgcolor=C("surface"), border_radius=8, padding=ft.Padding.all(14),
                    border=ft.Border.all(1, C("border")),
                ),
                ft.Container(height=8),
                ft.TextButton("フォルダを変更...", on_click=_browse_wizard,
                    style=ft.ButtonStyle(color=C("accent"))),
                ft.Container(height=24),
                ft.Button("始める", icon=ft.Icons.ARROW_FORWARD,
                    bgcolor=C("accent"), color="#fff", height=44,
                    on_click=_finish),
            ], horizontal_alignment=ft.CrossAxisAlignment.CENTER,
               width=500, spacing=0),
            expand=True, padding=ft.Padding.all(40),
            alignment=ft.Alignment.TOP_CENTER,
        ))
        page.update()

    # ── Open Project ──

    # ── Start ──
    page.add(content_area)
    if config.get("projects_dir"):
        show_start_screen()
    else:
        show_setup_wizard()

if __name__ == "__main__":
    ft.run(main)