TAKTデータフロー図解

このドキュメントでは、TAKTのデータフローをMermaid図で可視化します。

シーケンス図: インタラクティブモードからピース実行まで

sequenceDiagram
    participant User
    participant CLI as CLI Layer
    participant Interactive as Interactive Layer
    participant Orchestration as Execution Orchestration
    participant TaskExec as Task Execution
    participant PieceExec as Piece Execution
    participant Engine as PieceEngine
    participant StepExec as StepExecutor
    participant Provider as Provider Layer

    User->>CLI: takt (短い入力 or 引数なし)
    CLI->>Interactive: interactiveMode(cwd, initialInput?)

    loop 会話ループ
        Interactive->>User: プロンプト表示
        User->>Interactive: メッセージ入力
        Interactive->>Provider: callAI(prompt)
        Provider-->>Interactive: AIレスポンス
        Interactive->>User: AIレスポンス表示
    end

    User->>Interactive: /go コマンド
    Interactive->>Interactive: buildTaskFromHistory()
    Interactive-->>CLI: { confirmed: true, task: string }

    CLI->>Orchestration: selectAndExecuteTask(cwd, task)

    Orchestration->>Orchestration: determinePiece()
    Note over Orchestration: ピース選択<br/>(interactive or override)

    Orchestration->>Orchestration: confirmAndCreateWorktree()
    Orchestration->>Provider: summarizeTaskName(task)
    Provider-->>Orchestration: taskSlug
    Orchestration->>Orchestration: createSharedClone()

    Orchestration->>TaskExec: executeTask(options)
    TaskExec->>TaskExec: loadPieceByIdentifier()
    TaskExec->>PieceExec: executePiece(config, task, cwd)

    PieceExec->>PieceExec: セッション管理初期化
    Note over PieceExec: loadAgentSessions()<br/>generateSessionId()<br/>initNdjsonLog()

    PieceExec->>Engine: new PieceEngine(config, cwd, task, options)
    PieceExec->>Engine: イベント購読 (step:start, step:complete, etc.)
    PieceExec->>Engine: engine.run()

    loop ピースステップ
        Engine->>StepExec: runStep(step)

        StepExec->>StepExec: InstructionBuilder.build()
        Note over StepExec: コンテキスト → インストラクション

        StepExec->>Provider: runAgent(instruction)
        Note over Provider: Phase 1: Main Execution
        Provider-->>StepExec: AgentResponse

        opt step.report 定義あり
            StepExec->>Provider: runReportPhase()
            Note over Provider: Phase 2: Report Output<br/>(Write-only)
        end

        opt tag-based rules あり
            StepExec->>Provider: runStatusJudgmentPhase()
            Note over Provider: Phase 3: Status Judgment<br/>(no tools)
            Provider-->>StepExec: tagContent
        end

        StepExec->>StepExec: detectMatchedRule()
        Note over StepExec: ルール評価<br/>(5段階フォールバック)

        StepExec-->>Engine: { response, instruction }
        Engine->>Engine: resolveNextStep()

        alt nextStep === COMPLETE
            Engine-->>PieceExec: ピース完了
        else nextStep === ABORT
            Engine-->>PieceExec: ピース中断
        else 通常ステップ
            Engine->>Engine: state.currentStep = nextStep
        end
    end

    PieceExec-->>TaskExec: { success: boolean }
    TaskExec-->>Orchestration: taskSuccess

    opt taskSuccess && isWorktree
        Orchestration->>Orchestration: autoCommitAndPush()
        opt autoPr or user confirms
            Orchestration->>Orchestration: createPullRequest()
        end
    end

    Orchestration-->>User: タスク完了

フローチャート: 3フェーズステップ実行

