Monorepo for Tangled
lexicons: `sync.requestCrawl` and `knot.subscribeRepos`
Signed-off-by: Seongmin Lee <git@boltless.me>
authored by
Seongmin Lee
and committed by
tangled.org
(Mar 23, 2026, 1:00 PM UTC)
4b8fa95d
6631a3f7
+152
+34
api/tangled/knotsubscribeRepos.go
+34
api/tangled/knotsubscribeRepos.go
···
1
+
// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
2
+
3
+
package tangled
4
+
5
+
// schema: sh.tangled.knot.subscribeRepos
6
+
7
+
const (
8
+
KnotSubscribeReposNSID = "sh.tangled.knot.subscribeRepos"
9
+
)
10
+
11
+
// KnotSubscribeRepos_GitSync1 is a "gitSync1" in the sh.tangled.knot.subscribeRepos schema.
12
+
type KnotSubscribeRepos_GitSync1 struct {
13
+
// did: Repository DID identifier
14
+
Did string `json:"did" cborgen:"did"`
15
+
// seq: The stream sequence number of this message.
16
+
Seq int64 `json:"seq" cborgen:"seq"`
17
+
}
18
+
19
+
// KnotSubscribeRepos_GitSync2 is a "gitSync2" in the sh.tangled.knot.subscribeRepos schema.
20
+
type KnotSubscribeRepos_GitSync2 struct {
21
+
// did: Repository AT-URI identifier
22
+
Did *string `json:"did,omitempty" cborgen:"did,omitempty"`
23
+
// seq: The stream sequence number of this message.
24
+
Seq int64 `json:"seq" cborgen:"seq"`
25
+
}
26
+
27
+
// KnotSubscribeRepos_Identity is a "identity" in the sh.tangled.knot.subscribeRepos schema.
28
+
type KnotSubscribeRepos_Identity struct {
29
+
// did: Repository DID identifier
30
+
Did string `json:"did" cborgen:"did"`
31
+
// seq: The stream sequence number of this message.
32
+
Seq int64 `json:"seq" cborgen:"seq"`
33
+
Time string `json:"time" cborgen:"time"`
34
+
}
+32
api/tangled/syncrequestCrawl.go
+32
api/tangled/syncrequestCrawl.go
···
1
+
// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
2
+
3
+
package tangled
4
+
5
+
// schema: sh.tangled.sync.requestCrawl
6
+
7
+
import (
8
+
"context"
9
+
10
+
"github.com/bluesky-social/indigo/lex/util"
11
+
)
12
+
13
+
const (
14
+
SyncRequestCrawlNSID = "sh.tangled.sync.requestCrawl"
15
+
)
16
+
17
+
// SyncRequestCrawl_Input is the input argument to a sh.tangled.sync.requestCrawl call.
18
+
type SyncRequestCrawl_Input struct {
19
+
// ensureRepo: specific repository to ensure crawling
20
+
EnsureRepo *string `json:"ensureRepo,omitempty" cborgen:"ensureRepo,omitempty"`
21
+
// hostname: Hostname of the current service (eg, Knot) that is requesting to be crawled.
22
+
Hostname string `json:"hostname" cborgen:"hostname"`
23
+
}
24
+
25
+
// SyncRequestCrawl calls the XRPC method "sh.tangled.sync.requestCrawl".
26
+
func SyncRequestCrawl(ctx context.Context, c util.LexClient, input *SyncRequestCrawl_Input) error {
27
+
if err := c.LexDo(ctx, util.Procedure, "application/json", "sh.tangled.sync.requestCrawl", nil, input, nil); err != nil {
28
+
return err
29
+
}
30
+
31
+
return nil
32
+
}
+57
lexicons/knot/subscribeRepos.json
+57
lexicons/knot/subscribeRepos.json
···
1
+
{
2
+
"lexicon": 1,
3
+
"id": "sh.tangled.knot.subscribeRepos",
4
+
"defs": {
5
+
"main": {
6
+
"type": "subscription",
7
+
"description": "Repository event stream, aka Firehose endpoint. Outputs repo commits with diff data, and identity update events, for all repositories on the current server. See the atproto specifications for details around stream sequencing, repo versioning, CAR diff format, and more. Public and does not require auth; implemented by PDS and Relay.",
8
+
"parameters": {
9
+
"type": "params",
10
+
"properties": {
11
+
"cursor": {
12
+
"type": "integer",
13
+
"description": "The last known event seq number to backfill from."
14
+
}
15
+
}
16
+
},
17
+
"message": {
18
+
"schema": {
19
+
"type": "union",
20
+
"refs": ["#identity", "gitRefUpdate"]
21
+
}
22
+
},
23
+
"errors": [
24
+
{ "name": "FutureCursor" },
25
+
{
26
+
"name": "ConsumerTooSlow",
27
+
"description": "If the consumer of the stream can not keep up with events, and a backlog gets too large, the server will drop the connection."
28
+
}
29
+
]
30
+
},
31
+
"identity": {
32
+
"type": "object",
33
+
"required": ["seq", "did", "time"],
34
+
"properties": {
35
+
"seq": { "type": "integer", "description": "The stream sequence number of this message." },
36
+
"did": { "type": "string", "format": "did", "description": "Repository DID identifier" },
37
+
"time": { "type": "string", "format": "datetime" }
38
+
}
39
+
},
40
+
"gitSync1": {
41
+
"type": "object",
42
+
"required": ["seq", "did"],
43
+
"properties": {
44
+
"seq": { "type": "integer", "description": "The stream sequence number of this message." },
45
+
"did": { "type": "string", "format": "did", "description": "Repository DID identifier" }
46
+
}
47
+
},
48
+
"gitSync2": {
49
+
"type": "object",
50
+
"required": ["seq", "repo"],
51
+
"properties": {
52
+
"seq": { "type": "integer", "description": "The stream sequence number of this message." },
53
+
"did": { "type": "string", "format": "at-uri", "description": "Repository AT-URI identifier" }
54
+
}
55
+
}
56
+
}
57
+
}
+29
lexicons/sync/requestCrawl.json
+29
lexicons/sync/requestCrawl.json
···
1
+
{
2
+
"lexicon": 1,
3
+
"id": "sh.tangled.sync.requestCrawl",
4
+
"defs": {
5
+
"main": {
6
+
"type": "procedure",
7
+
"description": "Request a service to persistently crawl hosted repos. Does not require auth.",
8
+
"input": {
9
+
"encoding": "application/json",
10
+
"schema": {
11
+
"type": "object",
12
+
"required": ["hostname"],
13
+
"properties": {
14
+
"hostname": {
15
+
"type": "string",
16
+
"description": "Hostname of the current service (eg, Knot) that is requesting to be crawled."
17
+
},
18
+
"ensureRepo": {
19
+
"type": "string",
20
+
"format": "at-uri",
21
+
"description": "specific repository to ensure crawling"
22
+
}
23
+
}
24
+
}
25
+
},
26
+
"errors": [{ "name": "HostBanned" }]
27
+
}
28
+
}
29
+
}