alice.pds.demo.boltless.dev
This repository has no description
repoverify: use `identity.Directory` over `idresolver.Resolver`
Signed-off-by: Seongmin Lee <git@boltless.me>
author
Seongmin Lee
date
(Jul 29, 2026, 2:09 AM +0900)
commit
559145d4
559145d4345242fadafc2117af2f67e80f7c0717
parent
5dbcb361
5dbcb361f329ea98a14e61d2cde6a3e68de961c3
change-id
zvsnskqx
zvsnskqxxynlukmrrqwzomnksxvkyvrv
+8
-7
+1
-1
appview/state/state.go
+1
-1
appview/state/state.go
···
194
194
Logger: log.SubLogger(logger, "ingester"),
195
195
MentionsResolver: mentionsResolver,
196
196
Notifier: notifier,
197
-
Verifier: repoverify.New(res, config.Core.Dev),
197
+
Verifier: repoverify.New(res.Directory(), config.Core.Dev),
198
198
}
199
199
err = jc.StartJetstream(ctx, ingester.Ingest())
200
200
if err != nil {
+6
-5
repoverify/verify.go
+6
-5
repoverify/verify.go
···
10
10
"syscall"
11
11
"time"
12
12
13
+
"github.com/bluesky-social/indigo/atproto/identity"
14
+
"github.com/bluesky-social/indigo/atproto/syntax"
13
15
indigoxrpc "github.com/bluesky-social/indigo/xrpc"
14
16
"tangled.org/core/api/tangled"
15
-
"tangled.org/core/idresolver"
16
17
"tangled.org/core/repoident"
17
18
"tangled.org/core/xrpc/xrpcclient"
18
19
)
···
53
54
54
55
const verifyTimeout = 10 * time.Second
55
56
56
-
func New(resolver *idresolver.Resolver, dev bool) Verifier {
57
+
func New(dir identity.Directory, dev bool) Verifier {
57
58
transport := &http.Transport{
58
59
DialContext: safeDialer(dev).DialContext,
59
60
}
···
65
66
return func(ctx context.Context, repoDid repoident.RepoDid) (Result, error) {
66
67
ctx, cancel := context.WithTimeout(ctx, verifyTimeout)
67
68
defer cancel()
68
-
return resolveAndDescribe(ctx, resolver, httpClient, repoDid, dev)
69
+
return resolveAndDescribe(ctx, dir, httpClient, repoDid, dev)
69
70
}
70
71
}
71
72
72
73
func resolveAndDescribe(
73
74
ctx context.Context,
74
-
resolver *idresolver.Resolver,
75
+
dir identity.Directory,
75
76
httpClient *http.Client,
76
77
repoDid repoident.RepoDid,
77
78
dev bool,
78
79
) (Result, error) {
79
-
ident, err := resolver.ResolveIdent(ctx, repoDid.String())
80
+
ident, err := dir.LookupDID(ctx, syntax.DID(repoDid))
80
81
if err != nil {
81
82
return Result{}, fmt.Errorf("resolve repoDid %s: %w", repoDid, err)
82
83
}