1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
package xrpcserver
import (
"fmt"
"maps"
"github.com/bluesky-social/indigo/atproto/lexicon"
"github.com/johnandersen777/socialweb-computer-kcp/lexicons"
)
func loadCatalog() (*lexicon.BaseCatalog, error) {
c := lexicon.NewBaseCatalog()
if err := c.LoadEmbedFS(lexicons.FS); err != nil {
return nil, fmt.Errorf("xrpcserver: loading the embedded lexicons: %w", err)
}
return c, nil
}
type inline struct {
nsid string
obj lexicon.SchemaObject
catalog *lexicon.BaseCatalog
}
var _ lexicon.Catalog = inline{}
func (c inline) Resolve(ref string) (*lexicon.Schema, error) {
if ref != c.nsid {
return c.catalog.Resolve(ref)
}
return &lexicon.Schema{
ID: ref,
Def: lexicon.SchemaRecord{Type: "record", Key: "any", Record: c.obj},
}, nil
}
func objectOf(where string, def *lexicon.SchemaDef) (lexicon.SchemaObject, error) {
if def == nil {
return lexicon.SchemaObject{}, fmt.Errorf("xrpcserver: %s declares no schema", where)
}
obj, ok := def.Inner.(lexicon.SchemaObject)
if !ok {
return lexicon.SchemaObject{}, fmt.Errorf(
"xrpcserver: %s is %T, not an object, and this transport validates objects only",
where, def.Inner)
}
return obj, nil
}
func paramsAsObject(p *lexicon.SchemaParams) lexicon.SchemaObject {
if p == nil {
return lexicon.SchemaObject{Type: "object"}
}
return lexicon.SchemaObject{Type: "object", Properties: p.Properties, Required: p.Required}
}
func validate(where string, cat *lexicon.BaseCatalog, def lexicon.SchemaObject, data map[string]any) error {
v := make(map[string]any, len(data)+1)
maps.Copy(v, data)
v["$type"] = where
if err := lexicon.ValidateRecord(inline{nsid: where, obj: def, catalog: cat}, v, where, 0); err != nil {
return fmt.Errorf("%s: %w", where, err)
}
return nil
}
