Add more checks for backfill enabled

mautrix · Jan 25, 2024 · e76f500 · e76f500
1 parent 70b9fc0
commit e76f500
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/backfill.go b/backfill.go
@@ -122,6 +122,9 @@ func (user *User) handleBackfillTask(ctx context.Context, task *database.Backfil
 }
 
 func (user *User) BackfillLoop() {
+	if !user.bridge.Config.Bridge.Backfill.Enabled {
+		return
+	}
 	log := user.log.With().Str("action", "backfill loop").Logger()
 	defer func() {
 		log.Debug().Msg("Backfill loop stopped")

diff --git a/user.go b/user.go
@@ -555,6 +555,9 @@ func (user *User) handleTable(tbl *table.LSTable) {
 }
 
 func (user *User) requestMoreInbox(ctx context.Context, itrs []*table.LSUpsertInboxThreadsRange) {
+	if !user.bridge.Config.Bridge.Backfill.Enabled {
+		return
+	}
 	maxInboxPages := user.bridge.Config.Bridge.Backfill.InboxFetchPages
 	if len(itrs) == 0 || user.InboxFetched || maxInboxPages == 0 {
 		return