# Flow Scan - finds FANUC controls on the local network and shows them live in the browser.
# READ-ONLY: sends only read requests (model, state, program number, program comment,
# parts counter, tool, spindle speed and load, axis load, overrides, program line, alarms).
# Nothing is written to a machine. Listens on 127.0.0.1 only; nothing leaves this PC.
# Works in Windows PowerShell 5.1 with no extra software and no administrator rights.
param([int]$Port = 8377, [switch]$NoBrowser, [int]$Seconds = 0)
$ErrorActionPreference = 'Stop'
$FocasPort = 8193

function BE16([int]$v) { return [byte[]]((($v -shr 8) -band 0xFF), ($v -band 0xFF)) }
function BE32([int]$v) { $b = [BitConverter]::GetBytes([int32]$v); [Array]::Reverse($b); return [byte[]]$b }
function RdU16([byte[]]$b, [int]$o) { return (([int]$b[$o]) -shl 8) -bor ([int]$b[$o + 1]) }
function RdI32([byte[]]$b, [int]$o) { $t = [byte[]]($b[$o + 3], $b[$o + 2], $b[$o + 1], $b[$o]); return [BitConverter]::ToInt32($t, 0) }
function RdText([byte[]]$b, [int]$o, [int]$n) {
    $end = $o
    while ($end -lt ($o + $n) -and $b[$end] -ne 0) { $end++ }
    return [Text.Encoding]::ASCII.GetString($b, $o, $end - $o).Trim()
}

function Read-Exact($stream, [int]$n) {
    $buf = New-Object byte[] $n
    $got = 0
    while ($got -lt $n) {
        $r = $stream.Read($buf, $got, $n - $got)
        if ($r -le 0) { throw 'connection closed' }
        $got += $r
    }
    return , $buf
}

function Send-Frame($stream, [int]$ftype, [byte[]]$payload) {
    $out = New-Object IO.MemoryStream
    $head = [byte[]](0xA0, 0xA0, 0xA0, 0xA0)
    $out.Write($head, 0, 4)
    foreach ($part in @((BE16 1), (BE16 $ftype), (BE16 $payload.Length), $payload)) {
        if ($part.Length -gt 0) { $out.Write([byte[]]$part, 0, $part.Length) }
    }
    $bytes = $out.ToArray()
    $stream.Write($bytes, 0, $bytes.Length)
}

function Recv-Frame($stream) {
    [byte[]]$h = Read-Exact $stream 10
    if ($h[0] -ne 0xA0 -or $h[1] -ne 0xA0 -or $h[2] -ne 0xA0 -or $h[3] -ne 0xA0) { throw 'not a FOCAS answer' }
    $len = RdU16 $h 8
    [byte[]]$data = @()
    if ($len -gt 0) { $data = Read-Exact $stream $len }
    return @{ ftype = (RdU16 $h 6); data = $data }
}

# One read request. Returns the data bytes, or $null when the control refuses this request.
# $cls 1 = CNC, 2 = PMC (then $code 0x8001 reads a PMC range, $v1..$v2 = addresses).
function Focas-Read($conn, [int]$code, [int]$v1 = 0, [int]$v2 = 0, [int]$v3 = 0, [int]$path = 1, [int]$v4 = 0, [int]$cls = 1) {
    $cmd = New-Object IO.MemoryStream
    foreach ($part in @((BE16 $cls), (BE16 $path), (BE16 $code), (BE32 $v1), (BE32 $v2), (BE32 $v3), (BE32 $v4), (BE32 0))) {
        $cmd.Write([byte[]]$part, 0, $part.Length)
    }
    $c = $cmd.ToArray()
    $payload = [byte[]]((BE16 1) + (BE16 ($c.Length + 2)) + $c)
    Send-Frame $conn.stream 0x2101 $payload
    $f = Recv-Frame $conn.stream
    if ($f.ftype -ne 0x2102 -or $f.data.Length -lt 18) { throw 'unexpected answer' }
    [byte[]]$d = $f.data
    $o = 4                                   # count(2) + length(2), then the answer body
    for ($i = 0; $i -lt 6; $i++) { if ($d[$o + $i] -ne $c[$i]) { throw 'answer does not match request' } }
    for ($i = 6; $i -lt 12; $i++) { if ($d[$o + $i] -ne 0) { return $null } }
    $dlen = RdU16 $d ($o + 12)
    if ($dlen -le 0) { return $null }
    $res = New-Object byte[] $dlen
    [Array]::Copy($d, $o + 14, $res, 0, $dlen)
    return , $res
}

