aboutsummaryrefslogtreecommitdiff
path: root/build
diff options
context:
space:
mode:
authorNeil Alexander <neilalexander@users.noreply.github.com>2020-07-01 13:35:58 +0100
committerNeil Alexander <neilalexander@users.noreply.github.com>2020-07-01 13:35:58 +0100
commit8e7947926cd00a05f90a9d0bfdc29dcd2dc9ab7a (patch)
tree8bd7578f84822cf3313a6a199735909082034a92 /build
parent42dd96242574866378bb95d92bc0c7fdf3dbabf6 (diff)
Fix Yggdrasil gobind build, set display name at registration
Diffstat (limited to 'build')
-rw-r--r--build/gobind/monolith.go11
1 files changed, 11 insertions, 0 deletions
diff --git a/build/gobind/monolith.go b/build/gobind/monolith.go
index 750babad..62ca1744 100644
--- a/build/gobind/monolith.go
+++ b/build/gobind/monolith.go
@@ -11,6 +11,7 @@ import (
"github.com/matrix-org/dendrite/appservice"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-yggdrasil/signing"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-yggdrasil/yggconn"
+ "github.com/matrix-org/dendrite/currentstateserver"
"github.com/matrix-org/dendrite/eduserver"
"github.com/matrix-org/dendrite/eduserver/cache"
"github.com/matrix-org/dendrite/federationsender"
@@ -25,6 +26,7 @@ import (
)
type DendriteMonolith struct {
+ YggdrasilNode *yggconn.Node
StorageDirectory string
listener net.Listener
}
@@ -33,6 +35,10 @@ func (m *DendriteMonolith) BaseURL() string {
return fmt.Sprintf("http://%s", m.listener.Addr().String())
}
+func (m *DendriteMonolith) PeerCount() int {
+ return m.YggdrasilNode.PeerCount()
+}
+
func (m *DendriteMonolith) Start() {
logger := logrus.Logger{
Out: BindLogger{},
@@ -49,6 +55,7 @@ func (m *DendriteMonolith) Start() {
if err != nil {
panic(err)
}
+ m.YggdrasilNode = ygg
cfg := &config.Dendrite{}
cfg.SetDefaults()
@@ -69,6 +76,7 @@ func (m *DendriteMonolith) Start() {
cfg.Database.FederationSender = config.DataSource(fmt.Sprintf("file:%s/dendrite-federationsender.db", m.StorageDirectory))
cfg.Database.AppService = config.DataSource(fmt.Sprintf("file:%s/dendrite-appservice.db", m.StorageDirectory))
cfg.Database.PublicRoomsAPI = config.DataSource(fmt.Sprintf("file:%s/dendrite-publicroomsa.db", m.StorageDirectory))
+ cfg.Database.CurrentState = config.DataSource(fmt.Sprintf("file:%s/dendrite-currentstate.db", m.StorageDirectory))
cfg.Database.Naffka = config.DataSource(fmt.Sprintf("file:%s/dendrite-naffka.db", m.StorageDirectory))
if err = cfg.Derive(); err != nil {
panic(err)
@@ -108,6 +116,8 @@ func (m *DendriteMonolith) Start() {
logrus.WithError(err).Panicf("failed to connect to public rooms db")
}
+ stateAPI := currentstateserver.NewInternalAPI(base.Cfg, base.KafkaConsumer)
+
monolith := setup.Monolith{
Config: base.Cfg,
AccountDB: accountDB,
@@ -123,6 +133,7 @@ func (m *DendriteMonolith) Start() {
FederationSenderAPI: fsAPI,
RoomserverAPI: rsAPI,
UserAPI: userAPI,
+ StateAPI: stateAPI,
//ServerKeyAPI: serverKeyAPI,
PublicRoomsDB: publicRoomsDB,