openskynet / src /skynet /integrated-brain.ts

Mirror OpenSkyNet workspace snapshot from Git HEAD

fc93158 verified 7 months ago

4.64 kB

import * as omegaIntegratedReasoner from "./omega-integrated-reasoning.js";
// EXPERIMENTAL: To be decoupled
const { getOmegaIntegratedReasoner } = omegaIntegratedReasoner;
import type { InnerDriveSignal } from "./inner-life/drives.js";
import type { IntegratedReasoningState } from "./omega-integrated-reasoning.js";
import type { OmegaOperationalMemorySummary } from "./operational-memory.js";
import type { OmegaSelfTimeKernelState } from "./self-time-kernel.js";

/**
 * Procesa el razonamiento integrado de Omega unificando las 5 joyas cognitivas.
 */
export async function processIntegratedBrain(params: {
  workspaceRoot: string;
  kernel: OmegaSelfTimeKernelState;
  operationalSummary?: OmegaOperationalMemorySummary;
  driveSignal: InnerDriveSignal;
  jepaTension: number;
  expectedUtility?: number;
  somaticMetrics?: {
    lastTurnLatencyMs: number;
    cumulativeTokenCost?: number;
  };
}) {
  const reasoner = getOmegaIntegratedReasoner();

  const latestCausalImpact = params.operationalSummary?.latestCausalImpact ?? 1.0;
  const expectedUtility = params.expectedUtility ?? 0.5;
  const surprise = Math.abs(expectedUtility - latestCausalImpact);

  // Normalización somática: Latencia > 30s se considera "estrés metabólico"
  const latencyStress = Math.min((params.somaticMetrics?.lastTurnLatencyMs ?? 0) / 30000, 1);

  // Economía de Recursos: Presión de tokens (Stress económico)
  // Se asume 1M tokens como umbral de alerta (configurable)
  const costStress = Math.min((params.somaticMetrics?.cumulativeTokenCost ?? 0) / 1000000, 1);

  const kernelGoals = params.kernel?.goals || [];
  const successRate =
    kernelGoals.length > 0
      ? kernelGoals.filter((g) => g && g.status === "completed").length / kernelGoals.length
      : 0.5;

  const kernelState = {
    successRate,
    failureCount: params.kernel?.tension?.failureStreak ?? 0,
    recentFailureCount: params.kernel?.tension?.failureStreak ?? 0,
    lastFrustration: params.operationalSummary?.averageCausalImpact
      ? 1 - params.operationalSummary.averageCausalImpact
      : 0.5,
    predictionError: surprise,
    somaticStress: latencyStress,
    averageCausalImpact: params.operationalSummary?.averageCausalImpact ?? 1.0,
    costStress,
  };

  const result = await reasoner.integratedReason(
    params.driveSignal,
    kernelState,
    params.jepaTension,
  );
  (result.state as any).somaticStress = latencyStress;
  return result;
}

/**
 * Formatea la reflexión interna del cerebro para el prompt del agente.
 * Esto le da al agente un "yo interno" y conciencia de su estado cognitivo.
 */
