ptr.pet
ERROR
appview/idresolver/resolver.go
ERROR
appview/idresolver/resolver.go
Failed to calculate interdiff for this file.
REVERTED
appview/ingester.go
REVERTED
appview/ingester.go
···
40
}
41
}()
42
43
-
l := i.Logger.With("kind", e.Kind)
44
-
switch e.Kind {
45
-
case models.EventKindAccount:
46
-
if !e.Account.Active {
47
-
err = i.IdResolver.InvalidateIdent(ctx, e.Account.Did)
48
-
}
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)
67
-
}
68
-
l = i.Logger.With("nsid", e.Commit.Collection)
69
}
70
71
if err != nil {
72
l.Error("error ingesting record", "err", err)
73
}
74
···
40
}
41
}()
42
43
+
if e.Kind != models.EventKindCommit {
44
+
return nil
45
+
}
46
+
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)
62
}
63
64
if err != nil {
65
+
l := i.Logger.With("nsid", e.Commit.Collection)
66
l.Error("error ingesting record", "err", err)
67
}
68