Update chat lexicons

api/chat/actordefs.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package chat
+
+// schema: chat.bsky.actor.defs
+
+import (
+	comatprototypes "github.com/bluesky-social/indigo/api/atproto"
+	appbskytypes "github.com/bluesky-social/indigo/api/bsky"
+)
+
+// ActorDefs_ProfileViewBasic is a "profileViewBasic" in the chat.bsky.actor.defs schema.
+type ActorDefs_ProfileViewBasic struct {
+	Associated *appbskytypes.ActorDefs_ProfileAssociated `json:"associated,omitempty" cborgen:"associated,omitempty"`
+	Avatar     *string                                   `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
+	// chatDisabled: Set to true when the actor cannot actively participate in converations
+	ChatDisabled *bool                               `json:"chatDisabled,omitempty" cborgen:"chatDisabled,omitempty"`
+	Did          string                              `json:"did" cborgen:"did"`
+	DisplayName  *string                             `json:"displayName,omitempty" cborgen:"displayName,omitempty"`
+	Handle       string                              `json:"handle" cborgen:"handle"`
+	Labels       []*comatprototypes.LabelDefs_Label  `json:"labels,omitempty" cborgen:"labels,omitempty"`
+	Viewer       *appbskytypes.ActorDefs_ViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"`
+}

api/chat/actordeleteAccount.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package chat
+
+// schema: chat.bsky.actor.deleteAccount
+
+import (
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ActorDeleteAccount_Output is the output of a chat.bsky.actor.deleteAccount call.
+type ActorDeleteAccount_Output struct {
+}
+
+// ActorDeleteAccount calls the XRPC method "chat.bsky.actor.deleteAccount".
+func ActorDeleteAccount(ctx context.Context, c *xrpc.Client) (*ActorDeleteAccount_Output, error) {
+	var out ActorDeleteAccount_Output
+	if err := c.Do(ctx, xrpc.Procedure, "", "chat.bsky.actor.deleteAccount", nil, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

api/chat/actorexportAccountData.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+package chat
+
+// schema: chat.bsky.actor.exportAccountData
+
+import (
+	"bytes"
+	"context"
+
+	"github.com/bluesky-social/indigo/xrpc"
+)
+
+// ActorExportAccountData calls the XRPC method "chat.bsky.actor.exportAccountData".
+func ActorExportAccountData(ctx context.Context, c *xrpc.Client) ([]byte, error) {
+	buf := new(bytes.Buffer)
+	if err := c.Do(ctx, xrpc.Query, "", "chat.bsky.actor.exportAccountData", nil, nil, buf); err != nil {
+		return nil, err
+	}
+
+	return buf.Bytes(), nil
+}

api/chat/convodefs.go

···
 
 // ConvoDefs_ConvoView is a "convoView" in the chat.bsky.convo.defs schema.
 type ConvoDefs_ConvoView struct {
-	Id          string                                     `json:"id" cborgen:"id"`
-	LastMessage *ConvoDefs_ConvoView_LastMessage           `json:"lastMessage,omitempty" cborgen:"lastMessage,omitempty"`
-	Members     []*appbskytypes.ActorDefs_ProfileViewBasic `json:"members" cborgen:"members"`
-	Muted       bool                                       `json:"muted" cborgen:"muted"`
-	Rev         string                                     `json:"rev" cborgen:"rev"`
-	UnreadCount int64                                      `json:"unreadCount" cborgen:"unreadCount"`
+	Id          string                           `json:"id" cborgen:"id"`
+	LastMessage *ConvoDefs_ConvoView_LastMessage `json:"lastMessage,omitempty" cborgen:"lastMessage,omitempty"`
+	Members     []*ActorDefs_ProfileViewBasic    `json:"members" cborgen:"members"`
+	Muted       bool                             `json:"muted" cborgen:"muted"`
+	Rev         string                           `json:"rev" cborgen:"rev"`
+	UnreadCount int64                            `json:"unreadCount" cborgen:"unreadCount"`
 }
 
 type ConvoDefs_ConvoView_LastMessage struct {
···
 	LexiconTypeID string                       `json:"$type,const=chat.bsky.convo.defs#deletedMessageView" cborgen:"$type,const=chat.bsky.convo.defs#deletedMessageView"`
 	Id            string                       `json:"id" cborgen:"id"`
 	Rev           string                       `json:"rev" cborgen:"rev"`
-	Sender        *ConvoDefs_MessageViewSender `json:"sender,omitempty" cborgen:"sender,omitempty"`
+	Sender        *ConvoDefs_MessageViewSender `json:"sender" cborgen:"sender"`
 	SentAt        string                       `json:"sentAt" cborgen:"sentAt"`
 }
 
···
 	Rev           string `json:"rev" cborgen:"rev"`
 }
 
-// ConvoDefs_Message is a "message" in the chat.bsky.convo.defs schema.
-type ConvoDefs_Message struct {
-	Embed *ConvoDefs_Message_Embed `json:"embed,omitempty" cborgen:"embed,omitempty"`
+// ConvoDefs_MessageInput is the input argument to a chat.bsky.convo.defs call.
+type ConvoDefs_MessageInput struct {
+	Embed *ConvoDefs_MessageInput_Embed `json:"embed,omitempty" cborgen:"embed,omitempty"`
 	// facets: Annotations of text (mentions, URLs, hashtags, etc)
 	Facets []*appbskytypes.RichtextFacet `json:"facets,omitempty" cborgen:"facets,omitempty"`
-	Id     *string                       `json:"id,omitempty" cborgen:"id,omitempty"`
 	Text   string                        `json:"text" cborgen:"text"`
 }
 
+type ConvoDefs_MessageInput_Embed struct {
+	EmbedRecord *appbskytypes.EmbedRecord
+}
+
+func (t *ConvoDefs_MessageInput_Embed) MarshalJSON() ([]byte, error) {
+	if t.EmbedRecord != nil {
+		t.EmbedRecord.LexiconTypeID = "app.bsky.embed.record"
+		return json.Marshal(t.EmbedRecord)
+	}
+	return nil, fmt.Errorf("cannot marshal empty enum")
+}
+func (t *ConvoDefs_MessageInput_Embed) UnmarshalJSON(b []byte) error {
+	typ, err := util.TypeExtract(b)
+	if err != nil {
+		return err
+	}
+
+	switch typ {
+	case "app.bsky.embed.record":
+		t.EmbedRecord = new(appbskytypes.EmbedRecord)
+		return json.Unmarshal(b, t.EmbedRecord)
+
+	default:
+		return nil
+	}
+}
+
 // ConvoDefs_MessageRef is a "messageRef" in the chat.bsky.convo.defs schema.
 type ConvoDefs_MessageRef struct {
+	ConvoId   string `json:"convoId" cborgen:"convoId"`
 	Did       string `json:"did" cborgen:"did"`
 	MessageId string `json:"messageId" cborgen:"messageId"`
 }
···
 	Facets []*appbskytypes.RichtextFacet `json:"facets,omitempty" cborgen:"facets,omitempty"`
 	Id     string                        `json:"id" cborgen:"id"`
 	Rev    string                        `json:"rev" cborgen:"rev"`
-	Sender *ConvoDefs_MessageViewSender  `json:"sender,omitempty" cborgen:"sender,omitempty"`
+	Sender *ConvoDefs_MessageViewSender  `json:"sender" cborgen:"sender"`
 	SentAt string                        `json:"sentAt" cborgen:"sentAt"`
 	Text   string                        `json:"text" cborgen:"text"`
 }
···
 		return nil
 	}
 }
