add tooling for invite control

api/atproto/admindefs.go

···
 //
 // RECORDTYPE: AdminDefs_RepoView
 type AdminDefs_RepoView struct {
-	LexiconTypeID  string                     `json:"$type,const=com.atproto.admin.defs" cborgen:"$type,const=com.atproto.admin.defs"`
-	Did            string                     `json:"did" cborgen:"did"`
-	Email          *string                    `json:"email,omitempty" cborgen:"email,omitempty"`
-	Handle         string                     `json:"handle" cborgen:"handle"`
-	IndexedAt      string                     `json:"indexedAt" cborgen:"indexedAt"`
-	InvitedBy      *ServerDefs_InviteCode     `json:"invitedBy,omitempty" cborgen:"invitedBy,omitempty"`
-	Moderation     *AdminDefs_Moderation      `json:"moderation" cborgen:"moderation"`
-	RelatedRecords []*util.LexiconTypeDecoder `json:"relatedRecords" cborgen:"relatedRecords"`
+	LexiconTypeID   string                     `json:"$type,const=com.atproto.admin.defs" cborgen:"$type,const=com.atproto.admin.defs"`
+	Did             string                     `json:"did" cborgen:"did"`
+	Email           *string                    `json:"email,omitempty" cborgen:"email,omitempty"`
+	Handle          string                     `json:"handle" cborgen:"handle"`
+	IndexedAt       string                     `json:"indexedAt" cborgen:"indexedAt"`
+	InvitedBy       *ServerDefs_InviteCode     `json:"invitedBy,omitempty" cborgen:"invitedBy,omitempty"`
+	InvitesDisabled *bool                      `json:"invitesDisabled,omitempty" cborgen:"invitesDisabled,omitempty"`
+	Moderation      *AdminDefs_Moderation      `json:"moderation" cborgen:"moderation"`
+	RelatedRecords  []*util.LexiconTypeDecoder `json:"relatedRecords" cborgen:"relatedRecords"`
 }
 
 // AdminDefs_RepoViewDetail is a "repoViewDetail" in the com.atproto.admin.defs schema.
 type AdminDefs_RepoViewDetail struct {
-	Did            string                      `json:"did" cborgen:"did"`
-	Email          *string                     `json:"email,omitempty" cborgen:"email,omitempty"`
-	Handle         string                      `json:"handle" cborgen:"handle"`
-	IndexedAt      string                      `json:"indexedAt" cborgen:"indexedAt"`
-	InvitedBy      *ServerDefs_InviteCode      `json:"invitedBy,omitempty" cborgen:"invitedBy,omitempty"`
-	Invites        []*ServerDefs_InviteCode    `json:"invites,omitempty" cborgen:"invites,omitempty"`
-	Labels         []*LabelDefs_Label          `json:"labels,omitempty" cborgen:"labels,omitempty"`
-	Moderation     *AdminDefs_ModerationDetail `json:"moderation" cborgen:"moderation"`
-	RelatedRecords []*util.LexiconTypeDecoder  `json:"relatedRecords" cborgen:"relatedRecords"`
+	Did             string                      `json:"did" cborgen:"did"`
+	Email           *string                     `json:"email,omitempty" cborgen:"email,omitempty"`
+	Handle          string                      `json:"handle" cborgen:"handle"`
+	IndexedAt       string                      `json:"indexedAt" cborgen:"indexedAt"`
+	InvitedBy       *ServerDefs_InviteCode      `json:"invitedBy,omitempty" cborgen:"invitedBy,omitempty"`
+	Invites         []*ServerDefs_InviteCode    `json:"invites,omitempty" cborgen:"invites,omitempty"`
+	InvitesDisabled *bool                       `json:"invitesDisabled,omitempty" cborgen:"invitesDisabled,omitempty"`
+	Labels          []*LabelDefs_Label          `json:"labels,omitempty" cborgen:"labels,omitempty"`
+	Moderation      *AdminDefs_ModerationDetail `json:"moderation" cborgen:"moderation"`
+	RelatedRecords  []*util.LexiconTypeDecoder  `json:"relatedRecords" cborgen:"relatedRecords"`
 }
 
 // AdminDefs_ReportView is a "reportView" in the com.atproto.admin.defs schema.

api/atproto/admindisableAccountInvites.go

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

api/atproto/adminenableAccountInvites.go

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

api/atproto/admingetModerationReports.go

···
 }
 
 // AdminGetModerationReports calls the XRPC method "com.atproto.admin.getModerationReports".
