refactor(gateway): run_startup resolves adapters through the intake/delivery seams
Mechanical migration of the `_adapter_for_source` call sites in this sibling. Intake policy sites take `_intake_adapter_for`; every send/edit/typing/pending-slot site takes `_delivery_adapter_for`. Part of #88715 (phase 4).
This commit is contained in:
@@ -85,7 +85,7 @@ class GatewayStartupMixin:
|
||||
while queue:
|
||||
event = queue.pop(0)
|
||||
source = getattr(event, "source", None)
|
||||
adapter = self._adapter_for_source(source)
|
||||
adapter = self._intake_adapter_for(source)
|
||||
if adapter is None:
|
||||
logger.debug(
|
||||
"Dropping startup-restore queued message: adapter unavailable for %s",
|
||||
@@ -567,7 +567,7 @@ class GatewayStartupMixin:
|
||||
if self._is_session_running(entry.session_key):
|
||||
continue
|
||||
source = entry.origin
|
||||
adapter = self._adapter_for_source(source)
|
||||
adapter = self._delivery_adapter_for(source)
|
||||
if adapter is None:
|
||||
logger.debug(
|
||||
"Skipping auto-resume for %s: adapter not ready for %s", entry.session_key,
|
||||
|
||||
Reference in New Issue
Block a user