diff options
| author | onefang | 2021-11-10 02:33:07 +1000 |
|---|---|---|
| committer | onefang | 2021-11-10 02:33:07 +1000 |
| commit | a06e989281515344c562675b8b311ae627b96661 (patch) | |
| tree | 6fc508695c3a79ab51dce928d9e66aa2a868495e | |
| parent | Add back Jessie, and promote Chimaera, and add Daedalus. (diff) | |
| download | apt-panopticon-a06e989281515344c562675b8b311ae627b96661.zip apt-panopticon-a06e989281515344c562675b8b311ae627b96661.tar.gz apt-panopticon-a06e989281515344c562675b8b311ae627b96661.tar.bz2 apt-panopticon-a06e989281515344c562675b8b311ae627b96661.tar.xz | |
io.popen returns nil sometimes, deal with that.
Diffstat (limited to '')
| -rw-r--r-- | apt-panopticommon.lua | 19 | ||||
| -rwxr-xr-x | apt-panopticon.lua | 37 |
2 files changed, 33 insertions, 23 deletions
diff --git a/apt-panopticommon.lua b/apt-panopticommon.lua index 221c7e3..9de97b4 100644 --- a/apt-panopticommon.lua +++ b/apt-panopticommon.lua | |||
| @@ -483,6 +483,17 @@ local E = APT.E | |||
| 483 | local C = APT.C | 483 | local C = APT.C |
| 484 | 484 | ||
| 485 | 485 | ||
| 486 | APT.readCmd = function(cmd) | ||
| 487 | local result = {} | ||
| 488 | local output = io.popen(cmd) | ||
| 489 | if nil ~= output then | ||
| 490 | for l in output:lines() do | ||
| 491 | table.insert(result, l) | ||
| 492 | end | ||
| 493 | end | ||
| 494 | return result | ||
| 495 | end | ||
| 496 | |||
| 486 | APT.debians = {} | 497 | APT.debians = {} |
| 487 | APT.mirrors = {} | 498 | APT.mirrors = {} |
| 488 | 499 | ||
| @@ -559,10 +570,10 @@ APT.exe = function(c) | |||
| 559 | I'm getting 7168 or 0. No idea what the fuck that is. | 570 | I'm getting 7168 or 0. No idea what the fuck that is. |
| 560 | local ok, rslt, status = os.execute(s) | 571 | local ok, rslt, status = os.execute(s) |
| 561 | ]] | 572 | ]] |
| 562 | local f = io.popen(self.cmd .. ' ; echo "$?"', 'r') | 573 | local f = APT.readCmd(self.cmd .. ' ; echo "$?"', 'r') |
| 563 | -- The last line will be the command's returned status, collect everything else in result. | 574 | -- The last line will be the command's returned status, collect everything else in result. |
| 564 | self.status = '' -- Otherwise the result starts with 0. | 575 | self.status = '' -- Otherwise the result starts with 0. |
| 565 | for l in f:lines() do | 576 | for i,l in ipairs(f) do |
| 566 | self.result = self.result .. self.status .. "\n" | 577 | self.result = self.result .. self.status .. "\n" |
| 567 | self.status = l | 578 | self.status = l |
| 568 | end | 579 | end |
| @@ -579,7 +590,9 @@ APT.exe = function(c) | |||
| 579 | end | 590 | end |
| 580 | 591 | ||
| 581 | APT.checkExes = function (exe) | 592 | APT.checkExes = function (exe) |
| 582 | local count = io.popen('ps x | grep "' .. exe .. '" | grep -v " grep " | grep -v "flock -n apt-panopticon.lock " | wc -l'):read("*l") | 593 | local count = 0 |
| 594 | local ps = io.popen('ps x | grep "' .. exe .. '" | grep -v " grep " | grep -v "flock -n apt-panopticon.lock " | wc -l') | ||
| 595 | if nil ~= ps then count = ps:read("*l") end | ||
| 583 | D(count .. " " .. exe .. " commands still running.") | 596 | D(count .. " " .. exe .. " commands still running.") |
| 584 | return tonumber(count) | 597 | return tonumber(count) |
| 585 | end | 598 | end |
diff --git a/apt-panopticon.lua b/apt-panopticon.lua index 8543210..482a2ac 100755 --- a/apt-panopticon.lua +++ b/apt-panopticon.lua | |||
| @@ -175,24 +175,21 @@ gatherIPs = function (host) | |||
| 175 | -- Takes about 30 seconds to look up the lot. | 175 | -- Takes about 30 seconds to look up the lot. |
| 176 | -- I tested using dig's -f option, it didn't seem much faster. | 176 | -- I tested using dig's -f option, it didn't seem much faster. |
| 177 | -- The sort -r assumes that deb.devuan.org is the first alphabetically. | 177 | -- The sort -r assumes that deb.devuan.org is the first alphabetically. |
| 178 | local dig = io.popen('dig +keepopen +noall +nottlid +answer ' .. host .. ' A ' .. host .. ' AAAA ' .. host .. ' CNAME ' .. host .. ' SRV | sort -r | uniq') | 178 | local dig = APT.readCmd('dig +keepopen +noall +nottlid +answer ' .. host .. ' A ' .. host .. ' AAAA ' .. host .. ' CNAME ' .. host .. ' SRV | sort -r | uniq') |
| 179 | repeat | 179 | for i,IPs in ipairs(dig) do |
| 180 | IPs = dig:read("*l") | 180 | for k, t, v in IPs:gmatch("([%w_%-%.]*)%.%s*IN%s*(%a*)%s*(.*)") do |
| 181 | if nil ~= IPs then | 181 | if "." == v:sub(-1, -1) then v = v:sub(1, -2) end |
| 182 | for k, t, v in IPs:gmatch("([%w_%-%.]*)%.%s*IN%s*(%a*)%s*(.*)") do | 182 | if nil == IP[k] then IP[k] = {} end |
| 183 | if "." == v:sub(-1, -1) then v = v:sub(1, -2) end | 183 | IP[k][v] = t |
| 184 | if nil == IP[k] then IP[k] = {} end | 184 | D(" DNS record " .. host .. " == " .. k .. " type " .. t .. " -> " .. v) |
| 185 | IP[k][v] = t | 185 | if t == "CNAME" then |
| 186 | D(" DNS record " .. host .. " == " .. k .. " type " .. t .. " -> " .. v) | 186 | gatherIPs(v) |
| 187 | if t == "CNAME" then | 187 | IP[k][v] = IP[v] |
| 188 | gatherIPs(v) | 188 | elseif v == "SRV" then |
| 189 | IP[k][v] = IP[v] | 189 | print("SVR record found, now what do we do?") |
| 190 | elseif v == "SRV" then | ||
| 191 | print("SVR record found, now what do we do?") | ||
| 192 | end | ||
| 193 | end | 190 | end |
| 194 | end | 191 | end |
| 195 | until nil == IPs | 192 | end |
| 196 | end | 193 | end |
| 197 | 194 | ||
| 198 | -- If this is the DNS-RR domain name, gather the IPs for the mirrors that mirror_list.txt says should be in it. | 195 | -- If this is the DNS-RR domain name, gather the IPs for the mirrors that mirror_list.txt says should be in it. |
| @@ -1179,8 +1176,8 @@ else | |||
| 1179 | local APT_args = APT.args | 1176 | local APT_args = APT.args |
| 1180 | local APT_logFile = APT.logFile | 1177 | local APT_logFile = APT.logFile |
| 1181 | local debians = {} | 1178 | local debians = {} |
| 1182 | local srvs = io.popen('ls -1 results/*.lua') | 1179 | local srvs = APT.readCmd('ls -1 results/*.lua') |
| 1183 | for l in srvs:lines() do | 1180 | for ii,l in ipairs(srvs) do |
| 1184 | local hst = l:sub(9, -5) | 1181 | local hst = l:sub(9, -5) |
| 1185 | if nil ~= l:find('_R%.lua') then hst = hst:sub(1, -3) end | 1182 | if nil ~= l:find('_R%.lua') then hst = hst:sub(1, -3) end |
| 1186 | if (hst:find('_') == nil) and (nil == APT.mirrors[hst]) then | 1183 | if (hst:find('_') == nil) and (nil == APT.mirrors[hst]) then |
| @@ -1197,8 +1194,8 @@ else | |||
| 1197 | end | 1194 | end |
| 1198 | end | 1195 | end |
| 1199 | end | 1196 | end |
| 1200 | local files = io.popen('ls -1 results/LOG_' .. hst .. '_*.html') | 1197 | local files = APT.readCmd('ls -1 results/LOG_' .. hst .. '_*.html') |
| 1201 | for ll in files:lines() do | 1198 | for iii,ll in ipairs(files) do |
| 1202 | local dn = false | 1199 | local dn = false |
| 1203 | for i, a in pairs(ips) do | 1200 | for i, a in pairs(ips) do |
| 1204 | if type(a) == 'table' then | 1201 | if type(a) == 'table' then |
