KArtSell.Aegis/scripts/phase-2-orchestration.ps1

# Phase 2 Orchestration: Parallel Execution of VS-01 through VS-08
# Trigger: Gate 1 completion (Job 976 PBO/DSR evidence)
# Purpose: Execute 56 vertical slice items in optimal parallel schedule
# Governance: AGENTS.md v16.0 (Complexity, Safety, Traceability)

param(
    [switch]$DryRun = $false,
    [switch]$Sequential = $false,
    [string]$LogPath = "$(Get-Date -Format 'yyyyMMdd_HHmmss')_phase2_execution.log"
)

$ErrorActionPreference = "Stop"

# ==================== Phase 2 Dependency Graph ====================
# All 56 items (VS-01 through VS-08, 7 slices × 8 components each)

$Phase2Items = @{
    "VS-01" = @{
        Name = "ManageIdentityAndRoles"
        Depends = @()  # No dependencies (Gate 1 complete)
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-02" = @{
        Name = "SynchronizeSecurityMaster"
        Depends = @("VS-00")  # Platform bootstrap complete
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-03" = @{
        Name = "IngestMarketDataPIT"
        Depends = @("VS-02")  # Security master needed
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-04" = @{
        Name = "ApplyCorporateActions"
        Depends = @("VS-02", "VS-03")  # Security + market data
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-05" = @{
        Name = "IngestFundamentalsPIT"
        Depends = @("VS-02")  # Security master
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-06" = @{
        Name = "MaintainFeeTaxFxSchedule"
        Depends = @("VS-02")  # Security master
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-07" = @{
        Name = "ManageClientIPS"
        Depends = @("VS-01")  # IAM needed
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
    "VS-08" = @{
        Name = "MaintainPortfolioLedger"
        Depends = @("VS-02", "VS-06")  # Security + Fee/Tax
        Components = @("GOV", "DATA", "DOMAIN", "BE", "ASYNC", "FE", "TESTOPS")
    }
}

# ==================== Logging Setup ====================

function Write-Log {
    param([string]$Message, [string]$Level = "INFO")
    $timestamp = Get-Date -Format "yyyy-MM-dd HH:mm:ss"
    $output = "[$timestamp] [$Level] $Message"
    Write-Host $output
    Add-Content -Path $LogPath -Value $output
}

Write-Log "Phase 2 Orchestration Started"
Write-Log "Mode: $(if ($DryRun) { 'DRY-RUN' } else { 'EXECUTION' })"
Write-Log "Schedule: $(if ($Sequential) { 'SEQUENTIAL' } else { 'PARALLEL' })"

# ==================== Dependency Resolver ====================

function Resolve-Dependencies {
    param([hashtable]$Items)

    $resolved = @()
    $visited = @{}

    function Visit {
        param([string]$SliceId)

        if ($visited[$SliceId]) { return }
        $visited[$SliceId] = $true

        $item = $Items[$SliceId]
        foreach ($dep in $item.Depends) {
            if ($Items.ContainsKey($dep)) {
                Visit $dep
            }
        }

        $resolved += $SliceId
    }

    foreach ($sliceId in $Items.Keys) {
        Visit $sliceId
    }

    return $resolved
}

$executionOrder = Resolve-Dependencies $Phase2Items

Write-Log "Dependency Resolution Complete"
Write-Log "Execution Order: $($executionOrder -join ' → ')"

# ==================== Parallel Batch Calculator ====================

function Calculate-ParallelBatches {
    param([array]$Items, [hashtable]$Metadata)

    $batches = @()
    $completed = @{}

    while ($completed.Count -lt $Items.Count) {
        $batch = @()

        foreach ($item in $Items) {
            if ($completed[$item]) { continue }

            # Check if all dependencies completed
            $canRun = $true
            foreach ($dep in $Metadata[$item].Depends) {
                if (-not $completed[$dep]) {
                    $canRun = $false
                    break
                }
            }

            if ($canRun) {
                $batch += $item
                $completed[$item] = $true
            }
        }

        if ($batch.Count -eq 0) {
            Write-Log "ERROR: Circular dependency detected" -Level "ERROR"
            throw "Circular dependency in Phase 2 graph"
        }

        $batches += , $batch
    }

    return $batches
}

$parallelBatches = Calculate-ParallelBatches $executionOrder $Phase2Items

Write-Log "Parallel Batches Calculated: $($parallelBatches.Count) batches"
for ($i = 0; $i -lt $parallelBatches.Count; $i++) {
    Write-Log "  Batch $($i+1): $($parallelBatches[$i] -join ', ')"
}

# ==================== Execution Plan ====================

$executionPlan = @()

foreach ($batchIndex in 0..($parallelBatches.Count - 1)) {
    $batch = $parallelBatches[$batchIndex]
    $batchNumber = $batchIndex + 1

    foreach ($sliceId in $batch) {
        $item = $Phase2Items[$sliceId]

        foreach ($component in $item.Components) {
            $itemId = "$sliceId-$component"
            $wbsId = "AEG-VS-$(([int]$sliceId.Replace('VS-', ''))):$(([int]$component.Split('-'))[0])"

            $executionPlan += @{
                BatchNumber = $batchNumber
                SliceId = $sliceId
                Component = $component
                ItemId = $itemId
                WbsId = $wbsId
                TaskName = "$($item.Name) - $component"
                Status = "PENDING"
                StartTime = $null
                EndTime = $null
                Result = "UNKNOWN"
            }
        }
    }
}

Write-Log "Execution Plan Generated: $($executionPlan.Count) items total"

# ==================== Batch Execution ====================

function Execute-Batch {
    param(
        [array]$BatchItems,
        [int]$BatchNumber,
        [bool]$DryRun
    )

    Write-Log "========== Batch $BatchNumber =========="
    Write-Log "Executing $(($BatchItems | Group-Object SliceId | Measure-Object).Count) slices in parallel"

    $jobs = @()

    foreach ($item in $BatchItems) {
        $sliceId = $item.SliceId

        $jobScript = {
            param([string]$SliceId, [hashtable]$Item, [bool]$IsDryRun)

            $result = @{
                SliceId = $SliceId
                Status = "COMPLETED"
                Result = "SUCCESS"
            }

            if (-not $IsDryRun) {
                # TODO: Actual execution commands
                # - Create SLICE_SPEC
                # - Generate DATA_CONTRACT
                # - Implement pure policy tests
                # - Create Endpoint/Handler/Sql
                # - Register async events
                # - Build Vue components
                # - Write integration tests

                Start-Sleep -Seconds 2  # Simulated work
            }

            return $result
        }

        if ($Sequential) {
            # Sequential execution for debugging
            Write-Log "  Executing $($item.TaskName)..."
            & $jobScript -SliceId $item.SliceId -Item $Phase2Items[$item.SliceId] -IsDryRun $DryRun
        } else {
            # Parallel execution via background jobs
            $job = Start-Job -ScriptBlock $jobScript -ArgumentList @(
                $item.SliceId,
                $Phase2Items[$item.SliceId],
                $DryRun
            )
            $jobs += @{
                Job = $job
                Item = $item
            }

            Write-Log "  Started job for $($item.TaskName) (Job ID: $($job.Id))"
        }
    }

    # Wait for parallel jobs
    if ($jobs.Count -gt 0) {
        Write-Log "Waiting for $($jobs.Count) jobs to complete..."
        $results = @()

        foreach ($jobWrapper in $jobs) {
            $result = Receive-Job -Job $jobWrapper.Job -Wait
            $results += $result
            Remove-Job -Job $jobWrapper.Job
        }

        Write-Log "Batch $BatchNumber completed. Results:"
        foreach ($result in $results) {
            Write-Log "  ✅ $($result.SliceId): $($result.Result)"
        }
    }
}

# ==================== Main Execution Loop ====================

$overallStartTime = Get-Date
$batchResults = @()

for ($batchNum = 1; $batchNum -le $parallelBatches.Count; $batchNum++) {
    $batchItems = $executionPlan | Where-Object { $_.BatchNumber -eq $batchNum }

    Execute-Batch -BatchItems $batchItems -BatchNumber $batchNum -DryRun $DryRun

    # Mark batch as complete
    $batchResults += @{
        Batch = $batchNum
        Items = $batchItems.Count
        Status = "COMPLETED"
    }

    Write-Log "Batch $batchNum completed. Proceeding to next batch..."
}

# ==================== Summary Report ====================

$overallEndTime = Get-Date
$duration = $overallEndTime - $overallStartTime

Write-Log "========== Execution Summary =========="
Write-Log "Total Time: $($duration.TotalMinutes) minutes"
Write-Log "Total Batches: $($parallelBatches.Count)"
Write-Log "Total Items: $($executionPlan.Count)"
Write-Log "Success Rate: $(($batchResults | Measure-Object).Count) / $(($parallelBatches.Count)) batches"
Write-Log "========== Phase 2 Orchestration Complete =========="

# ==================== Output Execution Matrix ====================

Write-Log ""
Write-Log "Execution Matrix (for documentation):"
Write-Log ""
Write-Log "BatchNumber | SliceId | Component | WbsId | Status"
Write-Log "-----------|---------|-----------|-------|--------"

foreach ($item in $executionPlan) {
    Write-Log "$($item.BatchNumber) | $($item.SliceId) | $($item.Component) | $($item.WbsId) | $($item.Status)"
}

Write-Log ""
Write-Log "Full execution log: $LogPath"