···
"github.com/bluesky-social/indigo/atproto/syntax"
12
-
"github.com/bluesky-social/jetstream/pkg/models"
12
+
jmodels "github.com/bluesky-social/jetstream/pkg/models"
"github.com/go-git/go-git/v5/plumbing"
"tangled.org/core/api/tangled"
"tangled.org/core/appview/config"
"tangled.org/core/appview/db"
18
+
"tangled.org/core/appview/models"
"tangled.org/core/appview/serververify"
"tangled.org/core/appview/validator"
"tangled.org/core/idresolver"
···
Validator *validator.Validator
33
-
type processFunc func(ctx context.Context, e *models.Event) error
34
+
type processFunc func(ctx context.Context, e *jmodels.Event) error
func (i *Ingester) Ingest() processFunc {
36
-
return func(ctx context.Context, e *models.Event) error {
37
+
return func(ctx context.Context, e *jmodels.Event) error {
···
l := i.Logger.With("kind", e.Kind)
48
-
case models.EventKindAccount:
49
+
case jmodels.EventKindAccount:
if !e.Account.Active && *e.Account.Status == "deactivated" {
err = i.IdResolver.InvalidateIdent(ctx, e.Account.Did)
52
-
case models.EventKindIdentity:
53
+
case jmodels.EventKindIdentity:
err = i.IdResolver.InvalidateIdent(ctx, e.Identity.Did)
54
-
case models.EventKindCommit:
55
+
case jmodels.EventKindCommit:
switch e.Commit.Collection {
case tangled.GraphFollowNSID:
···
94
-
func (i *Ingester) ingestStar(e *models.Event) error {
95
+
func (i *Ingester) ingestStar(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
102
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
103
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
var subjectUri syntax.ATURI
raw := json.RawMessage(e.Commit.Record)
···
123
-
case models.CommitOperationDelete:
124
+
case jmodels.CommitOperationDelete:
err = db.DeleteStarByRkey(i.Db, did, e.Commit.RKey)
···
134
-
func (i *Ingester) ingestFollow(e *models.Event) error {
135
+
func (i *Ingester) ingestFollow(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
142
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
143
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.GraphFollow{}
err = json.Unmarshal(raw, &record)
···
SubjectDid: record.Subject,
156
-
case models.CommitOperationDelete:
157
+
case jmodels.CommitOperationDelete:
err = db.DeleteFollowByRkey(i.Db, did, e.Commit.RKey)
···
167
-
func (i *Ingester) ingestPublicKey(e *models.Event) error {
168
+
func (i *Ingester) ingestPublicKey(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
175
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
176
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
l.Debug("processing add of pubkey")
raw := json.RawMessage(e.Commit.Record)
record := tangled.PublicKey{}
···
err = db.AddPublicKey(i.Db, did, name, key, e.Commit.RKey)
188
-
case models.CommitOperationDelete:
189
+
case jmodels.CommitOperationDelete:
l.Debug("processing delete of pubkey")
err = db.DeletePublicKeyByRkey(i.Db, did, e.Commit.RKey)
···
200
-
func (i *Ingester) ingestArtifact(e *models.Event) error {
201
+
func (i *Ingester) ingestArtifact(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
208
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
209
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.RepoArtifact{}
err = json.Unmarshal(raw, &record)
···
237
-
artifact := db.Artifact{
238
+
artifact := models.Artifact{
···
err = db.AddArtifact(i.Db, artifact)
250
-
case models.CommitOperationDelete:
251
+
case jmodels.CommitOperationDelete:
err = db.DeleteArtifact(i.Db, db.FilterEq("did", did), db.FilterEq("rkey", e.Commit.RKey))
···
261
-
func (i *Ingester) ingestProfile(e *models.Event) error {
262
+
func (i *Ingester) ingestProfile(e *jmodels.Event) error {
···
switch e.Commit.Operation {
273
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
274
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.ActorProfile{}
err = json.Unmarshal(raw, &record)
···
err = db.UpsertProfile(tx, &profile)
341
-
case models.CommitOperationDelete:
342
+
case jmodels.CommitOperationDelete:
err = db.DeleteArtifact(i.Db, db.FilterEq("did", did), db.FilterEq("rkey", e.Commit.RKey))
···
352
-
func (i *Ingester) ingestSpindleMember(ctx context.Context, e *models.Event) error {
353
+
func (i *Ingester) ingestSpindleMember(ctx context.Context, e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
360
-
case models.CommitOperationCreate:
361
+
case jmodels.CommitOperationCreate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.SpindleMember{}
err = json.Unmarshal(raw, &record)
···
l.Info("added spindle member")
405
-
case models.CommitOperationDelete:
406
+
case jmodels.CommitOperationDelete:
ddb, ok := i.Db.Execer.(*db.DB)
···
458
-
func (i *Ingester) ingestSpindle(ctx context.Context, e *models.Event) error {
459
+
func (i *Ingester) ingestSpindle(ctx context.Context, e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
466
-
case models.CommitOperationCreate:
467
+
case jmodels.CommitOperationCreate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.Spindle{}
err = json.Unmarshal(raw, &record)
···
504
-
case models.CommitOperationDelete:
505
+
case jmodels.CommitOperationDelete:
instance := e.Commit.RKey
ddb, ok := i.Db.Execer.(*db.DB)
···
572
-
func (i *Ingester) ingestString(e *models.Event) error {
573
+
func (i *Ingester) ingestString(e *jmodels.Event) error {
···
switch e.Commit.Operation {
587
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
588
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.String{}
err = json.Unmarshal(raw, &record)
···
610
-
case models.CommitOperationDelete:
611
+
case jmodels.CommitOperationDelete:
if err := db.DeleteString(
···
626
-
func (i *Ingester) ingestKnotMember(e *models.Event) error {
627
+
func (i *Ingester) ingestKnotMember(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
634
-
case models.CommitOperationCreate:
635
+
case jmodels.CommitOperationCreate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.KnotMember{}
err = json.Unmarshal(raw, &record)
···
l.Info("added knot member")
664
-
case models.CommitOperationDelete:
665
+
case jmodels.CommitOperationDelete:
// we don't store knot members in a table (like we do for spindle)
// and we can't remove this just yet. possibly fixed if we switch
···
678
-
func (i *Ingester) ingestKnot(e *models.Event) error {
679
+
func (i *Ingester) ingestKnot(e *jmodels.Event) error {
···
l = l.With("nsid", e.Commit.Collection)
switch e.Commit.Operation {
686
-
case models.CommitOperationCreate:
687
+
case jmodels.CommitOperationCreate:
raw := json.RawMessage(e.Commit.Record)
err = json.Unmarshal(raw, &record)
···
721
-
case models.CommitOperationDelete:
722
+
case jmodels.CommitOperationDelete:
ddb, ok := i.Db.Execer.(*db.DB)
···
781
-
func (i *Ingester) ingestIssue(ctx context.Context, e *models.Event) error {
782
+
func (i *Ingester) ingestIssue(ctx context.Context, e *jmodels.Event) error {
···
switch e.Commit.Operation {
796
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
797
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.RepoIssue{}
err = json.Unmarshal(raw, &record)
···
832
-
case models.CommitOperationDelete:
833
+
case jmodels.CommitOperationDelete:
if err := db.DeleteIssues(
···
848
-
func (i *Ingester) ingestIssueComment(e *models.Event) error {
849
+
func (i *Ingester) ingestIssueComment(e *jmodels.Event) error {
···
switch e.Commit.Operation {
863
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
864
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.RepoIssueComment{}
err = json.Unmarshal(raw, &record)
···
887
-
case models.CommitOperationDelete:
888
+
case jmodels.CommitOperationDelete:
if err := db.DeleteIssueComments(
···
902
-
func (i *Ingester) ingestLabelDefinition(e *models.Event) error {
903
+
func (i *Ingester) ingestLabelDefinition(e *jmodels.Event) error {
···
switch e.Commit.Operation {
917
-
case models.CommitOperationCreate, models.CommitOperationUpdate:
918
+
case jmodels.CommitOperationCreate, jmodels.CommitOperationUpdate:
raw := json.RawMessage(e.Commit.Record)
record := tangled.LabelDefinition{}
err = json.Unmarshal(raw, &record)
···
941
-
case models.CommitOperationDelete:
942
+
case jmodels.CommitOperationDelete:
if err := db.DeleteLabelDefinition(
nel.pet
oppi.li