function Focas-Open([string]$ip) {
    $client = New-Object Net.Sockets.TcpClient
    try {
        $ar = $client.BeginConnect($ip, $FocasPort, $null, $null)
        if (-not $ar.AsyncWaitHandle.WaitOne(1500)) { throw 'connect timeout' }
        $client.EndConnect($ar)
        $stream = $client.GetStream()
        $stream.ReadTimeout = 2500
        $stream.WriteTimeout = 2500
        Send-Frame $stream 0x0101 ([byte[]](0, 2))
        $f = Recv-Frame $stream
        if ($f.ftype -ne 0x0102) { throw 'no FOCAS handshake' }
        $conn = @{ ip = $ip; client = $client; stream = $stream; comments = @{} }
        [byte[]]$s = Focas-Read $conn 0x18
        if ($null -eq $s -or $s.Length -lt 18) { throw 'no system info' }
        $conn.type = RdText $s 4 2
        $conn.kind = RdText $s 6 2
        $conn.series = RdText $s 8 4
        $conn.version = RdText $s 12 4
        $conn.axes = RdText $s 16 2
        # unique ID of the control: stays the same when its IP address changes
        $conn.id = ''
        [byte[]]$id = Focas-Read $conn 0xE8
        if ($null -ne $id -and $id.Length -ge 16) { $conn.id = (($id[0..15] | ForEach-Object { $_.ToString('x2') }) -join '') }
        # channels (paths): a second or third channel answers the same system-info request
        $conn.paths = 1
        foreach ($p in 2..4) {
            [byte[]]$more = Focas-Read $conn 0x18 0 0 0 $p
            if ($null -eq $more -or $more.Length -lt 18) { break }
            $conn.paths = $p
        }
        return $conn
    } catch {
        $client.Close()
        throw
    }
}

function Focas-Close($conn) {
    try { Send-Frame $conn.stream 0x0201 ([byte[]]@()); [void](Recv-Frame $conn.stream) } catch { }
    try { $conn.client.Close() } catch { }
}

function RdI16([byte[]]$b, [int]$o) { $v = RdU16 $b $o; if ($v -ge 0x8000) { $v -= 0x10000 }; return $v }

# Meter record: i32 value, i16 base (10), i16 decimals.
function Rd-Meter([byte[]]$b, [int]$o) {
    $v = RdI32 $b $o; $base = RdI16 $b ($o + 4); $dec = RdI16 $b ($o + 6)
    if ($base -gt 1 -and $dec -gt 0) { return [int][math]::Round($v / [math]::Pow($base, $dec)) }
    return $v
}

# What one channel does right now. Requests measured 26.10.2026 against the FANUC library on
# 31i, 32i, 18i, 0i-F and Citizen/Tornos controls; values compared with the library on 7 machines.
function Read-Live($conn, [int]$p) {
    $live = [ordered]@{ tool = $null; speed = $null; load = $null; axes = @(); feed = $null; line = $null; alarms = @() }
    [byte[]]$t = Focas-Read $conn 0x22 22 0 0 $p
    if ($null -ne $t -and $t.Length -ge 4) { $live.tool = RdI32 $t 0 }
    [byte[]]$sp = Focas-Read $conn 0x40 5 -1 0 $p
    if ($null -ne $sp -and $sp.Length -ge 8) { $live.speed = Rd-Meter $sp 0 }
    [byte[]]$sl = Focas-Read $conn 0x40 4 -1 0 $p
    if ($null -ne $sl -and $sl.Length -ge 8) { $live.load = Rd-Meter $sl 0 }
    # axis names do not change while the connection lives: ask once per channel
    if (-not $conn.ContainsKey('axisNames')) { $conn.axisNames = @{} }
    [byte[]]$names = $conn.axisNames[$p]
    if ($null -eq $names) { $names = Focas-Read $conn 0x89 0 0 0 $p; if ($null -ne $names) { $conn.axisNames[$p] = $names } }
    [byte[]]$loads = Focas-Read $conn 0x56 1 0 0 $p
    if ($null -ne $names -and $null -ne $loads) {
        $seen = @{}
        for ($i = 0; ($i * 4) -lt $names.Length -and (($i + 1) * 8) -le $loads.Length; $i++) {
            $n = ([char]$names[$i * 4]).ToString().Trim([char]0, ' ')
            if (-not $n -or $n -match '^\d$') { continue }   # 18i lists unused axis slots as "7", "8"
            if ($seen.ContainsKey($n)) { $n = "$n$($i + 1)" }
            $seen[$n] = 1
            $live.axes += [ordered]@{ name = $n; load = [math]::Abs([long](Rd-Meter $loads ($i * 8))) }
        }
    }
    # feed override: PMC G12, inverted (155 = 100 %); channel n at +1000*(n-1)
    $g = 1000 * ($p - 1)
    [byte[]]$g12 = Focas-Read $conn 0x8001 (12 + $g) (12 + $g) 0 1 0 2
    if ($null -ne $g12 -and $g12.Length -ge 1 -and $g12[0] -ne 0) { $live.feed = 255 - $g12[0] }
    [byte[]]$ex = Focas-Read $conn 0x20 240 0 0 $p
    if ($null -ne $ex -and $ex.Length -gt 4) {
        $text = [Text.Encoding]::ASCII.GetString($ex, 4, $ex.Length - 4).Split([char]0)[0] -replace "`r", ''
        $first = $text.Split("`n")[0].Trim()
        if ($first) { $live.line = $first.Substring(0, [math]::Min(120, $first.Length)) }
    }
    [byte[]]$al = Focas-Read $conn 0x23 -1 10 2 $p 64
    if ($null -ne $al) {
        for ($o = 0; ($o + 80) -le $al.Length -and $live.alarms.Count -lt 5; $o += 80) {
            $num = RdI32 $al $o; $len = [math]::Max(0, [math]::Min(64, (RdI32 $al ($o + 12))))
            $msg = [Text.Encoding]::ASCII.GetString($al, $o + 16, $len).Trim()
            if ($num -gt 0 -or $msg) { $live.alarms += ("$num $msg").Trim() }
        }
    }
    return $live
}

