CLI Recipes for CI

$m = & $exe @conn --list-measures --output-format json | ConvertFrom-Json

Write-Host "Measures: $($m.Count)"
$m | Group-Object RetrievalType | Sort-Object Count -Descending |
    ForEach-Object { Write-Host ("  {0,-16} {1}" -f $_.Name, $_.Count) }

# --- findings ---
$noUnit = $m | Where-Object { -not $_.UOM }
if ($noUnit) { Write-Host "`nNo unit ($($noUnit.Count)):"; $noUnit | ForEach-Object { Write-Host "  $($_.Name)" } }

$inactive = $m | Where-Object { -not $_.Active }
if ($inactive) { Write-Host "`nUndeployed ($($inactive.Count)):"; $inactive | ForEach-Object { Write-Host "  $($_.Name)" } }

$metrics = & $exe @conn --list-metrics --output-format json | ConvertFrom-Json
$empty = $metrics | Where-Object { $_.MeasureCount -eq 0 }
if ($empty) {
    Write-Host "Metrics with no measures ($($empty.Count)):"
    $empty | ForEach-Object { Write-Host "  $($_.MetricID)  $($_.Name)" }
}

foreach ($t in 'metricfolder','metric','eventscheme','measure') {
    & $exe @conn --list-out-of-sync --entity-type $t
    if ($LASTEXITCODE -ne 0) { throw "list-out-of-sync $t failed" }
}

$platforms = & $exe @conn --deployment-status --output-format json | ConvertFrom-Json

$undeployed = foreach ($p in $platforms) {
    foreach ($list in 'Engines','MessageEngines','IntegrationEngines','Servers','Connections','Consumers','NotificationServers') {
        $p.$list | Where-Object { -not $_.Deployed } | ForEach-Object { "{0,-20} {1}" -f $list, $_.Name }
    }
}
if ($undeployed) {
    Write-Host "Not deployed:"
    $undeployed | ForEach-Object { Write-Host "  $_" }
    exit 1
}
Write-Host "Every component is deployed."

$s = & $exe @conn --monitor-status --output-format json | ConvertFrom-Json

Write-Host ("Deployed {0} of {1} measures; pending periods {2}; backfilling {3}" -f $s.Deployed, $s.TotalMeasures, $s.PendingTimePeriods, $s.BackfillingMeasures)

if ($s.StaleMeasures) {
    Write-Host "Stale (last refresh over an hour ago):"
    $s.StaleMeasures | ForEach-Object { Write-Host ("  {0,-40} {1}" -f $_.Name, $_.LastRefresh) }
    exit 1
}

# --- 1. export from source ---
Invoke-FlowStep "export" @('--export-model','--export-file',$pkg,'--export-type','full') -Conn $srcConn
# (create the destination connections FIRST, named exactly as the source's)

# --- 2. rehearse, then import to destination ---
Invoke-FlowStep "import rehearsal" @('--import-model','--import-file',$pkg,'--dry-run','--conflict-handling','Skip') -Conn $dstConn
Invoke-FlowStep "import"           @('--import-model','--import-file',$pkg,'--conflict-handling','Skip') -Conn $dstConn

# --- 3. verify structure ---
$src = & $exe @srcConn --list-measures --output-format json | ConvertFrom-Json
$dst = & $exe @dstConn --list-measures --output-format json | ConvertFrom-Json
if ($dst.Count -lt $src.Count) { throw "destination has $($dst.Count) of $($src.Count) measures" }

# --- 4. connections still need credentials, by hand ---
Write-Host "Complete connection credentials in the destination, then deploy."

function Get-Signature($c) {
    (& $exe @c --list-measures --output-format json | ConvertFrom-Json |
        Sort-Object Name |
        ForEach-Object { "$($_.Name)|$($_.RetrievalType)|$($_.IntervalType)|$($_.UOM)" })
}

$a = Get-Signature $siteAConn
$b = Get-Signature $siteBConn

$onlyA = Compare-Object $a $b | Where-Object SideIndicator -eq '<='
$onlyB = Compare-Object $a $b | Where-Object SideIndicator -eq '=>'

if ($onlyA) { Write-Host "Only at site A:"; $onlyA.InputObject | ForEach-Object { Write-Host "  $_" } }
if ($onlyB) { Write-Host "Only at site B:"; $onlyB.InputObject | ForEach-Object { Write-Host "  $_" } }

foreach ($id in $chartIds) {
    $tree = & $exe @conn --list-chart-tree --chart-id $id --output-format json | ConvertFrom-Json
    if (-not $tree.Items -or $tree.Items.Count -eq 0) {
        Write-Host "Chart $id has no content"
    }
}

$out = "$reportDir\flow-health-$(Get-Date -Format 'yyyy-MM-dd').txt"

"Flow health — $(Get-Date -Format 'yyyy-MM-dd HH:mm')" | Out-File $out

# processing
$s = & $exe @conn --monitor-status --output-format json | ConvertFrom-Json
"Deployed measures: $($s.Deployed) of $($s.TotalMeasures)" | Out-File $out -Append
"Pending periods: $($s.PendingTimePeriods); backfilling: $($s.BackfillingMeasures); stale: $(@($s.StaleMeasures).Count)" | Out-File $out -Append
$s.StaleMeasures | ForEach-Object { "  stale: $($_.Name) (last $($_.LastRefresh))" | Out-File $out -Append }

# model size
$m = & $exe @conn --list-measures --output-format json | ConvertFrom-Json
"Measures: $($m.Count)" | Out-File $out -Append

# alert if anything is off
if ($s.StaleMeasures -or $s.Undeployed -gt 0) { exit 1 }

--list-measures --output-format json