go/ucan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

container: add a delegation iterator

Browse Source
This commit is contained in:
Michael Muré
2024-11-05 16:26:53 +01:00
parent 6f9a6fa5c1
commit 06a72868a5
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/container/reader.go
View File

@@ -4,6 +4,7 @@ import (
"encoding/base64" "encoding/base64"
"fmt" "fmt"
"io" "io"
"iter"
"github.com/ipfs/go-cid" "github.com/ipfs/go-cid"
"github.com/ipld/go-ipld-prime" "github.com/ipld/go-ipld-prime"
@@ -42,6 +43,19 @@ func (ctn Reader) GetDelegation(cid cid.Cid) (*delegation.Token, error) {
return nil, fmt.Errorf("not a delegation token") return nil, fmt.Errorf("not a delegation token")
} }
// GetAllDelegations returns all the delegation.Token in the container.
func (ctn Reader) GetAllDelegations() iter.Seq2[cid.Cid, *delegation.Token] {
return func(yield func(cid.Cid, *delegation.Token) bool) {
for c, t := range ctn {
if t, ok := t.(*delegation.Token); ok {
if !yield(c, t) {
return
}
}
}
}
}
// GetInvocation returns the first found invocation.Token. // GetInvocation returns the first found invocation.Token.
// If none are found, ErrNotFound is returned. // If none are found, ErrNotFound is returned.
func (ctn Reader) GetInvocation() (*invocation.Token, error) { func (ctn Reader) GetInvocation() (*invocation.Token, error) {