fix(stress): stop watchers when channels close

[colinaumaty]

Return when subscription or log channels close instead of processing zero values. This prevents repeated empty events and lets the watcher goroutine terminate.

No protocol behavior changes; this fixes stress watcher lifecycle only.

Testing

Run the stress package tests with PostgreSQL available at 127.0.0.1:8765.

[octane-security-app]

Summary by Octane

Adds closed-channel detection to the two goroutine loops in pkg/stress/watcher.go, so each returns instead of spinning on a closed channel.

Changes

• pkg/stress/watcher.go (modified) - In makeSubChannel and processLogs, receives from sub.Err() and newLog now use the two-value form and return with a Debug log when the channel is closed.

---

🔗 Commit Hash: 7ee7c37

[octane-security-app]

Overview

Warnings found:	1

Warnings

pkg/stress/watcher.go

• Closed-channel returns with deferred client close in pkg/stress Watcher.Listen cause reuse failure and monitoring downtime. See more

---

🔗 Commit Hash: 7ee7c37
🛡️ Octane Dashboard: All vulnerabilities

[colinaumaty]

@mkysel Hi, this is a small fix in pkg/stress/watcher.go to stop the watcher goroutines when the subscription or log channel is closed, instead of continuing to receive from a closed channel. Would you mind taking a look when you have a chance? Thanks!