this repo has no description
update code for new location
+19
-19
+3
-3
bgs/bgs.go
+3
-3
bgs/bgs.go
···
15
15
"sync"
16
16
"time"
17
17
18
-
"github.com/bluesky-social/indigo/api"
19
18
atproto "github.com/bluesky-social/indigo/api/atproto"
20
19
comatproto "github.com/bluesky-social/indigo/api/atproto"
21
20
"github.com/bluesky-social/indigo/carstore"
22
21
"github.com/bluesky-social/indigo/did"
23
22
"github.com/bluesky-social/indigo/events"
23
+
"github.com/bluesky-social/indigo/handles"
24
24
"github.com/bluesky-social/indigo/indexer"
25
25
"github.com/bluesky-social/indigo/models"
26
26
"github.com/bluesky-social/indigo/repomgr"
···
58
58
didr did.Resolver
59
59
repoFetcher *indexer.RepoFetcher
60
60
61
-
hr api.HandleResolver
61
+
hr handles.HandleResolver
62
62
63
63
// TODO: work on doing away with this flag in favor of more pluggable
64
64
// pieces that abstract the need for explicit ssl checks
···
134
134
}
135
135
}
136
136
137
-
func NewBGS(db *gorm.DB, ix *indexer.Indexer, repoman *repomgr.RepoManager, evtman *events.EventManager, didr did.Resolver, rf *indexer.RepoFetcher, hr api.HandleResolver, config *BGSConfig) (*BGS, error) {
137
+
func NewBGS(db *gorm.DB, ix *indexer.Indexer, repoman *repomgr.RepoManager, evtman *events.EventManager, didr did.Resolver, rf *indexer.RepoFetcher, hr handles.HandleResolver, config *BGSConfig) (*BGS, error) {
138
138
139
139
if config == nil {
140
140
config = DefaultBGSConfig()
+4
-4
cmd/bigsky/main.go
+4
-4
cmd/bigsky/main.go
···
14
14
"syscall"
15
15
"time"
16
16
17
-
"github.com/bluesky-social/indigo/api"
18
17
libbgs "github.com/bluesky-social/indigo/bgs"
19
18
"github.com/bluesky-social/indigo/carstore"
20
19
"github.com/bluesky-social/indigo/did"
21
20
"github.com/bluesky-social/indigo/events"
22
21
"github.com/bluesky-social/indigo/events/dbpersist"
23
22
"github.com/bluesky-social/indigo/events/diskpersist"
23
+
"github.com/bluesky-social/indigo/handles"
24
24
"github.com/bluesky-social/indigo/indexer"
25
25
"github.com/bluesky-social/indigo/plc"
26
26
"github.com/bluesky-social/indigo/repomgr"
···
478
478
}
479
479
}, false)
480
480
481
-
prodHR, err := api.NewProdHandleResolver(100_000, cctx.String("resolve-address"), cctx.Bool("force-dns-udp"))
481
+
prodHR, err := handles.NewProdHandleResolver(100_000, cctx.String("resolve-address"), cctx.Bool("force-dns-udp"))
482
482
if err != nil {
483
483
return fmt.Errorf("failed to set up handle resolver: %w", err)
484
484
}
···
491
491
}
492
492
}
493
493
494
-
var hr api.HandleResolver = prodHR
494
+
var hr handles.HandleResolver = prodHR
495
495
if cctx.StringSlice("handle-resolver-hosts") != nil {
496
-
hr = &api.TestHandleResolver{
496
+
hr = &handles.TestHandleResolver{
497
497
TrialHosts: cctx.StringSlice("handle-resolver-hosts"),
498
498
}
499
499
}
+6
-6
cmd/gosky/admin.go
+6
-6
cmd/gosky/admin.go
···
10
10
"sync"
11
11
"time"
12
12
13
-
"github.com/bluesky-social/indigo/api"
14
13
"github.com/bluesky-social/indigo/api/atproto"
15
14
comatproto "github.com/bluesky-social/indigo/api/atproto"
16
15
toolsozone "github.com/bluesky-social/indigo/api/ozone"
17
16
"github.com/bluesky-social/indigo/atproto/identity"
18
17
"github.com/bluesky-social/indigo/atproto/syntax"
18
+
"github.com/bluesky-social/indigo/handles"
19
19
"github.com/bluesky-social/indigo/util/cliutil"
20
20
cli "github.com/urfave/cli/v2"
21
21
)
···
442
442
adminKey := cctx.String("admin-password")
443
443
xrpcc.AdminToken = &adminKey
444
444
445
-
phr := &api.ProdHandleResolver{}
445
+
phr := &handles.ProdHandleResolver{}
446
446
handle := cctx.Args().First()
447
447
if !strings.HasPrefix(handle, "did:") {
448
448
resp, err := phr.ResolveHandleToDid(ctx, handle)
···
486
486
487
487
handle := cctx.Args().First()
488
488
if !strings.HasPrefix(handle, "did:") {
489
-
phr := &api.ProdHandleResolver{}
489
+
phr := &handles.ProdHandleResolver{}
490
490
resp, err := phr.ResolveHandleToDid(ctx, handle)
491
491
if err != nil {
492
492
return err
···
530
530
531
531
ctx := context.Background()
532
532
533
-
phr := &api.ProdHandleResolver{}
533
+
phr := &handles.ProdHandleResolver{}
534
534
535
535
did := cctx.Args().First()
536
536
if !strings.HasPrefix(did, "did:") {
···
695
695
696
696
did := cctx.Args().First()
697
697
if !strings.HasPrefix(did, "did:") {
698
-
phr := &api.ProdHandleResolver{}
698
+
phr := &handles.ProdHandleResolver{}
699
699
resp, err := phr.ResolveHandleToDid(ctx, did)
700
700
if err != nil {
701
701
return err
···
768
768
count := cctx.Int("useCount")
769
769
num := cctx.Int("num")
770
770
771
-
phr := &api.ProdHandleResolver{}
771
+
phr := &handles.ProdHandleResolver{}
772
772
if bulkfi := cctx.String("bulk"); bulkfi != "" {
773
773
xrpcc.AdminToken = &adminKey
774
774
dids, err := readDids(bulkfi)
+3
-3
cmd/gosky/main.go
+3
-3
cmd/gosky/main.go
···
15
15
"syscall"
16
16
"time"
17
17
18
-
"github.com/bluesky-social/indigo/api"
19
18
"github.com/bluesky-social/indigo/api/atproto"
20
19
comatproto "github.com/bluesky-social/indigo/api/atproto"
21
20
"github.com/bluesky-social/indigo/api/bsky"
···
23
22
"github.com/bluesky-social/indigo/atproto/syntax"
24
23
"github.com/bluesky-social/indigo/events"
25
24
"github.com/bluesky-social/indigo/events/schedulers/sequential"
25
+
"github.com/bluesky-social/indigo/handles"
26
26
lexutil "github.com/bluesky-social/indigo/lex/util"
27
27
"github.com/bluesky-social/indigo/repo"
28
28
"github.com/bluesky-social/indigo/util"
···
194
194
}()
195
195
196
196
didr := cliutil.GetDidResolver(cctx)
197
-
hr := &api.ProdHandleResolver{}
197
+
hr := &handles.ProdHandleResolver{}
198
198
resolveHandles := cctx.Bool("resolve-handles")
199
199
200
200
cache, _ := lru.New[string, *cachedHandle](10000)
···
206
206
}
207
207
}
208
208
209
-
h, _, err := api.ResolveDidToHandle(ctx, didr, hr, did)
209
+
h, _, err := handles.ResolveDidToHandle(ctx, didr, hr, did)
210
210
if err != nil {
211
211
return "", err
212
212
}
+3
-3
testing/utils.go
+3
-3
testing/utils.go
···
19
19
"testing"
20
20
"time"
21
21
22
-
"github.com/bluesky-social/indigo/api"
23
22
atproto "github.com/bluesky-social/indigo/api/atproto"
24
23
bsky "github.com/bluesky-social/indigo/api/bsky"
25
24
"github.com/bluesky-social/indigo/bgs"
···
27
26
"github.com/bluesky-social/indigo/events"
28
27
"github.com/bluesky-social/indigo/events/diskpersist"
29
28
"github.com/bluesky-social/indigo/events/schedulers/sequential"
29
+
"github.com/bluesky-social/indigo/handles"
30
30
"github.com/bluesky-social/indigo/indexer"
31
31
lexutil "github.com/bluesky-social/indigo/lex/util"
32
32
"github.com/bluesky-social/indigo/models"
···
496
496
497
497
type TestRelay struct {
498
498
bgs *bgs.BGS
499
-
tr *api.TestHandleResolver
499
+
tr *handles.TestHandleResolver
500
500
db *gorm.DB
501
501
502
502
// listener is owned by by the Relay structure and should be closed by
···
578
578
}
579
579
}, true) // TODO: actually want this to be false, but some tests use this to confirm the Relay has seen certain records
580
580
581
-
tr := &api.TestHandleResolver{}
581
+
tr := &handles.TestHandleResolver{}
582
582
583
583
bgsConfig := bgs.DefaultBGSConfig()
584
584
bgsConfig.SSL = false