···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// IdentityUpdateHandle_Input is the input argument to a com.atproto.identity.updateHandle call.
···1717}
18181919// IdentityUpdateHandle calls the XRPC method "com.atproto.identity.updateHandle".
2020-func IdentityUpdateHandle(ctx context.Context, c util.LexClient, input *IdentityUpdateHandle_Input) error {
2121- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.identity.updateHandle", nil, input, nil); err != nil {
2020+func IdentityUpdateHandle(ctx context.Context, c lexutil.LexClient, input *IdentityUpdateHandle_Input) error {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.identity.updateHandle", nil, input, nil); err != nil {
2222 return err
2323 }
2424
+2-2
api/atproto/labeldefs.go
···55package atproto
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111// LabelDefs_Label is a "label" in the com.atproto.label.defs schema.
···2121 // neg: If true, this is a negation label, overwriting a previous label.
2222 Neg *bool `json:"neg,omitempty" cborgen:"neg,omitempty"`
2323 // sig: Signature of dag-cbor encoded label.
2424- Sig util.LexBytes `json:"sig,omitempty" cborgen:"sig,omitempty"`
2424+ Sig lexutil.LexBytes `json:"sig,omitempty" cborgen:"sig,omitempty"`
2525 // src: DID of the actor who created this label.
2626 Src string `json:"src" cborgen:"src"`
2727 // uri: AT URI of the record, repository (account), or other resource that this label applies to.
+3-3
api/atproto/labelqueryLabels.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// LabelQueryLabels_Output is the output of a com.atproto.label.queryLabels call.
···2020//
2121// sources: Optional list of label sources (DIDs) to filter on.
2222// uriPatterns: List of AT URI patterns to match (boolean 'OR'). Each may be a prefix (ending with '*'; will match inclusive of the string leading to '*'), or a full URI.
2323-func LabelQueryLabels(ctx context.Context, c util.LexClient, cursor string, limit int64, sources []string, uriPatterns []string) (*LabelQueryLabels_Output, error) {
2323+func LabelQueryLabels(ctx context.Context, c lexutil.LexClient, cursor string, limit int64, sources []string, uriPatterns []string) (*LabelQueryLabels_Output, error) {
2424 var out LabelQueryLabels_Output
25252626 params := map[string]interface{}{}
···3434 params["sources"] = sources
3535 }
3636 params["uriPatterns"] = uriPatterns
3737- if err := c.LexDo(ctx, util.Query, "", "com.atproto.label.queryLabels", params, nil, &out); err != nil {
3737+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.label.queryLabels", params, nil, &out); err != nil {
3838 return nil, err
3939 }
4040
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// RepoListMissingBlobs_Output is the output of a com.atproto.repo.listMissingBlobs call.
···2323}
24242525// RepoListMissingBlobs calls the XRPC method "com.atproto.repo.listMissingBlobs".
2626-func RepoListMissingBlobs(ctx context.Context, c util.LexClient, cursor string, limit int64) (*RepoListMissingBlobs_Output, error) {
2626+func RepoListMissingBlobs(ctx context.Context, c lexutil.LexClient, cursor string, limit int64) (*RepoListMissingBlobs_Output, error) {
2727 var out RepoListMissingBlobs_Output
28282929 params := map[string]interface{}{}
···3333 if limit != 0 {
3434 params["limit"] = limit
3535 }
3636- if err := c.LexDo(ctx, util.Query, "", "com.atproto.repo.listMissingBlobs", params, nil, &out); err != nil {
3636+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.repo.listMissingBlobs", params, nil, &out); err != nil {
3737 return nil, err
3838 }
3939
+6-6
api/atproto/repolistRecords.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// RepoListRecords_Output is the output of a com.atproto.repo.listRecords call.
···18181919// RepoListRecords_Record is a "record" in the com.atproto.repo.listRecords schema.
2020type RepoListRecords_Record struct {
2121- Cid string `json:"cid" cborgen:"cid"`
2222- Uri string `json:"uri" cborgen:"uri"`
2323- Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"`
2121+ Cid string `json:"cid" cborgen:"cid"`
2222+ Uri string `json:"uri" cborgen:"uri"`
2323+ Value *lexutil.LexiconTypeDecoder `json:"value" cborgen:"value"`
2424}
25252626// RepoListRecords calls the XRPC method "com.atproto.repo.listRecords".
···2929// limit: The number of records to return.
3030// repo: The handle or DID of the repo.
3131// reverse: Flag to reverse the order of the returned records.
3232-func RepoListRecords(ctx context.Context, c util.LexClient, collection string, cursor string, limit int64, repo string, reverse bool) (*RepoListRecords_Output, error) {
3232+func RepoListRecords(ctx context.Context, c lexutil.LexClient, collection string, cursor string, limit int64, repo string, reverse bool) (*RepoListRecords_Output, error) {
3333 var out RepoListRecords_Output
34343535 params := map[string]interface{}{}
···4444 if reverse {
4545 params["reverse"] = reverse
4646 }
4747- if err := c.LexDo(ctx, util.Query, "", "com.atproto.repo.listRecords", params, nil, &out); err != nil {
4747+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.repo.listRecords", params, nil, &out); err != nil {
4848 return nil, err
4949 }
5050
+4-4
api/atproto/repoputRecord.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// RepoPutRecord_Input is the input argument to a com.atproto.repo.putRecord call.
···1515 // collection: The NSID of the record collection.
1616 Collection string `json:"collection" cborgen:"collection"`
1717 // record: The record to write.
1818- Record *util.LexiconTypeDecoder `json:"record" cborgen:"record"`
1818+ Record *lexutil.LexiconTypeDecoder `json:"record" cborgen:"record"`
1919 // repo: The handle or DID of the repo (aka, current account).
2020 Repo string `json:"repo" cborgen:"repo"`
2121 // rkey: The Record Key.
···3737}
38383939// RepoPutRecord calls the XRPC method "com.atproto.repo.putRecord".
4040-func RepoPutRecord(ctx context.Context, c util.LexClient, input *RepoPutRecord_Input) (*RepoPutRecord_Output, error) {
4040+func RepoPutRecord(ctx context.Context, c lexutil.LexClient, input *RepoPutRecord_Input) (*RepoPutRecord_Output, error) {
4141 var out RepoPutRecord_Output
4242- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.repo.putRecord", nil, input, &out); err != nil {
4242+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.repo.putRecord", nil, input, &out); err != nil {
4343 return nil, err
4444 }
4545
+2-2
api/atproto/repostrongRef.go
···55package atproto
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111func init() {
1212- util.RegisterType("com.atproto.repo.strongRef#main", &RepoStrongRef{})
1212+ lexutil.RegisterType("com.atproto.repo.strongRef#main", &RepoStrongRef{})
1313}
14141515// RepoStrongRef is a "main" in the com.atproto.repo.strongRef schema.
+4-4
api/atproto/repouploadBlob.go
···88 "context"
99 "io"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// RepoUploadBlob_Output is the output of a com.atproto.repo.uploadBlob call.
1515type RepoUploadBlob_Output struct {
1616- Blob *util.LexBlob `json:"blob" cborgen:"blob"`
1616+ Blob *lexutil.LexBlob `json:"blob" cborgen:"blob"`
1717}
18181919// RepoUploadBlob calls the XRPC method "com.atproto.repo.uploadBlob".
2020-func RepoUploadBlob(ctx context.Context, c util.LexClient, input io.Reader) (*RepoUploadBlob_Output, error) {
2020+func RepoUploadBlob(ctx context.Context, c lexutil.LexClient, input io.Reader) (*RepoUploadBlob_Output, error) {
2121 var out RepoUploadBlob_Output
2222- if err := c.LexDo(ctx, util.Procedure, "*/*", "com.atproto.repo.uploadBlob", nil, input, &out); err != nil {
2222+ if err := c.LexDo(ctx, lexutil.Procedure, "*/*", "com.atproto.repo.uploadBlob", nil, input, &out); err != nil {
2323 return nil, err
2424 }
2525
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerDescribeServer_Contact is a "contact" in the com.atproto.server.describeServer schema.
···3737}
38383939// ServerDescribeServer calls the XRPC method "com.atproto.server.describeServer".
4040-func ServerDescribeServer(ctx context.Context, c util.LexClient) (*ServerDescribeServer_Output, error) {
4040+func ServerDescribeServer(ctx context.Context, c lexutil.LexClient) (*ServerDescribeServer_Output, error) {
4141 var out ServerDescribeServer_Output
4242- if err := c.LexDo(ctx, util.Query, "", "com.atproto.server.describeServer", nil, nil, &out); err != nil {
4242+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.server.describeServer", nil, nil, &out); err != nil {
4343 return nil, err
4444 }
4545
+3-3
api/atproto/servergetAccountInviteCodes.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerGetAccountInviteCodes_Output is the output of a com.atproto.server.getAccountInviteCodes call.
···1818// ServerGetAccountInviteCodes calls the XRPC method "com.atproto.server.getAccountInviteCodes".
1919//
2020// createAvailable: Controls whether any new 'earned' but not 'created' invites should be created.
2121-func ServerGetAccountInviteCodes(ctx context.Context, c util.LexClient, createAvailable bool, includeUsed bool) (*ServerGetAccountInviteCodes_Output, error) {
2121+func ServerGetAccountInviteCodes(ctx context.Context, c lexutil.LexClient, createAvailable bool, includeUsed bool) (*ServerGetAccountInviteCodes_Output, error) {
2222 var out ServerGetAccountInviteCodes_Output
23232424 params := map[string]interface{}{}
···2828 if includeUsed {
2929 params["includeUsed"] = includeUsed
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "com.atproto.server.getAccountInviteCodes", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.server.getAccountInviteCodes", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/atproto/servergetServiceAuth.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerGetServiceAuth_Output is the output of a com.atproto.server.getServiceAuth call.
···2020// aud: The DID of the service that the token will be used to authenticate with
2121// exp: The time in Unix Epoch seconds that the JWT expires. Defaults to 60 seconds in the future. The service may enforce certain time bounds on tokens depending on the requested scope.
2222// lxm: Lexicon (XRPC) method to bind the requested token to
2323-func ServerGetServiceAuth(ctx context.Context, c util.LexClient, aud string, exp int64, lxm string) (*ServerGetServiceAuth_Output, error) {
2323+func ServerGetServiceAuth(ctx context.Context, c lexutil.LexClient, aud string, exp int64, lxm string) (*ServerGetServiceAuth_Output, error) {
2424 var out ServerGetServiceAuth_Output
25252626 params := map[string]interface{}{}
···3131 if lxm != "" {
3232 params["lxm"] = lxm
3333 }
3434- if err := c.LexDo(ctx, util.Query, "", "com.atproto.server.getServiceAuth", params, nil, &out); err != nil {
3434+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.server.getServiceAuth", params, nil, &out); err != nil {
3535 return nil, err
3636 }
3737
+3-3
api/atproto/servergetSession.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerGetSession_Output is the output of a com.atproto.server.getSession call.
···2424}
25252626// ServerGetSession calls the XRPC method "com.atproto.server.getSession".
2727-func ServerGetSession(ctx context.Context, c util.LexClient) (*ServerGetSession_Output, error) {
2727+func ServerGetSession(ctx context.Context, c lexutil.LexClient) (*ServerGetSession_Output, error) {
2828 var out ServerGetSession_Output
2929- if err := c.LexDo(ctx, util.Query, "", "com.atproto.server.getSession", nil, nil, &out); err != nil {
2929+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.server.getSession", nil, nil, &out); err != nil {
3030 return nil, err
3131 }
3232
+3-3
api/atproto/serverlistAppPasswords.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerListAppPasswords_AppPassword is a "appPassword" in the com.atproto.server.listAppPasswords schema.
···2323}
24242525// ServerListAppPasswords calls the XRPC method "com.atproto.server.listAppPasswords".
2626-func ServerListAppPasswords(ctx context.Context, c util.LexClient) (*ServerListAppPasswords_Output, error) {
2626+func ServerListAppPasswords(ctx context.Context, c lexutil.LexClient) (*ServerListAppPasswords_Output, error) {
2727 var out ServerListAppPasswords_Output
2828- if err := c.LexDo(ctx, util.Query, "", "com.atproto.server.listAppPasswords", nil, nil, &out); err != nil {
2828+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.server.listAppPasswords", nil, nil, &out); err != nil {
2929 return nil, err
3030 }
3131
+3-3
api/atproto/serverrefreshSession.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerRefreshSession_Output is the output of a com.atproto.server.refreshSession call.
···2323}
24242525// ServerRefreshSession calls the XRPC method "com.atproto.server.refreshSession".
2626-func ServerRefreshSession(ctx context.Context, c util.LexClient) (*ServerRefreshSession_Output, error) {
2626+func ServerRefreshSession(ctx context.Context, c lexutil.LexClient) (*ServerRefreshSession_Output, error) {
2727 var out ServerRefreshSession_Output
2828- if err := c.LexDo(ctx, util.Procedure, "", "com.atproto.server.refreshSession", nil, nil, &out); err != nil {
2828+ if err := c.LexDo(ctx, lexutil.Procedure, "", "com.atproto.server.refreshSession", nil, nil, &out); err != nil {
2929 return nil, err
3030 }
3131
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerRequestEmailUpdate_Output is the output of a com.atproto.server.requestEmailUpdate call.
···1616}
17171818// ServerRequestEmailUpdate calls the XRPC method "com.atproto.server.requestEmailUpdate".
1919-func ServerRequestEmailUpdate(ctx context.Context, c util.LexClient) (*ServerRequestEmailUpdate_Output, error) {
1919+func ServerRequestEmailUpdate(ctx context.Context, c lexutil.LexClient) (*ServerRequestEmailUpdate_Output, error) {
2020 var out ServerRequestEmailUpdate_Output
2121- if err := c.LexDo(ctx, util.Procedure, "", "com.atproto.server.requestEmailUpdate", nil, nil, &out); err != nil {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "", "com.atproto.server.requestEmailUpdate", nil, nil, &out); err != nil {
2222 return nil, err
2323 }
2424
+3-3
api/atproto/serverrequestPasswordReset.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerRequestPasswordReset_Input is the input argument to a com.atproto.server.requestPasswordReset call.
···1616}
17171818// ServerRequestPasswordReset calls the XRPC method "com.atproto.server.requestPasswordReset".
1919-func ServerRequestPasswordReset(ctx context.Context, c util.LexClient, input *ServerRequestPasswordReset_Input) error {
2020- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.server.requestPasswordReset", nil, input, nil); err != nil {
1919+func ServerRequestPasswordReset(ctx context.Context, c lexutil.LexClient, input *ServerRequestPasswordReset_Input) error {
2020+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.server.requestPasswordReset", nil, input, nil); err != nil {
2121 return err
2222 }
2323
+3-3
api/atproto/serverreserveSigningKey.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerReserveSigningKey_Input is the input argument to a com.atproto.server.reserveSigningKey call.
···2323}
24242525// ServerReserveSigningKey calls the XRPC method "com.atproto.server.reserveSigningKey".
2626-func ServerReserveSigningKey(ctx context.Context, c util.LexClient, input *ServerReserveSigningKey_Input) (*ServerReserveSigningKey_Output, error) {
2626+func ServerReserveSigningKey(ctx context.Context, c lexutil.LexClient, input *ServerReserveSigningKey_Input) (*ServerReserveSigningKey_Output, error) {
2727 var out ServerReserveSigningKey_Output
2828- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.server.reserveSigningKey", nil, input, &out); err != nil {
2828+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.server.reserveSigningKey", nil, input, &out); err != nil {
2929 return nil, err
3030 }
3131
+3-3
api/atproto/serverresetPassword.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerResetPassword_Input is the input argument to a com.atproto.server.resetPassword call.
···1717}
18181919// ServerResetPassword calls the XRPC method "com.atproto.server.resetPassword".
2020-func ServerResetPassword(ctx context.Context, c util.LexClient, input *ServerResetPassword_Input) error {
2121- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.server.resetPassword", nil, input, nil); err != nil {
2020+func ServerResetPassword(ctx context.Context, c lexutil.LexClient, input *ServerResetPassword_Input) error {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.server.resetPassword", nil, input, nil); err != nil {
2222 return err
2323 }
2424
+3-3
api/atproto/serverrevokeAppPassword.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerRevokeAppPassword_Input is the input argument to a com.atproto.server.revokeAppPassword call.
···1616}
17171818// ServerRevokeAppPassword calls the XRPC method "com.atproto.server.revokeAppPassword".
1919-func ServerRevokeAppPassword(ctx context.Context, c util.LexClient, input *ServerRevokeAppPassword_Input) error {
2020- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.server.revokeAppPassword", nil, input, nil); err != nil {
1919+func ServerRevokeAppPassword(ctx context.Context, c lexutil.LexClient, input *ServerRevokeAppPassword_Input) error {
2020+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.server.revokeAppPassword", nil, input, nil); err != nil {
2121 return err
2222 }
2323
+3-3
api/atproto/serverupdateEmail.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ServerUpdateEmail_Input is the input argument to a com.atproto.server.updateEmail call.
···1919}
20202121// ServerUpdateEmail calls the XRPC method "com.atproto.server.updateEmail".
2222-func ServerUpdateEmail(ctx context.Context, c util.LexClient, input *ServerUpdateEmail_Input) error {
2323- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.server.updateEmail", nil, input, nil); err != nil {
2222+func ServerUpdateEmail(ctx context.Context, c lexutil.LexClient, input *ServerUpdateEmail_Input) error {
2323+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.server.updateEmail", nil, input, nil); err != nil {
2424 return err
2525 }
2626
+3-3
api/atproto/syncgetBlob.go
···88 "bytes"
99 "context"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// SyncGetBlob calls the XRPC method "com.atproto.sync.getBlob".
1515//
1616// cid: The CID of the blob to fetch
1717// did: The DID of the account.
1818-func SyncGetBlob(ctx context.Context, c util.LexClient, cid string, did string) ([]byte, error) {
1818+func SyncGetBlob(ctx context.Context, c lexutil.LexClient, cid string, did string) ([]byte, error) {
1919 buf := new(bytes.Buffer)
20202121 params := map[string]interface{}{}
2222 params["cid"] = cid
2323 params["did"] = did
2424- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getBlob", params, nil, buf); err != nil {
2424+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getBlob", params, nil, buf); err != nil {
2525 return nil, err
2626 }
2727
+3-3
api/atproto/syncgetBlocks.go
···88 "bytes"
99 "context"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// SyncGetBlocks calls the XRPC method "com.atproto.sync.getBlocks".
1515//
1616// did: The DID of the repo.
1717-func SyncGetBlocks(ctx context.Context, c util.LexClient, cids []string, did string) ([]byte, error) {
1717+func SyncGetBlocks(ctx context.Context, c lexutil.LexClient, cids []string, did string) ([]byte, error) {
1818 buf := new(bytes.Buffer)
19192020 params := map[string]interface{}{}
2121 params["cids"] = cids
2222 params["did"] = did
2323- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getBlocks", params, nil, buf); err != nil {
2323+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getBlocks", params, nil, buf); err != nil {
2424 return nil, err
2525 }
2626
+3-3
api/atproto/syncgetCheckout.go
···88 "bytes"
99 "context"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// SyncGetCheckout calls the XRPC method "com.atproto.sync.getCheckout".
1515//
1616// did: The DID of the repo.
1717-func SyncGetCheckout(ctx context.Context, c util.LexClient, did string) ([]byte, error) {
1717+func SyncGetCheckout(ctx context.Context, c lexutil.LexClient, did string) ([]byte, error) {
1818 buf := new(bytes.Buffer)
19192020 params := map[string]interface{}{}
2121 params["did"] = did
2222- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getCheckout", params, nil, buf); err != nil {
2222+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getCheckout", params, nil, buf); err != nil {
2323 return nil, err
2424 }
2525
+3-3
api/atproto/syncgetHead.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncGetHead_Output is the output of a com.atproto.sync.getHead call.
···1818// SyncGetHead calls the XRPC method "com.atproto.sync.getHead".
1919//
2020// did: The DID of the repo.
2121-func SyncGetHead(ctx context.Context, c util.LexClient, did string) (*SyncGetHead_Output, error) {
2121+func SyncGetHead(ctx context.Context, c lexutil.LexClient, did string) (*SyncGetHead_Output, error) {
2222 var out SyncGetHead_Output
23232424 params := map[string]interface{}{}
2525 params["did"] = did
2626- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getHead", params, nil, &out); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getHead", params, nil, &out); err != nil {
2727 return nil, err
2828 }
2929
+3-3
api/atproto/syncgetHostStatus.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncGetHostStatus_Output is the output of a com.atproto.sync.getHostStatus call.
···2323// SyncGetHostStatus calls the XRPC method "com.atproto.sync.getHostStatus".
2424//
2525// hostname: Hostname of the host (eg, PDS or relay) being queried.
2626-func SyncGetHostStatus(ctx context.Context, c util.LexClient, hostname string) (*SyncGetHostStatus_Output, error) {
2626+func SyncGetHostStatus(ctx context.Context, c lexutil.LexClient, hostname string) (*SyncGetHostStatus_Output, error) {
2727 var out SyncGetHostStatus_Output
28282929 params := map[string]interface{}{}
3030 params["hostname"] = hostname
3131- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getHostStatus", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getHostStatus", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/atproto/syncgetLatestCommit.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncGetLatestCommit_Output is the output of a com.atproto.sync.getLatestCommit call.
···1919// SyncGetLatestCommit calls the XRPC method "com.atproto.sync.getLatestCommit".
2020//
2121// did: The DID of the repo.
2222-func SyncGetLatestCommit(ctx context.Context, c util.LexClient, did string) (*SyncGetLatestCommit_Output, error) {
2222+func SyncGetLatestCommit(ctx context.Context, c lexutil.LexClient, did string) (*SyncGetLatestCommit_Output, error) {
2323 var out SyncGetLatestCommit_Output
24242525 params := map[string]interface{}{}
2626 params["did"] = did
2727- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getLatestCommit", params, nil, &out); err != nil {
2727+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getLatestCommit", params, nil, &out); err != nil {
2828 return nil, err
2929 }
3030
+3-3
api/atproto/syncgetRecord.go
···88 "bytes"
99 "context"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// SyncGetRecord calls the XRPC method "com.atproto.sync.getRecord".
1515//
1616// did: The DID of the repo.
1717// rkey: Record Key
1818-func SyncGetRecord(ctx context.Context, c util.LexClient, collection string, did string, rkey string) ([]byte, error) {
1818+func SyncGetRecord(ctx context.Context, c lexutil.LexClient, collection string, did string, rkey string) ([]byte, error) {
1919 buf := new(bytes.Buffer)
20202121 params := map[string]interface{}{}
2222 params["collection"] = collection
2323 params["did"] = did
2424 params["rkey"] = rkey
2525- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getRecord", params, nil, buf); err != nil {
2525+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getRecord", params, nil, buf); err != nil {
2626 return nil, err
2727 }
2828
+3-3
api/atproto/syncgetRepo.go
···88 "bytes"
99 "context"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// SyncGetRepo calls the XRPC method "com.atproto.sync.getRepo".
1515//
1616// did: The DID of the repo.
1717// since: The revision ('rev') of the repo to create a diff from.
1818-func SyncGetRepo(ctx context.Context, c util.LexClient, did string, since string) ([]byte, error) {
1818+func SyncGetRepo(ctx context.Context, c lexutil.LexClient, did string, since string) ([]byte, error) {
1919 buf := new(bytes.Buffer)
20202121 params := map[string]interface{}{}
···2323 if since != "" {
2424 params["since"] = since
2525 }
2626- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getRepo", params, nil, buf); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getRepo", params, nil, buf); err != nil {
2727 return nil, err
2828 }
2929
+3-3
api/atproto/syncgetRepoStatus.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncGetRepoStatus_Output is the output of a com.atproto.sync.getRepoStatus call.
···2323// SyncGetRepoStatus calls the XRPC method "com.atproto.sync.getRepoStatus".
2424//
2525// did: The DID of the repo.
2626-func SyncGetRepoStatus(ctx context.Context, c util.LexClient, did string) (*SyncGetRepoStatus_Output, error) {
2626+func SyncGetRepoStatus(ctx context.Context, c lexutil.LexClient, did string) (*SyncGetRepoStatus_Output, error) {
2727 var out SyncGetRepoStatus_Output
28282929 params := map[string]interface{}{}
3030 params["did"] = did
3131- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.getRepoStatus", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.getRepoStatus", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/atproto/synclistBlobs.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncListBlobs_Output is the output of a com.atproto.sync.listBlobs call.
···2020//
2121// did: The DID of the repo.
2222// since: Optional revision of the repo to list blobs since.
2323-func SyncListBlobs(ctx context.Context, c util.LexClient, cursor string, did string, limit int64, since string) (*SyncListBlobs_Output, error) {
2323+func SyncListBlobs(ctx context.Context, c lexutil.LexClient, cursor string, did string, limit int64, since string) (*SyncListBlobs_Output, error) {
2424 var out SyncListBlobs_Output
25252626 params := map[string]interface{}{}
···3434 if since != "" {
3535 params["since"] = since
3636 }
3737- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.listBlobs", params, nil, &out); err != nil {
3737+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.listBlobs", params, nil, &out); err != nil {
3838 return nil, err
3939 }
4040
+3-3
api/atproto/synclistHosts.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncListHosts_Host is a "host" in the com.atproto.sync.listHosts schema.
···2828}
29293030// SyncListHosts calls the XRPC method "com.atproto.sync.listHosts".
3131-func SyncListHosts(ctx context.Context, c util.LexClient, cursor string, limit int64) (*SyncListHosts_Output, error) {
3131+func SyncListHosts(ctx context.Context, c lexutil.LexClient, cursor string, limit int64) (*SyncListHosts_Output, error) {
3232 var out SyncListHosts_Output
33333434 params := map[string]interface{}{}
···3838 if limit != 0 {
3939 params["limit"] = limit
4040 }
4141- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.listHosts", params, nil, &out); err != nil {
4141+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.listHosts", params, nil, &out); err != nil {
4242 return nil, err
4343 }
4444
+3-3
api/atproto/synclistRepos.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncListRepos_Output is the output of a com.atproto.sync.listRepos call.
···2828}
29293030// SyncListRepos calls the XRPC method "com.atproto.sync.listRepos".
3131-func SyncListRepos(ctx context.Context, c util.LexClient, cursor string, limit int64) (*SyncListRepos_Output, error) {
3131+func SyncListRepos(ctx context.Context, c lexutil.LexClient, cursor string, limit int64) (*SyncListRepos_Output, error) {
3232 var out SyncListRepos_Output
33333434 params := map[string]interface{}{}
···3838 if limit != 0 {
3939 params["limit"] = limit
4040 }
4141- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.listRepos", params, nil, &out); err != nil {
4141+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.listRepos", params, nil, &out); err != nil {
4242 return nil, err
4343 }
4444
+3-3
api/atproto/synclistReposByCollection.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncListReposByCollection_Output is the output of a com.atproto.sync.listReposByCollection call.
···2424// SyncListReposByCollection calls the XRPC method "com.atproto.sync.listReposByCollection".
2525//
2626// limit: Maximum size of response set. Recommend setting a large maximum (1000+) when enumerating large DID lists.
2727-func SyncListReposByCollection(ctx context.Context, c util.LexClient, collection string, cursor string, limit int64) (*SyncListReposByCollection_Output, error) {
2727+func SyncListReposByCollection(ctx context.Context, c lexutil.LexClient, collection string, cursor string, limit int64) (*SyncListReposByCollection_Output, error) {
2828 var out SyncListReposByCollection_Output
29293030 params := map[string]interface{}{}
···3535 if limit != 0 {
3636 params["limit"] = limit
3737 }
3838- if err := c.LexDo(ctx, util.Query, "", "com.atproto.sync.listReposByCollection", params, nil, &out); err != nil {
3838+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.sync.listReposByCollection", params, nil, &out); err != nil {
3939 return nil, err
4040 }
4141
+3-3
api/atproto/syncnotifyOfUpdate.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncNotifyOfUpdate_Input is the input argument to a com.atproto.sync.notifyOfUpdate call.
···1717}
18181919// SyncNotifyOfUpdate calls the XRPC method "com.atproto.sync.notifyOfUpdate".
2020-func SyncNotifyOfUpdate(ctx context.Context, c util.LexClient, input *SyncNotifyOfUpdate_Input) error {
2121- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.sync.notifyOfUpdate", nil, input, nil); err != nil {
2020+func SyncNotifyOfUpdate(ctx context.Context, c lexutil.LexClient, input *SyncNotifyOfUpdate_Input) error {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.sync.notifyOfUpdate", nil, input, nil); err != nil {
2222 return err
2323 }
2424
+3-3
api/atproto/syncrequestCrawl.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// SyncRequestCrawl_Input is the input argument to a com.atproto.sync.requestCrawl call.
···1717}
18181919// SyncRequestCrawl calls the XRPC method "com.atproto.sync.requestCrawl".
2020-func SyncRequestCrawl(ctx context.Context, c util.LexClient, input *SyncRequestCrawl_Input) error {
2121- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.sync.requestCrawl", nil, input, nil); err != nil {
2020+func SyncRequestCrawl(ctx context.Context, c lexutil.LexClient, input *SyncRequestCrawl_Input) error {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.sync.requestCrawl", nil, input, nil); err != nil {
2222 return err
2323 }
2424
+9-9
api/atproto/syncsubscribeRepos.go
···55package atproto
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111// SyncSubscribeRepos_Account is a "account" in the com.atproto.sync.subscribeRepos schema.
···2525//
2626// Represents an update of repository state. Note that empty commits are allowed, which include no repo data changes, but an update to rev and signature.
2727type SyncSubscribeRepos_Commit struct {
2828- Blobs []util.LexLink `json:"blobs" cborgen:"blobs"`
2828+ Blobs []lexutil.LexLink `json:"blobs" cborgen:"blobs"`
2929 // blocks: CAR file containing relevant blocks, as a diff since the previous repo state. The commit must be included as a block, and the commit block CID must be the first entry in the CAR header 'roots' list.
3030- Blocks util.LexBytes `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
3030+ Blocks lexutil.LexBytes `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
3131 // commit: Repo commit object CID.
3232- Commit util.LexLink `json:"commit" cborgen:"commit"`
3232+ Commit lexutil.LexLink `json:"commit" cborgen:"commit"`
3333 Ops []*SyncSubscribeRepos_RepoOp `json:"ops" cborgen:"ops"`
3434 // prevData: The root CID of the MST tree for the previous commit from this repo (indicated by the 'since' revision field in this message). Corresponds to the 'data' field in the repo commit object. NOTE: this field is effectively required for the 'inductive' version of firehose.
3535- PrevData *util.LexLink `json:"prevData,omitempty" cborgen:"prevData,omitempty"`
3535+ PrevData *lexutil.LexLink `json:"prevData,omitempty" cborgen:"prevData,omitempty"`
3636 // rebase: DEPRECATED -- unused
3737 Rebase bool `json:"rebase" cborgen:"rebase"`
3838 // repo: The repo this event comes from. Note that all other message types name this field 'did'.
···7272type SyncSubscribeRepos_RepoOp struct {
7373 Action string `json:"action" cborgen:"action"`
7474 // cid: For creates and updates, the new record CID. For deletions, null.
7575- Cid *util.LexLink `json:"cid" cborgen:"cid"`
7676- Path string `json:"path" cborgen:"path"`
7575+ Cid *lexutil.LexLink `json:"cid" cborgen:"cid"`
7676+ Path string `json:"path" cborgen:"path"`
7777 // prev: For updates and deletes, the previous record CID (required for inductive firehose). For creations, field should not be defined.
7878- Prev *util.LexLink `json:"prev,omitempty" cborgen:"prev,omitempty"`
7878+ Prev *lexutil.LexLink `json:"prev,omitempty" cborgen:"prev,omitempty"`
7979}
80808181// SyncSubscribeRepos_Sync is a "sync" in the com.atproto.sync.subscribeRepos schema.
···8383// Updates the repo to a new state, without necessarily including that state on the firehose. Used to recover from broken commit streams, data loss incidents, or in situations where upstream host does not know recent state of the repository.
8484type SyncSubscribeRepos_Sync struct {
8585 // blocks: CAR file containing the commit, as a block. The CAR header must include the commit block CID as the first 'root'.
8686- Blocks util.LexBytes `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
8686+ Blocks lexutil.LexBytes `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
8787 // did: The account this repo event corresponds to. Must match that in the commit object.
8888 Did string `json:"did" cborgen:"did"`
8989 // rev: The rev of the commit. This value must match that in the commit object.
+3-3
api/atproto/tempaddReservedHandle.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempAddReservedHandle_Input is the input argument to a com.atproto.temp.addReservedHandle call.
···2020}
21212222// TempAddReservedHandle calls the XRPC method "com.atproto.temp.addReservedHandle".
2323-func TempAddReservedHandle(ctx context.Context, c util.LexClient, input *TempAddReservedHandle_Input) (*TempAddReservedHandle_Output, error) {
2323+func TempAddReservedHandle(ctx context.Context, c lexutil.LexClient, input *TempAddReservedHandle_Input) (*TempAddReservedHandle_Output, error) {
2424 var out TempAddReservedHandle_Output
2525- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.temp.addReservedHandle", nil, input, &out); err != nil {
2525+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.temp.addReservedHandle", nil, input, &out); err != nil {
2626 return nil, err
2727 }
2828
+4-5
api/atproto/tempcheckHandleAvailability.go
···99 "encoding/json"
1010 "fmt"
11111212- "github.com/bluesky-social/indigo/lex/util"
1212+ lexutil "github.com/bluesky-social/indigo/lex/util"
1313)
14141515// TempCheckHandleAvailability_Output is the output of a com.atproto.temp.checkHandleAvailability call.
···3737}
38383939func (t *TempCheckHandleAvailability_Output_Result) UnmarshalJSON(b []byte) error {
4040- typ, err := util.TypeExtract(b)
4040+ typ, err := lexutil.TypeExtract(b)
4141 if err != nil {
4242 return err
4343 }
···4949 case "com.atproto.temp.checkHandleAvailability#resultUnavailable":
5050 t.TempCheckHandleAvailability_ResultUnavailable = new(TempCheckHandleAvailability_ResultUnavailable)
5151 return json.Unmarshal(b, t.TempCheckHandleAvailability_ResultUnavailable)
5252-5352 default:
5453 return nil
5554 }
···8382// birthDate: User-provided birth date. Might be used to build handle suggestions.
8483// email: User-provided email. Might be used to build handle suggestions.
8584// handle: Tentative handle. Will be checked for availability or used to build handle suggestions.
8686-func TempCheckHandleAvailability(ctx context.Context, c util.LexClient, birthDate string, email string, handle string) (*TempCheckHandleAvailability_Output, error) {
8585+func TempCheckHandleAvailability(ctx context.Context, c lexutil.LexClient, birthDate string, email string, handle string) (*TempCheckHandleAvailability_Output, error) {
8786 var out TempCheckHandleAvailability_Output
88878988 params := map[string]interface{}{}
···9493 params["email"] = email
9594 }
9695 params["handle"] = handle
9797- if err := c.LexDo(ctx, util.Query, "", "com.atproto.temp.checkHandleAvailability", params, nil, &out); err != nil {
9696+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.temp.checkHandleAvailability", params, nil, &out); err != nil {
9897 return nil, err
9998 }
10099
+3-3
api/atproto/tempcheckSignupQueue.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempCheckSignupQueue_Output is the output of a com.atproto.temp.checkSignupQueue call.
···1818}
19192020// TempCheckSignupQueue calls the XRPC method "com.atproto.temp.checkSignupQueue".
2121-func TempCheckSignupQueue(ctx context.Context, c util.LexClient) (*TempCheckSignupQueue_Output, error) {
2121+func TempCheckSignupQueue(ctx context.Context, c lexutil.LexClient) (*TempCheckSignupQueue_Output, error) {
2222 var out TempCheckSignupQueue_Output
2323- if err := c.LexDo(ctx, util.Query, "", "com.atproto.temp.checkSignupQueue", nil, nil, &out); err != nil {
2323+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.temp.checkSignupQueue", nil, nil, &out); err != nil {
2424 return nil, err
2525 }
2626
+3-3
api/atproto/tempdereferenceScope.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempDereferenceScope_Output is the output of a com.atproto.temp.dereferenceScope call.
···1919// TempDereferenceScope calls the XRPC method "com.atproto.temp.dereferenceScope".
2020//
2121// scope: The scope reference (starts with 'ref:')
2222-func TempDereferenceScope(ctx context.Context, c util.LexClient, scope string) (*TempDereferenceScope_Output, error) {
2222+func TempDereferenceScope(ctx context.Context, c lexutil.LexClient, scope string) (*TempDereferenceScope_Output, error) {
2323 var out TempDereferenceScope_Output
24242525 params := map[string]interface{}{}
2626 params["scope"] = scope
2727- if err := c.LexDo(ctx, util.Query, "", "com.atproto.temp.dereferenceScope", params, nil, &out); err != nil {
2727+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.temp.dereferenceScope", params, nil, &out); err != nil {
2828 return nil, err
2929 }
3030
+3-3
api/atproto/tempfetchLabels.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempFetchLabels_Output is the output of a com.atproto.temp.fetchLabels call.
···1616}
17171818// TempFetchLabels calls the XRPC method "com.atproto.temp.fetchLabels".
1919-func TempFetchLabels(ctx context.Context, c util.LexClient, limit int64, since int64) (*TempFetchLabels_Output, error) {
1919+func TempFetchLabels(ctx context.Context, c lexutil.LexClient, limit int64, since int64) (*TempFetchLabels_Output, error) {
2020 var out TempFetchLabels_Output
21212222 params := map[string]interface{}{}
···2626 if since != 0 {
2727 params["since"] = since
2828 }
2929- if err := c.LexDo(ctx, util.Query, "", "com.atproto.temp.fetchLabels", params, nil, &out); err != nil {
2929+ if err := c.LexDo(ctx, lexutil.Query, "", "com.atproto.temp.fetchLabels", params, nil, &out); err != nil {
3030 return nil, err
3131 }
3232
+3-3
api/atproto/temprequestPhoneVerification.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempRequestPhoneVerification_Input is the input argument to a com.atproto.temp.requestPhoneVerification call.
···1616}
17171818// TempRequestPhoneVerification calls the XRPC method "com.atproto.temp.requestPhoneVerification".
1919-func TempRequestPhoneVerification(ctx context.Context, c util.LexClient, input *TempRequestPhoneVerification_Input) error {
2020- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.temp.requestPhoneVerification", nil, input, nil); err != nil {
1919+func TempRequestPhoneVerification(ctx context.Context, c lexutil.LexClient, input *TempRequestPhoneVerification_Input) error {
2020+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.temp.requestPhoneVerification", nil, input, nil); err != nil {
2121 return err
2222 }
2323
+3-3
api/atproto/temprevokeAccountCredentials.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// TempRevokeAccountCredentials_Input is the input argument to a com.atproto.temp.revokeAccountCredentials call.
···1616}
17171818// TempRevokeAccountCredentials calls the XRPC method "com.atproto.temp.revokeAccountCredentials".
1919-func TempRevokeAccountCredentials(ctx context.Context, c util.LexClient, input *TempRevokeAccountCredentials_Input) error {
2020- if err := c.LexDo(ctx, util.Procedure, "application/json", "com.atproto.temp.revokeAccountCredentials", nil, input, nil); err != nil {
1919+func TempRevokeAccountCredentials(ctx context.Context, c lexutil.LexClient, input *TempRevokeAccountCredentials_Input) error {
2020+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "com.atproto.temp.revokeAccountCredentials", nil, input, nil); err != nil {
2121 return err
2222 }
2323
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// BookmarkCreateBookmark_Input is the input argument to a app.bsky.bookmark.createBookmark call.
···1717}
18181919// BookmarkCreateBookmark calls the XRPC method "app.bsky.bookmark.createBookmark".
2020-func BookmarkCreateBookmark(ctx context.Context, c util.LexClient, input *BookmarkCreateBookmark_Input) error {
2121- if err := c.LexDo(ctx, util.Procedure, "application/json", "app.bsky.bookmark.createBookmark", nil, input, nil); err != nil {
2020+func BookmarkCreateBookmark(ctx context.Context, c lexutil.LexClient, input *BookmarkCreateBookmark_Input) error {
2121+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "app.bsky.bookmark.createBookmark", nil, input, nil); err != nil {
2222 return err
2323 }
2424
+5-6
api/bsky/bookmarkdefs.go
···88 "encoding/json"
99 "fmt"
10101111- comatprototypes "github.com/bluesky-social/indigo/api/atproto"
1212- "github.com/bluesky-social/indigo/lex/util"
1111+ comatproto "github.com/bluesky-social/indigo/api/atproto"
1212+ lexutil "github.com/bluesky-social/indigo/lex/util"
1313)
14141515// BookmarkDefs_Bookmark is a "bookmark" in the app.bsky.bookmark.defs schema.
···1717// Object used to store bookmark data in stash.
1818type BookmarkDefs_Bookmark struct {
1919 // subject: A strong ref to the record to be bookmarked. Currently, only `app.bsky.feed.post` records are supported.
2020- Subject *comatprototypes.RepoStrongRef `json:"subject" cborgen:"subject"`
2020+ Subject *comatproto.RepoStrongRef `json:"subject" cborgen:"subject"`
2121}
22222323// BookmarkDefs_BookmarkView is a "bookmarkView" in the app.bsky.bookmark.defs schema.
···2525 CreatedAt *string `json:"createdAt,omitempty" cborgen:"createdAt,omitempty"`
2626 Item *BookmarkDefs_BookmarkView_Item `json:"item" cborgen:"item"`
2727 // subject: A strong ref to the bookmarked record.
2828- Subject *comatprototypes.RepoStrongRef `json:"subject" cborgen:"subject"`
2828+ Subject *comatproto.RepoStrongRef `json:"subject" cborgen:"subject"`
2929}
30303131type BookmarkDefs_BookmarkView_Item struct {
···5151}
52525353func (t *BookmarkDefs_BookmarkView_Item) UnmarshalJSON(b []byte) error {
5454- typ, err := util.TypeExtract(b)
5454+ typ, err := lexutil.TypeExtract(b)
5555 if err != nil {
5656 return err
5757 }
···6666 case "app.bsky.feed.defs#postView":
6767 t.FeedDefs_PostView = new(FeedDefs_PostView)
6868 return json.Unmarshal(b, t.FeedDefs_PostView)
6969-7069 default:
7170 return nil
7271 }
+3-3
api/bsky/bookmarkdeleteBookmark.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// BookmarkDeleteBookmark_Input is the input argument to a app.bsky.bookmark.deleteBookmark call.
···1616}
17171818// BookmarkDeleteBookmark calls the XRPC method "app.bsky.bookmark.deleteBookmark".
1919-func BookmarkDeleteBookmark(ctx context.Context, c util.LexClient, input *BookmarkDeleteBookmark_Input) error {
2020- if err := c.LexDo(ctx, util.Procedure, "application/json", "app.bsky.bookmark.deleteBookmark", nil, input, nil); err != nil {
1919+func BookmarkDeleteBookmark(ctx context.Context, c lexutil.LexClient, input *BookmarkDeleteBookmark_Input) error {
2020+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "app.bsky.bookmark.deleteBookmark", nil, input, nil); err != nil {
2121 return err
2222 }
2323
+3-3
api/bsky/bookmarkgetBookmarks.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// BookmarkGetBookmarks_Output is the output of a app.bsky.bookmark.getBookmarks call.
···1717}
18181919// BookmarkGetBookmarks calls the XRPC method "app.bsky.bookmark.getBookmarks".
2020-func BookmarkGetBookmarks(ctx context.Context, c util.LexClient, cursor string, limit int64) (*BookmarkGetBookmarks_Output, error) {
2020+func BookmarkGetBookmarks(ctx context.Context, c lexutil.LexClient, cursor string, limit int64) (*BookmarkGetBookmarks_Output, error) {
2121 var out BookmarkGetBookmarks_Output
22222323 params := map[string]interface{}{}
···2727 if limit != 0 {
2828 params["limit"] = limit
2929 }
3030- if err := c.LexDo(ctx, util.Query, "", "app.bsky.bookmark.getBookmarks", params, nil, &out); err != nil {
3030+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.bookmark.getBookmarks", params, nil, &out); err != nil {
3131 return nil, err
3232 }
3333
+6-6
api/bsky/embedexternal.go
···55package bsky
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111func init() {
1212- util.RegisterType("app.bsky.embed.external#main", &EmbedExternal{})
1212+ lexutil.RegisterType("app.bsky.embed.external#main", &EmbedExternal{})
1313}
14141515// EmbedExternal is a "main" in the app.bsky.embed.external schema.
···22222323// EmbedExternal_External is a "external" in the app.bsky.embed.external schema.
2424type EmbedExternal_External struct {
2525- Description string `json:"description" cborgen:"description"`
2626- Thumb *util.LexBlob `json:"thumb,omitempty" cborgen:"thumb,omitempty"`
2727- Title string `json:"title" cborgen:"title"`
2828- Uri string `json:"uri" cborgen:"uri"`
2525+ Description string `json:"description" cborgen:"description"`
2626+ Thumb *lexutil.LexBlob `json:"thumb,omitempty" cborgen:"thumb,omitempty"`
2727+ Title string `json:"title" cborgen:"title"`
2828+ Uri string `json:"uri" cborgen:"uri"`
2929}
30303131// EmbedExternal_View is a "view" in the app.bsky.embed.external schema.
+3-3
api/bsky/embedimages.go
···55package bsky
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111func init() {
1212- util.RegisterType("app.bsky.embed.images#main", &EmbedImages{})
1212+ lexutil.RegisterType("app.bsky.embed.images#main", &EmbedImages{})
1313}
14141515// EmbedImages is a "main" in the app.bsky.embed.images schema.
···2323 // alt: Alt text description of the image, for accessibility.
2424 Alt string `json:"alt" cborgen:"alt"`
2525 AspectRatio *EmbedDefs_AspectRatio `json:"aspectRatio,omitempty" cborgen:"aspectRatio,omitempty"`
2626- Image *util.LexBlob `json:"image" cborgen:"image"`
2626+ Image *lexutil.LexBlob `json:"image" cborgen:"image"`
2727}
28282929// EmbedImages_View is a "view" in the app.bsky.embed.images schema.
···55package bsky
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111func init() {
1212- util.RegisterType("app.bsky.embed.video#main", &EmbedVideo{})
1212+ lexutil.RegisterType("app.bsky.embed.video#main", &EmbedVideo{})
1313}
14141515// EmbedVideo is a "main" in the app.bsky.embed.video schema.
···2020 AspectRatio *EmbedDefs_AspectRatio `json:"aspectRatio,omitempty" cborgen:"aspectRatio,omitempty"`
2121 Captions []*EmbedVideo_Caption `json:"captions,omitempty" cborgen:"captions,omitempty"`
2222 // video: The mp4 video file. May be up to 100mb, formerly limited to 50mb.
2323- Video *util.LexBlob `json:"video" cborgen:"video"`
2323+ Video *lexutil.LexBlob `json:"video" cborgen:"video"`
2424}
25252626// EmbedVideo_Caption is a "caption" in the app.bsky.embed.video schema.
2727type EmbedVideo_Caption struct {
2828- File *util.LexBlob `json:"file" cborgen:"file"`
2929- Lang string `json:"lang" cborgen:"lang"`
2828+ File *lexutil.LexBlob `json:"file" cborgen:"file"`
2929+ Lang string `json:"lang" cborgen:"lang"`
3030}
31313232// EmbedVideo_View is a "view" in the app.bsky.embed.video schema.
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// FeedSearchPosts_Output is the output of a app.bsky.feed.searchPosts call.
···3131// tag: Filter to posts with the given tag (hashtag), based on rich-text facet or tag field. Do not include the hash (#) prefix. Multiple tags can be specified, with 'AND' matching.
3232// until: Filter results for posts before the indicated datetime (not inclusive). Expected to use 'sortAt' timestamp, which may not match 'createdAt'. Can be a datetime, or just an ISO date (YYY-MM-DD).
3333// url: Filter to posts with links (facet links or embeds) pointing to this URL. Server may apply URL normalization or fuzzy matching.
3434-func FeedSearchPosts(ctx context.Context, c util.LexClient, author string, cursor string, domain string, lang string, limit int64, mentions string, q string, since string, sort string, tag []string, until string, url string) (*FeedSearchPosts_Output, error) {
3434+func FeedSearchPosts(ctx context.Context, c lexutil.LexClient, author string, cursor string, domain string, lang string, limit int64, mentions string, q string, since string, sort string, tag []string, until string, url string) (*FeedSearchPosts_Output, error) {
3535 var out FeedSearchPosts_Output
36363737 params := map[string]interface{}{}
···6969 if url != "" {
7070 params["url"] = url
7171 }
7272- if err := c.LexDo(ctx, util.Query, "", "app.bsky.feed.searchPosts", params, nil, &out); err != nil {
7272+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.feed.searchPosts", params, nil, &out); err != nil {
7373 return nil, err
7474 }
7575
+3-3
api/bsky/feedsendInteractions.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// FeedSendInteractions_Input is the input argument to a app.bsky.feed.sendInteractions call.
···2020}
21212222// FeedSendInteractions calls the XRPC method "app.bsky.feed.sendInteractions".
2323-func FeedSendInteractions(ctx context.Context, c util.LexClient, input *FeedSendInteractions_Input) (*FeedSendInteractions_Output, error) {
2323+func FeedSendInteractions(ctx context.Context, c lexutil.LexClient, input *FeedSendInteractions_Input) (*FeedSendInteractions_Output, error) {
2424 var out FeedSendInteractions_Output
2525- if err := c.LexDo(ctx, util.Procedure, "application/json", "app.bsky.feed.sendInteractions", nil, input, &out); err != nil {
2525+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "app.bsky.feed.sendInteractions", nil, input, &out); err != nil {
2626 return nil, err
2727 }
2828
···55package bsky
6677import (
88- comatprototypes "github.com/bluesky-social/indigo/api/atproto"
88+ comatproto "github.com/bluesky-social/indigo/api/atproto"
99)
10101111// LabelerDefs_LabelerPolicies is a "labelerPolicies" in the app.bsky.labeler.defs schema.
1212type LabelerDefs_LabelerPolicies struct {
1313 // labelValueDefinitions: Label values created by this labeler and scoped exclusively to it. Labels defined here will override global label definitions for this labeler.
1414- LabelValueDefinitions []*comatprototypes.LabelDefs_LabelValueDefinition `json:"labelValueDefinitions,omitempty" cborgen:"labelValueDefinitions,omitempty"`
1414+ LabelValueDefinitions []*comatproto.LabelDefs_LabelValueDefinition `json:"labelValueDefinitions,omitempty" cborgen:"labelValueDefinitions,omitempty"`
1515 // labelValues: The label values which this labeler publishes. May include global or custom labels.
1616 LabelValues []*string `json:"labelValues" cborgen:"labelValues"`
1717}
18181919// LabelerDefs_LabelerView is a "labelerView" in the app.bsky.labeler.defs schema.
2020type LabelerDefs_LabelerView struct {
2121- LexiconTypeID string `json:"$type" cborgen:"$type,const=app.bsky.labeler.defs#labelerView"`
2222- Cid string `json:"cid" cborgen:"cid"`
2323- Creator *ActorDefs_ProfileView `json:"creator" cborgen:"creator"`
2424- IndexedAt string `json:"indexedAt" cborgen:"indexedAt"`
2525- Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"`
2626- LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"`
2727- Uri string `json:"uri" cborgen:"uri"`
2828- Viewer *LabelerDefs_LabelerViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"`
2121+ LexiconTypeID string `json:"$type" cborgen:"$type,const=app.bsky.labeler.defs#labelerView"`
2222+ Cid string `json:"cid" cborgen:"cid"`
2323+ Creator *ActorDefs_ProfileView `json:"creator" cborgen:"creator"`
2424+ IndexedAt string `json:"indexedAt" cborgen:"indexedAt"`
2525+ Labels []*comatproto.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"`
2626+ LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"`
2727+ Uri string `json:"uri" cborgen:"uri"`
2828+ Viewer *LabelerDefs_LabelerViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"`
2929}
30303131// LabelerDefs_LabelerViewDetailed is a "labelerViewDetailed" in the app.bsky.labeler.defs schema.
3232type LabelerDefs_LabelerViewDetailed struct {
3333- LexiconTypeID string `json:"$type" cborgen:"$type,const=app.bsky.labeler.defs#labelerViewDetailed"`
3434- Cid string `json:"cid" cborgen:"cid"`
3535- Creator *ActorDefs_ProfileView `json:"creator" cborgen:"creator"`
3636- IndexedAt string `json:"indexedAt" cborgen:"indexedAt"`
3737- Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"`
3838- LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"`
3939- Policies *LabelerDefs_LabelerPolicies `json:"policies" cborgen:"policies"`
3333+ LexiconTypeID string `json:"$type" cborgen:"$type,const=app.bsky.labeler.defs#labelerViewDetailed"`
3434+ Cid string `json:"cid" cborgen:"cid"`
3535+ Creator *ActorDefs_ProfileView `json:"creator" cborgen:"creator"`
3636+ IndexedAt string `json:"indexedAt" cborgen:"indexedAt"`
3737+ Labels []*comatproto.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"`
3838+ LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"`
3939+ Policies *LabelerDefs_LabelerPolicies `json:"policies" cborgen:"policies"`
4040 // reasonTypes: The set of report reason 'codes' which are in-scope for this service to review and action. These usually align to policy categories. If not defined (distinct from empty array), all reason types are allowed.
4141 ReasonTypes []*string `json:"reasonTypes,omitempty" cborgen:"reasonTypes,omitempty"`
4242 // subjectCollections: Set of record types (collection NSIDs) which can be reported to this service. If not defined (distinct from empty array), default is any record type.
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetOnboardingSuggestedStarterPacksSkeleton_Output is the output of a app.bsky.unspecced.getOnboardingSuggestedStarterPacksSkeleton call.
···1818// UnspeccedGetOnboardingSuggestedStarterPacksSkeleton calls the XRPC method "app.bsky.unspecced.getOnboardingSuggestedStarterPacksSkeleton".
1919//
2020// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2121-func UnspeccedGetOnboardingSuggestedStarterPacksSkeleton(ctx context.Context, c util.LexClient, limit int64, viewer string) (*UnspeccedGetOnboardingSuggestedStarterPacksSkeleton_Output, error) {
2121+func UnspeccedGetOnboardingSuggestedStarterPacksSkeleton(ctx context.Context, c lexutil.LexClient, limit int64, viewer string) (*UnspeccedGetOnboardingSuggestedStarterPacksSkeleton_Output, error) {
2222 var out UnspeccedGetOnboardingSuggestedStarterPacksSkeleton_Output
23232424 params := map[string]interface{}{}
···2828 if viewer != "" {
2929 params["viewer"] = viewer
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getOnboardingSuggestedStarterPacksSkeleton", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getOnboardingSuggestedStarterPacksSkeleton", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
-33
api/bsky/unspeccedgetPopular.go
···11-// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
22-33-package bsky
44-55-// schema: app.bsky.unspecced.getPopular
66-77-import (
88- "context"
99-1010- "github.com/bluesky-social/indigo/xrpc"
1111-)
1212-1313-// UnspeccedGetPopular_Output is the output of a app.bsky.unspecced.getPopular call.
1414-type UnspeccedGetPopular_Output struct {
1515- Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
1616- Feed []*FeedDefs_FeedViewPost `json:"feed" cborgen:"feed"`
1717-}
1818-1919-// UnspeccedGetPopular calls the XRPC method "app.bsky.unspecced.getPopular".
2020-func UnspeccedGetPopular(ctx context.Context, c *xrpc.Client, cursor string, includeNsfw bool, limit int64) (*UnspeccedGetPopular_Output, error) {
2121- var out UnspeccedGetPopular_Output
2222-2323- params := map[string]interface{}{
2424- "cursor": cursor,
2525- "includeNsfw": includeNsfw,
2626- "limit": limit,
2727- }
2828- if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getPopular", params, nil, &out); err != nil {
2929- return nil, err
3030- }
3131-3232- return &out, nil
3333-}
+3-3
api/bsky/unspeccedgetPopularFeedGenerators.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetPopularFeedGenerators_Output is the output of a app.bsky.unspecced.getPopularFeedGenerators call.
···1717}
18181919// UnspeccedGetPopularFeedGenerators calls the XRPC method "app.bsky.unspecced.getPopularFeedGenerators".
2020-func UnspeccedGetPopularFeedGenerators(ctx context.Context, c util.LexClient, cursor string, limit int64, query string) (*UnspeccedGetPopularFeedGenerators_Output, error) {
2020+func UnspeccedGetPopularFeedGenerators(ctx context.Context, c lexutil.LexClient, cursor string, limit int64, query string) (*UnspeccedGetPopularFeedGenerators_Output, error) {
2121 var out UnspeccedGetPopularFeedGenerators_Output
22222323 params := map[string]interface{}{}
···3030 if query != "" {
3131 params["query"] = query
3232 }
3333- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getPopularFeedGenerators", params, nil, &out); err != nil {
3333+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getPopularFeedGenerators", params, nil, &out); err != nil {
3434 return nil, err
3535 }
3636
+4-5
api/bsky/unspeccedgetPostThreadOtherV2.go
···99 "encoding/json"
1010 "fmt"
11111212- "github.com/bluesky-social/indigo/lex/util"
1212+ lexutil "github.com/bluesky-social/indigo/lex/util"
1313)
14141515// UnspeccedGetPostThreadOtherV2_Output is the output of a app.bsky.unspecced.getPostThreadOtherV2 call.
···3939}
40404141func (t *UnspeccedGetPostThreadOtherV2_ThreadItem_Value) UnmarshalJSON(b []byte) error {
4242- typ, err := util.TypeExtract(b)
4242+ typ, err := lexutil.TypeExtract(b)
4343 if err != nil {
4444 return err
4545 }
···4848 case "app.bsky.unspecced.defs#threadItemPost":
4949 t.UnspeccedDefs_ThreadItemPost = new(UnspeccedDefs_ThreadItemPost)
5050 return json.Unmarshal(b, t.UnspeccedDefs_ThreadItemPost)
5151-5251 default:
5352 return nil
5453 }
···5857//
5958// anchor: Reference (AT-URI) to post record. This is the anchor post.
6059// prioritizeFollowedUsers: Whether to prioritize posts from followed users. It only has effect when the user is authenticated.
6161-func UnspeccedGetPostThreadOtherV2(ctx context.Context, c util.LexClient, anchor string, prioritizeFollowedUsers bool) (*UnspeccedGetPostThreadOtherV2_Output, error) {
6060+func UnspeccedGetPostThreadOtherV2(ctx context.Context, c lexutil.LexClient, anchor string, prioritizeFollowedUsers bool) (*UnspeccedGetPostThreadOtherV2_Output, error) {
6261 var out UnspeccedGetPostThreadOtherV2_Output
63626463 params := map[string]interface{}{}
···6665 if prioritizeFollowedUsers {
6766 params["prioritizeFollowedUsers"] = prioritizeFollowedUsers
6867 }
6969- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getPostThreadOtherV2", params, nil, &out); err != nil {
6868+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getPostThreadOtherV2", params, nil, &out); err != nil {
7069 return nil, err
7170 }
7271
+4-5
api/bsky/unspeccedgetPostThreadV2.go
···99 "encoding/json"
1010 "fmt"
11111212- "github.com/bluesky-social/indigo/lex/util"
1212+ lexutil "github.com/bluesky-social/indigo/lex/util"
1313)
14141515// UnspeccedGetPostThreadV2_Output is the output of a app.bsky.unspecced.getPostThreadV2 call.
···5757}
58585959func (t *UnspeccedGetPostThreadV2_ThreadItem_Value) UnmarshalJSON(b []byte) error {
6060- typ, err := util.TypeExtract(b)
6060+ typ, err := lexutil.TypeExtract(b)
6161 if err != nil {
6262 return err
6363 }
···7575 case "app.bsky.unspecced.defs#threadItemBlocked":
7676 t.UnspeccedDefs_ThreadItemBlocked = new(UnspeccedDefs_ThreadItemBlocked)
7777 return json.Unmarshal(b, t.UnspeccedDefs_ThreadItemBlocked)
7878-7978 default:
8079 return nil
8180 }
···8988// branchingFactor: Maximum of replies to include at each level of the thread, except for the direct replies to the anchor, which are (NOTE: currently, during unspecced phase) all returned (NOTE: later they might be paginated).
9089// prioritizeFollowedUsers: Whether to prioritize posts from followed users. It only has effect when the user is authenticated.
9190// sort: Sorting for the thread replies.
9292-func UnspeccedGetPostThreadV2(ctx context.Context, c util.LexClient, above bool, anchor string, below int64, branchingFactor int64, prioritizeFollowedUsers bool, sort string) (*UnspeccedGetPostThreadV2_Output, error) {
9191+func UnspeccedGetPostThreadV2(ctx context.Context, c lexutil.LexClient, above bool, anchor string, below int64, branchingFactor int64, prioritizeFollowedUsers bool, sort string) (*UnspeccedGetPostThreadV2_Output, error) {
9392 var out UnspeccedGetPostThreadV2_Output
94939594 params := map[string]interface{}{}
···109108 if sort != "" {
110109 params["sort"] = sort
111110 }
112112- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getPostThreadV2", params, nil, &out); err != nil {
111111+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getPostThreadV2", params, nil, &out); err != nil {
113112 return nil, err
114113 }
115114
+3-3
api/bsky/unspeccedgetSuggestedFeeds.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedFeeds_Output is the output of a app.bsky.unspecced.getSuggestedFeeds call.
···1616}
17171818// UnspeccedGetSuggestedFeeds calls the XRPC method "app.bsky.unspecced.getSuggestedFeeds".
1919-func UnspeccedGetSuggestedFeeds(ctx context.Context, c util.LexClient, limit int64) (*UnspeccedGetSuggestedFeeds_Output, error) {
1919+func UnspeccedGetSuggestedFeeds(ctx context.Context, c lexutil.LexClient, limit int64) (*UnspeccedGetSuggestedFeeds_Output, error) {
2020 var out UnspeccedGetSuggestedFeeds_Output
21212222 params := map[string]interface{}{}
2323 if limit != 0 {
2424 params["limit"] = limit
2525 }
2626- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedFeeds", params, nil, &out); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedFeeds", params, nil, &out); err != nil {
2727 return nil, err
2828 }
2929
+3-3
api/bsky/unspeccedgetSuggestedFeedsSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedFeedsSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedFeedsSkeleton call.
···1818// UnspeccedGetSuggestedFeedsSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestedFeedsSkeleton".
1919//
2020// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2121-func UnspeccedGetSuggestedFeedsSkeleton(ctx context.Context, c util.LexClient, limit int64, viewer string) (*UnspeccedGetSuggestedFeedsSkeleton_Output, error) {
2121+func UnspeccedGetSuggestedFeedsSkeleton(ctx context.Context, c lexutil.LexClient, limit int64, viewer string) (*UnspeccedGetSuggestedFeedsSkeleton_Output, error) {
2222 var out UnspeccedGetSuggestedFeedsSkeleton_Output
23232424 params := map[string]interface{}{}
···2828 if viewer != "" {
2929 params["viewer"] = viewer
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedFeedsSkeleton", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedFeedsSkeleton", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/bsky/unspeccedgetSuggestedStarterPacks.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedStarterPacks_Output is the output of a app.bsky.unspecced.getSuggestedStarterPacks call.
···1616}
17171818// UnspeccedGetSuggestedStarterPacks calls the XRPC method "app.bsky.unspecced.getSuggestedStarterPacks".
1919-func UnspeccedGetSuggestedStarterPacks(ctx context.Context, c util.LexClient, limit int64) (*UnspeccedGetSuggestedStarterPacks_Output, error) {
1919+func UnspeccedGetSuggestedStarterPacks(ctx context.Context, c lexutil.LexClient, limit int64) (*UnspeccedGetSuggestedStarterPacks_Output, error) {
2020 var out UnspeccedGetSuggestedStarterPacks_Output
21212222 params := map[string]interface{}{}
2323 if limit != 0 {
2424 params["limit"] = limit
2525 }
2626- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedStarterPacks", params, nil, &out); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedStarterPacks", params, nil, &out); err != nil {
2727 return nil, err
2828 }
2929
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedStarterPacksSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedStarterPacksSkeleton call.
···1818// UnspeccedGetSuggestedStarterPacksSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestedStarterPacksSkeleton".
1919//
2020// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2121-func UnspeccedGetSuggestedStarterPacksSkeleton(ctx context.Context, c util.LexClient, limit int64, viewer string) (*UnspeccedGetSuggestedStarterPacksSkeleton_Output, error) {
2121+func UnspeccedGetSuggestedStarterPacksSkeleton(ctx context.Context, c lexutil.LexClient, limit int64, viewer string) (*UnspeccedGetSuggestedStarterPacksSkeleton_Output, error) {
2222 var out UnspeccedGetSuggestedStarterPacksSkeleton_Output
23232424 params := map[string]interface{}{}
···2828 if viewer != "" {
2929 params["viewer"] = viewer
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedStarterPacksSkeleton", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedStarterPacksSkeleton", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/bsky/unspeccedgetSuggestedUsers.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedUsers_Output is the output of a app.bsky.unspecced.getSuggestedUsers call.
···1818// UnspeccedGetSuggestedUsers calls the XRPC method "app.bsky.unspecced.getSuggestedUsers".
1919//
2020// category: Category of users to get suggestions for.
2121-func UnspeccedGetSuggestedUsers(ctx context.Context, c util.LexClient, category string, limit int64) (*UnspeccedGetSuggestedUsers_Output, error) {
2121+func UnspeccedGetSuggestedUsers(ctx context.Context, c lexutil.LexClient, category string, limit int64) (*UnspeccedGetSuggestedUsers_Output, error) {
2222 var out UnspeccedGetSuggestedUsers_Output
23232424 params := map[string]interface{}{}
···2828 if limit != 0 {
2929 params["limit"] = limit
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedUsers", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedUsers", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/bsky/unspeccedgetSuggestedUsersSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestedUsersSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedUsersSkeleton call.
···1919//
2020// category: Category of users to get suggestions for.
2121// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2222-func UnspeccedGetSuggestedUsersSkeleton(ctx context.Context, c util.LexClient, category string, limit int64, viewer string) (*UnspeccedGetSuggestedUsersSkeleton_Output, error) {
2222+func UnspeccedGetSuggestedUsersSkeleton(ctx context.Context, c lexutil.LexClient, category string, limit int64, viewer string) (*UnspeccedGetSuggestedUsersSkeleton_Output, error) {
2323 var out UnspeccedGetSuggestedUsersSkeleton_Output
24242525 params := map[string]interface{}{}
···3232 if viewer != "" {
3333 params["viewer"] = viewer
3434 }
3535- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestedUsersSkeleton", params, nil, &out); err != nil {
3535+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestedUsersSkeleton", params, nil, &out); err != nil {
3636 return nil, err
3737 }
3838
+3-3
api/bsky/unspeccedgetSuggestionsSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetSuggestionsSkeleton_Output is the output of a app.bsky.unspecced.getSuggestionsSkeleton call.
···2424//
2525// relativeToDid: DID of the account to get suggestions relative to. If not provided, suggestions will be based on the viewer.
2626// viewer: DID of the account making the request (not included for public/unauthenticated queries). Used to boost followed accounts in ranking.
2727-func UnspeccedGetSuggestionsSkeleton(ctx context.Context, c util.LexClient, cursor string, limit int64, relativeToDid string, viewer string) (*UnspeccedGetSuggestionsSkeleton_Output, error) {
2727+func UnspeccedGetSuggestionsSkeleton(ctx context.Context, c lexutil.LexClient, cursor string, limit int64, relativeToDid string, viewer string) (*UnspeccedGetSuggestionsSkeleton_Output, error) {
2828 var out UnspeccedGetSuggestionsSkeleton_Output
29293030 params := map[string]interface{}{}
···4040 if viewer != "" {
4141 params["viewer"] = viewer
4242 }
4343- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getSuggestionsSkeleton", params, nil, &out); err != nil {
4343+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getSuggestionsSkeleton", params, nil, &out); err != nil {
4444 return nil, err
4545 }
4646
+3-3
api/bsky/unspeccedgetTaggedSuggestions.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetTaggedSuggestions_Output is the output of a app.bsky.unspecced.getTaggedSuggestions call.
···2323}
24242525// UnspeccedGetTaggedSuggestions calls the XRPC method "app.bsky.unspecced.getTaggedSuggestions".
2626-func UnspeccedGetTaggedSuggestions(ctx context.Context, c util.LexClient) (*UnspeccedGetTaggedSuggestions_Output, error) {
2626+func UnspeccedGetTaggedSuggestions(ctx context.Context, c lexutil.LexClient) (*UnspeccedGetTaggedSuggestions_Output, error) {
2727 var out UnspeccedGetTaggedSuggestions_Output
28282929 params := map[string]interface{}{}
3030- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getTaggedSuggestions", params, nil, &out); err != nil {
3030+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getTaggedSuggestions", params, nil, &out); err != nil {
3131 return nil, err
3232 }
3333
-32
api/bsky/unspeccedgetTimelineSkeleton.go
···11-// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
22-33-package bsky
44-55-// schema: app.bsky.unspecced.getTimelineSkeleton
66-77-import (
88- "context"
99-1010- "github.com/bluesky-social/indigo/xrpc"
1111-)
1212-1313-// UnspeccedGetTimelineSkeleton_Output is the output of a app.bsky.unspecced.getTimelineSkeleton call.
1414-type UnspeccedGetTimelineSkeleton_Output struct {
1515- Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
1616- Feed []*FeedDefs_SkeletonFeedPost `json:"feed" cborgen:"feed"`
1717-}
1818-1919-// UnspeccedGetTimelineSkeleton calls the XRPC method "app.bsky.unspecced.getTimelineSkeleton".
2020-func UnspeccedGetTimelineSkeleton(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*UnspeccedGetTimelineSkeleton_Output, error) {
2121- var out UnspeccedGetTimelineSkeleton_Output
2222-2323- params := map[string]interface{}{
2424- "cursor": cursor,
2525- "limit": limit,
2626- }
2727- if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getTimelineSkeleton", params, nil, &out); err != nil {
2828- return nil, err
2929- }
3030-3131- return &out, nil
3232-}
+3-3
api/bsky/unspeccedgetTrendingTopics.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetTrendingTopics_Output is the output of a app.bsky.unspecced.getTrendingTopics call.
···1919// UnspeccedGetTrendingTopics calls the XRPC method "app.bsky.unspecced.getTrendingTopics".
2020//
2121// viewer: DID of the account making the request (not included for public/unauthenticated queries). Used to boost followed accounts in ranking.
2222-func UnspeccedGetTrendingTopics(ctx context.Context, c util.LexClient, limit int64, viewer string) (*UnspeccedGetTrendingTopics_Output, error) {
2222+func UnspeccedGetTrendingTopics(ctx context.Context, c lexutil.LexClient, limit int64, viewer string) (*UnspeccedGetTrendingTopics_Output, error) {
2323 var out UnspeccedGetTrendingTopics_Output
24242525 params := map[string]interface{}{}
···2929 if viewer != "" {
3030 params["viewer"] = viewer
3131 }
3232- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getTrendingTopics", params, nil, &out); err != nil {
3232+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getTrendingTopics", params, nil, &out); err != nil {
3333 return nil, err
3434 }
3535
+3-3
api/bsky/unspeccedgetTrends.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetTrends_Output is the output of a app.bsky.unspecced.getTrends call.
···1616}
17171818// UnspeccedGetTrends calls the XRPC method "app.bsky.unspecced.getTrends".
1919-func UnspeccedGetTrends(ctx context.Context, c util.LexClient, limit int64) (*UnspeccedGetTrends_Output, error) {
1919+func UnspeccedGetTrends(ctx context.Context, c lexutil.LexClient, limit int64) (*UnspeccedGetTrends_Output, error) {
2020 var out UnspeccedGetTrends_Output
21212222 params := map[string]interface{}{}
2323 if limit != 0 {
2424 params["limit"] = limit
2525 }
2626- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getTrends", params, nil, &out); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getTrends", params, nil, &out); err != nil {
2727 return nil, err
2828 }
2929
+3-3
api/bsky/unspeccedgetTrendsSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedGetTrendsSkeleton_Output is the output of a app.bsky.unspecced.getTrendsSkeleton call.
···1818// UnspeccedGetTrendsSkeleton calls the XRPC method "app.bsky.unspecced.getTrendsSkeleton".
1919//
2020// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2121-func UnspeccedGetTrendsSkeleton(ctx context.Context, c util.LexClient, limit int64, viewer string) (*UnspeccedGetTrendsSkeleton_Output, error) {
2121+func UnspeccedGetTrendsSkeleton(ctx context.Context, c lexutil.LexClient, limit int64, viewer string) (*UnspeccedGetTrendsSkeleton_Output, error) {
2222 var out UnspeccedGetTrendsSkeleton_Output
23232424 params := map[string]interface{}{}
···2828 if viewer != "" {
2929 params["viewer"] = viewer
3030 }
3131- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.getTrendsSkeleton", params, nil, &out); err != nil {
3131+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.getTrendsSkeleton", params, nil, &out); err != nil {
3232 return nil, err
3333 }
3434
+3-3
api/bsky/unspeccedinitAgeAssurance.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedInitAgeAssurance_Input is the input argument to a app.bsky.unspecced.initAgeAssurance call.
···2121}
22222323// UnspeccedInitAgeAssurance calls the XRPC method "app.bsky.unspecced.initAgeAssurance".
2424-func UnspeccedInitAgeAssurance(ctx context.Context, c util.LexClient, input *UnspeccedInitAgeAssurance_Input) (*UnspeccedDefs_AgeAssuranceState, error) {
2424+func UnspeccedInitAgeAssurance(ctx context.Context, c lexutil.LexClient, input *UnspeccedInitAgeAssurance_Input) (*UnspeccedDefs_AgeAssuranceState, error) {
2525 var out UnspeccedDefs_AgeAssuranceState
2626- if err := c.LexDo(ctx, util.Procedure, "application/json", "app.bsky.unspecced.initAgeAssurance", nil, input, &out); err != nil {
2626+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "app.bsky.unspecced.initAgeAssurance", nil, input, &out); err != nil {
2727 return nil, err
2828 }
2929
+3-3
api/bsky/unspeccedsearchActorsSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedSearchActorsSkeleton_Output is the output of a app.bsky.unspecced.searchActorsSkeleton call.
···2424// q: Search query string; syntax, phrase, boolean, and faceting is unspecified, but Lucene query syntax is recommended. For typeahead search, only simple term match is supported, not full syntax.
2525// typeahead: If true, acts as fast/simple 'typeahead' query.
2626// viewer: DID of the account making the request (not included for public/unauthenticated queries). Used to boost followed accounts in ranking.
2727-func UnspeccedSearchActorsSkeleton(ctx context.Context, c util.LexClient, cursor string, limit int64, q string, typeahead bool, viewer string) (*UnspeccedSearchActorsSkeleton_Output, error) {
2727+func UnspeccedSearchActorsSkeleton(ctx context.Context, c lexutil.LexClient, cursor string, limit int64, q string, typeahead bool, viewer string) (*UnspeccedSearchActorsSkeleton_Output, error) {
2828 var out UnspeccedSearchActorsSkeleton_Output
29293030 params := map[string]interface{}{}
···4141 if viewer != "" {
4242 params["viewer"] = viewer
4343 }
4444- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.searchActorsSkeleton", params, nil, &out); err != nil {
4444+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.searchActorsSkeleton", params, nil, &out); err != nil {
4545 return nil, err
4646 }
4747
+3-3
api/bsky/unspeccedsearchPostsSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedSearchPostsSkeleton_Output is the output of a app.bsky.unspecced.searchPostsSkeleton call.
···3232// until: Filter results for posts before the indicated datetime (not inclusive). Expected to use 'sortAt' timestamp, which may not match 'createdAt'. Can be a datetime, or just an ISO date (YYY-MM-DD).
3333// url: Filter to posts with links (facet links or embeds) pointing to this URL. Server may apply URL normalization or fuzzy matching.
3434// viewer: DID of the account making the request (not included for public/unauthenticated queries). Used for 'from:me' queries.
3535-func UnspeccedSearchPostsSkeleton(ctx context.Context, c util.LexClient, author string, cursor string, domain string, lang string, limit int64, mentions string, q string, since string, sort string, tag []string, until string, url string, viewer string) (*UnspeccedSearchPostsSkeleton_Output, error) {
3535+func UnspeccedSearchPostsSkeleton(ctx context.Context, c lexutil.LexClient, author string, cursor string, domain string, lang string, limit int64, mentions string, q string, since string, sort string, tag []string, until string, url string, viewer string) (*UnspeccedSearchPostsSkeleton_Output, error) {
3636 var out UnspeccedSearchPostsSkeleton_Output
37373838 params := map[string]interface{}{}
···7373 if viewer != "" {
7474 params["viewer"] = viewer
7575 }
7676- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.searchPostsSkeleton", params, nil, &out); err != nil {
7676+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.searchPostsSkeleton", params, nil, &out); err != nil {
7777 return nil, err
7878 }
7979
+3-3
api/bsky/unspeccedsearchStarterPacksSkeleton.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// UnspeccedSearchStarterPacksSkeleton_Output is the output of a app.bsky.unspecced.searchStarterPacksSkeleton call.
···2323// cursor: Optional pagination mechanism; may not necessarily allow scrolling through entire result set.
2424// q: Search query string; syntax, phrase, boolean, and faceting is unspecified, but Lucene query syntax is recommended.
2525// viewer: DID of the account making the request (not included for public/unauthenticated queries).
2626-func UnspeccedSearchStarterPacksSkeleton(ctx context.Context, c util.LexClient, cursor string, limit int64, q string, viewer string) (*UnspeccedSearchStarterPacksSkeleton_Output, error) {
2626+func UnspeccedSearchStarterPacksSkeleton(ctx context.Context, c lexutil.LexClient, cursor string, limit int64, q string, viewer string) (*UnspeccedSearchStarterPacksSkeleton_Output, error) {
2727 var out UnspeccedSearchStarterPacksSkeleton_Output
28282929 params := map[string]interface{}{}
···3737 if viewer != "" {
3838 params["viewer"] = viewer
3939 }
4040- if err := c.LexDo(ctx, util.Query, "", "app.bsky.unspecced.searchStarterPacksSkeleton", params, nil, &out); err != nil {
4040+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.unspecced.searchStarterPacksSkeleton", params, nil, &out); err != nil {
4141 return nil, err
4242 }
4343
+6-6
api/bsky/videodefs.go
···55package bsky
6677import (
88- "github.com/bluesky-social/indigo/lex/util"
88+ lexutil "github.com/bluesky-social/indigo/lex/util"
99)
10101111// VideoDefs_JobStatus is a "jobStatus" in the app.bsky.video.defs schema.
1212type VideoDefs_JobStatus struct {
1313- Blob *util.LexBlob `json:"blob,omitempty" cborgen:"blob,omitempty"`
1414- Did string `json:"did" cborgen:"did"`
1515- Error *string `json:"error,omitempty" cborgen:"error,omitempty"`
1616- JobId string `json:"jobId" cborgen:"jobId"`
1717- Message *string `json:"message,omitempty" cborgen:"message,omitempty"`
1313+ Blob *lexutil.LexBlob `json:"blob,omitempty" cborgen:"blob,omitempty"`
1414+ Did string `json:"did" cborgen:"did"`
1515+ Error *string `json:"error,omitempty" cborgen:"error,omitempty"`
1616+ JobId string `json:"jobId" cborgen:"jobId"`
1717+ Message *string `json:"message,omitempty" cborgen:"message,omitempty"`
1818 // progress: Progress within the current processing state.
1919 Progress *int64 `json:"progress,omitempty" cborgen:"progress,omitempty"`
2020 // state: The state of the video processing job. All values not listed as a known value indicate that the job is in process.
+3-3
api/bsky/videogetJobStatus.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// VideoGetJobStatus_Output is the output of a app.bsky.video.getJobStatus call.
···1616}
17171818// VideoGetJobStatus calls the XRPC method "app.bsky.video.getJobStatus".
1919-func VideoGetJobStatus(ctx context.Context, c util.LexClient, jobId string) (*VideoGetJobStatus_Output, error) {
1919+func VideoGetJobStatus(ctx context.Context, c lexutil.LexClient, jobId string) (*VideoGetJobStatus_Output, error) {
2020 var out VideoGetJobStatus_Output
21212222 params := map[string]interface{}{}
2323 params["jobId"] = jobId
2424- if err := c.LexDo(ctx, util.Query, "", "app.bsky.video.getJobStatus", params, nil, &out); err != nil {
2424+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.video.getJobStatus", params, nil, &out); err != nil {
2525 return nil, err
2626 }
2727
+3-3
api/bsky/videogetUploadLimits.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// VideoGetUploadLimits_Output is the output of a app.bsky.video.getUploadLimits call.
···2020}
21212222// VideoGetUploadLimits calls the XRPC method "app.bsky.video.getUploadLimits".
2323-func VideoGetUploadLimits(ctx context.Context, c util.LexClient) (*VideoGetUploadLimits_Output, error) {
2323+func VideoGetUploadLimits(ctx context.Context, c lexutil.LexClient) (*VideoGetUploadLimits_Output, error) {
2424 var out VideoGetUploadLimits_Output
2525- if err := c.LexDo(ctx, util.Query, "", "app.bsky.video.getUploadLimits", nil, nil, &out); err != nil {
2525+ if err := c.LexDo(ctx, lexutil.Query, "", "app.bsky.video.getUploadLimits", nil, nil, &out); err != nil {
2626 return nil, err
2727 }
2828
+3-3
api/bsky/videouploadVideo.go
···88 "context"
99 "io"
10101111- "github.com/bluesky-social/indigo/lex/util"
1111+ lexutil "github.com/bluesky-social/indigo/lex/util"
1212)
13131414// VideoUploadVideo_Output is the output of a app.bsky.video.uploadVideo call.
···1717}
18181919// VideoUploadVideo calls the XRPC method "app.bsky.video.uploadVideo".
2020-func VideoUploadVideo(ctx context.Context, c util.LexClient, input io.Reader) (*VideoUploadVideo_Output, error) {
2020+func VideoUploadVideo(ctx context.Context, c lexutil.LexClient, input io.Reader) (*VideoUploadVideo_Output, error) {
2121 var out VideoUploadVideo_Output
2222- if err := c.LexDo(ctx, util.Procedure, "video/mp4", "app.bsky.video.uploadVideo", nil, input, &out); err != nil {
2222+ if err := c.LexDo(ctx, lexutil.Procedure, "video/mp4", "app.bsky.video.uploadVideo", nil, input, &out); err != nil {
2323 return nil, err
2424 }
2525
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ModerationGetSubjects_Output is the output of a tools.ozone.moderation.getSubjects call.
···1616}
17171818// ModerationGetSubjects calls the XRPC method "tools.ozone.moderation.getSubjects".
1919-func ModerationGetSubjects(ctx context.Context, c util.LexClient, subjects []string) (*ModerationGetSubjects_Output, error) {
1919+func ModerationGetSubjects(ctx context.Context, c lexutil.LexClient, subjects []string) (*ModerationGetSubjects_Output, error) {
2020 var out ModerationGetSubjects_Output
21212222 params := map[string]interface{}{}
2323 params["subjects"] = subjects
2424- if err := c.LexDo(ctx, util.Query, "", "tools.ozone.moderation.getSubjects", params, nil, &out); err != nil {
2424+ if err := c.LexDo(ctx, lexutil.Query, "", "tools.ozone.moderation.getSubjects", params, nil, &out); err != nil {
2525 return nil, err
2626 }
2727
+3-3
api/ozone/moderationlistScheduledActions.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ModerationListScheduledActions_Input is the input argument to a tools.ozone.moderation.listScheduledActions call.
···3434}
35353636// ModerationListScheduledActions calls the XRPC method "tools.ozone.moderation.listScheduledActions".
3737-func ModerationListScheduledActions(ctx context.Context, c util.LexClient, input *ModerationListScheduledActions_Input) (*ModerationListScheduledActions_Output, error) {
3737+func ModerationListScheduledActions(ctx context.Context, c lexutil.LexClient, input *ModerationListScheduledActions_Input) (*ModerationListScheduledActions_Output, error) {
3838 var out ModerationListScheduledActions_Output
3939- if err := c.LexDo(ctx, util.Procedure, "application/json", "tools.ozone.moderation.listScheduledActions", nil, input, &out); err != nil {
3939+ if err := c.LexDo(ctx, lexutil.Procedure, "application/json", "tools.ozone.moderation.listScheduledActions", nil, input, &out); err != nil {
4040 return nil, err
4141 }
4242
+3-3
api/ozone/moderationqueryEvents.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ModerationQueryEvents_Output is the output of a tools.ozone.moderation.queryEvents call.
···3434// sortDirection: Sort direction for the events. Defaults to descending order of created at timestamp.
3535// subjectType: If specified, only events where the subject is of the given type (account or record) will be returned. When this is set to 'account' the 'collections' parameter will be ignored. When includeAllUserRecords or subject is set, this will be ignored.
3636// types: The types of events (fully qualified string in the format of tools.ozone.moderation.defs#modEvent<name>) to filter by. If not specified, all events are returned.
3737-func ModerationQueryEvents(ctx context.Context, c util.LexClient, addedLabels []string, addedTags []string, ageAssuranceState string, batchId string, collections []string, comment string, createdAfter string, createdBefore string, createdBy string, cursor string, hasComment bool, includeAllUserRecords bool, limit int64, modTool []string, policies []string, removedLabels []string, removedTags []string, reportTypes []string, sortDirection string, subject string, subjectType string, types []string) (*ModerationQueryEvents_Output, error) {
3737+func ModerationQueryEvents(ctx context.Context, c lexutil.LexClient, addedLabels []string, addedTags []string, ageAssuranceState string, batchId string, collections []string, comment string, createdAfter string, createdBefore string, createdBy string, cursor string, hasComment bool, includeAllUserRecords bool, limit int64, modTool []string, policies []string, removedLabels []string, removedTags []string, reportTypes []string, sortDirection string, subject string, subjectType string, types []string) (*ModerationQueryEvents_Output, error) {
3838 var out ModerationQueryEvents_Output
39394040 params := map[string]interface{}{}
···104104 if len(types) != 0 {
105105 params["types"] = types
106106 }
107107- if err := c.LexDo(ctx, util.Query, "", "tools.ozone.moderation.queryEvents", params, nil, &out); err != nil {
107107+ if err := c.LexDo(ctx, lexutil.Query, "", "tools.ozone.moderation.queryEvents", params, nil, &out); err != nil {
108108 return nil, err
109109 }
110110
+3-3
api/ozone/moderationqueryStatuses.go
···77import (
88 "context"
991010- "github.com/bluesky-social/indigo/lex/util"
1010+ lexutil "github.com/bluesky-social/indigo/lex/util"
1111)
12121313// ModerationQueryStatuses_Output is the output of a tools.ozone.moderation.queryStatuses call.
···4646// subject: The subject to get the status for.
4747// subjectType: If specified, subjects of the given type (account or record) will be returned. When this is set to 'account' the 'collections' parameter will be ignored. When includeAllUserRecords or subject is set, this will be ignored.
4848// takendown: Get subjects that were taken down
4949-func ModerationQueryStatuses(ctx context.Context, c util.LexClient, ageAssuranceState string, appealed bool, collections []string, comment string, cursor string, excludeTags []string, hostingDeletedAfter string, hostingDeletedBefore string, hostingStatuses []string, hostingUpdatedAfter string, hostingUpdatedBefore string, ignoreSubjects []string, includeAllUserRecords bool, includeMuted bool, lastReviewedBy string, limit int64, minAccountSuspendCount int64, minPriorityScore int64, minReportedRecordsCount int64, minTakendownRecordsCount int64, onlyMuted bool, queueCount int64, queueIndex int64, queueSeed string, reportedAfter string, reportedBefore string, reviewState string, reviewedAfter string, reviewedBefore string, sortDirection string, sortField string, subject string, subjectType string, tags []string, takendown bool) (*ModerationQueryStatuses_Output, error) {
4949+func ModerationQueryStatuses(ctx context.Context, c lexutil.LexClient, ageAssuranceState string, appealed bool, collections []string, comment string, cursor string, excludeTags []string, hostingDeletedAfter string, hostingDeletedBefore string, hostingStatuses []string, hostingUpdatedAfter string, hostingUpdatedBefore string, ignoreSubjects []string, includeAllUserRecords bool, includeMuted bool, lastReviewedBy string, limit int64, minAccountSuspendCount int64, minPriorityScore int64, minReportedRecordsCount int64, minTakendownRecordsCount int64, onlyMuted bool, queueCount int64, queueIndex int64, queueSeed string, reportedAfter string, reportedBefore string, reviewState string, reviewedAfter string, reviewedBefore string, sortDirection string, sortField string, subject string, subjectType string, tags []string, takendown bool) (*ModerationQueryStatuses_Output, error) {
5050 var out ModerationQueryStatuses_Output
51515252 params := map[string]interface{}{}
···155155 if takendown {
156156 params["takendown"] = takendown
157157 }
158158- if err := c.LexDo(ctx, util.Query, "", "tools.ozone.moderation.queryStatuses", params, nil, &out); err != nil {
158158+ if err := c.LexDo(ctx, lexutil.Query, "", "tools.ozone.moderation.queryStatuses", params, nil, &out); err != nil {
159159 return nil, err
160160 }
161161