Implement a selective cache flush interface for handle updates

api/plc.go

···
 	return &doc, nil
 }
 
+func (s *PLCServer) FlushCacheFor(did string) {
+	return
+}
+
 type CreateOp struct {
 	Type        string  `json:"type" cborgen:"type"`
 	SigningKey  string  `json:"signingKey" cborgen:"signingKey"`

bgs/bgs.go

···
 
 		return nil
 	case env.RepoHandle != nil:
+		// Flush any cached DID documents for this user
+		bgs.didr.FlushCacheFor(env.RepoHandle.Did)
 
 		// TODO: ignoring the data in the message and just going out to the DID doc
 		act, err := bgs.createExternalUser(ctx, env.RepoHandle.Did)

did/multi.go

···
 
 type Resolver interface {
 	GetDocument(ctx context.Context, didstr string) (*did.Document, error)
+	FlushCacheFor(did string)
 }
 
 type MultiResolver struct {
···
 
 func (mr *MultiResolver) AddHandler(method string, res Resolver) {
 	mr.handlers[method] = res
+}
+
+func (mr *MultiResolver) FlushCacheFor(didstr string) {
+	pdid, err := did.ParseDID(didstr)
+	if err != nil {
+		return
+	}
+
+	method := pdid.Protocol()
+
+	res, ok := mr.handlers[method]
+	if !ok {
+		return
+	}
+
+	res.FlushCacheFor(didstr)
 }
 
 func (mr *MultiResolver) GetDocument(ctx context.Context, didstr string) (*did.Document, error) {

did/web.go

···
 	"internal": true,
 }
 
+func (wr *WebResolver) FlushCacheFor(did string) {
+	return
+}
+
 func checkValidDidWeb(val string) error {
 	// no ports or ipv6
 	if strings.Contains(val, ":") {

plc/caching.go

···
 	"context"
 	"time"
 
-	did "github.com/bluesky-social/indigo/did"
+	"github.com/bluesky-social/indigo/did"
 	lru "github.com/hashicorp/golang-lru"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
···
 		cache:  c,
 		maxAge: maxAge,
 	}
+}
+
+func (r *CachingDidResolver) FlushCacheFor(didstr string) {
+	r.cache.Remove(didstr)
 }
 
 func (r *CachingDidResolver) tryCache(did string) (*did.Document, bool) {

plc/fakedid.go

···
 	}, nil
 }
 
+func (fd *FakeDid) FlushCacheFor(did string) {
+	return
+}
+
 func (fd *FakeDid) CreateDID(ctx context.Context, sigkey *did.PrivKey, recovery string, handle string, service string) (string, error) {
 	buf := make([]byte, 8)
 	rand.Read(buf)