inbound.go 31 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276
  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. if oldInbound.Protocol == "shadowsocks" {
  297. client_key = "email"
  298. }
  299. inerfaceClients := settings["clients"].([]interface{})
  300. var newClients []interface{}
  301. for _, client := range inerfaceClients {
  302. c := client.(map[string]interface{})
  303. c_id := c[client_key].(string)
  304. if c_id == clientId {
  305. email = c["email"].(string)
  306. } else {
  307. newClients = append(newClients, client)
  308. }
  309. }
  310. settings["clients"] = newClients
  311. newSettings, err := json.MarshalIndent(settings, "", " ")
  312. if err != nil {
  313. return err
  314. }
  315. oldInbound.Settings = string(newSettings)
  316. db := database.GetDB()
  317. err = s.DelClientStat(db, email)
  318. if err != nil {
  319. logger.Error("Delete stats Data Error")
  320. return err
  321. }
  322. err = s.DelClientIPs(db, email)
  323. if err != nil {
  324. logger.Error("Error in delete client IPs")
  325. return err
  326. }
  327. return db.Save(oldInbound).Error
  328. }
  329. func (s *InboundService) UpdateInboundClient(data *model.Inbound, clientId string) error {
  330. clients, err := s.GetClients(data)
  331. if err != nil {
  332. return err
  333. }
  334. var settings map[string]interface{}
  335. err = json.Unmarshal([]byte(data.Settings), &settings)
  336. if err != nil {
  337. return err
  338. }
  339. inerfaceClients := settings["clients"].([]interface{})
  340. oldInbound, err := s.GetInbound(data.Id)
  341. if err != nil {
  342. return err
  343. }
  344. oldClients, err := s.GetClients(oldInbound)
  345. if err != nil {
  346. return err
  347. }
  348. oldEmail := ""
  349. clientIndex := 0
  350. for index, oldClient := range oldClients {
  351. oldClientId := ""
  352. if oldInbound.Protocol == "trojan" {
  353. oldClientId = oldClient.Password
  354. } else if oldInbound.Protocol == "shadowsocks" {
  355. oldClientId = oldClient.Email
  356. } else {
  357. oldClientId = oldClient.ID
  358. }
  359. if clientId == oldClientId {
  360. oldEmail = oldClient.Email
  361. clientIndex = index
  362. break
  363. }
  364. }
  365. if len(clients[0].Email) > 0 && clients[0].Email != oldEmail {
  366. existEmail, err := s.checkEmailsExistForClients(clients)
  367. if err != nil {
  368. return err
  369. }
  370. if existEmail != "" {
  371. return common.NewError("Duplicate email:", existEmail)
  372. }
  373. }
  374. var oldSettings map[string]interface{}
  375. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  376. if err != nil {
  377. return err
  378. }
  379. settingsClients := oldSettings["clients"].([]interface{})
  380. settingsClients[clientIndex] = inerfaceClients[0]
  381. oldSettings["clients"] = settingsClients
  382. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  383. if err != nil {
  384. return err
  385. }
  386. oldInbound.Settings = string(newSettings)
  387. db := database.GetDB()
  388. if len(clients[0].Email) > 0 {
  389. if len(oldEmail) > 0 {
  390. err = s.UpdateClientStat(oldEmail, &clients[0])
  391. if err != nil {
  392. return err
  393. }
  394. err = s.UpdateClientIPs(db, oldEmail, clients[0].Email)
  395. if err != nil {
  396. return err
  397. }
  398. } else {
  399. s.AddClientStat(data.Id, &clients[0])
  400. }
  401. } else {
  402. err = s.DelClientStat(db, oldEmail)
  403. if err != nil {
  404. return err
  405. }
  406. err = s.DelClientIPs(db, oldEmail)
  407. if err != nil {
  408. return err
  409. }
  410. }
  411. return db.Save(oldInbound).Error
  412. }
  413. func (s *InboundService) AddTraffic(traffics []*xray.Traffic) error {
  414. if len(traffics) == 0 {
  415. return nil
  416. }
  417. // Update traffics in a single transaction
  418. err := database.GetDB().Transaction(func(tx *gorm.DB) error {
  419. for _, traffic := range traffics {
  420. if traffic.IsInbound {
  421. update := tx.Model(&model.Inbound{}).Where("tag = ?", traffic.Tag).
  422. Updates(map[string]interface{}{
  423. "up": gorm.Expr("up + ?", traffic.Up),
  424. "down": gorm.Expr("down + ?", traffic.Down),
  425. })
  426. if update.Error != nil {
  427. return update.Error
  428. }
  429. }
  430. }
  431. return nil
  432. })
  433. return err
  434. }
  435. func (s *InboundService) AddClientTraffic(traffics []*xray.ClientTraffic) (err error) {
  436. if len(traffics) == 0 {
  437. return nil
  438. }
  439. db := database.GetDB()
  440. tx := db.Begin()
  441. defer func() {
  442. if err != nil {
  443. tx.Rollback()
  444. } else {
  445. tx.Commit()
  446. }
  447. }()
  448. emails := make([]string, 0, len(traffics))
  449. for _, traffic := range traffics {
  450. emails = append(emails, traffic.Email)
  451. }
  452. dbClientTraffics := make([]*xray.ClientTraffic, 0, len(traffics))
  453. err = db.Model(xray.ClientTraffic{}).Where("email IN (?)", emails).Find(&dbClientTraffics).Error
  454. if err != nil {
  455. return err
  456. }
  457. dbClientTraffics, err = s.adjustTraffics(tx, dbClientTraffics)
  458. if err != nil {
  459. return err
  460. }
  461. for dbTraffic_index := range dbClientTraffics {
  462. for traffic_index := range traffics {
  463. if dbClientTraffics[dbTraffic_index].Email == traffics[traffic_index].Email {
  464. dbClientTraffics[dbTraffic_index].Up += traffics[traffic_index].Up
  465. dbClientTraffics[dbTraffic_index].Down += traffics[traffic_index].Down
  466. break
  467. }
  468. }
  469. }
  470. err = tx.Save(dbClientTraffics).Error
  471. if err != nil {
  472. logger.Warning("AddClientTraffic update data ", err)
  473. }
  474. return nil
  475. }
  476. func (s *InboundService) adjustTraffics(tx *gorm.DB, dbClientTraffics []*xray.ClientTraffic) ([]*xray.ClientTraffic, error) {
  477. inboundIds := make([]int, 0, len(dbClientTraffics))
  478. for _, dbClientTraffic := range dbClientTraffics {
  479. if dbClientTraffic.ExpiryTime < 0 {
  480. inboundIds = append(inboundIds, dbClientTraffic.InboundId)
  481. }
  482. }
  483. if len(inboundIds) > 0 {
  484. var inbounds []*model.Inbound
  485. err := tx.Model(model.Inbound{}).Where("id IN (?)", inboundIds).Find(&inbounds).Error
  486. if err != nil {
  487. return nil, err
  488. }
  489. for inbound_index := range inbounds {
  490. settings := map[string]interface{}{}
  491. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  492. clients, ok := settings["clients"].([]interface{})
  493. if ok {
  494. var newClients []interface{}
  495. for client_index := range clients {
  496. c := clients[client_index].(map[string]interface{})
  497. for traffic_index := range dbClientTraffics {
  498. if dbClientTraffics[traffic_index].ExpiryTime < 0 && c["email"] == dbClientTraffics[traffic_index].Email {
  499. oldExpiryTime := c["expiryTime"].(float64)
  500. newExpiryTime := (time.Now().Unix() * 1000) - int64(oldExpiryTime)
  501. c["expiryTime"] = newExpiryTime
  502. dbClientTraffics[traffic_index].ExpiryTime = newExpiryTime
  503. break
  504. }
  505. }
  506. newClients = append(newClients, interface{}(c))
  507. }
  508. settings["clients"] = newClients
  509. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  510. if err != nil {
  511. return nil, err
  512. }
  513. inbounds[inbound_index].Settings = string(modifiedSettings)
  514. }
  515. }
  516. err = tx.Save(inbounds).Error
  517. if err != nil {
  518. logger.Warning("AddClientTraffic update inbounds ", err)
  519. logger.Error(inbounds)
  520. }
  521. }
  522. return dbClientTraffics, nil
  523. }
  524. func (s *InboundService) DisableInvalidInbounds() (int64, error) {
  525. db := database.GetDB()
  526. now := time.Now().Unix() * 1000
  527. result := db.Model(model.Inbound{}).
  528. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  529. Update("enable", false)
  530. err := result.Error
  531. count := result.RowsAffected
  532. return count, err
  533. }
  534. func (s *InboundService) DisableInvalidClients() (int64, error) {
  535. db := database.GetDB()
  536. now := time.Now().Unix() * 1000
  537. result := db.Model(xray.ClientTraffic{}).
  538. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  539. Update("enable", false)
  540. err := result.Error
  541. count := result.RowsAffected
  542. return count, err
  543. }
  544. func (s *InboundService) MigrationRemoveOrphanedTraffics() {
  545. db := database.GetDB()
  546. db.Exec(`
  547. DELETE FROM client_traffics
  548. WHERE email NOT IN (
  549. SELECT JSON_EXTRACT(client.value, '$.email')
  550. FROM inbounds,
  551. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  552. )
  553. `)
  554. }
  555. func (s *InboundService) AddClientStat(inboundId int, client *model.Client) error {
  556. db := database.GetDB()
  557. clientTraffic := xray.ClientTraffic{}
  558. clientTraffic.InboundId = inboundId
  559. clientTraffic.Email = client.Email
  560. clientTraffic.Total = client.TotalGB
  561. clientTraffic.ExpiryTime = client.ExpiryTime
  562. clientTraffic.Enable = true
  563. clientTraffic.Up = 0
  564. clientTraffic.Down = 0
  565. result := db.Create(&clientTraffic)
  566. err := result.Error
  567. if err != nil {
  568. return err
  569. }
  570. return nil
  571. }
  572. func (s *InboundService) UpdateClientStat(email string, client *model.Client) error {
  573. db := database.GetDB()
  574. result := db.Model(xray.ClientTraffic{}).
  575. Where("email = ?", email).
  576. Updates(map[string]interface{}{
  577. "enable": true,
  578. "email": client.Email,
  579. "total": client.TotalGB,
  580. "expiry_time": client.ExpiryTime})
  581. err := result.Error
  582. if err != nil {
  583. return err
  584. }
  585. return nil
  586. }
  587. func (s *InboundService) UpdateClientIPs(tx *gorm.DB, oldEmail string, newEmail string) error {
  588. return tx.Model(model.InboundClientIps{}).Where("client_email = ?", oldEmail).Update("client_email", newEmail).Error
  589. }
  590. func (s *InboundService) DelClientStat(tx *gorm.DB, email string) error {
  591. return tx.Where("email = ?", email).Delete(xray.ClientTraffic{}).Error
  592. }
  593. func (s *InboundService) DelClientIPs(tx *gorm.DB, email string) error {
  594. logger.Warning(email)
  595. return tx.Where("client_email = ?", email).Delete(model.InboundClientIps{}).Error
  596. }
  597. func (s *InboundService) GetClientInboundByTrafficID(trafficId int) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  598. db := database.GetDB()
  599. var traffics []*xray.ClientTraffic
  600. err = db.Model(xray.ClientTraffic{}).Where("id = ?", trafficId).Find(&traffics).Error
  601. if err != nil {
  602. logger.Warning(err)
  603. return nil, nil, err
  604. }
  605. if len(traffics) > 0 {
  606. inbound, err = s.GetInbound(traffics[0].InboundId)
  607. return traffics[0], inbound, err
  608. }
  609. return nil, nil, nil
  610. }
  611. func (s *InboundService) GetClientInboundByEmail(email string) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  612. db := database.GetDB()
  613. var traffics []*xray.ClientTraffic
  614. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  615. if err != nil {
  616. logger.Warning(err)
  617. return nil, nil, err
  618. }
  619. if len(traffics) > 0 {
  620. inbound, err = s.GetInbound(traffics[0].InboundId)
  621. return traffics[0], inbound, err
  622. }
  623. return nil, nil, nil
  624. }
  625. func (s *InboundService) GetClientByEmail(clientEmail string) (*xray.ClientTraffic, *model.Client, error) {
  626. traffic, inbound, err := s.GetClientInboundByEmail(clientEmail)
  627. if err != nil {
  628. return nil, nil, err
  629. }
  630. if inbound == nil {
  631. return nil, nil, common.NewError("Inbound Not Found For Email:", clientEmail)
  632. }
  633. clients, err := s.GetClients(inbound)
  634. if err != nil {
  635. return nil, nil, err
  636. }
  637. for _, client := range clients {
  638. if client.Email == clientEmail {
  639. return traffic, &client, nil
  640. }
  641. }
  642. return nil, nil, common.NewError("Client Not Found In Inbound For Email:", clientEmail)
  643. }
  644. func (s *InboundService) SetClientTelegramUserID(trafficId int, tgId string) error {
  645. traffic, inbound, err := s.GetClientInboundByTrafficID(trafficId)
  646. if err != nil {
  647. return err
  648. }
  649. if inbound == nil {
  650. return common.NewError("Inbound Not Found For Traffic ID:", trafficId)
  651. }
  652. clientEmail := traffic.Email
  653. oldClients, err := s.GetClients(inbound)
  654. if err != nil {
  655. return err
  656. }
  657. clientId := ""
  658. for _, oldClient := range oldClients {
  659. if oldClient.Email == clientEmail {
  660. if inbound.Protocol == "trojan" {
  661. clientId = oldClient.Password
  662. } else {
  663. clientId = oldClient.ID
  664. }
  665. break
  666. }
  667. }
  668. if len(clientId) == 0 {
  669. return common.NewError("Client Not Found For Email:", clientEmail)
  670. }
  671. var settings map[string]interface{}
  672. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  673. if err != nil {
  674. return err
  675. }
  676. clients := settings["clients"].([]interface{})
  677. var newClients []interface{}
  678. for client_index := range clients {
  679. c := clients[client_index].(map[string]interface{})
  680. if c["email"] == clientEmail {
  681. c["tgId"] = tgId
  682. newClients = append(newClients, interface{}(c))
  683. }
  684. }
  685. settings["clients"] = newClients
  686. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  687. if err != nil {
  688. return err
  689. }
  690. inbound.Settings = string(modifiedSettings)
  691. return s.UpdateInboundClient(inbound, clientId)
  692. }
  693. func (s *InboundService) ToggleClientEnableByEmail(clientEmail string) (bool, error) {
  694. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  695. if err != nil {
  696. return false, err
  697. }
  698. if inbound == nil {
  699. return false, common.NewError("Inbound Not Found For Email:", clientEmail)
  700. }
  701. oldClients, err := s.GetClients(inbound)
  702. if err != nil {
  703. return false, err
  704. }
  705. clientId := ""
  706. clientOldEnabled := false
  707. for _, oldClient := range oldClients {
  708. if oldClient.Email == clientEmail {
  709. if inbound.Protocol == "trojan" {
  710. clientId = oldClient.Password
  711. } else {
  712. clientId = oldClient.ID
  713. }
  714. clientOldEnabled = oldClient.Enable
  715. break
  716. }
  717. }
  718. if len(clientId) == 0 {
  719. return false, common.NewError("Client Not Found For Email:", clientEmail)
  720. }
  721. var settings map[string]interface{}
  722. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  723. if err != nil {
  724. return false, err
  725. }
  726. clients := settings["clients"].([]interface{})
  727. var newClients []interface{}
  728. for client_index := range clients {
  729. c := clients[client_index].(map[string]interface{})
  730. if c["email"] == clientEmail {
  731. c["enable"] = !clientOldEnabled
  732. newClients = append(newClients, interface{}(c))
  733. }
  734. }
  735. settings["clients"] = newClients
  736. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  737. if err != nil {
  738. return false, err
  739. }
  740. inbound.Settings = string(modifiedSettings)
  741. return !clientOldEnabled, s.UpdateInboundClient(inbound, clientId)
  742. }
  743. func (s *InboundService) ResetClientIpLimitByEmail(clientEmail string, count int) error {
  744. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  745. if err != nil {
  746. return err
  747. }
  748. if inbound == nil {
  749. return common.NewError("Inbound Not Found For Email:", clientEmail)
  750. }
  751. oldClients, err := s.GetClients(inbound)
  752. if err != nil {
  753. return err
  754. }
  755. clientId := ""
  756. for _, oldClient := range oldClients {
  757. if oldClient.Email == clientEmail {
  758. if inbound.Protocol == "trojan" {
  759. clientId = oldClient.Password
  760. } else {
  761. clientId = oldClient.ID
  762. }
  763. break
  764. }
  765. }
  766. if len(clientId) == 0 {
  767. return common.NewError("Client Not Found For Email:", clientEmail)
  768. }
  769. var settings map[string]interface{}
  770. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  771. if err != nil {
  772. return err
  773. }
  774. clients := settings["clients"].([]interface{})
  775. var newClients []interface{}
  776. for client_index := range clients {
  777. c := clients[client_index].(map[string]interface{})
  778. if c["email"] == clientEmail {
  779. c["limitIp"] = count
  780. newClients = append(newClients, interface{}(c))
  781. }
  782. }
  783. settings["clients"] = newClients
  784. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  785. if err != nil {
  786. return err
  787. }
  788. inbound.Settings = string(modifiedSettings)
  789. return s.UpdateInboundClient(inbound, clientId)
  790. }
  791. func (s *InboundService) ResetClientExpiryTimeByEmail(clientEmail string, expiry_time int64) error {
  792. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  793. if err != nil {
  794. return err
  795. }
  796. if inbound == nil {
  797. return common.NewError("Inbound Not Found For Email:", clientEmail)
  798. }
  799. oldClients, err := s.GetClients(inbound)
  800. if err != nil {
  801. return err
  802. }
  803. clientId := ""
  804. for _, oldClient := range oldClients {
  805. if oldClient.Email == clientEmail {
  806. if inbound.Protocol == "trojan" {
  807. clientId = oldClient.Password
  808. } else {
  809. clientId = oldClient.ID
  810. }
  811. break
  812. }
  813. }
  814. if len(clientId) == 0 {
  815. return common.NewError("Client Not Found For Email:", clientEmail)
  816. }
  817. var settings map[string]interface{}
  818. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  819. if err != nil {
  820. return err
  821. }
  822. clients := settings["clients"].([]interface{})
  823. var newClients []interface{}
  824. for client_index := range clients {
  825. c := clients[client_index].(map[string]interface{})
  826. if c["email"] == clientEmail {
  827. c["expiryTime"] = expiry_time
  828. newClients = append(newClients, interface{}(c))
  829. }
  830. }
  831. settings["clients"] = newClients
  832. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  833. if err != nil {
  834. return err
  835. }
  836. inbound.Settings = string(modifiedSettings)
  837. return s.UpdateInboundClient(inbound, clientId)
  838. }
  839. func (s *InboundService) ResetClientTrafficByEmail(clientEmail string) error {
  840. db := database.GetDB()
  841. result := db.Model(xray.ClientTraffic{}).
  842. Where("email = ?", clientEmail).
  843. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  844. err := result.Error
  845. if err != nil {
  846. return err
  847. }
  848. return nil
  849. }
  850. func (s *InboundService) ResetClientTraffic(id int, clientEmail string) error {
  851. db := database.GetDB()
  852. result := db.Model(xray.ClientTraffic{}).
  853. Where("inbound_id = ? and email = ?", id, clientEmail).
  854. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  855. err := result.Error
  856. if err != nil {
  857. return err
  858. }
  859. return nil
  860. }
  861. func (s *InboundService) ResetAllClientTraffics(id int) error {
  862. db := database.GetDB()
  863. whereText := "inbound_id "
  864. if id == -1 {
  865. whereText += " > ?"
  866. } else {
  867. whereText += " = ?"
  868. }
  869. result := db.Model(xray.ClientTraffic{}).
  870. Where(whereText, id).
  871. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  872. err := result.Error
  873. if err != nil {
  874. return err
  875. }
  876. return nil
  877. }
  878. func (s *InboundService) ResetAllTraffics() error {
  879. db := database.GetDB()
  880. result := db.Model(model.Inbound{}).
  881. Where("user_id > ?", 0).
  882. Updates(map[string]interface{}{"up": 0, "down": 0})
  883. err := result.Error
  884. if err != nil {
  885. return err
  886. }
  887. return nil
  888. }
  889. func (s *InboundService) DelDepletedClients(id int) (err error) {
  890. db := database.GetDB()
  891. tx := db.Begin()
  892. defer func() {
  893. if err == nil {
  894. tx.Commit()
  895. } else {
  896. tx.Rollback()
  897. }
  898. }()
  899. whereText := "inbound_id "
  900. if id < 0 {
  901. whereText += "> ?"
  902. } else {
  903. whereText += "= ?"
  904. }
  905. depletedClients := []xray.ClientTraffic{}
  906. 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
  907. if err != nil {
  908. return err
  909. }
  910. for _, depletedClient := range depletedClients {
  911. emails := strings.Split(depletedClient.Email, ",")
  912. oldInbound, err := s.GetInbound(depletedClient.InboundId)
  913. if err != nil {
  914. return err
  915. }
  916. var oldSettings map[string]interface{}
  917. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  918. if err != nil {
  919. return err
  920. }
  921. oldClients := oldSettings["clients"].([]interface{})
  922. var newClients []interface{}
  923. for _, client := range oldClients {
  924. deplete := false
  925. c := client.(map[string]interface{})
  926. for _, email := range emails {
  927. if email == c["email"].(string) {
  928. deplete = true
  929. break
  930. }
  931. }
  932. if !deplete {
  933. newClients = append(newClients, client)
  934. }
  935. }
  936. if len(newClients) > 0 {
  937. oldSettings["clients"] = newClients
  938. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  939. if err != nil {
  940. return err
  941. }
  942. oldInbound.Settings = string(newSettings)
  943. err = tx.Save(oldInbound).Error
  944. if err != nil {
  945. return err
  946. }
  947. } else {
  948. // Delete inbound if no client remains
  949. s.DelInbound(depletedClient.InboundId)
  950. }
  951. }
  952. err = tx.Where(whereText+" and enable = ?", id, false).Delete(xray.ClientTraffic{}).Error
  953. if err != nil {
  954. return err
  955. }
  956. return nil
  957. }
  958. func (s *InboundService) GetClientTrafficTgBot(tguname string) ([]*xray.ClientTraffic, error) {
  959. db := database.GetDB()
  960. var inbounds []*model.Inbound
  961. err := db.Model(model.Inbound{}).Where("settings like ?", fmt.Sprintf(`%%"tgId": "%s"%%`, tguname)).Find(&inbounds).Error
  962. if err != nil && err != gorm.ErrRecordNotFound {
  963. return nil, err
  964. }
  965. var emails []string
  966. for _, inbound := range inbounds {
  967. clients, err := s.GetClients(inbound)
  968. if err != nil {
  969. logger.Error("Unable to get clients from inbound")
  970. }
  971. for _, client := range clients {
  972. if client.TgID == tguname {
  973. emails = append(emails, client.Email)
  974. }
  975. }
  976. }
  977. var traffics []*xray.ClientTraffic
  978. err = db.Model(xray.ClientTraffic{}).Where("email IN ?", emails).Find(&traffics).Error
  979. if err != nil {
  980. if err == gorm.ErrRecordNotFound {
  981. logger.Warning(err)
  982. return nil, err
  983. }
  984. }
  985. return traffics, err
  986. }
  987. func (s *InboundService) GetClientTrafficByEmail(email string) (traffic *xray.ClientTraffic, err error) {
  988. db := database.GetDB()
  989. var traffics []*xray.ClientTraffic
  990. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  991. if err != nil {
  992. logger.Warning(err)
  993. return nil, err
  994. }
  995. if len(traffics) > 0 {
  996. return traffics[0], nil
  997. }
  998. return nil, nil
  999. }
  1000. func (s *InboundService) SearchClientTraffic(query string) (traffic *xray.ClientTraffic, err error) {
  1001. db := database.GetDB()
  1002. inbound := &model.Inbound{}
  1003. traffic = &xray.ClientTraffic{}
  1004. err = db.Model(model.Inbound{}).Where("settings like ?", "%\""+query+"\"%").First(inbound).Error
  1005. if err != nil {
  1006. if err == gorm.ErrRecordNotFound {
  1007. logger.Warning(err)
  1008. return nil, err
  1009. }
  1010. }
  1011. traffic.InboundId = inbound.Id
  1012. // get settings clients
  1013. settings := map[string][]model.Client{}
  1014. json.Unmarshal([]byte(inbound.Settings), &settings)
  1015. clients := settings["clients"]
  1016. for _, client := range clients {
  1017. if client.ID == query && client.Email != "" {
  1018. traffic.Email = client.Email
  1019. break
  1020. }
  1021. if client.Password == query && client.Email != "" {
  1022. traffic.Email = client.Email
  1023. break
  1024. }
  1025. }
  1026. if traffic.Email == "" {
  1027. return nil, err
  1028. }
  1029. err = db.Model(xray.ClientTraffic{}).Where("email = ?", traffic.Email).First(traffic).Error
  1030. if err != nil {
  1031. logger.Warning(err)
  1032. return nil, err
  1033. }
  1034. return traffic, err
  1035. }
  1036. func (s *InboundService) GetInboundClientIps(clientEmail string) (string, error) {
  1037. db := database.GetDB()
  1038. InboundClientIps := &model.InboundClientIps{}
  1039. err := db.Model(model.InboundClientIps{}).Where("client_email = ?", clientEmail).First(InboundClientIps).Error
  1040. if err != nil {
  1041. return "", err
  1042. }
  1043. return InboundClientIps.Ips, nil
  1044. }
  1045. func (s *InboundService) ClearClientIps(clientEmail string) error {
  1046. db := database.GetDB()
  1047. result := db.Model(model.InboundClientIps{}).
  1048. Where("client_email = ?", clientEmail).
  1049. Update("ips", "")
  1050. err := result.Error
  1051. if err != nil {
  1052. return err
  1053. }
  1054. return nil
  1055. }
  1056. func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) {
  1057. db := database.GetDB()
  1058. var inbounds []*model.Inbound
  1059. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("remark like ?", "%"+query+"%").Find(&inbounds).Error
  1060. if err != nil && err != gorm.ErrRecordNotFound {
  1061. return nil, err
  1062. }
  1063. return inbounds, nil
  1064. }
  1065. func (s *InboundService) MigrationRequirements() {
  1066. db := database.GetDB()
  1067. // Fix inbounds based problems
  1068. var inbounds []*model.Inbound
  1069. err := db.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error
  1070. if err != nil && err != gorm.ErrRecordNotFound {
  1071. return
  1072. }
  1073. for inbound_index := range inbounds {
  1074. settings := map[string]interface{}{}
  1075. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  1076. clients, ok := settings["clients"].([]interface{})
  1077. if ok {
  1078. // Fix Clinet configuration problems
  1079. var newClients []interface{}
  1080. for client_index := range clients {
  1081. c := clients[client_index].(map[string]interface{})
  1082. // Add email='' if it is not exists
  1083. if _, ok := c["email"]; !ok {
  1084. c["email"] = ""
  1085. }
  1086. // Remove "flow": "xtls-rprx-direct"
  1087. if _, ok := c["flow"]; ok {
  1088. if c["flow"] == "xtls-rprx-direct" {
  1089. c["flow"] = ""
  1090. }
  1091. }
  1092. newClients = append(newClients, interface{}(c))
  1093. }
  1094. settings["clients"] = newClients
  1095. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1096. if err != nil {
  1097. return
  1098. }
  1099. inbounds[inbound_index].Settings = string(modifiedSettings)
  1100. }
  1101. // Add client traffic row for all clients which has email
  1102. modelClients, err := s.GetClients(inbounds[inbound_index])
  1103. if err != nil {
  1104. return
  1105. }
  1106. for _, modelClient := range modelClients {
  1107. if len(modelClient.Email) > 0 {
  1108. var count int64
  1109. db.Model(xray.ClientTraffic{}).Where("email = ?", modelClient.Email).Count(&count)
  1110. if count == 0 {
  1111. s.AddClientStat(inbounds[inbound_index].Id, &modelClient)
  1112. }
  1113. }
  1114. }
  1115. }
  1116. db.Save(inbounds)
  1117. // Remove orphaned traffics
  1118. db.Where("inbound_id = 0").Delete(xray.ClientTraffic{})
  1119. }
  1120. func (s *InboundService) MigrateDB() {
  1121. s.MigrationRequirements()
  1122. s.MigrationRemoveOrphanedTraffics()
  1123. }