oppi.li
do not return errors from ingesters, this causes the read loop to be killed.
Signed-off-by: oppiliappan me@oppi.li
ERROR
appview/ingester.go
ERROR
appview/ingester.go
Failed to calculate interdiff for this file.
ERROR
knotserver/ingester.go
ERROR
knotserver/ingester.go
Failed to calculate interdiff for this file.
ERROR
log/log.go
ERROR
log/log.go
Failed to calculate interdiff for this file.
ERROR
spindle/ingester.go
ERROR
spindle/ingester.go
Failed to calculate interdiff for this file.
NEW
knotserver/handler.go
NEW
knotserver/handler.go
···
52
52
return nil, fmt.Errorf("failed to setup enforcer: %w", err)
53
53
}
54
54
55
-
err = h.jc.StartJetstream(ctx, h.processMessages)
56
-
if err != nil {
57
-
return nil, fmt.Errorf("failed to start jetstream: %w", err)
58
-
}
59
-
60
55
// Check if the knot knows about any Dids;
61
56
// if it does, it is already initialized and we can repopulate the
62
57
// Jetstream subscriptions.
···
73
68
}
74
69
}
75
70
71
+
err = h.jc.StartJetstream(ctx, h.processMessages)
72
+
if err != nil {
73
+
return nil, fmt.Errorf("failed to start jetstream: %w", err)
74
+
}
75
+
76
76
r.Get("/", h.Index)
77
77
r.Get("/capabilities", h.Capabilities)
78
78
r.Get("/version", h.Version)