jetstream: configure logging dids added to in-memory filter

Signed-off-by: Anirudh Oppiliappan <[e-mail]>

appview/state/state.go

···
 		slog.Default(),
 		wrapper,
 		false,
+
+		// in-memory filter is inapplicalble to appview so
+		// we'll never log dids anyway.
+		false,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create jetstream client: %w", err)

jetstream/jetstream.go

···
 	ident  string
 	l      *slog.Logger
 
+	logDids    bool
 	wantedDids Set[string]
 	db         DB
 	waitForDid bool
···
 		return
 	}
 
-	j.l.Info("adding did to in-memory filter", "did", did)
+	if j.logDids {
+		j.l.Info("adding did to in-memory filter", "did", did)
+	}
 	j.mu.Lock()
 	j.wantedDids[did] = struct{}{}
 	j.mu.Unlock()
···
 	}
 }
 
-func NewJetstreamClient(endpoint, ident string, collections []string, cfg *client.ClientConfig, logger *slog.Logger, db DB, waitForDid bool) (*JetstreamClient, error) {
+func NewJetstreamClient(endpoint, ident string, collections []string, cfg *client.ClientConfig, logger *slog.Logger, db DB, waitForDid, logDids bool) (*JetstreamClient, error) {
 	if cfg == nil {
 		cfg = client.DefaultClientConfig()
 		cfg.WebsocketURL = endpoint
···
 		db:         db,
 		l:          logger,
 		wantedDids: make(map[string]struct{}),
+
+		logDids: logDids,
 
 		// This will make the goroutine in StartJetstream wait until
 		// j.wantedDids has been populated, typically using addDids.

knotserver/config/config.go

···
 	DBPath             string `env:"DB_PATH, default=knotserver.db"`
 	Hostname           string `env:"HOSTNAME, required"`
 	JetstreamEndpoint  string `env:"JETSTREAM_ENDPOINT, default=wss://jetstream1.us-west.bsky.network/subscribe"`
+	LogDids            bool   `env:"LOG_DIDS, default=true"`
 
 	// This disables signature verification so use with caution.
 	Dev bool `env:"DEV, default=false"`

knotserver/server.go

···
 	jc, err := jetstream.NewJetstreamClient(c.Server.JetstreamEndpoint, "knotserver", []string{
 		tangled.PublicKeyNSID,
 		tangled.KnotMemberNSID,
-	}, nil, logger, db, true)
+	}, nil, logger, db, true, c.Server.LogDids)
 	if err != nil {
 		logger.Error("failed to setup jetstream", "error", err)
 	}