Method stopAndStoreRecording

coderd/x/chatd/recording.go:32–223

stopAndStoreRecording stops the desktop recording, downloads the multipart response containing the MP4 and optional thumbnail, and stores them in chat_files. Only called when the subagent completed successfully. Returns file IDs on success, empty fields on any failure. All errors are logged but not

(
	ctx context.Context,
	conn workspacesdk.AgentConn,
	recordingID string,
	parentChatID uuid.UUID,
	ownerID uuid.UUID,
	workspaceID uuid.NullUUID,
)

// failure. All errors are logged but not propagated; recording is
// best-effort.
func (p *Server) stopAndStoreRecording(
	ctx context.Context,
	conn workspacesdk.AgentConn,
	recordingID string,
	parentChatID uuid.UUID,
	ownerID uuid.UUID,
	workspaceID uuid.NullUUID,
) recordingResult {
	var result recordingResult

	workspaceIDValue := ""
	if workspaceID.Valid {
		workspaceIDValue = workspaceID.UUID.String()
	}
	recordingWarnFields := []slog.Field{
		slog.F("recording_id", recordingID),
		slog.F("parent_chat_id", parentChatID.String()),
		slog.F("workspace_id", workspaceIDValue),
	}
	warn := func(msg string, fields ...slog.Field) {
		allFields := make([]slog.Field, 0, len(recordingWarnFields)+len(fields))
		allFields = append(allFields, recordingWarnFields...)
		allFields = append(allFields, fields...)
		p.logger.Warn(ctx, msg, allFields...)
	}

	select {
	case p.recordingSem <- struct{}{}:
		defer func() { <-p.recordingSem }()
	case <-ctx.Done():
		warn("context canceled waiting for recording semaphore", slog.Error(ctx.Err()))
		return result
	}

	resp, err := conn.StopDesktopRecording(ctx,
		workspacesdk.StopDesktopRecordingRequest{RecordingID: recordingID})
	if err != nil {
		warn("failed to stop desktop recording",
			slog.Error(err))
		return result
	}
	defer resp.Body.Close()

	_, params, err := mime.ParseMediaType(resp.ContentType)
	if err != nil {
		warn("failed to parse content type from recording response",
			slog.F("content_type", resp.ContentType),
			slog.Error(err))
		return result
	}
	boundary := params["boundary"]
	if boundary == "" {
		warn("missing boundary in recording response content type",
			slog.F("content_type", resp.ContentType))
		return result
	}

	if !workspaceID.Valid {