Skip to content

Commit e6e8a52

Browse files
samyfodilsamyfodil
authored
[dream] MCP server (#390)
1 parent 6b07050 commit e6e8a52

File tree

146 files changed

+5065
-656
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

146 files changed

+5065
-656
lines changed

‎clients/http/dream/universe_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,13 +29,15 @@ func TestRoutes(t *testing.T) {
2929

3030
univerName := "dream-http"
3131
// start multiverse
32-
m := dream.New(t.Context())
32+
m, err := dream.New(t.Context())
33+
assert.NilError(t, err)
3334
defer m.Close()
3435

35-
err := api.BigBang(m)
36+
err = api.BigBang(m)
3637
assert.NilError(t, err)
3738

38-
u := m.New(dream.UniverseConfig{Name: univerName})
39+
u, err := m.New(dream.UniverseConfig{Name: univerName})
40+
assert.NilError(t, err)
3941

4042
err = u.StartWithConfig(&dream.Config{
4143
Services: map[string]commonIface.ServiceConfig{

‎clients/p2p/auth/client_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,12 +18,14 @@ import (
1818
)
1919

2020
func TestAuthClient(t *testing.T) {
21-
m := dream.New(t.Context())
21+
m, err := dream.New(t.Context())
22+
assert.NilError(t, err)
2223
defer m.Close()
2324

24-
u := m.New(dream.UniverseConfig{Name: t.Name()})
25+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
26+
assert.NilError(t, err)
2527

26-
err := u.StartWithConfig(&dream.Config{
28+
err = u.StartWithConfig(&dream.Config{
2729
Services: map[string]commonIface.ServiceConfig{
2830
"auth": {},
2931
"tns": {},

‎clients/p2p/auth/inject_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,12 +43,14 @@ func injectCert(t *testing.T, client authIface.Client) []byte {
4343
func TestInject(t *testing.T) {
4444
testDir := t.TempDir()
4545

46-
m := dream.New(t.Context())
46+
m, err := dream.New(t.Context())
47+
assert.NilError(t, err)
4748
defer m.Close()
4849

49-
u := m.New(dream.UniverseConfig{Name: t.Name()})
50+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
51+
assert.NilError(t, err)
5052

51-
err := u.StartWithConfig(&dream.Config{
53+
err = u.StartWithConfig(&dream.Config{
5254
Services: map[string]commonIface.ServiceConfig{
5355
"auth": {},
5456
"tns": {},

‎clients/p2p/auth/stats_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,14 @@ import (
1515
func TestStats(t *testing.T) {
1616
t.TempDir()
1717

18-
m := dream.New(t.Context())
18+
m, err := dream.New(t.Context())
19+
assert.NilError(t, err)
1920
defer m.Close()
2021

21-
u := m.New(dream.UniverseConfig{Name: t.Name()})
22+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
23+
assert.NilError(t, err)
2224

23-
err := u.StartWithConfig(&dream.Config{
25+
err = u.StartWithConfig(&dream.Config{
2426
Services: map[string]commonIface.ServiceConfig{
2527
"auth": {},
2628
},

‎clients/p2p/monkey/tests/p2p_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,14 @@ func TestMonkeyClient(t *testing.T) {
2626

2727
protocolCommon.MockedPatrick = true
2828

29-
m := dream.New(t.Context())
29+
m, err := dream.New(t.Context())
30+
assert.NilError(t, err)
3031
defer m.Close()
3132

32-
u := m.New(dream.UniverseConfig{Name: t.Name()})
33+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
34+
assert.NilError(t, err)
3335

34-
err := u.StartWithConfig(&dream.Config{
36+
err = u.StartWithConfig(&dream.Config{
3537
Services: map[string]commonIface.ServiceConfig{
3638
"monkey": {},
3739
"hoarder": {},

‎clients/p2p/patrick/stats_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,14 @@ import (
1313
)
1414

1515
func TestStats(t *testing.T) {
16-
m := dream.New(t.Context())
16+
m, err := dream.New(t.Context())
17+
assert.NilError(t, err)
1718
defer m.Close()
1819

19-
u := m.New(dream.UniverseConfig{Name: t.Name()})
20+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
21+
assert.NilError(t, err)
2022

21-
err := u.StartWithConfig(&dream.Config{
23+
err = u.StartWithConfig(&dream.Config{
2224
Services: map[string]commonIface.ServiceConfig{
2325
"patrick": {},
2426
},

‎clients/p2p/patrick/tests/p2p_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,12 +22,14 @@ import (
2222
)
2323

2424
func TestClientWithUniverse(t *testing.T) {
25-
m := dream.New(t.Context())
25+
m, err := dream.New(t.Context())
26+
assert.NilError(t, err)
2627
defer m.Close()
2728

28-
u := m.New(dream.UniverseConfig{Name: t.Name()})
29+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
30+
assert.NilError(t, err)
2931

30-
err := u.StartWithConfig(&dream.Config{
32+
err = u.StartWithConfig(&dream.Config{
3133
Services: map[string]commonIface.ServiceConfig{
3234
"patrick": {},
3335
"auth": {},

‎clients/p2p/seer/heartbeat_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,14 @@ func TestHeartBeat(t *testing.T) {
2020
seerClient.DefaultAnnounceBeaconInterval = 100 * time.Millisecond
2121
seerClient.DefaultGeoBeaconInterval = 100 * time.Millisecond
2222

23-
m := dream.New(t.Context())
23+
m, err := dream.New(t.Context())
24+
assert.NilError(t, err)
2425
defer m.Close()
2526

26-
u := m.New(dream.UniverseConfig{Name: t.Name()})
27+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
28+
assert.NilError(t, err)
2729

28-
err := u.StartWithConfig(&dream.Config{
30+
err = u.StartWithConfig(&dream.Config{
2931
Services: map[string]commonIface.ServiceConfig{
3032
"seer": {},
3133
"auth": {},

‎clients/p2p/seer/tests/p2p_calls_test.go‎

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import (
77

88
commonIface "github.com/taubyte/tau/core/common"
99
"github.com/taubyte/tau/dream"
10+
"gotest.tools/v3/assert"
1011

1112
_ "github.com/taubyte/tau/services/auth/dream"
1213
_ "github.com/taubyte/tau/services/hoarder/dream"
@@ -25,12 +26,14 @@ func TestCalls(t *testing.T) {
2526
seerClient.DefaultAnnounceBeaconInterval = 100 * time.Millisecond
2627
seerClient.DefaultGeoBeaconInterval = 100 * time.Millisecond
2728

28-
m := dream.New(t.Context())
29+
m, err := dream.New(t.Context())
30+
assert.NilError(t, err)
2931
defer m.Close()
3032

31-
u := m.New(dream.UniverseConfig{Name: t.Name()})
33+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
34+
assert.NilError(t, err)
3235

33-
err := u.StartWithConfig(&dream.Config{
36+
err = u.StartWithConfig(&dream.Config{
3437
Services: map[string]commonIface.ServiceConfig{
3538
"seer": {Others: map[string]int{"mock": 1}},
3639
"auth": {Others: map[string]int{"copies": 2}},

‎clients/p2p/seer/tests/p2p_test.go‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,14 @@ import (
1313
)
1414

1515
func TestSeerClient(t *testing.T) {
16-
m := dream.New(t.Context())
16+
m, err := dream.New(t.Context())
17+
assert.NilError(t, err)
1718
defer m.Close()
1819

19-
u := m.New(dream.UniverseConfig{Name: t.Name()})
20+
u, err := m.New(dream.UniverseConfig{Name: t.Name()})
21+
assert.NilError(t, err)
2022

21-
err := u.StartWithConfig(&dream.Config{
23+
err = u.StartWithConfig(&dream.Config{
2224
Services: map[string]commonIface.ServiceConfig{
2325
"seer": {Others: map[string]int{"dns": 8988}},
2426
},

0 commit comments

Comments
 (0)