Compare commits

..

3 Commits

Author SHA1 Message Date
c1f02f0d8b Merge branch 'main' into fix/874
Some checks failed
Review Approval Gate / verify-review (pull_request) Failing after 11s
CI / test (pull_request) Failing after 1m10s
CI / validate (pull_request) Failing after 1m16s
2026-04-22 01:12:35 +00:00
d72cf9a4fd Merge branch 'main' into fix/874
Some checks failed
CI / test (pull_request) Failing after 1m13s
Review Approval Gate / verify-review (pull_request) Failing after 9s
CI / validate (pull_request) Failing after 1m13s
2026-04-22 01:05:28 +00:00
Alexander Whitestone
57bf47f724 fix: #874
Some checks failed
Review Approval Gate / verify-review (pull_request) Failing after 10s
CI / test (pull_request) Failing after 1m3s
CI / validate (pull_request) Failing after 1m7s
- Implement Nostr event stream visualization
- Add js/nostr-event-visualizer.js with particle visualization
- Add docs/nostr-event-visualizer.md with documentation
- Add script to index.html

Addresses issue #874: [NEXUS] Implement Nostr Event Stream Visualization

Features:
1. Connect to Nostr relay via WebSocket
2. Subscribe to event stream
3. Visualize events as colored particles
4. Color-coded by event type (text_note, recommend_server, etc.)
5. Animated particle system with turbulence
6. Reconnect on disconnect

Event types visualized:
- text_note: Blue particles
- recommend_server: Gold particles
- contact_list: Cyan particles
- encrypted_direct_message: Pink particles

Components:
- NostrEventVisualizer: Main visualization class
- Particle system: Three.js points
- Color manager: Event type colors
- Animation engine: Particle movement and pulsing
2026-04-20 22:33:42 -04:00
5 changed files with 725 additions and 681 deletions

View File

@@ -0,0 +1,268 @@
# 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.**

View File

@@ -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/spatial-search.js"></script>
<script src="./js/nostr-event-visualizer.js"></script>
<script src="./avatar-customization.js"></script>
<script src="./lod-system.js"></script>
<script>

View File

