archdraw agent및 힌트부분 수정

archdraw agent및 힌트부분 수정

Author: gyur1eek

backend/core/services/wars/agents/chaos/nodes.py

@@ -395,15 +395,27 @@ def regenerate(state: ChaosAgentState) -> ChaosAgentState:
 # ─────────────────────────────────────────────────────────────────────────────
 
 def finalize(state: ChaosAgentState) -> ChaosAgentState:
-    """최종 이벤트 확정"""
+    """최종 이벤트 확정 + required_component 결정 (채점 반영용)"""
     logger.info("[ChaosAgent] ▶ finalize 노드 실행")
 
     event = state.get("raw_event")
     if not event:
         logger.error("[ChaosAgent] 최종 이벤트 없음 → 폴백")
         event = _fallback_by_nodes(state["deployed_nodes"])
 
-    logger.info(f"[ChaosAgent] ✅ 이벤트 확정: {event.get('event_id')} / severity={event.get('severity')}")
+    # ✅ [Agent 행동] required_component 결정
+    # target_components 중 아직 배치 안 된 것 → 플레이어가 추가해야 할 컴포넌트
+    # 이미 다 배치한 경우 → target 중 하나를 그대로 사용 (심화 조건)
+    deployed_set = set(state.get("deployed_nodes", []))
+    targets = event.get("target_components", [])
+    not_deployed = [c for c in targets if c not in deployed_set]
+    required_component = not_deployed[0] if not_deployed else (targets[0] if targets else None)
+    event["required_component"] = required_component
+
+    logger.info(
+        f"[ChaosAgent] ✅ 이벤트 확정: {event.get('event_id')} / "
+        f"severity={event.get('severity')} / required_component={required_component}"
+    )
     return {**state, "final_event": event}
 
 

backend/core/services/wars/agents/coach/nodes.py

@@ -183,11 +183,12 @@ def generate_hint(state: CoachAgentState) -> CoachAgentState:
 
 
 def _generate_direct_hint(situation: str, missing: list, state: CoachAgentState) -> Dict:
-    """룰 기반 직접 힌트"""
+    """룰 기반 직접 힌트 + highlight_component 포함"""
     if situation == "empty":
         return {
             "message": "💡 아직 아무것도 배치하지 않으셨네요. 사용자(Client)부터 시작해보는 건 어떨까요?",
             "missing_components": list(state["mission_required"]),
+            "highlight_component": "client",  # ✅ [Agent 행동] 팔레트 하이라이트 대상
             "type": "general",
             "level": 1,
         }
@@ -203,6 +204,7 @@ def _generate_direct_hint(situation: str, missing: list, state: CoachAgentState)
         return {
             "message": f"💡 {msg}",
             "missing_components": missing,
+            "highlight_component": priority,  # ✅ [Agent 행동] 누락된 컴포넌트 팔레트 하이라이트
             "type": "missing_component",
             "level": 1,
         }
@@ -211,11 +213,12 @@ def _generate_direct_hint(situation: str, missing: list, state: CoachAgentState)
         return {
             "message": "💡 컴포넌트를 모두 배치했네요! 이제 데이터 흐름(화살표)을 연결해보세요.",
             "missing_components": [],
+            "highlight_component": None,
             "type": "no_arrows",
             "level": 1,
         }
 
-    return {"message": "", "missing_components": [], "type": "complete", "level": 0}
+    return {"message": "", "missing_components": [], "highlight_component": None, "type": "complete", "level": 0}
 
 
 def _generate_socratic_hint(state: CoachAgentState, missing: list) -> Dict:
@@ -252,9 +255,17 @@ def _generate_socratic_hint(state: CoachAgentState, missing: list) -> Dict:
         logger.error(f"[CoachAgent] socratic LLM 실패: {e}")
         message = COMPONENT_HINTS.get(priority, f"'{priority}'에 대해 생각해보세요.")
 
