Update treesyncer

anyproto · Aug 14, 2024 · c704c98 · c704c98
1 parent 9905afc
commit c704c98
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -7,7 +7,7 @@ toolchain go1.22.1
 require (
 	github.com/ahmetb/govvv v0.3.0
 	github.com/akrylysov/pogreb v0.10.3-0.20240803013244-523613e335e9
-	github.com/anyproto/any-sync v0.5.0-alpha.11
+	github.com/anyproto/any-sync v0.5.0-alpha.12
 	github.com/anyproto/go-chash v0.1.0
 	github.com/gogo/protobuf v1.3.2
 	github.com/prometheus/client_golang v1.19.1

diff --git a/go.sum b/go.sum
@@ -7,8 +7,8 @@ github.com/ahmetb/govvv v0.3.0 h1:YGLGwEyiUwHFy5eh/RUhdupbuaCGBYn5T5GWXp+WJB0=
 github.com/ahmetb/govvv v0.3.0/go.mod h1:4WRFpdWtc/YtKgPFwa1dr5+9hiRY5uKAL08bOlxOR6s=
 github.com/akrylysov/pogreb v0.10.3-0.20240803013244-523613e335e9 h1:GnBlbnor8geJB4j7GGXqVHiSG0cHNEkIYNmpYDAPa+Y=
 github.com/akrylysov/pogreb v0.10.3-0.20240803013244-523613e335e9/go.mod h1:fPb3n+7H42SxX84B4/os7POrR+UGRKSRr3kNS5+xq/c=
-github.com/anyproto/any-sync v0.5.0-alpha.11 h1:ZCLu22sbFj3Zj4DNPxHwXeqeiH0kC6moSztaEmDfyYk=
-github.com/anyproto/any-sync v0.5.0-alpha.11/go.mod h1:jXXg/qRUkgBH7T3yiJ1csDnxbNWhEsbWZyQzQ38w78s=
+github.com/anyproto/any-sync v0.5.0-alpha.12 h1:zpbjs7fli9gfQY9RQW72KhgSWcLt43dvlL2iNRT7V+8=
+github.com/anyproto/any-sync v0.5.0-alpha.12/go.mod h1:jXXg/qRUkgBH7T3yiJ1csDnxbNWhEsbWZyQzQ38w78s=
 github.com/anyproto/go-chash v0.1.0 h1:I9meTPjXFRfXZHRJzjOHC/XF7Q5vzysKkiT/grsogXY=
 github.com/anyproto/go-chash v0.1.0/go.mod h1:0UjNQi3PDazP0fINpFYu6VKhuna+W/V+1vpXHAfNgLY=
 github.com/anyproto/go-slip10 v1.0.0 h1:uAEtSuudR3jJBOfkOXf3bErxVoxbuKwdoJN55M1i6IA=

diff --git a/nodespace/treesyncer/treesyncer.go b/nodespace/treesyncer/treesyncer.go
@@ -54,6 +54,7 @@ func (t *treeSyncer) ShouldSync(peerId string) bool {
 func (t *treeSyncer) SyncAll(ctx context.Context, p peer.Peer, existing, missing []string) (err error) {
 	// TODO: copied from any-sync's previous version, should change later if needed to use queues
 	//  problem here is that all sync process is basically synchronous and has same timeout
+	ctx = peer.CtxWithPeerId(ctx, p.Id())
 	syncTrees := func(ids []string) {
 		for _, id := range ids {
 			log := log.With(zap.String("treeId", id))