flowchart TD
    Start([ステップ実行開始]) --> BuildInstruction[InstructionBuilder.build]
    BuildInstruction --> Phase1{Phase 1:<br/>Main Execution}

    Phase1 --> ContextBuild[コンテキスト収集]
    ContextBuild --> |7セクション自動注入| AssemblePrompt[プロンプト組み立て]
    AssemblePrompt --> |プレースホルダー置換| CompleteInstruction[完全なインストラクション]

    CompleteInstruction --> RunAgent[runAgent]
    RunAgent --> ProviderCall[provider.call]
    ProviderCall --> |onStream callback| StreamUI[UI表示]
    ProviderCall --> Response1[AgentResponse]

    Response1 --> CheckReport{step.report<br/>定義あり?}
    CheckReport -->|Yes| Phase2[Phase 2:<br/>Report Output]
    CheckReport -->|No| CheckTag{tag-based<br/>rules あり?}

    Phase2 --> ResumeSession1[セッション継続<br/>sessionId同じ]
    ResumeSession1 --> ReportBuilder[ReportInstructionBuilder.build]
    ReportBuilder --> WriteOnly[Write-only tools]
    WriteOnly --> RunReport[runAgent<br/>レポート出力]
    RunReport --> CheckTag

    CheckTag -->|Yes| Phase3[Phase 3:<br/>Status Judgment]
    CheckTag -->|No| RuleEval[detectMatchedRule]

    Phase3 --> ResumeSession2[セッション継続<br/>sessionId同じ]
    ResumeSession2 --> StatusBuilder[StatusJudgmentBuilder.build]
    StatusBuilder --> NoTools[Tools: なし<br/>判断のみ]
    NoTools --> RunStatus[runAgent<br/>ステータス出力]
    RunStatus --> TagContent[tagContent:<br/>STEP:N タグ]

    TagContent --> RuleEval
    RuleEval --> FiveStageFallback[5段階フォールバック]

    FiveStageFallback --> Stage1{1. Aggregate?}
    Stage1 -->|Yes| AllAny[all/any 評価]
    Stage1 -->|No| Stage2{2. Phase 3 tag?}

    AllAny --> Matched[マッチ!]

    Stage2 -->|Yes| Phase3Tag[STEP:N from<br/>status judgment]
    Stage2 -->|No| Stage3{3. Phase 1 tag?}

    Phase3Tag --> Matched

    Stage3 -->|Yes| Phase1Tag[STEP:N from<br/>main output]
    Stage3 -->|No| Stage4{4. AI judge<br/>ai rules?}

    Phase1Tag --> Matched

    Stage4 -->|Yes| AIJudge[AI evaluates<br/>ai conditions]
    Stage4 -->|No| Stage5[5. AI judge<br/>fallback]

    AIJudge --> Matched
    Stage5 --> AIFallback[AI evaluates<br/>all conditions]
    AIFallback --> Matched

    Matched --> UpdateResponse[response.matchedRuleIndex<br/>response.matchedRuleMethod]
    UpdateResponse --> StoreOutput[state.stepOutputs.set]
    StoreOutput --> End([ステップ完了])

    style Phase1 fill:#e1f5ff
    style Phase2 fill:#fff4e6
    style Phase3 fill:#f3e5f5
    style Matched fill:#c8e6c9

フローチャート: ルール評価の5段階フォールバック

flowchart TD
    Start([ルール評価開始]) --> Input[入力:<br/>step, content, tagContent]

    Input --> Stage1{Stage 1:<br/>Aggregate評価<br/>親ステップ?}
    Stage1 -->|Yes| CheckAggregate{rules に<br/>allまたはanyあり?}
    CheckAggregate -->|Yes| EvalAggregate[AggregateEvaluator]
    EvalAggregate --> CheckAggResult{マッチした?}
    CheckAggResult -->|Yes| ReturnAgg[method: aggregate<br/>返却]
    CheckAggResult -->|No| Stage2

    CheckAggregate -->|No| Stage2
    Stage1 -->|No| Stage2{Stage 2:<br/>Phase 3 tag<br/>tagContent に<br/>STEP:N あり?}

    Stage2 -->|Yes| ExtractTag3[正規表現で抽出:<br/>STEP:(\d+)]
    ExtractTag3 --> ValidateIndex3{index が<br/>rules 範囲内?}
    ValidateIndex3 -->|Yes| ReturnTag3[method: phase3_tag<br/>返却]
    ValidateIndex3 -->|No| Stage3

    Stage2 -->|No| Stage3{Stage 3:<br/>Phase 1 tag<br/>content に<br/>STEP:N あり?}

    Stage3 -->|Yes| ExtractTag1[正規表現で抽出:<br/>STEP:(\d+)]
    ExtractTag1 --> ValidateIndex1{index が<br/>rules 範囲内?}
    ValidateIndex1 -->|Yes| ReturnTag1[method: phase1_tag<br/>返却]
    ValidateIndex1 -->|No| Stage4

    Stage3 -->|No| Stage4{Stage 4:<br/>AI judge<br/>ai rules あり?}

    Stage4 -->|Yes| FilterAI[aiルールのみ抽出<br/>ai 関数パース]
    FilterAI --> CallAI[AIJudgeEvaluator<br/>condition を評価]
    CallAI --> CheckAIResult{マッチした?}
    CheckAIResult -->|Yes| ReturnAI[method: ai_judge<br/>返却]
    CheckAIResult -->|No| Stage5

    Stage4 -->|No| Stage5[Stage 5:<br/>AI judge fallback<br/>全条件を評価]

    Stage5 --> AllConditions[全ルール条件を収集]
    AllConditions --> CallAIFallback[AIJudgeEvaluator<br/>全条件を評価]
    CallAIFallback --> CheckFallbackResult{マッチした?}
    CheckFallbackResult -->|Yes| ReturnFallback[method: ai_judge_fallback<br/>返却]
    CheckFallbackResult -->|No| NoMatch[null 返却<br/>マッチなし]

    ReturnAgg --> End([返却:<br/>index, method])
    ReturnTag3 --> End
    ReturnTag1 --> End
    ReturnAI --> End
    ReturnFallback --> End
    NoMatch --> End

    style Stage1 fill:#e3f2fd
    style Stage2 fill:#fff3e0
    style Stage3 fill:#fce4ec
    style Stage4 fill:#f3e5f5
    style Stage5 fill:#e8f5e9
    style End fill:#c8e6c9
    style NoMatch fill:#ffcdd2

