inbound.go 45 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807
  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. xrayApi xray.XrayAPI
  16. }
  17. func (s *InboundService) GetInbounds(userId int) ([]*model.Inbound, error) {
  18. db := database.GetDB()
  19. var inbounds []*model.Inbound
  20. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("user_id = ?", userId).Find(&inbounds).Error
  21. if err != nil && err != gorm.ErrRecordNotFound {
  22. return nil, err
  23. }
  24. return inbounds, nil
  25. }
  26. func (s *InboundService) GetAllInbounds() ([]*model.Inbound, error) {
  27. db := database.GetDB()
  28. var inbounds []*model.Inbound
  29. err := db.Model(model.Inbound{}).Preload("ClientStats").Find(&inbounds).Error
  30. if err != nil && err != gorm.ErrRecordNotFound {
  31. return nil, err
  32. }
  33. return inbounds, nil
  34. }
  35. func (s *InboundService) checkPortExist(port int, ignoreId int) (bool, error) {
  36. db := database.GetDB()
  37. db = db.Model(model.Inbound{}).Where("port = ?", port)
  38. if ignoreId > 0 {
  39. db = db.Where("id != ?", ignoreId)
  40. }
  41. var count int64
  42. err := db.Count(&count).Error
  43. if err != nil {
  44. return false, err
  45. }
  46. return count > 0, nil
  47. }
  48. func (s *InboundService) GetClients(inbound *model.Inbound) ([]model.Client, error) {
  49. settings := map[string][]model.Client{}
  50. json.Unmarshal([]byte(inbound.Settings), &settings)
  51. if settings == nil {
  52. return nil, fmt.Errorf("setting is null")
  53. }
  54. clients := settings["clients"]
  55. if clients == nil {
  56. return nil, nil
  57. }
  58. return clients, nil
  59. }
  60. func (s *InboundService) getAllEmails() ([]string, error) {
  61. db := database.GetDB()
  62. var emails []string
  63. err := db.Raw(`
  64. SELECT JSON_EXTRACT(client.value, '$.email')
  65. FROM inbounds,
  66. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  67. `).Scan(&emails).Error
  68. if err != nil {
  69. return nil, err
  70. }
  71. return emails, nil
  72. }
  73. func (s *InboundService) contains(slice []string, str string) bool {
  74. for _, s := range slice {
  75. if s == str {
  76. return true
  77. }
  78. }
  79. return false
  80. }
  81. func (s *InboundService) checkEmailsExistForClients(clients []model.Client) (string, error) {
  82. allEmails, err := s.getAllEmails()
  83. if err != nil {
  84. return "", err
  85. }
  86. var emails []string
  87. for _, client := range clients {
  88. if client.Email != "" {
  89. if s.contains(emails, client.Email) {
  90. return client.Email, nil
  91. }
  92. if s.contains(allEmails, client.Email) {
  93. return client.Email, nil
  94. }
  95. emails = append(emails, client.Email)
  96. }
  97. }
  98. return "", nil
  99. }
  100. func (s *InboundService) checkEmailExistForInbound(inbound *model.Inbound) (string, error) {
  101. clients, err := s.GetClients(inbound)
  102. if err != nil {
  103. return "", err
  104. }
  105. allEmails, err := s.getAllEmails()
  106. if err != nil {
  107. return "", err
  108. }
  109. var emails []string
  110. for _, client := range clients {
  111. if client.Email != "" {
  112. if s.contains(emails, client.Email) {
  113. return client.Email, nil
  114. }
  115. if s.contains(allEmails, client.Email) {
  116. return client.Email, nil
  117. }
  118. emails = append(emails, client.Email)
  119. }
  120. }
  121. return "", nil
  122. }
  123. func (s *InboundService) AddInbound(inbound *model.Inbound) (*model.Inbound, bool, error) {
  124. exist, err := s.checkPortExist(inbound.Port, 0)
  125. if err != nil {
  126. return inbound, false, err
  127. }
  128. if exist {
  129. return inbound, false, common.NewError("Port already exists:", inbound.Port)
  130. }
  131. existEmail, err := s.checkEmailExistForInbound(inbound)
  132. if err != nil {
  133. return inbound, false, err
  134. }
  135. if existEmail != "" {
  136. return inbound, false, common.NewError("Duplicate email:", existEmail)
  137. }
  138. clients, err := s.GetClients(inbound)
  139. if err != nil {
  140. return inbound, false, err
  141. }
  142. db := database.GetDB()
  143. tx := db.Begin()
  144. defer func() {
  145. if err == nil {
  146. tx.Commit()
  147. } else {
  148. tx.Rollback()
  149. }
  150. }()
  151. err = tx.Save(inbound).Error
  152. if err == nil {
  153. for _, client := range clients {
  154. s.AddClientStat(tx, inbound.Id, &client)
  155. }
  156. }
  157. needRestart := false
  158. if inbound.Enable {
  159. s.xrayApi.Init(p.GetAPIPort())
  160. inboundJson, err1 := json.MarshalIndent(inbound.GenXrayInboundConfig(), "", " ")
  161. if err1 != nil {
  162. logger.Debug("Unable to marshal inbound config:", err1)
  163. }
  164. err1 = s.xrayApi.AddInbound(inboundJson)
  165. if err1 == nil {
  166. logger.Debug("New inbound added by api:", inbound.Tag)
  167. } else {
  168. logger.Debug("Unable to add inbound by api:", err1)
  169. needRestart = true
  170. }
  171. s.xrayApi.Close()
  172. }
  173. return inbound, needRestart, err
  174. }
  175. func (s *InboundService) DelInbound(id int) (bool, error) {
  176. db := database.GetDB()
  177. var tag string
  178. needRestart := false
  179. result := db.Model(model.Inbound{}).Select("tag").Where("id = ? and enable = ?", id, true).First(&tag)
  180. if result.Error == nil {
  181. s.xrayApi.Init(p.GetAPIPort())
  182. err1 := s.xrayApi.DelInbound(tag)
  183. if err1 == nil {
  184. logger.Debug("Inbound deleted by api:", tag)
  185. } else {
  186. logger.Debug("Unable to delete inbound by api:", err1)
  187. needRestart = true
  188. }
  189. s.xrayApi.Close()
  190. } else {
  191. logger.Debug("No enabled inbound founded to removing by api", tag)
  192. }
  193. // Delete client traffics of inbounds
  194. err := db.Where("inbound_id = ?", id).Delete(xray.ClientTraffic{}).Error
  195. if err != nil {
  196. return false, err
  197. }
  198. inbound, err := s.GetInbound(id)
  199. if err != nil {
  200. return false, err
  201. }
  202. clients, err := s.GetClients(inbound)
  203. if err != nil {
  204. return false, err
  205. }
  206. for _, client := range clients {
  207. err := s.DelClientIPs(db, client.Email)
  208. if err != nil {
  209. return false, err
  210. }
  211. }
  212. return needRestart, db.Delete(model.Inbound{}, id).Error
  213. }
  214. func (s *InboundService) GetInbound(id int) (*model.Inbound, error) {
  215. db := database.GetDB()
  216. inbound := &model.Inbound{}
  217. err := db.Model(model.Inbound{}).First(inbound, id).Error
  218. if err != nil {
  219. return nil, err
  220. }
  221. return inbound, nil
  222. }
  223. func (s *InboundService) UpdateInbound(inbound *model.Inbound) (*model.Inbound, bool, error) {
  224. exist, err := s.checkPortExist(inbound.Port, inbound.Id)
  225. if err != nil {
  226. return inbound, false, err
  227. }
  228. if exist {
  229. return inbound, false, common.NewError("Port already exists:", inbound.Port)
  230. }
  231. oldInbound, err := s.GetInbound(inbound.Id)
  232. if err != nil {
  233. return inbound, false, err
  234. }
  235. tag := oldInbound.Tag
  236. db := database.GetDB()
  237. tx := db.Begin()
  238. defer func() {
  239. if err != nil {
  240. tx.Rollback()
  241. } else {
  242. tx.Commit()
  243. }
  244. }()
  245. err = s.updateClientTraffics(tx, oldInbound, inbound)
  246. if err != nil {
  247. return inbound, false, err
  248. }
  249. oldInbound.Up = inbound.Up
  250. oldInbound.Down = inbound.Down
  251. oldInbound.Total = inbound.Total
  252. oldInbound.Remark = inbound.Remark
  253. oldInbound.Enable = inbound.Enable
  254. oldInbound.ExpiryTime = inbound.ExpiryTime
  255. oldInbound.Listen = inbound.Listen
  256. oldInbound.Port = inbound.Port
  257. oldInbound.Protocol = inbound.Protocol
  258. oldInbound.Settings = inbound.Settings
  259. oldInbound.StreamSettings = inbound.StreamSettings
  260. oldInbound.Sniffing = inbound.Sniffing
  261. oldInbound.Tag = fmt.Sprintf("inbound-%v", inbound.Port)
  262. needRestart := false
  263. s.xrayApi.Init(p.GetAPIPort())
  264. if s.xrayApi.DelInbound(tag) == nil {
  265. logger.Debug("Old inbound deleted by api:", tag)
  266. }
  267. if inbound.Enable {
  268. inboundJson, err2 := json.MarshalIndent(oldInbound.GenXrayInboundConfig(), "", " ")
  269. if err2 != nil {
  270. logger.Debug("Unable to marshal updated inbound config:", err2)
  271. needRestart = true
  272. } else {
  273. err2 = s.xrayApi.AddInbound(inboundJson)
  274. if err2 == nil {
  275. logger.Debug("Updated inbound added by api:", oldInbound.Tag)
  276. } else {
  277. logger.Debug("Unable to update inbound by api:", err2)
  278. needRestart = true
  279. }
  280. }
  281. }
  282. s.xrayApi.Close()
  283. return inbound, needRestart, tx.Save(oldInbound).Error
  284. }
  285. func (s *InboundService) updateClientTraffics(tx *gorm.DB, oldInbound *model.Inbound, newInbound *model.Inbound) error {
  286. oldClients, err := s.GetClients(oldInbound)
  287. if err != nil {
  288. return err
  289. }
  290. newClients, err := s.GetClients(newInbound)
  291. if err != nil {
  292. return err
  293. }
  294. var emailExists bool
  295. for _, oldClient := range oldClients {
  296. emailExists = false
  297. for _, newClient := range newClients {
  298. if oldClient.Email == newClient.Email {
  299. emailExists = true
  300. break
  301. }
  302. }
  303. if !emailExists {
  304. err = s.DelClientStat(tx, oldClient.Email)
  305. if err != nil {
  306. return err
  307. }
  308. }
  309. }
  310. for _, newClient := range newClients {
  311. emailExists = false
  312. for _, oldClient := range oldClients {
  313. if newClient.Email == oldClient.Email {
  314. emailExists = true
  315. break
  316. }
  317. }
  318. if !emailExists {
  319. err = s.AddClientStat(tx, oldInbound.Id, &newClient)
  320. if err != nil {
  321. return err
  322. }
  323. }
  324. }
  325. return nil
  326. }
  327. func (s *InboundService) AddInboundClient(data *model.Inbound) (bool, error) {
  328. clients, err := s.GetClients(data)
  329. if err != nil {
  330. return false, err
  331. }
  332. var settings map[string]interface{}
  333. err = json.Unmarshal([]byte(data.Settings), &settings)
  334. if err != nil {
  335. return false, err
  336. }
  337. interfaceClients := settings["clients"].([]interface{})
  338. existEmail, err := s.checkEmailsExistForClients(clients)
  339. if err != nil {
  340. return false, err
  341. }
  342. if existEmail != "" {
  343. return false, common.NewError("Duplicate email:", existEmail)
  344. }
  345. oldInbound, err := s.GetInbound(data.Id)
  346. if err != nil {
  347. return false, err
  348. }
  349. var oldSettings map[string]interface{}
  350. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  351. if err != nil {
  352. return false, err
  353. }
  354. oldClients := oldSettings["clients"].([]interface{})
  355. oldClients = append(oldClients, interfaceClients...)
  356. oldSettings["clients"] = oldClients
  357. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  358. if err != nil {
  359. return false, err
  360. }
  361. oldInbound.Settings = string(newSettings)
  362. db := database.GetDB()
  363. tx := db.Begin()
  364. defer func() {
  365. if err != nil {
  366. tx.Rollback()
  367. } else {
  368. tx.Commit()
  369. }
  370. }()
  371. needRestart := false
  372. s.xrayApi.Init(p.GetAPIPort())
  373. for _, client := range clients {
  374. if len(client.Email) > 0 {
  375. s.AddClientStat(tx, data.Id, &client)
  376. if client.Enable {
  377. cipher := ""
  378. if oldInbound.Protocol == "shadowsocks" {
  379. cipher = oldSettings["method"].(string)
  380. }
  381. err1 := s.xrayApi.AddUser(string(oldInbound.Protocol), oldInbound.Tag, map[string]interface{}{
  382. "email": client.Email,
  383. "id": client.ID,
  384. "flow": client.Flow,
  385. "password": client.Password,
  386. "cipher": cipher,
  387. })
  388. if err1 == nil {
  389. logger.Debug("Client added by api:", client.Email)
  390. } else {
  391. logger.Debug("Error in adding client by api:", err1)
  392. needRestart = true
  393. }
  394. }
  395. } else {
  396. needRestart = true
  397. }
  398. }
  399. s.xrayApi.Close()
  400. return needRestart, tx.Save(oldInbound).Error
  401. }
  402. func (s *InboundService) DelInboundClient(inboundId int, clientId string) (bool, error) {
  403. oldInbound, err := s.GetInbound(inboundId)
  404. if err != nil {
  405. logger.Error("Load Old Data Error")
  406. return false, err
  407. }
  408. var settings map[string]interface{}
  409. err = json.Unmarshal([]byte(oldInbound.Settings), &settings)
  410. if err != nil {
  411. return false, err
  412. }
  413. email := ""
  414. client_key := "id"
  415. if oldInbound.Protocol == "trojan" {
  416. client_key = "password"
  417. }
  418. if oldInbound.Protocol == "shadowsocks" {
  419. client_key = "email"
  420. }
  421. inerfaceClients := settings["clients"].([]interface{})
  422. var newClients []interface{}
  423. for _, client := range inerfaceClients {
  424. c := client.(map[string]interface{})
  425. c_id := c[client_key].(string)
  426. if c_id == clientId {
  427. email = c["email"].(string)
  428. } else {
  429. newClients = append(newClients, client)
  430. }
  431. }
  432. settings["clients"] = newClients
  433. newSettings, err := json.MarshalIndent(settings, "", " ")
  434. if err != nil {
  435. return false, err
  436. }
  437. oldInbound.Settings = string(newSettings)
  438. db := database.GetDB()
  439. err = s.DelClientStat(db, email)
  440. if err != nil {
  441. logger.Error("Delete stats Data Error")
  442. return false, err
  443. }
  444. err = s.DelClientIPs(db, email)
  445. if err != nil {
  446. logger.Error("Error in delete client IPs")
  447. return false, err
  448. }
  449. needRestart := false
  450. if len(email) > 0 {
  451. s.xrayApi.Init(p.GetAPIPort())
  452. err1 := s.xrayApi.RemoveUser(oldInbound.Tag, email)
  453. if err1 == nil {
  454. logger.Debug("Client deleted by api:", email)
  455. needRestart = false
  456. } else {
  457. logger.Debug("Unable to del client by api:", err1)
  458. needRestart = true
  459. }
  460. s.xrayApi.Close()
  461. }
  462. return needRestart, db.Save(oldInbound).Error
  463. }
  464. func (s *InboundService) UpdateInboundClient(data *model.Inbound, clientId string) (bool, error) {
  465. clients, err := s.GetClients(data)
  466. if err != nil {
  467. return false, err
  468. }
  469. var settings map[string]interface{}
  470. err = json.Unmarshal([]byte(data.Settings), &settings)
  471. if err != nil {
  472. return false, err
  473. }
  474. inerfaceClients := settings["clients"].([]interface{})
  475. oldInbound, err := s.GetInbound(data.Id)
  476. if err != nil {
  477. return false, err
  478. }
  479. oldClients, err := s.GetClients(oldInbound)
  480. if err != nil {
  481. return false, err
  482. }
  483. oldEmail := ""
  484. clientIndex := 0
  485. for index, oldClient := range oldClients {
  486. oldClientId := ""
  487. if oldInbound.Protocol == "trojan" {
  488. oldClientId = oldClient.Password
  489. } else if oldInbound.Protocol == "shadowsocks" {
  490. oldClientId = oldClient.Email
  491. } else {
  492. oldClientId = oldClient.ID
  493. }
  494. if clientId == oldClientId {
  495. oldEmail = oldClient.Email
  496. clientIndex = index
  497. break
  498. }
  499. }
  500. if len(clients[0].Email) > 0 && clients[0].Email != oldEmail {
  501. existEmail, err := s.checkEmailsExistForClients(clients)
  502. if err != nil {
  503. return false, err
  504. }
  505. if existEmail != "" {
  506. return false, common.NewError("Duplicate email:", existEmail)
  507. }
  508. }
  509. var oldSettings map[string]interface{}
  510. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  511. if err != nil {
  512. return false, err
  513. }
  514. settingsClients := oldSettings["clients"].([]interface{})
  515. settingsClients[clientIndex] = inerfaceClients[0]
  516. oldSettings["clients"] = settingsClients
  517. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  518. if err != nil {
  519. return false, err
  520. }
  521. oldInbound.Settings = string(newSettings)
  522. db := database.GetDB()
  523. tx := db.Begin()
  524. defer func() {
  525. if err != nil {
  526. tx.Rollback()
  527. } else {
  528. tx.Commit()
  529. }
  530. }()
  531. if len(clients[0].Email) > 0 {
  532. if len(oldEmail) > 0 {
  533. err = s.UpdateClientStat(tx, oldEmail, &clients[0])
  534. if err != nil {
  535. return false, err
  536. }
  537. err = s.UpdateClientIPs(tx, oldEmail, clients[0].Email)
  538. if err != nil {
  539. return false, err
  540. }
  541. } else {
  542. s.AddClientStat(tx, data.Id, &clients[0])
  543. }
  544. } else {
  545. err = s.DelClientStat(tx, oldEmail)
  546. if err != nil {
  547. return false, err
  548. }
  549. err = s.DelClientIPs(tx, oldEmail)
  550. if err != nil {
  551. return false, err
  552. }
  553. }
  554. needRestart := false
  555. if len(oldEmail) > 0 {
  556. s.xrayApi.Init(p.GetAPIPort())
  557. if s.xrayApi.RemoveUser(oldInbound.Tag, oldEmail) == nil {
  558. logger.Debug("Old client deleted by api:", clients[0].Email)
  559. }
  560. if clients[0].Enable {
  561. cipher := ""
  562. if oldInbound.Protocol == "shadowsocks" {
  563. cipher = oldSettings["method"].(string)
  564. }
  565. err1 := s.xrayApi.AddUser(string(oldInbound.Protocol), oldInbound.Tag, map[string]interface{}{
  566. "email": clients[0].Email,
  567. "id": clients[0].ID,
  568. "flow": clients[0].Flow,
  569. "password": clients[0].Password,
  570. "cipher": cipher,
  571. })
  572. if err1 == nil {
  573. logger.Debug("Client edited by api:", clients[0].Email)
  574. } else {
  575. logger.Debug("Error in adding client by api:", err1)
  576. needRestart = true
  577. }
  578. }
  579. s.xrayApi.Close()
  580. } else {
  581. logger.Debug("Client old email not found")
  582. needRestart = true
  583. }
  584. return needRestart, tx.Save(oldInbound).Error
  585. }
  586. func (s *InboundService) AddTraffic(inboundTraffics []*xray.Traffic, clientTraffics []*xray.ClientTraffic) (error, bool) {
  587. var err error
  588. db := database.GetDB()
  589. tx := db.Begin()
  590. defer func() {
  591. if err != nil {
  592. tx.Rollback()
  593. } else {
  594. tx.Commit()
  595. }
  596. }()
  597. err = s.addInboundTraffic(tx, inboundTraffics)
  598. if err != nil {
  599. return err, false
  600. }
  601. err = s.addClientTraffic(tx, clientTraffics)
  602. if err != nil {
  603. return err, false
  604. }
  605. needRestart0, count, err := s.autoRenewClients(tx)
  606. if err != nil {
  607. logger.Warning("Error in renew clients:", err)
  608. } else if count > 0 {
  609. logger.Debugf("%v clients renewed", count)
  610. }
  611. needRestart1, count, err := s.disableInvalidClients(tx)
  612. if err != nil {
  613. logger.Warning("Error in disabling invalid clients:", err)
  614. } else if count > 0 {
  615. logger.Debugf("%v clients disabled", count)
  616. }
  617. needRestart2, count, err := s.disableInvalidInbounds(tx)
  618. if err != nil {
  619. logger.Warning("Error in disabling invalid inbounds:", err)
  620. } else if count > 0 {
  621. logger.Debugf("%v inbounds disabled", count)
  622. }
  623. return nil, (needRestart0 || needRestart1 || needRestart2)
  624. }
  625. func (s *InboundService) addInboundTraffic(tx *gorm.DB, traffics []*xray.Traffic) error {
  626. if len(traffics) == 0 {
  627. return nil
  628. }
  629. var err error
  630. for _, traffic := range traffics {
  631. if traffic.IsInbound {
  632. err = tx.Model(&model.Inbound{}).Where("tag = ?", traffic.Tag).
  633. Updates(map[string]interface{}{
  634. "up": gorm.Expr("up + ?", traffic.Up),
  635. "down": gorm.Expr("down + ?", traffic.Down),
  636. }).Error
  637. if err != nil {
  638. return err
  639. }
  640. }
  641. }
  642. return nil
  643. }
  644. func (s *InboundService) addClientTraffic(tx *gorm.DB, traffics []*xray.ClientTraffic) (err error) {
  645. if len(traffics) == 0 {
  646. // Empty onlineUsers
  647. if p != nil {
  648. p.SetOnlineClients(nil)
  649. }
  650. return nil
  651. }
  652. var onlineClients []string
  653. emails := make([]string, 0, len(traffics))
  654. for _, traffic := range traffics {
  655. emails = append(emails, traffic.Email)
  656. }
  657. dbClientTraffics := make([]*xray.ClientTraffic, 0, len(traffics))
  658. err = tx.Model(xray.ClientTraffic{}).Where("email IN (?)", emails).Find(&dbClientTraffics).Error
  659. if err != nil {
  660. return err
  661. }
  662. // Avoid empty slice error
  663. if len(dbClientTraffics) == 0 {
  664. return nil
  665. }
  666. dbClientTraffics, err = s.adjustTraffics(tx, dbClientTraffics)
  667. if err != nil {
  668. return err
  669. }
  670. for dbTraffic_index := range dbClientTraffics {
  671. for traffic_index := range traffics {
  672. if dbClientTraffics[dbTraffic_index].Email == traffics[traffic_index].Email {
  673. dbClientTraffics[dbTraffic_index].Up += traffics[traffic_index].Up
  674. dbClientTraffics[dbTraffic_index].Down += traffics[traffic_index].Down
  675. // Add user in onlineUsers array on traffic
  676. if traffics[traffic_index].Up+traffics[traffic_index].Down > 0 {
  677. onlineClients = append(onlineClients, traffics[traffic_index].Email)
  678. }
  679. break
  680. }
  681. }
  682. }
  683. // Set onlineUsers
  684. p.SetOnlineClients(onlineClients)
  685. err = tx.Save(dbClientTraffics).Error
  686. if err != nil {
  687. logger.Warning("AddClientTraffic update data ", err)
  688. }
  689. return nil
  690. }
  691. func (s *InboundService) adjustTraffics(tx *gorm.DB, dbClientTraffics []*xray.ClientTraffic) ([]*xray.ClientTraffic, error) {
  692. inboundIds := make([]int, 0, len(dbClientTraffics))
  693. for _, dbClientTraffic := range dbClientTraffics {
  694. if dbClientTraffic.ExpiryTime < 0 {
  695. inboundIds = append(inboundIds, dbClientTraffic.InboundId)
  696. }
  697. }
  698. if len(inboundIds) > 0 {
  699. var inbounds []*model.Inbound
  700. err := tx.Model(model.Inbound{}).Where("id IN (?)", inboundIds).Find(&inbounds).Error
  701. if err != nil {
  702. return nil, err
  703. }
  704. for inbound_index := range inbounds {
  705. settings := map[string]interface{}{}
  706. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  707. clients, ok := settings["clients"].([]interface{})
  708. if ok {
  709. var newClients []interface{}
  710. for client_index := range clients {
  711. c := clients[client_index].(map[string]interface{})
  712. for traffic_index := range dbClientTraffics {
  713. if dbClientTraffics[traffic_index].ExpiryTime < 0 && c["email"] == dbClientTraffics[traffic_index].Email {
  714. oldExpiryTime := c["expiryTime"].(float64)
  715. newExpiryTime := (time.Now().Unix() * 1000) - int64(oldExpiryTime)
  716. c["expiryTime"] = newExpiryTime
  717. dbClientTraffics[traffic_index].ExpiryTime = newExpiryTime
  718. break
  719. }
  720. }
  721. newClients = append(newClients, interface{}(c))
  722. }
  723. settings["clients"] = newClients
  724. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  725. if err != nil {
  726. return nil, err
  727. }
  728. inbounds[inbound_index].Settings = string(modifiedSettings)
  729. }
  730. }
  731. err = tx.Save(inbounds).Error
  732. if err != nil {
  733. logger.Warning("AddClientTraffic update inbounds ", err)
  734. logger.Error(inbounds)
  735. }
  736. }
  737. return dbClientTraffics, nil
  738. }
  739. func (s *InboundService) autoRenewClients(tx *gorm.DB) (bool, int64, error) {
  740. // check for time expired
  741. var traffics []*xray.ClientTraffic
  742. now := time.Now().Unix() * 1000
  743. var err, err1 error
  744. err = tx.Model(xray.ClientTraffic{}).Where("reset > 0 and expiry_time > 0 and expiry_time <= ?", now).Find(&traffics).Error
  745. if err != nil {
  746. return false, 0, err
  747. }
  748. // return if there is no client to renew
  749. if len(traffics) == 0 {
  750. return false, 0, nil
  751. }
  752. var inbound_ids []int
  753. var inbounds []*model.Inbound
  754. needRestart := false
  755. var clientsToAdd []struct {
  756. protocol string
  757. tag string
  758. client map[string]interface{}
  759. }
  760. for _, traffic := range traffics {
  761. inbound_ids = append(inbound_ids, traffic.InboundId)
  762. }
  763. err = tx.Model(model.Inbound{}).Where("id IN ?", inbound_ids).Find(&inbounds).Error
  764. if err != nil {
  765. return false, 0, err
  766. }
  767. for inbound_index := range inbounds {
  768. settings := map[string]interface{}{}
  769. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  770. clients := settings["clients"].([]interface{})
  771. for client_index := range clients {
  772. c := clients[client_index].(map[string]interface{})
  773. for traffic_index, traffic := range traffics {
  774. if traffic.Email == c["email"].(string) {
  775. newExpiryTime := traffic.ExpiryTime
  776. for newExpiryTime < now {
  777. newExpiryTime += (int64(traffic.Reset) * 86400000)
  778. }
  779. c["expiryTime"] = newExpiryTime
  780. traffics[traffic_index].ExpiryTime = newExpiryTime
  781. traffics[traffic_index].Down = 0
  782. traffics[traffic_index].Up = 0
  783. if !traffic.Enable {
  784. traffics[traffic_index].Enable = true
  785. clientsToAdd = append(clientsToAdd,
  786. struct {
  787. protocol string
  788. tag string
  789. client map[string]interface{}
  790. }{
  791. protocol: string(inbounds[inbound_index].Protocol),
  792. tag: inbounds[inbound_index].Tag,
  793. client: c,
  794. })
  795. }
  796. clients[client_index] = interface{}(c)
  797. break
  798. }
  799. }
  800. }
  801. settings["clients"] = clients
  802. newSettings, err := json.MarshalIndent(settings, "", " ")
  803. if err != nil {
  804. return false, 0, err
  805. }
  806. inbounds[inbound_index].Settings = string(newSettings)
  807. }
  808. err = tx.Save(inbounds).Error
  809. if err != nil {
  810. return false, 0, err
  811. }
  812. err = tx.Save(traffics).Error
  813. if err != nil {
  814. return false, 0, err
  815. }
  816. if p != nil {
  817. err1 = s.xrayApi.Init(p.GetAPIPort())
  818. if err1 != nil {
  819. return true, int64(len(traffics)), nil
  820. }
  821. for _, clientToAdd := range clientsToAdd {
  822. err1 = s.xrayApi.AddUser(clientToAdd.protocol, clientToAdd.tag, clientToAdd.client)
  823. if err1 != nil {
  824. needRestart = true
  825. }
  826. }
  827. s.xrayApi.Close()
  828. }
  829. return needRestart, int64(len(traffics)), nil
  830. }
  831. func (s *InboundService) disableInvalidInbounds(tx *gorm.DB) (bool, int64, error) {
  832. now := time.Now().Unix() * 1000
  833. needRestart := false
  834. if p != nil {
  835. var tags []string
  836. err := tx.Table("inbounds").
  837. Select("inbounds.tag").
  838. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  839. Scan(&tags).Error
  840. if err != nil {
  841. return false, 0, err
  842. }
  843. s.xrayApi.Init(p.GetAPIPort())
  844. for _, tag := range tags {
  845. err1 := s.xrayApi.DelInbound(tag)
  846. if err == nil {
  847. logger.Debug("Inbound disabled by api:", tag)
  848. } else {
  849. logger.Debug("Error in disabling inbound by api:", err1)
  850. needRestart = true
  851. }
  852. }
  853. s.xrayApi.Close()
  854. }
  855. result := tx.Model(model.Inbound{}).
  856. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  857. Update("enable", false)
  858. err := result.Error
  859. count := result.RowsAffected
  860. return needRestart, count, err
  861. }
  862. func (s *InboundService) disableInvalidClients(tx *gorm.DB) (bool, int64, error) {
  863. now := time.Now().Unix() * 1000
  864. needRestart := false
  865. if p != nil {
  866. var results []struct {
  867. Tag string
  868. Email string
  869. }
  870. err := tx.Table("inbounds").
  871. Select("inbounds.tag, client_traffics.email").
  872. Joins("JOIN client_traffics ON inbounds.id = client_traffics.inbound_id").
  873. Where("((client_traffics.total > 0 AND client_traffics.up + client_traffics.down >= client_traffics.total) OR (client_traffics.expiry_time > 0 AND client_traffics.expiry_time <= ?)) AND client_traffics.enable = ?", now, true).
  874. Scan(&results).Error
  875. if err != nil {
  876. return false, 0, err
  877. }
  878. s.xrayApi.Init(p.GetAPIPort())
  879. for _, result := range results {
  880. err1 := s.xrayApi.RemoveUser(result.Tag, result.Email)
  881. if err1 == nil {
  882. logger.Debug("Client disabled by api:", result.Email)
  883. } else {
  884. logger.Debug("Error in disabling client by api:", err1)
  885. needRestart = true
  886. }
  887. }
  888. s.xrayApi.Close()
  889. }
  890. result := tx.Model(xray.ClientTraffic{}).
  891. Where("((total > 0 and up + down >= total) or (expiry_time > 0 and expiry_time <= ?)) and enable = ?", now, true).
  892. Update("enable", false)
  893. err := result.Error
  894. count := result.RowsAffected
  895. return needRestart, count, err
  896. }
  897. func (s *InboundService) GetInboundTags() (string, error) {
  898. db := database.GetDB()
  899. var inboundTags []string
  900. err := db.Model(model.Inbound{}).Select("tag").Find(&inboundTags).Error
  901. if err != nil && err != gorm.ErrRecordNotFound {
  902. return "", err
  903. }
  904. return "[\"" + strings.Join(inboundTags, "\", \"") + "\"]", nil
  905. }
  906. func (s *InboundService) MigrationRemoveOrphanedTraffics() {
  907. db := database.GetDB()
  908. db.Exec(`
  909. DELETE FROM client_traffics
  910. WHERE email NOT IN (
  911. SELECT JSON_EXTRACT(client.value, '$.email')
  912. FROM inbounds,
  913. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  914. )
  915. `)
  916. }
  917. func (s *InboundService) AddClientStat(tx *gorm.DB, inboundId int, client *model.Client) error {
  918. clientTraffic := xray.ClientTraffic{}
  919. clientTraffic.InboundId = inboundId
  920. clientTraffic.Email = client.Email
  921. clientTraffic.Total = client.TotalGB
  922. clientTraffic.ExpiryTime = client.ExpiryTime
  923. clientTraffic.Enable = true
  924. clientTraffic.Up = 0
  925. clientTraffic.Down = 0
  926. clientTraffic.Reset = client.Reset
  927. result := tx.Create(&clientTraffic)
  928. err := result.Error
  929. if err != nil {
  930. return err
  931. }
  932. return nil
  933. }
  934. func (s *InboundService) UpdateClientStat(tx *gorm.DB, email string, client *model.Client) error {
  935. result := tx.Model(xray.ClientTraffic{}).
  936. Where("email = ?", email).
  937. Updates(map[string]interface{}{
  938. "enable": true,
  939. "email": client.Email,
  940. "total": client.TotalGB,
  941. "expiry_time": client.ExpiryTime,
  942. "reset": client.Reset})
  943. err := result.Error
  944. if err != nil {
  945. return err
  946. }
  947. return nil
  948. }
  949. func (s *InboundService) UpdateClientIPs(tx *gorm.DB, oldEmail string, newEmail string) error {
  950. return tx.Model(model.InboundClientIps{}).Where("client_email = ?", oldEmail).Update("client_email", newEmail).Error
  951. }
  952. func (s *InboundService) DelClientStat(tx *gorm.DB, email string) error {
  953. return tx.Where("email = ?", email).Delete(xray.ClientTraffic{}).Error
  954. }
  955. func (s *InboundService) DelClientIPs(tx *gorm.DB, email string) error {
  956. logger.Warning(email)
  957. return tx.Where("client_email = ?", email).Delete(model.InboundClientIps{}).Error
  958. }
  959. func (s *InboundService) GetClientInboundByTrafficID(trafficId int) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  960. db := database.GetDB()
  961. var traffics []*xray.ClientTraffic
  962. err = db.Model(xray.ClientTraffic{}).Where("id = ?", trafficId).Find(&traffics).Error
  963. if err != nil {
  964. logger.Warning(err)
  965. return nil, nil, err
  966. }
  967. if len(traffics) > 0 {
  968. inbound, err = s.GetInbound(traffics[0].InboundId)
  969. return traffics[0], inbound, err
  970. }
  971. return nil, nil, nil
  972. }
  973. func (s *InboundService) GetClientInboundByEmail(email string) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  974. db := database.GetDB()
  975. var traffics []*xray.ClientTraffic
  976. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  977. if err != nil {
  978. logger.Warning(err)
  979. return nil, nil, err
  980. }
  981. if len(traffics) > 0 {
  982. inbound, err = s.GetInbound(traffics[0].InboundId)
  983. return traffics[0], inbound, err
  984. }
  985. return nil, nil, nil
  986. }
  987. func (s *InboundService) GetClientByEmail(clientEmail string) (*xray.ClientTraffic, *model.Client, error) {
  988. traffic, inbound, err := s.GetClientInboundByEmail(clientEmail)
  989. if err != nil {
  990. return nil, nil, err
  991. }
  992. if inbound == nil {
  993. return nil, nil, common.NewError("Inbound Not Found For Email:", clientEmail)
  994. }
  995. clients, err := s.GetClients(inbound)
  996. if err != nil {
  997. return nil, nil, err
  998. }
  999. for _, client := range clients {
  1000. if client.Email == clientEmail {
  1001. return traffic, &client, nil
  1002. }
  1003. }
  1004. return nil, nil, common.NewError("Client Not Found In Inbound For Email:", clientEmail)
  1005. }
  1006. func (s *InboundService) SetClientTelegramUserID(trafficId int, tgId string) error {
  1007. traffic, inbound, err := s.GetClientInboundByTrafficID(trafficId)
  1008. if err != nil {
  1009. return err
  1010. }
  1011. if inbound == nil {
  1012. return common.NewError("Inbound Not Found For Traffic ID:", trafficId)
  1013. }
  1014. clientEmail := traffic.Email
  1015. oldClients, err := s.GetClients(inbound)
  1016. if err != nil {
  1017. return err
  1018. }
  1019. clientId := ""
  1020. for _, oldClient := range oldClients {
  1021. if oldClient.Email == clientEmail {
  1022. if inbound.Protocol == "trojan" {
  1023. clientId = oldClient.Password
  1024. } else {
  1025. clientId = oldClient.ID
  1026. }
  1027. break
  1028. }
  1029. }
  1030. if len(clientId) == 0 {
  1031. return common.NewError("Client Not Found For Email:", clientEmail)
  1032. }
  1033. var settings map[string]interface{}
  1034. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1035. if err != nil {
  1036. return err
  1037. }
  1038. clients := settings["clients"].([]interface{})
  1039. var newClients []interface{}
  1040. for client_index := range clients {
  1041. c := clients[client_index].(map[string]interface{})
  1042. if c["email"] == clientEmail {
  1043. c["tgId"] = tgId
  1044. newClients = append(newClients, interface{}(c))
  1045. }
  1046. }
  1047. settings["clients"] = newClients
  1048. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1049. if err != nil {
  1050. return err
  1051. }
  1052. inbound.Settings = string(modifiedSettings)
  1053. _, err = s.UpdateInboundClient(inbound, clientId)
  1054. if err != nil {
  1055. return err
  1056. }
  1057. return nil
  1058. }
  1059. func (s *InboundService) ToggleClientEnableByEmail(clientEmail string) (bool, error) {
  1060. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1061. if err != nil {
  1062. return false, err
  1063. }
  1064. if inbound == nil {
  1065. return false, common.NewError("Inbound Not Found For Email:", clientEmail)
  1066. }
  1067. oldClients, err := s.GetClients(inbound)
  1068. if err != nil {
  1069. return false, err
  1070. }
  1071. clientId := ""
  1072. clientOldEnabled := false
  1073. for _, oldClient := range oldClients {
  1074. if oldClient.Email == clientEmail {
  1075. if inbound.Protocol == "trojan" {
  1076. clientId = oldClient.Password
  1077. } else {
  1078. clientId = oldClient.ID
  1079. }
  1080. clientOldEnabled = oldClient.Enable
  1081. break
  1082. }
  1083. }
  1084. if len(clientId) == 0 {
  1085. return false, common.NewError("Client Not Found For Email:", clientEmail)
  1086. }
  1087. var settings map[string]interface{}
  1088. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1089. if err != nil {
  1090. return false, err
  1091. }
  1092. clients := settings["clients"].([]interface{})
  1093. var newClients []interface{}
  1094. for client_index := range clients {
  1095. c := clients[client_index].(map[string]interface{})
  1096. if c["email"] == clientEmail {
  1097. c["enable"] = !clientOldEnabled
  1098. newClients = append(newClients, interface{}(c))
  1099. }
  1100. }
  1101. settings["clients"] = newClients
  1102. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1103. if err != nil {
  1104. return false, err
  1105. }
  1106. inbound.Settings = string(modifiedSettings)
  1107. _, err = s.UpdateInboundClient(inbound, clientId)
  1108. if err != nil {
  1109. return false, err
  1110. }
  1111. return !clientOldEnabled, nil
  1112. }
  1113. func (s *InboundService) ResetClientIpLimitByEmail(clientEmail string, count int) error {
  1114. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1115. if err != nil {
  1116. return err
  1117. }
  1118. if inbound == nil {
  1119. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1120. }
  1121. oldClients, err := s.GetClients(inbound)
  1122. if err != nil {
  1123. return err
  1124. }
  1125. clientId := ""
  1126. for _, oldClient := range oldClients {
  1127. if oldClient.Email == clientEmail {
  1128. if inbound.Protocol == "trojan" {
  1129. clientId = oldClient.Password
  1130. } else {
  1131. clientId = oldClient.ID
  1132. }
  1133. break
  1134. }
  1135. }
  1136. if len(clientId) == 0 {
  1137. return common.NewError("Client Not Found For Email:", clientEmail)
  1138. }
  1139. var settings map[string]interface{}
  1140. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1141. if err != nil {
  1142. return err
  1143. }
  1144. clients := settings["clients"].([]interface{})
  1145. var newClients []interface{}
  1146. for client_index := range clients {
  1147. c := clients[client_index].(map[string]interface{})
  1148. if c["email"] == clientEmail {
  1149. c["limitIp"] = count
  1150. newClients = append(newClients, interface{}(c))
  1151. }
  1152. }
  1153. settings["clients"] = newClients
  1154. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1155. if err != nil {
  1156. return err
  1157. }
  1158. inbound.Settings = string(modifiedSettings)
  1159. _, err = s.UpdateInboundClient(inbound, clientId)
  1160. if err != nil {
  1161. return err
  1162. }
  1163. return nil
  1164. }
  1165. func (s *InboundService) ResetClientExpiryTimeByEmail(clientEmail string, expiry_time int64) error {
  1166. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1167. if err != nil {
  1168. return err
  1169. }
  1170. if inbound == nil {
  1171. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1172. }
  1173. oldClients, err := s.GetClients(inbound)
  1174. if err != nil {
  1175. return err
  1176. }
  1177. clientId := ""
  1178. for _, oldClient := range oldClients {
  1179. if oldClient.Email == clientEmail {
  1180. if inbound.Protocol == "trojan" {
  1181. clientId = oldClient.Password
  1182. } else {
  1183. clientId = oldClient.ID
  1184. }
  1185. break
  1186. }
  1187. }
  1188. if len(clientId) == 0 {
  1189. return common.NewError("Client Not Found For Email:", clientEmail)
  1190. }
  1191. var settings map[string]interface{}
  1192. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1193. if err != nil {
  1194. return err
  1195. }
  1196. clients := settings["clients"].([]interface{})
  1197. var newClients []interface{}
  1198. for client_index := range clients {
  1199. c := clients[client_index].(map[string]interface{})
  1200. if c["email"] == clientEmail {
  1201. c["expiryTime"] = expiry_time
  1202. newClients = append(newClients, interface{}(c))
  1203. }
  1204. }
  1205. settings["clients"] = newClients
  1206. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1207. if err != nil {
  1208. return err
  1209. }
  1210. inbound.Settings = string(modifiedSettings)
  1211. _, err = s.UpdateInboundClient(inbound, clientId)
  1212. if err != nil {
  1213. return err
  1214. }
  1215. return nil
  1216. }
  1217. func (s *InboundService) ResetClientTrafficLimitByEmail(clientEmail string, totalGB int) error {
  1218. if totalGB < 0 {
  1219. return common.NewError("totalGB must be >= 0")
  1220. }
  1221. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1222. if err != nil {
  1223. return err
  1224. }
  1225. if inbound == nil {
  1226. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1227. }
  1228. oldClients, err := s.GetClients(inbound)
  1229. if err != nil {
  1230. return err
  1231. }
  1232. clientId := ""
  1233. for _, oldClient := range oldClients {
  1234. if oldClient.Email == clientEmail {
  1235. if inbound.Protocol == "trojan" {
  1236. clientId = oldClient.Password
  1237. } else {
  1238. clientId = oldClient.ID
  1239. }
  1240. break
  1241. }
  1242. }
  1243. if len(clientId) == 0 {
  1244. return common.NewError("Client Not Found For Email:", clientEmail)
  1245. }
  1246. var settings map[string]interface{}
  1247. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1248. if err != nil {
  1249. return err
  1250. }
  1251. clients := settings["clients"].([]interface{})
  1252. var newClients []interface{}
  1253. for client_index := range clients {
  1254. c := clients[client_index].(map[string]interface{})
  1255. if c["email"] == clientEmail {
  1256. c["totalGB"] = totalGB * 1024 * 1024 * 1024
  1257. newClients = append(newClients, interface{}(c))
  1258. }
  1259. }
  1260. settings["clients"] = newClients
  1261. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1262. if err != nil {
  1263. return err
  1264. }
  1265. inbound.Settings = string(modifiedSettings)
  1266. _, err = s.UpdateInboundClient(inbound, clientId)
  1267. if err != nil {
  1268. return err
  1269. }
  1270. return nil
  1271. }
  1272. func (s *InboundService) ResetClientTrafficByEmail(clientEmail string) error {
  1273. db := database.GetDB()
  1274. result := db.Model(xray.ClientTraffic{}).
  1275. Where("email = ?", clientEmail).
  1276. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  1277. err := result.Error
  1278. if err != nil {
  1279. return err
  1280. }
  1281. return nil
  1282. }
  1283. func (s *InboundService) ResetClientTraffic(id int, clientEmail string) (bool, error) {
  1284. needRestart := false
  1285. traffic, err := s.GetClientTrafficByEmail(clientEmail)
  1286. if err != nil {
  1287. return false, err
  1288. }
  1289. if !traffic.Enable {
  1290. inbound, err := s.GetInbound(id)
  1291. if err != nil {
  1292. return false, err
  1293. }
  1294. clients, err := s.GetClients(inbound)
  1295. if err != nil {
  1296. return false, err
  1297. }
  1298. for _, client := range clients {
  1299. if client.Email == clientEmail {
  1300. s.xrayApi.Init(p.GetAPIPort())
  1301. cipher := ""
  1302. if string(inbound.Protocol) == "shadowsocks" {
  1303. var oldSettings map[string]interface{}
  1304. err = json.Unmarshal([]byte(inbound.Settings), &oldSettings)
  1305. if err != nil {
  1306. return false, err
  1307. }
  1308. cipher = oldSettings["method"].(string)
  1309. }
  1310. err1 := s.xrayApi.AddUser(string(inbound.Protocol), inbound.Tag, map[string]interface{}{
  1311. "email": client.Email,
  1312. "id": client.ID,
  1313. "flow": client.Flow,
  1314. "password": client.Password,
  1315. "cipher": cipher,
  1316. })
  1317. if err1 == nil {
  1318. logger.Debug("Client enabled due to reset traffic:", clientEmail)
  1319. } else {
  1320. logger.Debug("Error in enabling client by api:", err1)
  1321. needRestart = true
  1322. }
  1323. s.xrayApi.Close()
  1324. break
  1325. }
  1326. }
  1327. }
  1328. traffic.Up = 0
  1329. traffic.Down = 0
  1330. traffic.Enable = true
  1331. db := database.GetDB()
  1332. err = db.Save(traffic).Error
  1333. if err != nil {
  1334. return false, err
  1335. }
  1336. return needRestart, nil
  1337. }
  1338. func (s *InboundService) ResetAllClientTraffics(id int) error {
  1339. db := database.GetDB()
  1340. whereText := "inbound_id "
  1341. if id == -1 {
  1342. whereText += " > ?"
  1343. } else {
  1344. whereText += " = ?"
  1345. }
  1346. result := db.Model(xray.ClientTraffic{}).
  1347. Where(whereText, id).
  1348. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  1349. err := result.Error
  1350. if err != nil {
  1351. return err
  1352. }
  1353. return nil
  1354. }
  1355. func (s *InboundService) ResetAllTraffics() error {
  1356. db := database.GetDB()
  1357. result := db.Model(model.Inbound{}).
  1358. Where("user_id > ?", 0).
  1359. Updates(map[string]interface{}{"up": 0, "down": 0})
  1360. err := result.Error
  1361. if err != nil {
  1362. return err
  1363. }
  1364. return nil
  1365. }
  1366. func (s *InboundService) DelDepletedClients(id int) (err error) {
  1367. db := database.GetDB()
  1368. tx := db.Begin()
  1369. defer func() {
  1370. if err == nil {
  1371. tx.Commit()
  1372. } else {
  1373. tx.Rollback()
  1374. }
  1375. }()
  1376. whereText := "reset = 0 and inbound_id "
  1377. if id < 0 {
  1378. whereText += "> ?"
  1379. } else {
  1380. whereText += "= ?"
  1381. }
  1382. depletedClients := []xray.ClientTraffic{}
  1383. 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
  1384. if err != nil {
  1385. return err
  1386. }
  1387. for _, depletedClient := range depletedClients {
  1388. emails := strings.Split(depletedClient.Email, ",")
  1389. oldInbound, err := s.GetInbound(depletedClient.InboundId)
  1390. if err != nil {
  1391. return err
  1392. }
  1393. var oldSettings map[string]interface{}
  1394. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  1395. if err != nil {
  1396. return err
  1397. }
  1398. oldClients := oldSettings["clients"].([]interface{})
  1399. var newClients []interface{}
  1400. for _, client := range oldClients {
  1401. deplete := false
  1402. c := client.(map[string]interface{})
  1403. for _, email := range emails {
  1404. if email == c["email"].(string) {
  1405. deplete = true
  1406. break
  1407. }
  1408. }
  1409. if !deplete {
  1410. newClients = append(newClients, client)
  1411. }
  1412. }
  1413. if len(newClients) > 0 {
  1414. oldSettings["clients"] = newClients
  1415. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  1416. if err != nil {
  1417. return err
  1418. }
  1419. oldInbound.Settings = string(newSettings)
  1420. err = tx.Save(oldInbound).Error
  1421. if err != nil {
  1422. return err
  1423. }
  1424. } else {
  1425. // Delete inbound if no client remains
  1426. s.DelInbound(depletedClient.InboundId)
  1427. }
  1428. }
  1429. err = tx.Where(whereText+" and enable = ?", id, false).Delete(xray.ClientTraffic{}).Error
  1430. if err != nil {
  1431. return err
  1432. }
  1433. return nil
  1434. }
  1435. func (s *InboundService) GetClientTrafficTgBot(tguname string) ([]*xray.ClientTraffic, error) {
  1436. db := database.GetDB()
  1437. var inbounds []*model.Inbound
  1438. err := db.Model(model.Inbound{}).Where("settings like ?", fmt.Sprintf(`%%"tgId": "%s"%%`, tguname)).Find(&inbounds).Error
  1439. if err != nil && err != gorm.ErrRecordNotFound {
  1440. return nil, err
  1441. }
  1442. var emails []string
  1443. for _, inbound := range inbounds {
  1444. clients, err := s.GetClients(inbound)
  1445. if err != nil {
  1446. logger.Error("Unable to get clients from inbound")
  1447. }
  1448. for _, client := range clients {
  1449. if client.TgID == tguname {
  1450. emails = append(emails, client.Email)
  1451. }
  1452. }
  1453. }
  1454. var traffics []*xray.ClientTraffic
  1455. err = db.Model(xray.ClientTraffic{}).Where("email IN ?", emails).Find(&traffics).Error
  1456. if err != nil {
  1457. if err == gorm.ErrRecordNotFound {
  1458. logger.Warning(err)
  1459. return nil, err
  1460. }
  1461. }
  1462. return traffics, err
  1463. }
  1464. func (s *InboundService) GetClientTrafficByEmail(email string) (traffic *xray.ClientTraffic, err error) {
  1465. db := database.GetDB()
  1466. var traffics []*xray.ClientTraffic
  1467. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  1468. if err != nil {
  1469. logger.Warning(err)
  1470. return nil, err
  1471. }
  1472. if len(traffics) > 0 {
  1473. return traffics[0], nil
  1474. }
  1475. return nil, nil
  1476. }
  1477. func (s *InboundService) SearchClientTraffic(query string) (traffic *xray.ClientTraffic, err error) {
  1478. db := database.GetDB()
  1479. inbound := &model.Inbound{}
  1480. traffic = &xray.ClientTraffic{}
  1481. err = db.Model(model.Inbound{}).Where("settings like ?", "%\""+query+"\"%").First(inbound).Error
  1482. if err != nil {
  1483. if err == gorm.ErrRecordNotFound {
  1484. logger.Warning(err)
  1485. return nil, err
  1486. }
  1487. }
  1488. traffic.InboundId = inbound.Id
  1489. // get settings clients
  1490. settings := map[string][]model.Client{}
  1491. json.Unmarshal([]byte(inbound.Settings), &settings)
  1492. clients := settings["clients"]
  1493. for _, client := range clients {
  1494. if client.ID == query && client.Email != "" {
  1495. traffic.Email = client.Email
  1496. break
  1497. }
  1498. if client.Password == query && client.Email != "" {
  1499. traffic.Email = client.Email
  1500. break
  1501. }
  1502. }
  1503. if traffic.Email == "" {
  1504. return nil, err
  1505. }
  1506. err = db.Model(xray.ClientTraffic{}).Where("email = ?", traffic.Email).First(traffic).Error
  1507. if err != nil {
  1508. logger.Warning(err)
  1509. return nil, err
  1510. }
  1511. return traffic, err
  1512. }
  1513. func (s *InboundService) GetInboundClientIps(clientEmail string) (string, error) {
  1514. db := database.GetDB()
  1515. InboundClientIps := &model.InboundClientIps{}
  1516. err := db.Model(model.InboundClientIps{}).Where("client_email = ?", clientEmail).First(InboundClientIps).Error
  1517. if err != nil {
  1518. return "", err
  1519. }
  1520. return InboundClientIps.Ips, nil
  1521. }
  1522. func (s *InboundService) ClearClientIps(clientEmail string) error {
  1523. db := database.GetDB()
  1524. result := db.Model(model.InboundClientIps{}).
  1525. Where("client_email = ?", clientEmail).
  1526. Update("ips", "")
  1527. err := result.Error
  1528. if err != nil {
  1529. return err
  1530. }
  1531. return nil
  1532. }
  1533. func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) {
  1534. db := database.GetDB()
  1535. var inbounds []*model.Inbound
  1536. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("remark like ?", "%"+query+"%").Find(&inbounds).Error
  1537. if err != nil && err != gorm.ErrRecordNotFound {
  1538. return nil, err
  1539. }
  1540. return inbounds, nil
  1541. }
  1542. func (s *InboundService) MigrationRequirements() {
  1543. db := database.GetDB()
  1544. tx := db.Begin()
  1545. var err error
  1546. defer func() {
  1547. if err == nil {
  1548. tx.Commit()
  1549. } else {
  1550. tx.Rollback()
  1551. }
  1552. }()
  1553. // Fix inbounds based problems
  1554. var inbounds []*model.Inbound
  1555. err = tx.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error
  1556. if err != nil && err != gorm.ErrRecordNotFound {
  1557. return
  1558. }
  1559. for inbound_index := range inbounds {
  1560. settings := map[string]interface{}{}
  1561. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  1562. clients, ok := settings["clients"].([]interface{})
  1563. if ok {
  1564. // Fix Clinet configuration problems
  1565. var newClients []interface{}
  1566. for client_index := range clients {
  1567. c := clients[client_index].(map[string]interface{})
  1568. // Add email='' if it is not exists
  1569. if _, ok := c["email"]; !ok {
  1570. c["email"] = ""
  1571. }
  1572. // Remove "flow": "xtls-rprx-direct"
  1573. if _, ok := c["flow"]; ok {
  1574. if c["flow"] == "xtls-rprx-direct" {
  1575. c["flow"] = ""
  1576. }
  1577. }
  1578. newClients = append(newClients, interface{}(c))
  1579. }
  1580. settings["clients"] = newClients
  1581. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1582. if err != nil {
  1583. return
  1584. }
  1585. inbounds[inbound_index].Settings = string(modifiedSettings)
  1586. }
  1587. // Add client traffic row for all clients which has email
  1588. modelClients, err := s.GetClients(inbounds[inbound_index])
  1589. if err != nil {
  1590. return
  1591. }
  1592. for _, modelClient := range modelClients {
  1593. if len(modelClient.Email) > 0 {
  1594. var count int64
  1595. tx.Model(xray.ClientTraffic{}).Where("email = ?", modelClient.Email).Count(&count)
  1596. if count == 0 {
  1597. s.AddClientStat(tx, inbounds[inbound_index].Id, &modelClient)
  1598. }
  1599. }
  1600. }
  1601. }
  1602. tx.Save(inbounds)
  1603. // Remove orphaned traffics
  1604. tx.Where("inbound_id = 0").Delete(xray.ClientTraffic{})
  1605. }
  1606. func (s *InboundService) MigrateDB() {
  1607. s.MigrationRequirements()
  1608. s.MigrationRemoveOrphanedTraffics()
  1609. }
  1610. func (s *InboundService) GetOnlineClinets() []string {
  1611. return p.GetOnlineClients()
  1612. }