inbound.go 44 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797
  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) MigrationRemoveOrphanedTraffics() {
  898. db := database.GetDB()
  899. db.Exec(`
  900. DELETE FROM client_traffics
  901. WHERE email NOT IN (
  902. SELECT JSON_EXTRACT(client.value, '$.email')
  903. FROM inbounds,
  904. JSON_EACH(JSON_EXTRACT(inbounds.settings, '$.clients')) AS client
  905. )
  906. `)
  907. }
  908. func (s *InboundService) AddClientStat(tx *gorm.DB, inboundId int, client *model.Client) error {
  909. clientTraffic := xray.ClientTraffic{}
  910. clientTraffic.InboundId = inboundId
  911. clientTraffic.Email = client.Email
  912. clientTraffic.Total = client.TotalGB
  913. clientTraffic.ExpiryTime = client.ExpiryTime
  914. clientTraffic.Enable = true
  915. clientTraffic.Up = 0
  916. clientTraffic.Down = 0
  917. clientTraffic.Reset = client.Reset
  918. result := tx.Create(&clientTraffic)
  919. err := result.Error
  920. if err != nil {
  921. return err
  922. }
  923. return nil
  924. }
  925. func (s *InboundService) UpdateClientStat(tx *gorm.DB, email string, client *model.Client) error {
  926. result := tx.Model(xray.ClientTraffic{}).
  927. Where("email = ?", email).
  928. Updates(map[string]interface{}{
  929. "enable": true,
  930. "email": client.Email,
  931. "total": client.TotalGB,
  932. "expiry_time": client.ExpiryTime,
  933. "reset": client.Reset})
  934. err := result.Error
  935. if err != nil {
  936. return err
  937. }
  938. return nil
  939. }
  940. func (s *InboundService) UpdateClientIPs(tx *gorm.DB, oldEmail string, newEmail string) error {
  941. return tx.Model(model.InboundClientIps{}).Where("client_email = ?", oldEmail).Update("client_email", newEmail).Error
  942. }
  943. func (s *InboundService) DelClientStat(tx *gorm.DB, email string) error {
  944. return tx.Where("email = ?", email).Delete(xray.ClientTraffic{}).Error
  945. }
  946. func (s *InboundService) DelClientIPs(tx *gorm.DB, email string) error {
  947. logger.Warning(email)
  948. return tx.Where("client_email = ?", email).Delete(model.InboundClientIps{}).Error
  949. }
  950. func (s *InboundService) GetClientInboundByTrafficID(trafficId int) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  951. db := database.GetDB()
  952. var traffics []*xray.ClientTraffic
  953. err = db.Model(xray.ClientTraffic{}).Where("id = ?", trafficId).Find(&traffics).Error
  954. if err != nil {
  955. logger.Warning(err)
  956. return nil, nil, err
  957. }
  958. if len(traffics) > 0 {
  959. inbound, err = s.GetInbound(traffics[0].InboundId)
  960. return traffics[0], inbound, err
  961. }
  962. return nil, nil, nil
  963. }
  964. func (s *InboundService) GetClientInboundByEmail(email string) (traffic *xray.ClientTraffic, inbound *model.Inbound, err error) {
  965. db := database.GetDB()
  966. var traffics []*xray.ClientTraffic
  967. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).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) GetClientByEmail(clientEmail string) (*xray.ClientTraffic, *model.Client, error) {
  979. traffic, inbound, err := s.GetClientInboundByEmail(clientEmail)
  980. if err != nil {
  981. return nil, nil, err
  982. }
  983. if inbound == nil {
  984. return nil, nil, common.NewError("Inbound Not Found For Email:", clientEmail)
  985. }
  986. clients, err := s.GetClients(inbound)
  987. if err != nil {
  988. return nil, nil, err
  989. }
  990. for _, client := range clients {
  991. if client.Email == clientEmail {
  992. return traffic, &client, nil
  993. }
  994. }
  995. return nil, nil, common.NewError("Client Not Found In Inbound For Email:", clientEmail)
  996. }
  997. func (s *InboundService) SetClientTelegramUserID(trafficId int, tgId string) error {
  998. traffic, inbound, err := s.GetClientInboundByTrafficID(trafficId)
  999. if err != nil {
  1000. return err
  1001. }
  1002. if inbound == nil {
  1003. return common.NewError("Inbound Not Found For Traffic ID:", trafficId)
  1004. }
  1005. clientEmail := traffic.Email
  1006. oldClients, err := s.GetClients(inbound)
  1007. if err != nil {
  1008. return err
  1009. }
  1010. clientId := ""
  1011. for _, oldClient := range oldClients {
  1012. if oldClient.Email == clientEmail {
  1013. if inbound.Protocol == "trojan" {
  1014. clientId = oldClient.Password
  1015. } else {
  1016. clientId = oldClient.ID
  1017. }
  1018. break
  1019. }
  1020. }
  1021. if len(clientId) == 0 {
  1022. return common.NewError("Client Not Found For Email:", clientEmail)
  1023. }
  1024. var settings map[string]interface{}
  1025. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1026. if err != nil {
  1027. return err
  1028. }
  1029. clients := settings["clients"].([]interface{})
  1030. var newClients []interface{}
  1031. for client_index := range clients {
  1032. c := clients[client_index].(map[string]interface{})
  1033. if c["email"] == clientEmail {
  1034. c["tgId"] = tgId
  1035. newClients = append(newClients, interface{}(c))
  1036. }
  1037. }
  1038. settings["clients"] = newClients
  1039. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1040. if err != nil {
  1041. return err
  1042. }
  1043. inbound.Settings = string(modifiedSettings)
  1044. _, err = s.UpdateInboundClient(inbound, clientId)
  1045. if err != nil {
  1046. return err
  1047. }
  1048. return nil
  1049. }
  1050. func (s *InboundService) ToggleClientEnableByEmail(clientEmail string) (bool, error) {
  1051. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1052. if err != nil {
  1053. return false, err
  1054. }
  1055. if inbound == nil {
  1056. return false, common.NewError("Inbound Not Found For Email:", clientEmail)
  1057. }
  1058. oldClients, err := s.GetClients(inbound)
  1059. if err != nil {
  1060. return false, err
  1061. }
  1062. clientId := ""
  1063. clientOldEnabled := false
  1064. for _, oldClient := range oldClients {
  1065. if oldClient.Email == clientEmail {
  1066. if inbound.Protocol == "trojan" {
  1067. clientId = oldClient.Password
  1068. } else {
  1069. clientId = oldClient.ID
  1070. }
  1071. clientOldEnabled = oldClient.Enable
  1072. break
  1073. }
  1074. }
  1075. if len(clientId) == 0 {
  1076. return false, common.NewError("Client Not Found For Email:", clientEmail)
  1077. }
  1078. var settings map[string]interface{}
  1079. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1080. if err != nil {
  1081. return false, err
  1082. }
  1083. clients := settings["clients"].([]interface{})
  1084. var newClients []interface{}
  1085. for client_index := range clients {
  1086. c := clients[client_index].(map[string]interface{})
  1087. if c["email"] == clientEmail {
  1088. c["enable"] = !clientOldEnabled
  1089. newClients = append(newClients, interface{}(c))
  1090. }
  1091. }
  1092. settings["clients"] = newClients
  1093. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1094. if err != nil {
  1095. return false, err
  1096. }
  1097. inbound.Settings = string(modifiedSettings)
  1098. _, err = s.UpdateInboundClient(inbound, clientId)
  1099. if err != nil {
  1100. return false, err
  1101. }
  1102. return !clientOldEnabled, nil
  1103. }
  1104. func (s *InboundService) ResetClientIpLimitByEmail(clientEmail string, count int) error {
  1105. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1106. if err != nil {
  1107. return err
  1108. }
  1109. if inbound == nil {
  1110. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1111. }
  1112. oldClients, err := s.GetClients(inbound)
  1113. if err != nil {
  1114. return err
  1115. }
  1116. clientId := ""
  1117. for _, oldClient := range oldClients {
  1118. if oldClient.Email == clientEmail {
  1119. if inbound.Protocol == "trojan" {
  1120. clientId = oldClient.Password
  1121. } else {
  1122. clientId = oldClient.ID
  1123. }
  1124. break
  1125. }
  1126. }
  1127. if len(clientId) == 0 {
  1128. return common.NewError("Client Not Found For Email:", clientEmail)
  1129. }
  1130. var settings map[string]interface{}
  1131. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1132. if err != nil {
  1133. return err
  1134. }
  1135. clients := settings["clients"].([]interface{})
  1136. var newClients []interface{}
  1137. for client_index := range clients {
  1138. c := clients[client_index].(map[string]interface{})
  1139. if c["email"] == clientEmail {
  1140. c["limitIp"] = count
  1141. newClients = append(newClients, interface{}(c))
  1142. }
  1143. }
  1144. settings["clients"] = newClients
  1145. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1146. if err != nil {
  1147. return err
  1148. }
  1149. inbound.Settings = string(modifiedSettings)
  1150. _, err = s.UpdateInboundClient(inbound, clientId)
  1151. if err != nil {
  1152. return err
  1153. }
  1154. return nil
  1155. }
  1156. func (s *InboundService) ResetClientExpiryTimeByEmail(clientEmail string, expiry_time int64) error {
  1157. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1158. if err != nil {
  1159. return err
  1160. }
  1161. if inbound == nil {
  1162. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1163. }
  1164. oldClients, err := s.GetClients(inbound)
  1165. if err != nil {
  1166. return err
  1167. }
  1168. clientId := ""
  1169. for _, oldClient := range oldClients {
  1170. if oldClient.Email == clientEmail {
  1171. if inbound.Protocol == "trojan" {
  1172. clientId = oldClient.Password
  1173. } else {
  1174. clientId = oldClient.ID
  1175. }
  1176. break
  1177. }
  1178. }
  1179. if len(clientId) == 0 {
  1180. return common.NewError("Client Not Found For Email:", clientEmail)
  1181. }
  1182. var settings map[string]interface{}
  1183. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1184. if err != nil {
  1185. return err
  1186. }
  1187. clients := settings["clients"].([]interface{})
  1188. var newClients []interface{}
  1189. for client_index := range clients {
  1190. c := clients[client_index].(map[string]interface{})
  1191. if c["email"] == clientEmail {
  1192. c["expiryTime"] = expiry_time
  1193. newClients = append(newClients, interface{}(c))
  1194. }
  1195. }
  1196. settings["clients"] = newClients
  1197. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1198. if err != nil {
  1199. return err
  1200. }
  1201. inbound.Settings = string(modifiedSettings)
  1202. _, err = s.UpdateInboundClient(inbound, clientId)
  1203. if err != nil {
  1204. return err
  1205. }
  1206. return nil
  1207. }
  1208. func (s *InboundService) ResetClientTrafficLimitByEmail(clientEmail string, totalGB int) error {
  1209. if totalGB < 0 {
  1210. return common.NewError("totalGB must be >= 0")
  1211. }
  1212. _, inbound, err := s.GetClientInboundByEmail(clientEmail)
  1213. if err != nil {
  1214. return err
  1215. }
  1216. if inbound == nil {
  1217. return common.NewError("Inbound Not Found For Email:", clientEmail)
  1218. }
  1219. oldClients, err := s.GetClients(inbound)
  1220. if err != nil {
  1221. return err
  1222. }
  1223. clientId := ""
  1224. for _, oldClient := range oldClients {
  1225. if oldClient.Email == clientEmail {
  1226. if inbound.Protocol == "trojan" {
  1227. clientId = oldClient.Password
  1228. } else {
  1229. clientId = oldClient.ID
  1230. }
  1231. break
  1232. }
  1233. }
  1234. if len(clientId) == 0 {
  1235. return common.NewError("Client Not Found For Email:", clientEmail)
  1236. }
  1237. var settings map[string]interface{}
  1238. err = json.Unmarshal([]byte(inbound.Settings), &settings)
  1239. if err != nil {
  1240. return err
  1241. }
  1242. clients := settings["clients"].([]interface{})
  1243. var newClients []interface{}
  1244. for client_index := range clients {
  1245. c := clients[client_index].(map[string]interface{})
  1246. if c["email"] == clientEmail {
  1247. c["totalGB"] = totalGB * 1024 * 1024 * 1024
  1248. newClients = append(newClients, interface{}(c))
  1249. }
  1250. }
  1251. settings["clients"] = newClients
  1252. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1253. if err != nil {
  1254. return err
  1255. }
  1256. inbound.Settings = string(modifiedSettings)
  1257. _, err = s.UpdateInboundClient(inbound, clientId)
  1258. if err != nil {
  1259. return err
  1260. }
  1261. return nil
  1262. }
  1263. func (s *InboundService) ResetClientTrafficByEmail(clientEmail string) error {
  1264. db := database.GetDB()
  1265. result := db.Model(xray.ClientTraffic{}).
  1266. Where("email = ?", clientEmail).
  1267. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  1268. err := result.Error
  1269. if err != nil {
  1270. return err
  1271. }
  1272. return nil
  1273. }
  1274. func (s *InboundService) ResetClientTraffic(id int, clientEmail string) (bool, error) {
  1275. needRestart := false
  1276. traffic, err := s.GetClientTrafficByEmail(clientEmail)
  1277. if err != nil {
  1278. return false, err
  1279. }
  1280. if !traffic.Enable {
  1281. inbound, err := s.GetInbound(id)
  1282. if err != nil {
  1283. return false, err
  1284. }
  1285. clients, err := s.GetClients(inbound)
  1286. if err != nil {
  1287. return false, err
  1288. }
  1289. for _, client := range clients {
  1290. if client.Email == clientEmail {
  1291. s.xrayApi.Init(p.GetAPIPort())
  1292. cipher := ""
  1293. if string(inbound.Protocol) == "shadowsocks" {
  1294. var oldSettings map[string]interface{}
  1295. err = json.Unmarshal([]byte(inbound.Settings), &oldSettings)
  1296. if err != nil {
  1297. return false, err
  1298. }
  1299. cipher = oldSettings["method"].(string)
  1300. }
  1301. err1 := s.xrayApi.AddUser(string(inbound.Protocol), inbound.Tag, map[string]interface{}{
  1302. "email": client.Email,
  1303. "id": client.ID,
  1304. "flow": client.Flow,
  1305. "password": client.Password,
  1306. "cipher": cipher,
  1307. })
  1308. if err1 == nil {
  1309. logger.Debug("Client enabled due to reset traffic:", clientEmail)
  1310. } else {
  1311. logger.Debug("Error in enabling client by api:", err1)
  1312. needRestart = true
  1313. }
  1314. s.xrayApi.Close()
  1315. break
  1316. }
  1317. }
  1318. }
  1319. traffic.Up = 0
  1320. traffic.Down = 0
  1321. traffic.Enable = true
  1322. db := database.GetDB()
  1323. err = db.Save(traffic).Error
  1324. if err != nil {
  1325. return false, err
  1326. }
  1327. return needRestart, nil
  1328. }
  1329. func (s *InboundService) ResetAllClientTraffics(id int) error {
  1330. db := database.GetDB()
  1331. whereText := "inbound_id "
  1332. if id == -1 {
  1333. whereText += " > ?"
  1334. } else {
  1335. whereText += " = ?"
  1336. }
  1337. result := db.Model(xray.ClientTraffic{}).
  1338. Where(whereText, id).
  1339. Updates(map[string]interface{}{"enable": true, "up": 0, "down": 0})
  1340. err := result.Error
  1341. if err != nil {
  1342. return err
  1343. }
  1344. return nil
  1345. }
  1346. func (s *InboundService) ResetAllTraffics() error {
  1347. db := database.GetDB()
  1348. result := db.Model(model.Inbound{}).
  1349. Where("user_id > ?", 0).
  1350. Updates(map[string]interface{}{"up": 0, "down": 0})
  1351. err := result.Error
  1352. if err != nil {
  1353. return err
  1354. }
  1355. return nil
  1356. }
  1357. func (s *InboundService) DelDepletedClients(id int) (err error) {
  1358. db := database.GetDB()
  1359. tx := db.Begin()
  1360. defer func() {
  1361. if err == nil {
  1362. tx.Commit()
  1363. } else {
  1364. tx.Rollback()
  1365. }
  1366. }()
  1367. whereText := "reset = 0 and inbound_id "
  1368. if id < 0 {
  1369. whereText += "> ?"
  1370. } else {
  1371. whereText += "= ?"
  1372. }
  1373. depletedClients := []xray.ClientTraffic{}
  1374. 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
  1375. if err != nil {
  1376. return err
  1377. }
  1378. for _, depletedClient := range depletedClients {
  1379. emails := strings.Split(depletedClient.Email, ",")
  1380. oldInbound, err := s.GetInbound(depletedClient.InboundId)
  1381. if err != nil {
  1382. return err
  1383. }
  1384. var oldSettings map[string]interface{}
  1385. err = json.Unmarshal([]byte(oldInbound.Settings), &oldSettings)
  1386. if err != nil {
  1387. return err
  1388. }
  1389. oldClients := oldSettings["clients"].([]interface{})
  1390. var newClients []interface{}
  1391. for _, client := range oldClients {
  1392. deplete := false
  1393. c := client.(map[string]interface{})
  1394. for _, email := range emails {
  1395. if email == c["email"].(string) {
  1396. deplete = true
  1397. break
  1398. }
  1399. }
  1400. if !deplete {
  1401. newClients = append(newClients, client)
  1402. }
  1403. }
  1404. if len(newClients) > 0 {
  1405. oldSettings["clients"] = newClients
  1406. newSettings, err := json.MarshalIndent(oldSettings, "", " ")
  1407. if err != nil {
  1408. return err
  1409. }
  1410. oldInbound.Settings = string(newSettings)
  1411. err = tx.Save(oldInbound).Error
  1412. if err != nil {
  1413. return err
  1414. }
  1415. } else {
  1416. // Delete inbound if no client remains
  1417. s.DelInbound(depletedClient.InboundId)
  1418. }
  1419. }
  1420. err = tx.Where(whereText+" and enable = ?", id, false).Delete(xray.ClientTraffic{}).Error
  1421. if err != nil {
  1422. return err
  1423. }
  1424. return nil
  1425. }
  1426. func (s *InboundService) GetClientTrafficTgBot(tguname string) ([]*xray.ClientTraffic, error) {
  1427. db := database.GetDB()
  1428. var inbounds []*model.Inbound
  1429. err := db.Model(model.Inbound{}).Where("settings like ?", fmt.Sprintf(`%%"tgId": "%s"%%`, tguname)).Find(&inbounds).Error
  1430. if err != nil && err != gorm.ErrRecordNotFound {
  1431. return nil, err
  1432. }
  1433. var emails []string
  1434. for _, inbound := range inbounds {
  1435. clients, err := s.GetClients(inbound)
  1436. if err != nil {
  1437. logger.Error("Unable to get clients from inbound")
  1438. }
  1439. for _, client := range clients {
  1440. if client.TgID == tguname {
  1441. emails = append(emails, client.Email)
  1442. }
  1443. }
  1444. }
  1445. var traffics []*xray.ClientTraffic
  1446. err = db.Model(xray.ClientTraffic{}).Where("email IN ?", emails).Find(&traffics).Error
  1447. if err != nil {
  1448. if err == gorm.ErrRecordNotFound {
  1449. logger.Warning(err)
  1450. return nil, err
  1451. }
  1452. }
  1453. return traffics, err
  1454. }
  1455. func (s *InboundService) GetClientTrafficByEmail(email string) (traffic *xray.ClientTraffic, err error) {
  1456. db := database.GetDB()
  1457. var traffics []*xray.ClientTraffic
  1458. err = db.Model(xray.ClientTraffic{}).Where("email = ?", email).Find(&traffics).Error
  1459. if err != nil {
  1460. logger.Warning(err)
  1461. return nil, err
  1462. }
  1463. if len(traffics) > 0 {
  1464. return traffics[0], nil
  1465. }
  1466. return nil, nil
  1467. }
  1468. func (s *InboundService) SearchClientTraffic(query string) (traffic *xray.ClientTraffic, err error) {
  1469. db := database.GetDB()
  1470. inbound := &model.Inbound{}
  1471. traffic = &xray.ClientTraffic{}
  1472. err = db.Model(model.Inbound{}).Where("settings like ?", "%\""+query+"\"%").First(inbound).Error
  1473. if err != nil {
  1474. if err == gorm.ErrRecordNotFound {
  1475. logger.Warning(err)
  1476. return nil, err
  1477. }
  1478. }
  1479. traffic.InboundId = inbound.Id
  1480. // get settings clients
  1481. settings := map[string][]model.Client{}
  1482. json.Unmarshal([]byte(inbound.Settings), &settings)
  1483. clients := settings["clients"]
  1484. for _, client := range clients {
  1485. if client.ID == query && client.Email != "" {
  1486. traffic.Email = client.Email
  1487. break
  1488. }
  1489. if client.Password == query && client.Email != "" {
  1490. traffic.Email = client.Email
  1491. break
  1492. }
  1493. }
  1494. if traffic.Email == "" {
  1495. return nil, err
  1496. }
  1497. err = db.Model(xray.ClientTraffic{}).Where("email = ?", traffic.Email).First(traffic).Error
  1498. if err != nil {
  1499. logger.Warning(err)
  1500. return nil, err
  1501. }
  1502. return traffic, err
  1503. }
  1504. func (s *InboundService) GetInboundClientIps(clientEmail string) (string, error) {
  1505. db := database.GetDB()
  1506. InboundClientIps := &model.InboundClientIps{}
  1507. err := db.Model(model.InboundClientIps{}).Where("client_email = ?", clientEmail).First(InboundClientIps).Error
  1508. if err != nil {
  1509. return "", err
  1510. }
  1511. return InboundClientIps.Ips, nil
  1512. }
  1513. func (s *InboundService) ClearClientIps(clientEmail string) error {
  1514. db := database.GetDB()
  1515. result := db.Model(model.InboundClientIps{}).
  1516. Where("client_email = ?", clientEmail).
  1517. Update("ips", "")
  1518. err := result.Error
  1519. if err != nil {
  1520. return err
  1521. }
  1522. return nil
  1523. }
  1524. func (s *InboundService) SearchInbounds(query string) ([]*model.Inbound, error) {
  1525. db := database.GetDB()
  1526. var inbounds []*model.Inbound
  1527. err := db.Model(model.Inbound{}).Preload("ClientStats").Where("remark like ?", "%"+query+"%").Find(&inbounds).Error
  1528. if err != nil && err != gorm.ErrRecordNotFound {
  1529. return nil, err
  1530. }
  1531. return inbounds, nil
  1532. }
  1533. func (s *InboundService) MigrationRequirements() {
  1534. db := database.GetDB()
  1535. tx := db.Begin()
  1536. var err error
  1537. defer func() {
  1538. if err == nil {
  1539. tx.Commit()
  1540. } else {
  1541. tx.Rollback()
  1542. }
  1543. }()
  1544. // Fix inbounds based problems
  1545. var inbounds []*model.Inbound
  1546. err = tx.Model(model.Inbound{}).Where("protocol IN (?)", []string{"vmess", "vless", "trojan"}).Find(&inbounds).Error
  1547. if err != nil && err != gorm.ErrRecordNotFound {
  1548. return
  1549. }
  1550. for inbound_index := range inbounds {
  1551. settings := map[string]interface{}{}
  1552. json.Unmarshal([]byte(inbounds[inbound_index].Settings), &settings)
  1553. clients, ok := settings["clients"].([]interface{})
  1554. if ok {
  1555. // Fix Clinet configuration problems
  1556. var newClients []interface{}
  1557. for client_index := range clients {
  1558. c := clients[client_index].(map[string]interface{})
  1559. // Add email='' if it is not exists
  1560. if _, ok := c["email"]; !ok {
  1561. c["email"] = ""
  1562. }
  1563. // Remove "flow": "xtls-rprx-direct"
  1564. if _, ok := c["flow"]; ok {
  1565. if c["flow"] == "xtls-rprx-direct" {
  1566. c["flow"] = ""
  1567. }
  1568. }
  1569. newClients = append(newClients, interface{}(c))
  1570. }
  1571. settings["clients"] = newClients
  1572. modifiedSettings, err := json.MarshalIndent(settings, "", " ")
  1573. if err != nil {
  1574. return
  1575. }
  1576. inbounds[inbound_index].Settings = string(modifiedSettings)
  1577. }
  1578. // Add client traffic row for all clients which has email
  1579. modelClients, err := s.GetClients(inbounds[inbound_index])
  1580. if err != nil {
  1581. return
  1582. }
  1583. for _, modelClient := range modelClients {
  1584. if len(modelClient.Email) > 0 {
  1585. var count int64
  1586. tx.Model(xray.ClientTraffic{}).Where("email = ?", modelClient.Email).Count(&count)
  1587. if count == 0 {
  1588. s.AddClientStat(tx, inbounds[inbound_index].Id, &modelClient)
  1589. }
  1590. }
  1591. }
  1592. }
  1593. tx.Save(inbounds)
  1594. // Remove orphaned traffics
  1595. tx.Where("inbound_id = 0").Delete(xray.ClientTraffic{})
  1596. }
  1597. func (s *InboundService) MigrateDB() {
  1598. s.MigrationRequirements()
  1599. s.MigrationRemoveOrphanedTraffics()
  1600. }
  1601. func (s *InboundService) GetOnlineClinets() []string {
  1602. return p.GetOnlineClients()
  1603. }