mirror of
https://github.com/anyproto/any-sync.git
synced 2025-06-11 02:13:49 +09:00
Use GetObject everywhere
This commit is contained in:
parent
8d97077cf7
commit
9b7b92f5c2
1 changed files with 3 additions and 3 deletions
|
@ -140,8 +140,8 @@ func (o *objectSync) HandleDeprecatedObjectSync(ctx context.Context, req *spaces
|
|||
|
||||
func (o *objectSync) ApplyRequest(ctx context.Context, rq syncdeps.Request, requestSender syncdeps.RequestSender) error {
|
||||
ctx = peer.CtxWithPeerId(ctx, rq.PeerId())
|
||||
obj, err := o.manager.GetTree(context.Background(), o.spaceId, rq.ObjectId())
|
||||
// if tree exists locally
|
||||
obj, err := o.manager.GetObject(context.Background(), rq.ObjectId())
|
||||
// if tree or acl exists locally
|
||||
if err == nil {
|
||||
objHandler, ok := obj.(syncdeps.ObjectSyncHandler)
|
||||
if !ok {
|
||||
|
@ -150,7 +150,7 @@ func (o *objectSync) ApplyRequest(ctx context.Context, rq syncdeps.Request, requ
|
|||
collector := objHandler.ResponseCollector()
|
||||
return requestSender.SendRequest(ctx, rq, collector)
|
||||
}
|
||||
_, err = o.manager.GetTree(ctx, o.spaceId, rq.ObjectId())
|
||||
_, err = o.manager.GetObject(ctx, rq.ObjectId())
|
||||
return err
|
||||
}
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue