+2
go.sum
+2
go.sum
···
10
10
github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
11
11
github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932 h1:mXoPYz/Ul5HYEDvkta6I8/rnYM5gSdSV2tJ6XbZuEtY=
12
12
github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=
13
+
github.com/bluesky-social/indigo v0.0.0-20250808182429-6f0837c2d12b h1:bJTlFwMhB9sluuqZxVXtv2yFcaWOC/PZokz9mcwb4u4=
14
+
github.com/bluesky-social/indigo v0.0.0-20250808182429-6f0837c2d12b/go.mod h1:0XUyOCRtL4/OiyeqMTmr6RlVHQMDgw3LS7CfibuZR5Q=
13
15
github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=
14
16
github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4=
15
17
github.com/bradfitz/gomemcache v0.0.0-20230905024940-24af94b03874 h1:N7oVaKyGp8bttX0bfZGmcGkjz7DLQXhAn3DNd3T0ous=
+1
-1
go.mod
+1
-1
go.mod
···
9
9
github.com/gorilla/websocket v1.5.1
10
10
github.com/ipfs/go-cid v0.4.1
11
11
github.com/urfave/cli/v2 v2.25.7
12
+
golang.org/x/sync v0.7.0
12
13
gorm.io/gorm v1.25.9
13
14
)
14
15
···
102
103
go.uber.org/zap v1.26.0 // indirect
103
104
golang.org/x/crypto v0.21.0 // indirect
104
105
golang.org/x/net v0.23.0 // indirect
105
-
golang.org/x/sync v0.7.0 // indirect
106
106
golang.org/x/sys v0.22.0 // indirect
107
107
golang.org/x/text v0.14.0 // indirect
108
108
golang.org/x/time v0.3.0 // indirect
+20
cmd/monarch/handlers.go
+20
cmd/monarch/handlers.go
···
5
5
"context"
6
6
"encoding/json"
7
7
"fmt"
8
+
"log/slog"
8
9
9
10
appbsky "github.com/bluesky-social/indigo/api/bsky"
10
11
"github.com/bluesky-social/indigo/atproto/syntax"
···
75
76
var out appbsky.LabelerService
76
77
out.UnmarshalCBOR(bytes.NewReader(*rec))
77
78
body, err = json.Marshal(out)
79
+
80
+
case syntax.NSID("app.bsky.graph.list"):
81
+
var out appbsky.GraphList
82
+
out.UnmarshalCBOR(bytes.NewReader(*rec))
83
+
body, err = json.Marshal(out)
84
+
85
+
case syntax.NSID("app.bsky.graph.verification"):
86
+
var out appbsky.GraphVerification
87
+
out.UnmarshalCBOR(bytes.NewReader(*rec))
88
+
body, err = json.Marshal(out)
89
+
90
+
case syntax.NSID("app.bsky.graph.starterpack"):
91
+
var out appbsky.GraphStarterpack
92
+
out.UnmarshalCBOR(bytes.NewReader(*rec))
93
+
body, err = json.Marshal(out)
94
+
95
+
default:
96
+
slog.Error("tracked collection missing handler", "collection", uri.Collection())
97
+
return nil
78
98
}
79
99
80
100
switch action {