-func AdminGetModerationReports(ctx context.Context, c *xrpc.Client, cursor string, limit int64, resolved bool, subject string) (*AdminGetModerationReports_Output, error) {
+func AdminGetModerationReports(ctx context.Context, c *xrpc.Client, actionType string, cursor string, limit int64, resolved bool, subject string) (*AdminGetModerationReports_Output, error) {
 	var out AdminGetModerationReports_Output
 
 	params := map[string]interface{}{
-		"cursor":   cursor,
-		"limit":    limit,
-		"resolved": resolved,
-		"subject":  subject,
+		"actionType": actionType,
+		"cursor":     cursor,
+		"limit":      limit,
+		"resolved":   resolved,
+		"subject":    subject,
 	}
 	if err := c.Do(ctx, xrpc.Query, "", "com.atproto.admin.getModerationReports", params, nil, &out); err != nil {
 		return nil, err

api/atproto/reporebaseRepo.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package atproto
+
+// schema: com.atproto.repo.rebaseRepo
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// RepoRebaseRepo_Input is the input argument to a com.atproto.repo.rebaseRepo call.
+type RepoRebaseRepo_Input struct {
+	// repo: The handle or DID of the repo.
+	Repo string `json:"repo" cborgen:"repo"`
+	// swapCommit: Compare and swap with the previous commit by cid.
+	SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"`
+}
+
+// RepoRebaseRepo calls the XRPC method "com.atproto.repo.rebaseRepo".
+func RepoRebaseRepo(ctx context.Context, c *xrpc.Client, input *RepoRebaseRepo_Input) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.repo.rebaseRepo", nil, input, nil); err != nil {
+		return err
+	}
+
+	return 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" cborgen:"email"`
 	Handle      string  `json:"handle" cborgen:"handle"`
 	InviteCode  *string `json:"inviteCode,omitempty" cborgen:"inviteCode,omitempty"`

api/bsky/actordefs.go

···
 // schema: app.bsky.actor.defs
 
 import (
+	"encoding/json"
+	"fmt"
+
 	comatprototypes "github.com/bluesky-social/indigo/api/atproto"
+	"github.com/bluesky-social/indigo/lex/util"
 )
 
+// ActorDefs_AdultContentPref is a "adultContentPref" in the app.bsky.actor.defs schema.
+//
+// RECORDTYPE: ActorDefs_AdultContentPref
+type ActorDefs_AdultContentPref struct {
+	LexiconTypeID string `json:"$type,const=app.bsky.actor.defs" cborgen:"$type,const=app.bsky.actor.defs"`
+	Enabled       bool   `json:"enabled" cborgen:"enabled"`
+}
+
+// ActorDefs_ContentLabelPref is a "contentLabelPref" in the app.bsky.actor.defs schema.
+//
+// RECORDTYPE: ActorDefs_ContentLabelPref
+type ActorDefs_ContentLabelPref struct {
+	LexiconTypeID string `json:"$type,const=app.bsky.actor.defs" cborgen:"$type,const=app.bsky.actor.defs"`
+	Label         string `json:"label" cborgen:"label"`
+	Visibility    string `json:"visibility" cborgen:"visibility"`
+}
+
+type ActorDefs_Preferences_Elem struct {
+	ActorDefs_AdultContentPref *ActorDefs_AdultContentPref
+	ActorDefs_ContentLabelPref *ActorDefs_ContentLabelPref
+}
+
+func (t *ActorDefs_Preferences_Elem) MarshalJSON() ([]byte, error) {
+	if t.ActorDefs_AdultContentPref != nil {
+		t.ActorDefs_AdultContentPref.LexiconTypeID = "app.bsky.actor.defs#adultContentPref"
+		return json.Marshal(t.ActorDefs_AdultContentPref)
+	}
+	if t.ActorDefs_ContentLabelPref != nil {
+		t.ActorDefs_ContentLabelPref.LexiconTypeID = "app.bsky.actor.defs#contentLabelPref"
+		return json.Marshal(t.ActorDefs_ContentLabelPref)
+	}
+	return nil, fmt.Errorf("cannot marshal empty enum")
+}
+func (t *ActorDefs_Preferences_Elem) UnmarshalJSON(b []byte) error {
+	typ, err := util.TypeExtract(b)
+	if err != nil {
+		return err
+	}
+
+	switch typ {
+	case "app.bsky.actor.defs#adultContentPref":
+		t.ActorDefs_AdultContentPref = new(ActorDefs_AdultContentPref)
+		return json.Unmarshal(b, t.ActorDefs_AdultContentPref)
+	case "app.bsky.actor.defs#contentLabelPref":
+		t.ActorDefs_ContentLabelPref = new(ActorDefs_ContentLabelPref)
+		return json.Unmarshal(b, t.ActorDefs_ContentLabelPref)
+
+	default:
+		return nil
+	}
+}
+
 // ActorDefs_ProfileView is a "profileView" in the app.bsky.actor.defs schema.
 type ActorDefs_ProfileView struct {
 	Avatar      *string                            `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
···
 
 // ActorDefs_ViewerState is a "viewerState" in the app.bsky.actor.defs schema.
 type ActorDefs_ViewerState struct {
-	FollowedBy *string `json:"followedBy,omitempty" cborgen:"followedBy,omitempty"`
-	Following  *string `json:"following,omitempty" cborgen:"following,omitempty"`
-	Muted      *bool   `json:"muted,omitempty" cborgen:"muted,omitempty"`
+	BlockedBy   *bool                    `json:"blockedBy,omitempty" cborgen:"blockedBy,omitempty"`
+	Blocking    *string                  `json:"blocking,omitempty" cborgen:"blocking,omitempty"`
+	FollowedBy  *string                  `json:"followedBy,omitempty" cborgen:"followedBy,omitempty"`
+	Following   *string                  `json:"following,omitempty" cborgen:"following,omitempty"`
+	Muted       *bool                    `json:"muted,omitempty" cborgen:"muted,omitempty"`
+	MutedByList *GraphDefs_ListViewBasic `json:"mutedByList,omitempty" cborgen:"mutedByList,omitempty"`
 }

api/bsky/cbor_gen.go

···
 
 	return nil
 }
+func (t *GraphBlock) MarshalCBOR(w io.Writer) error {
+	if t == nil {
+		_, err := w.Write(cbg.CborNull)
+		return err
+	}
+
+	cw := cbg.NewCborWriter(w)
+
+	if _, err := cw.Write([]byte{163}); err != nil {
+		return err
+	}
+
+	// t.LexiconTypeID (string) (string)
+	if len("$type") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"$type\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("$type"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("$type")); err != nil {
+		return err
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("app.bsky.graph.block"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("app.bsky.graph.block")); err != nil {
+		return err
+	}
+
+	// t.Subject (string) (string)
+	if len("subject") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"subject\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("subject"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("subject")); err != nil {
+		return err
+	}
+
+	if len(t.Subject) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.Subject was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Subject))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.Subject)); err != nil {
+		return err
+	}
+
+	// t.CreatedAt (string) (string)
+	if len("createdAt") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"createdAt\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("createdAt"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("createdAt")); err != nil {
+		return err
+	}
+
+	if len(t.CreatedAt) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.CreatedAt was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.CreatedAt))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.CreatedAt)); err != nil {
+		return err
+	}
+	return nil
+}
+
+func (t *GraphBlock) UnmarshalCBOR(r io.Reader) (err error) {
+	*t = GraphBlock{}
+
+	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("GraphBlock: 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.LexiconTypeID (string) (string)
+		case "$type":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.LexiconTypeID = string(sval)
+			}
+			// t.Subject (string) (string)
+		case "subject":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.Subject = string(sval)
+			}
+			// t.CreatedAt (string) (string)
+		case "createdAt":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.CreatedAt = string(sval)
+			}
+
+		default:
+			// Field doesn't exist on this type, so ignore it
+			cbg.ScanForLinks(r, func(cid.Cid) {})
+		}
+	}
+
+	return nil
+}
+func (t *GraphList) MarshalCBOR(w io.Writer) error {
+	if t == nil {
+		_, err := w.Write(cbg.CborNull)
+		return err
+	}
+
+	cw := cbg.NewCborWriter(w)
+	fieldCount := 7
+
+	if t.Avatar == nil {
+		fieldCount--
+	}
+
+	if t.Description == nil {
+		fieldCount--
+	}
+
+	if t.DescriptionFacets == nil {
+		fieldCount--
+	}
+
+	if _, err := cw.Write(cbg.CborEncodeMajorType(cbg.MajMap, uint64(fieldCount))); err != nil {
+		return err
+	}
+
+	// t.Name (string) (string)
+	if len("name") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"name\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("name"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("name")); err != nil {
+		return err
+	}
+
+	if len(t.Name) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.Name was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Name))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.Name)); err != nil {
+		return err
+	}
+
+	// t.LexiconTypeID (string) (string)
+	if len("$type") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"$type\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("$type"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("$type")); err != nil {
+		return err
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("app.bsky.graph.list"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("app.bsky.graph.list")); err != nil {
+		return err
+	}
+
+	// t.Avatar (util.LexBlob) (struct)
+	if t.Avatar != nil {
+
+		if len("avatar") > cbg.MaxLength {
+			return xerrors.Errorf("Value in field \"avatar\" was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("avatar"))); err != nil {
+			return err
+		}
+		if _, err := io.WriteString(w, string("avatar")); err != nil {
+			return err
+		}
+
+		if err := t.Avatar.MarshalCBOR(cw); err != nil {
+			return err
+		}
+	}
+
+	// t.Purpose (string) (string)
+	if len("purpose") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"purpose\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("purpose"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("purpose")); err != nil {
+		return err
+	}
+
+	if t.Purpose == nil {
+		if _, err := cw.Write(cbg.CborNull); err != nil {
+			return err
+		}
+	} else {
+		if len(*t.Purpose) > cbg.MaxLength {
+			return xerrors.Errorf("Value in field t.Purpose was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*t.Purpose))); err != nil {
+			return err
+		}
+		if _, err := io.WriteString(w, string(*t.Purpose)); err != nil {
+			return err
+		}
+	}
+
+	// t.CreatedAt (string) (string)
+	if len("createdAt") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"createdAt\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("createdAt"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("createdAt")); err != nil {
+		return err
+	}
+
+	if len(t.CreatedAt) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.CreatedAt was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.CreatedAt))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.CreatedAt)); err != nil {
+		return err
+	}
+
+	// t.Description (string) (string)
+	if t.Description != nil {
+
+		if len("description") > cbg.MaxLength {
+			return xerrors.Errorf("Value in field \"description\" was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("description"))); err != nil {
+			return err
+		}
+		if _, err := io.WriteString(w, string("description")); err != nil {
+			return err
+		}
+
+		if t.Description == nil {
+			if _, err := cw.Write(cbg.CborNull); err != nil {
+				return err
+			}
+		} else {
+			if len(*t.Description) > cbg.MaxLength {
+				return xerrors.Errorf("Value in field t.Description was too long")
+			}
+
+			if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*t.Description))); err != nil {
+				return err
+			}
+			if _, err := io.WriteString(w, string(*t.Description)); err != nil {
+				return err
+			}
+		}
+	}
+
+	// t.DescriptionFacets ([]*bsky.RichtextFacet) (slice)
+	if t.DescriptionFacets != nil {
+
+		if len("descriptionFacets") > cbg.MaxLength {
+			return xerrors.Errorf("Value in field \"descriptionFacets\" was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("descriptionFacets"))); err != nil {
+			return err
+		}
+		if _, err := io.WriteString(w, string("descriptionFacets")); err != nil {
+			return err
+		}
+
+		if len(t.DescriptionFacets) > cbg.MaxLength {
+			return xerrors.Errorf("Slice value in field t.DescriptionFacets was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajArray, uint64(len(t.DescriptionFacets))); err != nil {
+			return err
+		}
+		for _, v := range t.DescriptionFacets {
+			if err := v.MarshalCBOR(cw); err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
+func (t *GraphList) UnmarshalCBOR(r io.Reader) (err error) {
+	*t = GraphList{}
+
+	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("GraphList: 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.Name (string) (string)
+		case "name":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.Name = string(sval)
+			}
+			// t.LexiconTypeID (string) (string)
+		case "$type":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.LexiconTypeID = string(sval)
+			}
+			// t.Avatar (util.LexBlob) (struct)
+		case "avatar":
+
+			{
+
+				b, err := cr.ReadByte()
+				if err != nil {
+					return err
+				}
+				if b != cbg.CborNull[0] {
+					if err := cr.UnreadByte(); err != nil {
+						return err
+					}
+					t.Avatar = new(util.LexBlob)
+					if err := t.Avatar.UnmarshalCBOR(cr); err != nil {
+						return xerrors.Errorf("unmarshaling t.Avatar pointer: %w", err)
+					}
+				}
+
+			}
+			// t.Purpose (string) (string)
+		case "purpose":
+
+			{
+				b, err := cr.ReadByte()
+				if err != nil {
+					return err
+				}
+				if b != cbg.CborNull[0] {
+					if err := cr.UnreadByte(); err != nil {
+						return err
+					}
+
+					sval, err := cbg.ReadString(cr)
+					if err != nil {
+						return err
+					}
+
+					t.Purpose = (*string)(&sval)
+				}
+			}
+			// t.CreatedAt (string) (string)
+		case "createdAt":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.CreatedAt = string(sval)
+			}
+			// t.Description (string) (string)
+		case "description":
+
+			{
+				b, err := cr.ReadByte()
+				if err != nil {
+					return err
+				}
+				if b != cbg.CborNull[0] {
+					if err := cr.UnreadByte(); err != nil {
+						return err
+					}
+
+					sval, err := cbg.ReadString(cr)
+					if err != nil {
+						return err
+					}
+
+					t.Description = (*string)(&sval)
+				}
+			}
+			// t.DescriptionFacets ([]*bsky.RichtextFacet) (slice)
+		case "descriptionFacets":
+
+			maj, extra, err = cr.ReadHeader()
+			if err != nil {
+				return err
+			}
+
+			if extra > cbg.MaxLength {
+				return fmt.Errorf("t.DescriptionFacets: array too large (%d)", extra)
+			}
+
+			if maj != cbg.MajArray {
+				return fmt.Errorf("expected cbor array")
+			}
+
+			if extra > 0 {
+				t.DescriptionFacets = make([]*RichtextFacet, extra)
+			}
+
+			for i := 0; i < int(extra); i++ {
+
+				var v RichtextFacet
+				if err := v.UnmarshalCBOR(cr); err != nil {
+					return err
+				}
+
+				t.DescriptionFacets[i] = &v
+			}
+
+		default:
+			// Field doesn't exist on this type, so ignore it
+			cbg.ScanForLinks(r, func(cid.Cid) {})
+		}
+	}
+
+	return nil
+}
+func (t *GraphListitem) MarshalCBOR(w io.Writer) error {
+	if t == nil {
+		_, err := w.Write(cbg.CborNull)
+		return err
+	}
+
+	cw := cbg.NewCborWriter(w)
+
+	if _, err := cw.Write([]byte{164}); err != nil {
+		return err
+	}
+
+	// t.List (string) (string)
+	if len("list") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"list\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("list"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("list")); err != nil {
+		return err
+	}
+
+	if len(t.List) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.List was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.List))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.List)); err != nil {
+		return err
+	}
+
+	// t.LexiconTypeID (string) (string)
+	if len("$type") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"$type\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("$type"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("$type")); err != nil {
+		return err
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("app.bsky.graph.listitem"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("app.bsky.graph.listitem")); err != nil {
+		return err
+	}
+
+	// t.Subject (string) (string)
+	if len("subject") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"subject\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("subject"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("subject")); err != nil {
+		return err
+	}
+
+	if len(t.Subject) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.Subject was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Subject))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.Subject)); err != nil {
+		return err
+	}
+
+	// t.CreatedAt (string) (string)
+	if len("createdAt") > cbg.MaxLength {
+		return xerrors.Errorf("Value in field \"createdAt\" was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("createdAt"))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string("createdAt")); err != nil {
+		return err
+	}
+
+	if len(t.CreatedAt) > cbg.MaxLength {
+		return xerrors.Errorf("Value in field t.CreatedAt was too long")
+	}
+
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.CreatedAt))); err != nil {
+		return err
+	}
+	if _, err := io.WriteString(w, string(t.CreatedAt)); err != nil {
+		return err
+	}
+	return nil
+}
+
+func (t *GraphListitem) UnmarshalCBOR(r io.Reader) (err error) {
+	*t = GraphListitem{}
+
+	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("GraphListitem: 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.List (string) (string)
+		case "list":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.List = string(sval)
+			}
+			// t.LexiconTypeID (string) (string)
+		case "$type":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.LexiconTypeID = string(sval)
+			}
+			// t.Subject (string) (string)
+		case "subject":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.Subject = string(sval)
+			}
+			// t.CreatedAt (string) (string)
+		case "createdAt":
+
+			{
+				sval, err := cbg.ReadString(cr)
+				if err != nil {
+					return err
+				}
+
+				t.CreatedAt = string(sval)
+			}
+
+		default:
+			// Field doesn't exist on this type, so ignore it
+			cbg.ScanForLinks(r, func(cid.Cid) {})
+		}
+	}
+
+	return nil
+}

api/bsky/embedrecord.go

···
 	Record        *EmbedRecord_View_Record `json:"record" cborgen:"record"`
 }
 
+// EmbedRecord_ViewBlocked is a "viewBlocked" in the app.bsky.embed.record schema.
+//
+// RECORDTYPE: EmbedRecord_ViewBlocked
+type EmbedRecord_ViewBlocked struct {
+	LexiconTypeID string `json:"$type,const=app.bsky.embed.record" cborgen:"$type,const=app.bsky.embed.record"`
+	Uri           string `json:"uri" cborgen:"uri"`
+}
+
 // EmbedRecord_ViewNotFound is a "viewNotFound" in the app.bsky.embed.record schema.
 //
 // RECORDTYPE: EmbedRecord_ViewNotFound
···
 type EmbedRecord_View_Record struct {
 	EmbedRecord_ViewRecord   *EmbedRecord_ViewRecord
 	EmbedRecord_ViewNotFound *EmbedRecord_ViewNotFound
+	EmbedRecord_ViewBlocked  *EmbedRecord_ViewBlocked
 }
 
 func (t *EmbedRecord_View_Record) MarshalJSON() ([]byte, error) {
···
 		t.EmbedRecord_ViewNotFound.LexiconTypeID = "app.bsky.embed.record#viewNotFound"
 		return json.Marshal(t.EmbedRecord_ViewNotFound)
 	}
+	if t.EmbedRecord_ViewBlocked != nil {
+		t.EmbedRecord_ViewBlocked.LexiconTypeID = "app.bsky.embed.record#viewBlocked"
+		return json.Marshal(t.EmbedRecord_ViewBlocked)
+	}
 	return nil, fmt.Errorf("cannot marshal empty enum")
 }
 func (t *EmbedRecord_View_Record) UnmarshalJSON(b []byte) error {
···
 	case "app.bsky.embed.record#viewNotFound":
 		t.EmbedRecord_ViewNotFound = new(EmbedRecord_ViewNotFound)
 		return json.Unmarshal(b, t.EmbedRecord_ViewNotFound)
+	case "app.bsky.embed.record#viewBlocked":
+		t.EmbedRecord_ViewBlocked = new(EmbedRecord_ViewBlocked)
+		return json.Unmarshal(b, t.EmbedRecord_ViewBlocked)
 
 	default:
 		return nil

api/bsky/feeddefs.go

···
 	"github.com/bluesky-social/indigo/lex/util"
 )
 
+// FeedDefs_BlockedPost is a "blockedPost" in the app.bsky.feed.defs schema.
+//
+// RECORDTYPE: FeedDefs_BlockedPost
+type FeedDefs_BlockedPost struct {
+	LexiconTypeID string `json:"$type,const=app.bsky.feed.defs" cborgen:"$type,const=app.bsky.feed.defs"`
+	Blocked       bool   `json:"blocked" cborgen:"blocked"`
+	Uri           string `json:"uri" cborgen:"uri"`
+}
+
 // FeedDefs_FeedViewPost is a "feedViewPost" in the app.bsky.feed.defs schema.
 type FeedDefs_FeedViewPost struct {
 	Post   *FeedDefs_PostView            `json:"post" cborgen:"post"`
···
 type FeedDefs_ThreadViewPost_Parent struct {
 	FeedDefs_ThreadViewPost *FeedDefs_ThreadViewPost
 	FeedDefs_NotFoundPost   *FeedDefs_NotFoundPost
+	FeedDefs_BlockedPost    *FeedDefs_BlockedPost
 }
 
 func (t *FeedDefs_ThreadViewPost_Parent) MarshalJSON() ([]byte, error) {
···
 		t.FeedDefs_NotFoundPost.LexiconTypeID = "app.bsky.feed.defs#notFoundPost"
 		return json.Marshal(t.FeedDefs_NotFoundPost)
 	}
+	if t.FeedDefs_BlockedPost != nil {
+		t.FeedDefs_BlockedPost.LexiconTypeID = "app.bsky.feed.defs#blockedPost"
+		return json.Marshal(t.FeedDefs_BlockedPost)
+	}
 	return nil, fmt.Errorf("cannot marshal empty enum")
 }
 func (t *FeedDefs_ThreadViewPost_Parent) UnmarshalJSON(b []byte) error {
···
 	case "app.bsky.feed.defs#notFoundPost":
 		t.FeedDefs_NotFoundPost = new(FeedDefs_NotFoundPost)
 		return json.Unmarshal(b, t.FeedDefs_NotFoundPost)
+	case "app.bsky.feed.defs#blockedPost":
+		t.FeedDefs_BlockedPost = new(FeedDefs_BlockedPost)
+		return json.Unmarshal(b, t.FeedDefs_BlockedPost)
 
 	default:
 		return nil
···
 type FeedDefs_ThreadViewPost_Replies_Elem struct {
 	FeedDefs_ThreadViewPost *FeedDefs_ThreadViewPost
 	FeedDefs_NotFoundPost   *FeedDefs_NotFoundPost
+	FeedDefs_BlockedPost    *FeedDefs_BlockedPost
 }
 
 func (t *FeedDefs_ThreadViewPost_Replies_Elem) MarshalJSON() ([]byte, error) {
···
 		t.FeedDefs_NotFoundPost.LexiconTypeID = "app.bsky.feed.defs#notFoundPost"
 		return json.Marshal(t.FeedDefs_NotFoundPost)
 	}
+	if t.FeedDefs_BlockedPost != nil {
+		t.FeedDefs_BlockedPost.LexiconTypeID = "app.bsky.feed.defs#blockedPost"
+		return json.Marshal(t.FeedDefs_BlockedPost)
+	}
 	return nil, fmt.Errorf("cannot marshal empty enum")
 }
 func (t *FeedDefs_ThreadViewPost_Replies_Elem) UnmarshalJSON(b []byte) error {
···
 	case "app.bsky.feed.defs#notFoundPost":
 		t.FeedDefs_NotFoundPost = new(FeedDefs_NotFoundPost)
 		return json.Unmarshal(b, t.FeedDefs_NotFoundPost)
+	case "app.bsky.feed.defs#blockedPost":
+		t.FeedDefs_BlockedPost = new(FeedDefs_BlockedPost)
+		return json.Unmarshal(b, t.FeedDefs_BlockedPost)
 
 	default:
 		return nil

api/bsky/feedgetPostThread.go

···
 type FeedGetPostThread_Output_Thread struct {
 	FeedDefs_ThreadViewPost *FeedDefs_ThreadViewPost
 	FeedDefs_NotFoundPost   *FeedDefs_NotFoundPost
+	FeedDefs_BlockedPost    *FeedDefs_BlockedPost
 }
 
 func (t *FeedGetPostThread_Output_Thread) MarshalJSON() ([]byte, error) {
···
 		t.FeedDefs_NotFoundPost.LexiconTypeID = "app.bsky.feed.defs#notFoundPost"
 		return json.Marshal(t.FeedDefs_NotFoundPost)
 	}
+	if t.FeedDefs_BlockedPost != nil {
+		t.FeedDefs_BlockedPost.LexiconTypeID = "app.bsky.feed.defs#blockedPost"
+		return json.Marshal(t.FeedDefs_BlockedPost)
+	}
 	return nil, fmt.Errorf("cannot marshal empty enum")
 }
 func (t *FeedGetPostThread_Output_Thread) UnmarshalJSON(b []byte) error {
···
 	case "app.bsky.feed.defs#notFoundPost":
 		t.FeedDefs_NotFoundPost = new(FeedDefs_NotFoundPost)
 		return json.Unmarshal(b, t.FeedDefs_NotFoundPost)
+	case "app.bsky.feed.defs#blockedPost":
+		t.FeedDefs_BlockedPost = new(FeedDefs_BlockedPost)
+		return json.Unmarshal(b, t.FeedDefs_BlockedPost)
 
 	default:
 		return nil

api/bsky/graphblock.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.block
+
+import (
+	"github.com/bluesky-social/indigo/lex/util"
+)
+
+func init() {
+	util.RegisterType("app.bsky.graph.block", &GraphBlock{})
+} //
+// RECORDTYPE: GraphBlock
+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"`
+}

api/bsky/graphdefs.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.defs
+
+// GraphDefs_ListItemView is a "listItemView" in the app.bsky.graph.defs schema.
+type GraphDefs_ListItemView struct {
+	Subject *ActorDefs_ProfileView `json:"subject" cborgen:"subject"`
+}
+
+// GraphDefs_ListView is a "listView" in the app.bsky.graph.defs schema.
+type GraphDefs_ListView struct {
+	Avatar            *string                    `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
+	Creator           *ActorDefs_ProfileView     `json:"creator" cborgen:"creator"`
+	Description       *string                    `json:"description,omitempty" cborgen:"description,omitempty"`
+	DescriptionFacets []*RichtextFacet           `json:"descriptionFacets,omitempty" cborgen:"descriptionFacets,omitempty"`
+	IndexedAt         string                     `json:"indexedAt" cborgen:"indexedAt"`
+	Name              string                     `json:"name" cborgen:"name"`
+	Purpose           *string                    `json:"purpose" cborgen:"purpose"`
+	Uri               string                     `json:"uri" cborgen:"uri"`
+	Viewer            *GraphDefs_ListViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"`
+}
+
+// GraphDefs_ListViewBasic is a "listViewBasic" in the app.bsky.graph.defs schema.
+type GraphDefs_ListViewBasic struct {
+	Avatar    *string                    `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
+	IndexedAt *string                    `json:"indexedAt,omitempty" cborgen:"indexedAt,omitempty"`
+	Name      string                     `json:"name" cborgen:"name"`
+	Purpose   *string                    `json:"purpose" cborgen:"purpose"`
+	Uri       string                     `json:"uri" cborgen:"uri"`
+	Viewer    *GraphDefs_ListViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"`
+}
+
+// GraphDefs_ListViewerState is a "listViewerState" in the app.bsky.graph.defs schema.
+type GraphDefs_ListViewerState struct {
+	Muted *bool `json:"muted,omitempty" cborgen:"muted,omitempty"`
+}

api/bsky/graphgetBlocks.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.getBlocks
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphGetBlocks_Output is the output of a app.bsky.graph.getBlocks call.
+type GraphGetBlocks_Output struct {
+	Blocks []*ActorDefs_ProfileView `json:"blocks" cborgen:"blocks"`
+	Cursor *string                  `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
+}
+
+// GraphGetBlocks calls the XRPC method "app.bsky.graph.getBlocks".
+func GraphGetBlocks(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*GraphGetBlocks_Output, error) {
+	var out GraphGetBlocks_Output
+
+	params := map[string]interface{}{
+		"cursor": cursor,
+		"limit":  limit,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "app.bsky.graph.getBlocks", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/bsky/graphgetList.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.getList
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphGetList_Output is the output of a app.bsky.graph.getList call.
+type GraphGetList_Output struct {
+	Cursor *string                   `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
+	Items  []*GraphDefs_ListItemView `json:"items" cborgen:"items"`
+	List   *GraphDefs_ListView       `json:"list" cborgen:"list"`
+}
+
+// GraphGetList calls the XRPC method "app.bsky.graph.getList".
+func GraphGetList(ctx context.Context, c *xrpc.Client, cursor string, limit int64, list string) (*GraphGetList_Output, error) {
+	var out GraphGetList_Output
+
+	params := map[string]interface{}{
+		"cursor": cursor,
+		"limit":  limit,
+		"list":   list,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "app.bsky.graph.getList", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/bsky/graphgetListMutes.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.getListMutes
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphGetListMutes_Output is the output of a app.bsky.graph.getListMutes call.
+type GraphGetListMutes_Output struct {
+	Cursor *string               `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
+	Lists  []*GraphDefs_ListView `json:"lists" cborgen:"lists"`
+}
+
+// GraphGetListMutes calls the XRPC method "app.bsky.graph.getListMutes".
+func GraphGetListMutes(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*GraphGetListMutes_Output, error) {
+	var out GraphGetListMutes_Output
+
+	params := map[string]interface{}{
+		"cursor": cursor,
+		"limit":  limit,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "app.bsky.graph.getListMutes", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/bsky/graphgetLists.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.getLists
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphGetLists_Output is the output of a app.bsky.graph.getLists call.
+type GraphGetLists_Output struct {
+	Cursor *string               `json:"cursor,omitempty" cborgen:"cursor,omitempty"`
+	Lists  []*GraphDefs_ListView `json:"lists" cborgen:"lists"`
+}
+
+// GraphGetLists calls the XRPC method "app.bsky.graph.getLists".
+func GraphGetLists(ctx context.Context, c *xrpc.Client, actor string, cursor string, limit int64) (*GraphGetLists_Output, error) {
+	var out GraphGetLists_Output
+
+	params := map[string]interface{}{
+		"actor":  actor,
+		"cursor": cursor,
+		"limit":  limit,
+	}
+	if err := c.Do(ctx, xrpc.Query, "", "app.bsky.graph.getLists", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/bsky/graphlist.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.list
+
+import (
+	"github.com/bluesky-social/indigo/lex/util"
+)
+
+func init() {
+	util.RegisterType("app.bsky.graph.list", &GraphList{})
+} //
+// RECORDTYPE: GraphList
+type GraphList struct {
+	LexiconTypeID     string           `json:"$type,const=app.bsky.graph.list" cborgen:"$type,const=app.bsky.graph.list"`
+	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"`
+	Name              string           `json:"name" cborgen:"name"`
+	Purpose           *string          `json:"purpose" cborgen:"purpose"`
+}

api/bsky/graphlistitem.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.listitem
+
+import (
+	"github.com/bluesky-social/indigo/lex/util"
+)
+
+func init() {
+	util.RegisterType("app.bsky.graph.listitem", &GraphListitem{})
+} //
+// RECORDTYPE: GraphListitem
+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"`
+}

api/bsky/graphmuteActorList.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.muteActorList
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphMuteActorList_Input is the input argument to a app.bsky.graph.muteActorList call.
+type GraphMuteActorList_Input struct {
+	List string `json:"list" cborgen:"list"`
+}
+
+// GraphMuteActorList calls the XRPC method "app.bsky.graph.muteActorList".
+func GraphMuteActorList(ctx context.Context, c *xrpc.Client, input *GraphMuteActorList_Input) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "app.bsky.graph.muteActorList", nil, input, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/bsky/graphunmuteActorList.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package bsky
+
+// schema: app.bsky.graph.unmuteActorList
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// GraphUnmuteActorList_Input is the input argument to a app.bsky.graph.unmuteActorList call.
+type GraphUnmuteActorList_Input struct {
+	List string `json:"list" cborgen:"list"`
+}
+
+// GraphUnmuteActorList calls the XRPC method "app.bsky.graph.unmuteActorList".
+func GraphUnmuteActorList(ctx context.Context, c *xrpc.Client, input *GraphUnmuteActorList_Input) error {
+	if err := c.Do(ctx, xrpc.Procedure, "application/json", "app.bsky.graph.unmuteActorList", nil, input, nil); err != nil {
+		return err
+	}
+
+	return nil
+}

api/bsky/unspeccedgetPopular.go

···
 }
 
 // UnspeccedGetPopular calls the XRPC method "app.bsky.unspecced.getPopular".
-func UnspeccedGetPopular(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*UnspeccedGetPopular_Output, error) {
+func UnspeccedGetPopular(ctx context.Context, c *xrpc.Client, cursor string, includeNsfw bool, limit int64) (*UnspeccedGetPopular_Output, error) {
 	var out UnspeccedGetPopular_Output
 
 	params := map[string]interface{}{
-		"cursor": cursor,
-		"limit":  limit,
+		"cursor":      cursor,
+		"includeNsfw": includeNsfw,
+		"limit":       limit,
 	}
 	if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getPopular", params, nil, &out); err != nil {
 		return nil, err

cmd/gosky/admin.go

···
 	"fmt"
 	"os"
 	"sort"
+	"strings"
 	"sync"
 	"time"
 
 	"github.com/bluesky-social/indigo/api"
+	"github.com/bluesky-social/indigo/api/atproto"
 	comatproto "github.com/bluesky-social/indigo/api/atproto"
 	cliutil "github.com/bluesky-social/indigo/cmd/gosky/util"
 	cli "github.com/urfave/cli/v2"
···
 		buildInviteTreeCmd,
 		checkUserCmd,
 		reportsCmd,
+		disableInvitesCmd,
 	},
 }
 
···
 			fmt.Println(rep.Email)
 			fmt.Println("indexed at: ", rep.IndexedAt)
 			fmt.Printf("Invited by: %s\n", invby)
+			if rep.InvitesDisabled != nil && *rep.InvitesDisabled {
+				fmt.Println("INVITES DISABLED")
+			}
 
 			var invited []*comatproto.AdminDefs_RepoViewDetail
 			var lk sync.Mutex
···
 		adminKey := cctx.String("admin-password")
 		xrpcc.AdminToken = &adminKey
 
-		resp, err := comatproto.AdminGetModerationReports(ctx, xrpcc, "", 100, true, "")
+		resp, err := comatproto.AdminGetModerationReports(ctx, xrpcc, "", "", 100, true, "")
 		if err != nil {
 			return err
 		}
···
 		return nil
 	},
 }
