✨ feat: add event bus wiring for yield service

- Integrate `LocalBus` for settlement event publishing and consumption by `YieldService` in the application.
- Update `TODO.yield.md` to reflect this new feature in the development roadmap.

Author: nathfavoursagent

TODO.yield.md

@@ -20,6 +20,7 @@ This roadmap outlines the integration of the Riquid Self-Driving Yield Engine in
 - [x] **Auto-Route Service:** Implementation of routing logic upon `SETTLEMENT_CONFIRMED` events.
 - [x] **Threshold Logic:** Implement gas-efficiency triggers to prevent micro-transactions.
 - [x] **Cron Worker:** Develop a "Self-Driving" background worker for periodic harvesting and reinvestment.
+- [x] **Event Bus Wiring:** Settlement events are now published via `LocalBus` and consumed by `YieldService`.
 
 ## Phase 5: Account Abstraction & Session Keys (`pkg/crypto` & `pkg/yield`) 🔐
 - [/] **ERC-4337 Integration:** Logic to manage funds via non-custodial account abstraction (Skeleton).

apps/settlerd/main.go

@@ -52,15 +52,18 @@ func main() {
 		log.Fatalf("Failed to initialize Riquid adapter: %v", err)
 	}
 
-	// 5. Initialize Settlement Engine
-	engine := service.NewDefaultSettlementEngine(db, mc, riquid)
+	// 5. Initialize Event Bus
+	bus := service.NewLocalBus()
 
-	// 6. Initialize Yield Service
+	// 6. Initialize Settlement Engine
+	engine := service.NewDefaultSettlementEngine(db, mc, riquid, bus)
+
+	// 7. Initialize Yield Service
 	// Threshold: 0.1 BNB (demonstration)
 	threshold := big.NewInt(100000000000000000) 
 	yieldSvc := service.NewYieldService(engine, riquid, threshold)
 
-	// 7. Start Background Worker for Harvesting
+	// 8. Start Background Workers
 	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
 	defer stop()
 
@@ -73,8 +76,12 @@ func main() {
 		},
 	}
 
+	// Start Auto-Harvesting
 	go yieldSvc.StartAutoHarvestWorker(ctx, 1*time.Hour, strategies)
 
+	// Listen for new settlements and route 100% to Riquid
+	go yieldSvc.ListenForSettlements(ctx, bus, strategies[0], 100.0)
+
 	log.Println("✅ Settlement daemon is running")
 
 	// Keep alive until interrupt