Function addThreadMessage

mcp/src/server/store.ts:197–224

(
      annotationId: string,
      role: "human" | "agent",
      content: string
    )

    },

    addThreadMessage(
      annotationId: string,
      role: "human" | "agent",
      content: string
    ): Annotation | undefined {
      const annotation = annotations.get(annotationId);
      if (!annotation) return undefined;

      const message: ThreadMessage = {
        id: generateId(),
        role,
        content,
        timestamp: Date.now(),
      };

      if (!annotation.thread) {
        annotation.thread = [];
      }
      annotation.thread.push(message);
      annotation.updatedAt = new Date().toISOString();

      if (annotation.sessionId) {
        const event = eventBus.emit("thread.message", annotation.sessionId, message);
        events.push(event);
      }

      return annotation;
    },

    getPendingAnnotations(sessionId: string): Annotation[] {
      return Array.from(annotations.values()).filter(