$RunNames = @{ 0 = 'IDLE'; 1 = 'STOPPED'; 2 = 'HOLD'; 3 = 'RUNNING'; 4 = 'RUNNING' }
$KindNames = @{ 'T' = 'Lathe'; 'TT' = 'Lathe, multi-channel'; 'M' = 'Mill'; 'MM' = 'Mill, multi-channel' }

function Read-Snapshot($conn, [switch]$WithLive) {
    $m = [ordered]@{
        ip = $conn.ip; online = $true; id = $conn.id; channels = @()
        model = ('FANUC ' + $conn.type + 'i'); kind = $KindNames[$conn.kind]
        software = ($conn.series + ' / ' + $conn.version); axes = $conn.axes
        state = $null; program = $null; comment = $null; counter = $null
    }
    foreach ($p in 1..$conn.paths) {
        $state = $null
        [byte[]]$st = Focas-Read $conn 0x19 0 0 0 $p
        if ($null -ne $st -and $st.Length -ge 14) {
            $state = $RunNames[(RdU16 $st 2)]
            if ($null -eq $state) { $state = 'IDLE' }
            if ($state -ne 'RUNNING') {
                if ((RdU16 $st 10) -ne 0) { $state = 'ALARM' }
                if ((RdU16 $st 8) -ne 0) { $state = 'EMERGENCY STOP' }
            }
        }
        [byte[]]$pn = Focas-Read $conn 0x1c 0 0 0 $p
        if ($null -eq $pn -or $pn.Length -lt 8) { continue }
        $main = RdI32 $pn 4
        $key = "$p/$main"
        if (-not $conn.comments.ContainsKey($key)) {
            $conn.comments[$key] = ''
            [byte[]]$dir = Focas-Read $conn 0x06 $main 0x13 2 $p
            if ($null -ne $dir -and $dir.Length -ge 72 -and (RdI32 $dir 0) -eq $main) {
                $conn.comments[$key] = (RdText $dir 8 64).Trim('(', ')', '<', '>', ' ')
            }
        }
        $live = $null
        if ($WithLive) {   # only the live poll; the network scan stays quick
        # a refused request is just a missing value; a broken connection marks the machine offline
        try { $live = Read-Live $conn $p } catch [System.IO.IOException] { throw } catch { if ($_.Exception.Message -match 'closed|unexpected|not a FOCAS|does not match') { throw } }
        }
        $m.channels += [ordered]@{ channel = $p; state = $state; program = ('O' + $main); comment = $conn.comments[$key]; live = $live }
        if ($p -eq 1) { $m.program = ('O' + $main); $m.comment = $conn.comments[$key] }
    }
    # the machine runs when at least one channel runs; otherwise the worst channel state is shown
    $states = @($m.channels | ForEach-Object { $_.state })
    foreach ($s in @('RUNNING', 'EMERGENCY STOP', 'ALARM')) { if ($null -eq $m.state -and $states -contains $s) { $m.state = $s } }
    if ($null -eq $m.state -and $states.Count -gt 0) { $m.state = $states[0] }
    [byte[]]$mc = Focas-Read $conn 0x15 3901 3901
    if ($null -ne $mc -and $mc.Length -ge 8 -and -not ($mc[6] -eq 0xFF -and $mc[7] -eq 0xFF) -and $mc[5] -gt 0) {
        $m.counter = [long][math]::Round((RdI32 $mc 0) / [math]::Pow($mc[5], $mc[7]))
    }
    return $m
}

function Get-LocalPrefixes {
    $found = @()
    foreach ($nic in [Net.NetworkInformation.NetworkInterface]::GetAllNetworkInterfaces()) {
        if ($nic.OperationalStatus -ne 'Up') { continue }
        foreach ($a in $nic.GetIPProperties().UnicastAddresses) {
            $ip = $a.Address.ToString()
            if ($ip -match '^(10\.|192\.168\.|172\.(1[6-9]|2\d|3[01])\.)\d') {
                $found += ($ip -replace '\.\d+$', '')
            }
        }
    }
    return @($found | Select-Object -Unique)
}

function Find-OpenPorts([string]$prefix) {
    $tries = @()
    foreach ($i in 1..254) {
        $c = New-Object Net.Sockets.TcpClient
        $ip = "$prefix.$i"
        $tries += @{ ip = $ip; client = $c; task = $c.ConnectAsync($ip, $FocasPort) }
    }
    Start-Sleep -Milliseconds 900
    $open = @()
    foreach ($t in $tries) {
        if ($t.task.Status -eq 'RanToCompletion' -and $t.client.Connected) { $open += $t.ip }
        try { $t.client.Close() } catch { }
    }
    return @($open)
}

