chore: optimize the session usage validate worker

Author: ironman0x7b2

workers/session.go

@@ -195,7 +195,8 @@ func NewSessionUsageValidateWorker(c *core.Context, interval time.Duration) cron
 	handlerFunc := func(ctx context.Context) error {
 		// Retrieve session records from the database.
 		query := map[string]interface{}{
-			"node_addr": c.NodeAddr().String(),
+			"node_addr":    c.NodeAddr().String(),
+			"service_type": c.Service().Type().String(),
 		}
 
 		items, err := operations.SessionFind(c.Database(), query)
@@ -238,15 +239,6 @@ func NewSessionUsageValidateWorker(c *core.Context, interval time.Duration) cron
 					removePeer = true
 				}
 
-				// Ensure that only sessions of the current service type are validated.
-				if item.GetServiceType() != c.Service().Type() {
-					log.Debug("Skipping peer",
-						"id", item.GetID(), "peer_id", item.GetPeerID(), "cause", "invalid service type",
-						"got", item.GetServiceType(), "expected", c.Service().Type(),
-					)
-					removePeer = false
-				}
-
 				// If the session exceeded any limits, remove the associated peer.
 				if removePeer {
 					log.Debug("Removing peer from service", "id", item.GetID(), "peer_id", item.GetPeerID())