anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Merge branch 'main' of github.com:anyproto/any-sync into GO-3125-shared-spaces-limit

Browse source
This commit is contained in:
Sergey Cherepanov 2024-03-26 14:23:14 +01:00
commit 53fb239021
No known key found for this signature in database
GPG key ID: 87F8EDE8FBDF637C
11 changed files with 994 additions and 95 deletions
Download patch file Download diff file Expand all files Collapse all files

10
coordinator/coordinatorclient/coordinatorclient.go
View file

@ -261,7 +261,7 @@ func (c *coordinatorClient) AclAddRecord(ctx context.Context, spaceId string, re
Payload: recordData,
})
if err != nil {
return err
return rpcerr.Unwrap(err)
}
res = &consensusproto.RawRecordWithId{
Payload: resp.Payload,
@ -279,7 +279,7 @@ func (c *coordinatorClient) AclGetRecords(ctx context.Context, spaceId, aclHead
AclHead: aclHead,
})
if err != nil {
return err
return rpcerr.Unwrap(err)
}
res = make([]*consensusproto.RawRecordWithId, len(resp.Records))
for i, rec := range resp.Records {
@ -295,8 +295,10 @@ func (c *coordinatorClient) AclGetRecords(ctx context.Context, spaceId, aclHead
func (c *coordinatorClient) AccountLimitsSet(ctx context.Context, req *coordinatorproto.AccountLimitsSetRequest) error {
return c.doClient(ctx, func(cl coordinatorproto.DRPCCoordinatorClient) error {
_, err := cl.AccountLimitsSet(ctx, req)
return err
if _, err := cl.AccountLimitsSet(ctx, req); err != nil {
return rpcerr.Unwrap(err)
}
return nil
})
}