# FANUC network cards have addresses starting 00-E0-E4. After the scan the PC has seen every
# live device of the subnet, so its own neighbour table tells which FANUC devices exist.
function Get-FanucNeighbours {
    $ips = @()
    try {
        foreach ($line in (& arp -a 2>$null)) {
            if ($line -match '^\s*(\d+\.\d+\.\d+\.\d+)\s+00-e0-e4-') { $ips += $Matches[1] }
        }
    } catch { }
    return @($ips)
}

$Conns = @{}

function Get-Machine([string]$ip, [switch]$WithLive) {
    try {
        if (-not $Conns.ContainsKey($ip)) { $Conns[$ip] = Focas-Open $ip }
        return Read-Snapshot $Conns[$ip] -WithLive:$WithLive
    } catch {
        if ($Conns.ContainsKey($ip)) { Focas-Close $Conns[$ip]; $Conns.Remove($ip) }
        return [ordered]@{ ip = $ip; online = $false; error = "$($_.Exception.Message)" }
    }
}

function Invoke-Scan {
    $sw = [Diagnostics.Stopwatch]::StartNew()
    $prefixes = Get-LocalPrefixes
    $machines = @()
    $silent = @()
    $answered = @()
    foreach ($p in $prefixes) {
        foreach ($ip in (Find-OpenPorts $p)) {
            $answered += $ip
            $m = Get-Machine $ip
            if ($m.online) { $machines += $m } else { $silent += $ip }
        }
    }
    $closed = @(Get-FanucNeighbours | Where-Object { $answered -notcontains $_ })
    return @{ networks = @($prefixes | ForEach-Object { "$_.0/24" }); machines = @($machines); portOpenNoAnswer = @($silent); fanucClosed = $closed; ms = $sw.ElapsedMilliseconds }
}

