' | Select-String '>[IciC_]{4}<' | ForEach-Object {
$RAW = $_
if ($RAW -Match '(\d{1,3}\.){3}\d{1,3}:\d{1,5}') {
$ip_address = $Matches[0].Split(':')[0]
$peer_port = $Matches[0].Split(':')[1]
switch -Regex ($ip_address) {
'^10\.' {return}
'^172\.(1[6-9]|2[0-9]|3[01])\.' {return}
'^192\.168\.' {return}
'^100\.(6[4-9]|[7-9][0-9]|1[01][0-9]|12[0-7])\.' {return}
'^127\.' {return}
'^169\.254\.' {return}
}
} elseif ($RAW -Match '[0-9a-f]{4}:([0-9a-f]{1,4}):(:?[0-9a-f]{1,4}:?){1,6}:?:\d{1,5}') {
$ip_address = $Matches[0] -Replace ':[0-9]{1,5}$'
$peer_port = ($Matches[0] -Split ':')[-1]
if ($ip_address -Notmatch '^2') {return}
} else {
Write-Host (Get-Date) [ 无法识别的 IP 地址，记录原始数据至 UNKNOWN.txt ] -ForegroundColor Yellow
[String](Get-Date) + ' 无法识别的 IP 地址' | Out-File -Append $USERPATH\UNKNOWN.txt
[String](Get-Date) + ' ' + $RAW | Out-File -Append $USERPATH\UNKNOWN.txt
if ((Get-Content $USERPATH\UNKNOWN.txt -ErrorAction Ignore).Count -ge 1000) {
Move-Item $USERPATH\UNKNOWN.txt $USERPATH\UNKNOWN.txt.old -Force -ErrorAction Ignore
Write-Host (Get-Date) [ UNKNOWN.txt 达到 1000 行，已转存为 UNKNOWN.txt.old ] -ForegroundColor Yellow
}
return
}
if ($RAW -Match '[0-9a-f]{40}') {
$peer_id = -Join ($Matches[0].SubString(0,16) -Replace '(..)','[char]0x${0};'| Invoke-Expression)
} else {
$peer_id = ""
}
$RAW -Match '(?<=\d:\d\d:\d\d<\/td>| ).*?(?=<)' | Out-Null
if ($Matches[0] -Match 'n/a') {
$client_name = ""
} else {
$client_name = $Matches[0]
}
$downloaded = Invoke-Expression ((([Regex]::Matches($RAW,'(?<=>)\d*\.?\d* [KMGTPEZY]?B(?=<)')).Value[0]) -Replace ' |,')
$uploaded = Invoke-Expression ((([Regex]::Matches($RAW,'(?<=>)\d*\.?\d* [KMGTPEZY]?B(?=<)')).Value[1]) -Replace ' |,')
$peer_progress = Get-QuadFloat ([Regex]::Matches($RAW ,'\d*.?\d%'))
$BCFLAGS = [Regex]::Matches($RAW,'(?<=>)[IciC_]{4}(?=<)').Value
$peer_flag = ""
switch -Regex ($BCFLAGS) {
'Ic..' {$peer_flag = $peer_flag + 'd '}
'I_..' {$peer_flag = $peer_flag + 'D '}
'__..' {$peer_flag = $peer_flag + 'K '}
}
switch -Regex ($BCFLAGS) {
'..iC' {$peer_flag = $peer_flag + 'u '}
'..i_' {$peer_flag = $peer_flag + 'U '}
'..__' {$peer_flag = $peer_flag + '? '}
}
if ($RAW -Match 'Remote') {
$peer_flag = $peer_flag + 'I'
} else {
$peer_flag = $peer_flag -Replace ' $'
}
$RATESTR = $RAW -Replace '(Remote|Local).*'
$RATEVAL = [Regex]::Matches($RATESTR,'(?<=>)\d*\.?\d* [KMGTPEZY]?B\/s(?=<)')
switch ($RATEVAL.Count) {
0 {
$rt_download_speed = 0
$rt_upload_speed = 0
}
1 {
if (($peer_progress -eq 1 -or $peer_flag -Cmatch 'D|u' -or $peer_flag -Cnotmatch 'K|U') -and $downloader_progress -ne 1) {
$rt_download_speed = Invoke-Expression ($RATEVAL[0].Value -Replace ' |,|/s')
$rt_upload_speed = 0
} else {
$rt_download_speed = 0
$rt_upload_speed = Invoke-Expression ($RATEVAL[0].Value -Replace ' |,|/s')
}
}
2 {
$rt_download_speed = Invoke-Expression ($RATEVAL[0].Value -Replace ' |,|/s')
$rt_upload_speed = Invoke-Expression ($RATEVAL[1].Value -Replace ' |,|/s')
}
}
try {
$PEERHASH = @{
ip_address = $ip_address
peer_port = [Int]$peer_port
peer_id = $peer_id
client_name = $client_name
torrent_identifier = $torrent_identifier
torrent_size = [Math]::Round($torrent_size)
downloaded = [Math]::Round($downloaded)
rt_download_speed = [Math]::Round($rt_download_speed)
uploaded = [Math]::Round($uploaded)
rt_upload_speed = [Math]::Round($rt_upload_speed)
peer_progress = [decimal]$peer_progress
downloader_progress = [decimal]$downloader_progress
peer_flag = $peer_flag -Replace ' $'
}
$SUBMITHASH.peers += $PEERHASH
} catch {
Write-Host (Get-Date) [ 格式错误的 Peer 信息，记录原始数据至 UNKNOWN.txt ] -ForegroundColor Yellow
[String](Get-Date) + ' ' + $_.Exception.Message | Out-File -Append $USERPATH\UNKNOWN.txt
[String](Get-Date) + ' ' + $RAW | Out-File -Append $USERPATH\UNKNOWN.txt
[String](Get-Date) + " {torrent_identifier = $torrent_identifier, torrent_size = $torrent_size, downloader_progress = $downloader_progress}" | Out-File -Append $USERPATH\UNKNOWN.txt
if ((Get-Content $USERPATH\UNKNOWN.txt -ErrorAction Ignore).Count -ge 1000) {
Move-Item $USERPATH\UNKNOWN.txt $USERPATH\UNKNOWN.txt.old -Force -ErrorAction Ignore
Write-Host (Get-Date) [ UNKNOWN.txt 达到 1000 行，已转存为 UNKNOWN.txt.old ] -ForegroundColor Yellow
}
}
}
}
# 获取活动任务列表，并调用上述函数传递 URL 参数获取 Peers 哈希表
# Peers 哈希表转换为 JSON 保存
function Get-PeersJson {
Write-Host (Get-Date) [ 开始提交 Peers 快照... ] -ForegroundColor Cyan
Test-WebUIPort
try {
$ACTIVE = ((Invoke-RestMethod -TimeoutSec 15 -Credential $UIAUTH ${UIHOME}task_list) -Split '<.?tr>' -Replace '> (HTTPS|HTTP|FTP) <.*' -Split "'" | Select-String '.*action=stop') -Split '&|=' | Select-String '.*\d' | ForEach-Object {"${UIHOME}task_detail?id=" + $_}
} catch {
Write-Host (Get-Date) [ $_ ] -ForegroundColor Red
Write-Host (Get-Date) [ 获取任务列表超时，跳过本次提交 ] -ForegroundColor Yellow
$Global:SUBMIT = 0
return
}
Write-Host (Get-Date) [ 分析 $ACTIVE.Count 个活动任务 ] -ForegroundColor Cyan
$SUBMITHASH = @"
{
"populate_time": $([DateTimeOffset]::Now.ToUnixTimeMilliseconds()),
"peers": []
}
"@ | ConvertFrom-Json
$ACTIVE | ForEach-Object {Get-TaskPeers $_}
Write-Host (Get-Date) [ 提取 $($SUBMITHASH.peers.Count) 个活动 Peers，耗时 $((([DateTimeOffset]::Now.ToUnixTimeMilliseconds()) - $SUBMITHASH.populate_time) / 1000) 秒 ] -ForegroundColor Cyan
if ($SUBMITHASH.peers.Count -eq 0) {
$Global:SUBMIT = 0
return
}
$SUBMITHASH | ConvertTo-Json | Out-File $PEERSJSON
$Global:SUBMIT = 1
}
# JSON 打包为 Gzip 并提交至 BTN 服务器
$PEERSJSON = "$USERPATH\PEERS.json"
$PEERSGZIP = "$USERPATH\PEERS.gzip"
function Invoke-SumbitPeers {
if ($SUBMIT -eq 0) {
Write-Host (Get-Date) [ 没有需要提交的数据 ] -ForegroundColor Green
return
}
$JSONSTREAM = New-Object System.IO.FileStream($PEERSJSON,([IO.FileMode]::Open),([IO.FileAccess]::Read),([IO.FileShare]::Read))
$GZIPSTREAM = New-Object System.IO.FileStream($PEERSGZIP,([IO.FileMode]::Create),([IO.FileAccess]::Write),([IO.FileShare]::None))
$GZIPBUFFER = New-Object System.IO.Compression.GZipStream($GZIPSTREAM,[System.IO.Compression.CompressionMode]::Compress)
$JSONSTREAM.CopyTo($GZIPBUFFER)
$GZIPBUFFER.Dispose()
$JSONSTREAM.Dispose()
$GZIPSTREAM.Dispose()
$GZIPLENGTH = [Regex]::Matches(((Get-Item $PEERSGZIP).Length / 1KB),'\d*\.?\d')[0].Value
if ($GZIPLENGTH -Notmatch '\.\d') {$GZIPLENGTH = $GZIPLENGTH + '.0'}
try {
Invoke-RestMethod -TimeoutSec 30 -UserAgent $USERAGENT -Headers ($AUTHHEADS + @{"Content-Encoding"="gzip"; "Content-Type"="application/json"}) -Method Post -InFile $PEERSGZIP $NEWCONFIG.ability.submit_peers.endpoint | Out-Null
Write-Host (Get-Date) [ 提交 Peers 快照成功，数据大小 $GZIPLENGTH KiB ] -ForegroundColor Green
} catch {
Get-ErrorMessage
Write-Host (Get-Date) [ $_ ] -ForegroundColor Red
Write-Host (Get-Date) [ 提交 Peers 快照失败，数据大小 $GZIPLENGTH KiB ] -ForegroundColor Yellow
}
Remove-Item $PEERSGZIP
}
# 首次启动时，先获取 BTN 服务器配置，并添加下次执行时间
# 遵守 BTN 规范的首次随机延迟要求
# 以下循环工作流程
# 1. 按照下次执行时间排列任务
# 2. 等待并执行最近的一个（排列首位的）任务
# 3. 执行完成后，安排下次时间，回到 1.
# 当 BTN 服务器配置的间隔要求发生变化时，重新配置下次执行时间
Write-Host (Get-Date) [ BTNScriptBC 开始循环工作 ] -ForegroundColor Cyan
while ($True) {
Get-Job | Remove-Job -Force
$Global:JOBFLAG = 0
if (!$NOWCONFIG) {
Get-BTNConfig
$Menu_Peer.Enabled = $True
$Menu_Conf.Enabled = $True
$Menu_Show.Enabled = $True
}
if (
$NOWCONFIG.ability.submit_peers.interval -ne $NEWCONFIG.ability.submit_peers.interval -or
$NOWCONFIG.ability.reconfigure.interval -ne $NEWCONFIG.ability.reconfigure.interval
) {
$NOWCONFIG = $NEWCONFIG
$NOWCONFIG.ability.PSObject.Properties.Name | ForEach-Object {
$DELAY = Get-Random -Maximum $NOWCONFIG.ability.$_.random_initial_delay
$NOWCONFIG.ability.$_ | Add-Member next ((Get-Date) + (New-TimeSpan -Seconds (($NOWCONFIG.ability.$_.interval + $DELAY) / 1000)))
}
$NOWCONFIG.ability.submit_peers | Add-Member cmd "Get-PeersJson; Invoke-SumbitPeers"
$NOWCONFIG.ability.reconfigure | Add-Member cmd "Get-BTNConfig"
Write-Host (Get-Date) [ 每 $($NOWCONFIG.ability.submit_peers.interval / 1000) 秒提交 Peers 快照 ] -ForegroundColor Cyan
Write-Host (Get-Date) [ 每 $($NOWCONFIG.ability.reconfigure.interval / 1000) 秒查询 BTN 服务器配置更新 ] -ForegroundColor Cyan
}
[System.GC]::Collect()
$JOBLIST = $NOWCONFIG.ability.PSObject.Properties.Value | Sort-Object next
if (!$JOBLIST[0].cmd) {$JOBLIST[0].next = ((Get-Date) + (New-TimeSpan -Hours $JOBLIST[0].interval)); continue}
if ((Get-Date) -lt $JOBLIST[0].next) {
Start-Job {Start-Sleep ($Using:JOBLIST[0].next - (Get-Date)).TotalSeconds} | Out-Null
Get-Job | Wait-Job | Out-Null
}
switch ($JOBFLAG) {
0 {Invoke-Expression $JOBLIST[0].cmd; $JOBLIST[0].next = ((Get-Date) + (New-TimeSpan -Seconds ($JOBLIST[0].interval / 1000)))}
1 {continue}
2 {Remove-Variable NOWCONFIG -ErrorAction Ignore}
}
}
|