diff options
| author | Ho3ein <ho3ein.sanaei@gmail.com> | 2023-04-11 22:43:22 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-04-11 22:43:22 +0300 |
| commit | 2c7b8d1d36f23e0e32512f1a2c43200acda973be (patch) | |
| tree | 97048fb65c7f9f8d5570ed0ba0bb6bd95a948297 /web/service/inbound.go | |
| parent | de8ba292534e1ade2d7665a1e91734d7070ae085 (diff) | |
| parent | c38d75f3d901e7a3f550ab05aef711f95421cae6 (diff) | |
Merge pull request #214 from MHSanaei/dev
bug fixed + reality for trojan
Diffstat (limited to 'web/service/inbound.go')
| -rw-r--r-- | web/service/inbound.go | 19 |
1 files changed, 13 insertions, 6 deletions
diff --git a/web/service/inbound.go b/web/service/inbound.go index 74765ab3..2372e574 100644 --- a/web/service/inbound.go +++ b/web/service/inbound.go @@ -453,12 +453,10 @@ func (s *InboundService) adjustTraffics(traffics []*xray.ClientTraffic) (full_tr } continue } - // get settings clients - settings := map[string]interface{}{} - json.Unmarshal([]byte(inbound.Settings), &settings) - clients, ok := settings["clients"].([]model.Client) + // get clients + clients, err := s.getClients(inbound) needUpdate := false - if ok { + if err == nil { for client_index, client := range clients { if traffic.Email == client.Email { if client.ExpiryTime < 0 { @@ -473,7 +471,16 @@ func (s *InboundService) adjustTraffics(traffics []*xray.ClientTraffic) (full_tr } if needUpdate { - settings["clients"] = clients + settings := map[string]interface{}{} + json.Unmarshal([]byte(inbound.Settings), &settings) + + // Convert clients to []interface to update clients in settings + var clientsInterface []interface{} + for _, c := range clients { + clientsInterface = append(clientsInterface, interface{}(c)) + } + + settings["clients"] = clientsInterface modifiedSettings, err := json.MarshalIndent(settings, "", " ") if err != nil { return nil, err |
