254 lines
4.4 KiB
Go
254 lines
4.4 KiB
Go
package dag
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
func TestGraphDot_empty(t *testing.T) {
|
|
var g Graph
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
|
|
actual := strings.TrimSpace(string(g.Dot(nil)))
|
|
expected := strings.TrimSpace(testGraphDotEmptyStr)
|
|
if actual != expected {
|
|
t.Fatalf("bad: %s", actual)
|
|
}
|
|
}
|
|
|
|
func TestGraphDot_basic(t *testing.T) {
|
|
var g Graph
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
g.Connect(BasicEdge(1, 3))
|
|
|
|
actual := strings.TrimSpace(string(g.Dot(nil)))
|
|
expected := strings.TrimSpace(testGraphDotBasicStr)
|
|
if actual != expected {
|
|
t.Fatalf("bad: %s", actual)
|
|
}
|
|
}
|
|
|
|
const testGraphDotBasicStr = `digraph {
|
|
compound = "true"
|
|
newrank = "true"
|
|
subgraph "root" {
|
|
"[root] 1" -> "[root] 3"
|
|
}
|
|
}
|
|
`
|
|
|
|
const testGraphDotEmptyStr = `digraph {
|
|
compound = "true"
|
|
newrank = "true"
|
|
subgraph "root" {
|
|
}
|
|
}`
|
|
|
|
func TestGraphJSON_empty(t *testing.T) {
|
|
var g Graph
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
|
|
js, err := g.MarshalJSON()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
actual := strings.TrimSpace(string(js))
|
|
expected := strings.TrimSpace(testGraphJSONEmptyStr)
|
|
if actual != expected {
|
|
t.Fatalf("bad: %s", actual)
|
|
}
|
|
}
|
|
|
|
func TestGraphJSON_basic(t *testing.T) {
|
|
var g Graph
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
g.Connect(BasicEdge(1, 3))
|
|
|
|
js, err := g.MarshalJSON()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
actual := strings.TrimSpace(string(js))
|
|
expected := strings.TrimSpace(testGraphJSONBasicStr)
|
|
if actual != expected {
|
|
t.Fatalf("bad: %s", actual)
|
|
}
|
|
}
|
|
|
|
// record some graph transformations, and make sure we get the same graph when
|
|
// they're replayed
|
|
func TestGraphJSON_basicRecord(t *testing.T) {
|
|
var g Graph
|
|
var buf bytes.Buffer
|
|
g.SetDebugWriter(&buf)
|
|
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
g.Connect(BasicEdge(1, 2))
|
|
g.Connect(BasicEdge(1, 3))
|
|
g.Connect(BasicEdge(2, 3))
|
|
(&AcyclicGraph{g}).TransitiveReduction()
|
|
|
|
recorded := buf.Bytes()
|
|
// the Walk doesn't happen in a determined order, so just count operations
|
|
// for now to make sure we wrote stuff out.
|
|
if len(bytes.Split(recorded, []byte{'\n'})) != 17 {
|
|
t.Fatalf("bad: %s", recorded)
|
|
}
|
|
|
|
original, err := g.MarshalJSON()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
// replay the logs, and marshal the graph back out again
|
|
m, err := decodeGraph(bytes.NewReader(buf.Bytes()))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
replayed, err := json.MarshalIndent(m, "", " ")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
if !bytes.Equal(original, replayed) {
|
|
t.Fatalf("\noriginal: %s\nreplayed: %s", original, replayed)
|
|
}
|
|
}
|
|
|
|
// Verify that Vertex and Edge annotations appear in the debug output
|
|
func TestGraphJSON_debugInfo(t *testing.T) {
|
|
var g Graph
|
|
var buf bytes.Buffer
|
|
g.SetDebugWriter(&buf)
|
|
|
|
g.Add(1)
|
|
g.Add(2)
|
|
g.Add(3)
|
|
g.Connect(BasicEdge(1, 2))
|
|
|
|
g.DebugVertexInfo(2, "2")
|
|
g.DebugVertexInfo(3, "3")
|
|
g.DebugEdgeInfo(BasicEdge(1, 2), "1|2")
|
|
|
|
dec := json.NewDecoder(bytes.NewReader(buf.Bytes()))
|
|
|
|
var found2, found3, foundEdge bool
|
|
for dec.More() {
|
|
var d streamDecode
|
|
|
|
err := dec.Decode(&d)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
switch d.Type {
|
|
case "VertexDebugInfo":
|
|
va := &vertexDebugInfo{}
|
|
err := json.Unmarshal(d.JSON, va)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
switch va.Info {
|
|
case "2":
|
|
if va.Vertex.Name != "2" {
|
|
t.Fatalf("wrong vertex annotated 2: %#v", va)
|
|
}
|
|
found2 = true
|
|
case "3":
|
|
if va.Vertex.Name != "3" {
|
|
t.Fatalf("wrong vertex annotated 3: %#v", va)
|
|
}
|
|
found3 = true
|
|
default:
|
|
t.Fatalf("unexpected annotation: %#v", va)
|
|
}
|
|
case "EdgeDebugInfo":
|
|
ea := &edgeDebugInfo{}
|
|
err := json.Unmarshal(d.JSON, ea)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
switch ea.Info {
|
|
case "1|2":
|
|
if ea.Edge.Name != "1|2" {
|
|
t.Fatalf("incorrect edge annotation: %#v\n", ea)
|
|
}
|
|
foundEdge = true
|
|
default:
|
|
t.Fatalf("unexpected edge Info: %#v", ea)
|
|
}
|
|
}
|
|
}
|
|
|
|
if !found2 {
|
|
t.Fatal("annotation 2 not found")
|
|
}
|
|
if !found3 {
|
|
t.Fatal("annotation 3 not found")
|
|
}
|
|
if !foundEdge {
|
|
t.Fatal("edge annotation not found")
|
|
}
|
|
}
|
|
|
|
const testGraphJSONEmptyStr = `{
|
|
"Type": "Graph",
|
|
"Name": "root",
|
|
"Vertices": [
|
|
{
|
|
"ID": "1",
|
|
"Name": "1"
|
|
},
|
|
{
|
|
"ID": "2",
|
|
"Name": "2"
|
|
},
|
|
{
|
|
"ID": "3",
|
|
"Name": "3"
|
|
}
|
|
]
|
|
}`
|
|
|
|
const testGraphJSONBasicStr = `{
|
|
"Type": "Graph",
|
|
"Name": "root",
|
|
"Vertices": [
|
|
{
|
|
"ID": "1",
|
|
"Name": "1"
|
|
},
|
|
{
|
|
"ID": "2",
|
|
"Name": "2"
|
|
},
|
|
{
|
|
"ID": "3",
|
|
"Name": "3"
|
|
}
|
|
],
|
|
"Edges": [
|
|
{
|
|
"Name": "1|3",
|
|
"Source": "1",
|
|
"Target": "3"
|
|
}
|
|
]
|
|
}`
|