@@ -0,0 +1,456 @@
/**
* 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);
});
}

View File

@@ -1,457 +0,0 @@
/**
* Spatial Search - Find nearest user/object by name
* Issue #1540: feat: spatial search — find nearest user/object by name
*
* Provides search functionality to find users/objects by name
* and show distance, direction, and pathfinding.
*/
class SpatialSearch {
constructor(options = {}) {
this.maxDistance = options.maxDistance || 1000; // Maximum search distance
this.searchDelay = options.searchDelay || 300; // Delay before search (ms)
this.onResultSelect = options.onResultSelect || (() => {});
this.onError = options.onError || console.error;
// Track entities in the world
this.entities = new Map(); // id -> {name, position, type, ...}
// Search UI elements
this.searchInput = null;
this.resultsContainer = null;
this.pathArrow = null;
// Initialize UI
this.initUI();
}
/**
* Initialize search UI
*/
initUI() {
// Create search container
const searchContainer = document.createElement('div');
searchContainer.id = 'spatial-search-container';
searchContainer.style.cssText = `
position: fixed;
top: 20px;
left: 50%;
transform: translateX(-50%);
z-index: 1000;
display: none;
`;
// Create search input
this.searchInput = document.createElement('input');
this.searchInput.type = 'text';
this.searchInput.placeholder = 'Search users/objects...';
this.searchInput.style.cssText = `
width: 300px;
padding: 10px 15px;
border: 2px solid #4af0c0;
border-radius: 8px;
background: rgba(0, 0, 0, 0.8);
color: white;
font-size: 14px;
font-family: 'SF Mono', 'Cascadia Code', 'Fira Code', monospace;
`;
// Create results container
this.resultsContainer = document.createElement('div');
this.resultsContainer.id = 'spatial-search-results';
this.resultsContainer.style.cssText = `
max-height: 300px;
overflow-y: auto;
background: rgba(0, 0, 0, 0.9);
border: 1px solid #4af0c0;
border-radius: 8px;
margin-top: 5px;
`;
// Add event listeners
this.searchInput.addEventListener('input', () => this.handleSearch());
this.searchInput.addEventListener('keydown', (e) => this.handleKeydown(e));
// Add to container
searchContainer.appendChild(this.searchInput);
searchContainer.appendChild(this.resultsContainer);
// Add to document
document.body.appendChild(searchContainer);
// Create path arrow
this.pathArrow = document.createElement('div');
this.pathArrow.id = 'spatial-search-arrow';
this.pathArrow.style.cssText = `
position: fixed;
bottom: 100px;
right: 20px;
width: 60px;
height: 60px;
background: rgba(74, 240, 192, 0.2);
border: 2px solid #4af0c0;
border-radius: 50%;
display: none;
align-items: center;
justify-content: center;
font-size: 24px;
color: #4af0c0;
cursor: pointer;
z-index: 999;
`;
this.pathArrow.innerHTML = '→';
this.pathArrow.addEventListener('click', () => this.clearSearch());
document.body.appendChild(this.pathArrow);
}
/**
* Show search UI
*/
show() {
const container = document.getElementById('spatial-search-container');
if (container) {
container.style.display = 'block';
this.searchInput.focus();
}
}
/**
* Hide search UI
*/
hide() {
const container = document.getElementById('spatial-search-container');
if (container) {
container.style.display = 'none';
this.clearResults();
}
}
/**
* Toggle search UI
*/
toggle() {
const container = document.getElementById('spatial-search-container');
if (container) {
if (container.style.display === 'none') {
this.show();
} else {
this.hide();
}
}
}
/**
* Handle search input
*/
handleSearch() {
const query = this.searchInput.value.trim();
if (!query) {
this.clearResults();
return;
}
// Debounce search
clearTimeout(this.searchTimeout);
this.searchTimeout = setTimeout(() => {
this.performSearch(query);
}, this.searchDelay);
}
/**
* Handle keyboard events
*/
handleKeydown(event) {
if (event.key === 'Escape') {
this.hide();
} else if (event.key === 'Enter') {
const firstResult = this.resultsContainer.querySelector('.search-result');
if (firstResult) {
firstResult.click();
}
}
}
/**
* Perform search
*/
performSearch(query) {
const results = this.searchEntities(query);
this.displayResults(results);
}
/**
* Search entities by name
*/
searchEntities(query) {
const lowerQuery = query.toLowerCase();
const results = [];
for (const [id, entity] of this.entities) {
const name = (entity.name || '').toLowerCase();
const type = (entity.type || '').toLowerCase();
// Check if name or type matches query
if (name.includes(lowerQuery) || type.includes(lowerQuery)) {
results.push({
id,
name: entity.name,
type: entity.type,
position: entity.position,
distance: this.calculateDistance(entity.position),
direction: this.calculateDirection(entity.position)
});
}
}
// Sort by distance
results.sort((a, b) => a.distance - b.distance);
// Limit results
return results.slice(0, 10);
}
/**
* Calculate distance to entity
*/
calculateDistance(position) {
if (!position) return Infinity;
// Get local player position (would be from game state)
const localPos = this.getLocalPlayerPosition();
if (!localPos) return Infinity;
const dx = position.x - localPos.x;
const dy = position.y - localPos.y;
const dz = position.z - localPos.z;
return Math.sqrt(dx * dx + dy * dy + dz * dz);
}
/**
* Calculate direction to entity
*/
calculateDirection(position) {
if (!position) return 'unknown';
const localPos = this.getLocalPlayerPosition();
if (!localPos) return 'unknown';
const dx = position.x - localPos.x;
const dz = position.z - localPos.z;
// Calculate angle
const angle = Math.atan2(dz, dx) * (180 / Math.PI);
// Convert to direction
if (angle >= -22.5 && angle < 22.5) return 'E';
if (angle >= 22.5 && angle < 67.5) return 'SE';
if (angle >= 67.5 && angle < 112.5) return 'S';
if (angle >= 112.5 && angle < 157.5) return 'SW';
if (angle >= 157.5 || angle < -157.5) return 'W';
if (angle >= -157.5 && angle < -112.5) return 'NW';
if (angle >= -112.5 && angle < -67.5) return 'N';
if (angle >= -67.5 && angle < -22.5) return 'NE';
return 'unknown';
}
/**
* Get local player position (placeholder)
*/
getLocalPlayerPosition() {
// In real implementation, this would get position from game state
// For now, return a placeholder
return { x: 0, y: 0, z: 0 };
}
/**
* Display search results
*/
displayResults(results) {
this.clearResults();
if (results.length === 0) {
const noResults = document.createElement('div');
noResults.className = 'search-no-results';
noResults.textContent = 'No results found';
noResults.style.cssText = `
padding: 10px;
color: #888;
font-style: italic;
`;
this.resultsContainer.appendChild(noResults);
return;
}
for (const result of results) {
const resultElement = this.createResultElement(result);
this.resultsContainer.appendChild(resultElement);
}
}
/**
* Create result element
*/
createResultElement(result) {
const element = document.createElement('div');
element.className = 'search-result';
element.style.cssText = `
padding: 10px 15px;
border-bottom: 1px solid rgba(74, 240, 192, 0.2);
cursor: pointer;
display: flex;
justify-content: space-between;
align-items: center;
`;
element.innerHTML = `
<div>
<div style="font-weight: bold; color: #4af0c0;">${result.name}</div>
<div style="font-size: 12px; color: #888;">${result.type || 'Unknown'}</div>
</div>
<div style="text-align: right;">
<div style="color: #4af0c0;">${result.distance.toFixed(1)}m</div>
<div style="font-size: 12px; color: #888;">${result.direction}</div>
</div>
`;
element.addEventListener('click', () => {
this.selectResult(result);
});
return element;
}
/**
* Select a search result
*/
selectResult(result) {
console.log('[SpatialSearch] Selected:', result);
// Show path arrow
this.showPathArrow(result);
// Call callback
this.onResultSelect(result);
// Hide search
this.hide();
}
/**
* Show path arrow pointing to result
*/
showPathArrow(result) {
if (!this.pathArrow) return;
// Update arrow direction
const arrow = this.pathArrow.querySelector('span') || this.pathArrow;
const directionArrows = {
'N': '↑',
'NE': '↗',
'E': '→',
'SE': '↘',
'S': '↓',
'SW': '↙',
'W': '←',
'NW': '↖'
};
arrow.innerHTML = directionArrows[result.direction] || '?';
// Show arrow
this.pathArrow.style.display = 'flex';
// Update title
this.pathArrow.title = `${result.name} - ${result.distance.toFixed(1)}m ${result.direction}`;
}
/**
* Clear search results
*/
clearResults() {
if (this.resultsContainer) {
this.resultsContainer.innerHTML = '';
}
}
/**
* Clear search and hide arrow
*/
clearSearch() {
this.clearResults();
this.searchInput.value = '';
if (this.pathArrow) {
this.pathArrow.style.display = 'none';
}
}
/**
* Register an entity
*/
registerEntity(id, entity) {
this.entities.set(id, entity);
}
/**
* Unregister an entity
*/
unregisterEntity(id) {
this.entities.delete(id);
}
/**
* Update entity position
*/
updateEntityPosition(id, position) {
const entity = this.entities.get(id);
if (entity) {
entity.position = position;
}
}
/**
* Get search status
*/
getStatus() {
return {
entityCount: this.entities.size,
maxDistance: this.maxDistance,
searchDelay: this.searchDelay
};
}
}
// Export for use in other modules
if (typeof module !== 'undefined' && module.exports) {
module.exports = SpatialSearch;
}
// Global instance for browser use
if (typeof window !== 'undefined') {
window.SpatialSearch = SpatialSearch;
// Auto-initialize
document.addEventListener('DOMContentLoaded', () => {
const search = new SpatialSearch({
maxDistance: 1000,
onResultSelect: (result) => {
console.log('Selected:', result);
// In real implementation, this would navigate to the entity
}
});
// Store globally
window.spatialSearch = search;
// Add keyboard shortcut (Ctrl+F or Cmd+F)
document.addEventListener('keydown', (e) => {
if ((e.ctrlKey || e.metaKey) && e.key === 'f') {
e.preventDefault();
search.toggle();
}
});
});
}

