**7 issues found** across 11 files

Prompt for AI agents (unresolved issues)

```text Check if these issues are valid — if so, understand the root cause of each and fix them. If appropriate, use sub-agents to investigate and fix each issue separately. P2: The docstring claims the client "transparently reconnects to the leader address and retries once," but this reconnection logic was removed in the transport rewrite. Either implement the leader-hint handling over FIBP or update the docstring to reflect the current behavior. P1: Bare `except Exception: continue` silently drops messages that fail to decode. If the server sends a malformed frame or the protocol changes, consumed messages will vanish without any indication. At minimum, log the exception so operators can detect the data loss. P2: Independent per-queue requests in `enqueue_many` are awaited sequentially. Since these use separate correlation IDs and target different queues, they can be dispatched concurrently via `asyncio.gather` to avoid unnecessary serialisation in the async client. P1: Bare `except Exception: continue` silently drops messages that fail to decode, with no logging or metrics. This can hide protocol mismatches, corrupt frames, or bugs in `decode_consume_message`, making data loss invisible to operators. At minimum, log a warning with the exception before continuing. P2: Map FibpError via _map_enqueue_error_code here so batch enqueues preserve the same specific error types as single enqueues. P1: Missing write lock for socket sends — concurrent `sendall` calls from different threads can interleave frame bytes on the wire, corrupting the protocol stream. The async version correctly uses `_write_lock`; the sync version needs the same protection. P2: Unnecessary temp file for CA cert — `SSLContext.load_verify_locations` accepts PEM data directly via the `cadata` parameter, avoiding writing to disk: `ctx.load_verify_locations(cadata=ca_cert.decode('ascii'))`. ```

_{Reply with feedback, questions, or to request a fix. Tag `@cubic-dev-ai` to re-run a review.}