fix(sdk): reconnect on dropped socket via ConnectionManager

[TinDang97]

Problem

The Rust SDK's MoonClient wrapped a redis::aio::MultiplexedConnection, which opens one socket at connect time and never rebuilds it. When the backend drops the connection — a server restart, an idle-timeout reap, a transient network blip — every subsequent command fails with broken pipe forever; the only recovery is to reconstruct the client (restart the whole consuming process).

This wedged Lunaris in production: after a live Moon daemon flip, the lunaris-mcp server's pooled connection went permanently dead and memory.recall returned broken pipe on every call until the MCP process was restarted.

Fix

Switch MoonClient (and all 9 sub-clients, which clone the shared conn) to redis::aio::ConnectionManager — the reconnecting variant. It transparently re-establishes the socket with backoff, is Clone, and shares reconnect state across clones via Arc, so a heal on any handle repairs every sub-client. connect_with_timeout preserves the existing per-command response-timeout contract via ConnectionManagerConfig.

Test (red/green)

sdk/rust/tests/reconnect.rs spawns a real redis-server, drives a PING through a long-lived client, kills the server, restarts it on the same port, and asserts the same client recovers within a bounded window:

• RED (MultiplexedConnection): never recovers → times out.
• GREEN (ConnectionManager): reconnects → PONG.

Self-contained (spawns its own server; skips cleanly if redis-server is absent).

Scope

moondb is a standalone crate (not a member of the moon server workspace), so this does not touch the server build. Incidental: fixed pre-existing moon:: rename leftovers (crate is now moondb) in integration.rs + three doctests + one malformed FT.AGGREGATE doctest, so cargo test -p moondb (tests + doctests) is green.

skip-changelog: SDK-internal reliability fix; the commit touches only sdk/rust/*.

Summary by CodeRabbit

• New Features

  • Rust SDK connections now automatically reconnect after the backend restarts.
  • Long-lived clients can resume operations without requiring a new connection.

• Bug Fixes

  • Improved connection resilience across cache, graph, messaging, session, temporal, text, vector, and workspace operations.

• Documentation

  • Updated Rust examples and integration tests to use the current SDK naming and return types.

[qodo-code-review]

Qodo reviews are paused for this user.

Troubleshooting steps vary by plan Learn more →

On a Teams plan?
Reviews resume once this user has a paid seat and their Git account is linked in Qodo.
Link Git account →

Using GitHub Enterprise Server, GitLab Self-Managed, or Bitbucket Data Center?
These require an Enterprise plan - Contact us
Contact us →

[coderabbitai]

No actionable comments were generated in the recent review. 🎉

ℹ️ Recent review info

⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Pro

Run ID: 5a2cdd41-28df-46b6-877e-3ffdfbf18de0

📥 Commits

Reviewing files that changed from the base of the PR and between 5db9629 and 0134323.

⛔ Files ignored due to path filters (1)

• sdk/rust/Cargo.lock is excluded by !**/*.lock

📒 Files selected for processing (12)

• sdk/rust/Cargo.toml
• sdk/rust/src/cache.rs
• sdk/rust/src/client.rs
• sdk/rust/src/graph.rs
• sdk/rust/src/mq.rs
• sdk/rust/src/session.rs
• sdk/rust/src/temporal.rs
• sdk/rust/src/text.rs
• sdk/rust/src/vector.rs
• sdk/rust/src/workspace.rs
• sdk/rust/tests/integration.rs
• sdk/rust/tests/reconnect.rs

---

📝 Walkthrough

Walkthrough

The Rust SDK now uses Redis ConnectionManager connections, including timeout-aware construction and reconnect behavior. All Redis-backed clients adopt the new connection type, and a restart regression test verifies recovery of a long-lived client.

Changes

Redis connection manager migration

Layer / File(s)	Summary
Connection manager setup and timeout handling sdk/rust/Cargo.toml, sdk/rust/src/client.rs	Enables the Redis connection-manager feature, updates MoonClient construction and timeout configuration, and exposes the updated connection type through inner_mut.
Client connection field migration sdk/rust/src/cache.rs, sdk/rust/src/graph.rs, sdk/rust/src/mq.rs, sdk/rust/src/session.rs, sdk/rust/src/temporal.rs, sdk/rust/src/text.rs, sdk/rust/src/vector.rs, sdk/rust/src/workspace.rs	Changes Redis connection fields to ConnectionManager while preserving existing command methods.
Reconnect validation and SDK examples sdk/rust/tests/reconnect.rs, sdk/rust/tests/integration.rs, sdk/rust/src/graph.rs, sdk/rust/src/vector.rs, sdk/rust/src/text.rs	Adds backend restart recovery coverage and updates examples, doctests, validation formatting, and vector decode paths.

Estimated code review effort: 3 (Moderate) | ~25 minutes

Sequence Diagram(s)

sequenceDiagram
  participant Test
  participant MoonClient
  participant Redis
  Test->>Redis: Start backend and verify PING
  Test->>MoonClient: Create long-lived client
  Test->>Redis: Kill and restart backend
  MoonClient->>Redis: Retry ping through ConnectionManager
  Redis-->>MoonClient: Return PONG
  MoonClient-->>Test: Confirm recovery

Loading

🚥 Pre-merge checks | ✅ 5

✅ Passed checks (5 passed)

Check name	Status	Explanation
Title check	✅ Passed	The title accurately summarizes the main change: switching the Rust SDK to reconnect via ConnectionManager.
Description check	✅ Passed	The description is detailed and covers the problem, fix, test plan, and scope, though it does not follow the repository template headings exactly.
Docstring Coverage	✅ Passed	Docstring coverage is 100.00% which is sufficient. The required threshold is 80.00%.
Linked Issues check	✅ Passed	Check skipped because no linked issues were found for this pull request.
Out of Scope Changes check	✅ Passed	Check skipped because no linked issues were found for this pull request.

✨ Finishing Touches

📝 Generate docstrings

• Create stacked PR
• Commit on current branch

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Commit unit tests in branch fix/sdk-connection-manager-reconnect

---

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.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands.}