hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2025-07-29 12:42:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update Pinecone demo

Browse source
This commit is contained in:
Neil Alexander 2021-10-08 15:29:30 +01:00
parent be9e1b5367
commit a5cb8c00bd
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
5 changed files with 20 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

2
cmd/dendrite-demo-pinecone/main.go
View file

@ -91,7 +91,7 @@ func main() {
}
logger := log.New(os.Stdout, "", 0)
pRouter := pineconeRouter.NewRouter(logger, "dendrite", sk, pk, nil)
pRouter := pineconeRouter.NewRouter(logger, sk, "dendrite", nil)
go func() {
listener, err := net.Listen("tcp", *instanceListen)

6
cmd/dendrite-demo-pinecone/rooms/rooms.go
View file

@ -50,11 +50,9 @@ func NewPineconeRoomProvider(
}
func (p *PineconeRoomProvider) Rooms() []gomatrixserverlib.PublicRoom {
known := p.r.KnownNodes()
//known = append(known, p.s.Sessions()...)
list := []gomatrixserverlib.ServerName{}
for _, k := range known {
list = append(list, gomatrixserverlib.ServerName(k.String()))
for _, k := range p.r.Peers() {
list = append(list, gomatrixserverlib.ServerName(k.PublicKey))
}
return bulkFetchPublicRoomsFromServers(context.Background(), p.fedClient, list)
}