Conversaciones

// Primer mensaje — se crea una conversacion nueva
const stream1 = thaliq.agent.stream('Hola, necesito ayuda');
for await (const event of stream1) { /* ... */ }

// El conversationId se guarda automaticamente
console.log(stream1.conversationId); // 'abc-123-...'

// Crear una nueva conversacion
const conv = thaliq.conversations.create();

// Primer mensaje
const stream1 = thaliq.agent.stream('Hola', {
  conversationId: conv.id,
});
const response1 = await stream1.finalResponse();

// Segundo mensaje (misma conversacion, mantiene contexto)
const stream2 = thaliq.agent.stream('Dame mas detalles', {
  conversationId: conv.id,
});
const response2 = await stream2.finalResponse();

// Crear nueva conversacion
const conv = thaliq.conversations.create();
console.log(conv.id);        // UUID generado
console.log(conv.createdAt); // Date

// Ver conversacion activa
console.log(thaliq.conversations.active); // ConversationRef | null

// Cambiar conversacion activa
thaliq.conversations.setActive(conv.id);

// Historial de conversaciones (esta sesion)
console.log(thaliq.conversations.history); // ConversationRef[]

// Limpiar historial
thaliq.conversations.clear();

const stream = thaliq.agent.stream('Analiza mis datos', {
  conversationId: 'conv-123',
});

const response = await stream.finalResponse();

// El messageId viene en la metadata
if (response.metadata.messageId) {
  await thaliq.agent.feedback({
    conversationId: 'conv-123',
    messageId: response.metadata.messageId,
    feedback: 'positive',
  });
}

// Stream 1 — recibe la accion
const stream = thaliq.agent.stream('Quiero agendar una cita', {
  conversationId: 'conv-123',
});

let pendingAction;
for await (const event of stream) {
  if (event.type === 'action') {
    pendingAction = event;
    break; // El stream se cierra
  }
}

// El usuario decide en tu UI...
const userAccepted = true;

// Stream 2 — resume con la respuesta de la accion
const resumeStream = thaliq.agent.stream('Quiero agendar una cita', {
  conversationId: 'conv-123',
  actionResponse: {
    instructionId: pendingAction.instructionId,
    accepted: userAccepted,
  },
});

for await (const event of resumeStream) {
  // Siguen llegando content.delta, tool.start/end, etc.
  // El backend persiste todo (texto pre-accion + accion resuelta + tool calls + texto post-accion)
  // como UN SOLO mensaje del asistente con multiples parts en orden cronologico.
}