Skip to content

Groups

Source code in superme_sdk/services/_groups.py 
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
class GroupsMixin:
    def group_converse(
        self,
        participants: list[str],
        topic: str,
        *,
        max_turns: int = 3,
        conversation_id: Optional[str] = None,
    ) -> dict:
        """Start or continue a multi-turn group conversation.

        Example:
            ```python
            result = client.group_converse(
                participants=["ludo", "duy"],
                topic="What's the best growth channel for B2B SaaS?",
            )
            for p in result["perspectives"]:
                print(p["user_name"], p["content"])
            ```

        Args:
            participants: People to include — names, usernames, or user IDs.
                At least 2 must resolve to known users.
            topic: The topic or question for the group to discuss.
            max_turns: Maximum conversation turns (1-5, default 3).
            conversation_id: Continue an existing conversation. Omit to start new.

        Returns:
            Dict with conversation_id, perspectives, participant_ids, and
            any unresolved identifiers.
        """
        args: dict[str, Any] = {
            "participants": participants,
            "topic": topic,
        }
        if max_turns != 3:
            args["max_turns"] = max_turns
        if conversation_id is not None:
            args["conversation_id"] = conversation_id
        return self._mcp_tool_call("group_converse", args)

    def group_converse_stream(
        self,
        participants: list[str],
        topic: str,
        *,
        max_turns: int = 3,
        conversation_id: Optional[str] = None,
    ):
        """Stream a group conversation, yielding each perspective as it completes.

        Example:
            ```python
            for event in client.group_converse_stream(
                participants=["ludo", "duy"],
                topic="What is the future of AI agents?",
            ):
                if event.get("_done"):
                    print("conversation_id:", event["conversation_id"])
                else:
                    print(event["user_name"], event["content"])
            ```

        Yields dicts with keys: type, user_name, content, turn, user_id.
        Final yield: ``{"type": "done", "conversation_id": str, "_done": True}``.
        """
        payload: dict[str, Any] = {
            "participants": participants,
            "topic": topic,
            "max_turns": max_turns,
        }
        if conversation_id is not None:
            payload["conversation_id"] = conversation_id

        with self._http.stream(
            "POST",
            "/mcp/chat/stream/group_converse",
            json=payload,
            headers={"Accept-Encoding": "identity"},
        ) as resp:
            if not resp.is_success:
                resp.read()
            self._check_rest_response(resp)

            buf = ""
            for raw_chunk in resp.iter_text():
                buf += raw_chunk
                while "\n" in buf:
                    line, buf = buf.split("\n", 1)
                    line = line.strip()
                    if not line:
                        continue
                    if line.startswith("data: "):
                        line = line[6:]
                    elif line.startswith("data:"):
                        line = line[5:]
                    try:
                        obj = json.loads(line)
                    except (json.JSONDecodeError, ValueError):
                        continue
                    if not isinstance(obj, dict):
                        continue
                    if obj.get("type") == "done":
                        obj["_done"] = True
                    yield obj
            # Flush any remaining data not terminated by a newline
            if buf.strip():
                line = buf.strip()
                if line.startswith("data: "):
                    line = line[6:]
                elif line.startswith("data:"):
                    line = line[5:]
                try:
                    obj = json.loads(line)
                    if isinstance(obj, dict):
                        if obj.get("type") == "done":
                            obj["_done"] = True
                        yield obj
                except (json.JSONDecodeError, ValueError):
                    pass

group_converse 

group_converse(
    participants: list[str],
    topic: str,
    *,
    max_turns: int = 3,
    conversation_id: Optional[str] = None,
) -> dict

Start or continue a multi-turn group conversation.

Example 
result = client.group_converse(
    participants=["ludo", "duy"],
    topic="What's the best growth channel for B2B SaaS?",
)
for p in result["perspectives"]:
    print(p["user_name"], p["content"])

Parameters:

Name Type Description Default
participants list[str]

People to include — names, usernames, or user IDs. At least 2 must resolve to known users.

 required
topic str

The topic or question for the group to discuss.

 required
max_turns int

Maximum conversation turns (1-5, default 3).

 3
conversation_id Optional[str]

Continue an existing conversation. Omit to start new.

 None

Returns:

Type Description
dict

Dict with conversation_id, perspectives, participant_ids, and
dict

any unresolved identifiers.
Source code in superme_sdk/services/_groups.py 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
def group_converse(
    self,
    participants: list[str],
    topic: str,
    *,
    max_turns: int = 3,
    conversation_id: Optional[str] = None,
) -> dict:
    """Start or continue a multi-turn group conversation.

    Example:
        ```python
        result = client.group_converse(
            participants=["ludo", "duy"],
            topic="What's the best growth channel for B2B SaaS?",
        )
        for p in result["perspectives"]:
            print(p["user_name"], p["content"])
        ```

    Args:
        participants: People to include — names, usernames, or user IDs.
            At least 2 must resolve to known users.
        topic: The topic or question for the group to discuss.
        max_turns: Maximum conversation turns (1-5, default 3).
        conversation_id: Continue an existing conversation. Omit to start new.

    Returns:
        Dict with conversation_id, perspectives, participant_ids, and
        any unresolved identifiers.
    """
    args: dict[str, Any] = {
        "participants": participants,
        "topic": topic,
    }
    if max_turns != 3:
        args["max_turns"] = max_turns
    if conversation_id is not None:
        args["conversation_id"] = conversation_id
    return self._mcp_tool_call("group_converse", args)

group_converse_stream 

group_converse_stream(
    participants: list[str],
    topic: str,
    *,
    max_turns: int = 3,
    conversation_id: Optional[str] = None,
)

Stream a group conversation, yielding each perspective as it completes.

Example 
for event in client.group_converse_stream(
    participants=["ludo", "duy"],
    topic="What is the future of AI agents?",
):
    if event.get("_done"):
        print("conversation_id:", event["conversation_id"])
    else:
        print(event["user_name"], event["content"])

Yields dicts with keys: type, user_name, content, turn, user_id. Final yield: {"type": "done", "conversation_id": str, "_done": True}.

Source code in superme_sdk/services/_groups.py 
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
def group_converse_stream(
    self,
    participants: list[str],
    topic: str,
    *,
    max_turns: int = 3,
    conversation_id: Optional[str] = None,
):
    """Stream a group conversation, yielding each perspective as it completes.

    Example:
        ```python
        for event in client.group_converse_stream(
            participants=["ludo", "duy"],
            topic="What is the future of AI agents?",
        ):
            if event.get("_done"):
                print("conversation_id:", event["conversation_id"])
            else:
                print(event["user_name"], event["content"])
        ```

    Yields dicts with keys: type, user_name, content, turn, user_id.
    Final yield: ``{"type": "done", "conversation_id": str, "_done": True}``.
    """
    payload: dict[str, Any] = {
        "participants": participants,
        "topic": topic,
        "max_turns": max_turns,
    }
    if conversation_id is not None:
        payload["conversation_id"] = conversation_id

    with self._http.stream(
        "POST",
        "/mcp/chat/stream/group_converse",
        json=payload,
        headers={"Accept-Encoding": "identity"},
    ) as resp:
        if not resp.is_success:
            resp.read()
        self._check_rest_response(resp)

        buf = ""
        for raw_chunk in resp.iter_text():
            buf += raw_chunk
            while "\n" in buf:
                line, buf = buf.split("\n", 1)
                line = line.strip()
                if not line:
                    continue
                if line.startswith("data: "):
                    line = line[6:]
                elif line.startswith("data:"):
                    line = line[5:]
                try:
                    obj = json.loads(line)
                except (json.JSONDecodeError, ValueError):
                    continue
                if not isinstance(obj, dict):
                    continue
                if obj.get("type") == "done":
                    obj["_done"] = True
                yield obj
        # Flush any remaining data not terminated by a newline
        if buf.strip():
            line = buf.strip()
            if line.startswith("data: "):
                line = line[6:]
            elif line.startswith("data:"):
                line = line[5:]
            try:
                obj = json.loads(line)
                if isinstance(obj, dict):
                    if obj.get("type") == "done":
                        obj["_done"] = True
                    yield obj
            except (json.JSONDecodeError, ValueError):
                pass