alice.mosphere.at / indigo
this repo has no description
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

consistent import grouping

bryan newbold 6d9ab847 00d2c6b7

+84 -82
+2 -2
automod/consumer/firehose.go
··· 13 13 comatproto "github.com/bluesky-social/indigo/api/atproto" 14 14 "github.com/bluesky-social/indigo/atproto/syntax" 15 15 "github.com/bluesky-social/indigo/automod" 16 + "github.com/bluesky-social/indigo/events" 16 17 "github.com/bluesky-social/indigo/events/schedulers/autoscaling" 17 18 "github.com/bluesky-social/indigo/events/schedulers/parallel" 18 19 lexutil "github.com/bluesky-social/indigo/lex/util" 19 - 20 - "github.com/bluesky-social/indigo/events" 21 20 "github.com/bluesky-social/indigo/repo" 22 21 "github.com/bluesky-social/indigo/repomgr" 22 + 23 23 "github.com/earthboundkid/versioninfo/v2" 24 24 "github.com/gorilla/websocket" 25 25 "github.com/redis/go-redis/v9"
+2 -2
cmd/beemo/firehose_consumer.go
··· 11 11 comatproto "github.com/bluesky-social/indigo/api/atproto" 12 12 appbsky "github.com/bluesky-social/indigo/api/bsky" 13 13 "github.com/bluesky-social/indigo/atproto/syntax" 14 + "github.com/bluesky-social/indigo/events" 14 15 "github.com/bluesky-social/indigo/events/schedulers/parallel" 15 16 lexutil "github.com/bluesky-social/indigo/lex/util" 16 - 17 - "github.com/bluesky-social/indigo/events" 18 17 "github.com/bluesky-social/indigo/repo" 19 18 "github.com/bluesky-social/indigo/repomgr" 19 + 20 20 "github.com/earthboundkid/versioninfo/v2" 21 21 "github.com/gorilla/websocket" 22 22 )
+4 -4
cmd/bigsky/main.go
··· 5 5 "fmt" 6 6 "log/slog" 7 7 "net/http" 8 - _ "net/http/pprof" 9 8 "net/url" 10 9 "os" 11 10 "os/signal" ··· 13 12 "strings" 14 13 "syscall" 15 14 "time" 15 + 16 + _ "github.com/joho/godotenv/autoload" 17 + _ "go.uber.org/automaxprocs" 18 + _ "net/http/pprof" 16 19 17 20 libbgs "github.com/bluesky-social/indigo/bgs" 18 21 "github.com/bluesky-social/indigo/carstore" ··· 27 30 "github.com/bluesky-social/indigo/util" 28 31 "github.com/bluesky-social/indigo/util/cliutil" 29 32 "github.com/bluesky-social/indigo/xrpc" 30 - 31 - _ "github.com/joho/godotenv/autoload" 32 - _ "go.uber.org/automaxprocs" 33 33 34 34 "github.com/earthboundkid/versioninfo/v2" 35 35 "github.com/urfave/cli/v2"
+1 -1
cmd/bluepages/firehose.go
··· 10 10 11 11 comatproto "github.com/bluesky-social/indigo/api/atproto" 12 12 "github.com/bluesky-social/indigo/atproto/syntax" 13 + "github.com/bluesky-social/indigo/events" 13 14 "github.com/bluesky-social/indigo/events/schedulers/parallel" 14 15 15 - "github.com/bluesky-social/indigo/events" 16 16 "github.com/earthboundkid/versioninfo/v2" 17 17 "github.com/gorilla/websocket" 18 18 "github.com/redis/go-redis/v9"
+3 -2
cmd/bluepages/main.go
··· 6 6 "fmt" 7 7 "io" 8 8 "log/slog" 9 - _ "net/http/pprof" 10 9 "os" 11 10 "runtime" 12 11 "strings" 13 12 13 + _ "github.com/joho/godotenv/autoload" 14 + _ "net/http/pprof" 15 + 14 16 "github.com/bluesky-social/indigo/atproto/identity/apidir" 15 17 "github.com/bluesky-social/indigo/atproto/syntax" 16 18 17 19 "github.com/earthboundkid/versioninfo/v2" 18 - _ "github.com/joho/godotenv/autoload" 19 20 "github.com/urfave/cli/v2" 20 21 ) 21 22
+3 -3
cmd/fakermaker/main.go
··· 11 11 "os" 12 12 "runtime" 13 13 14 + _ "github.com/joho/godotenv/autoload" 15 + _ "go.uber.org/automaxprocs" 16 + 14 17 comatproto "github.com/bluesky-social/indigo/api/atproto" 15 18 "github.com/bluesky-social/indigo/fakedata" 16 19 "github.com/bluesky-social/indigo/util/cliutil" 17 - 18 - _ "github.com/joho/godotenv/autoload" 19 - _ "go.uber.org/automaxprocs" 20 20 21 21 "github.com/earthboundkid/versioninfo/v2" 22 22 "github.com/urfave/cli/v2"
+1 -1
cmd/gosky/account.go
··· 10 10 comatproto "github.com/bluesky-social/indigo/api/atproto" 11 11 "github.com/bluesky-social/indigo/util/cliutil" 12 12 13 - cli "github.com/urfave/cli/v2" 13 + "github.com/urfave/cli/v2" 14 14 ) 15 15 16 16 var accountCmd = &cli.Command{
+2 -1
cmd/gosky/admin.go
··· 17 17 "github.com/bluesky-social/indigo/atproto/syntax" 18 18 "github.com/bluesky-social/indigo/handles" 19 19 "github.com/bluesky-social/indigo/util/cliutil" 20 - cli "github.com/urfave/cli/v2" 20 + 21 + "github.com/urfave/cli/v2" 21 22 ) 22 23 23 24 var adminCmd = &cli.Command{
+2 -1
cmd/gosky/bgs.go
··· 9 9 "strconv" 10 10 11 11 "github.com/bluesky-social/indigo/xrpc" 12 - cli "github.com/urfave/cli/v2" 12 + 13 + "github.com/urfave/cli/v2" 13 14 ) 14 15 15 16 var bgsAdminCmd = &cli.Command{
+1 -1
cmd/gosky/bsky.go
··· 13 13 "github.com/bluesky-social/indigo/util" 14 14 "github.com/bluesky-social/indigo/util/cliutil" 15 15 16 - cli "github.com/urfave/cli/v2" 16 + "github.com/urfave/cli/v2" 17 17 ) 18 18 19 19 var bskyCmd = &cli.Command{
+1 -1
cmd/gosky/car.go
··· 12 12 "github.com/bluesky-social/indigo/repo" 13 13 14 14 "github.com/ipfs/go-cid" 15 - cli "github.com/urfave/cli/v2" 15 + "github.com/urfave/cli/v2" 16 16 ) 17 17 18 18 var carCmd = &cli.Command{
+1 -1
cmd/gosky/debug.go
··· 34 34 "github.com/ipfs/go-cid" 35 35 "github.com/ipfs/go-libipfs/blocks" 36 36 "github.com/ipld/go-car/v2" 37 - cli "github.com/urfave/cli/v2" 37 + "github.com/urfave/cli/v2" 38 38 ) 39 39 40 40 var debugCmd = &cli.Command{
+1 -1
cmd/gosky/did.go
··· 9 9 "github.com/bluesky-social/indigo/atproto/syntax" 10 10 "github.com/bluesky-social/indigo/util/cliutil" 11 11 12 - cli "github.com/urfave/cli/v2" 12 + "github.com/urfave/cli/v2" 13 13 ) 14 14 15 15 var didCmd = &cli.Command{
+1 -1
cmd/gosky/handle.go
··· 9 9 "github.com/bluesky-social/indigo/atproto/syntax" 10 10 "github.com/bluesky-social/indigo/util/cliutil" 11 11 12 - cli "github.com/urfave/cli/v2" 12 + "github.com/urfave/cli/v2" 13 13 ) 14 14 15 15 var handleCmd = &cli.Command{
+5 -6
cmd/gosky/main.go
··· 15 15 "syscall" 16 16 "time" 17 17 18 + _ "github.com/joho/godotenv/autoload" 19 + 18 20 "github.com/bluesky-social/indigo/api/atproto" 19 21 comatproto "github.com/bluesky-social/indigo/api/atproto" 20 22 "github.com/bluesky-social/indigo/api/bsky" ··· 28 30 "github.com/bluesky-social/indigo/util" 29 31 "github.com/bluesky-social/indigo/util/cliutil" 30 32 "github.com/bluesky-social/indigo/xrpc" 31 - "golang.org/x/time/rate" 32 33 34 + "github.com/earthboundkid/versioninfo/v2" 33 35 "github.com/gorilla/websocket" 34 36 lru "github.com/hashicorp/golang-lru/v2" 35 37 "github.com/ipfs/go-cid" 36 38 "github.com/ipfs/go-datastore" 37 39 blockstore "github.com/ipfs/go-ipfs-blockstore" 38 40 "github.com/ipld/go-car" 39 - 40 - _ "github.com/joho/godotenv/autoload" 41 - 42 - "github.com/earthboundkid/versioninfo/v2" 43 41 "github.com/polydawn/refmt/cbor" 44 42 rejson "github.com/polydawn/refmt/json" 45 43 "github.com/polydawn/refmt/shared" 46 - cli "github.com/urfave/cli/v2" 44 + "github.com/urfave/cli/v2" 45 + "golang.org/x/time/rate" 47 46 ) 48 47 49 48 var log = slog.Default().With("system", "gosky")
+2 -1
cmd/gosky/streamdiff.go
··· 8 8 comatproto "github.com/bluesky-social/indigo/api/atproto" 9 9 "github.com/bluesky-social/indigo/events" 10 10 "github.com/bluesky-social/indigo/events/schedulers/sequential" 11 + 11 12 "github.com/gorilla/websocket" 12 - cli "github.com/urfave/cli/v2" 13 + "github.com/urfave/cli/v2" 13 14 ) 14 15 15 16 // TODO: WIP - turns out to be more complicated than i initially thought
+4 -3
cmd/hepa/main.go
··· 7 7 "io" 8 8 "log/slog" 9 9 "net/http" 10 - _ "net/http/pprof" 11 10 "os" 12 11 "runtime" 13 12 "strings" 14 13 "time" 14 + 15 + _ "github.com/joho/godotenv/autoload" 16 + _ "net/http/pprof" 15 17 16 18 "github.com/bluesky-social/indigo/atproto/identity" 17 19 "github.com/bluesky-social/indigo/atproto/identity/redisdir" ··· 20 22 "github.com/bluesky-social/indigo/automod/consumer" 21 23 22 24 "github.com/earthboundkid/versioninfo/v2" 23 - _ "github.com/joho/godotenv/autoload" 24 - cli "github.com/urfave/cli/v2" 25 + "github.com/urfave/cli/v2" 25 26 "golang.org/x/time/rate" 26 27 ) 27 28
+2 -2
cmd/lexgen/main.go
··· 8 8 "path/filepath" 9 9 "strings" 10 10 11 - lex "github.com/bluesky-social/indigo/lex" 12 - cli "github.com/urfave/cli/v2" 11 + "github.com/bluesky-social/indigo/lex" 12 + "github.com/urfave/cli/v2" 13 13 ) 14 14 15 15 func findSchemas(dir string, out []string) ([]string, error) {
+5 -5
cmd/netsync/main.go
··· 19 19 "syscall" 20 20 "time" 21 21 22 + _ "github.com/joho/godotenv/autoload" 23 + 22 24 "github.com/bluesky-social/indigo/atproto/atdata" 23 25 "github.com/bluesky-social/indigo/repo" 26 + 27 + "github.com/earthboundkid/versioninfo/v2" 24 28 "github.com/ipfs/go-cid" 25 - _ "github.com/joho/godotenv/autoload" 26 29 "github.com/prometheus/client_golang/prometheus" 27 30 "github.com/prometheus/client_golang/prometheus/promauto" 28 31 "github.com/prometheus/client_golang/prometheus/promhttp" 29 - 32 + "github.com/urfave/cli/v2" 30 33 "golang.org/x/time/rate" 31 - 32 - "github.com/earthboundkid/versioninfo/v2" 33 - "github.com/urfave/cli/v2" 34 34 ) 35 35 36 36 func main() {
+8 -8
cmd/palomar/main.go
··· 13 13 "time" 14 14 15 15 _ "github.com/joho/godotenv/autoload" 16 - "go.opentelemetry.io/otel" 17 - "go.opentelemetry.io/otel/attribute" 18 - "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp" 19 - "go.opentelemetry.io/otel/sdk/resource" 20 - tracesdk "go.opentelemetry.io/otel/sdk/trace" 21 - semconv "go.opentelemetry.io/otel/semconv/v1.4.0" 22 - "golang.org/x/time/rate" 23 16 24 17 "github.com/bluesky-social/indigo/atproto/identity" 25 18 "github.com/bluesky-social/indigo/search" ··· 27 20 28 21 "github.com/earthboundkid/versioninfo/v2" 29 22 es "github.com/opensearch-project/opensearch-go/v2" 30 - cli "github.com/urfave/cli/v2" 23 + "github.com/urfave/cli/v2" 24 + "go.opentelemetry.io/otel" 25 + "go.opentelemetry.io/otel/attribute" 26 + "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp" 27 + "go.opentelemetry.io/otel/sdk/resource" 28 + tracesdk "go.opentelemetry.io/otel/sdk/trace" 29 + semconv "go.opentelemetry.io/otel/semconv/v1.4.0" 30 + "golang.org/x/time/rate" 31 31 ) 32 32 33 33 func main() {
+4 -6
cmd/querycheck/main.go
··· 5 5 "fmt" 6 6 "log" 7 7 "log/slog" 8 + "net/http" 8 9 "os" 9 10 "os/signal" 10 11 "sync" 11 12 "syscall" 12 13 13 - "net/http" 14 14 _ "net/http/pprof" 15 15 16 16 "github.com/bluesky-social/indigo/querycheck" 17 17 "github.com/bluesky-social/indigo/util/tracing" 18 + 19 + "github.com/earthboundkid/versioninfo/v2" 18 20 "github.com/labstack/echo-contrib/pprof" 19 21 "github.com/labstack/echo/v4" 20 - 21 22 "github.com/labstack/echo/v4/middleware" 22 - 23 23 "github.com/prometheus/client_golang/prometheus/promhttp" 24 + "github.com/urfave/cli/v2" 24 25 "go.opentelemetry.io/otel/trace" 25 - 26 - "github.com/earthboundkid/versioninfo/v2" 27 - "github.com/urfave/cli/v2" 28 26 ) 29 27 30 28 func main() {
+4 -3
cmd/sonar/main.go
··· 13 13 "syscall" 14 14 "time" 15 15 16 + _ "go.uber.org/automaxprocs" 17 + 16 18 "github.com/bluesky-social/indigo/events" 17 19 "github.com/bluesky-social/indigo/events/schedulers/sequential" 20 + 21 + "github.com/earthboundkid/versioninfo/v2" 18 22 "github.com/gorilla/websocket" 19 23 "github.com/prometheus/client_golang/prometheus/promhttp" 20 - _ "go.uber.org/automaxprocs" 21 - 22 - "github.com/earthboundkid/versioninfo/v2" 23 24 "github.com/urfave/cli/v2" 24 25 ) 25 26
+4 -5
cmd/stress/main.go
··· 9 9 "sync" 10 10 "time" 11 11 12 + _ "github.com/joho/godotenv/autoload" 13 + 12 14 comatproto "github.com/bluesky-social/indigo/api/atproto" 13 15 appbsky "github.com/bluesky-social/indigo/api/bsky" 14 16 "github.com/bluesky-social/indigo/carstore" ··· 18 20 "github.com/bluesky-social/indigo/util/cliutil" 19 21 "github.com/bluesky-social/indigo/xrpc" 20 22 23 + "github.com/earthboundkid/versioninfo/v2" 21 24 "github.com/ipfs/go-cid" 22 25 "github.com/ipfs/go-datastore" 23 26 blockstore "github.com/ipfs/go-ipfs-blockstore" 24 27 cbor "github.com/ipfs/go-ipld-cbor" 25 - 26 - _ "github.com/joho/godotenv/autoload" 27 - 28 - "github.com/earthboundkid/versioninfo/v2" 29 28 "github.com/ipld/go-car" 30 - cli "github.com/urfave/cli/v2" 29 + "github.com/urfave/cli/v2" 31 30 ) 32 31 33 32 func main() {
+13 -14
cmd/supercollider/main.go
··· 7 7 "log" 8 8 "log/slog" 9 9 "net" 10 + "net/http" 10 11 "os" 11 12 "os/signal" 12 13 "path/filepath" ··· 15 16 "syscall" 16 17 "time" 17 18 18 - "net/http" 19 + _ "go.uber.org/automaxprocs" 19 20 _ "net/http/pprof" 20 21 21 22 "github.com/bluesky-social/indigo/api/atproto" ··· 26 27 "github.com/bluesky-social/indigo/events" 27 28 "github.com/bluesky-social/indigo/events/yolopersist" 28 29 "github.com/bluesky-social/indigo/indexer" 30 + lexutil "github.com/bluesky-social/indigo/lex/util" 29 31 "github.com/bluesky-social/indigo/models" 30 32 "github.com/bluesky-social/indigo/plc" 33 + "github.com/bluesky-social/indigo/repomgr" 34 + "github.com/bluesky-social/indigo/util" 35 + 31 36 petname "github.com/dustinkirkland/golang-petname" 37 + "github.com/earthboundkid/versioninfo/v2" 38 + "github.com/gorilla/websocket" 32 39 "github.com/icrowley/fake" 33 40 "github.com/labstack/echo-contrib/pprof" 34 - "github.com/urfave/cli/v2" 35 - godid "github.com/whyrusleeping/go-did" 36 - "golang.org/x/crypto/acme/autocert" 37 - "golang.org/x/time/rate" 38 - 39 - lexutil "github.com/bluesky-social/indigo/lex/util" 40 - "github.com/bluesky-social/indigo/repomgr" 41 - "github.com/bluesky-social/indigo/util" 42 - "github.com/gorilla/websocket" 43 41 "github.com/labstack/echo/v4" 44 42 "github.com/labstack/echo/v4/middleware" 45 43 "github.com/prometheus/client_golang/prometheus" 46 44 "github.com/prometheus/client_golang/prometheus/promauto" 47 45 "github.com/prometheus/client_golang/prometheus/promhttp" 48 - _ "go.uber.org/automaxprocs" 46 + "github.com/urfave/cli/v2" 47 + cbg "github.com/whyrusleeping/cbor-gen" 48 + godid "github.com/whyrusleeping/go-did" 49 + "golang.org/x/crypto/acme/autocert" 50 + "golang.org/x/time/rate" 49 51 "gorm.io/driver/sqlite" 50 52 "gorm.io/gorm" 51 - 52 - "github.com/earthboundkid/versioninfo/v2" 53 - cbg "github.com/whyrusleeping/cbor-gen" 54 53 ) 55 54 56 55 var eventsGeneratedCounter = promauto.NewCounter(prometheus.CounterOpts{
+5 -5
search/firehose.go
··· 17 17 "github.com/bluesky-social/indigo/events/schedulers/autoscaling" 18 18 lexutil "github.com/bluesky-social/indigo/lex/util" 19 19 "github.com/bluesky-social/indigo/repo" 20 - typegen "github.com/whyrusleeping/cbor-gen" 21 20 22 21 "github.com/earthboundkid/versioninfo/v2" 23 22 "github.com/gorilla/websocket" 24 23 "github.com/ipfs/go-cid" 24 + typegen "github.com/whyrusleeping/cbor-gen" 25 25 ) 26 26 27 27 func (idx *Indexer) getLastCursor() (int64, error) { ··· 219 219 } 220 220 221 221 switch rec := rec.(type) { 222 - case *bsky.FeedPost: 222 + case *appbsky.FeedPost: 223 223 rkey, err := syntax.ParseTID(parts[1]) 224 224 if err != nil { 225 225 logger.Warn("skipping post record with non-TID rkey") ··· 236 236 // Send the job to the bulk indexer 237 237 idx.postQueue <- &job 238 238 postsIndexed.Inc() 239 - case *bsky.ActorProfile: 239 + case *appbsky.ActorProfile: 240 240 if parts[1] != "self" { 241 241 return nil 242 242 } ··· 330 330 } 331 331 332 332 switch rec := rec.(type) { 333 - case *bsky.FeedPost: 333 + case *appbsky.FeedPost: 334 334 rkey, err := syntax.ParseTID(parts[1]) 335 335 if err != nil { 336 336 logger.Warn("skipping post record with non-TID rkey") ··· 346 346 347 347 // Send the job to the bulk indexer 348 348 idx.postQueue <- &job 349 - case *bsky.ActorProfile: 349 + case *appbsky.ActorProfile: 350 350 if parts[1] != "self" { 351 351 return nil 352 352 }
+2 -2
search/server.go
··· 9 9 "os" 10 10 "strings" 11 11 12 + _ "net/http/pprof" // For pprof in the metrics server 13 + 12 14 "github.com/bluesky-social/indigo/atproto/identity" 13 15 14 16 "github.com/earthboundkid/versioninfo/v2" ··· 18 20 "github.com/prometheus/client_golang/prometheus/promhttp" 19 21 slogecho "github.com/samber/slog-echo" 20 22 "go.opentelemetry.io/contrib/instrumentation/github.com/labstack/echo/otelecho" 21 - 22 - _ "net/http/pprof" // For pprof in the metrics server 23 23 ) 24 24 25 25 type LastSeq struct {
+1
xrpc/xrpc.go
··· 14 14 "time" 15 15 16 16 "github.com/bluesky-social/indigo/util" 17 + 17 18 "github.com/earthboundkid/versioninfo/v2" 18 19 ) 19 20