1
0

inbound.go 48 KB

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