Expose job state

Author: vimpostor

autoload/tpipeline.vim

@@ -311,3 +311,15 @@ func tpipeline#deferred_cleanup()
 	let s:needs_cleanup = 1
 	let s:cleanup_timer = timer_start(s:cleanup_delay, {-> tpipeline#cautious_cleanup()})
 endfunc
+
+func tpipeline#job_state()
+	let res = ""
+	if s:is_nvim
+		let pid = jobpid(s:job)
+		let res = pid ? "run as PID " . pid : "dead"
+	else
+		let res = job_status(s:job)
+	endif
+
+	return res
+endfunc

autoload/tpipeline/debug.vim

@@ -18,8 +18,9 @@ func tpipeline#debug#info()
 	let left = readfile(s:tpipeline_filepath)
 	let right = readfile(s:tpipeline_right_filepath)
 	let tmux = systemlist("tmux -V")[-1]
+	let jobstate = tpipeline#job_state()
 	let os = tpipeline#debug#os()
-	let result = #{left: left, right: right, tmux: tmux, plugin_version: tpipeline#version#string(), os: os}
+	let result = #{left: left, right: right, tmux: tmux, plugin_version: tpipeline#version#string(), job_state: jobstate, os: os}
 
 	if has('nvim')
 		let stl = g:tpipeline_statusline

lua/tpipeline/health.lua

@@ -10,6 +10,12 @@ M.check = function()
 	else
 		vim.health.report_ok("Neovim version is supported")
 	end
+
+	if vim.regex('%run'):match_str(info.job_state) == nil then
+		vim.health.report_ok("Background job is running")
+	else
+		vim.health.report_error(string.format("Background job is not running: %s", info.job_state))
+	end
 end
 
 return M

tests/test_general.vim

@@ -26,6 +26,16 @@ func Read_socket()
 	endif
 endfunc
 
+func Test_loaded()
+	call assert_equal(1, g:loaded_tpipeline)
+endfunc
+
+func Test_job_runs()
+	let job = tpipeline#debug#info()
+	" background job is still running
+	call assert_match("^run", job.job_state)
+endfunc
+
 func Strip_hl(s)
 	return substitute(a:s, '#\[[^\]]*\]', '', 'g')
 endfunc