test: disable text batching in existing adapter tests
Set _text_batch_delay_seconds = 0 on test adapter fixtures so messages dispatch immediately (bypassing async batching). This preserves the existing synchronous assertion patterns while the batching logic is tested separately in test_text_batching.py.
This commit is contained in:
@@ -81,6 +81,7 @@ def adapter(monkeypatch):
|
|||||||
config = PlatformConfig(enabled=True, token="fake-token")
|
config = PlatformConfig(enabled=True, token="fake-token")
|
||||||
adapter = DiscordAdapter(config)
|
adapter = DiscordAdapter(config)
|
||||||
adapter._client = SimpleNamespace(user=SimpleNamespace(id=999))
|
adapter._client = SimpleNamespace(user=SimpleNamespace(id=999))
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
adapter.handle_message = AsyncMock()
|
adapter.handle_message = AsyncMock()
|
||||||
return adapter
|
return adapter
|
||||||
|
|
||||||
|
|||||||
@@ -91,6 +91,7 @@ def adapter(monkeypatch):
|
|||||||
config = PlatformConfig(enabled=True, token="fake-token")
|
config = PlatformConfig(enabled=True, token="fake-token")
|
||||||
adapter = DiscordAdapter(config)
|
adapter = DiscordAdapter(config)
|
||||||
adapter._client = SimpleNamespace(user=SimpleNamespace(id=999))
|
adapter._client = SimpleNamespace(user=SimpleNamespace(id=999))
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
adapter.handle_message = AsyncMock()
|
adapter.handle_message = AsyncMock()
|
||||||
return adapter
|
return adapter
|
||||||
|
|
||||||
|
|||||||
@@ -62,6 +62,7 @@ def adapter():
|
|||||||
fetch_channel=AsyncMock(),
|
fetch_channel=AsyncMock(),
|
||||||
user=SimpleNamespace(id=99999, name="HermesBot"),
|
user=SimpleNamespace(id=99999, name="HermesBot"),
|
||||||
)
|
)
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
return adapter
|
return adapter
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -44,6 +44,7 @@ def _make_adapter(tmp_path=None):
|
|||||||
},
|
},
|
||||||
)
|
)
|
||||||
adapter = MatrixAdapter(config)
|
adapter = MatrixAdapter(config)
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
adapter.handle_message = AsyncMock()
|
adapter.handle_message = AsyncMock()
|
||||||
adapter._startup_ts = time.time() - 10 # avoid startup grace filter
|
adapter._startup_ts = time.time() - 10 # avoid startup grace filter
|
||||||
return adapter
|
return adapter
|
||||||
|
|||||||
@@ -508,6 +508,7 @@ class TestInboundMessages:
|
|||||||
from gateway.platforms.wecom import WeComAdapter
|
from gateway.platforms.wecom import WeComAdapter
|
||||||
|
|
||||||
adapter = WeComAdapter(PlatformConfig(enabled=True))
|
adapter = WeComAdapter(PlatformConfig(enabled=True))
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
adapter.handle_message = AsyncMock()
|
adapter.handle_message = AsyncMock()
|
||||||
adapter._extract_media = AsyncMock(return_value=(["/tmp/test.png"], ["image/png"]))
|
adapter._extract_media = AsyncMock(return_value=(["/tmp/test.png"], ["image/png"]))
|
||||||
|
|
||||||
@@ -539,6 +540,7 @@ class TestInboundMessages:
|
|||||||
from gateway.platforms.wecom import WeComAdapter
|
from gateway.platforms.wecom import WeComAdapter
|
||||||
|
|
||||||
adapter = WeComAdapter(PlatformConfig(enabled=True))
|
adapter = WeComAdapter(PlatformConfig(enabled=True))
|
||||||
|
adapter._text_batch_delay_seconds = 0 # disable batching for tests
|
||||||
adapter.handle_message = AsyncMock()
|
adapter.handle_message = AsyncMock()
|
||||||
adapter._extract_media = AsyncMock(return_value=([], []))
|
adapter._extract_media = AsyncMock(return_value=([], []))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user