fix: use contents= for Message construction in agent-framework 1.3.0

- Update InputObserverMiddleware to use Message(contents=) instead of
  Message(text=) since agent-framework 1.3.0 renamed the parameter
- Update corresponding tests to verify contents field
- Fix teardown_module signature to accept optional module parameter

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: 2 people

src/processor/src/libs/agent_framework/middlewares.py

@@ -159,7 +159,7 @@ async def process(
                         f"[InputObserverMiddleware] Updated: '{original_text}' -> '{updated_text}'"
                     )
 
-                modified_message = Message(role=message.role, text=updated_text)
+                modified_message = Message(role=message.role, contents=updated_text)
                 modified_messages.append(modified_message)
                 modified_count += 1
             else:

src/processor/src/tests/unit/libs/agent_framework/test_groupchat_orchestrator_internals.py

@@ -40,7 +40,7 @@ def __init__(self, *, role, text=None, contents=None, author_name=None):
 )
 
 
-def teardown_module():
+def teardown_module(module=None):
     """Restore the original Message class to avoid leaking into other tests."""
     if _original_message is not None:
         groupchat_module.Message = _original_message

src/processor/src/tests/unit/libs/agent_framework/test_input_observer_middleware.py

@@ -26,7 +26,7 @@ def __init__(self, *, role, text=None, contents=None, author_name=None):
 from libs.agent_framework.middlewares import InputObserverMiddleware  # noqa: E402
 
 
-def teardown_module():
+def teardown_module(module=None):
     """Restore the original Message class to avoid leaking into other tests."""
     if _original_message is not None:
         middlewares_module.Message = _original_message

src/processor/src/tests/unit/libs/agent_framework/test_middlewares_extras.py

@@ -33,7 +33,7 @@ def __init__(self, *, role, text=None, contents=None, author_name=None):
 )
 
 
-def teardown_module():
+def teardown_module(module=None):
     """Restore the original Message class to avoid leaking into other tests."""
     if _original_message is not None:
         middlewares_module.Message = _original_message
@@ -110,22 +110,22 @@ class TestInputObserverMiddleware:
     def test_replaces_user_messages_when_replacement_set(self):
         from libs.agent_framework.middlewares import InputObserverMiddleware
 
-        msg_user = Message(role=ROLE_USER, text="orig user")
-        msg_assistant = Message(role=ROLE_ASSISTANT, text="hi")
+        msg_user = Message(role=ROLE_USER, text="orig user", contents="orig user")
+        msg_assistant = Message(role=ROLE_ASSISTANT, text="hi", contents="hi")
         ctx = MagicMock()
         ctx.messages = [msg_user, msg_assistant]
         next_fn = AsyncMock()
         mw = InputObserverMiddleware(replacement="REDACTED")
         _run(mw.process(ctx, next_fn))
         # First message replaced, second untouched
-        assert ctx.messages[0].text == "REDACTED"
-        assert ctx.messages[1].text == "hi"
+        assert ctx.messages[0].contents == "REDACTED"
+        assert ctx.messages[1].contents == "hi"
         next_fn.assert_awaited_once()
 
     def test_no_replacement_keeps_text(self):
         from libs.agent_framework.middlewares import InputObserverMiddleware
 
-        msg = Message(role=ROLE_USER, text="keep me")
+        msg = Message(role=ROLE_USER, text="keep me", contents="keep me")
         ctx = MagicMock()
         ctx.messages = [msg]
         mw = InputObserverMiddleware(replacement=None)