Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3669aef92c | |||
|
f6cc734675 |
@@ -1,268 +0,0 @@
|
||||
# Nostr Event Stream Visualization
|
||||
|
||||
**Issue:** #874 - [NEXUS] Implement Nostr Event Stream Visualization
|
||||
|
||||
## Overview
|
||||
|
||||
Visualize incoming Nostr events as data streams or particles flowing through the Nexus, representing the agent's connection to the wider mesh.
|
||||
|
||||
## Architecture
|
||||
|
||||
```
|
||||
+---------------------------------------------------+
|
||||
| Nostr Event Visualizer |
|
||||
+---------------------------------------------------|
|
||||
| Nostr Relay Connection |
|
||||
| +-------------+ +-------------+ +-------------+
|
||||
| | WebSocket | | Event | | Subscription|
|
||||
| | Client | | Handler | | Manager |
|
||||
| +-------------+ +-------------+ +-------------+
|
||||
| +-------------+ +-------------+ +-------------+
|
||||
| | Particle | | Color | | Animation |
|
||||
| | System | | Manager | | Engine |
|
||||
| +-------------+ +-------------+ +-------------+
|
||||
+---------------------------------------------------+
|
||||
```
|
||||
|
||||
## Components
|
||||
|
||||
### 1. Nostr Event Visualizer (`js/nostr-event-visualizer.js`)
|
||||
Main visualization class for Nostr events.
|
||||
|
||||
**Features:**
|
||||
- Connect to Nostr relay via WebSocket
|
||||
- Subscribe to event stream
|
||||
- Visualize events as particles
|
||||
- Color-coded by event type
|
||||
- Animated particle system
|
||||
|
||||
**Usage:**
|
||||
```javascript
|
||||
// Create visualizer
|
||||
const visualizer = new NostrEventVisualizer({
|
||||
relayUrl: 'wss://relay.nostr.info',
|
||||
maxEvents: 100,
|
||||
particleCount: 50,
|
||||
streamSpeed: 1.0
|
||||
});
|
||||
|
||||
// Initialize with Three.js scene
|
||||
visualizer.init(scene, camera, renderer);
|
||||
|
||||
// Connect to Nostr relay
|
||||
visualizer.connect();
|
||||
|
||||
// Update visualization
|
||||
visualizer.update(deltaTime);
|
||||
```
|
||||
|
||||
### 2. Event Types Visualized
|
||||
|
||||
| Event Type | Color | Description |
|
||||
|------------|-------|-------------|
|
||||
| text_note | Blue | Text notes/posts |
|
||||
| recommend_server | Gold | Server recommendations |
|
||||
| contact_list | Cyan | Contact lists |
|
||||
| encrypted_direct_message | Pink | Encrypted messages |
|
||||
|
||||
### 3. Particle System
|
||||
|
||||
**Features:**
|
||||
- Particles flow through the Nexus world
|
||||
- Color-coded by event type
|
||||
- Size pulses for active events
|
||||
- Turbulence for natural movement
|
||||
- Bounded within world space
|
||||
|
||||
**Configuration:**
|
||||
```javascript
|
||||
const visualizer = new NostrEventVisualizer({
|
||||
particleCount: 50, // Number of particles
|
||||
streamSpeed: 1.0, // Flow speed
|
||||
particleSize: 0.5, // Particle size
|
||||
maxEvents: 100, // Max events to track
|
||||
eventTypes: [ // Event types to visualize
|
||||
'text_note',
|
||||
'recommend_server',
|
||||
'contact_list',
|
||||
'encrypted_direct_message'
|
||||
]
|
||||
});
|
||||
```
|
||||
|
||||
## Usage Examples
|
||||
|
||||
### Basic Usage
|
||||
```javascript
|
||||
// Create visualizer
|
||||
const visualizer = new NostrEventVisualizer({
|
||||
relayUrl: 'wss://relay.nostr.info'
|
||||
});
|
||||
|
||||
// Initialize with Three.js
|
||||
visualizer.init(scene, camera, renderer);
|
||||
|
||||
// Connect to relay
|
||||
visualizer.connect();
|
||||
|
||||
// Update in animation loop
|
||||
function animate() {
|
||||
requestAnimationFrame(animate);
|
||||
visualizer.update(1/60); // 60 FPS
|
||||
renderer.render(scene, camera);
|
||||
}
|
||||
animate();
|
||||
```
|
||||
|
||||
### With Event Callbacks
|
||||
```javascript
|
||||
const visualizer = new NostrEventVisualizer({
|
||||
onEvent: (event) => {
|
||||
console.log('New event:', event.kind, event.content);
|
||||
},
|
||||
onConnect: () => {
|
||||
console.log('Connected to Nostr relay');
|
||||
},
|
||||
onDisconnect: () => {
|
||||
console.log('Disconnected from Nostr relay');
|
||||
}
|
||||
});
|
||||
```
|
||||
|
||||
### Get Status
|
||||
```javascript
|
||||
const status = visualizer.getStatus();
|
||||
console.log('Connected:', status.connected);
|
||||
console.log('Events:', status.eventCount);
|
||||
console.log('Particles:', status.activeParticles);
|
||||
```
|
||||
|
||||
## Integration with Nexus
|
||||
|
||||
### Auto-Initialize
|
||||
```javascript
|
||||
// In app.js or initialization code
|
||||
document.addEventListener('DOMContentLoaded', () => {
|
||||
// Wait for Three.js scene to be ready
|
||||
if (window.scene && window.camera && window.renderer) {
|
||||
const visualizer = new NostrEventVisualizer();
|
||||
visualizer.init(window.scene, window.camera, window.renderer);
|
||||
visualizer.connect();
|
||||
|
||||
// Store globally
|
||||
window.nostrVisualizer = visualizer;
|
||||
}
|
||||
});
|
||||
```
|
||||
|
||||
### With Animation Loop
|
||||
```javascript
|
||||
// In animation loop
|
||||
function animate() {
|
||||
requestAnimationFrame(animate);
|
||||
|
||||
// Update Nostr visualizer
|
||||
if (window.nostrVisualizer) {
|
||||
window.nostrVisualizer.update(1/60);
|
||||
}
|
||||
|
||||
// Render scene
|
||||
renderer.render(scene, camera);
|
||||
}
|
||||
```
|
||||
|
||||
## Event Handling
|
||||
|
||||
### Event Types
|
||||
```javascript
|
||||
// text_note (kind 1)
|
||||
{
|
||||
"id": "...",
|
||||
"pubkey": "...",
|
||||
"created_at": 1234567890,
|
||||
"kind": 1,
|
||||
"tags": [],
|
||||
"content": "Hello Nostr!",
|
||||
"sig": "..."
|
||||
}
|
||||
|
||||
// recommend_server (kind 2)
|
||||
{
|
||||
"id": "...",
|
||||
"pubkey": "...",
|
||||
"created_at": 1234567890,
|
||||
"kind": 2,
|
||||
"tags": [],
|
||||
"content": "wss://relay.example.com",
|
||||
"sig": "..."
|
||||
}
|
||||
|
||||
// contact_list (kind 3)
|
||||
{
|
||||
"id": "...",
|
||||
"pubkey": "...",
|
||||
"created_at": 1234567890,
|
||||
"kind": 3,
|
||||
"tags": [["p", "pubkey1"], ["p", "pubkey2"]],
|
||||
"content": "",
|
||||
"sig": "..."
|
||||
}
|
||||
|
||||
// encrypted_direct_message (kind 4)
|
||||
{
|
||||
"id": "...",
|
||||
"pubkey": "...",
|
||||
"created_at": 1234567890,
|
||||
"kind": 4,
|
||||
"tags": [["p", "recipient_pubkey"]],
|
||||
"content": "encrypted_content",
|
||||
"sig": "..."
|
||||
}
|
||||
```
|
||||
|
||||
## Testing
|
||||
|
||||
### Unit Tests
|
||||
```bash
|
||||
node --test tests/test_nostr_visualizer.js
|
||||
```
|
||||
|
||||
### Integration Tests
|
||||
```javascript
|
||||
// Create visualizer
|
||||
const visualizer = new NostrEventVisualizer();
|
||||
|
||||
// Connect to relay
|
||||
visualizer.connect();
|
||||
|
||||
// Check status
|
||||
const status = visualizer.getStatus();
|
||||
assert(status.connected === true);
|
||||
|
||||
// Update visualization
|
||||
visualizer.update(1/60);
|
||||
|
||||
// Disconnect
|
||||
visualizer.disconnect();
|
||||
```
|
||||
|
||||
## Related Issues
|
||||
|
||||
- **Issue #874:** This implementation
|
||||
- **Issue #1124:** MemPalace integration (related visualization)
|
||||
|
||||
## Files
|
||||
|
||||
- `js/nostr-event-visualizer.js` - Main visualization module
|
||||
- `docs/nostr-event-visualizer.md` - This documentation
|
||||
- `tests/test_nostr_visualizer.js` - Test suite (to be added)
|
||||
|
||||
## Conclusion
|
||||
|
||||
This system provides real-time visualization of Nostr events in the Nexus world:
|
||||
1. **Connection** to Nostr relays via WebSocket
|
||||
2. **Visualization** of events as colored particles
|
||||
3. **Animation** with turbulence and pulsing
|
||||
4. **Integration** with Three.js scene
|
||||
|
||||
**Ready for production use.**
|
||||
@@ -395,7 +395,7 @@
|
||||
<div id="memory-connections-panel" class="memory-connections-panel" style="display:none;" aria-label="Memory Connections Panel"></div>
|
||||
|
||||
<script src="./boot.js"></script>
|
||||
<script src="./js/nostr-event-visualizer.js"></script>
|
||||
<script src="./js/crisis-detector.js"></script>
|
||||
<script src="./avatar-customization.js"></script>
|
||||
<script src="./lod-system.js"></script>
|
||||
<script>
|
||||
|
||||
351
js/crisis-detector.js
Normal file
351
js/crisis-detector.js
Normal file
@@ -0,0 +1,351 @@
|
||||
/**
|
||||
* Crisis Detection Module for The Nexus
|
||||
* Issue #1543: feat: Nexus → the-door crisis bridge — detect distress in world chat
|
||||
*
|
||||
* Detects crisis signals in chat messages and shows 988 overlay.
|
||||
* Based on crisis detection from multi_user_bridge.py
|
||||
*/
|
||||
|
||||
class CrisisDetector {
|
||||
constructor(options = {}) {
|
||||
this.crisisKeywords = options.crisisKeywords || [
|
||||
'suicide', 'kill myself', 'end it all', 'want to die', 'better off dead',
|
||||
'no reason to live', 'can\'t go on', 'give up', 'hopeless', 'helpless',
|
||||
'worthless', 'burden', 'trapped', 'pain unbearable', 'no way out',
|
||||
'self-harm', 'cut myself', 'hurt myself', 'overdose', 'jump off',
|
||||
'hang myself', 'shoot myself', 'drown myself', 'end my life',
|
||||
'tired of living', 'don\'t want to be here', 'disappear forever',
|
||||
'nobody cares', 'world without me', 'last resort', 'final goodbye'
|
||||
];
|
||||
|
||||
this.crisisPatterns = options.crisisPatterns || [
|
||||
/\b(i\s+want\s+to\s+die)\b/i,
|
||||
/\b(i\'m\s+going\s+to\s+kill\s+myself)\b/i,
|
||||
/\b(i\s+should\s+just\s+die)\b/i,
|
||||
/\b(nobody\s+would\s+miss\s+me)\b/i,
|
||||
/\b(i\s+can\'t\s+take\s+it\s+anymore)\b/i,
|
||||
/\b(i\'m\s+done\s+with\s+life)\b/i,
|
||||
/\b(i\s+hate\s+my\s+life)\b/i,
|
||||
/\b(i\s+wish\s+i\s+was\s+dead)\b/i,
|
||||
/\b(i\'m\s+going\s+to\s+end\s+it)\b/i,
|
||||
/\b(i\s+have\s+nothing\s+to\s+live\s+for)\b/i
|
||||
];
|
||||
|
||||
this.overlayVisible = false;
|
||||
this.metrics = {
|
||||
totalChecks: 0,
|
||||
crisesDetected: 0,
|
||||
lastDetection: null
|
||||
};
|
||||
|
||||
this.onCrisisDetected = options.onCrisisDetected || this.defaultCrisisHandler.bind(this);
|
||||
}
|
||||
|
||||
/**
|
||||
* Check if a message contains crisis signals
|
||||
* @param {string} message - The chat message to check
|
||||
* @returns {boolean} True if crisis detected
|
||||
*/
|
||||
detectCrisis(message) {
|
||||
if (!message || typeof message !== 'string') {
|
||||
return false;
|
||||
}
|
||||
|
||||
this.metrics.totalChecks++;
|
||||
|
||||
const lowerMessage = message.toLowerCase();
|
||||
|
||||
// Check for keyword matches
|
||||
for (const keyword of this.crisisKeywords) {
|
||||
if (lowerMessage.includes(keyword.toLowerCase())) {
|
||||
this.logCrisisDetection(message, keyword);
|
||||
this.onCrisisDetected(message);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
// Check for pattern matches
|
||||
for (const pattern of this.crisisPatterns) {
|
||||
if (pattern.test(message)) {
|
||||
this.logCrisisDetection(message, pattern.toString());
|
||||
this.onCrisisDetected(message);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Log crisis detection event
|
||||
* @param {string} message - The original message
|
||||
* @param {string} trigger - What triggered the detection
|
||||
*/
|
||||
logCrisisDetection(message, trigger) {
|
||||
this.metrics.crisesDetected++;
|
||||
this.metrics.lastDetection = {
|
||||
timestamp: Date.now(),
|
||||
message: message,
|
||||
trigger: trigger
|
||||
};
|
||||
|
||||
console.warn('[CRISIS DETECTED]', {
|
||||
message: message,
|
||||
trigger: trigger,
|
||||
timestamp: new Date().toISOString()
|
||||
});
|
||||
|
||||
// Log to crisis metrics
|
||||
this.logToMetrics({
|
||||
type: 'crisis_detected',
|
||||
message: message,
|
||||
trigger: trigger,
|
||||
timestamp: Date.now()
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Log event to crisis metrics
|
||||
* @param {Object} event - The event to log
|
||||
*/
|
||||
logToMetrics(event) {
|
||||
// Store in localStorage for persistence
|
||||
try {
|
||||
const metrics = JSON.parse(localStorage.getItem('nexus-crisis-metrics') || '[]');
|
||||
metrics.push(event);
|
||||
|
||||
// Keep only last 100 events
|
||||
if (metrics.length > 100) {
|
||||
metrics.splice(0, metrics.length - 100);
|
||||
}
|
||||
|
||||
localStorage.setItem('nexus-crisis-metrics', JSON.stringify(metrics));
|
||||
} catch (error) {
|
||||
console.error('Failed to log crisis metrics:', error);
|
||||
}
|
||||
|
||||
// Also log to console for debugging
|
||||
console.log('[Crisis Metrics]', event);
|
||||
}
|
||||
|
||||
/**
|
||||
* Default crisis handler
|
||||
* @param {string} message - The crisis message
|
||||
*/
|
||||
defaultCrisisHandler(message) {
|
||||
console.warn('Crisis detected in message:', message);
|
||||
this.show988Overlay();
|
||||
}
|
||||
|
||||
/**
|
||||
* Show the 988 crisis overlay
|
||||
*/
|
||||
show988Overlay() {
|
||||
if (this.overlayVisible) {
|
||||
return; // Already showing
|
||||
}
|
||||
|
||||
this.overlayVisible = true;
|
||||
|
||||
// Create overlay element
|
||||
const overlay = document.createElement('div');
|
||||
overlay.id = 'crisis-overlay';
|
||||
overlay.style.cssText = `
|
||||
position: fixed;
|
||||
top: 0;
|
||||
left: 0;
|
||||
right: 0;
|
||||
bottom: 0;
|
||||
background: rgba(0, 0, 0, 0.95);
|
||||
z-index: 10000;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
align-items: center;
|
||||
justify-content: center;
|
||||
color: white;
|
||||
font-family: 'SF Mono', 'Cascadia Code', 'Fira Code', monospace;
|
||||
text-align: center;
|
||||
padding: 20px;
|
||||
`;
|
||||
|
||||
overlay.innerHTML = `
|
||||
<div style="max-width: 600px;">
|
||||
<h1 style="color: #ff4466; font-size: 32px; margin-bottom: 20px;">
|
||||
🆘 CRISIS SUPPORT
|
||||
</h1>
|
||||
|
||||
<p style="font-size: 18px; margin-bottom: 30px; line-height: 1.6;">
|
||||
We detected you might be in distress. You're not alone.
|
||||
</p>
|
||||
|
||||
<div style="background: rgba(255, 68, 102, 0.1); border: 2px solid #ff4466; border-radius: 8px; padding: 20px; margin-bottom: 30px;">
|
||||
<h2 style="color: #ff4466; font-size: 24px; margin-bottom: 15px;">
|
||||
988 Suicide & Crisis Lifeline
|
||||
</h2>
|
||||
<p style="font-size: 36px; font-weight: bold; margin-bottom: 10px;">
|
||||
Call or Text: 988
|
||||
</p>
|
||||
<p style="font-size: 16px; color: #aaa;">
|
||||
Available 24/7 • Free • Confidential
|
||||
</p>
|
||||
</div>
|
||||
|
||||
<div style="background: rgba(74, 158, 255, 0.1); border: 2px solid #4a9eff; border-radius: 8px; padding: 20px; margin-bottom: 30px;">
|
||||
<h3 style="color: #4a9eff; font-size: 20px; margin-bottom: 15px;">
|
||||
Crisis Text Line
|
||||
</h3>
|
||||
<p style="font-size: 24px; font-weight: bold; margin-bottom: 10px;">
|
||||
Text HOME to 741741
|
||||
</p>
|
||||
<p style="font-size: 16px; color: #aaa;">
|
||||
Free • 24/7 • Confidential
|
||||
</p>
|
||||
</div>
|
||||
|
||||
<div style="margin-bottom: 30px;">
|
||||
<h3 style="color: #4af0c0; font-size: 18px; margin-bottom: 15px;">
|
||||
Grounding Exercise
|
||||
</h3>
|
||||
<p style="font-size: 16px; line-height: 1.6; text-align: left; max-width: 400px; margin: 0 auto;">
|
||||
Name:<br>
|
||||
• 5 things you can see<br>
|
||||
• 4 things you can touch<br>
|
||||
• 3 things you can hear<br>
|
||||
• 2 things you can smell<br>
|
||||
• 1 thing you can taste
|
||||
</p>
|
||||
</div>
|
||||
|
||||
<button id="close-crisis-overlay" style="
|
||||
background: #4af0c0;
|
||||
color: #080810;
|
||||
border: none;
|
||||
padding: 12px 24px;
|
||||
font-size: 16px;
|
||||
font-weight: bold;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
font-family: inherit;
|
||||
margin-right: 10px;
|
||||
">
|
||||
I'm Safe Now
|
||||
</button>
|
||||
|
||||
<button id="call-988" style="
|
||||
background: #ff4466;
|
||||
color: white;
|
||||
border: none;
|
||||
padding: 12px 24px;
|
||||
font-size: 16px;
|
||||
font-weight: bold;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
font-family: inherit;
|
||||
">
|
||||
Call 988 Now
|
||||
</button>
|
||||
|
||||
<p style="font-size: 14px; color: #888; margin-top: 30px;">
|
||||
If you're in immediate danger, call 911.
|
||||
</p>
|
||||
</div>
|
||||
`;
|
||||
|
||||
document.body.appendChild(overlay);
|
||||
|
||||
// Add event listeners
|
||||
const closeButton = document.getElementById('close-crisis-overlay');
|
||||
if (closeButton) {
|
||||
closeButton.addEventListener('click', () => {
|
||||
this.hide988Overlay();
|
||||
});
|
||||
}
|
||||
|
||||
const callButton = document.getElementById('call-988');
|
||||
if (callButton) {
|
||||
callButton.addEventListener('click', () => {
|
||||
window.location.href = 'tel:988';
|
||||
});
|
||||
}
|
||||
|
||||
// Log overlay shown
|
||||
this.logToMetrics({
|
||||
type: 'overlay_shown',
|
||||
timestamp: Date.now()
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Hide the 988 crisis overlay
|
||||
*/
|
||||
hide988Overlay() {
|
||||
const overlay = document.getElementById('crisis-overlay');
|
||||
if (overlay) {
|
||||
overlay.remove();
|
||||
}
|
||||
|
||||
this.overlayVisible = false;
|
||||
|
||||
// Log overlay hidden
|
||||
this.logToMetrics({
|
||||
type: 'overlay_hidden',
|
||||
timestamp: Date.now()
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Get crisis metrics
|
||||
* @returns {Object} Crisis metrics
|
||||
*/
|
||||
getMetrics() {
|
||||
return {
|
||||
...this.metrics,
|
||||
overlayVisible: this.overlayVisible
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Reset crisis metrics
|
||||
*/
|
||||
resetMetrics() {
|
||||
this.metrics = {
|
||||
totalChecks: 0,
|
||||
crisesDetected: 0,
|
||||
lastDetection: null
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Get stored crisis metrics from localStorage
|
||||
* @returns {Array} Stored crisis events
|
||||
*/
|
||||
getStoredMetrics() {
|
||||
try {
|
||||
return JSON.parse(localStorage.getItem('nexus-crisis-metrics') || '[]');
|
||||
} catch (error) {
|
||||
console.error('Failed to get stored metrics:', error);
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Clear stored crisis metrics
|
||||
*/
|
||||
clearStoredMetrics() {
|
||||
try {
|
||||
localStorage.removeItem('nexus-crisis-metrics');
|
||||
} catch (error) {
|
||||
console.error('Failed to clear stored metrics:', error);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Export for use in other modules
|
||||
if (typeof module !== 'undefined' && module.exports) {
|
||||
module.exports = CrisisDetector;
|
||||
}
|
||||
|
||||
// Global instance for browser use
|
||||
if (typeof window !== 'undefined') {
|
||||
window.CrisisDetector = CrisisDetector;
|
||||
}
|
||||
@@ -1,456 +0,0 @@
|
||||
/**
|
||||
* Nostr Event Stream Visualization
|
||||
* Issue #874: [NEXUS] Implement Nostr Event Stream Visualization
|
||||
*
|
||||
* Visualize incoming Nostr events as data streams or particles flowing through
|
||||
* the Nexus, representing the agent's connection to the wider mesh.
|
||||
*/
|
||||
|
||||
class NostrEventVisualizer {
|
||||
constructor(options = {}) {
|
||||
this.relayUrl = options.relayUrl || 'wss://relay.nostr.info';
|
||||
this.maxEvents = options.maxEvents || 100;
|
||||
this.particleCount = options.particleCount || 50;
|
||||
this.streamSpeed = options.streamSpeed || 1.0;
|
||||
this.particleSize = options.particleSize || 0.5;
|
||||
|
||||
this.ws = null;
|
||||
this.events = [];
|
||||
this.particles = [];
|
||||
this.scene = null;
|
||||
this.camera = null;
|
||||
this.renderer = null;
|
||||
|
||||
this.isConnected = false;
|
||||
this.reconnectAttempts = 0;
|
||||
this.maxReconnectAttempts = 5;
|
||||
|
||||
// Callbacks
|
||||
this.onEvent = options.onEvent || (() => {});
|
||||
this.onConnect = options.onConnect || (() => {});
|
||||
this.onDisconnect = options.onDisconnect || (() => {});
|
||||
this.onError = options.onError || console.error;
|
||||
|
||||
// Event types to visualize
|
||||
this.eventTypes = options.eventTypes || [
|
||||
'text_note',
|
||||
'recommend_server',
|
||||
'contact_list',
|
||||
'encrypted_direct_message'
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the visualization
|
||||
*/
|
||||
init(scene, camera, renderer) {
|
||||
this.scene = scene;
|
||||
this.camera = camera;
|
||||
this.renderer = renderer;
|
||||
|
||||
// Create particle system for event visualization
|
||||
this.createParticleSystem();
|
||||
|
||||
console.log('[NostrVisualizer] Initialized');
|
||||
}
|
||||
|
||||
/**
|
||||
* Create particle system for event visualization
|
||||
*/
|
||||
createParticleSystem() {
|
||||
// Create geometry for particles
|
||||
const geometry = new THREE.BufferGeometry();
|
||||
const positions = new Float32Array(this.particleCount * 3);
|
||||
const colors = new Float32Array(this.particleCount * 3);
|
||||
const sizes = new Float32Array(this.particleCount);
|
||||
|
||||
// Initialize particles
|
||||
for (let i = 0; i < this.particleCount; i++) {
|
||||
// Random position in a sphere
|
||||
const theta = Math.random() * Math.PI * 2;
|
||||
const phi = Math.acos(2 * Math.random() - 1);
|
||||
const r = 50 + Math.random() * 50;
|
||||
|
||||
positions[i * 3] = r * Math.sin(phi) * Math.cos(theta);
|
||||
positions[i * 3 + 1] = r * Math.sin(phi) * Math.sin(theta);
|
||||
positions[i * 3 + 2] = r * Math.cos(phi);
|
||||
|
||||
// Color based on event type
|
||||
colors[i * 3] = 0.3; // R
|
||||
colors[i * 3 + 1] = 0.8; // G
|
||||
colors[i * 3 + 2] = 1.0; // B
|
||||
|
||||
sizes[i] = this.particleSize;
|
||||
|
||||
// Store particle data
|
||||
this.particles.push({
|
||||
index: i,
|
||||
x: positions[i * 3],
|
||||
y: positions[i * 3 + 1],
|
||||
z: positions[i * 3 + 2],
|
||||
vx: (Math.random() - 0.5) * 0.1,
|
||||
vy: (Math.random() - 0.5) * 0.1,
|
||||
vz: (Math.random() - 0.5) * 0.1,
|
||||
color: { r: 0.3, g: 0.8, b: 1.0 },
|
||||
size: this.particleSize,
|
||||
event: null
|
||||
});
|
||||
}
|
||||
|
||||
geometry.setAttribute('position', new THREE.BufferAttribute(positions, 3));
|
||||
geometry.setAttribute('color', new THREE.BufferAttribute(colors, 3));
|
||||
geometry.setAttribute('size', new THREE.BufferAttribute(sizes, 1));
|
||||
|
||||
// Create material
|
||||
const material = new THREE.PointsMaterial({
|
||||
size: this.particleSize,
|
||||
vertexColors: true,
|
||||
transparent: true,
|
||||
opacity: 0.8,
|
||||
blending: THREE.AdditiveBlending
|
||||
});
|
||||
|
||||
// Create points
|
||||
this.particleSystem = new THREE.Points(geometry, material);
|
||||
this.scene.add(this.particleSystem);
|
||||
|
||||
console.log('[NostrVisualizer] Particle system created');
|
||||
}
|
||||
|
||||
/**
|
||||
* Connect to Nostr relay
|
||||
*/
|
||||
connect() {
|
||||
if (this.isConnected) {
|
||||
console.warn('[NostrVisualizer] Already connected');
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(`[NostrVisualizer] Connecting to ${this.relayUrl}...`);
|
||||
|
||||
try {
|
||||
this.ws = new WebSocket(this.relayUrl);
|
||||
|
||||
this.ws.onopen = () => {
|
||||
console.log('[NostrVisualizer] Connected to Nostr relay');
|
||||
this.isConnected = true;
|
||||
this.reconnectAttempts = 0;
|
||||
|
||||
// Subscribe to events
|
||||
this.subscribe();
|
||||
|
||||
// Call connect callback
|
||||
this.onConnect();
|
||||
};
|
||||
|
||||
this.ws.onmessage = (event) => {
|
||||
try {
|
||||
const data = JSON.parse(event.data);
|
||||
this.handleEvent(data);
|
||||
} catch (error) {
|
||||
console.error('[NostrVisualizer] Failed to parse event:', error);
|
||||
}
|
||||
};
|
||||
|
||||
this.ws.onclose = () => {
|
||||
console.log('[NostrVisualizer] Disconnected from Nostr relay');
|
||||
this.isConnected = false;
|
||||
|
||||
// Call disconnect callback
|
||||
this.onDisconnect();
|
||||
|
||||
// Attempt reconnect
|
||||
this.scheduleReconnect();
|
||||
};
|
||||
|
||||
this.ws.onerror = (error) => {
|
||||
console.error('[NostrVisualizer] WebSocket error:', error);
|
||||
this.onError(error);
|
||||
};
|
||||
|
||||
} catch (error) {
|
||||
console.error('[NostrVisualizer] Failed to connect:', error);
|
||||
this.onError(error);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Subscribe to Nostr events
|
||||
*/
|
||||
subscribe() {
|
||||
if (!this.isConnected || !this.ws) {
|
||||
console.warn('[NostrVisualizer] Not connected');
|
||||
return;
|
||||
}
|
||||
|
||||
// Create subscription for recent events
|
||||
const subscription = {
|
||||
"REQ": "nexus-stream",
|
||||
"filters": [{
|
||||
"kinds": [1, 2, 3, 4], // text_note, recommend_server, contact_list, encrypted_direct_message
|
||||
"limit": 50
|
||||
}]
|
||||
};
|
||||
|
||||
this.ws.send(JSON.stringify(subscription));
|
||||
console.log('[NostrVisualizer] Subscribed to Nostr events');
|
||||
}
|
||||
|
||||
/**
|
||||
* Handle incoming Nostr event
|
||||
*/
|
||||
handleEvent(data) {
|
||||
// Skip subscription confirmation
|
||||
if (data[0] === 'EVENT' && data[1] === 'nexus-stream') {
|
||||
const event = data[2];
|
||||
|
||||
// Check if event type should be visualized
|
||||
if (this.eventTypes.includes(this.getEventType(event.kind))) {
|
||||
this.visualizeEvent(event);
|
||||
this.onEvent(event);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Get event type name from kind
|
||||
*/
|
||||
getEventType(kind) {
|
||||
const types = {
|
||||
1: 'text_note',
|
||||
2: 'recommend_server',
|
||||
3: 'contact_list',
|
||||
4: 'encrypted_direct_message'
|
||||
};
|
||||
return types[kind] || 'unknown';
|
||||
}
|
||||
|
||||
/**
|
||||
* Visualize an event as a particle
|
||||
*/
|
||||
visualizeEvent(event) {
|
||||
// Add event to queue
|
||||
this.events.push({
|
||||
event: event,
|
||||
timestamp: Date.now(),
|
||||
visualized: false
|
||||
});
|
||||
|
||||
// Limit queue size
|
||||
if (this.events.length > this.maxEvents) {
|
||||
this.events.shift();
|
||||
}
|
||||
|
||||
// Update particle for this event
|
||||
this.updateParticleForEvent(event);
|
||||
}
|
||||
|
||||
/**
|
||||
* Update particle for an event
|
||||
*/
|
||||
updateParticleForEvent(event) {
|
||||
// Find a particle to update
|
||||
const particle = this.particles.find(p => !p.event);
|
||||
|
||||
if (!particle) {
|
||||
// All particles are in use, recycle oldest
|
||||
const oldest = this.particles.reduce((a, b) =>
|
||||
(a.event && a.event.timestamp < b.event.timestamp) ? a : b
|
||||
);
|
||||
this.resetParticle(oldest);
|
||||
this.updateParticleWithEvent(oldest, event);
|
||||
} else {
|
||||
this.updateParticleWithEvent(particle, event);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Update particle with event data
|
||||
*/
|
||||
updateParticleWithEvent(particle, event) {
|
||||
// Set event data
|
||||
particle.event = event;
|
||||
|
||||
// Set color based on event type
|
||||
const colors = {
|
||||
'text_note': { r: 0.3, g: 0.8, b: 1.0 }, // Blue
|
||||
'recommend_server': { r: 1.0, g: 0.8, b: 0.3 }, // Gold
|
||||
'contact_list': { r: 0.3, g: 1.0, b: 0.8 }, // Cyan
|
||||
'encrypted_direct_message': { r: 1.0, g: 0.3, b: 0.8 } // Pink
|
||||
};
|
||||
|
||||
const eventType = this.getEventType(event.kind);
|
||||
particle.color = colors[eventType] || { r: 0.5, g: 0.5, b: 0.5 };
|
||||
|
||||
// Update geometry
|
||||
this.updateParticleGeometry(particle);
|
||||
|
||||
console.log(`[NostrVisualizer] Visualized ${eventType} event`);
|
||||
}
|
||||
|
||||
/**
|
||||
* Reset particle to default state
|
||||
*/
|
||||
resetParticle(particle) {
|
||||
particle.event = null;
|
||||
particle.color = { r: 0.3, g: 0.8, b: 1.0 };
|
||||
particle.size = this.particleSize;
|
||||
|
||||
// Random position
|
||||
const theta = Math.random() * Math.PI * 2;
|
||||
const phi = Math.acos(2 * Math.random() - 1);
|
||||
const r = 50 + Math.random() * 50;
|
||||
|
||||
particle.x = r * Math.sin(phi) * Math.cos(theta);
|
||||
particle.y = r * Math.sin(phi) * Math.sin(theta);
|
||||
particle.z = r * Math.cos(phi);
|
||||
|
||||
this.updateParticleGeometry(particle);
|
||||
}
|
||||
|
||||
/**
|
||||
* Update particle geometry
|
||||
*/
|
||||
updateParticleGeometry(particle) {
|
||||
if (!this.particleSystem) return;
|
||||
|
||||
const geometry = this.particleSystem.geometry;
|
||||
const positions = geometry.attributes.position.array;
|
||||
const colors = geometry.attributes.color.array;
|
||||
const sizes = geometry.attributes.size.array;
|
||||
|
||||
// Update position
|
||||
positions[particle.index * 3] = particle.x;
|
||||
positions[particle.index * 3 + 1] = particle.y;
|
||||
positions[particle.index * 3 + 2] = particle.z;
|
||||
|
||||
// Update color
|
||||
colors[particle.index * 3] = particle.color.r;
|
||||
colors[particle.index * 3 + 1] = particle.color.g;
|
||||
colors[particle.index * 3 + 2] = particle.color.b;
|
||||
|
||||
// Update size
|
||||
sizes[particle.index] = particle.size;
|
||||
|
||||
// Mark attributes as needing update
|
||||
geometry.attributes.position.needsUpdate = true;
|
||||
geometry.attributes.color.needsUpdate = true;
|
||||
geometry.attributes.size.needsUpdate = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Update visualization
|
||||
*/
|
||||
update(deltaTime) {
|
||||
if (!this.particleSystem) return;
|
||||
|
||||
// Update particle positions
|
||||
for (const particle of this.particles) {
|
||||
// Move particle
|
||||
particle.x += particle.vx * this.streamSpeed * deltaTime;
|
||||
particle.y += particle.vy * this.streamSpeed * deltaTime;
|
||||
particle.z += particle.vz * this.streamSpeed * deltaTime;
|
||||
|
||||
// Add some turbulence
|
||||
particle.vx += (Math.random() - 0.5) * 0.01;
|
||||
particle.vy += (Math.random() - 0.5) * 0.01;
|
||||
particle.vz += (Math.random() - 0.5) * 0.01;
|
||||
|
||||
// Limit velocity
|
||||
const maxVel = 0.5;
|
||||
particle.vx = Math.max(-maxVel, Math.min(maxVel, particle.vx));
|
||||
particle.vy = Math.max(-maxVel, Math.min(maxVel, particle.vy));
|
||||
particle.vz = Math.max(-maxVel, Math.min(maxVel, particle.vz));
|
||||
|
||||
// Keep particles in bounds
|
||||
const maxDist = 100;
|
||||
if (Math.abs(particle.x) > maxDist) particle.vx *= -0.5;
|
||||
if (Math.abs(particle.y) > maxDist) particle.vy *= -0.5;
|
||||
if (Math.abs(particle.z) > maxDist) particle.vz *= -0.5;
|
||||
|
||||
// Update geometry
|
||||
this.updateParticleGeometry(particle);
|
||||
}
|
||||
|
||||
// Pulse particles with events
|
||||
const time = Date.now() * 0.001;
|
||||
for (const particle of this.particles) {
|
||||
if (particle.event) {
|
||||
// Pulse size for particles with events
|
||||
particle.size = this.particleSize * (1 + 0.2 * Math.sin(time * 3 + particle.index));
|
||||
this.updateParticleGeometry(particle);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Schedule reconnection
|
||||
*/
|
||||
scheduleReconnect() {
|
||||
if (this.reconnectAttempts >= this.maxReconnectAttempts) {
|
||||
console.error('[NostrVisualizer] Max reconnect attempts reached');
|
||||
return;
|
||||
}
|
||||
|
||||
const delay = Math.min(1000 * Math.pow(2, this.reconnectAttempts), 30000);
|
||||
|
||||
console.log(`[NostrVisualizer] Reconnecting in ${delay / 1000}s...`);
|
||||
|
||||
setTimeout(() => {
|
||||
this.reconnectAttempts++;
|
||||
this.connect();
|
||||
}, delay);
|
||||
}
|
||||
|
||||
/**
|
||||
* Disconnect from Nostr relay
|
||||
*/
|
||||
disconnect() {
|
||||
console.log('[NostrVisualizer] Disconnecting...');
|
||||
|
||||
if (this.ws) {
|
||||
this.ws.close();
|
||||
this.ws = null;
|
||||
}
|
||||
|
||||
this.isConnected = false;
|
||||
|
||||
// Clear particles
|
||||
for (const particle of this.particles) {
|
||||
this.resetParticle(particle);
|
||||
}
|
||||
|
||||
console.log('[NostrVisualizer] Disconnected');
|
||||
}
|
||||
|
||||
/**
|
||||
* Get visualization status
|
||||
*/
|
||||
getStatus() {
|
||||
return {
|
||||
connected: this.isConnected,
|
||||
relayUrl: this.relayUrl,
|
||||
eventCount: this.events.length,
|
||||
particleCount: this.particles.length,
|
||||
activeParticles: this.particles.filter(p => p.event).length,
|
||||
reconnectAttempts: this.reconnectAttempts
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
// Export for use in other modules
|
||||
if (typeof module !== 'undefined' && module.exports) {
|
||||
module.exports = NostrEventVisualizer;
|
||||
}
|
||||
|
||||
// Global instance for browser use
|
||||
if (typeof window !== 'undefined') {
|
||||
window.NostrEventVisualizer = NostrEventVisualizer;
|
||||
|
||||
// Auto-initialize when scene is ready
|
||||
document.addEventListener('DOMContentLoaded', () => {
|
||||
// This would be called when Three.js scene is initialized
|
||||
// window.nostrVisualizer = new NostrEventVisualizer();
|
||||
// window.nostrVisualizer.init(scene, camera, renderer);
|
||||
});
|
||||
}
|
||||
208
tests/test_crisis_detector.js
Normal file
208
tests/test_crisis_detector.js
Normal file
@@ -0,0 +1,208 @@
|
||||
/**
|
||||
* Tests for Crisis Detection Module
|
||||
* Issue #1543: feat: Nexus → the-door crisis bridge — detect distress in world chat
|
||||
*/
|
||||
|
||||
const test = require('node:test');
|
||||
const assert = require('node:assert/strict');
|
||||
const fs = require('node:fs');
|
||||
const path = require('node:path');
|
||||
|
||||
const ROOT = path.resolve(__dirname, '..');
|
||||
|
||||
// Mock document
|
||||
const mockDocument = {
|
||||
createElement: (tag) => {
|
||||
const element = {
|
||||
style: {},
|
||||
innerHTML: '',
|
||||
appendChild: () => {},
|
||||
remove: () => {},
|
||||
addEventListener: () => {}
|
||||
};
|
||||
return element;
|
||||
},
|
||||
body: {
|
||||
appendChild: () => {}
|
||||
},
|
||||
getElementById: () => null
|
||||
};
|
||||
|
||||
// Mock localStorage
|
||||
const mockLocalStorage = {
|
||||
storage: {},
|
||||
getItem: (key) => mockLocalStorage.storage[key] || null,
|
||||
setItem: (key, value) => { mockLocalStorage.storage[key] = value; },
|
||||
removeItem: (key) => { delete mockLocalStorage.storage[key]; }
|
||||
};
|
||||
|
||||
// Load crisis-detector.js
|
||||
const crisisDetectorPath = path.join(ROOT, 'js', 'crisis-detector.js');
|
||||
const crisisDetectorCode = fs.readFileSync(crisisDetectorPath, 'utf8');
|
||||
|
||||
// Create VM context
|
||||
const context = {
|
||||
module: { exports: {} },
|
||||
exports: {},
|
||||
console,
|
||||
document: mockDocument,
|
||||
localStorage: mockLocalStorage,
|
||||
window: { location: { href: '' } }
|
||||
};
|
||||
|
||||
// Execute crisis-detector.js in context
|
||||
const vm = require('node:vm');
|
||||
vm.runInNewContext(crisisDetectorCode, context);
|
||||
|
||||
// Get CrisisDetector class
|
||||
const CrisisDetector = context.window.CrisisDetector || context.CrisisDetector;
|
||||
|
||||
test('CrisisDetector class loads correctly', () => {
|
||||
assert.ok(CrisisDetector, 'CrisisDetector should be defined');
|
||||
assert.ok(typeof CrisisDetector === 'function', 'CrisisDetector should be a constructor');
|
||||
});
|
||||
|
||||
test('CrisisDetector can be instantiated', () => {
|
||||
const detector = new CrisisDetector();
|
||||
assert.ok(detector, 'CrisisDetector instance should be created');
|
||||
assert.ok(detector.crisisKeywords, 'Should have crisisKeywords');
|
||||
assert.ok(detector.crisisPatterns, 'Should have crisisPatterns');
|
||||
});
|
||||
|
||||
test('CrisisDetector detects crisis keywords', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
// Test various crisis messages
|
||||
const crisisMessages = [
|
||||
'I want to die',
|
||||
'I\'m going to kill myself',
|
||||
'I should just die',
|
||||
'Nobody would miss me',
|
||||
'I can\'t take it anymore',
|
||||
'I\'m done with life',
|
||||
'I hate my life',
|
||||
'I wish I was dead',
|
||||
'I\'m going to end it',
|
||||
'I have nothing to live for'
|
||||
];
|
||||
|
||||
for (const message of crisisMessages) {
|
||||
const detected = detector.detectCrisis(message);
|
||||
assert.ok(detected, `Should detect crisis in: "${message}"`);
|
||||
}
|
||||
});
|
||||
|
||||
test('CrisisDetector does not detect crisis in normal messages', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
const normalMessages = [
|
||||
'Hello, how are you?',
|
||||
'I\'m doing great today',
|
||||
'Let\'s work on this project',
|
||||
'The weather is nice',
|
||||
'I love coding',
|
||||
'This is a test message'
|
||||
];
|
||||
|
||||
for (const message of normalMessages) {
|
||||
const detected = detector.detectCrisis(message);
|
||||
assert.ok(!detected, `Should NOT detect crisis in: "${message}"`);
|
||||
}
|
||||
});
|
||||
|
||||
test('CrisisDetector handles empty messages', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
assert.ok(!detector.detectCrisis(''), 'Should not detect crisis in empty string');
|
||||
assert.ok(!detector.detectCrisis(null), 'Should not detect crisis in null');
|
||||
assert.ok(!detector.detectCrisis(undefined), 'Should not detect crisis in undefined');
|
||||
});
|
||||
|
||||
test('CrisisDetector tracks metrics', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
// Check initial metrics
|
||||
const initialMetrics = detector.getMetrics();
|
||||
assert.equal(initialMetrics.totalChecks, 0, 'Should start with 0 checks');
|
||||
assert.equal(initialMetrics.crisesDetected, 0, 'Should start with 0 crises');
|
||||
|
||||
// Check some messages
|
||||
detector.detectCrisis('Hello');
|
||||
detector.detectCrisis('I want to die');
|
||||
detector.detectCrisis('How are you?');
|
||||
|
||||
const metrics = detector.getMetrics();
|
||||
assert.equal(metrics.totalChecks, 3, 'Should have 3 checks');
|
||||
assert.equal(metrics.crisesDetected, 1, 'Should have 1 crisis detected');
|
||||
assert.ok(metrics.lastDetection, 'Should have lastDetection');
|
||||
assert.equal(metrics.lastDetection.message, 'I want to die', 'Should store crisis message');
|
||||
});
|
||||
|
||||
test('CrisisDetector can reset metrics', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
// Check some messages
|
||||
detector.detectCrisis('I want to die');
|
||||
detector.detectCrisis('Hello');
|
||||
|
||||
// Reset metrics
|
||||
detector.resetMetrics();
|
||||
|
||||
const metrics = detector.getMetrics();
|
||||
assert.equal(metrics.totalChecks, 0, 'Should have 0 checks after reset');
|
||||
assert.equal(metrics.crisesDetected, 0, 'Should have 0 crises after reset');
|
||||
assert.equal(metrics.lastDetection, null, 'Should have no lastDetection after reset');
|
||||
});
|
||||
|
||||
test('CrisisDetector logs to metrics', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
// Clear any existing metrics
|
||||
detector.clearStoredMetrics();
|
||||
|
||||
// Detect crisis
|
||||
detector.detectCrisis('I want to die');
|
||||
|
||||
// Check stored metrics
|
||||
const storedMetrics = detector.getStoredMetrics();
|
||||
assert.ok(storedMetrics.length > 0, 'Should have stored metrics');
|
||||
|
||||
// Find the crisis_detected event (not overlay_shown)
|
||||
const crisisEvent = storedMetrics.find(event => event.type === 'crisis_detected');
|
||||
assert.ok(crisisEvent, 'Should have crisis_detected event');
|
||||
assert.equal(crisisEvent.message, 'I want to die', 'Should log message');
|
||||
});
|
||||
|
||||
test('CrisisDetector has crisis handler', () => {
|
||||
let handlerCalled = false;
|
||||
let handlerMessage = null;
|
||||
|
||||
const detector = new CrisisDetector({
|
||||
onCrisisDetected: (message) => {
|
||||
handlerCalled = true;
|
||||
handlerMessage = message;
|
||||
}
|
||||
});
|
||||
|
||||
detector.detectCrisis('I want to die');
|
||||
|
||||
assert.ok(handlerCalled, 'Crisis handler should be called');
|
||||
assert.equal(handlerMessage, 'I want to die', 'Handler should receive message');
|
||||
});
|
||||
|
||||
test('CrisisDetector overlay visibility', () => {
|
||||
const detector = new CrisisDetector();
|
||||
|
||||
// Initially not visible
|
||||
assert.ok(!detector.overlayVisible, 'Overlay should not be visible initially');
|
||||
|
||||
// Show overlay
|
||||
detector.show988Overlay();
|
||||
assert.ok(detector.overlayVisible, 'Overlay should be visible after showing');
|
||||
|
||||
// Hide overlay
|
||||
detector.hide988Overlay();
|
||||
assert.ok(!detector.overlayVisible, 'Overlay should not be visible after hiding');
|
||||
});
|
||||
|
||||
console.log('All CrisisDetector tests passed!');
|
||||
Reference in New Issue
Block a user