ステートマシン図: PieceEngineのステップ遷移

stateDiagram-v2
    [*] --> Initializing: new PieceEngine

    Initializing --> Running: engine.run()
    note right of Initializing
        state = {
          status: 'running',
          currentStep: initialStep,
          iteration: 0,
          ...
        }
    end note

    state Running {
        [*] --> CheckAbort: while loop

        CheckAbort --> CheckIteration: abortRequested?
        CheckAbort --> Aborted: Yes → abort

        CheckIteration --> CheckLoop: iteration < max?
        CheckIteration --> IterationLimit: No → emit iteration:limit

        IterationLimit --> UserDecision: onIterationLimit callback
        UserDecision --> CheckLoop: 追加イテレーション許可
        UserDecision --> Aborted: 拒否

        CheckLoop --> GetStep: loopDetector.check()
        CheckLoop --> Aborted: loop detected

        GetStep --> BuildInstruction: getStep(currentStep)

        BuildInstruction --> EmitStart: InstructionBuilder

        EmitStart --> RunStep: emit step:start

        RunStep --> EmitComplete: runStep(step)
        note right of RunStep
            - Normal: StepExecutor
            - Parallel: ParallelRunner
            3-phase execution
        end note

        EmitComplete --> CheckBlocked: emit step:complete

        CheckBlocked --> HandleBlocked: status === blocked?
        CheckBlocked --> EvaluateRules: No

        HandleBlocked --> UserInput: handleBlocked()
        UserInput --> CheckAbort: ユーザー入力追加
        UserInput --> Aborted: キャンセル

        EvaluateRules --> ResolveNext: detectMatchedRule()

        ResolveNext --> CheckNext: determineNextStepByRules()

        CheckNext --> Completed: nextStep === COMPLETE
        CheckNext --> Aborted: nextStep === ABORT
        CheckNext --> Transition: 通常ステップ

        Transition --> CheckAbort: state.currentStep = nextStep
    }

    Running --> Completed: piece:complete
    Running --> Aborted: piece:abort

    Completed --> [*]: return state
    Aborted --> [*]: return state

    note right of Completed
        state.status = 'completed'
        emit piece:complete
    end note

    note right of Aborted
        state.status = 'aborted'
        emit piece:abort
        原因:
        - User abort (Ctrl+C)
        - Iteration limit
        - Loop detected
        - Blocked without input
        - Step execution error
    end note

データ変換の流れ

