inbound.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965
  1. package service
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "strings"
  6. "time"
  7. "x-ui/database"
  8. "x-ui/database/model"
  9. "x-ui/logger"
  10. "x-ui/util/common"
  11. "x-ui/xray"
  12. "gorm.io/gorm"
  13. )
  14. type InboundService struct {
  15. }
  16. func (s *InboundService) GetInbounds(userId int) ([]*model.Inbound, error) {
  17. db := database.GetDB()
  18. var inbounds []*model.Inbound
  19. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("user_id = ?", userId).Find(&inbounds).Error
  20. if err != nil && err != gorm.ErrRecordNotFound {
  21. return nil, err
  22. }
  23. return inbounds, nil
  24. }
  25. func (s *InboundService) GetAllInbounds() ([]*model.Inbound, error) {
  26. db := database.GetDB()
  27. var inbounds []*model.Inbound
  28. err := db.Model(model.Inbound{}).Preload("ClientStats").Find(&inbounds).Error
  29. if err != nil && err != gorm.ErrRecordNotFound {
  30. return nil, err
  31. }
  32. return inbounds, nil
  33. }
  34. func (s *InboundService) checkPortExist(port int, ignoreId int) (bool, error) {
  35. db := database.GetDB()
  36. db = db.Model(model.Inbound{}).Where("port = ?", port)
  37. if ignoreId > 0 {
  38. db = db.Where("id != ?", ignoreId)
  39. }
  40. var count int64
  41. err := db.Count(&count).Error
  42. if err != nil {
  43. return false, err
  44. }
  45. return count > 0, nil
  46. }
  47. func (s *InboundService) getClients(inbound *model.Inbound) ([]model.Client, error) {
  48. settings := map[string][]model.Client{}
  49. json.Unmarshal([]byte(inbound.Settings), &settings)
  50. if settings == nil {
  51. return nil, fmt.Errorf("setting is null")
  52. }
  53. clients := settings["clients"]
  54. if clients == nil {
  55. return nil, nil
  56. }
  57. return clients, nil
  58. }
  59. func (s *InboundService) getAllEmails() ([]string, error) {
  60. db := database.GetDB()
  61. var emails []string
  62. err := db.Raw(`
  63. SELECT JSON_EXTRACT(client.value, '$.email')
  64. FROM inbounds,
  65. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  66. `).Scan(&emails).Error
  67. if err != nil {
  68. return nil, err
  69. }
  70. return emails, nil
  71. }
  72. func (s *InboundService) contains(slice []string, str string) bool {
  73. for _, s := range slice {
  74. if s == str {
  75. return true
  76. }
  77. }
  78. return false
  79. }
  80. func (s *InboundService) checkEmailsExistForClients(clients []model.Client) (string, error) {
  81. allEmails, err := s.getAllEmails()
  82. if err != nil {
  83. return "", err
  84. }
  85. var emails []string
  86. for _, client := range clients {
  87. if client.Email != "" {
  88. if s.contains(emails, client.Email) {
  89. return client.Email, nil
  90. }
  91. if s.contains(allEmails, client.Email) {
  92. return client.Email, nil
  93. }
  94. emails = append(emails, client.Email)
  95. }
  96. }
  97. return "", nil
  98. }
  99. func (s *InboundService) checkEmailExistForInbound(inbound *model.Inbound) (string, error) {
  100. clients, err := s.getClients(inbound)
  101. if err != nil {
  102. return "", err
  103. }
  104. allEmails, err := s.getAllEmails()
  105. if err != nil {
  106. return "", err
  107. }
  108. var emails []string
  109. for _, client := range clients {
  110. if client.Email != "" {
  111. if s.contains(emails, client.Email) {
  112. return client.Email, nil
  113. }
  114. if s.contains(allEmails, client.Email) {
  115. return client.Email, nil
  116. }
  117. emails = append(emails, client.Email)
  118. }
  119. }
  120. return "", nil
  121. }
  122. func (s *InboundService) AddInbound(inbound *model.Inbound) (*model.Inbound, error) {
  123. exist, err := s.checkPortExist(inbound.Port, 0)
  124. if err != nil {
  125. return inbound, err
  126. }
  127. if exist {
  128. return inbound, common.NewError("Port already exists:", inbound.Port)
  129. }
  130. existEmail, err := s.checkEmailExistForInbound(inbound)
  131. if err != nil {
  132. return inbound, err
  133. }
  134. if existEmail != "" {
  135. return inbound, common.NewError("Duplicate email:", existEmail)
  136. }
  137. clients, err := s.getClients(inbound)
  138. if err != nil {
  139. return inbound, err
  140. }
  141. db := database.GetDB()
  142. err = db.Save(inbound).Error
  143. if err == nil {
  144. for _, client := range clients {
  145. s.AddClientStat(inbound.Id, &client)
  146. }
  147. }
  148. return inbound, err
  149. }
  150. func (s *InboundService) AddInbounds(inbounds []*model.Inbound) error {
  151. for _, inbound := range inbounds {
  152. exist, err := s.checkPortExist(inbound.Port, 0)
  153. if err != nil {
  154. return err
  155. }
  156. if exist {
  157. return common.NewError("Port already exists:", inbound.Port)
  158. }
  159. }
  160. db := database.GetDB()
  161. tx := db.Begin()
  162. var err error
  163. defer func() {
  164. if err == nil {
  165. tx.Commit()
  166. } else {
  167. tx.Rollback()
  168. }
  169. }()
  170. for _, inbound := range inbounds {
  171. err = tx.Save(inbound).Error
  172. if err != nil {
  173. return err
  174. }
  175. }
  176. return nil
  177. }
  178. func (s *InboundService) DelInbound(id int) error {
  179. db := database.GetDB()
  180. err := db.Where("inbound_id = ?", id).Delete(xray.ClientTraffic{}).Error
  181. if err != nil {
  182. return err
  183. }
  184. inbound, err := s.GetInbound(id)
  185. if err != nil {
  186. return err
  187. }
  188. clients, err := s.getClients(inbound)
  189. if err != nil {
  190. return err
  191. }
  192. for _, client := range clients {
  193. err := s.DelClientIPs(db, client.Email)
  194. if err != nil {
  195. return err
  196. }
  197. }
  198. return db.Delete(model.Inbound{}, id).Error
  199. }
  200. func (s *InboundService) GetInbound(id int) (*model.Inbound, error) {
  201. db := database.GetDB()
  202. inbound := &model.Inbound{}
  203. err := db.Model(model.Inbound{}).First(inbound, id).Error
  204. if err != nil {
  205. return nil, err
  206. }
  207. return inbound, nil
  208. }
  209. func (s *InboundService) UpdateInbound(inbound *model.Inbound) (*model.Inbound, error) {
  210. exist, err := s.checkPortExist(inbound.Port, inbound.Id)
  211. if err != nil {
  212. return inbound, err
  213. }
  214. if exist {
  215. return inbound, common.NewError("Port already exists:", inbound.Port)
  216. }
  217. oldInbound, err := s.GetInbound(inbound.Id)
  218. if err != nil {
  219. return inbound, err
  220. }
  221. oldInbound.Up = inbound.Up
  222. oldInbound.Down = inbound.Down
  223. oldInbound.Total = inbound.Total
  224. oldInbound.Remark = inbound.Remark
  225. oldInbound.Enable = inbound.Enable
  226. oldInbound.ExpiryTime = inbound.ExpiryTime
  227. oldInbound.Listen = inbound.Listen
  228. oldInbound.Port = inbound.Port
  229. oldInbound.Protocol = inbound.Protocol
  230. oldInbound.Settings = inbound.Settings
  231. oldInbound.StreamSettings = inbound.StreamSettings
  232. oldInbound.Sniffing = inbound.Sniffing
  233. oldInbound.Tag = fmt.Sprintf("inbound-%v", inbound.Port)
  234. db := database.GetDB()
  235. return inbound, db.Save(oldInbound).Error
  236. }
  237. func (s *InboundService) AddInboundClient(data *model.Inbound) error {
  238. clients, err := s.getClients(data)
  239. if err != nil {
  240. return err
  241. }
  242. var settings map[string]interface{}
  243. err = json.Unmarshal([]byte(data.Settings), &settings)
  244. if err != nil {
  245. return err
  246. }
  247. interfaceClients := settings["clients"].([]interface{})
  248. existEmail, err := s.checkEmailsExistForClients(clients)
  249. if err != nil {
  250. return err
  251. }
  252. if existEmail != "" {
  253. return common.NewError("Duplicate email:", existEmail)
  254. }
  255. oldInbound, err := s.GetInbound(data.Id)
  256. if err != nil {
  257. return err
  258. }
  259. var oldSettings map[string]interface{}
  260. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  261. if err != nil {
  262. return err
  263. }
  264. oldClients := oldSettings["clients"].([]interface{})
  265. oldClients = append(oldClients, interfaceClients...)
  266. oldSettings["clients"] = oldClients
  267. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  268. if err != nil {
  269. return err
  270. }
  271. oldInbound.Settings = string(newSettings)
  272. for _, client := range clients {
  273. if len(client.Email) > 0 {
  274. s.AddClientStat(data.Id, &client)
  275. }
  276. }
  277. db := database.GetDB()
  278. return db.Save(oldInbound).Error
  279. }
  280. func (s *InboundService) DelInboundClient(inboundId int, clientId string) error {
  281. oldInbound, err := s.GetInbound(inboundId)
  282. if err != nil {
  283. logger.Error("Load Old Data Error")
  284. return err
  285. }
  286. var settings map[string]interface{}
  287. err = json.Unmarshal([]byte(oldInbound.Settings), &settings)
  288. if err != nil {
  289. return err
  290. }
  291. email := ""
  292. client_key := "id"
  293. if oldInbound.Protocol == "trojan" {
  294. client_key = "password"
  295. }
  296. inerfaceClients := settings["clients"].([]interface{})
  297. var newClients []interface{}
  298. for _, client := range inerfaceClients {
  299. c := client.(map[string]interface{})
  300. c_id := c[client_key].(string)
  301. if c_id == clientId {
  302. email = c["email"].(string)
  303. } else {
  304. newClients = append(newClients, client)
  305. }
  306. }
  307. settings["clients"] = newClients
  308. newSettings, err := json.MarshalIndent(settings, "", " ")
  309. if err != nil {
  310. return err
  311. }
  312. oldInbound.Settings = string(newSettings)
  313. db := database.GetDB()
  314. err = s.DelClientStat(db, email)
  315. if err != nil {
  316. logger.Error("Delete stats Data Error")
  317. return err
  318. }
  319. err = s.DelClientIPs(db, email)
  320. if err != nil {
  321. logger.Error("Error in delete client IPs")
  322. return err
  323. }
  324. return db.Save(oldInbound).Error
  325. }
  326. func (s *InboundService) UpdateInboundClient(data *model.Inbound, clientId string) error {
  327. clients, err := s.getClients(data)
  328. if err != nil {
  329. return err
  330. }
  331. var settings map[string]interface{}
  332. err = json.Unmarshal([]byte(data.Settings), &settings)
  333. if err != nil {
  334. return err
  335. }
  336. inerfaceClients := settings["clients"].([]interface{})
  337. oldInbound, err := s.GetInbound(data.Id)
  338. if err != nil {
  339. return err
  340. }
  341. oldClients, err := s.getClients(oldInbound)
  342. if err != nil {
  343. return err
  344. }
  345. oldEmail := ""
  346. clientIndex := 0
  347. for index, oldClient := range oldClients {
  348. oldClientId := ""
  349. if oldInbound.Protocol == "trojan" {
  350. oldClientId = oldClient.Password
  351. } else {
  352. oldClientId = oldClient.ID
  353. }
  354. if clientId == oldClientId {
  355. oldEmail = oldClient.Email
  356. clientIndex = index
  357. break
  358. }
  359. }
  360. if len(clients[0].Email) > 0 && clients[0].Email != oldEmail {
  361. existEmail, err := s.checkEmailsExistForClients(clients)
  362. if err != nil {
  363. return err
  364. }
  365. if existEmail != "" {
  366. return common.NewError("Duplicate email:", existEmail)
  367. }
  368. }
  369. var oldSettings map[string]interface{}
  370. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  371. if err != nil {
  372. return err
  373. }
  374. settingsClients := oldSettings["clients"].([]interface{})
  375. settingsClients[clientIndex] = inerfaceClients[0]
  376. oldSettings["clients"] = settingsClients
  377. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  378. if err != nil {
  379. return err
  380. }
  381. oldInbound.Settings = string(newSettings)
  382. db := database.GetDB()
  383. if len(clients[0].Email) > 0 {
  384. if len(oldEmail) > 0 {
  385. err = s.UpdateClientStat(oldEmail, &clients[0])
  386. if err != nil {
  387. return err
  388. }
  389. err = s.UpdateClientIPs(db, oldEmail, clients[0].Email)
  390. if err != nil {
  391. return err
  392. }
  393. } else {
  394. s.AddClientStat(data.Id, &clients[0])
  395. }
  396. } else {
  397. err = s.DelClientStat(db, oldEmail)
  398. if err != nil {
  399. return err
  400. }
  401. err = s.DelClientIPs(db, oldEmail)
  402. if err != nil {
  403. return err
  404. }
  405. }
  406. return db.Save(oldInbound).Error
  407. }
  408. func (s *InboundService) AddTraffic(traffics []*xray.Traffic) error {
  409. if len(traffics) == 0 {
  410. return nil
  411. }
  412. // Update traffics in a single transaction
  413. err := database.GetDB().Transaction(func(tx *gorm.DB) error {
  414. for _, traffic := range traffics {
  415. if traffic.IsInbound {
  416. update := tx.Model(&model.Inbound{}).Where("tag = ?", traffic.Tag).
  417. Updates(map[string]interface{}{
  418. "up": gorm.Expr("up + ?", traffic.Up),
  419. "down": gorm.Expr("down + ?", traffic.Down),
  420. })
  421. if update.Error != nil {
  422. return update.Error
  423. }
  424. }
  425. }
  426. return nil
  427. })
  428. return err
  429. }
  430. func (s *InboundService) AddClientTraffic(traffics []*xray.ClientTraffic) (err error) {
  431. if len(traffics) == 0 {
  432. return nil
  433. }
  434. db := database.GetDB()
  435. tx := db.Begin()
  436. defer func() {
  437. if err != nil {
  438. tx.Rollback()
  439. } else {
  440. tx.Commit()
  441. }
  442. }()
  443. emails := make([]string, 0, len(traffics))
  444. for _, traffic := range traffics {
  445. emails = append(emails, traffic.Email)
  446. }
  447. dbClientTraffics := make([]*xray.ClientTraffic, 0, len(traffics))
  448. err = db.Model(xray.ClientTraffic{}).Where("email IN (?)", emails).Find(&dbClientTraffics).Error
  449. if err != nil {
  450. return err
  451. }
  452. dbClientTraffics, err = s.adjustTraffics(tx, dbClientTraffics)
  453. if err != nil {
  454. return err
  455. }
  456. for dbTraffic_index := range dbClientTraffics {
  457. for traffic_index := range traffics {
  458. if dbClientTraffics[dbTraffic_index].Email == traffics[traffic_index].Email {
  459. dbClientTraffics[dbTraffic_index].Up += traffics[traffic_index].Up
  460. dbClientTraffics[dbTraffic_index].Down += traffics[traffic_index].Down
  461. break
  462. }
  463. }
  464. }
  465. err = tx.Save(dbClientTraffics).Error
  466. if err != nil {
  467. logger.Warning("AddClientTraffic update data ", err)
  468. }
  469. return nil
  470. }
  471. func (s *InboundService) adjustTraffics(tx *gorm.DB, dbClientTraffics []*xray.ClientTraffic) ([]*xray.ClientTraffic, error) {
  472. inboundIds := make([]int, 0, len(dbClientTraffics))
  473. for _, dbClientTraffic := range dbClientTraffics {
  474. if dbClientTraffic.ExpiryTime < 0 {
  475. inboundIds = append(inboundIds, dbClientTraffic.InboundId)
  476. }
  477. }
  478. if len(inboundIds) > 0 {
  479. var inbounds []*model.Inbound
  480. err := tx.Model(model.Inbound{}).Where("id IN (?)", inboundIds).Find(&inbounds).Error
  481. if err != nil {
  482. return nil, err
  483. }
  484. for inbound_index := range inbounds {
  485. settings := map[string]interface{}{}
  486. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  487. clients, ok := settings["clients"].([]interface{})
  488. if ok {
  489. var newClients []interface{}
  490. for client_index := range clients {
  491. c := clients[client_index].(map[string]interface{})
  492. for traffic_index := range dbClientTraffics {
  493. if c["email"] == dbClientTraffics[traffic_index].Email {
  494. oldExpiryTime := c["expiryTime"].(float64)
  495. newExpiryTime := (time.Now().Unix() * 1000) - int64(oldExpiryTime)
  496. c["expiryTime"] = newExpiryTime
  497. dbClientTraffics[traffic_index].ExpiryTime = newExpiryTime
  498. break
  499. }
  500. }
  501. newClients = append(newClients, interface{}(c))
  502. }
  503. settings["clients"] = newClients
  504. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  505. if err != nil {
  506. return nil, err
  507. }
  508. inbounds[inbound_index].Settings = string(modifiedSettings)
  509. }
  510. }
  511. err = tx.Save(inbounds).Error
  512. if err != nil {
  513. logger.Warning("AddClientTraffic update inbounds ", err)
  514. logger.Error(inbounds)
  515. }
  516. }
  517. return dbClientTraffics, nil
  518. }
  519. func (s *InboundService) DisableInvalidInbounds() (int64, error) {
  520. db := database.GetDB()
  521. now := time.Now().Unix() * 1000
  522. result := db.Model(model.Inbound{}).
  523. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  524. Update("enable", false)
  525. err := result.Error
  526. count := result.RowsAffected
  527. return count, err
  528. }
  529. func (s *InboundService) DisableInvalidClients() (int64, error) {
  530. db := database.GetDB()
  531. now := time.Now().Unix() * 1000
  532. result := db.Model(xray.ClientTraffic{}).
  533. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  534. Update("enable", false)
  535. err := result.Error
  536. count := result.RowsAffected
  537. return count, err
  538. }
  539. func (s *InboundService) RemoveOrphanedTraffics() {
  540. db := database.GetDB()
  541. db.Exec(`
  542. DELETE FROM client_traffics
  543. WHERE email NOT IN (
  544. SELECT JSON_EXTRACT(client.value, '$.email')
  545. FROM inbounds,
  546. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  547. )
  548. `)
  549. }
  550. func (s *InboundService) AddClientStat(inboundId int, client *model.Client) error {
  551. db := database.GetDB()
  552. clientTraffic := xray.ClientTraffic{}
  553. clientTraffic.InboundId = inboundId
  554. clientTraffic.Email = client.Email
  555. clientTraffic.Total = client.TotalGB
  556. clientTraffic.ExpiryTime = client.ExpiryTime
  557. clientTraffic.Enable = true
  558. clientTraffic.Up = 0
  559. clientTraffic.Down = 0
  560. result := db.Create(&clientTraffic)
  561. err := result.Error
  562. if err != nil {
  563. return err
  564. }
  565. return nil
  566. }
  567. func (s *InboundService) UpdateClientStat(email string, client *model.Client) error {
  568. db := database.GetDB()
  569. result := db.Model(xray.ClientTraffic{}).
  570. Where("email = ?", email).
  571. Updates(map[string]interface{}{
  572. "enable": true,
  573. "email": client.Email,
  574. "total": client.TotalGB,
  575. "expiry_time": client.ExpiryTime})
  576. err := result.Error
  577. if err != nil {
  578. return err
  579. }
  580. return nil
  581. }
  582. func (s *InboundService) UpdateClientIPs(tx *gorm.DB, oldEmail string, newEmail string) error {
  583. return tx.Model(model.InboundClientIps{}).Where("client_email = ?", oldEmail).Update("client_email", newEmail).Error
  584. }
  585. func (s *InboundService) DelClientStat(tx *gorm.DB, email string) error {
  586. return tx.Where("email = ?", email).Delete(xray.ClientTraffic{}).Error
  587. }
  588. func (s *InboundService) DelClientIPs(tx *gorm.DB, email string) error {
  589. logger.Warning(email)
  590. return tx.Where("client_email = ?", email).Delete(model.InboundClientIps{}).Error
  591. }
  592. func (s *InboundService) ResetClientTraffic(id int, clientEmail string) error {
  593. db := database.GetDB()
  594. result := db.Model(xray.ClientTraffic{}).
  595. Where("inbound_id = ? and email = ?", id, clientEmail).
  596. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  597. err := result.Error
  598. if err != nil {
  599. return err
  600. }
  601. return nil
  602. }
  603. func (s *InboundService) ResetAllClientTraffics(id int) error {
  604. db := database.GetDB()
  605. whereText := "inbound_id "
  606. if id == -1 {
  607. whereText += " > ?"
  608. } else {
  609. whereText += " = ?"
  610. }
  611. result := db.Model(xray.ClientTraffic{}).
  612. Where(whereText, id).
  613. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  614. err := result.Error
  615. if err != nil {
  616. return err
  617. }
  618. return nil
  619. }
  620. func (s *InboundService) ResetAllTraffics() error {
  621. db := database.GetDB()
  622. result := db.Model(model.Inbound{}).
  623. Where("user_id > ?", 0).
  624. Updates(map[string]interface{}{"up": 0, "down": 0})
  625. err := result.Error
  626. if err != nil {
  627. return err
  628. }
  629. return nil
  630. }
  631. func (s *InboundService) DelDepletedClients(id int) (err error) {
  632. db := database.GetDB()
  633. tx := db.Begin()
  634. defer func() {
  635. if err == nil {
  636. tx.Commit()
  637. } else {
  638. tx.Rollback()
  639. }
  640. }()
  641. whereText := "inbound_id "
  642. if id < 0 {
  643. whereText += "> ?"
  644. } else {
  645. whereText += "= ?"
  646. }
  647. depletedClients := []xray.ClientTraffic{}
  648. err = db.Model(xray.ClientTraffic{}).Where(whereText+" and enable = ?", id, false).Select("inbound_id, GROUP_CONCAT(email) as email").Group("inbound_id").Find(&depletedClients).Error
  649. if err != nil {
  650. return err
  651. }
  652. for _, depletedClient := range depletedClients {
  653. emails := strings.Split(depletedClient.Email, ",")
  654. oldInbound, err := s.GetInbound(depletedClient.InboundId)
  655. if err != nil {
  656. return err
  657. }
  658. var oldSettings map[string]interface{}
  659. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  660. if err != nil {
  661. return err
  662. }
  663. oldClients := oldSettings["clients"].([]interface{})
  664. var newClients []interface{}
  665. for _, client := range oldClients {
  666. deplete := false
  667. c := client.(map[string]interface{})
  668. for _, email := range emails {
  669. if email == c["email"].(string) {
  670. deplete = true
  671. break
  672. }
  673. }
  674. if !deplete {
  675. newClients = append(newClients, client)
  676. }
  677. }
  678. if len(newClients) > 0 {
  679. oldSettings["clients"] = newClients
  680. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  681. if err != nil {
  682. return err
  683. }
  684. oldInbound.Settings = string(newSettings)
  685. err = tx.Save(oldInbound).Error
  686. if err != nil {
  687. return err
  688. }
  689. } else {
  690. // Delete inbound if no client remains
  691. s.DelInbound(depletedClient.InboundId)
  692. }
  693. }
  694. err = tx.Where(whereText+" and enable = ?", id, false).Delete(xray.ClientTraffic{}).Error
  695. if err != nil {
  696. return err
  697. }
  698. return nil
  699. }
  700. func (s *InboundService) GetClientTrafficTgBot(tguname string) ([]*xray.ClientTraffic, error) {
  701. db := database.GetDB()
  702. var inbounds []*model.Inbound
  703. err := db.Model(model.Inbound{}).Where("settings like ?", fmt.Sprintf(`%%"tgId": "%s"%%`, tguname)).Find(&inbounds).Error
  704. if err != nil && err != gorm.ErrRecordNotFound {
  705. return nil, err
  706. }
  707. var emails []string
  708. for _, inbound := range inbounds {
  709. clients, err := s.getClients(inbound)
  710. if err != nil {
  711. logger.Error("Unable to get clients from inbound")
  712. }
  713. for _, client := range clients {
  714. if client.TgID == tguname {
  715. emails = append(emails, client.Email)
  716. }
  717. }
  718. }
  719. var traffics []*xray.ClientTraffic
  720. err = db.Model(xray.ClientTraffic{}).Where("email IN ?", emails).Find(&traffics).Error
  721. if err != nil {
  722. if err == gorm.ErrRecordNotFound {
  723. logger.Warning(err)
  724. return nil, err
  725. }
  726. }
  727. return traffics, err
  728. }
  729. func (s *InboundService) GetClientTrafficByEmail(email string) (traffic *xray.ClientTraffic, err error) {
  730. db := database.GetDB()
  731. var traffics []*xray.ClientTraffic
  732. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  733. if err != nil {
  734. if err == gorm.ErrRecordNotFound {
  735. logger.Warning(err)
  736. return nil, err
  737. }
  738. }
  739. return traffics[0], err
  740. }
  741. func (s *InboundService) SearchClientTraffic(query string) (traffic *xray.ClientTraffic, err error) {
  742. db := database.GetDB()
  743. inbound := &model.Inbound{}
  744. traffic = &xray.ClientTraffic{}
  745. err = db.Model(model.Inbound{}).Where("settings like ?", "%\""+query+"\"%").First(inbound).Error
  746. if err != nil {
  747. if err == gorm.ErrRecordNotFound {
  748. logger.Warning(err)
  749. return nil, err
  750. }
  751. }
  752. traffic.InboundId = inbound.Id
  753. // get settings clients
  754. settings := map[string][]model.Client{}
  755. json.Unmarshal([]byte(inbound.Settings), &settings)
  756. clients := settings["clients"]
  757. for _, client := range clients {
  758. if client.ID == query && client.Email != "" {
  759. traffic.Email = client.Email
  760. break
  761. }
  762. if client.Password == query && client.Email != "" {
  763. traffic.Email = client.Email
  764. break
  765. }
  766. }
  767. if traffic.Email == "" {
  768. return nil, err
  769. }
  770. err = db.Model(xray.ClientTraffic{}).Where("email = ?", traffic.Email).First(traffic).Error
  771. if err != nil {
  772. logger.Warning(err)
  773. return nil, err
  774. }
  775. return traffic, err
  776. }
  777. func (s *InboundService) GetInboundClientIps(clientEmail string) (string, error) {
  778. db := database.GetDB()
  779. InboundClientIps := &model.InboundClientIps{}
  780. err := db.Model(model.InboundClientIps{}).Where("client_email = ?", clientEmail).First(InboundClientIps).Error
  781. if err != nil {
  782. return "", err
  783. }
  784. return InboundClientIps.Ips, nil
  785. }
  786. func (s *InboundService) ClearClientIps(clientEmail string) error {
  787. db := database.GetDB()
  788. result := db.Model(model.InboundClientIps{}).
  789. Where("client_email = ?", clientEmail).
  790. Update("ips", "")
  791. err := result.Error
  792. if err != nil {
  793. return err
  794. }
  795. return nil
  796. }
  797. func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) {
  798. db := database.GetDB()
  799. var inbounds []*model.Inbound
  800. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("remark like ?", "%"+query+"%").Find(&inbounds).Error
  801. if err != nil && err != gorm.ErrRecordNotFound {
  802. return nil, err
  803. }
  804. return inbounds, nil
  805. }
  806. func (s *InboundService) MigrationRequirements() {
  807. db := database.GetDB()
  808. var inbounds []*model.Inbound
  809. err := db.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error
  810. if err != nil && err != gorm.ErrRecordNotFound {
  811. return
  812. }
  813. for inbound_index := range inbounds {
  814. settings := map[string]interface{}{}
  815. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  816. clients, ok := settings["clients"].([]interface{})
  817. if ok {
  818. var newClients []interface{}
  819. for client_index := range clients {
  820. c := clients[client_index].(map[string]interface{})
  821. // Add email='' if it is not exists
  822. if _, ok := c["email"]; !ok {
  823. c["email"] = ""
  824. }
  825. // Remove "flow": "xtls-rprx-direct"
  826. if _, ok := c["flow"]; ok {
  827. if c["flow"] == "xtls-rprx-direct" {
  828. c["flow"] = ""
  829. }
  830. }
  831. newClients = append(newClients, interface{}(c))
  832. }
  833. settings["clients"] = newClients
  834. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  835. if err != nil {
  836. return
  837. }
  838. inbounds[inbound_index].Settings = string(modifiedSettings)
  839. }
  840. modelClients, err := s.getClients(inbounds[inbound_index])
  841. if err != nil {
  842. return
  843. }
  844. for _, modelClient := range modelClients {
  845. if len(modelClient.Email) > 0 {
  846. var count int64
  847. db.Model(xray.ClientTraffic{}).Where("email = ?", modelClient.Email).Count(&count)
  848. if count == 0 {
  849. s.AddClientStat(inbounds[inbound_index].Id, &modelClient)
  850. }
  851. }
  852. }
  853. }
  854. db.Save(inbounds)
  855. }