initial commit for security survey

app.py

@@ -1,52 +1,43 @@
 import chainlit as cl
-from models.chat_state import get_initial_state, add_user_message
-from workflows.chat_workflow import chainlit_app
+from models.chat_state import get_security_survey_initial_state
+from workflows.chat_workflow import survey_chainlit_app
+from security_checklist import security_checklist
+from langchain_core.messages import HumanMessage
 
-# Chainlit message handler
 @cl.on_message
 async def process_user_message(message: cl.Message):
-    """Process user message and generate response"""
-    # Get state from session
+    """ユーザメッセージを処理する"""
     state = cl.user_session.get("state")
     
-    # Add user message to state
-    state = add_user_message(state, message.content)
+    # ユーザ回答をmessagesに追加（HumanMessage型で追加）
+    state['messages'].append(HumanMessage(content=message.content))
     
-    # Generate response
-    state = await chainlit_app.ainvoke(state)
+    # ワークフロー進行 - process_input -> display_question or survey_complete
+    state = await survey_chainlit_app.ainvoke(state)
     
-    # Update state in session
     cl.user_session.set("state", state)
 
 @cl.on_chat_start
 async def start():
-    """
-    This function is called when a new chat starts.
-    Initialize the chat state and store it in the session
-    """  
-    # Initialize state
-    state = get_initial_state()
-    
-    # Store state in session
+    """チャット開始時の処理"""
+    # 初期状態を作成
+    state = get_security_survey_initial_state(security_checklist)
     cl.user_session.set("state", state)
