this repo has no description
subscribeAllRepos -> subscribeRepos
+12
-12
+1
-1
bgs/bgs.go
+1
-1
bgs/bgs.go
···
168
168
169
169
// TODO: this API is temporary until we formalize what we want here
170
170
171
-
e.GET("/xrpc/com.atproto.sync.subscribeAllRepos", bgs.EventsHandler)
171
+
e.GET("/xrpc/com.atproto.sync.subscribeRepos", bgs.EventsHandler)
172
172
173
173
e.GET("/xrpc/com.atproto.sync.getCheckout", bgs.HandleComAtprotoSyncGetCheckout)
174
174
e.GET("/xrpc/com.atproto.sync.getCommitPath", bgs.HandleComAtprotoSyncGetCommitPath)
+1
-1
bgs/fedmgr.go
+1
-1
bgs/fedmgr.go
···
115
115
116
116
var backoff int
117
117
for {
118
-
url := fmt.Sprintf("%s://%s/xrpc/com.atproto.sync.subscribeAllRepos?cursor=%d", protocol, host.Host, cursor)
118
+
url := fmt.Sprintf("%s://%s/xrpc/com.atproto.sync.subscribeRepos?cursor=%d", protocol, host.Host, cursor)
119
119
con, res, err := d.Dial(url, nil)
120
120
if err != nil {
121
121
log.Warnf("dialing %q failed: %s", host.Host, err)
+1
-1
cmd/gosky/debug.go
+1
-1
cmd/gosky/debug.go
···
44
44
45
45
h := cctx.String("host")
46
46
47
-
url := fmt.Sprintf("%s/xrpc/com.atproto.sync.subscribeAllRepos?cursor=%d", h, n-1)
47
+
url := fmt.Sprintf("%s/xrpc/com.atproto.sync.subscribeRepos?cursor=%d", h, n-1)
48
48
d := websocket.DefaultDialer
49
49
con, _, err := d.Dial(url, http.Header{})
50
50
if err != nil {
+2
-2
cmd/gosky/main.go
+2
-2
cmd/gosky/main.go
···
861
861
defer stop()
862
862
863
863
arg := cctx.Args().First()
864
-
if !strings.Contains(arg, "subscribeAllRepos") {
865
-
arg = arg + "/xrpc/com.atproto.sync.subscribeAllRepos"
864
+
if !strings.Contains(arg, "subscribeRepos") {
865
+
arg = arg + "/xrpc/com.atproto.sync.subscribeRepos"
866
866
}
867
867
if len(cctx.Args().Slice()) == 2 {
868
868
arg = fmt.Sprintf("%s?cursor=%s", arg, cctx.Args().Get(1))
+2
-2
pds/server.go
+2
-2
pds/server.go
···
344
344
switch c.Path() {
345
345
case "/xrpc/_health":
346
346
return true
347
-
case "/xrpc/com.atproto.sync.subscribeAllRepos":
347
+
case "/xrpc/com.atproto.sync.subscribeRepos":
348
348
return true
349
349
case "/xrpc/com.atproto.account.create":
350
350
return true
···
384
384
e.Use(middleware.JWTWithConfig(cfg), s.userCheckMiddleware)
385
385
s.RegisterHandlersComAtproto(e)
386
386
s.RegisterHandlersAppBsky(e)
387
-
e.GET("/xrpc/com.atproto.sync.subscribeAllRepos", s.EventsHandler)
387
+
e.GET("/xrpc/com.atproto.sync.subscribeRepos", s.EventsHandler)
388
388
e.GET("/xrpc/_health", s.HandleHealthCheck)
389
389
390
390
return e.Start(listen)
+1
-1
testing/utils.go
+1
-1
testing/utils.go
···
444
444
q = fmt.Sprintf("?cursor=%d", since)
445
445
}
446
446
447
-
con, resp, err := d.Dial("ws://"+b.host+"/xrpc/com.atproto.sync.subscribeAllRepos"+q, h)
447
+
con, resp, err := d.Dial("ws://"+b.host+"/xrpc/com.atproto.sync.subscribeRepos"+q, h)
448
448
if err != nil {
449
449
t.Fatal(err)
450
450
}
+4
-4
xrpc/xrpc.go
+4
-4
xrpc/xrpc.go
···
32
32
type XRPCRequestType int
33
33
34
34
type AuthInfo struct {
35
-
AccessJwt string `json:"accessJwt"`
36
-
RefreshJwt string `json:"refreshJwt"`
37
-
Handle string `json:"handle"`
38
-
Did string `json:"did"`
35
+
AccessJwt string `json:"accessJwt"`
36
+
RefreshJwt string `json:"refreshJwt"`
37
+
Handle string `json:"handle"`
38
+
Did string `json:"did"`
39
39
}
40
40
41
41
const (