Exit 1 when check error

script/cli/check.lua

@@ -5,97 +5,104 @@ local json       = require 'json'
 local jsonb      = require 'json-beautify'
 local util       = require 'utility'
 
+local export = {}
 
-local numThreads = tonumber(NUM_THREADS or 1)
+function export.runCLI()
+    local numThreads = tonumber(NUM_THREADS or 1)
 
-local exe
-local minIndex = -1
-while arg[minIndex] do
-    exe = arg[minIndex]
-    minIndex = minIndex - 1
-end
--- TODO: is this necessary? got it from the shell.lua helper in bee.lua tests
-if platform.os == 'windows' and not exe:match('%.[eE][xX][eE]$') then
-    exe = exe..'.exe'
-end
+    local exe
+    local minIndex = -1
+    while arg[minIndex] do
+        exe = arg[minIndex]
+        minIndex = minIndex - 1
+    end
+    -- TODO: is this necessary? got it from the shell.lua helper in bee.lua tests
+    if platform.os == 'windows' and not exe:match('%.[eE][xX][eE]$') then
+        exe = exe..'.exe'
+    end
 
-local function logFileForThread(threadId)
-    return LOGPATH .. '/check-partial-' .. threadId .. '.json'
-end
+    local function logFileForThread(threadId)
+        return LOGPATH .. '/check-partial-' .. threadId .. '.json'
+    end
 
-local function buildArgs(threadId)
-    local args = {exe}
-    local skipNext = false
-    for i = 1, #arg do
-        local arg = arg[i]
-        -- --check needs to be transformed into --check_worker
-        if arg:lower():match('^%-%-check$') or arg:lower():match('^%-%-check=') then
-            args[#args + 1] = arg:gsub('%-%-%w*', '--check_worker')
-        -- --check_out_path needs to be removed if we have more than one thread
-        elseif arg:lower():match('%-%-check_out_path') and numThreads > 1 then
-            if not arg:match('%-%-%w*=') then
-                skipNext = true
-            end
-        else
-            if skipNext then
-                skipNext = false
+    local function buildArgs(threadId)
+        local args = {exe}
+        local skipNext = false
+        for i = 1, #arg do
+            local arg = arg[i]
+            -- --check needs to be transformed into --check_worker
+            if arg:lower():match('^%-%-check$') or arg:lower():match('^%-%-check=') then
+                args[#args + 1] = arg:gsub('%-%-%w*', '--check_worker')
+            -- --check_out_path needs to be removed if we have more than one thread
+            elseif arg:lower():match('%-%-check_out_path') and numThreads > 1 then
+                if not arg:match('%-%-%w*=') then
+                    skipNext = true
+                end
             else
-                args[#args + 1] = arg
+                if skipNext then
+                    skipNext = false
+                else
+                    args[#args + 1] = arg
+                end
             end
         end
+        args[#args + 1] = '--thread_id'
+        args[#args + 1] = tostring(threadId)
+        if numThreads > 1 then
+            args[#args + 1] = '--quiet'
+            args[#args + 1] = '--check_out_path'
+            args[#args + 1] = logFileForThread(threadId)
+        end
+        return args
     end
-    args[#args + 1] = '--thread_id'
-    args[#args + 1] = tostring(threadId)
+
     if numThreads > 1 then
-        args[#args + 1] = '--quiet'
-        args[#args + 1] = '--check_out_path'
-        args[#args + 1] = logFileForThread(threadId)
+        print(lang.script('CLI_CHECK_MULTIPLE_WORKERS', numThreads))
     end
-    return args
-end
 
-if numThreads > 1 then
-    print(lang.script('CLI_CHECK_MULTIPLE_WORKERS', numThreads))
-end
-
-local procs = {}
-for i = 1, numThreads do
-    local process, err = subprocess.spawn({buildArgs(i)})
-    if err then
-        print(err)
-    end
-    if process then
-        procs[#procs + 1] = process
+    local procs = {}
+    for i = 1, numThreads do
+        local process, err = subprocess.spawn({buildArgs(i)})
+        if err then
+            print(err)
+        end
+        if process then
+            procs[#procs + 1] = process
+        end
     end
-end
 
-for _, process in ipairs(procs) do
-    process:wait()
-end
+    local checkPassed = true
+    for _, process in ipairs(procs) do
+        checkPassed = process:wait() == 0 and checkPassed
+    end
 
-local outpath = CHECK_OUT_PATH
-if outpath == nil then
-    outpath = LOGPATH .. '/check.json'
-end
+    local outpath = CHECK_OUT_PATH
+    if outpath == nil then
+        outpath = LOGPATH .. '/check.json'
+    end
 
-if numThreads > 1 then
-    local mergedResults = {}
-    local count = 0
-    for i = 1, numThreads do
-        local result = json.decode(util.loadFile(logFileForThread(i)) or '[]')
-        for k, v in pairs(result) do
-            local entries = mergedResults[k] or {}
-            mergedResults[k] = entries
-            for _, entry in ipairs(v) do
-                entries[#entries + 1] = entry
-                count = count + 1
+    if numThreads > 1 then
+        local mergedResults = {}
+        local count = 0
+        for i = 1, numThreads do
+            local result = json.decode(util.loadFile(logFileForThread(i)) or '[]')
+            for k, v in pairs(result) do
+                local entries = mergedResults[k] or {}
+                mergedResults[k] = entries
+                for _, entry in ipairs(v) do
+                    entries[#entries + 1] = entry
+                    count = count + 1
+                end
             end
         end
+        util.saveFile(outpath, jsonb.beautify(mergedResults))
+        if count == 0 then
+            print(lang.script('CLI_CHECK_SUCCESS'))
+        else
+            print(lang.script('CLI_CHECK_RESULTS', count, outpath))
+        end
     end
-    util.saveFile(outpath, jsonb.beautify(mergedResults))
-    if count == 0 then
-        print(lang.script('CLI_CHECK_SUCCESS'))
-    else
-        print(lang.script('CLI_CHECK_RESULTS', count, outpath))
-    end
+    return checkPassed and 0 or 1
 end
+
+return export