inbound.go 46 KB

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