Compare commits
1 Commits
mimo/code/
...
mimo/creat
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d5099a18c6 |
@@ -694,61 +694,15 @@ const SpatialMemory = (() => {
|
||||
}
|
||||
}
|
||||
|
||||
// ─── CONTEXT COMPACTION (issue #675) ──────────────────
|
||||
const COMPACT_CONTENT_MAXLEN = 80; // max chars for low-strength memories
|
||||
const COMPACT_STRENGTH_THRESHOLD = 0.5; // below this, content gets truncated
|
||||
const COMPACT_MAX_CONNECTIONS = 5; // cap connections per memory
|
||||
const COMPACT_POSITION_DECIMALS = 1; // round positions to 1 decimal
|
||||
|
||||
function _compactPosition(pos) {
|
||||
const factor = Math.pow(10, COMPACT_POSITION_DECIMALS);
|
||||
return pos.map(v => Math.round(v * factor) / factor);
|
||||
}
|
||||
|
||||
/**
|
||||
* Deterministically compact a memory for storage.
|
||||
* Same input always produces same output — no randomness.
|
||||
* Strong memories keep full fidelity; weak memories get truncated.
|
||||
*/
|
||||
function _compactMemory(o) {
|
||||
const strength = o.mesh.userData.strength || 0.7;
|
||||
const content = o.data.content || '';
|
||||
const connections = o.data.connections || [];
|
||||
|
||||
// Deterministic content truncation for weak memories
|
||||
let compactContent = content;
|
||||
if (strength < COMPACT_STRENGTH_THRESHOLD && content.length > COMPACT_CONTENT_MAXLEN) {
|
||||
compactContent = content.slice(0, COMPACT_CONTENT_MAXLEN) + '\u2026';
|
||||
}
|
||||
|
||||
// Cap connections (keep first N, deterministic)
|
||||
const compactConnections = connections.length > COMPACT_MAX_CONNECTIONS
|
||||
? connections.slice(0, COMPACT_MAX_CONNECTIONS)
|
||||
: connections;
|
||||
|
||||
return {
|
||||
id: o.data.id,
|
||||
content: compactContent,
|
||||
category: o.region,
|
||||
position: _compactPosition([o.mesh.position.x, o.mesh.position.y - 1.5, o.mesh.position.z]),
|
||||
source: o.data.source || 'unknown',
|
||||
timestamp: o.data.timestamp || o.mesh.userData.createdAt,
|
||||
strength: Math.round(strength * 100) / 100, // 2 decimal precision
|
||||
connections: compactConnections
|
||||
};
|
||||
}
|
||||
|
||||
// ─── PERSISTENCE ─────────────────────────────────────
|
||||
function exportIndex(options = {}) {
|
||||
const compact = options.compact !== false; // compact by default
|
||||
function exportIndex() {
|
||||
return {
|
||||
version: 1,
|
||||
exportedAt: new Date().toISOString(),
|
||||
compacted: compact,
|
||||
regions: Object.fromEntries(
|
||||
Object.entries(REGIONS).map(([k, v]) => [k, { label: v.label, center: v.center, radius: v.radius, color: v.color }])
|
||||
),
|
||||
memories: Object.values(_memoryObjects).map(o => compact ? _compactMemory(o) : {
|
||||
memories: Object.values(_memoryObjects).map(o => ({
|
||||
id: o.data.id,
|
||||
content: o.data.content,
|
||||
category: o.region,
|
||||
@@ -757,7 +711,7 @@ const SpatialMemory = (() => {
|
||||
timestamp: o.data.timestamp || o.mesh.userData.createdAt,
|
||||
strength: o.mesh.userData.strength || 0.7,
|
||||
connections: o.data.connections || []
|
||||
})
|
||||
}))
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
@@ -45,6 +45,7 @@ from nexus.perception_adapter import (
|
||||
)
|
||||
from nexus.experience_store import ExperienceStore
|
||||
from nexus.groq_worker import GroqWorker
|
||||
from nexus.heartbeat import write_heartbeat
|
||||
from nexus.trajectory_logger import TrajectoryLogger
|
||||
|
||||
logging.basicConfig(
|
||||
@@ -286,6 +287,13 @@ class NexusMind:
|
||||
|
||||
self.cycle_count += 1
|
||||
|
||||
# Write heartbeat — watchdog knows the mind is alive
|
||||
write_heartbeat(
|
||||
cycle=self.cycle_count,
|
||||
model=self.model,
|
||||
status="thinking",
|
||||
)
|
||||
|
||||
# Periodically distill old memories
|
||||
if self.cycle_count % 50 == 0 and self.cycle_count > 0:
|
||||
await self._distill_memories()
|
||||
@@ -383,6 +391,13 @@ class NexusMind:
|
||||
salience=1.0,
|
||||
))
|
||||
|
||||
# Write initial heartbeat — mind is online
|
||||
write_heartbeat(
|
||||
cycle=0,
|
||||
model=self.model,
|
||||
status="thinking",
|
||||
)
|
||||
|
||||
while self.running:
|
||||
try:
|
||||
await self.think_once()
|
||||
@@ -423,6 +438,13 @@ class NexusMind:
|
||||
log.info("Nexus Mind shutting down...")
|
||||
self.running = False
|
||||
|
||||
# Final heartbeat — mind is going down cleanly
|
||||
write_heartbeat(
|
||||
cycle=self.cycle_count,
|
||||
model=self.model,
|
||||
status="idle",
|
||||
)
|
||||
|
||||
# Final stats
|
||||
stats = self.trajectory_logger.get_session_stats()
|
||||
log.info(f"Session stats: {json.dumps(stats, indent=2)}")
|
||||
|
||||
Reference in New Issue
Block a user