mirror of
https://github.com/anyproto/any-sync.git
synced 2025-06-11 10:18:08 +09:00
Merge pull request #176 from anyproto/GO-2982-provide-acl-in-acl-waiter
GO-2982: Provide acl in aclwaiter
This commit is contained in:
commit
32a1c9feb8
1 changed files with 3 additions and 3 deletions
|
@ -41,11 +41,11 @@ type aclWaiter struct {
|
||||||
spaceId string
|
spaceId string
|
||||||
prevHeadId string
|
prevHeadId string
|
||||||
|
|
||||||
onFinish func() error
|
onFinish func(acl list.AclList) error
|
||||||
finished bool
|
finished bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func New(spaceId string, onFinish func() error) AclWaiter {
|
func New(spaceId string, onFinish func(acl list.AclList) error) AclWaiter {
|
||||||
return &aclWaiter{
|
return &aclWaiter{
|
||||||
spaceId: spaceId,
|
spaceId: spaceId,
|
||||||
onFinish: onFinish,
|
onFinish: onFinish,
|
||||||
|
@ -101,7 +101,7 @@ func (a *aclWaiter) loop(ctx context.Context) error {
|
||||||
// if the user was added
|
// if the user was added
|
||||||
if !a.acl.AclState().Permissions(a.keys.SignKey.GetPublic()).NoPermissions() {
|
if !a.acl.AclState().Permissions(a.keys.SignKey.GetPublic()).NoPermissions() {
|
||||||
if !a.finished {
|
if !a.finished {
|
||||||
err := a.onFinish()
|
err := a.onFinish(a.acl)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
a.finished = true
|
a.finished = true
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue