Add device registry id to assist call (#2838)

<!-- Thank you for submitting a Pull Request and helping to improve Home
Assistant. Please complete the following sections to help the processing
and review of your changes. Please do not delete anything from this
template. -->

## Summary
<!-- Provide a brief summary of the changes you have made and most
importantly what they aim to achieve -->

Integration PR:
home-assistant/core#121496 (comment)

## Screenshots
<!-- If this is a user-facing change not in the frontend, please include
screenshots in light and dark mode. -->

## Link to pull request in Documentation repository
<!-- Pull requests that add, change or remove functionality must have a
corresponding pull request in the Companion App Documentation repository
(https://github.com/home-assistant/companion.home-assistant). Please add
the number of this pull request after the "#" -->
Documentation: home-assistant/companion.home-assistant#

## Any other notes
<!-- If there is any other information of note, like if this Pull
Request is part of a bigger change, please include it here. -->

Sources/Shared/API/HAAPI.swift

@@ -315,6 +315,7 @@ public class HomeAssistantAPI {
  server.connection.cloudhookURL = config.CloudhookURL
  server.connection.set(address: config.RemoteUIURL, for: .remoteUI)
  server.remoteName = config.LocationName ?? ServerInfo.defaultName
+ server.hassDeviceId = config.hassDeviceId
 
  if let version = try? Version(hassVersion: config.Version) {
  server.version = version

Sources/Shared/API/Responses/ConfigResponse.swift

@@ -4,6 +4,7 @@ import ObjectMapper
 public class ConfigResponse: Mappable {
  public var Components: [String] = []
  public var Version: String = ""
+ public var hassDeviceId: String?
 
  public var TemperatureUnit: String?
  public var LengthUnit: String?
@@ -27,6 +28,7 @@ public class ConfigResponse: Mappable {
  public func mapping(map: Map) {
  Components <- map["components"]
  Version <- map["version"]
+ hassDeviceId <- map["hass_device_id"]
 
  TemperatureUnit <- map["unit_system.temperature"]
  LengthUnit <- map["unit_system.length"]

Sources/Shared/API/Server.swift

@@ -66,6 +66,7 @@ public struct ServerInfo: Codable, Equatable {
  }
 
  public var remoteName: String
+ public var hassDeviceId: String?
  public var sortOrder: Int
  public var version: Version
  public var connection: ConnectionInfo
@@ -84,12 +85,14 @@ public struct ServerInfo: Codable, Equatable {
  case connectionInfo
  case tokenInfo
  case settings
+ case hassDeviceId
  }
 
  public init(from decoder: Decoder) throws {
  let container = try decoder.container(keyedBy: CodingKeys.self)
 
  self.remoteName = try container.decode(String.self, forKey: .name)
+ self.hassDeviceId = try container.decodeIfPresent(String.self, forKey: .hassDeviceId)
  self.sortOrder = try container.decode(Int.self, forKey: .sortOrder)
  self.connection = try container.decode(ConnectionInfo.self, forKey: .connectionInfo)
  self.token = try container.decode(TokenInfo.self, forKey: .tokenInfo)
@@ -105,6 +108,7 @@ public struct ServerInfo: Codable, Equatable {
  try container.encode(connection, forKey: .connectionInfo)
  try container.encode(token, forKey: .tokenInfo)
  try container.encode(settings, forKey: .settings)
+ try container.encode(hassDeviceId, forKey: .hassDeviceId)
  }
 
  public init(

Sources/Shared/Intents/AssistInApp/AssistRequests.swift

@@ -5,7 +5,8 @@ public enum AssistRequests {
  public static func assistByVoiceTypedSubscription(
  preferredPipelineId: String,
  audioSampleRate: Double,
- conversationId: String?
+ conversationId: String?,
+ hassDeviceId: String?
  ) -> HATypedSubscription<AssistResponse> {
  var data: [String: Any] = [
  "pipeline": preferredPipelineId,
@@ -18,13 +19,17 @@ public enum AssistRequests {
  if let conversationId {
  data["conversation_id"] = conversationId
  }
+ if let hassDeviceId {
+ data["device_id"] = hassDeviceId
+ }
  return .init(request: .init(type: .webSocket("assist_pipeline/run"), data: data))
  }
 
  public static func assistByTextTypedSubscription(
  preferredPipelineId: String,
  inputText: String,
- conversationId: String?
+ conversationId: String?,
+ hassDeviceId: String?
  ) -> HATypedSubscription<AssistResponse> {
  var data: [String: Any] = [
  "pipeline": preferredPipelineId,
@@ -37,6 +42,9 @@ public enum AssistRequests {
  if let conversationId {
  data["conversation_id"] = conversationId
  }
+ if let hassDeviceId {
+ data["device_id"] = hassDeviceId
+ }
  return .init(request: .init(type: .webSocket("assist_pipeline/run"), data: data))
  }
 

Sources/Shared/Intents/AssistInApp/AssistService.swift

@@ -109,7 +109,8 @@ public final class AssistService: AssistServiceProtocol {
  connection.subscribe(to: AssistRequests.assistByVoiceTypedSubscription(
  preferredPipelineId: pipelineId,
  audioSampleRate: audioSampleRate,
- conversationId: conversationId
+ conversationId: conversationId,
+ hassDeviceId: server.info.hassDeviceId
  )) { [weak self] cancellable, data in
  guard let self else { return }
  self.cancellable = cancellable
@@ -122,7 +123,8 @@ public final class AssistService: AssistServiceProtocol {
  connection.subscribe(to: AssistRequests.assistByTextTypedSubscription(
  preferredPipelineId: pipelineId,
  inputText: input,
- conversationId: conversationId
+ conversationId: conversationId,
+ hassDeviceId: server.info.hassDeviceId
  )) { [weak self] cancellable, data in
  guard let self else { return }
  self.cancellable = cancellable