[migrate] remove orphaned traffics

Co-Authored-By: Alireza Ahmadi <alireza7@gmail.com>

1 files changed, 7 insertions, 0 deletions

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{})
 }