From 81d60d54488a2e4b4bbcdbab0f7e01f780e5fbe8 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Fri, 7 May 2021 12:48:30 +0100
Subject: [PATCH] Update room directory in Pinecone demo some more

---
 cmd/dendrite-demo-pinecone/rooms/rooms.go | 25 ++++++++---------------
 1 file changed, 8 insertions(+), 17 deletions(-)

diff --git a/cmd/dendrite-demo-pinecone/rooms/rooms.go b/cmd/dendrite-demo-pinecone/rooms/rooms.go
index a7071352..ed6ab78c 100644
--- a/cmd/dendrite-demo-pinecone/rooms/rooms.go
+++ b/cmd/dendrite-demo-pinecone/rooms/rooms.go
@@ -27,8 +27,6 @@ import (
 	pineconeSessions "github.com/matrix-org/pinecone/sessions"
 )
 
-const pineconeRoomAttempts = 3
-
 type PineconeRoomProvider struct {
 	r         *pineconeRouter.Router
 	s         *pineconeSessions.Sessions
@@ -77,31 +75,24 @@ func bulkFetchPublicRoomsFromServers(
 	var wg sync.WaitGroup
 	wg.Add(len(homeservers))
 	// concurrently query for public rooms
-	reqctx, reqcancel := context.WithCancel(ctx)
+	reqctx, reqcancel := context.WithTimeout(ctx, time.Second*5)
 	for _, hs := range homeservers {
 		go func(homeserverDomain gomatrixserverlib.ServerName) {
 			defer wg.Done()
 			util.GetLogger(reqctx).WithField("hs", homeserverDomain).Info("Querying HS for public rooms")
-			var fres gomatrixserverlib.RespPublicRooms
-			var err error
-			for i := 0; i < pineconeRoomAttempts; i++ {
-				fres, err = fedClient.GetPublicRooms(reqctx, homeserverDomain, int(limit), "", false, "")
-				if err != nil {
-					util.GetLogger(reqctx).WithError(err).WithField("hs", homeserverDomain).Warn(
-						"bulkFetchPublicRoomsFromServers: failed to query hs",
-					)
-					if i == pineconeRoomAttempts-1 {
-						return
-					}
-				} else {
-					break
-				}
+			fres, err := fedClient.GetPublicRooms(reqctx, homeserverDomain, int(limit), "", false, "")
+			if err != nil {
+				util.GetLogger(reqctx).WithError(err).WithField("hs", homeserverDomain).Warn(
+					"bulkFetchPublicRoomsFromServers: failed to query hs",
+				)
+				return
 			}
 			for _, room := range fres.Chunk {
 				// atomically send a room or stop
 				select {
 				case roomCh <- room:
 				case <-done:
+				case <-reqctx.Done():
 					util.GetLogger(reqctx).WithError(err).WithField("hs", homeserverDomain).Info("Interrupted whilst sending rooms")
 					return
 				}