View File

@@ -1,223 +0,0 @@
/**
* Tests for Spatial Search
* Issue #1540: feat: spatial search — find nearest user/object by name
*/
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: '',
textContent: '',
placeholder: '',
title: '',
addEventListener: () => {},
appendChild: () => {},
querySelector: () => null,
querySelectorAll: () => [],
focus: () => {}
};
return element;
},
body: {
appendChild: () => {}
},
getElementById: () => null,
addEventListener: () => {}
};
// Mock console
const mockConsole = {
log: () => {},
warn: () => {},
error: () => {}
};
// Load spatial-search.js
const spatialSearchPath = path.join(ROOT, 'js', 'spatial-search.js');
const spatialSearchCode = fs.readFileSync(spatialSearchPath, 'utf8');
// Create VM context
const context = {
module: { exports: {} },
exports: {},
console: mockConsole,
document: mockDocument,
window: {
addEventListener: () => {},
location: { protocol: 'http:', hostname: 'localhost' }
},
Math: Math,
setTimeout: () => {},
clearTimeout: () => {}
};
// Execute spatial-search.js in context
const vm = require('node:vm');
vm.runInNewContext(spatialSearchCode, context);
// Get SpatialSearch class
const SpatialSearch = context.window.SpatialSearch || context.module.exports;
test('SpatialSearch loads correctly', () => {
assert.ok(SpatialSearch, 'SpatialSearch should be defined');
assert.ok(typeof SpatialSearch === 'function', 'SpatialSearch should be a constructor');
});
test('SpatialSearch can be instantiated', () => {
const search = new SpatialSearch();
assert.ok(search, 'SpatialSearch instance should be created');
assert.equal(search.maxDistance, 1000, 'Should have default max distance');
assert.equal(search.searchDelay, 300, 'Should have default search delay');
assert.ok(search.entities, 'Should have entities Map');
});
test('SpatialSearch can register entities', () => {
const search = new SpatialSearch();
search.registerEntity('user1', {
name: 'Alice',
type: 'user',
position: { x: 10, y: 0, z: 5 }
});
search.registerEntity('user2', {
name: 'Bob',
type: 'user',
position: { x: 20, y: 0, z: 10 }
});
assert.equal(search.entities.size, 2, 'Should have 2 entities');
assert.ok(search.entities.get('user1'), 'Should have user1');
assert.ok(search.entities.get('user2'), 'Should have user2');
});
test('SpatialSearch can unregister entities', () => {
const search = new SpatialSearch();
search.registerEntity('user1', { name: 'Alice', type: 'user' });
search.registerEntity('user2', { name: 'Bob', type: 'user' });
assert.equal(search.entities.size, 2, 'Should have 2 entities');
search.unregisterEntity('user1');
assert.equal(search.entities.size, 1, 'Should have 1 entity after unregister');
assert.ok(!search.entities.get('user1'), 'Should not have user1');
});
test('SpatialSearch can update entity position', () => {
const search = new SpatialSearch();
search.registerEntity('user1', {
name: 'Alice',
type: 'user',
position: { x: 10, y: 0, z: 5 }
});
const newPos = { x: 15, y: 0, z: 10 };
search.updateEntityPosition('user1', newPos);
const entity = search.entities.get('user1');
assert.deepEqual(entity.position, newPos, 'Should update position');
});
test('SpatialSearch calculates distance correctly', () => {
const search = new SpatialSearch();
// Mock getLocalPlayerPosition
search.getLocalPlayerPosition = () => ({ x: 0, y: 0, z: 0 });
const pos1 = { x: 3, y: 0, z: 4 };
const distance1 = search.calculateDistance(pos1);
assert.equal(distance1, 5, 'Should calculate 3-4-5 triangle correctly');
const pos2 = { x: 0, y: 0, z: 0 };
const distance2 = search.calculateDistance(pos2);
assert.equal(distance2, 0, 'Should be 0 at same position');
});
test('SpatialSearch calculates direction correctly', () => {
const search = new SpatialSearch();
// Mock getLocalPlayerPosition
search.getLocalPlayerPosition = () => ({ x: 0, y: 0, z: 0 });
// Test different directions
assert.equal(search.calculateDirection({ x: 10, y: 0, z: 0 }), 'E', 'Should be East');
assert.equal(search.calculateDirection({ x: 0, y: 0, z: 10 }), 'S', 'Should be South');
assert.equal(search.calculateDirection({ x: -10, y: 0, z: 0 }), 'W', 'Should be West');
assert.equal(search.calculateDirection({ x: 0, y: 0, z: -10 }), 'N', 'Should be North');
});
test('SpatialSearch searches entities correctly', () => {
const search = new SpatialSearch();
// Mock getLocalPlayerPosition
search.getLocalPlayerPosition = () => ({ x: 0, y: 0, z: 0 });
// Register entities
search.registerEntity('user1', {
name: 'Alice',
type: 'user',
position: { x: 10, y: 0, z: 0 }
});
search.registerEntity('user2', {
name: 'Bob',
type: 'user',
position: { x: 20, y: 0, z: 0 }
});
search.registerEntity('obj1', {
name: 'Apple',
type: 'object',
position: { x: 5, y: 0, z: 0 }
});
// Search for 'ali'
const results1 = search.searchEntities('ali');
assert.equal(results1.length, 1, 'Should find 1 result for "ali"');
assert.equal(results1[0].name, 'Alice', 'Should find Alice');
// Search for 'bob'
const results2 = search.searchEntities('bob');
assert.equal(results2.length, 1, 'Should find 1 result for "bob"');
assert.equal(results2[0].name, 'Bob', 'Should find Bob');
// Search for 'user' (type)
const results3 = search.searchEntities('user');
assert.equal(results3.length, 2, 'Should find 2 results for "user"');
// Search for 'apple'
const results4 = search.searchEntities('apple');
assert.equal(results4.length, 1, 'Should find 1 result for "apple"');
assert.equal(results4[0].name, 'Apple', 'Should find Apple');
// Search for non-existent
const results5 = search.searchEntities('xyz');
assert.equal(results5.length, 0, 'Should find 0 results for "xyz"');
});
test('SpatialSearch gets status', () => {
const search = new SpatialSearch();
search.registerEntity('user1', { name: 'Alice', type: 'user' });
search.registerEntity('user2', { name: 'Bob', type: 'user' });
const status = search.getStatus();
assert.ok(status, 'Should return status object');
assert.equal(status.entityCount, 2, 'Should have 2 entities');
assert.equal(status.maxDistance, 1000, 'Should have correct max distance');
assert.equal(status.searchDelay, 300, 'Should have correct search delay');
});
console.log('All SpatialSearch tests passed!');