+2 -2

cmd/relayered/relay/firehose.go

reviewed

··· 97 97 98 98 // Check if the PDS is still authoritative 99 99 // if not we don't want to be propagating this account event 100 100 - if account.GetPDS() != host.ID { 100 100 + if account.GetPDS() != host.ID && !r.Config.SkipAccountHostCheck { 101 101 r.Logger.Error("account event from non-authoritative pds", 102 102 "seq", env.RepoAccount.Seq, 103 103 "did", env.RepoAccount.Did, ··· 218 218 return err 219 219 } 220 220 221 221 - if account.GetPDS() != host.ID { 221 221 + if account.GetPDS() != host.ID && !r.Config.SkipAccountHostCheck { 222 222 repoCommitsResultCounter.WithLabelValues(host.Host, "noauth").Inc() 223 223 return fmt.Errorf("event from non-authoritative pds") 224 224 }

+1

cmd/relayered/relay/relay.go

reviewed

··· 46 46 ConcurrencyPerPDS int64 47 47 MaxQueuePerPDS int64 48 48 ApplyPDSClientSettings func(c *xrpc.Client) 49 49 + SkipAccountHostCheck bool // XXX: only used for testing 49 50 } 50 51 51 52 func DefaultRelayConfig() *RelayConfig {

+1

cmd/relayered/testing/runner.go

reviewed

··· 31 31 32 32 relayConfig := relay.DefaultRelayConfig() 33 33 relayConfig.SSL = false 34 34 + relayConfig.SkipAccountHostCheck = true 34 35 35 36 db, err := cliutil.SetupDatabase("sqlite://:memory:", 40) 36 37 if err != nil {