$Page = @'
<!doctype html><html lang="en"><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1">
<title>Flow Scan</title><style>
:root{--bg:#c9d3d8;--fg:#1e282f;--card:#fff;--mut:#5c656b;--line:#d9dfe2;--acc:#278ea4;--ring:4px;
--run:#2ecc71;--idle:#f1c40f;--bad:#c0392b;--off:#bdc3c7}
*{box-sizing:border-box}body{margin:0;background:var(--bg);color:var(--fg);font:15px/1.45 Rubik,Inter,system-ui,Segoe UI,Roboto,Arial,sans-serif}
main{max-width:1180px;margin:0 auto;padding:20px 16px 40px}h1{font-size:22px;margin:0}p.sub{margin:2px 0 18px;color:var(--mut)}
h2{font-size:16px;margin:0 0 10px}
button{font:inherit;font-weight:600;border:0;border-radius:8px;padding:10px 18px;background:var(--acc);color:#fff;cursor:pointer}
button:disabled{opacity:.45;cursor:default}button.ghost{background:transparent;color:var(--acc);border:1px solid var(--acc)}
.bar{display:flex;gap:12px;align-items:center;flex-wrap:wrap;margin-bottom:14px}.note{color:var(--mut)}.hide{display:none!important}
.panel{background:var(--card);border-radius:12px;box-shadow:0 8px 28px rgba(0,0,0,.14);margin-bottom:16px;overflow:hidden}.pad{padding:14px 16px}
.wrap{overflow-x:auto}table{width:100%;border-collapse:collapse}th,td{text-align:left;padding:9px 12px;border-bottom:1px solid var(--line);white-space:nowrap}
th{font-size:11px;text-transform:uppercase;letter-spacing:.05em;color:var(--mut)}tr:last-child td{border-bottom:0}
td input[type=text]{font:inherit;font-weight:600;width:120px;border:1px solid transparent;border-radius:6px;padding:4px 8px;background:#eef2f4}
td input[type=text]:focus{border-color:var(--acc);background:#fff;outline:0}
.dot{display:inline-block;width:10px;height:10px;border-radius:50%;margin-right:7px;vertical-align:baseline;flex-shrink:0}
.d-run{background:var(--run)}.d-idle{background:var(--idle)}.d-bad{background:var(--bad)}.d-off{background:var(--off)}
.rep{display:grid;grid-template-columns:repeat(auto-fit,minmax(250px,1fr));gap:0}.rep>div{padding:14px 16px;border-right:1px solid var(--line)}.rep>div:last-child{border-right:0}
.rep .n{font-size:30px;font-weight:700;line-height:1}.rep .t{font-weight:700;margin:6px 0 4px}.rep .d{color:var(--mut);font-size:13px}
.summary{display:flex;gap:10px;flex-wrap:wrap}.chip{background:#f5f8f9;border-radius:8px;padding:7px 14px;text-align:center;min-width:92px}
.chip b{display:block;font-size:22px;line-height:1.15}.chip span{font-size:10px;text-transform:uppercase;letter-spacing:.05em;color:var(--mut)}
.chip.run{box-shadow:0 0 0 3px var(--run)}.chip.idle{box-shadow:0 0 0 3px var(--idle)}.chip.bad{box-shadow:0 0 0 3px var(--bad)}
.grid{display:grid;grid-template-columns:repeat(auto-fill,minmax(290px,1fr));gap:14px;margin-top:6px}
.mc{background:var(--card);border-radius:8px;overflow:hidden;display:flex;flex-direction:column;box-shadow:0 0 0 var(--ring) var(--sc);--sc:var(--off)}
.mc.run{--sc:var(--run)}.mc.idle{--sc:var(--idle)}.mc.bad{--sc:var(--bad)}
.mh{display:flex;align-items:center;justify-content:space-between;gap:6px;padding:7px 10px;background:var(--sc);color:#fff;text-shadow:0 1px 2px rgba(0,0,0,.3)}
.mh .nm{font-weight:700;font-size:15px;flex:1;text-align:center}.mh .sm{font-size:11px;font-weight:500;white-space:nowrap}
.mid{display:flex;align-items:center;gap:10px;padding:10px 12px 6px}.donut{width:104px;height:104px;flex-shrink:0}
.leg{flex:1;font-size:12px}.leg .st{font-size:13px;font-weight:700;padding-bottom:4px;margin-bottom:5px;border-bottom:1px solid var(--line)}
.leg .row{display:flex;align-items:center;gap:6px;margin-bottom:3px}.leg .sq{width:12px;height:12px;border-radius:3px}.leg .v{margin-left:auto;font-weight:700;font-variant-numeric:tabular-nums}
.idlebox{margin:0 12px 8px;padding:6px 10px;border-radius:6px;background:#fdf6d8;color:#7a5b00;font-weight:700;display:flex;justify-content:space-between;font-variant-numeric:tabular-nums}
.mc.bad .idlebox{background:#fbe4e1;color:#8f1d12}
.ib{display:flex;border-top:1px solid var(--line);padding:6px 4px}.ib>div{flex:1;text-align:center;min-width:0}
.ib .l{display:block;font-size:9px;text-transform:uppercase;letter-spacing:.05em;color:#9ca3af}.ib .v{display:block;font-weight:600;font-size:13px;white-space:nowrap;overflow:hidden;text-overflow:ellipsis}
.alarm{margin:0 12px 8px;padding:6px 10px;border-radius:6px;background:#fbe4e1;color:#8f1d12;font-size:12px;font-weight:600}
.alarm small{display:block;font-weight:400;color:#a6493f}
.chn{border-top:1px solid var(--line);padding:7px 12px 9px}
.chh{display:flex;align-items:baseline;gap:8px;font-size:12px;margin-bottom:5px;flex-wrap:wrap}
.chh .c{font-weight:700}.chh .t{font-weight:800;color:#007590;font-size:14px}.chh .rpm{color:var(--mut)}
.ov{background:#fdf0c4;color:#7a5b00;border-radius:999px;padding:0 7px;font-size:11px;font-weight:600}
.ld{display:grid;grid-template-columns:44px minmax(0,1fr) 36px;gap:6px;align-items:center;font-size:11px;color:var(--mut);margin:2px 0}
.ld .b{height:6px;background:#eef2f4;border-radius:3px;overflow:hidden}.ld .b span{display:block;height:100%;background:#278ea4}
.ld.sp .b span{background:#c73d63}.ld .p{text-align:right;font-weight:600;color:var(--fg);font-variant-numeric:tabular-nums}
.pl{background:#1e282f;color:#f4c66b;font-family:ui-monospace,Consolas,monospace;font-size:11px;border-radius:4px;padding:4px 8px;margin-top:6px;white-space:nowrap;overflow:hidden;text-overflow:ellipsis}
.chs{border-top:1px solid var(--line);padding:6px 12px;font-size:12px;color:var(--mut)}.chs div{display:flex;gap:6px;align-items:center;white-space:nowrap;overflow:hidden;text-overflow:ellipsis}
@media print{button,.bar .note,#mon,td:first-child,th:first-child{display:none!important}body{background:#fff}.panel{break-inside:avoid}}
</style></head><body><main>
<h1>Flow Scan</h1><p class="sub">Finds FANUC controls on this network and shows them live. Read-only: nothing is written to a machine, nothing leaves this computer.</p>

<section id="find">
<div class="bar"><button id="scan">Scan network</button><span class="note" id="note"></span></div>
<div class="panel hide" id="report"><div class="rep" id="rep"></div></div>
<div class="panel hide" id="tw"><div class="wrap"><table><thead><tr><th></th><th>Name</th><th>Control</th><th>Address</th><th>Channels</th><th>State</th><th>Program</th><th>Drawing</th><th>Parts counter</th></tr></thead><tbody id="rows"></tbody></table></div></div>
<div class="bar"><button id="go" class="hide" disabled>Start monitoring</button><button id="print" class="ghost hide">Print readiness report</button><span class="note hide" id="hint">Tick the machines to watch. Names can be changed right in the table.</span></div>
</section>

<section id="mon" class="hide">
<div class="bar"><button id="back" class="ghost">Back to list</button><div class="summary" id="sum"></div><span class="note" id="tick"></span></div>
<div class="grid" id="cards"></div>
</section>
</main><script>
var $=function(i){return document.getElementById(i)},timer=null,polling=false,picked=[],track={},found=[],started=0;
function esc(s){return String(s==null?'':s).replace(/[&<>"]/g,function(c){return{'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;'}[c]})}
function get(u){return fetch(u,{cache:'no-store'}).then(function(r){return r.json()})}
function kind(s){return s==='RUNNING'?'run':(s==='ALARM'||s==='EMERGENCY STOP')?'bad':s?'idle':'off'}
function dur(ms){var s=Math.floor(ms/1000),h=Math.floor(s/3600),m=Math.floor(s%3600/60);s=s%60;return (h?h+':'+(m<10?'0':''):'')+m+':'+(s<10?'0':'')+s}
// names are kept in this browser, tied to the control ID - they survive an address change
function names(){try{return JSON.parse(localStorage.getItem('flowscan.names')||'{}')}catch(e){return{}}}
function nameOf(m){return names()[m.id]||(m.model.replace('FANUC ','')+' .'+m.ip.split('.').pop())}
function saveName(id,v){var n=names();if(v)n[id]=v;else delete n[id];try{localStorage.setItem('flowscan.names',JSON.stringify(n))}catch(e){}}

$('scan').onclick=function(){
  $('scan').disabled=true;$('note').textContent='Scanning...';
  get('/scan').then(function(d){
    found=d.machines;var h='';
    found.forEach(function(m){var k=kind(m.state);
      h+='<tr><td><input type="checkbox" value="'+esc(m.ip)+'"></td><td><input type="text" data-id="'+esc(m.id)+'" value="'+esc(nameOf(m))+'" aria-label="Machine name"></td>'
        +'<td>'+esc(m.model)+'</td><td>'+esc(m.ip)+'</td><td>'+m.channels.length+'</td><td><span class="dot d-'+k+'"></span><b>'+esc(m.state||'')+'</b></td>'
        +'<td>'+esc(m.program||'')+'</td><td>'+esc(m.comment||'')+'</td><td>'+esc(m.counter==null?'':m.counter)+'</td></tr>'});
    $('rows').innerHTML=h;var any=found.length>0;
    ['tw','go','print','hint'].forEach(function(i){$(i).classList.toggle('hide',!any)});$('go').disabled=true;
    var closed=d.fanucClosed||[],nets=d.networks.join(', ');
    $('rep').innerHTML='<div><div class="n">'+found.length+'</div><div class="t"><span class="dot d-run"></span>Ready to monitor</div><div class="d">FANUC controls that answer on the network right now. No installation on the machine is needed.</div></div>'
      +'<div><div class="n">'+closed.length+'</div><div class="t"><span class="dot d-idle"></span>On the network, not readable yet</div><div class="d">'+(closed.length?('FANUC devices at '+esc(closed.join(', '))+'. The network data function has to be switched on in the control settings.'):'No FANUC devices with a closed data port were seen.')+'</div></div>'
      +'<div><div class="n">?</div><div class="t"><span class="dot d-off"></span>Not on this network</div><div class="d">Machines without a network cable, or on another network, cannot be seen from here. They are connected with a small add-on unit - count them and tell us.</div></div>';
    $('report').classList.remove('hide');
    $('note').textContent=d.networks.length?('Scanned '+nets+' in '+(d.ms/1000).toFixed(1)+' s.'):'This computer has no local network connection.';
    if(!any&&d.networks.length)$('note').textContent+=' No controls answered: this computer may not be on the machine network.';
  }).catch(function(){$('note').textContent='Scan failed. Is the Flow Scan window still open?'}).then(function(){$('scan').disabled=false});
};
$('rows').onchange=function(e){
  if(e.target.type==='text')saveName(e.target.getAttribute('data-id'),e.target.value.trim());
  $('go').disabled=!document.querySelector('#rows input[type=checkbox]:checked');
};
$('print').onclick=function(){window.print()};

function donut(p,color){var c=2*Math.PI*40,on=c*p/100;
  return '<svg class="donut" viewBox="0 0 100 100"><circle cx="50" cy="50" r="40" fill="none" stroke="#e5e7eb" stroke-width="10"/>'
   +'<circle cx="50" cy="50" r="40" fill="none" stroke="'+color+'" stroke-width="10" stroke-dasharray="'+on+' '+(c-on)+'" transform="rotate(-90 50 50)"/>'
   +'<text x="50" y="52" text-anchor="middle" font-size="22" font-weight="700" fill="#1f2937">'+Math.round(p)+'%</text>'
   +'<text x="50" y="66" text-anchor="middle" font-size="9" fill="#6b7280" letter-spacing=".5">RUNNING</text></svg>'}
function bar(label,v,cls){var w=Math.max(0,Math.min(100,v||0));
  return '<div class="ld'+(cls?' '+cls:'')+'"><span>'+esc(label)+'</span><div class="b"><span style="width:'+w+'%"></span></div><span class="p">'+(v==null?'-':v+'%')+'</span></div>'}
// one channel: tool, speed, load bars and the program line, as read from the control right now
function chan(c){var L=c.live;
  if(!L)return '<div class="chs"><div><span class="dot d-'+kind(c.state)+'"></span>Channel '+c.channel+' &middot; '+esc(c.state||'')+' &middot; '+esc(c.program)+' '+esc(c.comment)+'</div></div>';
  var stopped=c.state!=='RUNNING',h='<div class="chn"><div class="chh"><span class="c">Channel '+c.channel+'</span>'
    +(L.tool?'<span class="t">T'+esc(L.tool)+'</span>':'')+(L.speed!=null?'<span class="rpm">'+esc(L.speed)+' rpm</span>':'')
    +(L.feed!=null&&L.feed<100?'<span class="ov">feed '+esc(L.feed)+'%</span>':'')+'</div>';
  if(L.load!=null)h+=bar('Spindle',L.load,'sp');
  // linear axes first (X, Z, Y), then the rest, at most four bars
  var ax=(L.axes||[]).slice().sort(function(a,b){var o={X:0,Z:1,Y:2};return (o[a.name]==null?9:o[a.name])-(o[b.name]==null?9:o[b.name])});
  ax.slice(0,4).forEach(function(a){h+=bar(a.name,a.load)});
  if(L.line)h+='<div class="pl">'+(stopped?'&#9208; ':'')+esc(L.line)+'</div>';
  return h+'</div>'}
// cycle time = median gap between the last part-counter steps of one part each
function cycle(t,counter,now){if(counter==null)return null;
  if(t.lastCount!=null&&counter===t.lastCount+1){if(t.lastAt)t.gaps.push(now-t.lastAt);if(t.gaps.length>5)t.gaps.shift();t.lastAt=now}
  else if(t.lastCount==null||counter!==t.lastCount){t.lastAt=t.lastCount==null?null:now;if(counter<t.lastCount)t.gaps=[]}
  t.lastCount=counter;if(t.gaps.length<3)return null;var g=t.gaps.slice().sort(function(a,b){return a-b})[Math.floor((t.gaps.length-1)/2)]/1000;
  return g<120?Math.round(g)+' s':Math.floor(g/60)+' min '+Math.round(g%60)+' s'}
function poll(){
  get('/state?ips='+picked.join(',')).then(function(d){
    var now=Date.now(),h='',cnt={run:0,idle:0,bad:0};
    d.machines.forEach(function(m){
      var t=track[m.ip]||(track[m.ip]={last:now,run:0,stop:0,since:null,base:null,gaps:[],lastCount:null,lastAt:null});
      var running=m.online&&(m.channels||[]).some(function(c){return c.state==='RUNNING'}),k=!m.online?'off':running?'run':kind(m.state)==='bad'?'bad':'idle';
      var step=now-t.last;t.last=now;if(t.k==='run')t.run+=step;else if(t.k)t.stop+=step;
      if(k!=='run'&&t.k==='run'||t.since===null&&k!=='run')t.since=now;if(k==='run')t.since=null;t.k=k;
      if(cnt[k]!=null)cnt[k]++;
      var name=esc(nameOf(m.online?m:{id:'',model:'FANUC',ip:m.ip}));
      if(!m.online){h+='<div class="mc"><div class="mh"><span class="nm">'+name+'</span></div><div class="idlebox" style="margin-top:10px"><span>NO ANSWER</span></div></div>';return}
      if(m.counter!=null&&t.base===null)t.base=m.counter;
      var total=t.run+t.stop,p=total?t.run*100/total:(k==='run'?100:0),made=m.counter==null?'-':'+'+(m.counter-t.base),cyc=cycle(t,m.counter,now);
      var alarm='';(m.channels||[]).some(function(c){var L=c.live;if(L&&L.alarms&&L.alarms.length){
        alarm='<div class="alarm">'+esc(L.alarms[0])+(L.line&&c.state!=='RUNNING'?'<small>Stopped at line: '+esc(L.line)+'</small>':'')+'</div>';return true}});
      h+='<div class="mc '+k+'"><div class="mh"><span class="sm">'+esc(m.model)+'</span><span class="nm">'+name+'</span><span class="sm">'+esc(m.ip)+'</span></div>'
        +'<div class="mid">'+donut(p,'#2ecc71')+'<div class="leg"><div class="st">'+esc(running?'RUNNING':m.state)+'</div>'
        +'<div class="row"><span class="sq" style="background:#2ecc71"></span>Running<span class="v">'+dur(t.run)+'</span></div>'
        +'<div class="row"><span class="sq" style="background:#f1c40f"></span>Stopped<span class="v">'+dur(t.stop)+'</span></div></div></div>'
        +(k==='run'?'':'<div class="idlebox"><span>'+(k==='bad'?'ALARM, stopped for':'Stopped for')+'</span><span>'+dur(now-t.since)+'</span></div>')
        +alarm
        +'<div class="ib"><div><span class="l">Program</span><span class="v">'+esc(m.program||'-')+'</span></div><div><span class="l">Drawing</span><span class="v">'+esc(m.comment||'-')+'</span></div><div><span class="l">Parts</span><span class="v">'+esc(made)+'</span></div>'
        +(cyc?'<div><span class="l">Cycle</span><span class="v">'+esc(cyc)+'</span></div>':'')+'</div>'
        +m.channels.map(chan).join('')+'</div>'});
    $('cards').innerHTML=h;
    $('sum').innerHTML='<div class="chip run"><b>'+cnt.run+'</b><span>Running</span></div><div class="chip idle"><b>'+cnt.idle+'</b><span>Stopped</span></div><div class="chip bad"><b>'+cnt.bad+'</b><span>Alarm</span></div>';
    $('tick').textContent='Live for '+dur(now-started);
  }).catch(function(){$('tick').textContent='Connection to Flow Scan lost.'}).then(function(){
    // the next poll starts 2 s after this answer: a slow answer never piles requests up
    if(polling)timer=setTimeout(poll,2000)});
}
$('go').onclick=function(){
  picked=[].map.call(document.querySelectorAll('#rows input[type=checkbox]:checked'),function(i){return i.value});track={};started=Date.now();
  $('find').classList.add('hide');$('mon').classList.remove('hide');polling=true;poll();
};
$('back').onclick=function(){polling=false;clearTimeout(timer);$('mon').classList.add('hide');$('find').classList.remove('hide')};
</script></body></html>
'@

function Send-Http($stream, [string]$status, [string]$type, [byte[]]$body) {
    $head = "HTTP/1.1 $status`r`nContent-Type: $type`r`nContent-Length: $($body.Length)`r`nCache-Control: no-store`r`nConnection: close`r`n`r`n"
    $hb = [Text.Encoding]::ASCII.GetBytes($head)
    $stream.Write($hb, 0, $hb.Length)
    if ($body.Length -gt 0) { $stream.Write($body, 0, $body.Length) }
}

function Handle-Request($client) {
    $stream = $client.GetStream()
    $stream.ReadTimeout = 3000
    $reader = New-Object IO.StreamReader($stream, [Text.Encoding]::ASCII)
    $first = $reader.ReadLine()
    while ($true) { $line = $reader.ReadLine(); if ([string]::IsNullOrEmpty($line)) { break } }
    if ($first -notmatch '^GET (\S+) ') { Send-Http $stream '405 Method Not Allowed' 'text/plain' ([byte[]]@()); return }
    $url = $Matches[1]
    $utf8 = [Text.Encoding]::UTF8
    if ($url -eq '/') {
        Send-Http $stream '200 OK' 'text/html; charset=utf-8' $utf8.GetBytes($Page)
    } elseif ($url -eq '/scan') {
        Send-Http $stream '200 OK' 'application/json' $utf8.GetBytes((Invoke-Scan | ConvertTo-Json -Depth 5 -Compress))
    } elseif ($url -match '^/state\?ips=([0-9.,]*)$') {
        $list = @()
        # only controls found by a scan may be polled - the page cannot point us at other hosts
        foreach ($ip in ($Matches[1] -split ',')) { if ($ip -and $script:Known -contains $ip) { $list += (Get-Machine $ip -WithLive) } }
        Send-Http $stream '200 OK' 'application/json' $utf8.GetBytes((@{ machines = @($list) } | ConvertTo-Json -Depth 8 -Compress))
    } else {
        Send-Http $stream '404 Not Found' 'text/plain' ([byte[]]@())
    }
}

$script:Known = @()
$listener = $null
foreach ($try in 0..9) {
    try { $listener = New-Object Net.Sockets.TcpListener([Net.IPAddress]::Loopback, ($Port + $try)); $listener.Start(); $Port = $Port + $try; break }
    catch { $listener = $null }
}
if ($null -eq $listener) { throw "No free local port near $Port" }
$address = "http://127.0.0.1:$Port/"
Write-Host "Flow Scan is running: $address"
Write-Host "Read-only. Close this window (or press Ctrl+C) to stop."
if (-not $NoBrowser) {
    # no default browser (or a server without a desktop): keep running, the address is printed above
    try { Start-Process $address } catch { Write-Host "Open this address in a browser: $address" }
}
$started = Get-Date
try {
    while ($true) {
        if ($Seconds -gt 0 -and ((Get-Date) - $started).TotalSeconds -gt $Seconds) { break }
        if (-not $listener.Pending()) { Start-Sleep -Milliseconds 30; continue }
        $client = $listener.AcceptTcpClient()
        try {
            Handle-Request $client
            $script:Known = @($Conns.Keys)
        } catch {
            Write-Host "request failed: $($_.Exception.Message)"
        } finally {
            $client.Close()
        }
    }
} finally {
    foreach ($c in @($Conns.Values)) { Focas-Close $c }
    $listener.Stop()
    Write-Host 'Flow Scan stopped.'
}