-
-
+    
+    # 最初の質問を表示するためにワークフローを呼び出す
+    await process_user_message(cl.Message(content="セキュリティチェックリスト診断を開始したい"))
 
 @cl.set_chat_profiles
 async def chat_profile():
     return [
         cl.ChatProfile(
-            name="mitre_attck_navigator_layer_writer",
-            markdown_description="MITRE ATT&CK Navigatorのlayerを生成するチャットボットです。",
+            name="security_survey_bot",
+            markdown_description="セキュリティチェックリスト診断を行うチャットボットです。",
             icon="public/icon.jpg",
             starters=[
                 cl.Starter(
-                    label="Lockbitの攻撃シナリオ",
-                    message="Lockbitの攻撃シナリオを生成してください"
-                ),
-                cl.Starter(
-                    label="ランサムウェアギャングが使っているテクニックの頻度",
-                    message="最近のランサムウェアギャングが使っているテクニックと頻度を色の濃さで表現してください"
+                    label="セキュリティチェックリスト診断",
+                    message="セキュリティチェックリスト診断を開始したい"
                 ),
             ]
         )

models/chat_state.py

@@ -2,6 +2,8 @@ from typing import List, Optional, Union, Dict, Any
 from langgraph.graph.message import MessagesState
 from langchain_core.messages import AIMessage, HumanMessage
 from pydantic import BaseModel
+from collections import OrderedDict
+import re
 
 class AttackState(MessagesState, total=False):
     """State for the ATT&CK Navigator workflow"""
@@ -11,6 +13,18 @@ class AttackState(MessagesState, total=False):
     extracted_user_scenario: Optional[str] = None
     extracted_user_layer_operation: Optional[str] = None
 
+class SecuritySurveyState(MessagesState, total=False):
+    """State for the Security Survey workflow"""
+    security_checklist: OrderedDict = None  # 質問リスト
+    current_part: str = None  # 今のパート名
+    current_question_index: int = 0  # 今のパート内の質問番号
+    answers: dict = None  # 回答を格納
+    is_survey_complete: bool = False  # 全質問終了フラグ
+    awaiting_clear_answer: bool = False  # 明確な回答待ちフラグ
+    last_question: str = None  # 直近の質問内容
+    expecting_answer: bool = False  # 回答待ちフラグ
+    is_new_session: bool = True  # 新規セッションフラグ
+
 def get_initial_state() -> AttackState:
     """Get the initial state for the workflow"""
     return AttackState(
@@ -22,6 +36,22 @@ def get_initial_state() -> AttackState:
         extracted_user_layer_operation=None
     )
 
+def get_security_survey_initial_state(security_checklist: OrderedDict) -> SecuritySurveyState:
+    """Get the initial state for the security survey workflow"""
+    first_part = next(iter(security_checklist))
+    return SecuritySurveyState(
+        messages=[],
+        security_checklist=security_checklist,
+        current_part=first_part,
+        current_question_index=0,
+        answers={part: {} for part in security_checklist},
+        is_survey_complete=False,
+        awaiting_clear_answer=False,
+        last_question=None,
+        expecting_answer=False,
+        is_new_session=True
+    )
+
 def add_user_message(state: AttackState, content: str) -> AttackState:
     """Add a user message to the state"""
     state['messages'].append(HumanMessage(content=content))
@@ -45,4 +75,100 @@ def set_scenario(state: AttackState, scenario: str) -> AttackState:
 def set_valid_context(state: AttackState, is_valid: bool) -> AttackState:
     """Set the context validity in the state"""
     state['is_valid_context'] = is_valid
-    return state 
+    return state
+
+def evaluate_answer(answer: str) -> Optional[bool]:
+    """ユーザの回答からTrue/Falseを判定する。判断できない場合はNoneを返す"""
+    positive_patterns = [
+        r'(はい|イエス|yes|hai|true|正しい|実施|行[っな]て|対策済み|している|いる|やっている|やってる|対応している|対策している|やっております|している)',
+        r'導入しています',
+        r'設定しています',
+        r'確認しています',
+        r'実施しています'
+    ]
+    
+    negative_patterns = [
+        r'(いいえ|ノー|no|iie|false|違う|違います|してない|していない|いない|やっていない|対応していない|対策していない|行[っな]ていない)',
+        r'導入していません',
+        r'設定していません',
+        r'確認していません',
+        r'実施していません'
+    ]
+    
+    answer = answer.lower()
+    
+    for pattern in positive_patterns:
+        if re.search(pattern, answer):
+            return True
+            
+    for pattern in negative_patterns:
+        if re.search(pattern, answer):
+            return False
+            
+    return None  # 判断できない場合
+
+def process_answer(state: SecuritySurveyState, answer: str) -> SecuritySurveyState:
+    """ユーザの回答を処理する"""
+    if not state.get('expecting_answer', False):
+        # 回答待ちでなければ何もしない
+        return state
+    
+    part = state['current_part']
+    idx = state['current_question_index']
+    questions = list(state['security_checklist'][part].keys())
+    question = questions[idx]
+    
+    # 回答を評価
+    answer_value = evaluate_answer(answer)
+    
+    if answer_value is None:
+        # 曖昧な回答の場合
+        state['awaiting_clear_answer'] = True
+    else:
+        # 明確な回答の場合
+        state['awaiting_clear_answer'] = False
+        state['answers'][part][question] = answer_value
+        
+        # 次の質問インデックスを設定
+        if idx + 1 < len(questions):
+            state['current_question_index'] += 1
+        else:
+            # 次のパートへ
+            parts = list(state['security_checklist'].keys())
+            current_part_idx = parts.index(part)
+            if current_part_idx + 1 < len(parts):
+                state['current_part'] = parts[current_part_idx + 1]
+                state['current_question_index'] = 0
+            else:
+                # 全て終了
+                state['is_survey_complete'] = True
+    
+    # 回答待ちフラグをオフ
+    state['expecting_answer'] = False
+    return state
+
+def get_next_question(state: SecuritySurveyState) -> Optional[str]:
+    """次の質問を取得する。全て終了している場合はNoneを返す"""
+    if state['is_survey_complete']:
+        return None
+        
+    part = state['current_part']
+    idx = state['current_question_index']
+    questions = list(state['security_checklist'][part].keys())
+    question_text = questions[idx]
+    
+    # 明確な回答が必要な場合は追加メッセージをつける
+    if state.get('awaiting_clear_answer', False):
+        full_question = f"【{part}】\n{question_text}\n\n※「はい」か「いいえ」ではっきりお答えください"
+    else:
+        full_question = f"【{part}】\n{question_text}"
+    
+    # 質問を保存
+    state['last_question'] = full_question
+    state['expecting_answer'] = True
+    
+    return full_question
+
+def has_unanswered_questions(state: SecuritySurveyState) -> bool:
+    """未回答の質問があるかチェック"""
+    return not state['is_survey_complete'] 

security_checklist.py

@@ -0,0 +1,38 @@
+from collections import OrderedDict
+
+# 未回答を示す特殊値
+UNDEFINED = "未回答"
+
+security_checklist = OrderedDict({
+    "Part 1: 基本的対策": OrderedDict({
+        "パソコンやスマホなど情報機器のOSやソフトウェアは常に最新の状態にしていますか？": UNDEFINED,
+        "パソコンやスマホなどにはウイルス対策ソフトを導入し、ウイルス定義ファイルは最新の状態にしていますか？": UNDEFINED,
+        "パスワードは破られにくい「長く」「複雑な」パスワードを設定していますか？": UNDEFINED,
+        "重要情報に対する適切なアクセス制限を行っていますか？": UNDEFINED
+    }),
+    "Part 2: 従業員としての対策": OrderedDict({
+        "新たな脅威や攻撃の手口を知り対策を社内共有する仕組みはできていますか？": UNDEFINED,
+        "電子メールの添付ファイルや本文中のURLリンクを介したウイルス感染に気をつけていますか？": UNDEFINED,
+        "電子メールやFAXの宛先の送信ミスを防ぐ取り組みを実施していますか？": UNDEFINED,
+        "重要情報は電子メール本文に書くのではなく、添付するファイルに書いてパスワードなどで保護していますか？": UNDEFINED,
+        "無線LANを安全に使うために適切な暗号化方式を設定するなどの対策をしていますか？": UNDEFINED,
+        "インターネットを介したウイルス感染やSNSへの書き込みなどのトラブルへの対策をしていますか？": UNDEFINED,
+        "パソコンやサーバーのウイルス感染、故障や誤操作による重要情報の消失に備えてバックアップを取得していますか？": UNDEFINED,
+        "紛失や盗難を防止するため、重要情報が記載された書類や電子媒体は机上に放置せず、書庫などに安全に保管していますか？": UNDEFINED,
+        "重要情報が記載された書類や電子媒体を持ち出す時に、盗難や紛失の対策をしていますか？": UNDEFINED,
+        "離席時にパソコン画面の見えや勝手に操作できないようにしていますか？": UNDEFINED,
+        "関係者以外の事務所への立ち入りを制限していますか？": UNDEFINED,
+        "退社時にノートパソコンや備品を施錠保管するなど盗難防止対策をしていますか？": UNDEFINED,
+        "事務所が無人になる時の施錠対策を実施していますか？": UNDEFINED,
+        "不要になった重要書類や重要データは、復元できないようにして破棄していますか？": UNDEFINED,
+        "従業員に守秘義務を課しており、業務上知り得た情報を外部に漏らさないなどのルールを守らせていますか？": UNDEFINED,
+        "従業員にセキュリティに関する教育や注意喚起を行っていますか？": UNDEFINED
+    }),
+    "Part 3: 組織としての対策": OrderedDict({
+        "個人所有の情報機器を業務で利用する場合のセキュリティ対策を明確にしていますか？": UNDEFINED,
+        "重要情報の授受を行う取引先との契約書に、秘密保持条件を規定していますか？": UNDEFINED,
+        "クラウドサービスやアウトソーシング先の選定において、安全・信頼性を把握して選定していますか？": UNDEFINED,
+        "セキュリティ事象が発生した場合に備え、緊急時の体制整備や対応手順を作成するなど準備をしていますか？": UNDEFINED,
+        "情報セキュリティ対策（上記1〜24など）をルール化し、従業員に明示していますか？": UNDEFINED
+    })
+}) 

workflows/chat_workflow.py

@@ -1,378 +1,101 @@
 from langgraph.graph import StateGraph, START, END
-from langgraph.graph.message import MessagesState
-from langchain_core.messages import AIMessage, HumanMessage, SystemMessage
-from services.llm_service import LLMService
-from services.file_service import save_response, create_file_element
-from models.chat_state import AttackState, get_initial_state
+from models.chat_state import SecuritySurveyState, process_answer, get_next_question, has_unanswered_questions
+from security_checklist import security_checklist, UNDEFINED
 import chainlit as cl
 import json
-import logging
-import os
-from urllib.parse import quote
-# Initialize services
-llm_service = LLMService()
-logger = logging.getLogger(__name__)
 
-CHAINLIT_URL = os.environ.get("SPACE_HOST")
-if not CHAINLIT_URL:
-    CHAINLIT_URL = "http://localhost:8080"
-if not CHAINLIT_URL.startswith("https://"):
-    CHAINLIT_URL = "https://" + CHAINLIT_URL
-    
-@cl.step(name="コンテキスト評価", type="evaluation")
-async def evaluate_context_node(state: AttackState) -> AttackState:
-    """Node for evaluating if the user input is valid for ATT&CK context"""
-    msg = cl.Message(content="")
-    
-    # Get the last user message
-    user_messages = [msg for msg in state['messages'] if isinstance(msg, HumanMessage)]
-    user_message = user_messages[-1].content if user_messages else ""
-    
-    try:
-        evaluation_result = await llm_service.evaluate_context(user_message)
-        state['is_valid_context'] = evaluation_result.is_valid
-        state['extracted_user_scenario'] = evaluation_result.extracted_scenario
-        state['extracted_user_layer_operation'] = evaluation_result.extracted_layer_operation
-        
-        if state['is_valid_context']:
-            response_text = "入力はATT&CKフレームワークのコンテキストに合致します。シナリオの評価を続けます。"
-        else:
-            response_text = "申し訳ありませんが、この入力はサイバー攻撃の分析やATT&CKフレームワークのレイヤーに関する指示として認識できませんでした。適切な指示を入力してください。"
-        
-        await msg.stream_token(response_text)
-        await msg.send()
-        state['messages'].append(AIMessage(content=response_text))
-        
-    except Exception as e:
-        error_msg = f"コンテキスト評価中にエラーが発生しました: {str(e)}"
-        await msg.stream_token(error_msg)
-        await msg.send()
-        state['messages'].append(AIMessage(content=error_msg))
-        state['is_valid_context'] = False
-    
+@cl.step(name="ユーザ入力処理", type="input_processing")
+async def process_input_node(state: SecuritySurveyState) -> SecuritySurveyState:
+    """ユーザの入力を処理するノード。新規セッションか回答かを判断する"""
+    # 新規セッションの場合は何もしない
+    if state.get('is_new_session', True):
+        state['is_new_session'] = False
+        return state
+    
+    # ユーザの最後のメッセージを取得
+    user_messages = [msg for msg in state['messages'] if msg.type == 'human']
+    if not user_messages:
+        return state
+    
+    answer = user_messages[-1].content
+    # 回答を処理
+    state = process_answer(state, answer)
     return state
 
-@cl.step(name="シナリオ更新", type="update")
-async def update_scenario_node(state: AttackState) -> AttackState:
-    """Node for updating the scenario based on user input"""
-    msg = cl.Message(content="")
-    
-    # Get the last user message
-    user_message = state.get('extracted_user_scenario', None)
-    current_scenario = state.get('scenario', None)
-    if not user_message and not current_scenario:
-        raise ValueError("シナリオの更新に必要な情報がありません。")
-        
-    try:
-        updated_scenario = await llm_service.generate_scenario(user_message, current_scenario)
-        state['scenario'] = updated_scenario
-        
-        message = "新しいシナリオを作成しました。" if not current_scenario else "シナリオを更新しました。"
-        await msg.stream_token(message)
-        await msg.send()
-        state['messages'].append(AIMessage(content=message))
-        
-    except Exception as e:
-        error_msg = f"シナリオの{'作成' if not current_scenario else '更新'}中にエラーが発生しました: {str(e)}"
-        await msg.stream_token(error_msg)
+@cl.step(name="質問表示", type="question_display")
+async def display_question_node(state: SecuritySurveyState) -> SecuritySurveyState:
+    """質問を表示するノード"""
+    question = get_next_question(state)
+    if question:
+        msg = cl.Message(content=question)
         await msg.send()
-        state['messages'].append(AIMessage(content=error_msg))
-    
     return state
 
-@cl.step(name="JSON生成/更新", type="generation", language="json")
-async def generate_json_node(state: AttackState) -> AttackState:
-    """Node for generating or updating ATT&CK Navigator JSON"""
-    user_message = state.get('extracted_user_layer_operation')
-    current_scenario = state.get('scenario')
-    existing_json = state.get('attack_json')
-    
-    try:
-        json_content = await llm_service.generate_attack_json(user_message, current_scenario, existing_json)
-        
-        # Save JSON to file
-        filename, filepath = save_response(json_content)
-        file_element = create_file_element(filename, filepath)
-        
-        json_url = CHAINLIT_URL + "/" + filepath
-        json_url = quote(json_url)
-
-        # Prepare and send the response message
-        response = "MITRE ATT&CK Navigatorレイヤーを更新しました。" if existing_json else "MITRE ATT&CK Navigatorレイヤーを生成しました。"
-        response += " ファイルをダウンロードしてインポートできます。"
-        response += f"ATT&CK Navigator : https://mitre-attack.github.io/attack-navigator//#layerURL={json_url}"
-        
-        msg = cl.Message(content=response, elements=[file_element])
-        await msg.send()
-        
-        # Update state
-        state['messages'].append(AIMessage(content=response))
-        state['attack_json'] = json.loads(json_content)
-        
-    except Exception as e:
-        error_msg = f"ATT&CK Navigatorレイヤーの生成中にエラーが発生しました: {str(e)}"
-        msg = cl.Message(content=error_msg)
-        await msg.send()
-        state['messages'].append(AIMessage(content=error_msg))
-    
-    return state
-
-async def display_state_node(state: AttackState) -> AttackState:
-    """Node for displaying the current state before ending"""
-    async with cl.Step(name="状態表示", type="display") as step:
-        # コンテキストの評価結果
-        if state.get('is_valid_context') is not None:
-            status = "有効" if state['is_valid_context'] else "無効"
-            step.input = "コンテキスト評価"
-            step.output = f"コンテキストの評価結果: {status}"
-        
-        # 現在のシナリオ
-        if state.get('scenario'):
-            async with cl.Step(name="シナリオ情報", type="display") as scenario_step:
-                scenario_step.input = "現在のシナリオ"
-                scenario_step.output = state['scenario']
-        
-        # JSONの状態
-        if state.get('attack_json'):
-            async with cl.Step(name="ATT&CK情報", type="display") as attack_step:
-                techniques = state['attack_json'].get('techniques', [])
-                technique_count = len(techniques)
-                attack_step.input = "登録済みテクニック"
-                
-                if technique_count > 0:
-                    technique_list = "\n".join([
-                        f"- {t.get('techniqueID', 'Unknown')}: {t.get('comment', '説明なし')}"
-                        for t in techniques[:5]
-                    ])
-                    if technique_count > 5:
-                        technique_list += f"\n... 他 {technique_count - 5} 件"
-                    attack_step.output = f"登録済みテクニック数: {technique_count}\n\n{technique_list}"
-                else:
-                    attack_step.output = "登録済みテクニックはありません"
-    msg = cl.Message(content="処理が完了しました。")
+@cl.step(name="調査完了", type="survey_complete")
+async def survey_complete_node(state: SecuritySurveyState) -> SecuritySurveyState:
+    """全質問が回答された後の処理を行うノード"""
+    # 回答をより人間が読みやすいフォーマットに変換する
+    formatted_answers = {}
+    for part, questions in state['answers'].items():
+        formatted_answers[part] = {}
+        for question, answer in questions.items():
+            if answer is True:
+                formatted_answers[part][question] = "対応済み"
+            elif answer is False:
+                formatted_answers[part][question] = "未対応"
+            else:
+                formatted_answers[part][question] = "未回答"
+    
+    result_json = json.dumps(formatted_answers, ensure_ascii=False, indent=2)
+    
+    # 結果のサマリーを作成する
+    total_items = 0
+    implemented_items = 0
+    
+    for part, questions in state['answers'].items():
+        for question, answer in questions.items():
+            total_items += 1
+            if answer is True:
+                implemented_items += 1
+    
+    implementation_rate = (implemented_items / total_items) * 100 if total_items > 0 else 0
+    
+    summary = f"セキュリティ対策実施率: {implementation_rate:.1f}% ({implemented_items}/{total_items}項目)"
+    
+    # 結果を返す
+    msg = cl.Message(content=f"セキュリティチェックリストの結果です。\n\n{summary}", author="system")
     await msg.send()
+    msg2 = cl.Message(content=f"```json\n{result_json}\n```", language="json", author="system")
+    await msg2.send()
     return state
 
-# Create the graph
-workflow = StateGraph(AttackState)
+# ワークフローの定義
+survey_workflow = StateGraph(SecuritySurveyState)
 
-# Add nodes
-workflow.add_node("evaluate_context", evaluate_context_node)
-workflow.add_node("update_scenario", update_scenario_node)
-workflow.add_node("generate_json", generate_json_node)
-workflow.add_node("display_state", display_state_node)
+# ノードの追加
+survey_workflow.add_node("process_input", process_input_node)
+survey_workflow.add_node("display_question", display_question_node)
+survey_workflow.add_node("survey_complete", survey_complete_node)
 
-# Add edges
-workflow.add_edge(START, "evaluate_context")
-workflow.add_conditional_edges(
-    "evaluate_context",
-    lambda state: state.get('is_valid_context', False),
+# エッジの追加
+survey_workflow.add_edge(START, "process_input")
+
+# process_input から次のノードへの条件付きエッジ
+survey_workflow.add_conditional_edges(
+    "process_input",
+    # 条件関数: 質問が全て終わったかどうか
+    lambda state: not has_unanswered_questions(state),
     {
-        True: "update_scenario",
-        False: "display_state"
+        True: "survey_complete",   # 全質問完了 → 調査完了
+        False: "display_question"  # まだ質問あり → 質問表示
     }
 )
-workflow.add_edge("update_scenario", "generate_json")
-workflow.add_edge("generate_json", "display_state")
-workflow.add_edge("display_state", END)
-
-# Compile the graph
-chainlit_app = workflow.compile()
-
-async def test_evaluate_context_node(state: AttackState) -> AttackState:
-    """テスト用のコンテキスト評価ノード"""
-    user_messages = [msg for msg in state['messages'] if isinstance(msg, HumanMessage)]
-    user_message = user_messages[-1].content if user_messages else ""
-    
-    try:
-        evaluation_result = await llm_service.evaluate_context(user_message)
-        state['is_valid_context'] = evaluation_result.is_valid
-        state['extracted_user_scenario'] = evaluation_result.extracted_scenario
-        state['extracted_user_layer_operation'] = evaluation_result.extracted_layer_operation
-        response_text = "入力はATT&CKフレームワークのコンテキストに合致します。シナリオの評価を続けます。" if state['is_valid_context'] else "申し訳ありませんが、この入力はサイバー攻撃の分析やATT&CKフレームワークのレイヤーに関する指示として認識できませんでした。適切な指示を入力してください。"
-        state['messages'].append(AIMessage(content=response_text))
-    except Exception as e:
-        error_msg = f"コンテキスト評価中にエラーが発生しました: {str(e)}"
-        state['messages'].append(AIMessage(content=error_msg))
-        state['is_valid_context'] = False
-    
-    return state
-
-async def test_update_scenario_node(state: AttackState) -> AttackState:
-    """テスト用のシナリオ更新ノード"""
-    # Get the last user message
-    user_message = state.get('extracted_user_scenario')
-    current_scenario = state.get('scenario')
-    
-    try:
-        updated_scenario = await llm_service.generate_scenario(user_message, current_scenario)
-        state['scenario'] = updated_scenario
-        message = "新しいシナリオを作成しました。" if not current_scenario else "シナリオを更新しました。"
-        state['messages'].append(AIMessage(content=message))
-    except Exception as e:
-        error_msg = f"シナリオの{'作成' if not current_scenario else '更新'}中にエラーが発生しました: {str(e)}"
-        state['messages'].append(AIMessage(content=error_msg))
-    
-    return state
-
-async def test_generate_json_node(state: AttackState) -> AttackState:
-    """テスト用のJSON生成ノード"""
-    user_message = state.get('extracted_user_layer_operation')
-    current_scenario = state.get('scenario')
-    existing_json = state.get('attack_json')
-    
-    try:
-        json_content = await llm_service.generate_attack_json(user_message, current_scenario, existing_json)
-        response = "MITRE ATT&CK Navigatorレイヤーを更新しました。" if existing_json else "MITRE ATT&CK Navigatorレイヤーを生成しました。"
-        response += " ファイルをダウンロードしてインポートできます。"
-        state['messages'].append(AIMessage(content=response))
-        state['attack_json'] = json.loads(json_content)
-    except Exception as e:
-        error_msg = f"ATT&CK Navigatorレイヤーの生成中にエラーが発生しました: {str(e)}"
-        state['messages'].append(AIMessage(content=error_msg))
-    
-    return state
-
-async def test_display_state_node(state: AttackState) -> AttackState:
-    """テスト用の状態表示ノード"""
-    summary = []
-    
-    if state.get('is_valid_context') is not None:
-        status = "有効" if state['is_valid_context'] else "無効"
-        summary.append(f"コンテキストの評価結果: {status}")
-    
-    if state.get('scenario'):
-        summary.append(f"現在のシナリオ:\n{state['scenario']}")
-    
-    if state.get('attack_json'):
-        techniques = state['attack_json'].get('techniques', [])
-        technique_count = len(techniques)
-        summary.append(f"登録済みテクニック数: {technique_count}")
-        
-        if technique_count > 0:
-            technique_list = "\n".join([
-                f"- {t.get('techniqueID', 'Unknown')}: {t.get('comment', '説明なし')}"
-                for t in techniques[:5]
-            ])
-            if technique_count > 5:
-                technique_list += f"\n... 他 {technique_count - 5} 件"
-            summary.append(f"\n登録済みテクニック:\n{technique_list}")
-    
-    if summary:
-        state_summary = "\n\n".join(summary)
-        state['messages'].append(AIMessage(content=f"現在の状態:\n{state_summary}"))
-    
-    return state
-
-async def main():
-    """テスト用のメイン関数"""
-    try:
-        # 初期状態の作成
-        initial_state = get_initial_state()
-        
-        # テスト用の既存シナリオ
-        existing_scenario = """
-        標的システムへの不正アクセスシナリオ
-
-        概要:
-        攻撃者は、標的のシステムに不正アクセスを試み、機密情報を窃取します。
-
-        攻撃フェーズ:
-        1. 初期アクセス
-           - パスワードスプレー攻撃による認証情報の取得
-           - 有効なアカウントの特定
-
-        2. 実行
-           - 取得した認証情報を使用してシステムにログイン
-           - 不正なコマンドの実行
-
-        3. 権限昇格
-           - 管理者権限の取得
-           - システム設定の変更
 
-        4. 防御回避
-           - ログの削除
-           - 攻撃痕跡の隠蔽
-        """
-        
-        # テスト用の既存JSON
-        existing_json = {
-            "name": "Test Layer",
-            "versions": {
-                "attack": "16.0",
-                "navigator": "4.9.0",
-                "layer": "4.5"
-            },
-            "domain": "enterprise-attack",
-            "description": "Test layer for development",
-            "filters": {
-                "platforms": ["Windows", "Linux", "macOS"]
-            },
-            "gradient": {
-                "colors": ["#ffffff", "#ff6666"],
-                "minValue": 0,
-                "maxValue": 100
-            },
-            "techniques": [
-                {
-                    "techniqueID": "T1110",
-                    "score": 50,
-                    "color": "#ff6666",
-                    "comment": "パスワードスプレー攻撃による認証情報の取得",
-                    "enabled": True
-                },
-                {
-                    "techniqueID": "T1078",
-                    "score": 50,
-                    "color": "#ff6666",
-                    "comment": "有効なアカウントを使用した不正アクセス",
-                    "enabled": True
-                }
-            ]
-        }
-        
-        # 初期状態に既存データを設定
-        initial_state['scenario'] = existing_scenario
-        initial_state['attack_json'] = existing_json
-        
-        # テスト用のユーザーメッセージ
-        test_message = """
-        以下の攻撃シナリオを分析してください：
-        
-        攻撃者は、標的のシステムに不正アクセスを試みます。
-        まず、パスワードスプレー攻撃を実行して、有効なアカウントの認証情報を取得します。
-        取得した認証情報を使用して、システムにログインし、機密情報を窃取します。
-        最後に、攻撃の痕跡を隠蔽するために、ログを削除します。
-        """
-        
-        test_message = "ATTACKのバージョンを16にして、テクニックは青にして。"
+# display_question から次のノードへのエッジ (必ずENDへ)
+survey_workflow.add_edge("display_question", END)
 
-        # ユーザーメッセージを状態に追加
-        initial_state['messages'].append(HumanMessage(content=test_message))
-        
-        # テスト用ワークフローの実行
-        state = await test_evaluate_context_node(initial_state)
-        
-        if state.get('is_valid_context', False):
-            # シナリオ更新
-            state = await test_update_scenario_node(state)
-            
-            # JSON生成
-            state = await test_generate_json_node(state)
-        
-        # 状態表示
-        state = await test_display_state_node(state)
-        
-        # 結果の表示
-        for msg in state['messages']:
-            role = "User" if isinstance(msg, HumanMessage) else "Assistant"
-            print(f"\n{role}:")
-            print(msg.content)
-        
-    except Exception as e:
-        print(f"エラーが発生しました: {str(e)}")
-        raise
+# survey_complete から次のノード��のエッジ (必ずENDへ)
+survey_workflow.add_edge("survey_complete", END)
 
-if __name__ == "__main__":
-    import asyncio
-    asyncio.run(main()) 
+# ワークフローをコンパイル
+survey_chainlit_app = survey_workflow.compile()