chore(envoy-client): log command and event payloads

[NathanFlurry]

Summary

• log each decoded envoy command wrapper at info level when commands arrive
• log each event wrapper at info level when events are sent or resent

Verification

• cargo check -p rivet-envoy-client

[claude]

PR Review: chore(envoy-client): log command and event payloads

Note: This is a draft PR — feedback assumes it will eventually be promoted.

Summary

The PR adds per-item structured logging to three envoy-client functions: handle_commands, handle_send_events, and resend_unacknowledged_events. The implementation is clean and follows project conventions, but a few issues are worth addressing before promoting this to ready.

---

Issues

1. Log level is too verbose for production (info → debug or trace)

Per-item command/event logs will be very noisy under load. The aggregate count lines (received commands, resending unacknowledged events) are reasonable at info, but individual item logs should be debug or trace:

// Keep at info
tracing::info!(command_count = commands.len(), "received commands");

// Lower to debug
for command_wrapper in &commands {
    tracing::debug!(
        command = %stringify_command_wrapper(command_wrapper),
        "received command"
    );
}

2. stringify_* functions are called unconditionally

In Rust, macro arguments are evaluated before the macro executes, so stringify_command_wrapper(command_wrapper) is always called — even when the effective log level is above info. Lowering to debug/trace means this cost only appears when explicitly opted-in, which avoids overhead in production.

3. Inconsistent count field names

handle_send_events uses event_count but the pre-existing resend_unacknowledged_events site uses count. Since you're touching both sites, worth unifying:

// events.rs — resend path (pre-existing, should match)
tracing::info!(event_count = events.len(), "resending unacknowledged events");

4. actor_id should be a separate structured field

The actor ID is embedded inside the stringified output but is not queryable as a top-level field. Structured log search works much better when important identifiers are promoted:

tracing::debug!(
    actor_id = %command_wrapper.checkpoint.actor_id,
    command = %stringify_command_wrapper(command_wrapper),
    "received command"
);

5. Double iteration over commands in commands.rs

The logging loop iterates &commands separately before the processing loop. Consider logging inside the existing processing loop to avoid the extra pass, or — once the level is lowered to debug — guard it with tracing::enabled!(tracing::Level::DEBUG) to skip the loop entirely when debug logging is off.

---

Minor

• Log messages follow the lowercase convention from CLAUDE.md ✓
• Structured field format (command = %stringify_command_wrapper(...)) follows tracing conventions ✓
• No functional logic was changed ✓

[NathanFlurry]

Warning

This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
Learn more

• chore(claude): add pkg-pr-new preview deploy lookup instructions #4767
• refactor(pegboard-gateway2): consolidate hibernation in-flight and tunnel flush #4754
• chore(kitchen-sink): configurable endpoint #4766
• refactor(rivetkit-core): rename StopReason to ShutdownKind and kill enum fallthroughs #4765
• chore(envoy-client): log command and event payloads #4751 👈 (View in Graphite)
• fix(rivetkit): minor sleep-cleanup follow-ups #4761
• docs(rivetkit): clean up stale setPreventSleep references in docs and JSDoc #4760
• docs(rivetkit): document keepAwake/waitUntil counter-arm race and surface bridge errors #4759
• test(engine): force overdue branch in alarm-during-sleep test with negative offset #4758
• fix(rivetkit-core): return stopping not starting when sleep/destroy called mid-shutdown #4757
• test(rivetkit): remove sleepWithPreventSleep fixture and tests #4756
• test(engine): add regression test for alarm-during-sleep-transition race #4755
• test(rivetkit-core): cover sleep/destroy guards and prevent_sleep no-op #4750
• docs: add keepAwake vs waitUntil table and internal sleep-sequence invariants #4749
• feat(rivetkit): expose c.keepAwake(promise) through native path #4748
• refactor(rivetkit): deprecate setPreventSleep to no-op in TypeScript #4747
• fix(rivetkit-core): enumerate non-drained counters in grace deadline warn log #4746
• fix(rivetkit-core): abort graceful cleanup task when grace deadline elapses #4745
• fix(rivetkit-core): error on sleep/destroy before startup or already-requested #4743
• fix(rivetkit-core): cap SerializeState shutdown timeout at 15s #4742
• refactor(rivetkit-core): remove prevent_sleep field and deprecate set_prevent_sleep to no-op #4741
• fix(api-public): remove orphan import_export actors module #4764
• main

This stack of pull requests is managed by Graphite. Learn more about stacking.

[github-actions]

Preview packages published to npm

Install with:

npm install rivetkit@pr-4751

All packages published as 0.0.0-pr.4751.26b9398 with tag pr-4751.

Engine binary is shipped via @rivetkit/engine-cli on linux-x64-musl, linux-arm64-musl, darwin-x64, and darwin-arm64. Windows users should use the release installer or set RIVET_ENGINE_BINARY.

Docker images:

docker pull rivetdev/engine:slim-26b9398
docker pull rivetdev/engine:full-26b9398

Individual packages

npm install rivetkit@pr-4751
npm install @rivetkit/react@pr-4751
npm install @rivetkit/rivetkit-napi@pr-4751
npm install @rivetkit/workflow-engine@pr-4751