MCPcopy
hub / github.com/ruc-datalab/DeepAnalyze / create_message

Method create_message

example/4c_competition/storage.py:134–161  ·  view source on GitHub ↗

Create a message record

(
        self,
        thread_id: str,
        role: str,
        content: str,
        file_ids: Optional[List[str]] = None,
        metadata: Optional[Dict] = None,
    )

Source from the content-addressed store, hash-verified

132 return False
133
134 def create_message(
135 self,
136 thread_id: str,
137 role: str,
138 content: str,
139 file_ids: Optional[List[str]] = None,
140 metadata: Optional[Dict] = None,
141 ) -> MessageObject:
142 """Create a message record"""
143 with self._lock:
144 if thread_id not in self.threads:
145 raise ValueError(f"Thread {thread_id} not found")
146
147 message_id = f"msg-{uuid.uuid4().hex[:24]}"
148 message = {
149 "id": message_id,
150 "object": "thread.message",
151 "created_at": int(time.time()),
152 "thread_id": thread_id,
153 "role": role,
154 "content": [{"type": "text", "text": {"value": content}}],
155 "file_ids": file_ids or [],
156 "assistant_id": None,
157 "run_id": None,
158 "metadata": metadata or {},
159 }
160 self.messages[thread_id].append(message)
161 return MessageObject(**message)
162
163 def list_messages(self, thread_id: str) -> List[MessageObject]:
164 """List messages in a thread"""

Callers

nothing calls this directly

Calls 2

MessageObjectClass · 0.90
appendMethod · 0.45

Tested by

no test coverage detected