Something went wrong. Try again.
https://github.com/bluesky-social/goat but with tangled's CI
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340package main
import ( "context" "encoding/json" "fmt" "os"
"github.com/bluesky-social/indigo/api/agnostic" comatproto "github.com/bluesky-social/indigo/api/atproto" "github.com/bluesky-social/indigo/atproto/data" "github.com/bluesky-social/indigo/atproto/identity" "github.com/bluesky-social/indigo/atproto/syntax" "github.com/bluesky-social/indigo/xrpc"
"github.com/urfave/cli/v3")
var cmdRecord = &cli.Command{ Name: "record", Usage: "commands for public repo records", Flags: []cli.Flag{}, Commands: []*cli.Command{ cmdRecordGet, cmdRecordList, &cli.Command{ Name: "create", Usage: "create record from JSON", ArgsUsage: `<file>`, Flags: []cli.Flag{ &cli.StringFlag{ Name: "rkey", Aliases: []string{"r"}, Usage: "record key", }, &cli.BoolFlag{ Name: "no-validate", Aliases: []string{"n"}, Usage: "tells PDS not to validate record Lexicon schema", }, }, Action: runRecordCreate, }, &cli.Command{ Name: "update", Usage: "replace existing record from JSON", ArgsUsage: `<file>`, Flags: []cli.Flag{ &cli.StringFlag{ Name: "rkey", Aliases: []string{"r"}, Required: true, Usage: "record key", }, &cli.BoolFlag{ Name: "no-validate", Aliases: []string{"n"}, Usage: "tells PDS not to validate record Lexicon schema", }, }, Action: runRecordUpdate, }, &cli.Command{ Name: "delete", Usage: "delete an existing record", Flags: []cli.Flag{ &cli.StringFlag{ Name: "collection", Aliases: []string{"c"}, Required: true, Usage: "collection (NSID)", }, &cli.StringFlag{ Name: "rkey", Aliases: []string{"r"}, Required: true, Usage: "record key", }, }, Action: runRecordDelete, }, },}
var cmdRecordGet = &cli.Command{ Name: "get", Usage: "fetch record from the network", ArgsUsage: `<at-uri>`, Flags: []cli.Flag{}, Action: runRecordGet,}
var cmdRecordList = &cli.Command{ Name: "ls", Aliases: []string{"list"}, Usage: "list all records for an account", ArgsUsage: `<at-identifier>`, Flags: []cli.Flag{ &cli.StringFlag{ Name: "collection", Usage: "only list records from a specific collection", }, &cli.BoolFlag{ Name: "collections", Aliases: []string{"c"}, Usage: "list collections, not individual record paths", }, }, Action: runRecordList,}
func runRecordGet(ctx context.Context, cmd *cli.Command) error { dir := identity.DefaultDirectory()
uriArg := cmd.Args().First() if uriArg == "" { return fmt.Errorf("expected a single AT-URI argument") }
aturi, err := syntax.ParseATURI(uriArg) if err != nil { return fmt.Errorf("not a valid AT-URI: %v", err) } ident, err := dir.Lookup(ctx, aturi.Authority()) if err != nil { return err }
record, err := fetchRecord(ctx, *ident, aturi) if err != nil { return err }
b, err := json.MarshalIndent(record, "", " ") if err != nil { return err }
fmt.Println(string(b)) return nil}
func runRecordList(ctx context.Context, cmd *cli.Command) error { username := cmd.Args().First() if username == "" { return fmt.Errorf("need to provide username as an argument") } ident, err := resolveIdent(ctx, username) if err != nil { return err }
// create a new API client to connect to the account's PDS xrpcc := xrpc.Client{ Host: ident.PDSEndpoint(), UserAgent: userAgent(), } if xrpcc.Host == "" { return fmt.Errorf("no PDS endpoint for identity") }
desc, err := comatproto.RepoDescribeRepo(ctx, &xrpcc, ident.DID.String()) if err != nil { return err } if cmd.Bool("collections") { for _, nsid := range desc.Collections { fmt.Printf("%s\n", nsid) } return nil } collections := desc.Collections filter := cmd.String("collection") if filter != "" { collections = []string{filter} }
for _, nsid := range collections { cursor := "" for { // collection string, cursor string, limit int64, repo string, reverse bool resp, err := agnostic.RepoListRecords(ctx, &xrpcc, nsid, cursor, 100, ident.DID.String(), false) if err != nil { return err } for _, rec := range resp.Records { aturi, err := syntax.ParseATURI(rec.Uri) if err != nil { return err } fmt.Printf("%s\t%s\t%s\n", aturi.Collection(), aturi.RecordKey(), rec.Cid) } if resp.Cursor != nil && *resp.Cursor != "" { cursor = *resp.Cursor } else { break } } }
return nil}
func runRecordCreate(ctx context.Context, cmd *cli.Command) error { recordPath := cmd.Args().First() if recordPath == "" { return fmt.Errorf("need to provide file path as an argument") }
xrpcc, err := loadAuthClient(ctx) if err == ErrNoAuthSession { return fmt.Errorf("auth required, but not logged in") } else if err != nil { return err }
recordBytes, err := os.ReadFile(recordPath) if err != nil { return err }
recordVal, err := data.UnmarshalJSON(recordBytes) if err != nil { return err }
nsid, err := data.ExtractTypeJSON(recordBytes) if err != nil { return err }
var rkey *string if cmd.String("rkey") != "" { rk, err := syntax.ParseRecordKey(cmd.String("rkey")) if err != nil { return err } s := rk.String() rkey = &s } validate := !cmd.Bool("no-validate")
resp, err := agnostic.RepoCreateRecord(ctx, xrpcc, &agnostic.RepoCreateRecord_Input{ Collection: nsid, Repo: xrpcc.Auth.Did, Record: recordVal, Rkey: rkey, Validate: &validate, }) if err != nil { return err }
fmt.Printf("%s\t%s\n", resp.Uri, resp.Cid) return nil}
func runRecordUpdate(ctx context.Context, cmd *cli.Command) error { recordPath := cmd.Args().First() if recordPath == "" { return fmt.Errorf("need to provide file path as an argument") }
xrpcc, err := loadAuthClient(ctx) if err == ErrNoAuthSession { return fmt.Errorf("auth required, but not logged in") } else if err != nil { return err }
recordBytes, err := os.ReadFile(recordPath) if err != nil { return err }
recordVal, err := data.UnmarshalJSON(recordBytes) if err != nil { return err }
nsid, err := data.ExtractTypeJSON(recordBytes) if err != nil { return err }
rkey := cmd.String("rkey")
// NOTE: need to fetch existing record CID to perform swap. this is optional in theory, but golang can't deal with "optional" and "nullable", so we always need to set this (?) existing, err := agnostic.RepoGetRecord(ctx, xrpcc, "", nsid, xrpcc.Auth.Did, rkey) if err != nil { return err }
validate := !cmd.Bool("no-validate")
resp, err := agnostic.RepoPutRecord(ctx, xrpcc, &agnostic.RepoPutRecord_Input{ Collection: nsid, Repo: xrpcc.Auth.Did, Record: recordVal, Rkey: rkey, Validate: &validate, SwapRecord: existing.Cid, }) if err != nil { return err }
fmt.Printf("%s\t%s\n", resp.Uri, resp.Cid) return nil}
func runRecordDelete(ctx context.Context, cmd *cli.Command) error {
xrpcc, err := loadAuthClient(ctx) if err == ErrNoAuthSession { return fmt.Errorf("auth required, but not logged in") } else if err != nil { return err }
rkey, err := syntax.ParseRecordKey(cmd.String("rkey")) if err != nil { return err } collection, err := syntax.ParseNSID(cmd.String("collection")) if err != nil { return err }
_, err = comatproto.RepoDeleteRecord(ctx, xrpcc, &comatproto.RepoDeleteRecord_Input{ Collection: collection.String(), Repo: xrpcc.Auth.Did, Rkey: rkey.String(), }) if err != nil { return err } return nil}