Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/MHSanaei/3x-ui.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/web/job
diff options
context:
space:
mode:
authorMHSanaei <ho3ein.sanaei@gmail.com>2024-01-21 14:09:15 +0300
committerMHSanaei <ho3ein.sanaei@gmail.com>2024-01-21 14:09:15 +0300
commite7ce8c8ddb8472695b296eac305c5ac9b8c1d3d8 (patch)
tree4d2d3153d5ed585fbade011cfaca58175e5301e5 /web/job
parent4b9bbbc34b3ed5563f9cb14420b768d241580cf3 (diff)
minor changes
disAllowedIps doesn't show on debug if there is no ip change copy to clipboard to export inbound
Diffstat (limited to 'web/job')
-rw-r--r--web/job/check_client_ip_job.go23
1 files changed, 14 insertions, 9 deletions
diff --git a/web/job/check_client_ip_job.go b/web/job/check_client_ip_job.go
index 65257170..b393e68d 100644
--- a/web/job/check_client_ip_job.go
+++ b/web/job/check_client_ip_job.go
@@ -16,17 +16,18 @@ import (
"x-ui/xray"
)
-type CheckClientIpJob struct{}
+type CheckClientIpJob struct {
+ disAllowedIps []string
+}
var job *CheckClientIpJob
-var disAllowedIps []string
var ipFiles = []string{
xray.GetIPLimitLogPath(),
-xray.GetIPLimitPrevLogPath(),
+ xray.GetIPLimitPrevLogPath(),
xray.GetIPLimitBannedLogPath(),
-xray.GetIPLimitBannedPrevLogPath(),
+ xray.GetIPLimitBannedPrevLogPath(),
xray.GetAccessPersistentLogPath(),
-xray.GetAccessPersistentPrevLogPath(),
+ xray.GetAccessPersistentPrevLogPath(),
}
func NewCheckClientIpJob() *CheckClientIpJob {
@@ -130,7 +131,6 @@ func (j *CheckClientIpJob) processLogFile() {
}
}
- disAllowedIps = []string{}
shouldCleanLog := false
for clientEmail, ips := range InboundClientIps {
@@ -237,6 +237,7 @@ func (j *CheckClientIpJob) updateInboundClientIps(inboundClientIps *model.Inboun
json.Unmarshal([]byte(inbound.Settings), &settings)
clients := settings["clients"]
shouldCleanLog := false
+ j.disAllowedIps = []string{}
// create iplimit log file channel
logIpFile, err := os.OpenFile(xray.GetIPLimitLogPath(), os.O_CREATE|os.O_APPEND|os.O_RDWR, 0644)
@@ -255,7 +256,7 @@ func (j *CheckClientIpJob) updateInboundClientIps(inboundClientIps *model.Inboun
shouldCleanLog = true
if limitIp < len(ips) && inbound.Enable {
- disAllowedIps = append(disAllowedIps, ips[limitIp:]...)
+ j.disAllowedIps = append(j.disAllowedIps, ips[limitIp:]...)
for i := limitIp; i < len(ips); i++ {
log.Printf("[LIMIT_IP] Email = %s || SRC = %s", clientEmail, ips[i])
}
@@ -263,8 +264,12 @@ func (j *CheckClientIpJob) updateInboundClientIps(inboundClientIps *model.Inboun
}
}
}
- logger.Debug("disAllowedIps ", disAllowedIps)
- sort.Strings(disAllowedIps)
+
+ sort.Strings(j.disAllowedIps)
+
+ if len(j.disAllowedIps) > 0 {
+ logger.Debug("disAllowedIps ", j.disAllowedIps)
+ }
db := database.GetDB()
err = db.Save(inboundClientIps).Error