+
+var disableInvitesCmd = &cli.Command{
+	Name: "disableInvites",
+	Flags: []cli.Flag{
+		&cli.StringFlag{
+			Name:     "admin-password",
+			EnvVars:  []string{"ATP_AUTH_ADMIN_PASSWORD"},
+			Required: true,
+		},
+	},
+	Action: func(cctx *cli.Context) error {
+
+		xrpcc, err := cliutil.GetXrpcClient(cctx, false)
+		if err != nil {
+			return err
+		}
+
+		ctx := context.Background()
+
+		adminKey := cctx.String("admin-password")
+		xrpcc.AdminToken = &adminKey
+
+		handle := cctx.Args().First()
+		if !strings.HasPrefix(handle, "did:") {
+			resp, err := atproto.IdentityResolveHandle(ctx, xrpcc, handle)
+			if err != nil {
+				return err
+			}
+
+			handle = resp.Did
+		}
+
+		return comatproto.AdminDisableAccountInvites(ctx, xrpcc, &comatproto.AdminDisableAccountInvites_Input{
+			Account: handle,
+		})
+	},
+}

gen/main.go

···
 		bsky.RichtextFacet_Link{}, bsky.RichtextFacet_Mention{},
 		bsky.EmbedRecordWithMedia{},
 		bsky.FeedDefs_NotFoundPost{},
