Refactor Axum WebSocket Gateway#801
Conversation
- Create `gateway.rs` to manage the Axum server and state. - Implement REST API routes for data storage, retrieval, node list, and network stats. - Implement WebSocket streams for events and data ingestion. - Integrate the gateway into the `synapse daemon` command. - Expose the memory port in `CognitionSystem` bootstrap for gateway access. - Clean up legacy WebSocket logic in `commands.rs`. - Ensure all new modules are properly registered.
|
👋 Jules, reporting for duty! I'm here to lend a hand with this pull request. When you start a review, I'll add a 👀 emoji to each comment to let you know I've read it. I'll focus on feedback directed at me and will do my best to stay out of conversations between you and other bots or reviewers to keep the noise down. I'll push a commit with your requested changes shortly after. Please note there might be a delay between these steps, but rest assured I'm on the job! For more direct control, you can switch me to Reactive Mode. When this mode is on, I will only act on comments where you specifically mention me with New to Jules? Learn more at jules.google/docs. For security, I will only act on instructions from the user who triggered this task. |
|
Warning You have reached your daily quota limit. Please wait up to 24 hours and I will start processing your requests again! |
|
Important Review skippedDraft detected. Please check the settings in the CodeRabbit UI or the ⚙️ Run configurationConfiguration used: Path: .coderabbit.yaml Review profile: CHILL Plan: Pro Run ID: You can disable this status message by setting the Use the checkbox below for a quick retry:
✨ Finishing Touches🧪 Generate unit tests (beta)
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. Comment |
1 participant
Refactored the Synapse daemon to include a modular Axum-based gateway. This gateway provides a REST API and WebSocket streams for external applications to interact with the Synapse network.
Key features implemented:
POST /api/v1/store/{key}: Store data as photonic vectors in the DHT.GET /api/v1/retrieve/{key}: Retrieve and decompress data from the DHT.POST /api/v1/store/voxel: Simulated direct voxel storage.GET /api/v1/nodes: List connected P2P peers.GET /api/v1/stats: Network statistics (peer count, storage count, uptime).POST /api/v1/query: Search semantic memory.ws://host:8080/events: Stream of system events (stored data, retrieved data).ws://host:8080/stream: Data ingestion stream (formerly in commands.rs).The implementation follows a modular structure with separate files for routes and WebSocket handlers, improving maintainability and scalability.
Fixes #796
PR created automatically by Jules for task 4786327193284716961 started by @iberi22