mirror of
https://github.com/home-assistant/core.git
synced 2025-08-08 15:15:09 +02:00
Always include flow_id
This commit is contained in:
@@ -411,6 +411,7 @@ def config_entries_flow_subscribe(
|
|||||||
msg["id"],
|
msg["id"],
|
||||||
{
|
{
|
||||||
"type": change_type,
|
"type": change_type,
|
||||||
|
"flow_id": flow_id,
|
||||||
"flow": hass.config_entries.flow.async_get(flow_id),
|
"flow": hass.config_entries.flow.async_get(flow_id),
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
@@ -428,7 +429,7 @@ def config_entries_flow_subscribe(
|
|||||||
connection.send_message(
|
connection.send_message(
|
||||||
websocket_api.event_message(
|
websocket_api.event_message(
|
||||||
msg["id"],
|
msg["id"],
|
||||||
{"type": "init", "flow": flw},
|
{"type": "init", "flow_id": flw["flow_id"], "flow": flw},
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
connection.send_result(msg["id"])
|
connection.send_result(msg["id"])
|
||||||
|
@@ -985,6 +985,7 @@ async def test_get_progress_subscribe(
|
|||||||
"step_id": "account",
|
"step_id": "account",
|
||||||
"context": {"source": core_ce.SOURCE_HASSIO},
|
"context": {"source": core_ce.SOURCE_HASSIO},
|
||||||
},
|
},
|
||||||
|
"flow_id": form_hassio["flow_id"],
|
||||||
"type": "init",
|
"type": "init",
|
||||||
},
|
},
|
||||||
"id": subscription,
|
"id": subscription,
|
||||||
@@ -999,6 +1000,7 @@ async def test_get_progress_subscribe(
|
|||||||
"step_id": "account",
|
"step_id": "account",
|
||||||
"context": {"entry_id": "1234", "source": core_ce.SOURCE_REAUTH},
|
"context": {"entry_id": "1234", "source": core_ce.SOURCE_REAUTH},
|
||||||
},
|
},
|
||||||
|
"flow_id": form_reauth["flow_id"],
|
||||||
"type": "init",
|
"type": "init",
|
||||||
},
|
},
|
||||||
"id": subscription,
|
"id": subscription,
|
||||||
@@ -1115,6 +1117,7 @@ async def test_get_progress_subscribe_in_progress(
|
|||||||
"step_id": "account",
|
"step_id": "account",
|
||||||
"context": {"source": core_ce.SOURCE_HASSIO},
|
"context": {"source": core_ce.SOURCE_HASSIO},
|
||||||
},
|
},
|
||||||
|
"flow_id": form_hassio["flow_id"],
|
||||||
"type": "init",
|
"type": "init",
|
||||||
},
|
},
|
||||||
"id": 1,
|
"id": 1,
|
||||||
@@ -1131,6 +1134,7 @@ async def test_get_progress_subscribe_in_progress(
|
|||||||
"source": core_ce.SOURCE_REAUTH,
|
"source": core_ce.SOURCE_REAUTH,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
"flow_id": form_reauth["flow_id"],
|
||||||
"type": "init",
|
"type": "init",
|
||||||
},
|
},
|
||||||
"id": 1,
|
"id": 1,
|
||||||
|
Reference in New Issue
Block a user