Progress

Documentation for this module may be created at Module:LabProcess/Progress/doc

-- creates an overview over a process chain
-- Module:SMW
local p = {}

function p.GetProcessesGraph()
	local process_types = {"LabProcess:OSL9a645a64b15442398ad3c057e1b64d87", "LabProcess:OSL4c1f7444e389471a8250f53407191735", "LabProcess:OSLd0c734a239844a0d8820856add12aeca"}
	--local process_types = {"LabProcess:OSL4c1f7444e389471a8250f53407191735", "LabProcess:OSLd0c734a239844a0d8820856add12aeca"}
	local result = p.GetProcesses(process_types)
	--mw.logObject(result)
	
	local d = mw.html.create( 'div' )
	d:attr( 'class', 'graphviz' )
	local g = [[
digraph G {
	rankdir=LR
]]
	for id,process in pairs(result) do
		--mw.logObject(process)
		local nodes = ""
		local edges = ""
		for obj_id, obj in pairs(process['objects']) do
			
			--if p.IsGlobalObject(obj) then
			nodes = nodes .. '"' .. obj_id .. '" [label="' .. obj['local_id'] .. '" href="/wiki/' .. obj_id .. '"];' 
			--end
			local successors = nil
			successors = p.concatTables(obj['successor_object'], obj['successor_object_semistatic'])
			successors = p.concatTables(successors, obj['successor_object_static'])
			successors = p.removeDuplicates(successors)
			obj['successors'] = successors
			successors = p.GetNextGlobalObject(result, obj);
			--if (obj['successor_object'] ~= nil) then 
			--	successors = p.toTable(obj['successor_object']);
			--end
			--if (obj['successor_process_output'] ~= nil) then 
			--	_successors = p.toTable(obj['successor_process_output']);
			--	if (p.tablelength(_successors) == 1) then successors = _successors end
			--end
			if (successors ~= nil) then 
				for succ_id, succ in pairs(successors) do
					edges = edges .. '"' .. obj_id .. '" -> "' .. succ .. '";' 
				end
			end

		end
		g = g .. [[
	subgraph cluster_]] .. id:gsub(":","_") .. [[ {
		node [style=filled];
		label = "]] .. process['label'] .. [[";
		color=blue;
		]] .. nodes .. [[
		
	}
	]] .. edges .. [[
	
]]
	end
	g = g .. [[
}]]
	d:wikitext(g)
	mw.logObject(d)
	return tostring( d )
		
end
	
function p.GetProcesses(process_types)

	local results = {}

	for key,process_type in pairs(process_types) do
		results[process_type] = {}
		results[process_type]['objects'] = {}
    	--result = p.GetOutputs(process_type)
    	result = p.GetProcessObjects(process_type)
    	if (result ~= nil) then
	    	for index, obj in pairs(result) do
	    		--mw.logObject(obj['id'])
	    		results[process_type]['objects'][obj['id']] = obj
	    	end
	    end
	end
	
	local process_type_query = "[[" .. table.concat(process_types, "]] OR [[") .. "]]"
	process_type_query = process_type_query .. " |?Display title of#-=label |?#-=process_type |?HasId#-=id |format=plain"
	--mw.logObject(process_type_query)
	local process_type_infos = mw.smw.ask( process_type_query )
	for key,process_type_info in pairs(process_type_infos) do
		--mw.logObject(process_type_info)
		process_type = process_type_info['process_type']
		if (process_type ~= nil) then
			for k,v in pairs(process_type_info) do 
				if (k ~= "process_type") then results[process_type][k] = v end 
			end
		end
    end
    --mw.logObject(results)
	return results
end

function p.GetNextGlobalObject(dataset, src_obj)
	if (src_obj['successors'] == nil) then return nil end
	local result = {}
	for id,process in pairs(dataset) do
		for obj_id, obj in pairs(process['objects']) do
			for succ_id, succ in pairs(src_obj['successors']) do
				--mw.log("Compare " .. obj_id .. " with " .. succ)
				if obj_id == succ then 
					local isGlobal = p.IsGlobalObject(obj)
					if isGlobal == false then 
						mw.log("Follow " .. obj_id)
						p.concatTables(result,p.GetNextGlobalObject(dataset, obj)) 
					elseif (succ ~= nil) then 
						mw.log("Found " .. succ)
						table.insert(result, succ) 
					end
				end
			end
		end
	end
	return result
end

function p.IsGlobalObject(obj)
	local isGlobal = false
	for type_id, type in pairs(obj['type']) do
		if (type == "Category:LabProcessOutput") then isGlobal = true end
	end
	return isGlobal
end

function p.GetOutputs(process_type)
	--mw.logObject(obj)
	-- please note the unlinking of properties 'page authors', and mainlabel '?' by using the #- operator
	-- note also: unlinking via parameter link is not supported at this point
	--local process_type = "LabProcess:OSL9a645a64b15442398ad3c057e1b64d87"
	local query = "[[Category:LabProcessOutput]] [[-HasObject.IsInstanceOf::" .. process_type .. "]] " .. [[
		|?#-=id 
		|?HasId#-=local_id 
		|?-HasPredecessor#-=successor_param 
		|?-HasPredecessor.IsProcessParameterOf#-=successor_subprocess 
		|?-HasPredecessor.IsObjectParameterOf#-=successor_object 
		|?-HasPredecessor.IsProcessParameterOf.IsSubprocessOf#-=successor_process 
		|?-HasPredecessor.IsProcessParameterOf.IsSubprocessOf.-IsOutputOf#-=successor_process_output
		|format=plain
		|limit=10000
	]]
	local result = mw.smw.ask( query )
	--mw.logObject(result)
	return result
end

function p.GetProcessObjects(process_types)
	--local process_types = {"LabProcess:OSL9a645a64b15442398ad3c057e1b64d87", "LabProcess:OSL4c1f7444e389471a8250f53407191735", "LabProcess:OSLd0c734a239844a0d8820856add12aeca"}
	process_types = p.toTable(process_types)
	local query = "[[-HasObject.IsInstanceOf::" .. table.concat(process_types, "]] OR [[-HasObject.IsInstanceOf::") .. "]]"
	query = query .. [[
		|?#-=id 
		|?HasId#-=local_id 
		|?-HasPredecessor.IsProcessParameterOf.HasOutput#-=successor_object_semistatic
		|?-HasPredecessor.IsObjectParameterOf#-=successor_object
		|?-HasInput.HasOutput#-=successor_object_static
		|?Category#-=type
		|format=plain
		|limit=10000
	]]
	local result = mw.smw.ask( query )
	--mw.logObject(result)
	
	return result
end

-- expands single values for properties to tables with len 1
function p.toTable(v)
	if (v == nil) then return nil end
	if (type(v) ~= "table") then
		v = {v}
	end
	return v	
end

function p.tablelength(T)
  local count = 0
  for _ in pairs(T) do count = count + 1 end
  return count
end

function p.concatTables(t1,t2)
	t1 = p.toTable(t1)
	t2 = p.toTable(t2)
	if (t1 == nil) then 
		t1 = t2
	elseif (t2 ~= nil) then
		for _,v in ipairs(t2) do 
	    	table.insert(t1, v)
	    end
	end
	return t1
end

function p.removeDuplicates(t)
	if (t == nil) then return nil end
	local hash = {}
	local res = {}
	for _,v in ipairs(t) do
		if (not hash[v]) then
			res[#res+1] = v
			hash[v] = true
		end
	end	
	return res
end

return p