aboutsummaryrefslogtreecommitdiff
path: root/cmd/dendrite-demo-pinecone/main.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/dendrite-demo-pinecone/main.go')
-rw-r--r--cmd/dendrite-demo-pinecone/main.go12
1 files changed, 5 insertions, 7 deletions
diff --git a/cmd/dendrite-demo-pinecone/main.go b/cmd/dendrite-demo-pinecone/main.go
index 122da1c5..5c086b7e 100644
--- a/cmd/dendrite-demo-pinecone/main.go
+++ b/cmd/dendrite-demo-pinecone/main.go
@@ -22,7 +22,6 @@ import (
"flag"
"fmt"
"io/ioutil"
- "log"
"net"
"net/http"
"os"
@@ -91,8 +90,7 @@ func main() {
pk = sk.Public().(ed25519.PublicKey)
}
- logger := log.New(os.Stdout, "", 0)
- pRouter := pineconeRouter.NewRouter(logger, sk, false)
+ pRouter := pineconeRouter.NewRouter(logrus.WithField("pinecone", "router"), sk, false)
go func() {
listener, err := net.Listen("tcp", *instanceListen)
@@ -122,8 +120,8 @@ func main() {
}
}()
- pQUIC := pineconeSessions.NewSessions(logger, pRouter)
- pMulticast := pineconeMulticast.NewMulticast(logger, pRouter)
+ pQUIC := pineconeSessions.NewSessions(logrus.WithField("pinecone", "sessions"), pRouter, []string{"matrix"})
+ pMulticast := pineconeMulticast.NewMulticast(logrus.WithField("pinecone", "multicast"), pRouter)
pMulticast.Start()
connectToStaticPeer := func() {
@@ -253,7 +251,7 @@ func main() {
pMux.PathPrefix(httputil.PublicFederationPathPrefix).Handler(base.PublicFederationAPIMux)
pMux.PathPrefix(httputil.PublicMediaPathPrefix).Handler(base.PublicMediaAPIMux)
- pHTTP := pQUIC.HTTP()
+ pHTTP := pQUIC.Protocol("matrix").HTTP()
pHTTP.Mux().Handle(users.PublicURL, pMux)
pHTTP.Mux().Handle(httputil.PublicFederationPathPrefix, pMux)
pHTTP.Mux().Handle(httputil.PublicMediaPathPrefix, pMux)
@@ -275,7 +273,7 @@ func main() {
go func() {
pubkey := pRouter.PublicKey()
logrus.Info("Listening on ", hex.EncodeToString(pubkey[:]))
- logrus.Fatal(httpServer.Serve(pQUIC))
+ logrus.Fatal(httpServer.Serve(pQUIC.Protocol("matrix")))
}()
go func() {
httpBindAddr := fmt.Sprintf(":%d", *instancePort)