MainViewModel.swift 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283
  1. //
  2. // MainViewModel.swift
  3. // naiyoup
  4. //
  5. // Created by C Auto on 2021/8/2.
  6. //
  7. import Foundation
  8. import SwiftyUserDefaults
  9. import Combine
  10. //# Shadowsocks
  11. //SS = ss, 1.2.3.4, 8485, encrypt-method=chacha20-ietf-poly1305, password=123456
  12. //Proxy = trojan, server.com, 443, password=123456
  13. //EXTERNAL, site:cn, Direct
  14. //EXTERNAL, mmdb:cn, Direct
  15. //trace
  16. //debug
  17. let conf = """
  18. [General]
  19. loglevel = debug
  20. tun-fd = REPLACE-ME-WITH-THE-FD
  21. dns-server = 223.5.5.5,8.8.8.8
  22. always-fake-ip=*
  23. routing-domain-resolve = true
  24. [Proxy]
  25. Direct = direct
  26. Proxy = ssproxzy
  27. [Rule]
  28. site
  29. mmdb
  30. FINAL, Proxy
  31. """
  32. //[Host]
  33. //proxy_host
  34. let conf_tro = """
  35. [General]
  36. loglevel = trace
  37. dns-server = 223.5.5.5, 114.114.114.114
  38. tun-fd = REPLACE-ME-WITH-THE-FD
  39. always-fake-ip=*
  40. routing-domain-resolve = true
  41. [Proxy]
  42. Direct = direct
  43. Proxy = ssproxzy
  44. [Rule]
  45. site
  46. mmdb
  47. FINAL, Proxy
  48. [Host]
  49. proxy_host
  50. """
  51. class MainViewModel: ObservableObject {
  52. static let main = MainViewModel()
  53. @Published var vpnstatus = "未连接"
  54. @Published var serviceOpen = false
  55. @Published var authting = false
  56. var serverip = ""
  57. var password = ""
  58. var port = 0
  59. var encrypt = ""
  60. var route : Bool = false
  61. var type = "shadowsocks"
  62. var sni = ""
  63. var ip:String? = nil
  64. var status: VPNStatus {
  65. didSet(o) {
  66. updateConnect()
  67. }
  68. }
  69. required init() {
  70. self.status = VPNHelper.shared.vpnStatus
  71. NotificationCenter.default.addObserver(self,selector: #selector(onVPNStatusChanged), name: NSNotification.Name(rawValue: kProxyServiceVPNStatusNotification), object: nil)
  72. }
  73. deinit {
  74. NotificationCenter.default.removeObserver(self)
  75. }
  76. @objc func onVPNStatusChanged(){
  77. self.status = VPNHelper.shared.vpnStatus
  78. }
  79. func updateConnect() {
  80. switch status {
  81. case .connecting:
  82. break
  83. case .on:
  84. self.vpnstatus = "点击断开"
  85. self.serviceOpen = true
  86. break
  87. case .disconnecting:
  88. break
  89. case .off:
  90. self.vpnstatus = "未连接"
  91. self.serviceOpen = false
  92. break
  93. }
  94. guard let bundleAppGroup = Bundle.main.infoDictionary?["appGroup"] as? String else {
  95. fatalError("The application must contain appGroup in Info.plist file")
  96. }
  97. let name = bundleAppGroup
  98. print("打印值\(String(describing: name))")
  99. }
  100. func GetLoginModel() -> LoginModel? {
  101. if let loginModel = Defaults[\.loginModel] {
  102. return JsonUtil.LoginjsonToModel(loginModel, LoginModel.self)
  103. }
  104. return nil
  105. }
  106. func GetAuthNode(nodel:NodelModel?,success:@escaping Success<String?>,completion: ((_ error: Error?)-> Void)?) {
  107. self.vpnstatus = "开始验证"
  108. self.authting = true
  109. NetworkApi.shared.Auth { nodelmodel in
  110. if nodelmodel == nil {
  111. self.vpnstatus = "验证错误,没有获取到节点"
  112. self.authting = false
  113. }
  114. else{
  115. self.vpnstatus = "完成验证"
  116. self.authting = false
  117. if nodel == nil {
  118. self.serverip = nodelmodel?.host ?? ""
  119. self.port = nodelmodel?.port ?? 0
  120. self.encrypt = nodelmodel?.method ?? ""
  121. self.password = nodelmodel?.passwd ?? ""
  122. self.type = nodelmodel?.type ?? "shadowsocks"
  123. self.sni = nodelmodel?.sni ?? ""
  124. self.ip = nodelmodel?.ip
  125. success(nodelmodel?.name ?? "智能选线")
  126. } else {
  127. self.serverip = nodel?.host ?? ""
  128. self.port = nodel?.port ?? 0
  129. self.encrypt = nodel?.method ?? ""
  130. self.password = nodel?.passwd ?? ""
  131. self.type = nodel?.type ?? "shadowsocks"
  132. self.sni = nodel?.sni ?? ""
  133. self.ip = nodel?.ip
  134. success(nodel?.name ?? "智能选线")
  135. }
  136. self.openService{ e in
  137. completion?(e)
  138. }
  139. }
  140. } failure: { err in
  141. self.vpnstatus = "验证错误\(err)"
  142. self.authting = false
  143. }
  144. }
  145. // 域名解析
  146. func getIPAddress(domainName: String) -> String {
  147. var result = ""
  148. let host = CFHostCreateWithName(nil,domainName as CFString).takeRetainedValue()
  149. CFHostStartInfoResolution(host, .addresses, nil)
  150. var success: DarwinBoolean = false
  151. if let addresses = CFHostGetAddressing(host, &success)?.takeUnretainedValue() as NSArray?,
  152. let theAddress = addresses.firstObject as? NSData {
  153. var hostname = [CChar](repeating: 0, count: Int(NI_MAXHOST))
  154. if getnameinfo(theAddress.bytes.assumingMemoryBound(to: sockaddr.self), socklen_t(theAddress.length),
  155. &hostname, socklen_t(hostname.count), nil, 0, NI_NUMERICHOST) == 0 {
  156. let numAddress = String(cString: hostname)
  157. result = numAddress
  158. print(numAddress)
  159. }
  160. }
  161. return result
  162. }
  163. func openService(completion: ((_ error: Error?)-> Void)?) {
  164. // guard (self.activingEndpoint != nil) else {
  165. // completion?(NSError(domain: "ErrorDomain", code: -1, userInfo: ["error" : "没有激活服务节点"]))
  166. // return
  167. // }
  168. // let configData = try? JSONEncoder().encode(self.v2rayConfig)
  169. // guard configData != nil else {
  170. // completion?(NSError(domain: "ErrorDomain", code: -1, userInfo: ["error" : "配置错误"]))
  171. // return
  172. // }
  173. guard let bundleAppGroup = Bundle.main.infoDictionary?["appGroup"] as? String else {
  174. //fatalError("The application must contain appGroup in Info.plist file")
  175. completion?(NSError(domain: "ErrorDomain", code: -1, userInfo: ["error" : "appGroup没有获取到"]))
  176. return
  177. }
  178. var conftmp = ""
  179. //let serverIP = PacketTunnelMessage.getIPAddress(domainName: "")
  180. if (self.type == "shadowsocks")
  181. {
  182. let ss = "ss , \(self.serverip) , \(self.port) , encrypt-method=\(self.encrypt) , password=\(self.password)"
  183. conftmp = conf.replacingOccurrences(of: "ssproxzy", with: String(ss))
  184. } else if(self.type == "trojan") {
  185. if(self.sni == ""){
  186. self.sni = self.serverip
  187. }
  188. //Trojan = trojan, 4.3.2.1, 443, password=123456, sni=www.domain.com
  189. //Proxy = trojan, 1.2.3.4, 443, password=123456, ws=true, ws-path=/abc, sni=www.domain.com //, sni=\(self.sni)
  190. let trojan = "trojan,\(self.serverip),\(self.port),password=\(self.password), sni=\(self.sni)"
  191. let con = conf_tro.replacingOccurrences(of: "ssproxzy", with: String(trojan))
  192. self.serverip = self.ip ?? getIPAddress(domainName: self.serverip)
  193. let host = "\(self.sni) = \(self.serverip)"
  194. //proxy_host
  195. conftmp = con.replacingOccurrences(of: "proxy_host", with: String(host))
  196. }
  197. if self.route {
  198. //EXTERNAL, site:cn, Direct
  199. conftmp = conftmp.replacingOccurrences(of: "site", with: String("EXTERNAL, site:cn, Direct"))
  200. conftmp = conftmp.replacingOccurrences(of: "mmdb", with: String("EXTERNAL, mmdb:cn, Direct"))
  201. }
  202. else {
  203. conftmp = conftmp.replacingOccurrences(of: "site", with: String("EXTERNAL, site:cn, Proxy"))
  204. conftmp = conftmp.replacingOccurrences(of: "mmdb", with: String("EXTERNAL, mmdb:cn, Proxy"))
  205. }
  206. log.debug(conftmp)
  207. let packetTunnelMessage = PacketTunnelMessage(configData: Data(conftmp.utf8), serverIP: self.serverip,appGroup: bundleAppGroup)
  208. VPNHelper.shared.open(with: packetTunnelMessage, completion: { (error) in
  209. completion?(error)
  210. })
  211. }
  212. func closeService(completion: (() -> Void)?) {
  213. VPNHelper.shared.close {
  214. self.serviceOpen = false
  215. completion?()
  216. }
  217. }
  218. func valueFromPlist(value: Int, file: String) -> String? {
  219. if let plistpath = Bundle.main.path(forResource: file, ofType: "entitlements") {
  220. if let entries = NSArray(contentsOfFile: plistpath) as Array? {
  221. // var entry = Dictionary<String, Int>()
  222. for entry in entries {
  223. if let id = entry.object(forKey:"id") as? Int {
  224. if id == value {
  225. if let name = entry.object(forKey:"name") as? String {
  226. return name
  227. }
  228. }
  229. }
  230. }
  231. }
  232. }
  233. return nil
  234. }
  235. }