|
|
@ -3,6 +3,8 @@ package graphvent
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"testing"
|
|
|
|
"testing"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
"fmt"
|
|
|
|
|
|
|
|
"encoding/json"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
func TestGQLThread(t * testing.T) {
|
|
|
|
func TestGQLThread(t * testing.T) {
|
|
|
@ -32,3 +34,31 @@ func TestGQLThread(t * testing.T) {
|
|
|
|
err = RunThread(ctx, gql_thread)
|
|
|
|
err = RunThread(ctx, gql_thread)
|
|
|
|
fatalErr(t, err)
|
|
|
|
fatalErr(t, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func TestGQLDBLoad(t * testing.T) {
|
|
|
|
|
|
|
|
ctx := logTestContext(t, []string{})
|
|
|
|
|
|
|
|
l1, err := NewSimpleBaseLockable(ctx, "Test Lockable 1", []Lockable{})
|
|
|
|
|
|
|
|
fatalErr(t, err)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
t1, err := NewGQLThread(ctx, ":8080", []Lockable{l1})
|
|
|
|
|
|
|
|
fatalErr(t, err)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
SendUpdate(ctx, t1, CancelSignal(nil))
|
|
|
|
|
|
|
|
err = RunThread(ctx, t1)
|
|
|
|
|
|
|
|
fatalErr(t, err)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
err = UseStates(ctx, []GraphNode{t1}, func(states NodeStateMap) error {
|
|
|
|
|
|
|
|
ser, err := json.MarshalIndent(states[t1.ID()], "", " ")
|
|
|
|
|
|
|
|
fmt.Printf("\n%s\n\n", ser)
|
|
|
|
|
|
|
|
return err
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
t1_loaded, err := LoadNode(ctx, t1.ID())
|
|
|
|
|
|
|
|
fatalErr(t, err)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
err = UseStates(ctx, []GraphNode{t1_loaded}, func(states NodeStateMap) error {
|
|
|
|
|
|
|
|
ser, err := json.MarshalIndent(states[t1_loaded.ID()], "", " ")
|
|
|
|
|
|
|
|
fmt.Printf("\n%s\n\n", ser)
|
|
|
|
|
|
|
|
return err
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
}
|
|
|
|