xinyin025/LangBot
1
0
Fork 0
mirror of https://github.com/langbot-app/LangBot.git synced 2026-06-04 04:54:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: serialization bug in events emitting

Browse Source
This commit is contained in:
Junyan Qin
2025-06-27 21:16:52 +08:00
parent 5553a86ac8
commit f474e42b79
2 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/pipeline/cntfilter/cntfilter.py
View File

@@ -85,7 +85,7 @@ class ContentFilterStage(stage.PipelineStage):
elif result.level == filter_entities.ResultLevel.PASS: # 传到下一个
message = result.replacement
query.message_chain = platform_message.MessageChain(platform_message.Plain(message))
query.message_chain = platform_message.MessageChain(platform_message.Plain(text=message))
return entities.StageProcessResult(result_type=entities.ResultType.CONTINUE, new_query=query)

10
pkg/pipeline/pipelinemgr.py
View File

@@ -184,24 +184,20 @@ class RuntimePipeline:
else events.GroupMessageReceived
)
print(query)
print(query.model_dump(exclude_none=True))
event_obj = event_type(
launcher_type=query.launcher_type.value,
launcher_id=query.launcher_id,
sender_id=query.sender_id,
message_chain=query.message_chain,
query=query,
)
event_ctx = event_context.EventContext(
event=event_obj,
)
event_ctx_result = await self.ap.plugin_connector.handler.emit_event(
event_ctx.model_dump(exclude_none=True)
)
event_ctx_data = event_ctx.model_dump(serialize_as_any=True)
event_ctx_result = await self.ap.plugin_connector.handler.emit_event(event_ctx_data)
event_ctx.update(**event_ctx_result)