inbound.go 46 KB

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