1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
package mill.main.graphviz
import guru.nidi.graphviz.attribute.Style
import mill.define.{Graph, NamedTask}
import org.jgrapht.graph.{DefaultEdge, SimpleDirectedGraph}
object GraphvizTools{
def apply(targets: Seq[NamedTask[Any]], rs: Seq[NamedTask[Any]], dest: os.Path) = {
val transitive = Graph.transitiveTargets(rs.distinct)
val topoSorted = Graph.topoSorted(transitive)
val goalSet = rs.toSet
val sortedGroups = Graph.groupAroundImportantTargets(topoSorted){
case x: NamedTask[Any] if goalSet.contains(x) => x
}
import guru.nidi.graphviz.engine.{Format, Graphviz}
import guru.nidi.graphviz.model.Factory._
val edgesIterator =
for((k, vs) <- sortedGroups.items())
yield (
k,
for {
v <- vs.items
dest <- v.inputs.collect { case v: NamedTask[Any] => v }
if goalSet.contains(dest)
} yield dest
)
val edges = edgesIterator.map{case (k, v) => (k, v.toArray.distinct)}.toArray
val indexToTask = edges.flatMap{case (k, vs) => Iterator(k) ++ vs}.distinct
val taskToIndex = indexToTask.zipWithIndex.toMap
val jgraph = new SimpleDirectedGraph[Int, DefaultEdge](classOf[DefaultEdge])
for(i <- indexToTask.indices) jgraph.addVertex(i)
for((src, dests) <- edges; dest <- dests) {
jgraph.addEdge(taskToIndex(src), taskToIndex(dest))
}
org.jgrapht.alg.TransitiveReduction.INSTANCE.reduce(jgraph)
val nodes = indexToTask.map(t =>
node(t.ctx.segments.render).`with`{
if(targets.contains(t)) Style.SOLID
else Style.DOTTED
}
)
var g = graph("example1").directed
for(i <- indexToTask.indices){
val outgoing = for{
e <- edges(i)._2
j = taskToIndex(e)
if jgraph.containsEdge(i, j)
} yield nodes(j)
g = g.`with`(nodes(i).link(outgoing:_*))
}
val gv = Graphviz.fromGraph(g).totalMemory(100 * 1000 * 1000)
val outputs = Seq(
Format.PLAIN -> "out.txt",
Format.XDOT -> "out.dot",
Format.JSON -> "out.json",
Format.PNG -> "out.png",
Format.SVG -> "out.svg"
)
for((fmt, name) <- outputs) {
gv.render(fmt).toFile((dest / name).toIO)
}
outputs.map(x => mill.PathRef(dest / x._2))
}
}
|
