Skip to content

Commit

Permalink
Temporary: just disable forward backfill
Browse files Browse the repository at this point in the history
  • Loading branch information
Fizzadar committed Sep 19, 2023
1 parent ab1b030 commit 40a18aa
Showing 1 changed file with 11 additions and 13 deletions.
24 changes: 11 additions & 13 deletions user.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,9 @@ package main
import (
"errors"
"fmt"
"math/rand"
"sort"
"strings"
"sync"
"time"

log "maunium.net/go/maulogger/v2"

Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 40a18aa

Please sign in to comment.