config.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676
  1. /*
  2. * Copyright (c) 2016, Psiphon Inc.
  3. * All rights reserved.
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. *
  18. */
  19. package server
  20. import (
  21. "crypto/rand"
  22. "crypto/rsa"
  23. "crypto/x509"
  24. "encoding/base64"
  25. "encoding/json"
  26. "encoding/pem"
  27. "errors"
  28. "fmt"
  29. "net"
  30. "strconv"
  31. "strings"
  32. "github.com/Psiphon-Inc/crypto/nacl/box"
  33. "github.com/Psiphon-Inc/crypto/ssh"
  34. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common"
  35. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/protocol"
  36. )
  37. const (
  38. SERVER_CONFIG_FILENAME = "psiphond.config"
  39. SERVER_TRAFFIC_RULES_FILENAME = "psiphond-traffic-rules.config"
  40. SERVER_ENTRY_FILENAME = "server-entry.dat"
  41. DEFAULT_SERVER_IP_ADDRESS = "127.0.0.1"
  42. WEB_SERVER_SECRET_BYTE_LENGTH = 32
  43. DISCOVERY_VALUE_KEY_BYTE_LENGTH = 32
  44. SSH_USERNAME_SUFFIX_BYTE_LENGTH = 8
  45. SSH_PASSWORD_BYTE_LENGTH = 32
  46. SSH_RSA_HOST_KEY_BITS = 2048
  47. SSH_OBFUSCATED_KEY_BYTE_LENGTH = 32
  48. )
  49. // Config specifies the configuration and behavior of a Psiphon
  50. // server.
  51. type Config struct {
  52. // LogLevel specifies the log level. Valid values are:
  53. // panic, fatal, error, warn, info, debug
  54. LogLevel string
  55. // LogFilename specifies the path of the file to log
  56. // to. When blank, logs are written to stderr.
  57. LogFilename string
  58. // SkipPanickingLogWriter disables panicking when
  59. // unable to write any logs.
  60. SkipPanickingLogWriter bool
  61. // DiscoveryValueHMACKey is the network-wide secret value
  62. // used to determine a unique discovery strategy.
  63. DiscoveryValueHMACKey string
  64. // GeoIPDatabaseFilenames are paths of GeoIP2/GeoLite2
  65. // MaxMind database files. When empty, no GeoIP lookups are
  66. // performed. Each file is queried, in order, for the
  67. // logged fields: country code, city, and ISP. Multiple
  68. // file support accomodates the MaxMind distribution where
  69. // ISP data in a separate file.
  70. GeoIPDatabaseFilenames []string
  71. // PsinetDatabaseFilename is the path of the Psiphon automation
  72. // jsonpickle format Psiphon API data file.
  73. PsinetDatabaseFilename string
  74. // HostID is the ID of the server host; this is used for API
  75. // event logging.
  76. HostID string
  77. // ServerIPAddress is the public IP address of the server.
  78. ServerIPAddress string
  79. // WebServerPort is the listening port of the web server.
  80. // When <= 0, no web server component is run.
  81. WebServerPort int
  82. // WebServerSecret is the unique secret value that the client
  83. // must supply to make requests to the web server.
  84. WebServerSecret string
  85. // WebServerCertificate is the certificate the client uses to
  86. // authenticate the web server.
  87. WebServerCertificate string
  88. // WebServerPrivateKey is the private key the web server uses to
  89. // authenticate itself to clients.
  90. WebServerPrivateKey string
  91. // WebServerPortForwardAddress specifies the expected network
  92. // address ("<host>:<port>") specified in a client's port forward
  93. // HostToConnect and PortToConnect when the client is making a
  94. // tunneled connection to the web server. This address is always
  95. // exempted from validation against SSH_DISALLOWED_PORT_FORWARD_HOSTS
  96. // and AllowTCPPorts.
  97. WebServerPortForwardAddress string
  98. // WebServerPortForwardRedirectAddress specifies an alternate
  99. // destination address to be substituted and dialed instead of
  100. // the original destination when the port forward destination is
  101. // WebServerPortForwardAddress.
  102. WebServerPortForwardRedirectAddress string
  103. // TunnelProtocolPorts specifies which tunnel protocols to run
  104. // and which ports to listen on for each protocol. Valid tunnel
  105. // protocols include: "SSH", "OSSH", "UNFRONTED-MEEK-OSSH",
  106. // "UNFRONTED-MEEK-HTTPS-OSSH", "FRONTED-MEEK-OSSH",
  107. // "FRONTED-MEEK-HTTP-OSSH".
  108. TunnelProtocolPorts map[string]int
  109. // SSHPrivateKey is the SSH host key. The same key is used for
  110. // all protocols, run by this server instance, which use SSH.
  111. SSHPrivateKey string
  112. // SSHServerVersion is the server version presented in the
  113. // identification string. The same value is used for all
  114. // protocols, run by this server instance, which use SSH.
  115. SSHServerVersion string
  116. // SSHUserName is the SSH user name to be presented by the
  117. // the tunnel-core client. The same value is used for all
  118. // protocols, run by this server instance, which use SSH.
  119. SSHUserName string
  120. // SSHPassword is the SSH password to be presented by the
  121. // the tunnel-core client. The same value is used for all
  122. // protocols, run by this server instance, which use SSH.
  123. SSHPassword string
  124. // ObfuscatedSSHKey is the secret key for use in the Obfuscated
  125. // SSH protocol. The same secret key is used for all protocols,
  126. // run by this server instance, which use Obfuscated SSH.
  127. ObfuscatedSSHKey string
  128. // MeekCookieEncryptionPrivateKey is the NaCl private key used
  129. // to decrypt meek cookie payload sent from clients. The same
  130. // key is used for all meek protocols run by this server instance.
  131. MeekCookieEncryptionPrivateKey string
  132. // MeekObfuscatedKey is the secret key used for obfuscating
  133. // meek cookies sent from clients. The same key is used for all
  134. // meek protocols run by this server instance.
  135. MeekObfuscatedKey string
  136. // MeekProhibitedHeaders is a list of HTTP headers to check for
  137. // in client requests. If one of these headers is found, the
  138. // request fails. This is used to defend against abuse.
  139. MeekProhibitedHeaders []string
  140. // MeekProxyForwardedForHeaders is a list of HTTP headers which
  141. // may be added by downstream HTTP proxies or CDNs in front
  142. // of clients. These headers supply the original client IP
  143. // address, which is geolocated for stats purposes. Headers
  144. // include, for example, X-Forwarded-For. The header's value
  145. // is assumed to be a comma delimted list of IP addresses where
  146. // the client IP is the first IP address in the list. Meek protocols
  147. // look for these headers and use the client IP address from
  148. // the header if any one is present and the value is a valid
  149. // IP address; otherwise the direct connection remote address is
  150. // used as the client IP.
  151. MeekProxyForwardedForHeaders []string
  152. // MeekCachedResponseBufferSize is the size of a private,
  153. // fixed-size buffer allocated for every meek client. The buffer
  154. // is used to cache response payload, allowing the client to retry
  155. // fetching when a network connection is interrupted. This retry
  156. // makes the OSSH tunnel within meek resilient to interruptions
  157. // at the HTTP TCP layer.
  158. // Larger buffers increase resiliency to interruption, but consume
  159. // more memory as buffers as never freed. The maximum size of a
  160. // response payload is a function of client activity, network
  161. // throughput and throttling.
  162. // A default of 64K is used when MeekCachedResponseBufferSize is 0.
  163. MeekCachedResponseBufferSize int
  164. // MeekCachedResponsePoolBufferSize is the size of a fixed-size,
  165. // shared buffer used to temporarily extend a private buffer when
  166. // MeekCachedResponseBufferSize is insufficient. Shared buffers
  167. // allow some clients to sucessfully retry longer response payloads
  168. // without allocating large buffers for all clients.
  169. // A default of 64K is used when MeekCachedResponsePoolBufferSize
  170. // is 0.
  171. MeekCachedResponsePoolBufferSize int
  172. // MeekCachedResponsePoolBufferCount is the number of shared
  173. // buffers. Shared buffers are allocated on first use and remain
  174. // allocated, so shared buffer count * size is roughly the memory
  175. // overhead of this facility.
  176. // A default of 2048 is used when MeekCachedResponsePoolBufferCount
  177. // is 0.
  178. MeekCachedResponsePoolBufferCount int
  179. // UDPInterceptUdpgwServerAddress specifies the network address of
  180. // a udpgw server which clients may be port forwarding to. When
  181. // specified, these TCP port forwards are intercepted and handled
  182. // directly by this server, which parses the SSH channel using the
  183. // udpgw protocol. Handling includes udpgw transparent DNS: tunneled
  184. // UDP DNS packets are rerouted to the host's DNS server.
  185. //
  186. // The intercept is applied before the port forward destination is
  187. // validated against SSH_DISALLOWED_PORT_FORWARD_HOSTS and
  188. // AllowTCPPorts. So the intercept address may be any otherwise
  189. // prohibited destination.
  190. UDPInterceptUdpgwServerAddress string
  191. // DNSResolverIPAddress specifies the IP address of a DNS server
  192. // to be used when "/etc/resolv.conf" doesn't exist or fails to
  193. // parse. When blank, "/etc/resolv.conf" must contain a usable
  194. // "nameserver" entry.
  195. DNSResolverIPAddress string
  196. // LoadMonitorPeriodSeconds indicates how frequently to log server
  197. // load information (number of connected clients per tunnel protocol,
  198. // number of running goroutines, amount of memory allocated, etc.)
  199. // The default, 0, disables load logging.
  200. LoadMonitorPeriodSeconds int
  201. // ProcessProfileOutputDirectory is the path of a directory to which
  202. // process profiles will be written when signaled with SIGUSR2. The
  203. // files are overwritten on each invocation. When set to the default
  204. // value, blank, no profiles are written on SIGUSR2. Profiles include
  205. // the default profiles here: https://golang.org/pkg/runtime/pprof/#Profile.
  206. ProcessProfileOutputDirectory string
  207. // ProcessBlockProfileDurationSeconds specifies the sample duration for
  208. // "block" profiling. For the default, 0, no "block" profile is taken.
  209. ProcessBlockProfileDurationSeconds int
  210. // ProcessCPUProfileDurationSeconds specifies the sample duration for
  211. // CPU profiling. For the default, 0, no CPU profile is taken.
  212. ProcessCPUProfileDurationSeconds int
  213. // TrafficRulesFilename is the path of a file containing a JSON-encoded
  214. // TrafficRulesSet, the traffic rules to apply to Psiphon client tunnels.
  215. TrafficRulesFilename string
  216. // OSLConfigFilename is the path of a file containing a JSON-encoded
  217. // OSL Config, the OSL schemes to apply to Psiphon client tunnels.
  218. OSLConfigFilename string
  219. // RunPacketTunnel specifies whether to run a packet tunnel.
  220. RunPacketTunnel bool
  221. // PacketTunnelEgressInterface specifies tun.ServerConfig.EgressInterface.
  222. PacketTunnelEgressInterface string
  223. // PacketTunnelDownStreamPacketQueueSize specifies
  224. // tun.ServerConfig.DownStreamPacketQueueSize.
  225. PacketTunnelDownStreamPacketQueueSize int
  226. // PacketTunnelSessionIdleExpirySeconds specifies
  227. // tun.ServerConfig.SessionIdleExpirySeconds.
  228. PacketTunnelSessionIdleExpirySeconds int
  229. // PacketTunnelSudoNetworkConfigCommands sets
  230. // tun.ServerConfig.SudoNetworkConfigCommands.
  231. PacketTunnelSudoNetworkConfigCommands bool
  232. }
  233. // RunWebServer indicates whether to run a web server component.
  234. func (config *Config) RunWebServer() bool {
  235. return config.WebServerPort > 0
  236. }
  237. // RunLoadMonitor indicates whether to monitor and log server load.
  238. func (config *Config) RunLoadMonitor() bool {
  239. return config.LoadMonitorPeriodSeconds > 0
  240. }
  241. // LoadConfig loads and validates a JSON encoded server config.
  242. func LoadConfig(configJSON []byte) (*Config, error) {
  243. var config Config
  244. err := json.Unmarshal(configJSON, &config)
  245. if err != nil {
  246. return nil, common.ContextError(err)
  247. }
  248. if config.ServerIPAddress == "" {
  249. return nil, errors.New("ServerIPAddress is required")
  250. }
  251. if config.WebServerPort > 0 && (config.WebServerSecret == "" || config.WebServerCertificate == "" ||
  252. config.WebServerPrivateKey == "") {
  253. return nil, errors.New(
  254. "Web server requires WebServerSecret, WebServerCertificate, WebServerPrivateKey")
  255. }
  256. if config.WebServerPortForwardAddress != "" {
  257. if err := validateNetworkAddress(config.WebServerPortForwardAddress, false); err != nil {
  258. return nil, errors.New("WebServerPortForwardAddress is invalid")
  259. }
  260. }
  261. if config.WebServerPortForwardRedirectAddress != "" {
  262. if config.WebServerPortForwardAddress == "" {
  263. return nil, errors.New(
  264. "WebServerPortForwardRedirectAddress requires WebServerPortForwardAddress")
  265. }
  266. if err := validateNetworkAddress(config.WebServerPortForwardRedirectAddress, false); err != nil {
  267. return nil, errors.New("WebServerPortForwardRedirectAddress is invalid")
  268. }
  269. }
  270. for tunnelProtocol, _ := range config.TunnelProtocolPorts {
  271. if !common.Contains(protocol.SupportedTunnelProtocols, tunnelProtocol) {
  272. return nil, fmt.Errorf("Unsupported tunnel protocol: %s", tunnelProtocol)
  273. }
  274. if protocol.TunnelProtocolUsesSSH(tunnelProtocol) ||
  275. protocol.TunnelProtocolUsesObfuscatedSSH(tunnelProtocol) {
  276. if config.SSHPrivateKey == "" || config.SSHServerVersion == "" ||
  277. config.SSHUserName == "" || config.SSHPassword == "" {
  278. return nil, fmt.Errorf(
  279. "Tunnel protocol %s requires SSHPrivateKey, SSHServerVersion, SSHUserName, SSHPassword",
  280. tunnelProtocol)
  281. }
  282. }
  283. if protocol.TunnelProtocolUsesObfuscatedSSH(tunnelProtocol) {
  284. if config.ObfuscatedSSHKey == "" {
  285. return nil, fmt.Errorf(
  286. "Tunnel protocol %s requires ObfuscatedSSHKey",
  287. tunnelProtocol)
  288. }
  289. }
  290. if protocol.TunnelProtocolUsesMeekHTTP(tunnelProtocol) ||
  291. protocol.TunnelProtocolUsesMeekHTTPS(tunnelProtocol) {
  292. if config.MeekCookieEncryptionPrivateKey == "" || config.MeekObfuscatedKey == "" {
  293. return nil, fmt.Errorf(
  294. "Tunnel protocol %s requires MeekCookieEncryptionPrivateKey, MeekObfuscatedKey",
  295. tunnelProtocol)
  296. }
  297. }
  298. }
  299. if config.UDPInterceptUdpgwServerAddress != "" {
  300. if err := validateNetworkAddress(config.UDPInterceptUdpgwServerAddress, true); err != nil {
  301. return nil, fmt.Errorf("UDPInterceptUdpgwServerAddress is invalid: %s", err)
  302. }
  303. }
  304. if config.DNSResolverIPAddress != "" {
  305. if net.ParseIP(config.DNSResolverIPAddress) == nil {
  306. return nil, fmt.Errorf("DNSResolverIPAddress is invalid")
  307. }
  308. }
  309. return &config, nil
  310. }
  311. func validateNetworkAddress(address string, requireIPaddress bool) error {
  312. host, portStr, err := net.SplitHostPort(address)
  313. if err != nil {
  314. return err
  315. }
  316. if requireIPaddress && net.ParseIP(host) == nil {
  317. return errors.New("host must be an IP address")
  318. }
  319. port, err := strconv.Atoi(portStr)
  320. if err != nil {
  321. return err
  322. }
  323. if port < 0 || port > 65535 {
  324. return errors.New("invalid port")
  325. }
  326. return nil
  327. }
  328. // GenerateConfigParams specifies customizations to be applied to
  329. // a generated server config.
  330. type GenerateConfigParams struct {
  331. LogFilename string
  332. SkipPanickingLogWriter bool
  333. LogLevel string
  334. ServerIPAddress string
  335. WebServerPort int
  336. EnableSSHAPIRequests bool
  337. TunnelProtocolPorts map[string]int
  338. TrafficRulesFilename string
  339. }
  340. // GenerateConfig creates a new Psiphon server config. It returns JSON
  341. // encoded configs and a client-compatible "server entry" for the server. It
  342. // generates all necessary secrets and key material, which are emitted in
  343. // the config file and server entry as necessary.
  344. // GenerateConfig uses sample values for many fields. The intention is for
  345. // generated configs to be used for testing or as a template for production
  346. // setup, not to generate production-ready configurations.
  347. func GenerateConfig(params *GenerateConfigParams) ([]byte, []byte, []byte, error) {
  348. // Input validation
  349. if net.ParseIP(params.ServerIPAddress) == nil {
  350. return nil, nil, nil, common.ContextError(errors.New("invalid IP address"))
  351. }
  352. if len(params.TunnelProtocolPorts) == 0 {
  353. return nil, nil, nil, common.ContextError(errors.New("no tunnel protocols"))
  354. }
  355. usedPort := make(map[int]bool)
  356. if params.WebServerPort != 0 {
  357. usedPort[params.WebServerPort] = true
  358. }
  359. usingMeek := false
  360. for tunnelProtocol, port := range params.TunnelProtocolPorts {
  361. if !common.Contains(protocol.SupportedTunnelProtocols, tunnelProtocol) {
  362. return nil, nil, nil, common.ContextError(errors.New("invalid tunnel protocol"))
  363. }
  364. if usedPort[port] {
  365. return nil, nil, nil, common.ContextError(errors.New("duplicate listening port"))
  366. }
  367. usedPort[port] = true
  368. if protocol.TunnelProtocolUsesMeekHTTP(tunnelProtocol) ||
  369. protocol.TunnelProtocolUsesMeekHTTPS(tunnelProtocol) {
  370. usingMeek = true
  371. }
  372. }
  373. // Web server config
  374. var webServerSecret, webServerCertificate,
  375. webServerPrivateKey, webServerPortForwardAddress string
  376. if params.WebServerPort != 0 {
  377. var err error
  378. webServerSecret, err = common.MakeRandomStringHex(WEB_SERVER_SECRET_BYTE_LENGTH)
  379. if err != nil {
  380. return nil, nil, nil, common.ContextError(err)
  381. }
  382. webServerCertificate, webServerPrivateKey, err = GenerateWebServerCertificate("")
  383. if err != nil {
  384. return nil, nil, nil, common.ContextError(err)
  385. }
  386. webServerPortForwardAddress = net.JoinHostPort(
  387. params.ServerIPAddress, strconv.Itoa(params.WebServerPort))
  388. }
  389. // SSH config
  390. rsaKey, err := rsa.GenerateKey(rand.Reader, SSH_RSA_HOST_KEY_BITS)
  391. if err != nil {
  392. return nil, nil, nil, common.ContextError(err)
  393. }
  394. sshPrivateKey := pem.EncodeToMemory(
  395. &pem.Block{
  396. Type: "RSA PRIVATE KEY",
  397. Bytes: x509.MarshalPKCS1PrivateKey(rsaKey),
  398. },
  399. )
  400. signer, err := ssh.NewSignerFromKey(rsaKey)
  401. if err != nil {
  402. return nil, nil, nil, common.ContextError(err)
  403. }
  404. sshPublicKey := signer.PublicKey()
  405. sshUserNameSuffix, err := common.MakeRandomStringHex(SSH_USERNAME_SUFFIX_BYTE_LENGTH)
  406. if err != nil {
  407. return nil, nil, nil, common.ContextError(err)
  408. }
  409. sshUserName := "psiphon_" + sshUserNameSuffix
  410. sshPassword, err := common.MakeRandomStringHex(SSH_PASSWORD_BYTE_LENGTH)
  411. if err != nil {
  412. return nil, nil, nil, common.ContextError(err)
  413. }
  414. sshServerVersion := "SSH-2.0-Psiphon"
  415. // Obfuscated SSH config
  416. obfuscatedSSHKey, err := common.MakeRandomStringHex(SSH_OBFUSCATED_KEY_BYTE_LENGTH)
  417. if err != nil {
  418. return nil, nil, nil, common.ContextError(err)
  419. }
  420. // Meek config
  421. var meekCookieEncryptionPublicKey, meekCookieEncryptionPrivateKey, meekObfuscatedKey string
  422. if usingMeek {
  423. rawMeekCookieEncryptionPublicKey, rawMeekCookieEncryptionPrivateKey, err :=
  424. box.GenerateKey(rand.Reader)
  425. if err != nil {
  426. return nil, nil, nil, common.ContextError(err)
  427. }
  428. meekCookieEncryptionPublicKey = base64.StdEncoding.EncodeToString(rawMeekCookieEncryptionPublicKey[:])
  429. meekCookieEncryptionPrivateKey = base64.StdEncoding.EncodeToString(rawMeekCookieEncryptionPrivateKey[:])
  430. meekObfuscatedKey, err = common.MakeRandomStringHex(SSH_OBFUSCATED_KEY_BYTE_LENGTH)
  431. if err != nil {
  432. return nil, nil, nil, common.ContextError(err)
  433. }
  434. }
  435. // Other config
  436. discoveryValueHMACKey, err := common.MakeRandomStringBase64(DISCOVERY_VALUE_KEY_BYTE_LENGTH)
  437. if err != nil {
  438. return nil, nil, nil, common.ContextError(err)
  439. }
  440. // Assemble configs and server entry
  441. // Note: this config is intended for either testing or as an illustrative
  442. // example or template and is not intended for production deployment.
  443. logLevel := params.LogLevel
  444. if logLevel == "" {
  445. logLevel = "info"
  446. }
  447. config := &Config{
  448. LogLevel: logLevel,
  449. LogFilename: params.LogFilename,
  450. SkipPanickingLogWriter: params.SkipPanickingLogWriter,
  451. GeoIPDatabaseFilenames: nil,
  452. HostID: "example-host-id",
  453. ServerIPAddress: params.ServerIPAddress,
  454. DiscoveryValueHMACKey: discoveryValueHMACKey,
  455. WebServerPort: params.WebServerPort,
  456. WebServerSecret: webServerSecret,
  457. WebServerCertificate: webServerCertificate,
  458. WebServerPrivateKey: webServerPrivateKey,
  459. WebServerPortForwardAddress: webServerPortForwardAddress,
  460. SSHPrivateKey: string(sshPrivateKey),
  461. SSHServerVersion: sshServerVersion,
  462. SSHUserName: sshUserName,
  463. SSHPassword: sshPassword,
  464. ObfuscatedSSHKey: obfuscatedSSHKey,
  465. TunnelProtocolPorts: params.TunnelProtocolPorts,
  466. DNSResolverIPAddress: "8.8.8.8",
  467. UDPInterceptUdpgwServerAddress: "127.0.0.1:7300",
  468. MeekCookieEncryptionPrivateKey: meekCookieEncryptionPrivateKey,
  469. MeekObfuscatedKey: meekObfuscatedKey,
  470. MeekProhibitedHeaders: nil,
  471. MeekProxyForwardedForHeaders: []string{"X-Forwarded-For"},
  472. LoadMonitorPeriodSeconds: 300,
  473. TrafficRulesFilename: params.TrafficRulesFilename,
  474. }
  475. encodedConfig, err := json.MarshalIndent(config, "\n", " ")
  476. if err != nil {
  477. return nil, nil, nil, common.ContextError(err)
  478. }
  479. intPtr := func(i int) *int {
  480. return &i
  481. }
  482. trafficRulesSet := &TrafficRulesSet{
  483. DefaultRules: TrafficRules{
  484. RateLimits: RateLimits{
  485. ReadUnthrottledBytes: new(int64),
  486. ReadBytesPerSecond: new(int64),
  487. WriteUnthrottledBytes: new(int64),
  488. WriteBytesPerSecond: new(int64),
  489. },
  490. IdleTCPPortForwardTimeoutMilliseconds: intPtr(DEFAULT_IDLE_TCP_PORT_FORWARD_TIMEOUT_MILLISECONDS),
  491. IdleUDPPortForwardTimeoutMilliseconds: intPtr(DEFAULT_IDLE_UDP_PORT_FORWARD_TIMEOUT_MILLISECONDS),
  492. MaxTCPPortForwardCount: intPtr(DEFAULT_MAX_TCP_PORT_FORWARD_COUNT),
  493. MaxUDPPortForwardCount: intPtr(DEFAULT_MAX_UDP_PORT_FORWARD_COUNT),
  494. AllowTCPPorts: nil,
  495. AllowUDPPorts: nil,
  496. },
  497. }
  498. encodedTrafficRulesSet, err := json.MarshalIndent(trafficRulesSet, "\n", " ")
  499. if err != nil {
  500. return nil, nil, nil, common.ContextError(err)
  501. }
  502. capabilities := []string{}
  503. if params.EnableSSHAPIRequests {
  504. capabilities = append(capabilities, protocol.CAPABILITY_SSH_API_REQUESTS)
  505. }
  506. if params.WebServerPort != 0 {
  507. capabilities = append(capabilities, protocol.CAPABILITY_UNTUNNELED_WEB_API_REQUESTS)
  508. }
  509. for tunnelProtocol, _ := range params.TunnelProtocolPorts {
  510. capabilities = append(capabilities, protocol.GetCapability(tunnelProtocol))
  511. }
  512. sshPort := params.TunnelProtocolPorts["SSH"]
  513. obfuscatedSSHPort := params.TunnelProtocolPorts["OSSH"]
  514. // Meek port limitations
  515. // - fronted meek protocols are hard-wired in the client to be port 443 or 80.
  516. // - only one other meek port may be specified.
  517. meekPort := params.TunnelProtocolPorts["UNFRONTED-MEEK-OSSH"]
  518. if meekPort == 0 {
  519. meekPort = params.TunnelProtocolPorts["UNFRONTED-MEEK-HTTPS-OSSH"]
  520. }
  521. if meekPort == 0 {
  522. meekPort = params.TunnelProtocolPorts["UNFRONTED-MEEK-SESSION-TICKET-OSSH"]
  523. }
  524. // Note: fronting params are a stub; this server entry will exercise
  525. // client and server fronting code paths, but not actually traverse
  526. // a fronting hop.
  527. serverEntryWebServerPort := ""
  528. strippedWebServerCertificate := ""
  529. if params.WebServerPort != 0 {
  530. serverEntryWebServerPort = fmt.Sprintf("%d", params.WebServerPort)
  531. // Server entry format omits the BEGIN/END lines and newlines
  532. lines := strings.Split(webServerCertificate, "\n")
  533. strippedWebServerCertificate = strings.Join(lines[1:len(lines)-2], "")
  534. }
  535. serverEntry := &protocol.ServerEntry{
  536. IpAddress: params.ServerIPAddress,
  537. WebServerPort: serverEntryWebServerPort,
  538. WebServerSecret: webServerSecret,
  539. WebServerCertificate: strippedWebServerCertificate,
  540. SshPort: sshPort,
  541. SshUsername: sshUserName,
  542. SshPassword: sshPassword,
  543. SshHostKey: base64.RawStdEncoding.EncodeToString(sshPublicKey.Marshal()),
  544. SshObfuscatedPort: obfuscatedSSHPort,
  545. SshObfuscatedKey: obfuscatedSSHKey,
  546. Capabilities: capabilities,
  547. Region: "US",
  548. MeekServerPort: meekPort,
  549. MeekCookieEncryptionPublicKey: meekCookieEncryptionPublicKey,
  550. MeekObfuscatedKey: meekObfuscatedKey,
  551. MeekFrontingHosts: []string{params.ServerIPAddress},
  552. MeekFrontingAddresses: []string{params.ServerIPAddress},
  553. MeekFrontingDisableSNI: false,
  554. }
  555. encodedServerEntry, err := protocol.EncodeServerEntry(serverEntry)
  556. if err != nil {
  557. return nil, nil, nil, common.ContextError(err)
  558. }
  559. return encodedConfig, encodedTrafficRulesSet, []byte(encodedServerEntry), nil
  560. }