back interdiff of round #1 and #0

appview,knotserver,spindle: rework jetstream #480

merged
opened by oppi.li targeting master from push-mtsxyxnkznyy

do not return errors from ingesters, this causes the read loop to be killed.

Signed-off-by: oppiliappan me@oppi.li

files
appview
knotserver
log
spindle
ERROR
appview/ingester.go

Failed to calculate interdiff for this file.

ERROR
knotserver/ingester.go

Failed to calculate interdiff for this file.

ERROR
log/log.go

Failed to calculate interdiff for this file.

ERROR
spindle/ingester.go

Failed to calculate interdiff for this file.

NEW
knotserver/handler.go
···
return nil, fmt.Errorf("failed to setup enforcer: %w", err)
}
-
err = h.jc.StartJetstream(ctx, h.processMessages)
-
if err != nil {
-
return nil, fmt.Errorf("failed to start jetstream: %w", err)
-
}
-
// Check if the knot knows about any Dids;
// if it does, it is already initialized and we can repopulate the
// Jetstream subscriptions.
···
}
}
+
err = h.jc.StartJetstream(ctx, h.processMessages)
+
if err != nil {
+
return nil, fmt.Errorf("failed to start jetstream: %w", err)
+
}
+
r.Get("/", h.Index)
r.Get("/capabilities", h.Capabilities)
r.Get("/version", h.Version)