+    # 우선순위 컴포넌트 재계산 (highlight용)
+    priority = missing[0] if missing else None
+    for req in state["mission_required"]:
+        if req in missing:
+            priority = req
+            break
+
     return {
         "message": message,
         "missing_components": missing,
+        "highlight_component": priority,  # ✅ [Agent 행동]
         "type": "missing_component",
         "level": 2,
     }
@@ -291,9 +302,16 @@ def _generate_escalate_hint(state: CoachAgentState, missing: list) -> Dict:
         logger.error(f"[CoachAgent] escalate LLM 실패: {e}")
         message = f"🚨 {missing_str} 컴포넌트를 지금 바로 캔버스에 추가하세요. 왼쪽 패널에서 드래그해서 배치할 수 있습니다."
 
+    priority = missing[0] if missing else None
+    for req in state["mission_required"]:
+        if req in missing:
+            priority = req
+            break
+
     return {
         "message": message,
         "missing_components": missing,
+        "highlight_component": priority,  # ✅ [Agent 행동]
         "type": "escalate",
         "level": 3,
     }

backend/core/services/wars/agents/orchestrator/nodes.py

@@ -122,9 +122,34 @@ def observe_game_state(state: OrchestratorState) -> OrchestratorState:
             player_line += f", ⚠️감지된아키이슈={arch_issues}"
         lines.append(player_line)
 
+    # ✅ [Agent 행동] 두 플레이어 비교 분석 — Orchestrator가 게임 밸런싱 판단
+    leading_sid = None
+    trailing_sid = None
+    node_gap = 0
+
+    if len(snapshots) == 2:
+        sids = list(snapshots.keys())
+        n0 = snapshots[sids[0]]['node_count']
+        n1 = snapshots[sids[1]]['node_count']
+        node_gap = abs(n0 - n1)
+
+        if node_gap >= 2:  # 2개 이상 차이 나면 격차 감지
+            leading_sid = sids[0] if n0 > n1 else sids[1]
+            trailing_sid = sids[1] if n0 > n1 else sids[0]
+            lines.append(
+                f"⚠️ 설계 격차 감지: {node_gap}개 차이 — "
+                f"선두={leading_sid[:8]}, 지연={trailing_sid[:8]}"
+            )
+
     summary = "\n".join(lines)
     logger.info(f"[Orchestrator] 상황 요약:\n{summary}")
-    return {**state, "situation_summary": summary}
+    return {
+        **state,
+        "situation_summary": summary,
+        "leading_sid": leading_sid,
+        "trailing_sid": trailing_sid,
+        "node_gap": node_gap,
+    }
 
 
 # ─────────────────────────────────────────────────────────────────────────────
@@ -200,6 +225,19 @@ def _llm_decide(state: OrchestratorState) -> List[Dict[str, Any]]:
             "arch_issues_detected": arch_issues,
         })
 
