From df62dc9260cb6a1ab62c597046c9814b8ca82ea5 Mon Sep 17 00:00:00 2001 From: Juliet Date: Thu, 3 Apr 2025 22:45:19 +0200 Subject: [PATCH] cid deletion fix (#2) --- server/repo.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/repo.go b/server/repo.go index 5a22d4c..c4cd31c 100644 --- a/server/repo.go +++ b/server/repo.go @@ -209,6 +209,7 @@ func (rm *RepoMan) applyWrites(urepo models.Repo, writes []Op, swapCommit *strin ops := make([]*atproto.SyncSubscribeRepos_RepoOp, 0, len(diffops)) for _, op := range diffops { + var c cid.Cid switch op.Op { case "add", "mut": kind := "create" @@ -216,6 +217,7 @@ func (rm *RepoMan) applyWrites(urepo models.Repo, writes []Op, swapCommit *strin kind = "update" } + c = op.NewCid ll := lexutil.LexLink(op.NewCid) ops = append(ops, &atproto.SyncSubscribeRepos_RepoOp{ Action: kind, @@ -224,6 +226,7 @@ func (rm *RepoMan) applyWrites(urepo models.Repo, writes []Op, swapCommit *strin }) case "del": + c = op.OldCid ll := lexutil.LexLink(op.OldCid) ops = append(ops, &atproto.SyncSubscribeRepos_RepoOp{ Action: "delete", @@ -233,7 +236,7 @@ func (rm *RepoMan) applyWrites(urepo models.Repo, writes []Op, swapCommit *strin }) } - blk, err := dbs.Get(context.TODO(), op.NewCid) + blk, err := dbs.Get(context.TODO(), c) if err != nil { return nil, err } -- 2.51.2