From 40a18aa920c99546f98ee890c903a07b1bacb73d Mon Sep 17 00:00:00 2001 From: Nick Mills-Barrett Date: Tue, 19 Sep 2023 11:26:12 +0100 Subject: [PATCH] Temporary: just disable forward backfill --- user.go | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) diff --git a/user.go b/user.go index 68248fa..60af0ee 100644 --- a/user.go +++ b/user.go @@ -19,11 +19,9 @@ package main import ( "errors" "fmt" - "math/rand" "sort" "strings" "sync" - "time" log "maunium.net/go/maulogger/v2" @@ -408,20 +406,20 @@ func (user *User) slackMessageHandler(userTeam *database.UserTeam) { userTeam.Upsert() user.tryAutomaticDoublePuppeting(userTeam) - user.BridgeStates[userTeam.Key.TeamID].Send(status.BridgeState{StateEvent: status.StateBackfilling}) + // user.BridgeStates[userTeam.Key.TeamID].Send(status.BridgeState{StateEvent: status.StateBackfilling}) user.log.Infofln("connected to team %s as %s", userTeam.TeamName, userTeam.SlackEmail) - portals := user.bridge.dbPortalsToPortals(user.bridge.DB.Portal.GetAllForUserTeam(userTeam.Key)) - for _, portal := range portals { - // Don't hit rate limits here or we'll never progress - r := rand.Intn(len(user.Teams) * 10) - time.Sleep(time.Duration(r) * time.Second) - err := portal.ForwardBackfill() - if err != nil { - user.log.Warnfln("Forward backfill for portal %s failed: %v", portal.Key, err) - } - } + // portals := user.bridge.dbPortalsToPortals(user.bridge.DB.Portal.GetAllForUserTeam(userTeam.Key)) + // for _, portal := range portals { + // // Don't hit rate limits here or we'll never progress + // r := rand.Intn(len(user.Teams) * 10) + // time.Sleep(time.Duration(r) * time.Second) + // err := portal.ForwardBackfill() + // if err != nil { + // user.log.Warnfln("Forward backfill for portal %s failed: %v", portal.Key, err) + // } + // } user.BridgeStates[userTeam.Key.TeamID].Send(status.BridgeState{StateEvent: status.StateConnected}) case *slack.HelloEvent: // Ignored for now