-
-type ConvoDefs_Message_Embed struct {
-	EmbedRecord *appbskytypes.EmbedRecord
-}
-
-func (t *ConvoDefs_Message_Embed) MarshalJSON() ([]byte, error) {
-	if t.EmbedRecord != nil {
-		t.EmbedRecord.LexiconTypeID = "app.bsky.embed.record"
-		return json.Marshal(t.EmbedRecord)
-	}
-	return nil, fmt.Errorf("cannot marshal empty enum")
-}
-func (t *ConvoDefs_Message_Embed) UnmarshalJSON(b []byte) error {
-	typ, err := util.TypeExtract(b)
-	if err != nil {
-		return err
-	}
-
-	switch typ {
-	case "app.bsky.embed.record":
-		t.EmbedRecord = new(appbskytypes.EmbedRecord)
-		return json.Unmarshal(b, t.EmbedRecord)
-
-	default:
-		return nil
-	}
-}

api/chat/convosendMessage.go

···
 
 // ConvoSendMessage_Input is the input argument to a chat.bsky.convo.sendMessage call.
 type ConvoSendMessage_Input struct {
-	ConvoId string             `json:"convoId" cborgen:"convoId"`
-	Message *ConvoDefs_Message `json:"message" cborgen:"message"`
+	ConvoId string                  `json:"convoId" cborgen:"convoId"`
+	Message *ConvoDefs_MessageInput `json:"message" cborgen:"message"`
 }
 
 // ConvoSendMessage calls the XRPC method "chat.bsky.convo.sendMessage".

api/chat/convosendMessageBatch.go

