Method storeChatAttachment

coderd/x/chatd/store_chat_attachment.go:30–71

(
	ctx context.Context,
	chatSnapshot database.Chat,
	name string,
	detectName string,
	data []byte,
)

}

func (p *Server) storeChatAttachment(
	ctx context.Context,
	chatSnapshot database.Chat,
	name string,
	detectName string,
	data []byte,
) (chattool.AttachmentMetadata, error) {
	if !chatSnapshot.WorkspaceID.Valid {
		return chattool.AttachmentMetadata{}, xerrors.New("no workspace is associated with this chat. Use the create_workspace tool to create one")
	}

	storedName, mediaType, err := chatfiles.PrepareStoredFile(name, detectName, data)
	if err != nil {
		return chattool.AttachmentMetadata{}, err
	}

	// Insert and link in one transaction so a cap rejection or linking
	// failure does not leave behind an unlinked chat file row.
	var attachment chattool.AttachmentMetadata
	err = p.db.InTx(func(tx database.Store) error {
		ws, err := tx.GetWorkspaceByID(ctx, chatSnapshot.WorkspaceID.UUID)
		if err != nil {
			return xerrors.Errorf("resolve workspace: %w", err)
		}

		attachment, err = storeLinkedChatFileTx(
			ctx,
			tx,
			chatSnapshot.ID,
			chatSnapshot.OwnerID,
			ws.OrganizationID,
			storedName,
			mediaType,
			data,
		)
		return err
	}, database.DefaultTXOptions().WithID("store_chat_attachment"))
	if err != nil {
		return chattool.AttachmentMetadata{}, err
	}
	return attachment, nil
}

func storeLinkedChatFileTx(
	ctx context.Context,