support Message() without content param

metagpt/roles/researcher.py

@@ -54,18 +54,27 @@ class Researcher(Role):
         research_system_text = self.research_system_text(topic, todo)
         if isinstance(todo, CollectLinks):
             links = await todo.run(topic, 4, 4)
-            ret = Message("", Report(topic=topic, links=links), role=self.profile, cause_by=todo)
+            ret = Message(
+                content="", instruct_content=Report(topic=topic, links=links), role=self.profile, cause_by=todo
+            )
         elif isinstance(todo, WebBrowseAndSummarize):
             links = instruct_content.links
             todos = (todo.run(*url, query=query, system_text=research_system_text) for (query, url) in links.items())
             summaries = await asyncio.gather(*todos)
             summaries = list((url, summary) for i in summaries for (url, summary) in i.items() if summary)
-            ret = Message("", Report(topic=topic, summaries=summaries), role=self.profile, cause_by=todo)
+            ret = Message(
+                content="", instruct_content=Report(topic=topic, summaries=summaries), role=self.profile, cause_by=todo
+            )
         else:
             summaries = instruct_content.summaries
             summary_text = "\n---\n".join(f"url: {url}\nsummary: {summary}" for (url, summary) in summaries)
             content = await self._rc.todo.run(topic, summary_text, system_text=research_system_text)
-            ret = Message("", Report(topic=topic, content=content), role=self.profile, cause_by=self._rc.todo)
+            ret = Message(
+                content="",
+                instruct_content=Report(topic=topic, content=content),
+                role=self.profile,
+                cause_by=self._rc.todo,
+            )
         self._rc.memory.add(ret)
         return ret
 

metagpt/schema.py

@@ -110,7 +110,7 @@ class Message(BaseModel):
     sent_from: str = ""
     send_to: Set = Field(default_factory={MESSAGE_ROUTE_TO_ALL})
 
-    def __init__(self, **kwargs):
+    def __init__(self, content: str = "", **kwargs):
         ic = kwargs.get("instruct_content", None)
         if ic and not isinstance(ic, BaseModel) and "class" in ic:
             # compatible with custom-defined ActionOutput
@@ -122,6 +122,7 @@ class Message(BaseModel):
             kwargs["instruct_content"] = ic_new
 
         kwargs["id"] = kwargs.get("id", uuid.uuid4().hex)
+        kwargs["content"] = kwargs.get("content", content)
         kwargs["cause_by"] = any_to_str(
             kwargs.get("cause_by", import_class("UserRequirement", "metagpt.actions.add_requirement"))
         )

metagpt/subscription.py

@@ -19,7 +19,7 @@ class SubscriptionRunner(BaseModel):
 
         >>> async def trigger():
         ...     while True:
-        ...         yield Message("the latest news about OpenAI")
+        ...         yield Message(content="the latest news about OpenAI")
         ...         await asyncio.sleep(3600 * 24)
 
         >>> async def callback(msg: Message):