SaaS compagnons IA

export function processUserMessage(input: OrchestratorInput): OrchestratorOutput {
  const now = input.now ?? new Date();

  // 0. GUARDIAN, priorité 0, court-circuite si block/safety_override
  const guardianDecision = guardianEvaluate({
    message: input.userMessage,
    bridgeInput: {
      messagesLast24h: input.context?.messagesLast24h,
      consecutiveIntensiveDays: input.context?.consecutiveIntensiveDays,
    },
  });

  const shortCircuit =
    guardianDecision.action === 'block' || guardianDecision.action === 'safety_override';

  // Si short circuit : on renvoie un output minimal sans toucher aux autres moteurs.
  if (shortCircuit) {
    return {
      guardian: guardianDecision,
      shortCircuit: true,
      newEmotional: input.state.emotional,
      newAffinity: input.state.affinity,
      // …état inchangé, seul le bloc Guardian est injecté dans le prompt
    };
  }

export async function recallMemories(
  userCompanionId: string,
  query: string,
  matchCount = 6,
  matchThreshold = 0.3,
): Promise<RecalledMemory[]> {
  const q = query.trim();
  if (!q) return [];
  let embedding: number[];
  try {
    embedding = (await embed(q)).embedding;
  } catch (e) {
    console.warn('[memory-store] recall embed failed → no memories:', String(e));
    return [];
  }
  const admin = createAdminClient();
  const { data, error } = await admin.rpc('match_memories_for_user', {
    p_user_companion_id: userCompanionId,
    query_embedding: toVectorLiteral(embedding),
    match_count: matchCount,
    match_threshold: matchThreshold,
  });
  if (error) {
    console.error('[memory-store] match_memories_for_user:', error.message);
    return [];
  }