this repo has no description
use atclient & add pprof
+13
-17
+7
-11
cmd/nexus/crawler.go
+7
-11
cmd/nexus/crawler.go
···
8
8
"time"
9
9
10
10
comatproto "github.com/bluesky-social/indigo/api/atproto"
11
+
"github.com/bluesky-social/indigo/atproto/atclient"
11
12
"github.com/bluesky-social/indigo/cmd/nexus/models"
12
-
"github.com/bluesky-social/indigo/xrpc"
13
13
"go.opentelemetry.io/otel/attribute"
14
14
"gorm.io/gorm"
15
15
)
···
30
30
return err
31
31
}
32
32
33
-
client := &xrpc.Client{
34
-
Client: &http.Client{
35
-
Timeout: 30 * time.Second,
36
-
},
37
-
Host: c.RelayUrl,
33
+
client := atclient.NewAPIClient(c.RelayUrl)
34
+
client.Client = &http.Client{
35
+
Timeout: 30 * time.Second,
38
36
}
39
37
40
38
for {
···
112
110
return err
113
111
}
114
112
115
-
client := &xrpc.Client{
116
-
Client: &http.Client{
117
-
Timeout: 30 * time.Second,
118
-
},
119
-
Host: c.RelayUrl,
113
+
client := atclient.NewAPIClient(c.RelayUrl)
114
+
client.Client = &http.Client{
115
+
Timeout: 30 * time.Second,
120
116
}
121
117
122
118
for {
+4
-6
cmd/nexus/resync.go
+4
-6
cmd/nexus/resync.go
···
9
9
"time"
10
10
11
11
comatproto "github.com/bluesky-social/indigo/api/atproto"
12
+
"github.com/bluesky-social/indigo/atproto/atclient"
12
13
"github.com/bluesky-social/indigo/atproto/atdata"
13
14
"github.com/bluesky-social/indigo/atproto/repo"
14
15
"github.com/bluesky-social/indigo/atproto/syntax"
15
16
"github.com/bluesky-social/indigo/cmd/nexus/models"
16
-
"github.com/bluesky-social/indigo/xrpc"
17
17
"github.com/ipfs/go-cid"
18
18
"go.opentelemetry.io/otel/attribute"
19
19
"gorm.io/gorm"
···
118
118
119
119
n.logger.Info("fetching repo from PDS", "did", did, "pds", pdsURL)
120
120
121
-
client := &xrpc.Client{
122
-
Client: &http.Client{
123
-
Timeout: 30 * time.Second,
124
-
},
125
-
Host: pdsURL,
121
+
client := atclient.NewAPIClient(pdsURL)
122
+
client.Client = &http.Client{
123
+
Timeout: 30 * time.Second,
126
124
}
127
125
128
126
repoBytes, err := comatproto.SyncGetRepo(ctx, client, did, "")
+2
cmd/nexus/server.go
+2
cmd/nexus/server.go
···
4
4
"context"
5
5
"log/slog"
6
6
"net/http"
7
+
_ "net/http/pprof"
7
8
8
9
"github.com/bluesky-social/indigo/cmd/nexus/models"
9
10
"github.com/gorilla/websocket"
···
25
26
ns.echo.GET("/channel", ns.handleChannelWebsocket)
26
27
ns.echo.POST("/add-repos", ns.handleAddRepos)
27
28
ns.echo.POST("/remove-repos", ns.handleRemoveRepos)
29
+
ns.echo.Any("/debug/pprof/*", echo.WrapHandler(http.DefaultServeMux))
28
30
return ns.echo.Start(address)
29
31
}
30
32