···
 
 // ConvoSendMessageBatch_BatchItem is a "batchItem" in the chat.bsky.convo.sendMessageBatch schema.
 type ConvoSendMessageBatch_BatchItem struct {
-	ConvoId string             `json:"convoId" cborgen:"convoId"`
-	Message *ConvoDefs_Message `json:"message" cborgen:"message"`
+	ConvoId string                  `json:"convoId" cborgen:"convoId"`
+	Message *ConvoDefs_MessageInput `json:"message" cborgen:"message"`
 }
 
 // ConvoSendMessageBatch_Input is the input argument to a chat.bsky.convo.sendMessageBatch call.

api/chat/moderationgetMessageContext.go

···
 }
 
 // ModerationGetMessageContext calls the XRPC method "chat.bsky.moderation.getMessageContext".
-func ModerationGetMessageContext(ctx context.Context, c *xrpc.Client, after int64, before int64, messageId string) (*ModerationGetMessageContext_Output, error) {
+//
+// convoId: Conversation that the message is from. NOTE: this field will eventually be required.
+func ModerationGetMessageContext(ctx context.Context, c *xrpc.Client, after int64, before int64, convoId string, messageId string) (*ModerationGetMessageContext_Output, error) {
 	var out ModerationGetMessageContext_Output
 
 	params := map[string]interface{}{
 		"after":     after,
 		"before":    before,
+		"convoId":   convoId,
 		"messageId": messageId,
 	}
 	if err := c.Do(ctx, xrpc.Query, "", "chat.bsky.moderation.getMessageContext", params, nil, &out); err != nil {

api/chat/moderationupdateActorAccess.go

···
 
 // ModerationUpdateActorAccess_Input is the input argument to a chat.bsky.moderation.updateActorAccess call.
 type ModerationUpdateActorAccess_Input struct {
-	Actor       string `json:"actor" cborgen:"actor"`
-	AllowAccess bool   `json:"allowAccess" cborgen:"allowAccess"`
+	Actor       string  `json:"actor" cborgen:"actor"`
+	AllowAccess bool    `json:"allowAccess" cborgen:"allowAccess"`
+	Ref         *string `json:"ref,omitempty" cborgen:"ref,omitempty"`
 }
 
 // ModerationUpdateActorAccess calls the XRPC method "chat.bsky.moderation.updateActorAccess".

lex/gen.go

···
 )
 
 const (
-	EncodingCBOR = "application/cbor"
-	EncodingJSON = "application/json"
-	EncodingCAR  = "application/vnd.ipld.car"
-	EncodingANY  = "*/*"
+	EncodingCBOR  = "application/cbor"
+	EncodingJSON  = "application/json"
+	EncodingJSONL = "application/jsonl"
+	EncodingCAR   = "application/vnd.ipld.car"
+	EncodingANY   = "*/*"
 )
 
 type Schema struct {
···
 
 		if ts.Output != nil {
 			if ts.Output.Schema == nil {
-				if ts.Output.Encoding != "application/cbor" && ts.Output.Encoding != "application/vnd.ipld.car" && ts.Output.Encoding != "*/*" {
+				if ts.Output.Encoding != "application/cbor" && ts.Output.Encoding != "application/vnd.ipld.car" && ts.Output.Encoding != "*/*" && ts.Output.Encoding != "application/jsonl" {
 					panic(fmt.Sprintf("strange output type def in %s", s.ID))
 				}
 			} else {
···
 	out := "error"
 	if s.Output != nil {
 		switch s.Output.Encoding {
-		case EncodingCBOR, EncodingCAR, EncodingANY:
+		case EncodingCBOR, EncodingCAR, EncodingANY, EncodingJSONL:
 			out = "([]byte, error)"
 		case EncodingJSON:
 			outname := fname + "_Output"
···
 	outRet := "nil"
 	if s.Output != nil {
 		switch s.Output.Encoding {
-		case EncodingCBOR, EncodingCAR, EncodingANY:
+		case EncodingCBOR, EncodingCAR, EncodingANY, EncodingJSONL:
 			pf("buf := new(bytes.Buffer)\n")
 			outvar = "buf"
 			errRet = "nil, err"
···
 			}
 			pf("var out *%s.%s\n", impname, outname)
 			returndef = fmt.Sprintf("(*%s.%s, error)", impname, outname)
-		case EncodingCBOR, EncodingCAR, EncodingANY:
+		case EncodingCBOR, EncodingCAR, EncodingANY, EncodingJSONL:
 			assign = "out, handleErr"
 			pf("var out io.Reader\n")
 			returndef = "(io.Reader, error)"
···
 			pf("return c.Stream(200, \"application/octet-stream\", out)\n}\n\n")
 		case EncodingCAR:
 			pf("return c.Stream(200, \"application/vnd.ipld.car\", out)\n}\n\n")
+		case EncodingJSONL:
+			pf("return c.Stream(200, \"application/jsonl\", out)\n}\n\n")
 		default:
 			return fmt.Errorf("unrecognized output encoding (RPC output handler return): %q", s.Output.Encoding)
 		}