start_thread

Instructions

Implementation Reference

• src/mcp_teams_server/teams.py:142-205 (handler)

  The core implementation of start_thread logic in TeamsClient. Creates a thread by sending an activity via the bot adapter, optionally mentioning a member. Returns a TeamsThread object with the created thread ID.

  async def start_thread(
      self, title: str, content: str, member_name: str | None = None
  ) -> TeamsThread:
      """Start a new thread in a channel.
  
      Args:
          title: Thread title
          content: Initial thread content
          member_name: Member name to mention in content
  
      Returns:
          Created thread details including ID
      """
      try:
          await self._initialize()
  
          result = TeamsThread(title=title, content=content, thread_id="")
  
          async def start_thread_callback(context: TurnContext):
              mention_member = await self._get_mention_member(context, member_name)
  
              mentions = []
              if mention_member is not None:
                  result.content = (
                      f"# **{title}**\n<at>{mention_member.name}</at> {content}"
                  )
                  mention = Mention(
                      text=f"<at>{mention_member.name}</at>",
                      mentioned=ChannelAccount(
                          id=mention_member.id, name=mention_member.name
                      ),
                  )
                  mentions.append(mention)
  
              try:
                  activity = Activity(
                      type=ActivityTypes.message,
                      from_property=ChannelAccount( id=self.teams_app_id, name=MCP_BOT_NAME), # type: ignore
                      channel_id="msteams",  # type: ignore
                      conversation=context.activity.conversation,
                      topic_name=title,
                      text=result.content,
                      text_format=TextFormatTypes.markdown,
                      entities=mentions,
                  )
  
                  responses = await self.adapter.send_activities(context, [activity])
                  response = responses[0] if responses else None
  
                  if response is not None:
                      result.thread_id = response.id
              except Exception as ae:
                  LOGGER.exception(ae)
  
          await self.adapter.continue_conversation(
              agent_app_id=self.teams_app_id,
              continuation_activity=self._create_continuation_activity(),
              callback=start_thread_callback,
          )
  
          return result
      except Exception as e:
          LOGGER.error(f"Error creating thread: {str(e)}")
          raise

• src/mcp_teams_server/__init__.py:107-120 (registration)

  Registers the 'start_thread' MCP tool with FastMCP decorator. Extracts the TeamsClient from context and delegates to client.start_thread().

  @mcp.tool(
      name="start_thread", description="Start a new thread with a given title and content"
  )
  async def start_thread(
      ctx: Context,
      title: str = Field(description="The thread title"),
      content: str = Field(description="The thread content"),
      member_name: str | None = Field(
          description="Member name to mention in the thread", default=None
      ),
  ) -> TeamsThread:
      await ctx.debug(f"start_thread with title={title} and content={content}")
      client = _get_teams_client(ctx)
      return await client.start_thread(title, content, member_name)

• src/mcp_teams_server/teams.py:39-44 (schema)

  The TeamsThread model returned by start_thread, containing thread_id, title, and content fields.

  class TeamsThread(BaseModel):
      thread_id: str = Field(
          description="Thread ID as a string in the format '1743086901347'"
      )
      title: str = Field(description="Message title")
      content: str = Field(description="Message content")

• src/mcp_teams_server/__init__.py:110-117 (schema)

  Input parameter schema for the start_thread MCP tool: title (str), content (str), and optional member_name (str | None).

  async def start_thread(
      ctx: Context,
      title: str = Field(description="The thread title"),
      content: str = Field(description="The thread content"),
      member_name: str | None = Field(
          description="Member name to mention in the thread", default=None
      ),
  ) -> TeamsThread:

• tests/test_teams.py:69-76 (helper)

  Integration test for start_thread that exercises the TeamsClient.start_thread method with title, content, and a user mention.

  async def test_start_thread(setup_teams_client, user_name):
      LOGGER.info(
          f"test_start_thread in team: {setup_teams_client.team_id} "
          f"and channel {setup_teams_client.teams_channel_id}"
      )
      try:
          result = await setup_teams_client.start_thread(
              "First thread", "First thread content with mention", user_name