diff options
| author | mhsanaei <ho3ein.sanaei@gmail.com> | 2025-09-18 12:41:11 +0300 |
|---|---|---|
| committer | mhsanaei <ho3ein.sanaei@gmail.com> | 2025-09-18 12:41:11 +0300 |
| commit | 170d24499e5dff91bda121d0b46190de7156ce78 (patch) | |
| tree | cc2a2b88437f40e5b3a75ecc01d59eb0ca62f648 | |
| parent | 99c79d4056a1efb636010739f56bb1c623f47634 (diff) | |
fix PeriodicTrafficResetJob: log only when there are matching inbound
| -rw-r--r-- | web/job/periodic_traffic_reset_job.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/web/job/periodic_traffic_reset_job.go b/web/job/periodic_traffic_reset_job.go index 79001973..1369c200 100644 --- a/web/job/periodic_traffic_reset_job.go +++ b/web/job/periodic_traffic_reset_job.go @@ -20,12 +20,16 @@ func NewPeriodicTrafficResetJob(period Period) *PeriodicTrafficResetJob { func (j *PeriodicTrafficResetJob) Run() { inbounds, err := j.inboundService.GetInboundsByTrafficReset(string(j.period)) - logger.Infof("Running periodic traffic reset job for period: %s", j.period) if err != nil { logger.Warning("Failed to get inbounds for traffic reset:", err) return } + if len(inbounds) == 0 { + return + } + logger.Infof("Running periodic traffic reset job for period: %s (%d matching inbounds)", j.period, len(inbounds)) + resetCount := 0 for _, inbound := range inbounds { |