an app.bsky.* indexer

Compare changes

Choose any two refs to compare.

Changed files
+23 -1
cmd
monarch
+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
··· 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
··· 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 {