···
43
+
if e.Kind != models.EventKindCommit {
47
+
switch e.Commit.Collection {
48
+
case tangled.GraphFollowNSID:
49
+
err = i.ingestFollow(e)
50
+
case tangled.FeedStarNSID:
51
+
err = i.ingestStar(e)
52
+
case tangled.PublicKeyNSID:
53
+
err = i.ingestPublicKey(e)
54
+
case tangled.RepoArtifactNSID:
55
+
err = i.ingestArtifact(e)
56
+
case tangled.ActorProfileNSID:
57
+
err = i.ingestProfile(e)
58
+
case tangled.SpindleMemberNSID:
59
+
err = i.ingestSpindleMember(e)
60
+
case tangled.SpindleNSID:
61
+
err = i.ingestSpindle(e)
43
-
l := i.Logger.With("kind", e.Kind)
45
-
case models.EventKindAccount:
46
-
if !e.Account.Active {
47
-
err = i.IdResolver.InvalidateIdent(ctx, e.Account.Did)
49
-
case models.EventKindIdentity:
50
-
err = i.IdResolver.InvalidateIdent(ctx, e.Identity.Did)
51
-
case models.EventKindCommit:
52
-
switch e.Commit.Collection {
53
-
case tangled.GraphFollowNSID:
54
-
err = i.ingestFollow(e)
55
-
case tangled.FeedStarNSID:
56
-
err = i.ingestStar(e)
57
-
case tangled.PublicKeyNSID:
58
-
err = i.ingestPublicKey(e)
59
-
case tangled.RepoArtifactNSID:
60
-
err = i.ingestArtifact(e)
61
-
case tangled.ActorProfileNSID:
62
-
err = i.ingestProfile(e)
63
-
case tangled.SpindleMemberNSID:
64
-
err = i.ingestSpindleMember(e)
65
-
case tangled.SpindleNSID:
66
-
err = i.ingestSpindle(e)
68
-
l = i.Logger.With("nsid", e.Commit.Collection)
65
+
l := i.Logger.With("nsid", e.Commit.Collection)
l.Error("error ingesting record", "err", err)