248 lines
7.0 KiB
Go
248 lines
7.0 KiB
Go
package graphvent
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
"errors"
|
|
"net"
|
|
"net/http"
|
|
"io"
|
|
"fmt"
|
|
"encoding/json"
|
|
"bytes"
|
|
"crypto/rand"
|
|
"crypto/ecdh"
|
|
"crypto/ecdsa"
|
|
"crypto/elliptic"
|
|
"encoding/base64"
|
|
)
|
|
|
|
func TestGQLThread(t * testing.T) {
|
|
ctx := logTestContext(t, []string{})
|
|
key, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
fatalErr(t, err)
|
|
gql_t_r := NewGQLThread(RandID(), "GQL Thread", "init", ":0", ecdh.P256(), key)
|
|
gql_t := &gql_t_r
|
|
|
|
t1_r := NewSimpleThread(RandID(), "Test thread 1", "init", nil, BaseThreadActions, BaseThreadHandlers)
|
|
t1 := &t1_r
|
|
t2_r := NewSimpleThread(RandID(), "Test thread 2", "init", nil, BaseThreadActions, BaseThreadHandlers)
|
|
t2 := &t2_r
|
|
|
|
err = UpdateStates(ctx, []Node{gql_t, t1, t2}, func(nodes NodeMap) error {
|
|
i1 := NewParentThreadInfo(true, "start", "restore")
|
|
err := LinkThreads(ctx, gql_t, t1, &i1, nodes)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
i2 := NewParentThreadInfo(false, "start", "restore")
|
|
return LinkThreads(ctx, gql_t, t2, &i2, nodes)
|
|
})
|
|
fatalErr(t, err)
|
|
|
|
go func(thread Thread){
|
|
time.Sleep(10*time.Millisecond)
|
|
err := UseStates(ctx, []Node{thread}, func(nodes NodeMap) error {
|
|
return thread.Signal(ctx, CancelSignal(nil), nodes)
|
|
})
|
|
fatalErr(t, err)
|
|
}(gql_t)
|
|
|
|
err = ThreadLoop(ctx, gql_t, "start")
|
|
fatalErr(t, err)
|
|
}
|
|
|
|
func TestGQLDBLoad(t * testing.T) {
|
|
ctx := logTestContext(t, []string{})
|
|
l1_r := NewSimpleLockable(RandID(), "Test Lockable 1")
|
|
l1 := &l1_r
|
|
|
|
t1_r := NewSimpleThread(RandID(), "Test Thread 1", "init", nil, BaseThreadActions, BaseThreadHandlers)
|
|
t1 := &t1_r
|
|
update_channel := UpdateChannel(t1, 10, NodeID{})
|
|
|
|
u1_key, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
fatalErr(t, err)
|
|
|
|
u1_shared := []byte{0xDE, 0xAD, 0xBE, 0xEF, 0x01, 0x23, 0x45, 0x67}
|
|
|
|
u1_r := NewUser("Test User", time.Now(), &u1_key.PublicKey, u1_shared)
|
|
u1 := &u1_r
|
|
|
|
key, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
fatalErr(t, err)
|
|
gql_r := NewGQLThread(RandID(), "GQL Thread", "init", ":0", ecdh.P256(), key)
|
|
gql := &gql_r
|
|
|
|
info := NewParentThreadInfo(true, "start", "restore")
|
|
err = UpdateStates(ctx, []Node{gql, t1, l1, u1}, func(nodes NodeMap) error {
|
|
gql.Users[KeyID(&u1_key.PublicKey)] = u1
|
|
err := LinkLockables(ctx, gql, []Lockable{l1}, nodes)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return LinkThreads(ctx, gql, t1, &info, nodes)
|
|
})
|
|
fatalErr(t, err)
|
|
|
|
err = UseStates(ctx, []Node{gql}, func(nodes NodeMap) error {
|
|
err := gql.Signal(ctx, NewSignal(t1, "child_added"), nodes)
|
|
if err != nil {
|
|
return nil
|
|
}
|
|
return gql.Signal(ctx, AbortSignal(nil), nodes)
|
|
})
|
|
fatalErr(t, err)
|
|
|
|
err = ThreadLoop(ctx, gql, "start")
|
|
if errors.Is(err, NewThreadAbortedError(NodeID{})) {
|
|
ctx.Log.Logf("test", "Main thread aborted by signal: %s", err)
|
|
} else {
|
|
fatalErr(t, err)
|
|
}
|
|
|
|
(*GraphTester)(t).WaitForValue(ctx, update_channel, "thread_aborted", t1, 100*time.Millisecond, "Didn't receive thread_abort from t1 on t1")
|
|
|
|
err = UseStates(ctx, []Node{gql, t1}, func(nodes NodeMap) error {
|
|
ser1, err := gql.Serialize()
|
|
ser2, err := t1.Serialize()
|
|
ctx.Log.Logf("test", "\n%s\n\n", ser1)
|
|
ctx.Log.Logf("test", "\n%s\n\n", ser2)
|
|
return err
|
|
})
|
|
|
|
gql_loaded, err := LoadNode(ctx, gql.ID())
|
|
fatalErr(t, err)
|
|
var t1_loaded *SimpleThread = nil
|
|
|
|
var update_channel_2 chan GraphSignal
|
|
err = UseStates(ctx, []Node{gql_loaded}, func(nodes NodeMap) error {
|
|
ser, err := gql_loaded.Serialize()
|
|
ctx.Log.Logf("test", "\n%s\n\n", ser)
|
|
child := gql_loaded.(Thread).Children()[0].(*SimpleThread)
|
|
t1_loaded = child
|
|
update_channel_2 = UpdateChannel(t1_loaded, 10, NodeID{})
|
|
err = UseMoreStates(ctx, []Node{child}, nodes, func(nodes NodeMap) error {
|
|
ser, err := child.Serialize()
|
|
ctx.Log.Logf("test", "\n%s\n\n", ser)
|
|
return err
|
|
})
|
|
gql_loaded.Signal(ctx, AbortSignal(nil), nodes)
|
|
return err
|
|
})
|
|
|
|
err = ThreadLoop(ctx, gql_loaded.(Thread), "restore")
|
|
if errors.Is(err, NewThreadAbortedError(NodeID{})) {
|
|
ctx.Log.Logf("test", "Main thread aborted by signal: %s", err)
|
|
} else {
|
|
fatalErr(t, err)
|
|
}
|
|
(*GraphTester)(t).WaitForValue(ctx, update_channel_2, "thread_aborted", t1_loaded, 100*time.Millisecond, "Didn't received thread_aborted on t1_loaded from t1_loaded")
|
|
|
|
}
|
|
|
|
func TestGQLAuth(t * testing.T) {
|
|
ctx := logTestContext(t, []string{"test", "gql"})
|
|
key, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
fatalErr(t, err)
|
|
gql_t_r := NewGQLThread(RandID(), "GQL Thread", "init", ":0", ecdh.P256(), key)
|
|
gql_t := &gql_t_r
|
|
|
|
done := make(chan error, 1)
|
|
|
|
var update_channel chan GraphSignal
|
|
err = UseStates(ctx, []Node{gql_t}, func(nodes NodeMap) error {
|
|
update_channel = UpdateChannel(gql_t, 10, NodeID{})
|
|
return nil
|
|
})
|
|
fatalErr(t, err)
|
|
|
|
go func(done chan error, thread Thread) {
|
|
timeout := time.After(2*time.Second)
|
|
select {
|
|
case <-timeout:
|
|
ctx.Log.Logf("test", "TIMEOUT")
|
|
case <-done:
|
|
ctx.Log.Logf("test", "DONE")
|
|
}
|
|
err := UseStates(ctx, []Node{gql_t}, func(nodes NodeMap) error {
|
|
return thread.Signal(ctx, CancelSignal(nil), nodes)
|
|
})
|
|
fatalErr(t, err)
|
|
}(done, gql_t)
|
|
|
|
go func(thread Thread){
|
|
(*GraphTester)(t).WaitForValue(ctx, update_channel, "server_started", gql_t, 100*time.Millisecond, "Server didn't start")
|
|
port := gql_t.tcp_listener.Addr().(*net.TCPAddr).Port
|
|
ctx.Log.Logf("test", "GQL_PORT: %d", port)
|
|
client := &http.Client{}
|
|
url := fmt.Sprintf("http://localhost:%d/auth", port)
|
|
|
|
id, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
fatalErr(t, err)
|
|
|
|
auth_req, ec_key, err := NewAuthReqJSON(ecdh.P256(), id)
|
|
fatalErr(t, err)
|
|
|
|
str, err := json.Marshal(auth_req)
|
|
fatalErr(t, err)
|
|
|
|
b := bytes.NewBuffer(str)
|
|
req, err := http.NewRequest("PUT", url, b)
|
|
fatalErr(t, err)
|
|
|
|
resp, err := client.Do(req)
|
|
fatalErr(t, err)
|
|
|
|
body, err := io.ReadAll(resp.Body)
|
|
fatalErr(t, err)
|
|
|
|
resp.Body.Close()
|
|
|
|
var j AuthRespJSON
|
|
err = json.Unmarshal(body, &j)
|
|
fatalErr(t, err)
|
|
|
|
shared, err := ParseAuthRespJSON(j, elliptic.P256(), ecdh.P256(), ec_key)
|
|
fatalErr(t, err)
|
|
|
|
url = fmt.Sprintf("http://localhost:%d/gql", port)
|
|
ser, err := json.MarshalIndent(&GQLPayload{
|
|
Query: "query { Self { ID } }",
|
|
}, "", " ")
|
|
fatalErr(t, err)
|
|
|
|
b = bytes.NewBuffer(ser)
|
|
req, err = http.NewRequest("GET", url, b)
|
|
fatalErr(t, err)
|
|
|
|
req.SetBasicAuth(KeyID(&id.PublicKey).String(), base64.StdEncoding.EncodeToString(shared))
|
|
resp, err = client.Do(req)
|
|
fatalErr(t, err)
|
|
|
|
body, err = io.ReadAll(resp.Body)
|
|
fatalErr(t, err)
|
|
|
|
resp.Body.Close()
|
|
|
|
ctx.Log.Logf("test", "TEST_RESP: %s", body)
|
|
|
|
req.SetBasicAuth(KeyID(&id.PublicKey).String(), "BAD_PASSWORD")
|
|
resp, err = client.Do(req)
|
|
fatalErr(t, err)
|
|
|
|
body, err = io.ReadAll(resp.Body)
|
|
fatalErr(t, err)
|
|
|
|
resp.Body.Close()
|
|
|
|
ctx.Log.Logf("test", "TEST_RESP: %s", body)
|
|
|
|
done <- nil
|
|
}(gql_t)
|
|
|
|
err = ThreadLoop(ctx, gql_t, "start")
|
|
fatalErr(t, err)
|
|
}
|