Module:LabProcess/Progress - Revision history

Simon Stier: add sparql query

2022-07-11T05:02:51Z

add sparql query

Simon Stier: adapt filter and labels

2022-07-09T17:20:07Z

adapt filter and labels

Simon Stier at 12:04, 9 July 2022

2022-07-09T12:04:36Z

Simon Stier: filter objects

2022-07-09T12:02:57Z

filter objects

Simon Stier: fix dimension, query for final process outputs

2022-07-09T07:39:46Z

fix dimension, query for final process outputs

Simon Stier: import from DevWiki

2022-07-08T05:57:40Z

import from DevWiki

New page

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

function p.GetProcessesGraph()
local process_types = {"LabProcess:OSL9a645a64b15442398ad3c057e1b64d87", "LabProcess:OSL4c1f7444e389471a8250f53407191735"}
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
nodes = nodes .. '"' .. obj_id .. '" [label="' .. obj['local_id'] .. '"];'
if (obj['successor_object'] ~= nil) then
for succ_id, succ in pairs(obj['successor_object']) 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)
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

return results
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 |format=plain"
local result = mw.smw.ask( query )
return result
end

return p

@@ Line 2: / Line 2: @@
 -- Module:SMW
 local p = {}
+local linkedwiki = require 'linkedwiki'
 function p.GetProcessesGraph()
 	local process_types = {"LabProcess:OSL9a645a64b15442398ad3c057e1b64d87", "LabProcess:OSL4c1f7444e389471a8250f53407191735", "LabProcess:OSLd0c734a239844a0d8820856add12aeca"}
@@ Line 191: / Line 191: @@
 end
 -- expands single values for properties to tables with len 1
 function p.toTable(v)

@@ Line 15: / Line 15: @@
 	rankdir=LR
 ]]
 	for id,process in pairs(result) do
 		--mw.logObject(process)
 		local nodes = ""
-		local edges = ""
+		local nodes2 = ""
 		for obj_id, obj in pairs(process['objects']) do
 			if p.IsGlobalObject(obj) then
 			local successors = nil
-			successors = p.concatTables(obj['successor_object'], obj['successor_object_semistatic'])
+			successors = p.concatTables(obj['successor_object'], obj['successor_object_static'])
-			successors = p.concatTables(successors, obj['successor_object_static'])
+			--if (successors == nil) then successors = p.toTable(obj['successor_object_semistatic']) end
 			successors = p.removeDuplicates(successors)
 			obj['successors'] = successors
@@ Line 37: / Line 38: @@
 			--	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];
+		node [shape=rect];
 		label = "]] .. process['label'] .. [[";
 		color=blue;
 		]] .. nodes .. [[
+	}
 ]]
 	end
 	g = g .. [[
 }]]
 	d:wikitext(g)
@@ Line 108: / Line 117: @@
 					local isGlobal = p.IsGlobalObject(obj)
 					if isGlobal == false then
-						mw.log("Follow " .. obj_id)
+						--mw.log("Follow " .. obj_id)
 						p.concatTables(result,p.GetNextGlobalObject(dataset, obj))
 					elseif (succ ~= nil) then
-						mw.log("Found " .. succ)
+						--mw.log("Found " .. succ)
 						table.insert(result, succ)
 					end
@@ Line 123: / Line 132: @@
 function p.IsGlobalObject(obj)
 	local isGlobal = false
-	for type_id, type in pairs(obj['type']) do
+	local visible_types = {"Material:OSL344e5c0f20e04894abe53678e2f68351"}
-		if (type == "Category:LabProcessOutput") then isGlobal = true end
+	for category_id, category in pairs(p.toTable(obj['category'])) do
 	end
 	return isGlobal
@@ Line 137: / Line 154: @@
 		|?#-=id
 		|?HasId#-=local_id
 		|?-HasPredecessor#-=successor_param
 		|?-HasPredecessor.IsProcessParameterOf#-=successor_subprocess
@@ Line 157: / Line 175: @@
 		|?#-=id
 		|?HasId#-=local_id
 		|?-HasPredecessor.IsProcessParameterOf.HasOutput#-=successor_object_semistatic
 		|?-HasPredecessor.IsObjectParameterOf#-=successor_object
 		|?-HasInput.HasOutput#-=successor_object_static
-		|?Category#-=type
+		|?Category#-=category
 		|format=plain
 		|limit=10000
@@ Line 196: / Line 217: @@
 	end
 	return t1
 end

@@ Line 21: / Line 21: @@
 		for obj_id, obj in pairs(process['objects']) do
-			--if p.IsGlobalObject(obj) then
+			if p.IsGlobalObject(obj) then
 			nodes = nodes .. '"' .. obj_id .. '" [label="' .. obj['local_id'] .. '" href="/wiki/' .. obj_id .. '"];'
-			--end
+			end
 			local successors = nil
 			successors = p.concatTables(obj['successor_object'], obj['successor_object_semistatic'])

@@ Line 5: / Line 5: @@
 function p.GetProcessesGraph()
 	local process_types = {"LabProcess:OSL9a645a64b15442398ad3c057e1b64d87", "LabProcess:OSL4c1f7444e389471a8250f53407191735", "LabProcess:OSLd0c734a239844a0d8820856add12aeca"}
 	local result = p.GetProcesses(process_types)
 	--mw.logObject(result)
@@ Line 19: / Line 20: @@
 		local edges = ""
 		for obj_id, obj in pairs(process['objects']) do
-			nodes = nodes .. '"' .. obj_id .. '" [label="' .. obj['local_id'] .. '" href="https://kiprobatt.de/wiki/' .. obj_id .. '"];'
 			local successors = nil
-			if (obj['successor_object'] ~= nil) then
+			successors = p.concatTables(obj['successor_object'], obj['successor_object_semistatic'])
-				successors = p.NormalizePropertyValue(obj['successor_object']);
+			successors = p.concatTables(successors, obj['successor_object_static'])
-			end
+			successors = p.removeDuplicates(successors)
-			if (obj['successor_process_output'] ~= nil) then
+			obj['successors'] = successors
-				_successors = p.NormalizePropertyValue(obj['successor_process_output']);
+			successors = p.GetNextGlobalObject(result, obj);
-				if (p.tablelength(_successors) == 1) then successors = _successors end
+			--if (obj['successor_object'] ~= nil) then
-			end
+			--	successors = p.toTable(obj['successor_object']);
 			if (successors ~= nil) then
 				for succ_id, succ in pairs(successors) do
@@ Line 33: / Line 42: @@
 				end
 			end
 		end
 		g = g .. [[
@@ Line 61: / Line 71: @@
 		results[process_type] = {}
 		results[process_type]['objects'] = {}
-     	result = p.GetOutputs(process_type)
+     	--result = p.GetOutputs(process_type)
      	if (result ~= nil) then
 	    	for index, obj in pairs(result) do
@@ Line 85: / Line 96: @@
      --mw.logObject(results)
 	return results
 end
@@ Line 104: / Line 146: @@
 	]]
 	local result = mw.smw.ask( query )
-	mw.logObject(result)
+	--mw.logObject(result)
 	return result
 end
 -- expands single values for properties to tables with len 1
-function p.NormalizePropertyValue(v)
+function p.toTable(v)
 	if (type(v) ~= "table") then
 		v = {v}
@@ Line 120: / Line 183: @@
    for _ in pairs(T) do count = count + 1 end
    return count
 end
 return p