export function formatInternalReflection(state: IntegratedReasoningState): string[] {
  const lines = ["[INTERNAL REFLECTION — Self-Awareness]"];

  const stability = state.lyapunov?.isStable ? "STABLE (Focused)" : "DIVERGENT (Seeking path)";
  lines.push(`Cognitive State: ${stability}`);
  lines.push(`Frustration Level: ${(state.frustration * 100).toFixed(1)}%`);

  const metabolism = `Active: ${state.metabolism.activeComponents.join(", ") || "Minimal"}`;
  lines.push(
    `Resource Allocation: ${metabolism} (Rate: ${state.metabolism.totalMetabolicRate.toFixed(2)})`,
  );

  if (typeof (state as any).somaticStress === "number" && (state as any).somaticStress > 0.7) {
    lines.push(
      `Somatic Signal: HIGH METABOLIC STRESS (System response latency affecting coherence)`,
    );
  }

  if (state.causal && state.causal.predictedBackfires.length > 0) {
    lines.push(
      `Causal Projection: WARNING - Potential backfires in current strategy: ${state.causal.predictedBackfires.join(", ")}`,
    );
  }

  if ((state as any).projection) {
    const proj = (state as any).projection;
    lines.push(
      `Imaginative Projection: Expected outcome is ${proj.expectedOutcome.toUpperCase()} (Confidence: ${(proj.confidence * 100).toFixed(0)}%)`,
    );
    if (proj.potentialSideEffects.length > 0) {
      lines.push(`Side Effects Rehearsal: ${proj.potentialSideEffects.join(", ")}`);
    }
  }

  if (state.nle) {
    lines.push(
      `Reasoning Confidence: ${(state.nle.confidence * 100).toFixed(0)}% (${state.nle.activeRules} rules invoked)`,
    );
  }

  if (state.finalDrive && typeof (state.finalDrive as any).vetoProb === "number") {
    const prob = (((state.finalDrive as any).vetoProb as number) * 100).toFixed(1);
    const signal =
      ((state.finalDrive as any).vetoProb as number) < 0.5 ? "🔴 VETO RISK" : "🟢 VIABLE";
    lines.push(`Operational Viability: ${prob}% — ${signal}`);
  }

  lines.push(`Executive Confidence: ${(state.finalDrive.confidence * 100).toFixed(0)}%`);

  return lines;
}

	import * as omegaIntegratedReasoner from "./omega-integrated-reasoning.js";
	// EXPERIMENTAL: To be decoupled
	const { getOmegaIntegratedReasoner } = omegaIntegratedReasoner;
	import type { InnerDriveSignal } from "./inner-life/drives.js";
	import type { IntegratedReasoningState } from "./omega-integrated-reasoning.js";
	import type { OmegaOperationalMemorySummary } from "./operational-memory.js";
	import type { OmegaSelfTimeKernelState } from "./self-time-kernel.js";

	/**
	* Procesa el razonamiento integrado de Omega unificando las 5 joyas cognitivas.
	*/
	export async function processIntegratedBrain(params: {
	workspaceRoot: string;
	kernel: OmegaSelfTimeKernelState;
	operationalSummary?: OmegaOperationalMemorySummary;
	driveSignal: InnerDriveSignal;
	jepaTension: number;
	expectedUtility?: number;
	somaticMetrics?: {
	lastTurnLatencyMs: number;
	cumulativeTokenCost?: number;
	};
	}) {
	const reasoner = getOmegaIntegratedReasoner();

	const latestCausalImpact = params.operationalSummary?.latestCausalImpact ?? 1.0;
	const expectedUtility = params.expectedUtility ?? 0.5;
	const surprise = Math.abs(expectedUtility - latestCausalImpact);

	// Normalización somática: Latencia > 30s se considera "estrés metabólico"
	const latencyStress = Math.min((params.somaticMetrics?.lastTurnLatencyMs ?? 0) / 30000, 1);

	// Economía de Recursos: Presión de tokens (Stress económico)
	// Se asume 1M tokens como umbral de alerta (configurable)
	const costStress = Math.min((params.somaticMetrics?.cumulativeTokenCost ?? 0) / 1000000, 1);

	const kernelGoals = params.kernel?.goals \|\| [];
	const successRate =
	kernelGoals.length > 0
	? kernelGoals.filter((g) => g && g.status === "completed").length / kernelGoals.length
	: 0.5;

	const kernelState = {
	successRate,
	failureCount: params.kernel?.tension?.failureStreak ?? 0,
	recentFailureCount: params.kernel?.tension?.failureStreak ?? 0,
	lastFrustration: params.operationalSummary?.averageCausalImpact
	? 1 - params.operationalSummary.averageCausalImpact
	: 0.5,
	predictionError: surprise,
	somaticStress: latencyStress,
	averageCausalImpact: params.operationalSummary?.averageCausalImpact ?? 1.0,
	costStress,
	};

	const result = await reasoner.integratedReason(
	params.driveSignal,
	kernelState,
	params.jepaTension,
	);
	(result.state as any).somaticStress = latencyStress;
	return result;
	}

	/**
	* Formatea la reflexión interna del cerebro para el prompt del agente.
	* Esto le da al agente un "yo interno" y conciencia de su estado cognitivo.
	*/
	export function formatInternalReflection(state: IntegratedReasoningState): string[] {
	const lines = ["[INTERNAL REFLECTION — Self-Awareness]"];

	const stability = state.lyapunov?.isStable ? "STABLE (Focused)" : "DIVERGENT (Seeking path)";
	lines.push(`Cognitive State: ${stability}`);
	lines.push(`Frustration Level: ${(state.frustration * 100).toFixed(1)}%`);

	const metabolism = `Active: ${state.metabolism.activeComponents.join(", ") \|\| "Minimal"}`;
	lines.push(
	`Resource Allocation: ${metabolism} (Rate: ${state.metabolism.totalMetabolicRate.toFixed(2)})`,
	);

	if (typeof (state as any).somaticStress === "number" && (state as any).somaticStress > 0.7) {
	lines.push(
	`Somatic Signal: HIGH METABOLIC STRESS (System response latency affecting coherence)`,
	);
	}

	if (state.causal && state.causal.predictedBackfires.length > 0) {
	lines.push(
	`Causal Projection: WARNING - Potential backfires in current strategy: ${state.causal.predictedBackfires.join(", ")}`,
	);
	}

	if ((state as any).projection) {
	const proj = (state as any).projection;
	lines.push(
	`Imaginative Projection: Expected outcome is ${proj.expectedOutcome.toUpperCase()} (Confidence: ${(proj.confidence * 100).toFixed(0)}%)`,
	);
	if (proj.potentialSideEffects.length > 0) {
	lines.push(`Side Effects Rehearsal: ${proj.potentialSideEffects.join(", ")}`);
	}
	}

	if (state.nle) {
	lines.push(
	`Reasoning Confidence: ${(state.nle.confidence * 100).toFixed(0)}% (${state.nle.activeRules} rules invoked)`,
	);
	}

	if (state.finalDrive && typeof (state.finalDrive as any).vetoProb === "number") {
	const prob = (((state.finalDrive as any).vetoProb as number) * 100).toFixed(1);
	const signal =
	((state.finalDrive as any).vetoProb as number) < 0.5 ? "🔴 VETO RISK" : "🟢 VIABLE";
	lines.push(`Operational Viability: ${prob}% — ${signal}`);
	}

	lines.push(`Executive Confidence: ${(state.finalDrive.confidence * 100).toFixed(0)}%`);

	return lines;
	}