ucan/toolkit/client/requester.go

package client

import (
	"context"
	"iter"
	"time"

	"code.sonr.org/go/did-it"
	"github.com/avast/retry-go/v4"

	"code.sonr.org/go/ucan/pkg/command"
	"code.sonr.org/go/ucan/token/delegation"
)

type DelegationRequester interface {
	// RequestDelegation retrieve a delegation or chain of delegation for the given parameters.
	// - cmd: the command to execute
	// - audience: the DID of the client, also the issuer of the invocation token
	// - subject: the DID of the resource to operate on, also the subject (or audience if defined) of the invocation token
	// The returned delegations MUST be ordered starting from the leaf (the one matching the invocation) to the root
	// (the one given by the service).
	// Note: you can read it as "(audience) wants to do (cmd) on (subject)".
	// Note: the returned delegation(s) don't have to match exactly the parameters, as long as they allow them.
	RequestDelegation(ctx context.Context, audience did.DID, cmd command.Command, subject did.DID) (iter.Seq2[*delegation.Bundle, error], error)
}

var _ DelegationRequester = &withRetry{}

type withRetry struct {
	requester    DelegationRequester
	initialDelay time.Duration
	maxAttempts  uint
}

// RequesterWithRetry wraps a DelegationRequester to perform exponential backoff,
// with an initial delay and a maximum attempt count.
func RequesterWithRetry(requester DelegationRequester, initialDelay time.Duration, maxAttempt uint) DelegationRequester {
	return &withRetry{
		requester:    requester,
		initialDelay: initialDelay,
		maxAttempts:  maxAttempt,
	}
}

func (w withRetry) RequestDelegation(ctx context.Context, audience did.DID, cmd command.Command, subject did.DID) (iter.Seq2[*delegation.Bundle, error], error) {
	return retry.DoWithData(func() (iter.Seq2[*delegation.Bundle, error], error) {
		return w.requester.RequestDelegation(ctx, audience, cmd, subject)
	},
		retry.Context(ctx),
		retry.Delay(w.initialDelay),
		retry.Attempts(w.maxAttempts),
	)
}