From 103a26edb6990338249c2f33f1a68d83b971a070 Mon Sep 17 00:00:00 2001 From: MHSanaei Date: Thu, 27 Apr 2023 19:05:36 +0330 Subject: [PATCH] [migrate] remove orphaned traffics Co-Authored-By: Alireza Ahmadi --- web/service/inbound.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/web/service/inbound.go b/web/service/inbound.go index 64e54af7..b4549309 100644 --- a/web/service/inbound.go +++ b/web/service/inbound.go @@ -912,6 +912,8 @@ func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) func (s *InboundService) MigrationRequirements() { db := database.GetDB() + + // Fix inbounds based problems var inbounds []*model.Inbound err := db.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error if err != nil && err != gorm.ErrRecordNotFound { @@ -922,6 +924,7 @@ func (s *InboundService) MigrationRequirements() { json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings) clients, ok := settings["clients"].([]interface{}) if ok { + // Fix Clinet configuration problems var newClients []interface{} for client_index := range clients { c := clients[client_index].(map[string]interface{}) @@ -947,6 +950,7 @@ func (s *InboundService) MigrationRequirements() { inbounds[inbound_index].Settings = string(modifiedSettings) } + // Add client traffic row for all clients which has email modelClients, err := s.getClients(inbounds[inbound_index]) if err != nil { return @@ -962,4 +966,7 @@ func (s *InboundService) MigrationRequirements() { } } db.Save(inbounds) + + // Remove orphaned traffics + db.Where("inbound_id = 0").Delete(xray.ClientTraffic{}) }