Bump lexgen and support #identity events on the firehose

api/atproto/cbor_gen.go

···
 
 	return nil
 }
+func (t *SyncSubscribeRepos_Identity) MarshalCBOR(w io.Writer) error {
+	if t == nil {
+		_, err := w.Write(cbg.CborNull)
+		return err
+	}
+
+	cw := cbg.NewCborWriter(w)
+
+	if _, err := cw.Write([]byte{162}); err != nil {
+		return err
+	}
+
+	// t.Did (string) (string)
+	if uint64(len("did")) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"did\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("did"))); err != nil {
+		return err
+	}
+	if _, err := cw.WriteString(string("did")); err != nil {
+		return err
+	}
+
+	if uint64(len(t.Did)) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.Did was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Did))); err != nil {
+		return err
+	}
+	if _, err := cw.WriteString(string(t.Did)); err != nil {
+		return err
+	}
+
+	// t.Seq (int64) (int64)
+	if uint64(len("seq")) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"seq\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("seq"))); err != nil {
+		return err
+	}
+	if _, err := cw.WriteString(string("seq")); err != nil {
+		return err
+	}
+
+	if t.Seq >= 0 {
+		if err := cw.WriteMajorTypeHeader(cbg.MajUnsignedInt, uint64(t.Seq)); err != nil {
+			return err
+		}
+	} else {
+		if err := cw.WriteMajorTypeHeader(cbg.MajNegativeInt, uint64(-t.Seq-1)); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (t *SyncSubscribeRepos_Identity) UnmarshalCBOR(r io.Reader) (err error) {
+	*t = SyncSubscribeRepos_Identity{}
+
+	cr := cbg.NewCborReader(r)
+
+	maj, extra, err := cr.ReadHeader()
+	if err != nil {
+		return err
+	}
+	defer func() {
+		if err == io.EOF {
+			err = io.ErrUnexpectedEOF
+		}
+	}()
+
+	if maj != cbg.MajMap {
+		return fmt.Errorf("cbor input should be of type map")
+	}
+
+	if extra > cbg.MaxLength {
+		return fmt.Errorf("SyncSubscribeRepos_Identity: map struct too large (%d)", extra)
+	}
+
+	var name string
+	n := extra
+
+	for i := uint64(0); i < n; i++ {
+
+		{
+			sval, err := cbg.ReadString(cr)
+			if err != nil {
+				return err
+			}
+
+			name = string(sval)
+		}
+
+		switch name {
+		// t.Did (string) (string)
+		case "did":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.Did = string(sval)
+			}
+			// t.Seq (int64) (int64)
+		case "seq":
+			{
+				maj, extra, err := cr.ReadHeader()
+				var extraI int64
+				if err != nil {
+					return err
+				}
+				switch maj {
+				case cbg.MajUnsignedInt:
+					extraI = int64(extra)
+					if extraI < 0 {
+						return fmt.Errorf("int64 positive overflow")
+					}
+				case cbg.MajNegativeInt:
+					extraI = int64(extra)
+					if extraI < 0 {
+						return fmt.Errorf("int64 negative overflow")
+					}
+					extraI = -1 - extraI
+				default:
+					return fmt.Errorf("wrong type for int64 field: %d", maj)
+				}
+
+				t.Seq = int64(extraI)
+			}
+
+		default:
+			// Field doesn't exist on this type, so ignore it
+			cbg.ScanForLinks(r, func(cid.Cid) {})
+		}
+	}
+
+	return nil
+}
 func (t *SyncSubscribeRepos_Info) MarshalCBOR(w io.Writer) error {
 	if t == nil {
 		_, err := w.Write(cbg.CborNull)

api/atproto/identitygetRecommendedDidCredentials.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.identity.getRecommendedDidCredentials
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/lex/util"
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// IdentityGetRecommendedDidCredentials_Output is the output of a com.atproto.identity.getRecommendedDidCredentials call.
+type IdentityGetRecommendedDidCredentials_Output struct {
+	AlsoKnownAs []string `json:"alsoKnownAs,omitempty" cborgen:"alsoKnownAs,omitempty"`
+	// rotationKeys: Recommended rotation keys for PLC dids. Should be undefined (or ignored) for did:webs.
+	RotationKeys        []string                 `json:"rotationKeys,omitempty" cborgen:"rotationKeys,omitempty"`
+	Services            *util.LexiconTypeDecoder `json:"services,omitempty" cborgen:"services,omitempty"`
+	VerificationMethods *util.LexiconTypeDecoder `json:"verificationMethods,omitempty" cborgen:"verificationMethods,omitempty"`
+}
+
+// IdentityGetRecommendedDidCredentials calls the XRPC method "com.atproto.identity.getRecommendedDidCredentials".
+func IdentityGetRecommendedDidCredentials(ctx context.Context, c *xrpc.Client) (*IdentityGetRecommendedDidCredentials_Output, error) {
+	var out IdentityGetRecommendedDidCredentials_Output
+	if err := c.Do(ctx, xrpc.Query, "", "com.atproto.identity.getRecommendedDidCredentials", nil, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/atproto/identityrequestPlcOperationSignature.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.identity.requestPlcOperationSignature
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// IdentityRequestPlcOperationSignature calls the XRPC method "com.atproto.identity.requestPlcOperationSignature".
+func IdentityRequestPlcOperationSignature(ctx context.Context, c *xrpc.Client) error {
+	if err := c.Do(ctx, xrpc.Procedure, "", "com.atproto.identity.requestPlcOperationSignature", nil, nil, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/atproto/identitysignPlcOperation.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.identity.signPlcOperation
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/lex/util"
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// IdentitySignPlcOperation_Input is the input argument to a com.atproto.identity.signPlcOperation call.
+type IdentitySignPlcOperation_Input struct {
+	AlsoKnownAs  []string                 `json:"alsoKnownAs,omitempty" cborgen:"alsoKnownAs,omitempty"`
+	RotationKeys []string                 `json:"rotationKeys,omitempty" cborgen:"rotationKeys,omitempty"`
+	Services     *util.LexiconTypeDecoder `json:"services,omitempty" cborgen:"services,omitempty"`
+	// token: A token received through com.atproto.identity.requestPlcOperationSignature
+	Token               *string                  `json:"token,omitempty" cborgen:"token,omitempty"`
+	VerificationMethods *util.LexiconTypeDecoder `json:"verificationMethods,omitempty" cborgen:"verificationMethods,omitempty"`
+}
+
+// IdentitySignPlcOperation_Output is the output of a com.atproto.identity.signPlcOperation call.
+type IdentitySignPlcOperation_Output struct {
+	// operation: A signed DID PLC operation.
+	Operation *util.LexiconTypeDecoder `json:"operation" cborgen:"operation"`
+}
+
+// IdentitySignPlcOperation calls the XRPC method "com.atproto.identity.signPlcOperation".
+func IdentitySignPlcOperation(ctx context.Context, c *xrpc.Client, input *IdentitySignPlcOperation_Input) (*IdentitySignPlcOperation_Output, error) {
+	var out IdentitySignPlcOperation_Output
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.identity.signPlcOperation", nil, input, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/atproto/identitysubmitPlcOperation.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.identity.submitPlcOperation
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/lex/util"
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// IdentitySubmitPlcOperation_Input is the input argument to a com.atproto.identity.submitPlcOperation call.
+type IdentitySubmitPlcOperation_Input struct {
+	Operation *util.LexiconTypeDecoder `json:"operation" cborgen:"operation"`
+}
+
+// IdentitySubmitPlcOperation calls the XRPC method "com.atproto.identity.submitPlcOperation".
+func IdentitySubmitPlcOperation(ctx context.Context, c *xrpc.Client, input *IdentitySubmitPlcOperation_Input) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.identity.submitPlcOperation", nil, input, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/atproto/identityupdateHandle.go

···
 
 // IdentityUpdateHandle_Input is the input argument to a com.atproto.identity.updateHandle call.
 type IdentityUpdateHandle_Input struct {
+	// handle: The new handle.
 	Handle string `json:"handle" cborgen:"handle"`
 }
 

api/atproto/moderationcreateReport.go

···
 
 // ModerationCreateReport_Input is the input argument to a com.atproto.moderation.createReport call.
 type ModerationCreateReport_Input struct {
-	Reason     *string                               `json:"reason,omitempty" cborgen:"reason,omitempty"`
+	// reason: Additional context about the content and violation.
+	Reason *string `json:"reason,omitempty" cborgen:"reason,omitempty"`
+	// reasonType: Indicates the broad category of violation the report is for.
 	ReasonType *string                               `json:"reasonType" cborgen:"reasonType"`
 	Subject    *ModerationCreateReport_Input_Subject `json:"subject" cborgen:"subject"`
 }

api/atproto/repoapplyWrites.go

···
 
 // RepoApplyWrites_Create is a "create" in the com.atproto.repo.applyWrites schema.
 //
-// Create a new record.
+// Operation which creates a new record.
 //
 // RECORDTYPE: RepoApplyWrites_Create
 type RepoApplyWrites_Create struct {
···
 
 // RepoApplyWrites_Delete is a "delete" in the com.atproto.repo.applyWrites schema.
 //
-// Delete an existing record.
+// Operation which deletes an existing record.
 //
 // RECORDTYPE: RepoApplyWrites_Delete
 type RepoApplyWrites_Delete struct {
···
 
 // RepoApplyWrites_Input is the input argument to a com.atproto.repo.applyWrites call.
 type RepoApplyWrites_Input struct {
-	// repo: The handle or DID of the repo.
-	Repo       string  `json:"repo" cborgen:"repo"`
+	// repo: The handle or DID of the repo (aka, current account).
+	Repo string `json:"repo" cborgen:"repo"`
+	// swapCommit: If provided, the entire operation will fail if the current repo commit CID does not match this value. Used to prevent conflicting repo mutations.
 	SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"`
-	// validate: Flag for validating the records.
+	// validate: Can be set to 'false' to skip Lexicon schema validation of record data, for all operations.
 	Validate *bool                                `json:"validate,omitempty" cborgen:"validate,omitempty"`
 	Writes   []*RepoApplyWrites_Input_Writes_Elem `json:"writes" cborgen:"writes"`
 }
···
 
 // RepoApplyWrites_Update is a "update" in the com.atproto.repo.applyWrites schema.
 //
-// Update an existing record.
+// Operation which updates an existing record.
 //
 // RECORDTYPE: RepoApplyWrites_Update
 type RepoApplyWrites_Update struct {

api/atproto/repocreateRecord.go

···
 type RepoCreateRecord_Input struct {
 	// collection: The NSID of the record collection.
 	Collection string `json:"collection" cborgen:"collection"`
-	// record: The record to create.
+	// record: The record itself. Must contain a $type field.
 	Record *util.LexiconTypeDecoder `json:"record" cborgen:"record"`
-	// repo: The handle or DID of the repo.
+	// repo: The handle or DID of the repo (aka, current account).
 	Repo string `json:"repo" cborgen:"repo"`
-	// rkey: The key of the record.
+	// rkey: The Record Key.
 	Rkey *string `json:"rkey,omitempty" cborgen:"rkey,omitempty"`
 	// swapCommit: Compare and swap with the previous commit by CID.
 	SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"`
-	// validate: Flag for validating the record.
+	// validate: Can be set to 'false' to skip Lexicon schema validation of record data.
 	Validate *bool `json:"validate,omitempty" cborgen:"validate,omitempty"`
 }
 

api/atproto/repodeleteRecord.go

···
 type RepoDeleteRecord_Input struct {
 	// collection: The NSID of the record collection.
 	Collection string `json:"collection" cborgen:"collection"`
-	// repo: The handle or DID of the repo.
+	// repo: The handle or DID of the repo (aka, current account).
 	Repo string `json:"repo" cborgen:"repo"`
-	// rkey: The key of the record.
+	// rkey: The Record Key.
 	Rkey string `json:"rkey" cborgen:"rkey"`
 	// swapCommit: Compare and swap with the previous commit by CID.
 	SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"`

api/atproto/repodescribeRepo.go

···
 
 // RepoDescribeRepo_Output is the output of a com.atproto.repo.describeRepo call.
 type RepoDescribeRepo_Output struct {
-	Collections     []string    `json:"collections" cborgen:"collections"`
-	Did             string      `json:"did" cborgen:"did"`
-	DidDoc          interface{} `json:"didDoc" cborgen:"didDoc"`
-	Handle          string      `json:"handle" cborgen:"handle"`
-	HandleIsCorrect bool        `json:"handleIsCorrect" cborgen:"handleIsCorrect"`
+	// collections: List of all the collections (NSIDs) for which this repo contains at least one record.
+	Collections []string `json:"collections" cborgen:"collections"`
+	Did         string   `json:"did" cborgen:"did"`
+	// didDoc: The complete DID document for this account.
+	DidDoc interface{} `json:"didDoc" cborgen:"didDoc"`
+	Handle string      `json:"handle" cborgen:"handle"`
+	// handleIsCorrect: Indicates if handle is currently valid (resolves bi-directionally)
+	HandleIsCorrect bool `json:"handleIsCorrect" cborgen:"handleIsCorrect"`
 }
 
 // RepoDescribeRepo calls the XRPC method "com.atproto.repo.describeRepo".

api/atproto/repogetRecord.go

···
 // cid: The CID of the version of the record. If not specified, then return the most recent version.
 // collection: The NSID of the record collection.
 // repo: The handle or DID of the repo.
-// rkey: The key of the record.
+// rkey: The Record Key.
 func RepoGetRecord(ctx context.Context, c *xrpc.Client, cid string, collection string, repo string, rkey string) (*RepoGetRecord_Output, error) {
 	var out RepoGetRecord_Output
 

api/atproto/repoimportRepo.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.repo.importRepo
+
+import (
+	"context"
+	"io"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// RepoImportRepo calls the XRPC method "com.atproto.repo.importRepo".
+func RepoImportRepo(ctx context.Context, c *xrpc.Client, input io.Reader) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/vnd.ipld.car", "com.atproto.repo.importRepo", nil, input, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/atproto/repolistMissingBlobs.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.repo.listMissingBlobs
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// RepoListMissingBlobs_Output is the output of a com.atproto.repo.listMissingBlobs call.
+type RepoListMissingBlobs_Output struct {
+	Blobs  []*RepoListMissingBlobs_RecordBlob `json:"blobs" cborgen:"blobs"`
+	Cursor *string                            `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
+}
+
+// RepoListMissingBlobs_RecordBlob is a "recordBlob" in the com.atproto.repo.listMissingBlobs schema.
+type RepoListMissingBlobs_RecordBlob struct {
+	Cid       string `json:"cid" cborgen:"cid"`
+	RecordUri string `json:"recordUri" cborgen:"recordUri"`
+}
+
+// RepoListMissingBlobs calls the XRPC method "com.atproto.repo.listMissingBlobs".
+func RepoListMissingBlobs(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*RepoListMissingBlobs_Output, error) {
+	var out RepoListMissingBlobs_Output
+
+	params := map[string]interface{}{
+		"cursor": cursor,
+		"limit":  limit,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "com.atproto.repo.listMissingBlobs", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/atproto/repoputRecord.go

···
 	Collection string `json:"collection" cborgen:"collection"`
 	// record: The record to write.
 	Record *util.LexiconTypeDecoder `json:"record" cborgen:"record"`
-	// repo: The handle or DID of the repo.
+	// repo: The handle or DID of the repo (aka, current account).
 	Repo string `json:"repo" cborgen:"repo"`
-	// rkey: The key of the record.
+	// rkey: The Record Key.
 	Rkey string `json:"rkey" cborgen:"rkey"`
 	// swapCommit: Compare and swap with the previous commit by CID.
 	SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"`
-	// swapRecord: Compare and swap with the previous record by CID.
+	// swapRecord: Compare and swap with the previous record by CID. WARNING: nullable and optional field; may cause problems with golang implementation
 	SwapRecord *string `json:"swapRecord" cborgen:"swapRecord"`
-	// validate: Flag for validating the record.
+	// validate: Can be set to 'false' to skip Lexicon schema validation of record data.
 	Validate *bool `json:"validate,omitempty" cborgen:"validate,omitempty"`
 }
 

api/atproto/serveractivateAccount.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.server.activateAccount
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ServerActivateAccount calls the XRPC method "com.atproto.server.activateAccount".
+func ServerActivateAccount(ctx context.Context, c *xrpc.Client) error {
+	if err := c.Do(ctx, xrpc.Procedure, "", "com.atproto.server.activateAccount", nil, nil, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/atproto/servercheckAccountStatus.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.server.checkAccountStatus
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ServerCheckAccountStatus_Output is the output of a com.atproto.server.checkAccountStatus call.
+type ServerCheckAccountStatus_Output struct {
+	Activated          bool   `json:"activated" cborgen:"activated"`
+	ExpectedBlobs      int64  `json:"expectedBlobs" cborgen:"expectedBlobs"`
+	ImportedBlobs      int64  `json:"importedBlobs" cborgen:"importedBlobs"`
+	IndexedRecords     int64  `json:"indexedRecords" cborgen:"indexedRecords"`
+	PrivateStateValues int64  `json:"privateStateValues" cborgen:"privateStateValues"`
+	RepoBlocks         int64  `json:"repoBlocks" cborgen:"repoBlocks"`
+	RepoCommit         string `json:"repoCommit" cborgen:"repoCommit"`
+	RepoRev            string `json:"repoRev" cborgen:"repoRev"`
+	ValidDid           bool   `json:"validDid" cborgen:"validDid"`
+}
+
+// ServerCheckAccountStatus calls the XRPC method "com.atproto.server.checkAccountStatus".
+func ServerCheckAccountStatus(ctx context.Context, c *xrpc.Client) (*ServerCheckAccountStatus_Output, error) {
+	var out ServerCheckAccountStatus_Output
+	if err := c.Do(ctx, xrpc.Query, "", "com.atproto.server.checkAccountStatus", nil, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/atproto/servercreateAccount.go

···
 
 // ServerCreateAccount_Input is the input argument to a com.atproto.server.createAccount call.
 type ServerCreateAccount_Input struct {
-	Did               *string      `json:"did,omitempty" cborgen:"did,omitempty"`
-	Email             *string      `json:"email,omitempty" cborgen:"email,omitempty"`
-	Handle            string       `json:"handle" cborgen:"handle"`
-	InviteCode        *string      `json:"inviteCode,omitempty" cborgen:"inviteCode,omitempty"`
-	Password          *string      `json:"password,omitempty" cborgen:"password,omitempty"`
-	PlcOp             *interface{} `json:"plcOp,omitempty" cborgen:"plcOp,omitempty"`
-	RecoveryKey       *string      `json:"recoveryKey,omitempty" cborgen:"recoveryKey,omitempty"`
-	VerificationCode  *string      `json:"verificationCode,omitempty" cborgen:"verificationCode,omitempty"`
-	VerificationPhone *string      `json:"verificationPhone,omitempty" cborgen:"verificationPhone,omitempty"`
+	// did: Pre-existing atproto DID, being imported to a new account.
+	Did   *string `json:"did,omitempty" cborgen:"did,omitempty"`
+	Email *string `json:"email,omitempty" cborgen:"email,omitempty"`
+	// handle: Requested handle for the account.
+	Handle     string  `json:"handle" cborgen:"handle"`
+	InviteCode *string `json:"inviteCode,omitempty" cborgen:"inviteCode,omitempty"`
+	// password: Initial account password. May need to meet instance-specific password strength requirements.
+	Password *string `json:"password,omitempty" cborgen:"password,omitempty"`
+	// plcOp: A signed DID PLC operation to be submitted as part of importing an existing account to this instance. NOTE: this optional field may be updated when full account migration is implemented.
+	PlcOp *interface{} `json:"plcOp,omitempty" cborgen:"plcOp,omitempty"`
+	// recoveryKey: DID PLC rotation key (aka, recovery key) to be included in PLC creation operation.
+	RecoveryKey       *string `json:"recoveryKey,omitempty" cborgen:"recoveryKey,omitempty"`
+	VerificationCode  *string `json:"verificationCode,omitempty" cborgen:"verificationCode,omitempty"`
+	VerificationPhone *string `json:"verificationPhone,omitempty" cborgen:"verificationPhone,omitempty"`
 }
 
 // ServerCreateAccount_Output is the output of a com.atproto.server.createAccount call.
+//
+// Account login session returned on successful account creation.
 type ServerCreateAccount_Output struct {
-	AccessJwt  string       `json:"accessJwt" cborgen:"accessJwt"`
-	Did        string       `json:"did" cborgen:"did"`
+	AccessJwt string `json:"accessJwt" cborgen:"accessJwt"`
+	// did: The DID of the new account.
+	Did string `json:"did" cborgen:"did"`
+	// didDoc: Complete DID document.
 	DidDoc     *interface{} `json:"didDoc,omitempty" cborgen:"didDoc,omitempty"`
 	Handle     string       `json:"handle" cborgen:"handle"`
 	RefreshJwt string       `json:"refreshJwt" cborgen:"refreshJwt"`

api/atproto/servercreateAppPassword.go

···
 
 // ServerCreateAppPassword_Input is the input argument to a com.atproto.server.createAppPassword call.
 type ServerCreateAppPassword_Input struct {
+	// name: A short name for the App Password, to help distinguish them.
 	Name string `json:"name" cborgen:"name"`
 }
 

api/atproto/serverdeactivateAccount.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.server.deactivateAccount
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ServerDeactivateAccount_Input is the input argument to a com.atproto.server.deactivateAccount call.
+type ServerDeactivateAccount_Input struct {
+	// deleteAfter: A recommendation to server as to how long they should hold onto the deactivated account before deleting.
+	DeleteAfter *string `json:"deleteAfter,omitempty" cborgen:"deleteAfter,omitempty"`
+}
+
+// ServerDeactivateAccount calls the XRPC method "com.atproto.server.deactivateAccount".
+func ServerDeactivateAccount(ctx context.Context, c *xrpc.Client, input *ServerDeactivateAccount_Input) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.server.deactivateAccount", nil, input, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/atproto/serverdescribeServer.go

···
 
 // ServerDescribeServer_Output is the output of a com.atproto.server.describeServer call.
 type ServerDescribeServer_Output struct {
-	AvailableUserDomains      []string                    `json:"availableUserDomains" cborgen:"availableUserDomains"`
-	InviteCodeRequired        *bool                       `json:"inviteCodeRequired,omitempty" cborgen:"inviteCodeRequired,omitempty"`
-	Links                     *ServerDescribeServer_Links `json:"links,omitempty" cborgen:"links,omitempty"`
-	PhoneVerificationRequired *bool                       `json:"phoneVerificationRequired,omitempty" cborgen:"phoneVerificationRequired,omitempty"`
+	// availableUserDomains: List of domain suffixes that can be used in account handles.
+	AvailableUserDomains []string `json:"availableUserDomains" cborgen:"availableUserDomains"`
+	Did                  string   `json:"did" cborgen:"did"`
+	// inviteCodeRequired: If true, an invite code must be supplied to create an account on this instance.
+	InviteCodeRequired *bool `json:"inviteCodeRequired,omitempty" cborgen:"inviteCodeRequired,omitempty"`
+	// links: URLs of service policy documents.
+	Links *ServerDescribeServer_Links `json:"links,omitempty" cborgen:"links,omitempty"`
+	// phoneVerificationRequired: If true, a phone verification token must be supplied to create an account on this instance.
+	PhoneVerificationRequired *bool `json:"phoneVerificationRequired,omitempty" cborgen:"phoneVerificationRequired,omitempty"`
 }
 
 // ServerDescribeServer calls the XRPC method "com.atproto.server.describeServer".

api/atproto/servergetAccountInviteCodes.go

···
 }
 
 // ServerGetAccountInviteCodes calls the XRPC method "com.atproto.server.getAccountInviteCodes".
+//
+// createAvailable: Controls whether any new 'earned' but not 'created' invites should be created.
 func ServerGetAccountInviteCodes(ctx context.Context, c *xrpc.Client, createAvailable bool, includeUsed bool) (*ServerGetAccountInviteCodes_Output, error) {
 	var out ServerGetAccountInviteCodes_Output
 

api/atproto/servergetServiceAuth.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.server.getServiceAuth
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ServerGetServiceAuth_Output is the output of a com.atproto.server.getServiceAuth call.
+type ServerGetServiceAuth_Output struct {
+	Token string `json:"token" cborgen:"token"`
+}
+
+// ServerGetServiceAuth calls the XRPC method "com.atproto.server.getServiceAuth".
+//
+// aud: The DID of the service that the token will be used to authenticate with
+func ServerGetServiceAuth(ctx context.Context, c *xrpc.Client, aud string) (*ServerGetServiceAuth_Output, error) {
+	var out ServerGetServiceAuth_Output
+
+	params := map[string]interface{}{
+		"aud": aud,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "com.atproto.server.getServiceAuth", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/atproto/serverreserveSigningKey.go

···
 
 // ServerReserveSigningKey_Input is the input argument to a com.atproto.server.reserveSigningKey call.
 type ServerReserveSigningKey_Input struct {
-	// did: The did to reserve a new did:key for
+	// did: The DID to reserve a key for.
 	Did *string `json:"did,omitempty" cborgen:"did,omitempty"`
 }
 
 // ServerReserveSigningKey_Output is the output of a com.atproto.server.reserveSigningKey call.
 type ServerReserveSigningKey_Output struct {
-	// signingKey: Public signing key in the form of a did:key.
+	// signingKey: The public key for the reserved signing key, in did:key serialization.
 	SigningKey string `json:"signingKey" cborgen:"signingKey"`
 }
 

api/atproto/syncgetBlob.go

···
 // SyncGetBlob calls the XRPC method "com.atproto.sync.getBlob".
 //
 // cid: The CID of the blob to fetch
-// did: The DID of the repo.
+// did: The DID of the account.
 func SyncGetBlob(ctx context.Context, c *xrpc.Client, cid string, did string) ([]byte, error) {
 	buf := new(bytes.Buffer)
 

api/atproto/syncgetRecord.go

···
 //
 // commit: An optional past commit CID.
 // did: The DID of the repo.
+// rkey: Record Key
 func SyncGetRecord(ctx context.Context, c *xrpc.Client, collection string, commit string, did string, rkey string) ([]byte, error) {
 	buf := new(bytes.Buffer)
 

api/atproto/syncgetRepo.go

···
 // SyncGetRepo calls the XRPC method "com.atproto.sync.getRepo".
 //
 // did: The DID of the repo.
-// since: The revision of the repo to catch up from.
+// since: The revision ('rev') of the repo to create a diff from.
 func SyncGetRepo(ctx context.Context, c *xrpc.Client, did string, since string) ([]byte, error) {
 	buf := new(bytes.Buffer)
 

api/atproto/synclistRepos.go

···
 
 // SyncListRepos_Repo is a "repo" in the com.atproto.sync.listRepos schema.
 type SyncListRepos_Repo struct {
-	Did  string `json:"did" cborgen:"did"`
+	Did string `json:"did" cborgen:"did"`
+	// head: Current repo commit CID
 	Head string `json:"head" cborgen:"head"`
 	Rev  string `json:"rev" cborgen:"rev"`
 }

api/atproto/syncnotifyOfUpdate.go

···
 
 // SyncNotifyOfUpdate_Input is the input argument to a com.atproto.sync.notifyOfUpdate call.
 type SyncNotifyOfUpdate_Input struct {
-	// hostname: Hostname of the service that is notifying of update.
+	// hostname: Hostname of the current service (usually a PDS) that is notifying of update.
 	Hostname string `json:"hostname" cborgen:"hostname"`
 }
 

api/atproto/syncrequestCrawl.go

···
 
 // SyncRequestCrawl_Input is the input argument to a com.atproto.sync.requestCrawl call.
 type SyncRequestCrawl_Input struct {
-	// hostname: Hostname of the service that is requesting to be crawled.
+	// hostname: Hostname of the current service (eg, PDS) that is requesting to be crawled.
 	Hostname string `json:"hostname" cborgen:"hostname"`
 }
 

api/atproto/syncsubscribeRepos.go

···
 )
 
 // SyncSubscribeRepos_Commit is a "commit" in the com.atproto.sync.subscribeRepos schema.
+//
+// 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.
 type SyncSubscribeRepos_Commit struct {
 	Blobs []util.LexLink `json:"blobs" cborgen:"blobs"`
-	// blocks: CAR file containing relevant blocks.
-	Blocks util.LexBytes                `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
+	// blocks: CAR file containing relevant blocks, as a diff since the previous repo state.
+	Blocks util.LexBytes `json:"blocks,omitempty" cborgen:"blocks,omitempty"`
+	// commit: Repo commit object CID.
 	Commit util.LexLink                 `json:"commit" cborgen:"commit"`
 	Ops    []*SyncSubscribeRepos_RepoOp `json:"ops" cborgen:"ops"`
-	Prev   *util.LexLink                `json:"prev" cborgen:"prev"`
-	Rebase bool                         `json:"rebase" cborgen:"rebase"`
-	Repo   string                       `json:"repo" cborgen:"repo"`
-	// rev: The rev of the emitted commit.
+	// prev: DEPRECATED -- unused. WARNING -- nullable and optional; stick with optional to ensure golang interoperability.
+	Prev *util.LexLink `json:"prev" cborgen:"prev"`
+	// rebase: DEPRECATED -- unused
+	Rebase bool `json:"rebase" cborgen:"rebase"`
+	// repo: The repo this event comes from.
+	Repo string `json:"repo" cborgen:"repo"`
+	// rev: The rev of the emitted commit. Note that this information is also in the commit object included in blocks, unless this is a tooBig event.
 	Rev string `json:"rev" cborgen:"rev"`
-	Seq int64  `json:"seq" cborgen:"seq"`
-	// since: The rev of the last emitted commit from this repo.
-	Since  *string `json:"since" cborgen:"since"`
-	Time   string  `json:"time" cborgen:"time"`
-	TooBig bool    `json:"tooBig" cborgen:"tooBig"`
+	// seq: The stream sequence number of this message.
+	Seq int64 `json:"seq" cborgen:"seq"`
+	// since: The rev of the last emitted commit from this repo (if any).
+	Since *string `json:"since" cborgen:"since"`
+	// time: Timestamp of when this message was originally broadcast.
+	Time string `json:"time" cborgen:"time"`
+	// tooBig: Indicates that this commit contained too many ops, or data size was too large. Consumers will need to make a separate request to get missing data.
+	TooBig bool `json:"tooBig" cborgen:"tooBig"`
 }
 
 // SyncSubscribeRepos_Handle is a "handle" in the com.atproto.sync.subscribeRepos schema.
+//
+// Represents an update of the account's handle, or transition to/from invalid state. NOTE: Will be deprecated in favor of #identity.
 type SyncSubscribeRepos_Handle struct {
 	Did    string `json:"did" cborgen:"did"`
 	Handle string `json:"handle" cborgen:"handle"`
 	Seq    int64  `json:"seq" cborgen:"seq"`
 	Time   string `json:"time" cborgen:"time"`
+}
+
+// SyncSubscribeRepos_Identity is a "identity" in the com.atproto.sync.subscribeRepos schema.
+//
+// Represents a change to an account's identity. Could be an updated handle, signing key, or pds hosting endpoint. Serves as a prod to all downstream services to refresh their identity cache.
+type SyncSubscribeRepos_Identity struct {
+	Did string `json:"did" cborgen:"did"`
+	Seq int64  `json:"seq" cborgen:"seq"`
 }
 
 // SyncSubscribeRepos_Info is a "info" in the com.atproto.sync.subscribeRepos schema.
···
 }
 
 // SyncSubscribeRepos_Migrate is a "migrate" in the com.atproto.sync.subscribeRepos schema.
+//
+// Represents an account moving from one PDS instance to another. NOTE: not implemented; account migration uses #identity instead
 type SyncSubscribeRepos_Migrate struct {
 	Did       string  `json:"did" cborgen:"did"`
 	MigrateTo *string `json:"migrateTo" cborgen:"migrateTo"`
···
 
 // SyncSubscribeRepos_RepoOp is a "repoOp" in the com.atproto.sync.subscribeRepos schema.
 //
-// A repo operation, ie a write of a single record. For creates and updates, CID is the record's CID as of this operation. For deletes, it's null.
+// A repo operation, ie a mutation of a single record.
 type SyncSubscribeRepos_RepoOp struct {
-	Action string        `json:"action" cborgen:"action"`
-	Cid    *util.LexLink `json:"cid" cborgen:"cid"`
-	Path   string        `json:"path" cborgen:"path"`
+	Action string `json:"action" cborgen:"action"`
+	// cid: For creates and updates, the new record CID. For deletions, null.
+	Cid  *util.LexLink `json:"cid" cborgen:"cid"`
+	Path string        `json:"path" cborgen:"path"`
 }
 
 // SyncSubscribeRepos_Tombstone is a "tombstone" in the com.atproto.sync.subscribeRepos schema.
+//
+// Indicates that an account has been deleted. NOTE: may be deprecated in favor of #identity or a future #account event
 type SyncSubscribeRepos_Tombstone struct {
 	Did  string `json:"did" cborgen:"did"`
 	Seq  int64  `json:"seq" cborgen:"seq"`

api/bsky/actordefs.go

···
 	LexiconTypeID string   `json:"$type,const=app.bsky.actor.defs#savedFeedsPref" cborgen:"$type,const=app.bsky.actor.defs#savedFeedsPref"`
 	Pinned        []string `json:"pinned" cborgen:"pinned"`
 	Saved         []string `json:"saved" cborgen:"saved"`
+	TimelineIndex *int64   `json:"timelineIndex,omitempty" cborgen:"timelineIndex,omitempty"`
 }
 
 // ActorDefs_ThreadViewPref is a "threadViewPref" in the app.bsky.actor.defs schema.
···
 }
 
 // ActorDefs_ViewerState is a "viewerState" in the app.bsky.actor.defs schema.
+//
+// Metadata about the requesting account's relationship with the subject account. Only has meaningful content for authed requests.
 type ActorDefs_ViewerState struct {
 	BlockedBy      *bool                    `json:"blockedBy,omitempty" cborgen:"blockedBy,omitempty"`
 	Blocking       *string                  `json:"blocking,omitempty" cborgen:"blocking,omitempty"`

api/bsky/actorgetProfile.go

···
 )
 
 // ActorGetProfile calls the XRPC method "app.bsky.actor.getProfile".
+//
+// actor: Handle or DID of account to fetch profile of.
 func ActorGetProfile(ctx context.Context, c *xrpc.Client, actor string) (*ActorDefs_ProfileViewDetailed, error) {
 	var out ActorDefs_ProfileViewDetailed
 

api/bsky/actorprofile.go

···
 } //
 // RECORDTYPE: ActorProfile
 type ActorProfile struct {
-	LexiconTypeID string               `json:"$type,const=app.bsky.actor.profile" cborgen:"$type,const=app.bsky.actor.profile"`
-	Avatar        *util.LexBlob        `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
-	Banner        *util.LexBlob        `json:"banner,omitempty" cborgen:"banner,omitempty"`
-	Description   *string              `json:"description,omitempty" cborgen:"description,omitempty"`
-	DisplayName   *string              `json:"displayName,omitempty" cborgen:"displayName,omitempty"`
-	Labels        *ActorProfile_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
+	LexiconTypeID string `json:"$type,const=app.bsky.actor.profile" cborgen:"$type,const=app.bsky.actor.profile"`
+	// avatar: Small image to be displayed next to posts from account. AKA, 'profile picture'
+	Avatar *util.LexBlob `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
+	// banner: Larger horizontal image to display behind profile view.
+	Banner *util.LexBlob `json:"banner,omitempty" cborgen:"banner,omitempty"`
+	// description: Free-form profile description text.
+	Description *string `json:"description,omitempty" cborgen:"description,omitempty"`
+	DisplayName *string `json:"displayName,omitempty" cborgen:"displayName,omitempty"`
+	// labels: Self-label values, specific to the Bluesky application, on the overall account.
+	Labels *ActorProfile_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
 }
 
+// Self-label values, specific to the Bluesky application, on the overall account.
 type ActorProfile_Labels struct {
 	LabelDefs_SelfLabels *comatprototypes.LabelDefs_SelfLabels
 }

api/bsky/embedexternal.go

···
 func init() {
 	util.RegisterType("app.bsky.embed.external#main", &EmbedExternal{})
 } // EmbedExternal is a "main" in the app.bsky.embed.external schema.
+// A representation of some externally linked content (eg, a URL and 'card'), embedded in a Bluesky record (eg, a post).
+//
 // RECORDTYPE: EmbedExternal
 type EmbedExternal struct {
 	LexiconTypeID string                  `json:"$type,const=app.bsky.embed.external" cborgen:"$type,const=app.bsky.embed.external"`

api/bsky/embedimages.go

···
 
 // EmbedImages_Image is a "image" in the app.bsky.embed.images schema.
 type EmbedImages_Image struct {
+	// alt: Alt text description of the image, for accessibility.
 	Alt         string                   `json:"alt" cborgen:"alt"`
 	AspectRatio *EmbedImages_AspectRatio `json:"aspectRatio,omitempty" cborgen:"aspectRatio,omitempty"`
 	Image       *util.LexBlob            `json:"image" cborgen:"image"`
···
 
 // EmbedImages_ViewImage is a "viewImage" in the app.bsky.embed.images schema.
 type EmbedImages_ViewImage struct {
+	// alt: Alt text description of the image, for accessibility.
 	Alt         string                   `json:"alt" cborgen:"alt"`
 	AspectRatio *EmbedImages_AspectRatio `json:"aspectRatio,omitempty" cborgen:"aspectRatio,omitempty"`
-	Fullsize    string                   `json:"fullsize" cborgen:"fullsize"`
-	Thumb       string                   `json:"thumb" cborgen:"thumb"`
+	// fullsize: Fully-qualified URL where a large version of the image can be fetched. May or may not be the exact original blob. For example, CDN location provided by the App View.
+	Fullsize string `json:"fullsize" cborgen:"fullsize"`
+	// thumb: Fully-qualified URL where a thumbnail of the image can be fetched. For example, CDN location provided by the App View.
+	Thumb string `json:"thumb" cborgen:"thumb"`
 }

api/bsky/embedrecord.go

···
 	IndexedAt     string                                `json:"indexedAt" cborgen:"indexedAt"`
 	Labels        []*comatprototypes.LabelDefs_Label    `json:"labels,omitempty" cborgen:"labels,omitempty"`
 	Uri           string                                `json:"uri" cborgen:"uri"`
-	Value         *util.LexiconTypeDecoder              `json:"value" cborgen:"value"`
+	// value: The record data itself.
+	Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"`
 }
 
 type EmbedRecord_ViewRecord_Embeds_Elem struct {

api/bsky/feeddefs.go

···
 }
 
 // FeedDefs_ViewerState is a "viewerState" in the app.bsky.feed.defs schema.
+//
+// Metadata about the requesting account's relationship with the subject content. Only has meaningful content for authed requests.
 type FeedDefs_ViewerState struct {
 	Like          *string `json:"like,omitempty" cborgen:"like,omitempty"`
 	ReplyDisabled *bool   `json:"replyDisabled,omitempty" cborgen:"replyDisabled,omitempty"`

api/bsky/feedgenerator.go

···
 } //
 // RECORDTYPE: FeedGenerator
 type FeedGenerator struct {
-	LexiconTypeID     string                `json:"$type,const=app.bsky.feed.generator" cborgen:"$type,const=app.bsky.feed.generator"`
-	Avatar            *util.LexBlob         `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
-	CreatedAt         string                `json:"createdAt" cborgen:"createdAt"`
-	Description       *string               `json:"description,omitempty" cborgen:"description,omitempty"`
-	DescriptionFacets []*RichtextFacet      `json:"descriptionFacets,omitempty" cborgen:"descriptionFacets,omitempty"`
-	Did               string                `json:"did" cborgen:"did"`
-	DisplayName       string                `json:"displayName" cborgen:"displayName"`
-	Labels            *FeedGenerator_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
+	LexiconTypeID     string           `json:"$type,const=app.bsky.feed.generator" cborgen:"$type,const=app.bsky.feed.generator"`
+	Avatar            *util.LexBlob    `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
+	CreatedAt         string           `json:"createdAt" cborgen:"createdAt"`
+	Description       *string          `json:"description,omitempty" cborgen:"description,omitempty"`
+	DescriptionFacets []*RichtextFacet `json:"descriptionFacets,omitempty" cborgen:"descriptionFacets,omitempty"`
+	Did               string           `json:"did" cborgen:"did"`
+	DisplayName       string           `json:"displayName" cborgen:"displayName"`
+	// labels: Self-label values
+	Labels *FeedGenerator_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
 }
 
+// Self-label values
 type FeedGenerator_Labels struct {
 	LabelDefs_SelfLabels *comatprototypes.LabelDefs_SelfLabels
 }

api/bsky/feedgetAuthorFeed.go

···
 }
 
 // FeedGetAuthorFeed calls the XRPC method "app.bsky.feed.getAuthorFeed".
+//
+// filter: Combinations of post/repost types to include in response.
 func FeedGetAuthorFeed(ctx context.Context, c *xrpc.Client, actor string, cursor string, filter string, limit int64) (*FeedGetAuthorFeed_Output, error) {
 	var out FeedGetAuthorFeed_Output
 

api/bsky/feedgetFeedGenerator.go

···
 
 // FeedGetFeedGenerator_Output is the output of a app.bsky.feed.getFeedGenerator call.
 type FeedGetFeedGenerator_Output struct {
-	IsOnline bool                    `json:"isOnline" cborgen:"isOnline"`
-	IsValid  bool                    `json:"isValid" cborgen:"isValid"`
-	View     *FeedDefs_GeneratorView `json:"view" cborgen:"view"`
+	// isOnline: Indicates whether the feed generator service has been online recently, or else seems to be inactive.
+	IsOnline bool `json:"isOnline" cborgen:"isOnline"`
+	// isValid: Indicates whether the feed generator service is compatible with the record declaration.
+	IsValid bool                    `json:"isValid" cborgen:"isValid"`
+	View    *FeedDefs_GeneratorView `json:"view" cborgen:"view"`
 }
 
 // FeedGetFeedGenerator calls the XRPC method "app.bsky.feed.getFeedGenerator".
+//
+// feed: AT-URI of the feed generator record.
 func FeedGetFeedGenerator(ctx context.Context, c *xrpc.Client, feed string) (*FeedGetFeedGenerator_Output, error) {
 	var out FeedGetFeedGenerator_Output
 

api/bsky/feedgetFeedSkeleton.go

···
 }
 
 // FeedGetFeedSkeleton calls the XRPC method "app.bsky.feed.getFeedSkeleton".
+//
+// feed: Reference to feed generator record describing the specific feed being requested.
 func FeedGetFeedSkeleton(ctx context.Context, c *xrpc.Client, cursor string, feed string, limit int64) (*FeedGetFeedSkeleton_Output, error) {
 	var out FeedGetFeedSkeleton_Output
 

api/bsky/feedgetLikes.go

···
 }
 
 // FeedGetLikes calls the XRPC method "app.bsky.feed.getLikes".
+//
+// cid: CID of the subject record (aka, specific version of record), to filter likes.
+// uri: AT-URI of the subject (eg, a post record).
 func FeedGetLikes(ctx context.Context, c *xrpc.Client, cid string, cursor string, limit int64, uri string) (*FeedGetLikes_Output, error) {
 	var out FeedGetLikes_Output
 

api/bsky/feedgetListFeed.go

···
 }
 
 // FeedGetListFeed calls the XRPC method "app.bsky.feed.getListFeed".
+//
+// list: Reference (AT-URI) to the list record.
 func FeedGetListFeed(ctx context.Context, c *xrpc.Client, cursor string, limit int64, list string) (*FeedGetListFeed_Output, error) {
 	var out FeedGetListFeed_Output
 

api/bsky/feedgetPostThread.go

···
 }
 
 // FeedGetPostThread calls the XRPC method "app.bsky.feed.getPostThread".
+//
+// depth: How many levels of reply depth should be included in response.
+// parentHeight: How many levels of parent (and grandparent, etc) post to include.
+// uri: Reference (AT-URI) to post record.
 func FeedGetPostThread(ctx context.Context, c *xrpc.Client, depth int64, parentHeight int64, uri string) (*FeedGetPostThread_Output, error) {
 	var out FeedGetPostThread_Output
 

api/bsky/feedgetPosts.go

···
 }
 
 // FeedGetPosts calls the XRPC method "app.bsky.feed.getPosts".
+//
+// uris: List of post AT-URIs to return hydrated views for.
 func FeedGetPosts(ctx context.Context, c *xrpc.Client, uris []string) (*FeedGetPosts_Output, error) {
 	var out FeedGetPosts_Output
 

api/bsky/feedgetRepostedBy.go

···
 }
 
 // FeedGetRepostedBy calls the XRPC method "app.bsky.feed.getRepostedBy".
+//
+// cid: If supplied, filters to reposts of specific version (by CID) of the post record.
+// uri: Reference (AT-URI) of post record
 func FeedGetRepostedBy(ctx context.Context, c *xrpc.Client, cid string, cursor string, limit int64, uri string) (*FeedGetRepostedBy_Output, error) {
 	var out FeedGetRepostedBy_Output
 

api/bsky/feedgetTimeline.go

···
 }
 
 // FeedGetTimeline calls the XRPC method "app.bsky.feed.getTimeline".
+//
+// algorithm: Variant 'algorithm' for timeline. Implementation-specific. NOTE: most feed flexibility has been moved to feed generator mechanism.
 func FeedGetTimeline(ctx context.Context, c *xrpc.Client, algorithm string, cursor string, limit int64) (*FeedGetTimeline_Output, error) {
 	var out FeedGetTimeline_Output
 

api/bsky/feedpost.go

···
 } //
 // RECORDTYPE: FeedPost
 type FeedPost struct {
-	LexiconTypeID string          `json:"$type,const=app.bsky.feed.post" cborgen:"$type,const=app.bsky.feed.post"`
-	CreatedAt     string          `json:"createdAt" cborgen:"createdAt"`
-	Embed         *FeedPost_Embed `json:"embed,omitempty" cborgen:"embed,omitempty"`
-	// entities: Deprecated: replaced by app.bsky.richtext.facet.
+	LexiconTypeID string `json:"$type,const=app.bsky.feed.post" cborgen:"$type,const=app.bsky.feed.post"`
+	// createdAt: Client-declared timestamp when this post was originally created.
+	CreatedAt string          `json:"createdAt" cborgen:"createdAt"`
+	Embed     *FeedPost_Embed `json:"embed,omitempty" cborgen:"embed,omitempty"`
+	// entities: DEPRECATED: replaced by app.bsky.richtext.facet.
 	Entities []*FeedPost_Entity `json:"entities,omitempty" cborgen:"entities,omitempty"`
-	Facets   []*RichtextFacet   `json:"facets,omitempty" cborgen:"facets,omitempty"`
-	Labels   *FeedPost_Labels   `json:"labels,omitempty" cborgen:"labels,omitempty"`
-	Langs    []string           `json:"langs,omitempty" cborgen:"langs,omitempty"`
-	Reply    *FeedPost_ReplyRef `json:"reply,omitempty" cborgen:"reply,omitempty"`
-	// tags: Additional non-inline tags describing this post.
+	// facets: Annotations of text (mentions, URLs, hashtags, etc)
+	Facets []*RichtextFacet `json:"facets,omitempty" cborgen:"facets,omitempty"`
+	// labels: Self-label values for this post. Effectively content warnings.
+	Labels *FeedPost_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
+	// langs: Indicates human language of post primary text content.
+	Langs []string           `json:"langs,omitempty" cborgen:"langs,omitempty"`
+	Reply *FeedPost_ReplyRef `json:"reply,omitempty" cborgen:"reply,omitempty"`
+	// tags: Additional hashtags, in addition to any included in post text and facets.
 	Tags []string `json:"tags,omitempty" cborgen:"tags,omitempty"`
-	Text string   `json:"text" cborgen:"text"`
+	// text: The primary post content. May be an empty string, if there are embeds.
+	Text string `json:"text" cborgen:"text"`
 }
 
 type FeedPost_Embed struct {
···
 	Value string `json:"value" cborgen:"value"`
 }
 
+// Self-label values for this post. Effectively content warnings.
 type FeedPost_Labels struct {
 	LabelDefs_SelfLabels *comatprototypes.LabelDefs_SelfLabels
 }

api/bsky/feedthreadgate.go

···
 	LexiconTypeID string                       `json:"$type,const=app.bsky.feed.threadgate" cborgen:"$type,const=app.bsky.feed.threadgate"`
 	Allow         []*FeedThreadgate_Allow_Elem `json:"allow,omitempty" cborgen:"allow,omitempty"`
 	CreatedAt     string                       `json:"createdAt" cborgen:"createdAt"`
-	Post          string                       `json:"post" cborgen:"post"`
+	// post: Reference (AT-URI) to the post record.
+	Post string `json:"post" cborgen:"post"`
 }
 
 type FeedThreadgate_Allow_Elem struct {

api/bsky/graphblock.go

···
 type GraphBlock struct {
 	LexiconTypeID string `json:"$type,const=app.bsky.graph.block" cborgen:"$type,const=app.bsky.graph.block"`
 	CreatedAt     string `json:"createdAt" cborgen:"createdAt"`
-	Subject       string `json:"subject" cborgen:"subject"`
+	// subject: DID of the account to be blocked.
+	Subject string `json:"subject" cborgen:"subject"`
 }

api/bsky/graphgetList.go

···
 }
 
 // GraphGetList calls the XRPC method "app.bsky.graph.getList".
+//
+// list: Reference (AT-URI) of the list record to hydrate.
 func GraphGetList(ctx context.Context, c *xrpc.Client, cursor string, limit int64, list string) (*GraphGetList_Output, error) {
 	var out GraphGetList_Output
 

api/bsky/graphgetLists.go

···
 }
 
 // GraphGetLists calls the XRPC method "app.bsky.graph.getLists".
+//
+// actor: The account (actor) to enumerate lists from.
 func GraphGetLists(ctx context.Context, c *xrpc.Client, actor string, cursor string, limit int64) (*GraphGetLists_Output, error) {
 	var out GraphGetLists_Output
 

api/bsky/graphgetRelationships.go

···
 }
 
 // GraphGetRelationships calls the XRPC method "app.bsky.graph.getRelationships".
+//
+// actor: Primary account requesting relationships for.
+// others: List of 'other' accounts to be related back to the primary.
 func GraphGetRelationships(ctx context.Context, c *xrpc.Client, actor string, others []string) (*GraphGetRelationships_Output, error) {
 	var out GraphGetRelationships_Output
 

api/bsky/graphlist.go

···
 	Description       *string           `json:"description,omitempty" cborgen:"description,omitempty"`
 	DescriptionFacets []*RichtextFacet  `json:"descriptionFacets,omitempty" cborgen:"descriptionFacets,omitempty"`
 	Labels            *GraphList_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"`
-	Name              string            `json:"name" cborgen:"name"`
-	Purpose           *string           `json:"purpose" cborgen:"purpose"`
+	// name: Display name for list; can not be empty.
+	Name string `json:"name" cborgen:"name"`
+	// purpose: Defines the purpose of the list (aka, moderation-oriented or curration-oriented)
+	Purpose *string `json:"purpose" cborgen:"purpose"`
 }
 
 type GraphList_Labels struct {

api/bsky/graphlistblock.go

···
 type GraphListblock struct {
 	LexiconTypeID string `json:"$type,const=app.bsky.graph.listblock" cborgen:"$type,const=app.bsky.graph.listblock"`
 	CreatedAt     string `json:"createdAt" cborgen:"createdAt"`
-	Subject       string `json:"subject" cborgen:"subject"`
+	// subject: Reference (AT-URI) to the mod list record.
+	Subject string `json:"subject" cborgen:"subject"`
 }

api/bsky/graphlistitem.go

···
 type GraphListitem struct {
 	LexiconTypeID string `json:"$type,const=app.bsky.graph.listitem" cborgen:"$type,const=app.bsky.graph.listitem"`
 	CreatedAt     string `json:"createdAt" cborgen:"createdAt"`
-	List          string `json:"list" cborgen:"list"`
-	Subject       string `json:"subject" cborgen:"subject"`
+	// list: Reference (AT-URI) to the list record (app.bsky.graph.list).
+	List string `json:"list" cborgen:"list"`
+	// subject: The account which is included on the list.
+	Subject string `json:"subject" cborgen:"subject"`
 }

api/bsky/richtextfacet.go

···
 )
 
 // RichtextFacet is a "main" in the app.bsky.richtext.facet schema.
+//
+// Annotation of a sub-string within rich text.
 type RichtextFacet struct {
 	Features []*RichtextFacet_Features_Elem `json:"features" cborgen:"features"`
 	Index    *RichtextFacet_ByteSlice       `json:"index" cborgen:"index"`
···
 
 // RichtextFacet_ByteSlice is a "byteSlice" in the app.bsky.richtext.facet schema.
 //
-// A text segment. Start is inclusive, end is exclusive. Indices are for utf8-encoded strings.
+// Specifies the sub-string range a facet feature applies to. Start index is inclusive, end index is exclusive. Indices are zero-indexed, counting bytes of the UTF-8 encoded text. NOTE: some languages, like Javascript, use UTF-16 or Unicode codepoints for string slice indexing; in these languages, convert to byte arrays before working with facets.
 type RichtextFacet_ByteSlice struct {
 	ByteEnd   int64 `json:"byteEnd" cborgen:"byteEnd"`
 	ByteStart int64 `json:"byteStart" cborgen:"byteStart"`
···
 
 // RichtextFacet_Link is a "link" in the app.bsky.richtext.facet schema.
 //
-// A facet feature for links.
+// Facet feature for a URL. The text URL may have been simplified or truncated, but the facet reference should be a complete URL.
 //
 // RECORDTYPE: RichtextFacet_Link
 type RichtextFacet_Link struct {
···
 
 // RichtextFacet_Mention is a "mention" in the app.bsky.richtext.facet schema.
 //
-// A facet feature for actor mentions.
+// Facet feature for mention of another account. The text is usually a handle, including a '@' prefix, but the facet reference is a DID.
 //
 // RECORDTYPE: RichtextFacet_Mention
 type RichtextFacet_Mention struct {
···
 
 // RichtextFacet_Tag is a "tag" in the app.bsky.richtext.facet schema.
 //
-// A hashtag.
+// Facet feature for a hashtag. The text usually includes a '#' prefix, but the facet reference should not (except in the case of 'double hash tags').
 //
 // RECORDTYPE: RichtextFacet_Tag
 type RichtextFacet_Tag struct {

automod/engine/persisthelpers.go

···
 	// NOTE: this is running in an inner loop (if there are multiple reports), which is a bit inefficient, but seems acceptable
 
 	// AdminQueryModerationEvents(ctx context.Context, c *xrpc.Client, createdBy string, cursor string, inc ludeAllUserRecords bool, limit int64, sortDirection string, subject string, types []string)
-	resp, err := comatproto.AdminQueryModerationEvents(ctx, xrpcc, xrpcc.Auth.Did, "", false, 5, "", did.String(), []string{"com.atproto.admin.defs#modEventReport"})
+	resp, err := comatproto.AdminQueryModerationEvents(
+		ctx,
+		xrpcc,
+		xrpcc.Auth.Did,
+		"",
+		false,
+		5,
+		"",
+		did.String(),
+		[]string{"com.atproto.admin.defs#modEventReport"},
+	)
 	if err != nil {
 		return false, err
 	}

bgs/bgs.go

···
 		}
 
 		return nil
+	case env.Identity != nil:
+		log.Infow("bgs got identity event", "did", env.Identity.Did)
+		// Flush any cached DID documents for this user
+		bgs.didr.FlushCacheFor(env.Identity.Did)
+
+		// Refetch the DID doc and update our cached keys and handle etc.
+		_, err := bgs.createExternalUser(ctx, env.Identity.Did)
+		if err != nil {
+			return err
+		}
+
+		// Broadcast the identity event to all consumers
+		err = bgs.events.AddEvent(ctx, &events.XRPCStreamEvent{
+			Identity: &comatproto.SyncSubscribeRepos_Identity{
+				Did: env.Identity.Did,
+				Seq: env.Identity.Seq,
+			},
+		})
+		if err != nil {
+			log.Errorw("failed to broadcast Identity event", "error", err, "did", env.Identity.Did)
+			return fmt.Errorf("failed to broadcast Identity event: %w", err)
+		}
+
+		return nil
 	case env.RepoMigrate != nil:
 		if _, err := bgs.createExternalUser(ctx, env.RepoMigrate.Did); err != nil {
 			return err

events/consumer.go

···
 type RepoStreamCallbacks struct {
 	RepoCommit    func(evt *comatproto.SyncSubscribeRepos_Commit) error
 	RepoHandle    func(evt *comatproto.SyncSubscribeRepos_Handle) error
+	Identity      func(evt *comatproto.SyncSubscribeRepos_Identity) error
 	RepoInfo      func(evt *comatproto.SyncSubscribeRepos_Info) error
 	RepoMigrate   func(evt *comatproto.SyncSubscribeRepos_Migrate) error
 	RepoTombstone func(evt *comatproto.SyncSubscribeRepos_Tombstone) error
···
 		return rsc.RepoInfo(xev.RepoInfo)
 	case xev.RepoMigrate != nil && rsc.RepoMigrate != nil:
 		return rsc.RepoMigrate(xev.RepoMigrate)
+	case xev.Identity != nil && rsc.Identity != nil:
+		return rsc.Identity(xev.Identity)
 	case xev.RepoTombstone != nil && rsc.RepoTombstone != nil:
 		return rsc.RepoTombstone(xev.RepoTombstone)
 	case xev.LabelLabels != nil && rsc.LabelLabels != nil:
···
 
 				if err := sched.AddWork(ctx, evt.Did, &XRPCStreamEvent{
 					RepoHandle: &evt,
+				}); err != nil {
+					return err
+				}
+			case "#identity":
+				var evt comatproto.SyncSubscribeRepos_Identity
+				if err := evt.UnmarshalCBOR(r); err != nil {
+					return err
+				}
+
+				if evt.Seq < lastSeq {
+					log.Errorf("Got events out of order from stream (seq = %d, prev = %d)", evt.Seq, lastSeq)
+				}
+				lastSeq = evt.Seq
+
+				if err := sched.AddWork(ctx, evt.Did, &XRPCStreamEvent{
+					Identity: &evt,
 				}); err != nil {
 					return err
 				}

events/events.go

···
 	Error         *ErrorFrame
 	RepoCommit    *comatproto.SyncSubscribeRepos_Commit
 	RepoHandle    *comatproto.SyncSubscribeRepos_Handle
+	Identity      *comatproto.SyncSubscribeRepos_Identity
 	RepoInfo      *comatproto.SyncSubscribeRepos_Info
 	RepoMigrate   *comatproto.SyncSubscribeRepos_Migrate
 	RepoTombstone *comatproto.SyncSubscribeRepos_Tombstone
···
 		return evt.RepoMigrate.Seq
 	case evt.RepoTombstone != nil:
 		return evt.RepoTombstone.Seq
+	case evt.Identity != nil:
+		return evt.Identity.Seq
 	case evt.RepoInfo != nil:
 		return -1
 	case evt.Error != nil:

events/persist.go

···
 		e.RepoCommit.Seq = mp.seq
 	case e.RepoHandle != nil:
 		e.RepoHandle.Seq = mp.seq
+	case e.Identity != nil:
+		e.Identity.Seq = mp.seq
 	case e.RepoMigrate != nil:
 		e.RepoMigrate.Seq = mp.seq
 	case e.RepoTombstone != nil:

events/yolopersist.go

···
 		e.RepoCommit.Seq = yp.seq
 	case e.RepoHandle != nil:
 		e.RepoHandle.Seq = yp.seq
+	case e.Identity != nil:
+		e.Identity.Seq = yp.seq
 	case e.RepoMigrate != nil:
 		e.RepoMigrate.Seq = yp.seq
 	case e.RepoTombstone != nil:

gen/main.go

···
 		atproto.RepoStrongRef{},
 		atproto.SyncSubscribeRepos_Commit{},
 		atproto.SyncSubscribeRepos_Handle{},
+		atproto.SyncSubscribeRepos_Identity{},
 		atproto.SyncSubscribeRepos_Info{},
 		atproto.SyncSubscribeRepos_Migrate{},
 		atproto.SyncSubscribeRepos_RepoOp{},

lex/gen.go

···
 		inpvar = "input"
 		inpenc = s.Input.Encoding
 		switch s.Input.Encoding {
-		case EncodingCBOR, EncodingANY:
+		case EncodingCBOR, EncodingCAR, EncodingANY:
 			params = fmt.Sprintf("%s, input io.Reader", params)
 		case EncodingJSON:
 			params = fmt.Sprintf("%s, input *%s_Input", params, fname)

sonar/sonar.go

···
 		lastEvtProcessedAtGauge.WithLabelValues(s.SocketURL).Set(float64(now.UnixNano()))
 		lastEvtCreatedEvtProcessedGapGauge.WithLabelValues(s.SocketURL).Set(float64(now.Sub(t).Seconds()))
 		lastSeqGauge.WithLabelValues(s.SocketURL).Set(float64(xe.RepoHandle.Seq))
+	case xe.Identity != nil:
+		eventsProcessedCounter.WithLabelValues("identity", s.SocketURL).Inc()
+		now := time.Now()
+		s.ProgMux.Lock()
+		s.Progress.LastSeq = xe.RepoHandle.Seq
+		s.Progress.LastSeqProcessedAt = now
+		s.ProgMux.Unlock()
 	case xe.RepoInfo != nil:
 		eventsProcessedCounter.WithLabelValues("repo_info", s.SocketURL).Inc()
 	case xe.RepoMigrate != nil: