diff options
| author | Saeid <43953720+surbiks@users.noreply.github.com> | 2024-01-29 23:37:20 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-01-29 23:37:20 +0300 |
| commit | 6c0775b12055e4546cb0fd86e1d8d569d886eefa (patch) | |
| tree | 8f7ee64e54f83f9c563a178c4afaee10e072eddc /web/job | |
| parent | 9fbaede59f87dd9d8b77479a3fb295c3c882630e (diff) | |
Show outbound traffic in outbounds table (#1711)
* store outbound traffic in database
* show outbound traffic in outbounds table
* add refresh button
Diffstat (limited to 'web/job')
| -rw-r--r-- | web/job/xray_traffic_job.go | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/web/job/xray_traffic_job.go b/web/job/xray_traffic_job.go index 158930a4..c0de4428 100644 --- a/web/job/xray_traffic_job.go +++ b/web/job/xray_traffic_job.go @@ -6,8 +6,9 @@ import ( ) type XrayTrafficJob struct { - xrayService service.XrayService - inboundService service.InboundService + xrayService service.XrayService + inboundService service.InboundService + outboundService service.OutboundService } func NewXrayTrafficJob() *XrayTrafficJob { @@ -24,11 +25,15 @@ func (j *XrayTrafficJob) Run() { logger.Warning("get xray traffic failed:", err) return } - err, needRestart := j.inboundService.AddTraffic(traffics, clientTraffics) + err, needRestart0 := j.inboundService.AddTraffic(traffics, clientTraffics) if err != nil { - logger.Warning("add traffic failed:", err) + logger.Warning("add inbound traffic failed:", err) } - if needRestart { + err, needRestart1 := j.outboundService.AddTraffic(traffics, clientTraffics) + if err != nil { + logger.Warning("add outbound traffic failed:", err) + } + if needRestart0 || needRestart1 { j.xrayService.SetToNeedRestart() } |