diff --git a/pkg/consumer/base.go b/pkg/consumer/base.go index 349afa1..2c2d9ce 100644 --- a/pkg/consumer/base.go +++ b/pkg/consumer/base.go @@ -272,7 +272,7 @@ func ConsumeAndSaveToMongoDB( postBatch = []*collections.Post{} // Clear batch after insert } else { // If we haven't seen any data for 25 seconds, cancel the consumer connection - if consumerLastFlushingTime.Add(time.Second*25).Before(time.Now()) { + if consumerLastFlushingTime.Add(time.Second * 25).Before(time.Now()) { cancel() } } diff --git a/pkg/generator/az.go b/pkg/generator/az.go index d272e7b..3901f2e 100644 --- a/pkg/generator/az.go +++ b/pkg/generator/az.go @@ -16,6 +16,7 @@ import ( var azInvalidUser []string = []string{ "did:plc:5zww7zorx2ajw7hqrhuix3ba", "did:plc:c4vhz47h566t2ntgd7gtawen", + "did:plc:lc7j7xdq67gn7vc6vzmydfqk", } var azValidUsers []string = []string{