flowchart LR
    subgraph Input ["入力"]
        A1[ユーザー入力<br/>CLI引数]
        A2[会話履歴<br/>ConversationMessage]
    end

    subgraph Transform1 ["変換1: タスク化"]
        B1[isDirectTask判定]
        B2[buildTaskFromHistory]
    end

    subgraph Task ["タスク"]
        C[task: string]
    end

    subgraph Transform2 ["変換2: 環境準備"]
        D1[determinePiece]
        D2[summarizeTaskName<br/>AI呼び出し]
        D3[createSharedClone]
    end

    subgraph Execution ["実行環境"]
        E1[pieceIdentifier]
        E2[execCwd, branch]
    end

    subgraph Transform3 ["変換3: 設定読み込み"]
        F1[loadPieceByIdentifier]
        F2[loadAgentSessions]
    end

    subgraph Config ["設定"]
        G1[PieceConfig]
        G2[initialSessions]
    end

    subgraph Transform4 ["変換4: 状態初期化"]
        H[createInitialState]
    end

    subgraph State ["実行状態"]
        I[PieceState]
    end

    subgraph Transform5 ["変換5: インストラクション"]
        J[InstructionBuilder.build]
    end

    subgraph Instruction ["プロンプト"]
        K[instruction: string]
    end

    subgraph Transform6 ["変換6: AI実行"]
        L[provider.call]
    end

    subgraph Response ["応答"]
        M[AgentResponse]
    end

    subgraph Transform7 ["変換7: ルール評価"]
        N[detectMatchedRule]
    end

    subgraph Transition ["遷移"]
        O[nextStep: string]
    end

    A1 --> B1
    A2 --> B2
    B1 --> C
    B2 --> C

    C --> D1
    C --> D2
    D1 --> E1
    D2 --> D3
    D3 --> E2

    E1 --> F1
    E2 --> F2
    F1 --> G1
    F2 --> G2

    G1 --> H
    G2 --> H
    H --> I

    I --> J
    C --> J
    J --> K

    K --> L
    L --> M

    M --> N
    I --> N
    N --> O

    O -.-> I

    style Input fill:#e3f2fd
    style Task fill:#fff3e0
    style Execution fill:#fce4ec
    style Config fill:#f3e5f5
    style State fill:#e8f5e9
    style Instruction fill:#fff9c4
    style Response fill:#f1f8e9
    style Transition fill:#c8e6c9

コンテキスト蓄積の流れ

flowchart TB
    subgraph Initial ["初期入力"]
        A[task: string]
    end

    subgraph Context1 ["コンテキスト1: タスク"]
        B[InstructionContext]
        B1[task]
    end

    subgraph Step1 ["ステップ1実行"]
        C1[Phase 1: Main]
        C2[Phase 2: Report]
        C3[Phase 3: Status]
        C4[AgentResponse]
    end

    subgraph Context2 ["コンテキスト2: +前回応答"]
        D[InstructionContext]
        D1[task]
        D2[previousOutput]
    end

    subgraph Blocked ["Blocked発生"]
        E[handleBlocked]
        E1[ユーザー追加入力]
    end

    subgraph Context3 ["コンテキスト3: +ユーザー入力"]
        F[InstructionContext]
        F1[task]
        F2[previousOutput]
        F3[userInputs]
    end

    subgraph Step2 ["ステップ2実行"]
        G1[Phase 1: Main]
        G2[stepOutputs蓄積]
        G3[AgentResponse]
    end

    subgraph Context4 ["コンテキスト4: 完全"]
        H[InstructionContext]
        H1[task]
        H2[previousOutput]
        H3[userInputs]
        H4[iteration]
        H5[stepIteration]
        H6[reportDir]
        H7[...すべてのメタデータ]
    end

    A --> B1
    B1 --> C1
    C1 --> C2
    C2 --> C3
    C3 --> C4

    C4 --> D2
    B1 --> D1

    D --> E
    E --> E1
    E1 --> F3
    D1 --> F1
    D2 --> F2

    F --> G1
    G1 --> G2
    G2 --> G3

    G3 --> H2
    F1 --> H1
    F3 --> H3
    G2 --> H4
    G2 --> H5
    G2 --> H6

    H -.繰り返し.-> Step2

    style Initial fill:#e3f2fd
    style Context1 fill:#fff3e0
    style Step1 fill:#fce4ec
    style Context2 fill:#fff9c4
    style Blocked fill:#ffcdd2
    style Context3 fill:#f1f8e9
    style Step2 fill:#c8e6c9
    style Context4 fill:#dcedc8

まとめ

これらの図は、TAKTのデータフローを以下の視点から可視化しています:

シーケンス図: 時系列での各レイヤー間のやりとり
3フェーズフローチャート: ステップ実行の詳細な処理フロー
ルール評価フローチャート: 5段階フォールバックの意思決定ロジック
ステートマシン: PieceEngineの状態遷移
データ変換図: 各段階でのデータ形式変換
コンテキスト蓄積図: 実行が進むにつれてコンテキストが蓄積される様子

これらの図を data-flow.md と合わせて参照することで、TAKTのアーキテクチャを多角的に理解できます。

16 KiB Raw Blame History

TAKTデータフロー図解

目次

シーケンス図: インタラクティブモードからピース実行まで

フローチャート: 3フェーズステップ実行

フローチャート: ルール評価の5段階フォールバック

ステートマシン図: PieceEngineのステップ遷移

データ変換の流れ

コンテキスト蓄積の流れ

まとめ

16 KiB

Raw Blame History