inbound.go 24 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004
  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 dbClientTraffics[traffic_index].ExpiryTime < 0 && 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) ResetClientExpiryTimeByEmail(clientEmail string, expiry_time int64) error {
  593. db := database.GetDB()
  594. result := db.Model(xray.ClientTraffic{}).
  595. Where("email = ?", clientEmail).
  596. Updates(map[string]interface{}{"enable": true, "expiry_time": expiry_time})
  597. err := result.Error
  598. if err != nil {
  599. return err
  600. }
  601. return nil
  602. }
  603. func (s *InboundService) ResetClientTrafficByEmail(clientEmail string) error {
  604. db := database.GetDB()
  605. result := db.Model(xray.ClientTraffic{}).
  606. Where("email = ?", clientEmail).
  607. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  608. err := result.Error
  609. if err != nil {
  610. return err
  611. }
  612. return nil
  613. }
  614. func (s *InboundService) ResetClientTraffic(id int, clientEmail string) error {
  615. db := database.GetDB()
  616. result := db.Model(xray.ClientTraffic{}).
  617. Where("inbound_id = ? and email = ?", id, clientEmail).
  618. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  619. err := result.Error
  620. if err != nil {
  621. return err
  622. }
  623. return nil
  624. }
  625. func (s *InboundService) ResetAllClientTraffics(id int) error {
  626. db := database.GetDB()
  627. whereText := "inbound_id "
  628. if id == -1 {
  629. whereText += " > ?"
  630. } else {
  631. whereText += " = ?"
  632. }
  633. result := db.Model(xray.ClientTraffic{}).
  634. Where(whereText, id).
  635. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  636. err := result.Error
  637. if err != nil {
  638. return err
  639. }
  640. return nil
  641. }
  642. func (s *InboundService) ResetAllTraffics() error {
  643. db := database.GetDB()
  644. result := db.Model(model.Inbound{}).
  645. Where("user_id > ?", 0).
  646. Updates(map[string]interface{}{"up": 0, "down": 0})
  647. err := result.Error
  648. if err != nil {
  649. return err
  650. }
  651. return nil
  652. }
  653. func (s *InboundService) DelDepletedClients(id int) (err error) {
  654. db := database.GetDB()
  655. tx := db.Begin()
  656. defer func() {
  657. if err == nil {
  658. tx.Commit()
  659. } else {
  660. tx.Rollback()
  661. }
  662. }()
  663. whereText := "inbound_id "
  664. if id < 0 {
  665. whereText += "> ?"
  666. } else {
  667. whereText += "= ?"
  668. }
  669. depletedClients := []xray.ClientTraffic{}
  670. 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
  671. if err != nil {
  672. return err
  673. }
  674. for _, depletedClient := range depletedClients {
  675. emails := strings.Split(depletedClient.Email, ",")
  676. oldInbound, err := s.GetInbound(depletedClient.InboundId)
  677. if err != nil {
  678. return err
  679. }
  680. var oldSettings map[string]interface{}
  681. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  682. if err != nil {
  683. return err
  684. }
  685. oldClients := oldSettings["clients"].([]interface{})
  686. var newClients []interface{}
  687. for _, client := range oldClients {
  688. deplete := false
  689. c := client.(map[string]interface{})
  690. for _, email := range emails {
  691. if email == c["email"].(string) {
  692. deplete = true
  693. break
  694. }
  695. }
  696. if !deplete {
  697. newClients = append(newClients, client)
  698. }
  699. }
  700. if len(newClients) > 0 {
  701. oldSettings["clients"] = newClients
  702. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  703. if err != nil {
  704. return err
  705. }
  706. oldInbound.Settings = string(newSettings)
  707. err = tx.Save(oldInbound).Error
  708. if err != nil {
  709. return err
  710. }
  711. } else {
  712. // Delete inbound if no client remains
  713. s.DelInbound(depletedClient.InboundId)
  714. }
  715. }
  716. err = tx.Where(whereText+" and enable = ?", id, false).Delete(xray.ClientTraffic{}).Error
  717. if err != nil {
  718. return err
  719. }
  720. return nil
  721. }
  722. func (s *InboundService) GetClientTrafficTgBot(tguname string) ([]*xray.ClientTraffic, error) {
  723. db := database.GetDB()
  724. var inbounds []*model.Inbound
  725. err := db.Model(model.Inbound{}).Where("settings like ?", fmt.Sprintf(`%%"tgId": "%s"%%`, tguname)).Find(&inbounds).Error
  726. if err != nil && err != gorm.ErrRecordNotFound {
  727. return nil, err
  728. }
  729. var emails []string
  730. for _, inbound := range inbounds {
  731. clients, err := s.getClients(inbound)
  732. if err != nil {
  733. logger.Error("Unable to get clients from inbound")
  734. }
  735. for _, client := range clients {
  736. if client.TgID == tguname {
  737. emails = append(emails, client.Email)
  738. }
  739. }
  740. }
  741. var traffics []*xray.ClientTraffic
  742. err = db.Model(xray.ClientTraffic{}).Where("email IN ?", emails).Find(&traffics).Error
  743. if err != nil {
  744. if err == gorm.ErrRecordNotFound {
  745. logger.Warning(err)
  746. return nil, err
  747. }
  748. }
  749. return traffics, err
  750. }
  751. func (s *InboundService) GetClientTrafficByEmail(email string) (traffic *xray.ClientTraffic, err error) {
  752. db := database.GetDB()
  753. var traffics []*xray.ClientTraffic
  754. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  755. if err != nil {
  756. logger.Warning(err)
  757. return nil, err
  758. }
  759. if len(traffics) > 0 {
  760. return traffics[0], nil
  761. }
  762. return nil, nil
  763. }
  764. func (s *InboundService) SearchClientTraffic(query string) (traffic *xray.ClientTraffic, err error) {
  765. db := database.GetDB()
  766. inbound := &model.Inbound{}
  767. traffic = &xray.ClientTraffic{}
  768. err = db.Model(model.Inbound{}).Where("settings like ?", "%\""+query+"\"%").First(inbound).Error
  769. if err != nil {
  770. if err == gorm.ErrRecordNotFound {
  771. logger.Warning(err)
  772. return nil, err
  773. }
  774. }
  775. traffic.InboundId = inbound.Id
  776. // get settings clients
  777. settings := map[string][]model.Client{}
  778. json.Unmarshal([]byte(inbound.Settings), &settings)
  779. clients := settings["clients"]
  780. for _, client := range clients {
  781. if client.ID == query && client.Email != "" {
  782. traffic.Email = client.Email
  783. break
  784. }
  785. if client.Password == query && client.Email != "" {
  786. traffic.Email = client.Email
  787. break
  788. }
  789. }
  790. if traffic.Email == "" {
  791. return nil, err
  792. }
  793. err = db.Model(xray.ClientTraffic{}).Where("email = ?", traffic.Email).First(traffic).Error
  794. if err != nil {
  795. logger.Warning(err)
  796. return nil, err
  797. }
  798. return traffic, err
  799. }
  800. func (s *InboundService) GetInboundClientIps(clientEmail string) (string, error) {
  801. db := database.GetDB()
  802. InboundClientIps := &model.InboundClientIps{}
  803. err := db.Model(model.InboundClientIps{}).Where("client_email = ?", clientEmail).First(InboundClientIps).Error
  804. if err != nil {
  805. return "", err
  806. }
  807. return InboundClientIps.Ips, nil
  808. }
  809. func (s *InboundService) ClearClientIps(clientEmail string) error {
  810. db := database.GetDB()
  811. result := db.Model(model.InboundClientIps{}).
  812. Where("client_email = ?", clientEmail).
  813. Update("ips", "")
  814. err := result.Error
  815. if err != nil {
  816. return err
  817. }
  818. return nil
  819. }
  820. func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) {
  821. db := database.GetDB()
  822. var inbounds []*model.Inbound
  823. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("remark like ?", "%"+query+"%").Find(&inbounds).Error
  824. if err != nil && err != gorm.ErrRecordNotFound {
  825. return nil, err
  826. }
  827. return inbounds, nil
  828. }
  829. func (s *InboundService) MigrationRequirements() {
  830. db := database.GetDB()
  831. // Fix inbounds based problems
  832. var inbounds []*model.Inbound
  833. err := db.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error
  834. if err != nil && err != gorm.ErrRecordNotFound {
  835. return
  836. }
  837. for inbound_index := range inbounds {
  838. settings := map[string]interface{}{}
  839. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  840. clients, ok := settings["clients"].([]interface{})
  841. if ok {
  842. // Fix Clinet configuration problems
  843. var newClients []interface{}
  844. for client_index := range clients {
  845. c := clients[client_index].(map[string]interface{})
  846. // Add email='' if it is not exists
  847. if _, ok := c["email"]; !ok {
  848. c["email"] = ""
  849. }
  850. // Remove "flow": "xtls-rprx-direct"
  851. if _, ok := c["flow"]; ok {
  852. if c["flow"] == "xtls-rprx-direct" {
  853. c["flow"] = ""
  854. }
  855. }
  856. newClients = append(newClients, interface{}(c))
  857. }
  858. settings["clients"] = newClients
  859. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  860. if err != nil {
  861. return
  862. }
  863. inbounds[inbound_index].Settings = string(modifiedSettings)
  864. }
  865. // Add client traffic row for all clients which has email
  866. modelClients, err := s.getClients(inbounds[inbound_index])
  867. if err != nil {
  868. return
  869. }
  870. for _, modelClient := range modelClients {
  871. if len(modelClient.Email) > 0 {
  872. var count int64
  873. db.Model(xray.ClientTraffic{}).Where("email = ?", modelClient.Email).Count(&count)
  874. if count == 0 {
  875. s.AddClientStat(inbounds[inbound_index].Id, &modelClient)
  876. }
  877. }
  878. }
  879. }
  880. db.Save(inbounds)
  881. // Remove orphaned traffics
  882. db.Where("inbound_id = 0").Delete(xray.ClientTraffic{})
  883. }