+		bsky.GraphBlock{},
+		bsky.GraphList{},
+		bsky.GraphListitem{},
 		/*bsky.EmbedImages_View{},
 		bsky.EmbedRecord_View{}, bsky.EmbedRecordWithMedia_View{},
 		bsky.EmbedExternal_View{}, bsky.EmbedImages_ViewImage{},

pds/stubs.go

···
 )
 
 func (s *Server) RegisterHandlersAppBsky(e *echo.Echo) error {
+	e.GET("/xrpc/app.bsky.actor.getPreferences", s.HandleAppBskyActorGetPreferences)
 	e.GET("/xrpc/app.bsky.actor.getProfile", s.HandleAppBskyActorGetProfile)
 	e.GET("/xrpc/app.bsky.actor.getProfiles", s.HandleAppBskyActorGetProfiles)
 	e.GET("/xrpc/app.bsky.actor.getSuggestions", s.HandleAppBskyActorGetSuggestions)
+	e.POST("/xrpc/app.bsky.actor.putPreferences", s.HandleAppBskyActorPutPreferences)
 	e.GET("/xrpc/app.bsky.actor.searchActors", s.HandleAppBskyActorSearchActors)
 	e.GET("/xrpc/app.bsky.actor.searchActorsTypeahead", s.HandleAppBskyActorSearchActorsTypeahead)
 	e.GET("/xrpc/app.bsky.feed.getAuthorFeed", s.HandleAppBskyFeedGetAuthorFeed)
 	e.GET("/xrpc/app.bsky.feed.getLikes", s.HandleAppBskyFeedGetLikes)
 	e.GET("/xrpc/app.bsky.feed.getPostThread", s.HandleAppBskyFeedGetPostThread)
+	e.GET("/xrpc/app.bsky.feed.getPosts", s.HandleAppBskyFeedGetPosts)
 	e.GET("/xrpc/app.bsky.feed.getRepostedBy", s.HandleAppBskyFeedGetRepostedBy)
 	e.GET("/xrpc/app.bsky.feed.getTimeline", s.HandleAppBskyFeedGetTimeline)
+	e.GET("/xrpc/app.bsky.graph.getBlocks", s.HandleAppBskyGraphGetBlocks)
 	e.GET("/xrpc/app.bsky.graph.getFollowers", s.HandleAppBskyGraphGetFollowers)
 	e.GET("/xrpc/app.bsky.graph.getFollows", s.HandleAppBskyGraphGetFollows)
+	e.GET("/xrpc/app.bsky.graph.getList", s.HandleAppBskyGraphGetList)
+	e.GET("/xrpc/app.bsky.graph.getListMutes", s.HandleAppBskyGraphGetListMutes)
+	e.GET("/xrpc/app.bsky.graph.getLists", s.HandleAppBskyGraphGetLists)
 	e.GET("/xrpc/app.bsky.graph.getMutes", s.HandleAppBskyGraphGetMutes)
 	e.POST("/xrpc/app.bsky.graph.muteActor", s.HandleAppBskyGraphMuteActor)
+	e.POST("/xrpc/app.bsky.graph.muteActorList", s.HandleAppBskyGraphMuteActorList)
 	e.POST("/xrpc/app.bsky.graph.unmuteActor", s.HandleAppBskyGraphUnmuteActor)
+	e.POST("/xrpc/app.bsky.graph.unmuteActorList", s.HandleAppBskyGraphUnmuteActorList)
 	e.GET("/xrpc/app.bsky.notification.getUnreadCount", s.HandleAppBskyNotificationGetUnreadCount)
 	e.GET("/xrpc/app.bsky.notification.listNotifications", s.HandleAppBskyNotificationListNotifications)
 	e.POST("/xrpc/app.bsky.notification.updateSeen", s.HandleAppBskyNotificationUpdateSeen)
 	e.GET("/xrpc/app.bsky.unspecced.getPopular", s.HandleAppBskyUnspeccedGetPopular)
 	return nil
+}
+
+func (s *Server) HandleAppBskyActorGetPreferences(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorGetPreferences")
+	defer span.End()
+	var out *appbskytypes.ActorGetPreferences_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyActorGetPreferences(ctx context.Context) (*appbskytypes.ActorGetPreferences_Output, error)
+	out, handleErr = s.handleAppBskyActorGetPreferences(ctx)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
 }
 
 func (s *Server) HandleAppBskyActorGetProfile(c echo.Context) error {
···
 	return c.JSON(200, out)
 }
 
+func (s *Server) HandleAppBskyActorPutPreferences(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorPutPreferences")
+	defer span.End()
+
+	var body appbskytypes.ActorPutPreferences_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleAppBskyActorPutPreferences(ctx context.Context,body *appbskytypes.ActorPutPreferences_Input) error
+	handleErr = s.handleAppBskyActorPutPreferences(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
+}
+
 func (s *Server) HandleAppBskyActorSearchActors(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorSearchActors")
 	defer span.End()
···
 	return c.JSON(200, out)
 }
 
+func (s *Server) HandleAppBskyFeedGetPosts(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetPosts")
+	defer span.End()
+
+	uris := c.QueryParams()["uris"]
+	var out *appbskytypes.FeedGetPosts_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyFeedGetPosts(ctx context.Context,uris []string) (*appbskytypes.FeedGetPosts_Output, error)
+	out, handleErr = s.handleAppBskyFeedGetPosts(ctx, uris)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
+}
+
 func (s *Server) HandleAppBskyFeedGetRepostedBy(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetRepostedBy")
 	defer span.End()
···
 	return c.JSON(200, out)
 }
 
+func (s *Server) HandleAppBskyGraphGetBlocks(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetBlocks")
+	defer span.End()
+	cursor := c.QueryParam("cursor")
+
+	var limit int
+	if p := c.QueryParam("limit"); p != "" {
+		var err error
+		limit, err = strconv.Atoi(p)
+		if err != nil {
+			return err
+		}
+	} else {
+		limit = 50
+	}
+	var out *appbskytypes.GraphGetBlocks_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphGetBlocks(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetBlocks_Output, error)
+	out, handleErr = s.handleAppBskyGraphGetBlocks(ctx, cursor, limit)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
+}
+
 func (s *Server) HandleAppBskyGraphGetFollowers(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetFollowers")
 	defer span.End()
···
 	return c.JSON(200, out)
 }
 
+func (s *Server) HandleAppBskyGraphGetList(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetList")
+	defer span.End()
+	cursor := c.QueryParam("cursor")
+
+	var limit int
+	if p := c.QueryParam("limit"); p != "" {
+		var err error
+		limit, err = strconv.Atoi(p)
+		if err != nil {
+			return err
+		}
+	} else {
+		limit = 50
+	}
+	list := c.QueryParam("list")
+	var out *appbskytypes.GraphGetList_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphGetList(ctx context.Context,cursor string,limit int,list string) (*appbskytypes.GraphGetList_Output, error)
+	out, handleErr = s.handleAppBskyGraphGetList(ctx, cursor, limit, list)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
+}
+
+func (s *Server) HandleAppBskyGraphGetListMutes(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetListMutes")
+	defer span.End()
+	cursor := c.QueryParam("cursor")
+
+	var limit int
+	if p := c.QueryParam("limit"); p != "" {
+		var err error
+		limit, err = strconv.Atoi(p)
+		if err != nil {
+			return err
+		}
+	} else {
+		limit = 50
+	}
+	var out *appbskytypes.GraphGetListMutes_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphGetListMutes(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetListMutes_Output, error)
+	out, handleErr = s.handleAppBskyGraphGetListMutes(ctx, cursor, limit)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
+}
+
+func (s *Server) HandleAppBskyGraphGetLists(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetLists")
+	defer span.End()
+	actor := c.QueryParam("actor")
+	cursor := c.QueryParam("cursor")
+
+	var limit int
+	if p := c.QueryParam("limit"); p != "" {
+		var err error
+		limit, err = strconv.Atoi(p)
+		if err != nil {
+			return err
+		}
+	} else {
+		limit = 50
+	}
+	var out *appbskytypes.GraphGetLists_Output
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphGetLists(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.GraphGetLists_Output, error)
+	out, handleErr = s.handleAppBskyGraphGetLists(ctx, actor, cursor, limit)
+	if handleErr != nil {
+		return handleErr
+	}
+	return c.JSON(200, out)
+}
+
 func (s *Server) HandleAppBskyGraphGetMutes(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetMutes")
 	defer span.End()
···
 	return nil
 }
 
+func (s *Server) HandleAppBskyGraphMuteActorList(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphMuteActorList")
+	defer span.End()
+
+	var body appbskytypes.GraphMuteActorList_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphMuteActorList(ctx context.Context,body *appbskytypes.GraphMuteActorList_Input) error
+	handleErr = s.handleAppBskyGraphMuteActorList(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
+}
+
 func (s *Server) HandleAppBskyGraphUnmuteActor(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphUnmuteActor")
 	defer span.End()
···
 	var handleErr error
 	// func (s *Server) handleAppBskyGraphUnmuteActor(ctx context.Context,body *appbskytypes.GraphUnmuteActor_Input) error
 	handleErr = s.handleAppBskyGraphUnmuteActor(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
+}
+
+func (s *Server) HandleAppBskyGraphUnmuteActorList(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphUnmuteActorList")
+	defer span.End()
+
+	var body appbskytypes.GraphUnmuteActorList_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleAppBskyGraphUnmuteActorList(ctx context.Context,body *appbskytypes.GraphUnmuteActorList_Input) error
+	handleErr = s.handleAppBskyGraphUnmuteActorList(ctx, &body)
 	if handleErr != nil {
 		return handleErr
 	}
···
 	defer span.End()
 	cursor := c.QueryParam("cursor")
 
+	var includeNsfw bool
+	if p := c.QueryParam("includeNsfw"); p != "" {
+		var err error
+		includeNsfw, err = strconv.ParseBool(p)
+		if err != nil {
+			return err
+		}
+	} else {
+		includeNsfw = false
+	}
+
 	var limit int
 	if p := c.QueryParam("limit"); p != "" {
 		var err error
···
 	}
 	var out *appbskytypes.UnspeccedGetPopular_Output
 	var handleErr error
-	// func (s *Server) handleAppBskyUnspeccedGetPopular(ctx context.Context,cursor string,limit int) (*appbskytypes.UnspeccedGetPopular_Output, error)
-	out, handleErr = s.handleAppBskyUnspeccedGetPopular(ctx, cursor, limit)
+	// func (s *Server) handleAppBskyUnspeccedGetPopular(ctx context.Context,cursor string,includeNsfw bool,limit int) (*appbskytypes.UnspeccedGetPopular_Output, error)
+	out, handleErr = s.handleAppBskyUnspeccedGetPopular(ctx, cursor, includeNsfw, limit)
 	if handleErr != nil {
 		return handleErr
 	}
···
 }
 
 func (s *Server) RegisterHandlersComAtproto(e *echo.Echo) error {
+	e.POST("/xrpc/com.atproto.admin.disableAccountInvites", s.HandleComAtprotoAdminDisableAccountInvites)
 	e.POST("/xrpc/com.atproto.admin.disableInviteCodes", s.HandleComAtprotoAdminDisableInviteCodes)
+	e.POST("/xrpc/com.atproto.admin.enableAccountInvites", s.HandleComAtprotoAdminEnableAccountInvites)
 	e.GET("/xrpc/com.atproto.admin.getInviteCodes", s.HandleComAtprotoAdminGetInviteCodes)
 	e.GET("/xrpc/com.atproto.admin.getModerationAction", s.HandleComAtprotoAdminGetModerationAction)
 	e.GET("/xrpc/com.atproto.admin.getModerationActions", s.HandleComAtprotoAdminGetModerationActions)
···
 	e.GET("/xrpc/com.atproto.repo.getRecord", s.HandleComAtprotoRepoGetRecord)
 	e.GET("/xrpc/com.atproto.repo.listRecords", s.HandleComAtprotoRepoListRecords)
 	e.POST("/xrpc/com.atproto.repo.putRecord", s.HandleComAtprotoRepoPutRecord)
+	e.POST("/xrpc/com.atproto.repo.rebaseRepo", s.HandleComAtprotoRepoRebaseRepo)
 	e.POST("/xrpc/com.atproto.repo.uploadBlob", s.HandleComAtprotoRepoUploadBlob)
 	e.POST("/xrpc/com.atproto.server.createAccount", s.HandleComAtprotoServerCreateAccount)
 	e.POST("/xrpc/com.atproto.server.createAppPassword", s.HandleComAtprotoServerCreateAppPassword)
···
 	return nil
 }
 
+func (s *Server) HandleComAtprotoAdminDisableAccountInvites(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminDisableAccountInvites")
+	defer span.End()
+
+	var body comatprototypes.AdminDisableAccountInvites_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleComAtprotoAdminDisableAccountInvites(ctx context.Context,body *comatprototypes.AdminDisableAccountInvites_Input) error
+	handleErr = s.handleComAtprotoAdminDisableAccountInvites(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
+}
+
 func (s *Server) HandleComAtprotoAdminDisableInviteCodes(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminDisableInviteCodes")
 	defer span.End()
···
 	var handleErr error
 	// func (s *Server) handleComAtprotoAdminDisableInviteCodes(ctx context.Context,body *comatprototypes.AdminDisableInviteCodes_Input) error
 	handleErr = s.handleComAtprotoAdminDisableInviteCodes(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
+}
+
+func (s *Server) HandleComAtprotoAdminEnableAccountInvites(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminEnableAccountInvites")
+	defer span.End()
+
+	var body comatprototypes.AdminEnableAccountInvites_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleComAtprotoAdminEnableAccountInvites(ctx context.Context,body *comatprototypes.AdminEnableAccountInvites_Input) error
+	handleErr = s.handleComAtprotoAdminEnableAccountInvites(ctx, &body)
 	if handleErr != nil {
 		return handleErr
 	}
···
 func (s *Server) HandleComAtprotoAdminGetModerationReports(c echo.Context) error {
 	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminGetModerationReports")
 	defer span.End()
+	actionType := c.QueryParam("actionType")
 	cursor := c.QueryParam("cursor")
 
 	var limit int
···
 	subject := c.QueryParam("subject")
 	var out *comatprototypes.AdminGetModerationReports_Output
 	var handleErr error
-	// func (s *Server) handleComAtprotoAdminGetModerationReports(ctx context.Context,cursor string,limit int,resolved *bool,subject string) (*comatprototypes.AdminGetModerationReports_Output, error)
-	out, handleErr = s.handleComAtprotoAdminGetModerationReports(ctx, cursor, limit, resolved, subject)
+	// func (s *Server) handleComAtprotoAdminGetModerationReports(ctx context.Context,actionType string,cursor string,limit int,resolved *bool,subject string) (*comatprototypes.AdminGetModerationReports_Output, error)
+	out, handleErr = s.handleComAtprotoAdminGetModerationReports(ctx, actionType, cursor, limit, resolved, subject)
 	if handleErr != nil {
 		return handleErr
 	}
···
 		return handleErr
 	}
 	return c.JSON(200, out)
+}
+
+func (s *Server) HandleComAtprotoRepoRebaseRepo(c echo.Context) error {
+	ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoRepoRebaseRepo")
+	defer span.End()
+
+	var body comatprototypes.RepoRebaseRepo_Input
+	if err := c.Bind(&body); err != nil {
+		return err
+	}
+	var handleErr error
+	// func (s *Server) handleComAtprotoRepoRebaseRepo(ctx context.Context,body *comatprototypes.RepoRebaseRepo_Input) error
+	handleErr = s.handleComAtprotoRepoRebaseRepo(ctx, &body)
+	if handleErr != nil {
+		return handleErr
+	}
+	return nil
 }
 
 func (s *Server) HandleComAtprotoRepoUploadBlob(c echo.Context) error {