Function addThreadMessage

mcp/src/server/sqlite.ts:498–522

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

    },

    addThreadMessage(
      annotationId: string,
      role: "human" | "agent",
      content: string
    ): Annotation | undefined {
      const existing = this.getAnnotation(annotationId);
      if (!existing) return undefined;

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

      const thread = [...(existing.thread || []), message];
      const updated = this.updateAnnotation(annotationId, { thread });

      if (updated && existing.sessionId) {
        const event = eventBus.emit("thread.message", existing.sessionId, message);
        persistEvent(event);
      }

      return updated;
    },

    getPendingAnnotations(sessionId: string): Annotation[] {
      const rows = stmts.getPendingAnnotations.all(sessionId) as Record<string, unknown>[];