+    # ✅ 격차 정보 추출
+    leading_sid = state.get('leading_sid')
+    trailing_sid = state.get('trailing_sid')
+    node_gap = state.get('node_gap', 0)
+    gap_context = ""
+    if leading_sid and trailing_sid:
+        gap_context = f"""
+[실시간 격차 감지]
+{leading_sid[:8]}가 {trailing_sid[:8]}보다 {node_gap}개 앞서있습니다.
+→ 뒤캘지는 플레이어({trailing_sid[:8]})에게 Coach 우선 개입을 고려하세요.
+→ 앞선 플레이어({leading_sid[:8]})에게는 Chaos 발동으로 역전 기회를 부여하는 것을 고려하세요.
+"""
+
     response = _get_client().chat.completions.create(
         model="gpt-4o-mini",
         messages=[
@@ -237,7 +275,7 @@ def _llm_decide(state: OrchestratorState) -> List[Dict[str, Any]]:
 
 [플레이어 상세 데이터]
 {json.dumps(player_info, ensure_ascii=False, indent=2)}
-
+{gap_context}
 [핵심 제약]
 - chaos_triggered: {state.get('chaos_triggered')} → True면 chaos 절대 불가
 - 전체 배치 노드 합계: {total_nodes}개 → {_CHAOS_MIN_NODES}개 미만이면 chaos 불가
@@ -338,15 +376,22 @@ def _rule_based_action_plan(state: OrchestratorState) -> List[Dict[str, Any]]:
     plan = []
 
     if can_trigger_coach(tmp_room, trigger_sid):
+        # ✅ [격차 반영] 뒤쳌지는 플레이어에게 Coach 우선
+        target_coach_sid = state.get('trailing_sid') or trigger_sid
         plan.append({
-            "agent": "coach", "sid": trigger_sid,
-            "reason": "룰 기반: 헤매는 상황 감지"
+            "agent": "coach", "sid": target_coach_sid,
+            "reason": "룰 기반: 헤매는 상황 감지" + (
+                f" (압도적 격차로 인한 Coach 우선)" if state.get('node_gap', 0) >= 2 else ""
+            )
         })
 
     if can_trigger_chaos(tmp_room):
         plan.append({
             "agent": "chaos", "sid": None,
-            "reason": "룰 기반: 설계 시작됨 + chaos 발동 조건 충족"
+            "reason": "룰 기반: 설계 시작됨 + chaos 발동 조건 충족" + (
+                f" (앞선 플레이어 {state.get('leading_sid', '')[:8]}에게 펕디쿥제)"
+                if state.get('node_gap', 0) >= 2 else ""
+            )
         })
 
     if not plan:

backend/core/socket_server.py

@@ -227,6 +227,8 @@ async def draw_start(sid, data):
             p['last_nodes'] = []
             p['last_arrows'] = []
             p['submitted'] = False
+        # ✅ [Agent 행동] Chaos 채점 룰 초기화 (신규 게임 시작)
+        room['chaos_bonus_check'] = None
         # [수정일: 2026-03-03] DB(unit03) 미션 lazy 로드
         missions = await _get_missions()
         if not missions:
@@ -282,8 +284,17 @@ async def run_draw_room_tick(room_id):
                     print(f"⏰ [Poll] Hint pushed to {actual_target[:8]}")
                     await sio.emit('coach_hint', hint_payload, to=actual_target)
                 if res.get('chaos_event'):
+                    chaos_ev = res['chaos_event']
                     print(f"⏰ [Poll] Chaos pushed in Room: {room_id}")
-                    await sio.emit('chaos_event', res['chaos_event'], room=room_id)
+                    # ✅ [Agent 행동] Poll에서 오는 Chaos도 동일하게 게임 룰 수정
+                    req_comp = chaos_ev.get('required_component')
+                    if req_comp and room_id in draw_rooms:
+                        draw_rooms[room_id]['chaos_bonus_check'] = {
+                            'component': req_comp,
+                            'bonus_pts': 20,
+                            'penalty_pts': -10,
+                        }
+                    await sio.emit('chaos_event', chaos_ev, room=room_id)
 
         await asyncio.sleep(8) # 8초마다 체크 (trigger_policy 임계값과 상충되지 않는 주기로 선정)
     print(f"🛑 [ArchDraw] Periodic check stopped for room: {room_id}")
@@ -310,7 +321,18 @@ async def draw_submit(sid, data):
         complete_bonus = 20 if ratio == 1.0 else 0                   # 전부 통과 시 +20점
         combo_bonus = min(data.get('combo', 0), 5) * 2               # 최대 10점 (5콤보 상한)
         pts = check_score + time_bonus + complete_bonus + combo_bonus
-        
+
+        # ✅ [Agent 행동 반영] ChaosAgent가 설정한 게임 룰 체크
+        chaos_check = room.get('chaos_bonus_check')
+        if chaos_check:
+            placed_ids = [n.get('compId') for n in data.get('final_nodes', [])]
+            if chaos_check['component'] in placed_ids:
+                pts += chaos_check['bonus_pts']
+                print(f"✅ [ArchDraw] Chaos 조건 충족: {player['name']} +{chaos_check['bonus_pts']}점 ({chaos_check['component']} 배치 확인)")
+            else:
+                pts += chaos_check['penalty_pts']  # 음수값
+                print(f"❌ [ArchDraw] Chaos 조건 미충족: {player['name']} {chaos_check['penalty_pts']}점 ({chaos_check['component']} 누락)")
+
         player['score'] += pts
         player['last_pts'] = pts
         player['last_checks'] = checks
@@ -439,6 +461,8 @@ async def draw_next_round(sid, data):
             room_state.hint_history = {}
             room_state.past_event_ids = []
             room_state.player_designs = {}
+        # ✅ [Agent 행동] 다음 라운드에서 Chaos 채점 룰 리셋
+        room['chaos_bonus_check'] = None
 
         # 새로운 무작위 문제 선택 + 팔레트 서버 생성
         cur_round = data.get('round', room.get('current_round', 1) + 1)
@@ -487,9 +511,19 @@ async def draw_canvas_sync(sid, data):
             target_sid = res['coach_hint'].get('_target_sid', sid)
             print(f"💡 [ArchDraw] Hint Sent to {target_sid[:8]}: {hint_payload.get('message', '')[:20]}...")
             await sio.emit('coach_hint', hint_payload, to=target_sid)  # [수정일: 2026-03-03] room= → to= (개인 전송)
-        if res.get('chaos_event'): 
-            print(f"🔥 [ArchDraw] Chaos Event in Room: {room_id}")
-            await sio.emit('chaos_event', res['chaos_event'], room=room_id)
+        if res.get('chaos_event'):
+            chaos_ev = res['chaos_event']
+            print(f"🔥 [ArchDraw] Chaos Event in Room: {room_id} | required_component={chaos_ev.get('required_component')}")
+            # ✅ [Agent 행동] Chaos가 게임 룰을 직접 수정 — 채점 시 반영됨
+            req_comp = chaos_ev.get('required_component')
+            if req_comp:
+                draw_rooms[room_id]['chaos_bonus_check'] = {
+                    'component': req_comp,
+                    'bonus_pts': 20,
+                    'penalty_pts': -10,
+                }
+                print(f"📋 [ArchDraw] Chaos 채점 룰 추가: +20 if {req_comp} placed, -10 if not")
+            await sio.emit('chaos_event', chaos_ev, room=room_id)
 
 @sio.event
 async def draw_chaos_complete(sid, data):

frontend/src/features/wars/WarsModeSelect.vue

@@ -259,7 +259,7 @@ const goTo = (path) => router.push(path);
 }
 
 .exit-btn {
-  position: fixed; top: 1.5rem; left: 1.5rem;
+  position: fixed; top: 1.5rem; right: 1.5rem;
   background: rgba(255,255,255,0.04);
   border: 1px solid rgba(255,255,255,0.1);
   color: #94a3b8;

frontend/src/features/wars/composables/useDrawSocket.js

@@ -27,7 +27,7 @@ export function useDrawSocket() {
   const onChaosRecovered = ref(null) // [추가 2026-03-03] 장애 복구 알림
   const onGameOver = ref(null)
 
-  function connect(roomId, userName, userId) {
+  function connect(roomId, userName, userId, avatarUrl) {
     if (socket.value) return
 
     // [수정일: 2026-03-01] 소켓 URL 결정 로직 수정
@@ -50,7 +50,7 @@ export function useDrawSocket() {
     socket.value.on('connect', () => {
       connected.value = true
       // [수정일: 2026-03-03] DB 연동을 위해 user_id 포함하여 전송
-      socket.value.emit('draw_join', { room_id: roomId, user_name: userName, user_id: userId })
+      socket.value.emit('draw_join', { room_id: roomId, user_name: userName, user_id: userId, avatar_url: avatarUrl || '' })
     })
 
     socket.value.on('disconnect', () => { connected.value = false })