mirror of
https://github.com/HKUDS/nanobot.git
synced 2026-09-01 16:51:53 +03:00
fix(cron): sanitize migrated legacy metadata
This commit is contained in:
@@ -153,7 +153,7 @@ def _normalize_agent_turn_job(job: CronJob) -> bool:
|
|||||||
payload.origin_channel = payload.origin_channel or payload.channel
|
payload.origin_channel = payload.origin_channel or payload.channel
|
||||||
payload.origin_chat_id = payload.origin_chat_id or payload.to
|
payload.origin_chat_id = payload.origin_chat_id or payload.to
|
||||||
if not payload.origin_metadata:
|
if not payload.origin_metadata:
|
||||||
payload.origin_metadata = dict(payload.channel_meta or {})
|
payload.origin_metadata = _persistable_origin_metadata(payload.channel_meta or {})
|
||||||
|
|
||||||
payload.deliver = False
|
payload.deliver = False
|
||||||
payload.channel = None
|
payload.channel = None
|
||||||
|
|||||||
@@ -293,7 +293,12 @@ def test_load_store_migrates_legacy_delivery_context(tmp_path) -> None:
|
|||||||
"deliver": True,
|
"deliver": True,
|
||||||
"channel": "telegram",
|
"channel": "telegram",
|
||||||
"to": "user-1",
|
"to": "user-1",
|
||||||
"channelMeta": {"message_thread_id": 42},
|
"channelMeta": {
|
||||||
|
"message_thread_id": 42,
|
||||||
|
RUNTIME_CONTEXT_INPUT_META: [
|
||||||
|
{"source": "webui_quote", "content": "stale quote"}
|
||||||
|
],
|
||||||
|
},
|
||||||
"sessionKey": "telegram:user-1:topic:42",
|
"sessionKey": "telegram:user-1:topic:42",
|
||||||
},
|
},
|
||||||
"state": {},
|
"state": {},
|
||||||
|
|||||||
Reference in New Issue
Block a user