Method publishChatPubsubEvent

coderd/x/chatd/chatd.go:5518–5549

publishChatPubsubEvent broadcasts a chat lifecycle event via PostgreSQL pubsub so that all replicas can push updates to watching clients.

(chat database.Chat, kind codersdk.ChatWatchEventKind, diffStatus *codersdk.ChatDiffStatus)

// publishChatPubsubEvent broadcasts a chat lifecycle event via PostgreSQL
// pubsub so that all replicas can push updates to watching clients.
func (p *Server) publishChatPubsubEvent(chat database.Chat, kind codersdk.ChatWatchEventKind, diffStatus *codersdk.ChatDiffStatus) {
	if p.pubsub == nil {
		return
	}
	// diffStatus is applied below. File metadata is intentionally
	// omitted from pubsub events to avoid an extra DB query per
	// publish. Clients must merge pubsub updates, not replace
	// cached file metadata.
	sdkChat := db2sdk.Chat(chat, nil, nil)
	if diffStatus != nil {
		sdkChat.DiffStatus = diffStatus
	}
	event := codersdk.ChatWatchEvent{
		Kind: kind,
		Chat: sdkChat,
	}
	payload, err := json.Marshal(event)
	if err != nil {
		p.logger.Error(context.Background(), "failed to marshal chat pubsub event",
			slog.F("chat_id", chat.ID),
			slog.Error(err),
		)
		return
	}
	if err := p.pubsub.Publish(coderdpubsub.ChatWatchEventChannel(chat.OwnerID), payload); err != nil {
		p.logger.Error(context.Background(), "failed to publish chat pubsub event",
			slog.F("chat_id", chat.ID),
			slog.F("kind", kind),
			slog.Error(err),
		)
	}
}

// pendingToStreamToolCalls converts a slice of chatloop pending
// tool calls into the SDK streaming representation.