diff options
| author | devonh <devon.dmytro@gmail.com> | 2023-01-23 17:55:12 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-23 17:55:12 +0000 |
| commit | 5b73592f5a4dddf64184fcbe33f4c1835c656480 (patch) | |
| tree | b6dac51b6be7a1e591f24881ee1bfae1b92088e9 /test/testrig | |
| parent | 48fa869fa3578741d1d5775d30f24f6b097ab995 (diff) | |
Initial Store & Forward Implementation (#2917)
This adds store & forward relays into dendrite for p2p.
A few things have changed:
- new relay api serves new http endpoints for s&f federation
- updated outbound federation queueing which will attempt to forward
using s&f if appropriate
- database entries to track s&f relays for other nodes
Diffstat (limited to 'test/testrig')
| -rw-r--r-- | test/testrig/base.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/test/testrig/base.go b/test/testrig/base.go index 9773da22..dfc0d8aa 100644 --- a/test/testrig/base.go +++ b/test/testrig/base.go @@ -67,9 +67,10 @@ func CreateBaseDendrite(t *testing.T, dbType test.DBType) (*base.BaseDendrite, f case test.DBTypeSQLite: cfg.Defaults(config.DefaultOpts{ Generate: true, - Monolithic: false, // because we need a database per component + Monolithic: true, }) cfg.Global.ServerName = "test" + // use a distinct prefix else concurrent postgres/sqlite runs will clash since NATS will use // the file system event with InMemory=true :( cfg.Global.JetStream.TopicPrefix = fmt.Sprintf("Test_%d_", dbType) @@ -83,6 +84,7 @@ func CreateBaseDendrite(t *testing.T, dbType test.DBType) (*base.BaseDendrite, f cfg.RoomServer.Database.ConnectionString = config.DataSource(filepath.Join("file://", tempDir, "roomserver.db")) cfg.SyncAPI.Database.ConnectionString = config.DataSource(filepath.Join("file://", tempDir, "syncapi.db")) cfg.UserAPI.AccountDatabase.ConnectionString = config.DataSource(filepath.Join("file://", tempDir, "userapi.db")) + cfg.RelayAPI.Database.ConnectionString = config.DataSource(filepath.Join("file://", tempDir, "relayapi.db")) base := base.NewBaseDendrite(&cfg, "Test", base.DisableMetrics) return base, func() { |