back interdiff of round #1 and #0

appview: invalidate cached identity on receiving identity / account deactivation events from the jetstream #268

merged
opened by ptr.pet targeting master from ptr.pet/core: master
files
appview
ERROR
appview/idresolver/resolver.go

Failed to calculate interdiff for this file.

REVERTED
appview/ingester.go
···
}
}()
+
if e.Kind != models.EventKindCommit {
+
return nil
+
}
+
+
switch e.Commit.Collection {
+
case tangled.GraphFollowNSID:
+
err = i.ingestFollow(e)
+
case tangled.FeedStarNSID:
+
err = i.ingestStar(e)
+
case tangled.PublicKeyNSID:
+
err = i.ingestPublicKey(e)
+
case tangled.RepoArtifactNSID:
+
err = i.ingestArtifact(e)
+
case tangled.ActorProfileNSID:
+
err = i.ingestProfile(e)
+
case tangled.SpindleMemberNSID:
+
err = i.ingestSpindleMember(e)
+
case tangled.SpindleNSID:
+
err = i.ingestSpindle(e)
-
l := i.Logger.With("kind", e.Kind)
-
switch e.Kind {
-
case models.EventKindAccount:
-
if !e.Account.Active {
-
err = i.IdResolver.InvalidateIdent(ctx, e.Account.Did)
-
}
-
case models.EventKindIdentity:
-
err = i.IdResolver.InvalidateIdent(ctx, e.Identity.Did)
-
case models.EventKindCommit:
-
switch e.Commit.Collection {
-
case tangled.GraphFollowNSID:
-
err = i.ingestFollow(e)
-
case tangled.FeedStarNSID:
-
err = i.ingestStar(e)
-
case tangled.PublicKeyNSID:
-
err = i.ingestPublicKey(e)
-
case tangled.RepoArtifactNSID:
-
err = i.ingestArtifact(e)
-
case tangled.ActorProfileNSID:
-
err = i.ingestProfile(e)
-
case tangled.SpindleMemberNSID:
-
err = i.ingestSpindleMember(e)
-
case tangled.SpindleNSID:
-
err = i.ingestSpindle(e)
-
}
-
l = i.Logger.With("nsid", e.Commit.Collection)
}
if err != nil {
+
l := i.Logger.With("nsid", e.Commit.Collection)
l.Error("error ingesting record", "err", err)
}