serverApi.go 36 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159
  1. /*
  2. * Copyright (c) 2015, 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 psiphon
  20. import (
  21. "bytes"
  22. "context"
  23. "encoding/base64"
  24. "encoding/hex"
  25. "encoding/json"
  26. "fmt"
  27. "io"
  28. "io/ioutil"
  29. "net"
  30. "net/http"
  31. "net/url"
  32. "strconv"
  33. "strings"
  34. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common"
  35. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/buildinfo"
  36. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/errors"
  37. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/fragmentor"
  38. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/parameters"
  39. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/prng"
  40. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/protocol"
  41. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/tactics"
  42. "github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/transferstats"
  43. )
  44. // ServerContext is a utility struct which holds all of the data associated
  45. // with a Psiphon server connection. In addition to the established tunnel, this
  46. // includes data and transport mechanisms for Psiphon API requests. Legacy servers
  47. // offer the Psiphon API through a web service; newer servers offer the Psiphon
  48. // API through SSH requests made directly through the tunnel's SSH client.
  49. type ServerContext struct {
  50. tunnel *Tunnel
  51. psiphonHttpsClient *http.Client
  52. statsRegexps *transferstats.Regexps
  53. clientRegion string
  54. clientUpgradeVersion string
  55. serverHandshakeTimestamp string
  56. paddingPRNG *prng.PRNG
  57. }
  58. // MakeSessionId creates a new session ID. The same session ID is used across
  59. // multi-tunnel controller runs, where each tunnel has its own ServerContext
  60. // instance.
  61. // In server-side stats, we now consider a "session" to be the lifetime of the
  62. // Controller (e.g., the user's commanded start and stop) and we measure this
  63. // duration as well as the duration of each tunnel within the session.
  64. func MakeSessionId() (string, error) {
  65. randomId, err := common.MakeSecureRandomBytes(protocol.PSIPHON_API_CLIENT_SESSION_ID_LENGTH)
  66. if err != nil {
  67. return "", errors.Trace(err)
  68. }
  69. return hex.EncodeToString(randomId), nil
  70. }
  71. // NewServerContext makes the tunneled handshake request to the Psiphon server
  72. // and returns a ServerContext struct for use with subsequent Psiphon server API
  73. // requests (e.g., periodic connected and status requests).
  74. func NewServerContext(tunnel *Tunnel) (*ServerContext, error) {
  75. // For legacy servers, set up psiphonHttpsClient for
  76. // accessing the Psiphon API via the web service.
  77. var psiphonHttpsClient *http.Client
  78. if !tunnel.dialParams.ServerEntry.SupportsSSHAPIRequests() ||
  79. tunnel.config.TargetApiProtocol == protocol.PSIPHON_WEB_API_PROTOCOL {
  80. var err error
  81. psiphonHttpsClient, err = makePsiphonHttpsClient(tunnel)
  82. if err != nil {
  83. return nil, errors.Trace(err)
  84. }
  85. }
  86. serverContext := &ServerContext{
  87. tunnel: tunnel,
  88. psiphonHttpsClient: psiphonHttpsClient,
  89. paddingPRNG: prng.NewPRNGWithSeed(tunnel.dialParams.APIRequestPaddingSeed),
  90. }
  91. ignoreRegexps := tunnel.config.GetClientParameters().Get().Bool(
  92. parameters.IgnoreHandshakeStatsRegexps)
  93. err := serverContext.doHandshakeRequest(ignoreRegexps)
  94. if err != nil {
  95. return nil, errors.Trace(err)
  96. }
  97. return serverContext, nil
  98. }
  99. // doHandshakeRequest performs the "handshake" API request. The handshake
  100. // returns upgrade info, newly discovered server entries -- which are
  101. // stored -- and sponsor info (home pages, stat regexes).
  102. func (serverContext *ServerContext) doHandshakeRequest(
  103. ignoreStatsRegexps bool) error {
  104. params := serverContext.getBaseAPIParameters(baseParametersAll)
  105. // The server will return a signed copy of its own server entry when the
  106. // client specifies this 'missing_server_entry_signature' parameter.
  107. //
  108. // The purpose of this mechanism is to rapidly upgrade client local storage
  109. // from unsigned to signed server entries, and to ensure that the client has
  110. // a signed server entry for its currently connected server as required for
  111. // the client-to-client exchange feature.
  112. //
  113. // The server entry will be included in handshakeResponse.EncodedServerList,
  114. // along side discovery servers.
  115. requestedMissingSignature := false
  116. if !serverContext.tunnel.dialParams.ServerEntry.HasSignature() {
  117. requestedMissingSignature = true
  118. params["missing_server_entry_signature"] =
  119. serverContext.tunnel.dialParams.ServerEntry.Tag
  120. }
  121. doTactics := !serverContext.tunnel.config.DisableTactics
  122. networkID := ""
  123. if doTactics {
  124. // Limitation: it is assumed that the network ID obtained here is the
  125. // one that is active when the handshake request is received by the
  126. // server. However, it is remotely possible to switch networks
  127. // immediately after invoking the GetNetworkID callback and initiating
  128. // the handshake, if the tunnel protocol is meek.
  129. //
  130. // The response handling code below calls GetNetworkID again and ignores
  131. // any tactics payload if the network ID is not the same. While this
  132. // doesn't detect all cases of changing networks, it reduces the already
  133. // narrow window.
  134. networkID = serverContext.tunnel.config.GetNetworkID()
  135. err := tactics.SetTacticsAPIParameters(
  136. serverContext.tunnel.config.clientParameters,
  137. GetTacticsStorer(serverContext.tunnel.config),
  138. networkID,
  139. params)
  140. if err != nil {
  141. return errors.Trace(err)
  142. }
  143. }
  144. var response []byte
  145. if serverContext.psiphonHttpsClient == nil {
  146. params[protocol.PSIPHON_API_HANDSHAKE_AUTHORIZATIONS] =
  147. serverContext.tunnel.config.GetAuthorizations()
  148. request, err := serverContext.makeSSHAPIRequestPayload(params)
  149. if err != nil {
  150. return errors.Trace(err)
  151. }
  152. response, err = serverContext.tunnel.SendAPIRequest(
  153. protocol.PSIPHON_API_HANDSHAKE_REQUEST_NAME, request)
  154. if err != nil {
  155. return errors.Trace(err)
  156. }
  157. } else {
  158. // Legacy web service API request
  159. responseBody, err := serverContext.doGetRequest(
  160. makeRequestUrl(serverContext.tunnel, "", "handshake", params))
  161. if err != nil {
  162. return errors.Trace(err)
  163. }
  164. // Skip legacy format lines and just parse the JSON config line
  165. configLinePrefix := []byte("Config: ")
  166. for _, line := range bytes.Split(responseBody, []byte("\n")) {
  167. if bytes.HasPrefix(line, configLinePrefix) {
  168. response = line[len(configLinePrefix):]
  169. break
  170. }
  171. }
  172. if len(response) == 0 {
  173. return errors.TraceNew("no config line found")
  174. }
  175. }
  176. // Legacy fields:
  177. // - 'preemptive_reconnect_lifetime_milliseconds' is unused and ignored
  178. // - 'ssh_session_id' is ignored; client session ID is used instead
  179. var handshakeResponse protocol.HandshakeResponse
  180. // Initialize these fields to distinguish between psiphond omitting values in
  181. // the response and the zero value, which means unlimited rate.
  182. handshakeResponse.UpstreamBytesPerSecond = -1
  183. handshakeResponse.DownstreamBytesPerSecond = -1
  184. err := json.Unmarshal(response, &handshakeResponse)
  185. if err != nil {
  186. return errors.Trace(err)
  187. }
  188. serverContext.clientRegion = handshakeResponse.ClientRegion
  189. NoticeClientRegion(serverContext.clientRegion)
  190. var serverEntries []protocol.ServerEntryFields
  191. // Store discovered server entries
  192. // We use the server's time, as it's available here, for the server entry
  193. // timestamp since this is more reliable than the client time.
  194. for _, encodedServerEntry := range handshakeResponse.EncodedServerList {
  195. serverEntryFields, err := protocol.DecodeServerEntryFields(
  196. encodedServerEntry,
  197. common.TruncateTimestampToHour(handshakeResponse.ServerTimestamp),
  198. protocol.SERVER_ENTRY_SOURCE_DISCOVERY)
  199. if err != nil {
  200. return errors.Trace(err)
  201. }
  202. // Retain the original timestamp and source in the requestedMissingSignature
  203. // case, as this server entry was not discovered here.
  204. //
  205. // Limitation: there is a transient edge case where
  206. // requestedMissingSignature will be set for a discovery server entry that
  207. // _is_ also discovered here.
  208. if requestedMissingSignature &&
  209. serverEntryFields.GetIPAddress() == serverContext.tunnel.dialParams.ServerEntry.IpAddress {
  210. serverEntryFields.SetLocalTimestamp(serverContext.tunnel.dialParams.ServerEntry.LocalTimestamp)
  211. serverEntryFields.SetLocalSource(serverContext.tunnel.dialParams.ServerEntry.LocalSource)
  212. }
  213. err = protocol.ValidateServerEntryFields(serverEntryFields)
  214. if err != nil {
  215. // Skip this entry and continue with the next one
  216. NoticeWarning("invalid handshake server entry: %s", err)
  217. continue
  218. }
  219. serverEntries = append(serverEntries, serverEntryFields)
  220. }
  221. err = StoreServerEntries(
  222. serverContext.tunnel.config,
  223. serverEntries,
  224. true)
  225. if err != nil {
  226. return errors.Trace(err)
  227. }
  228. NoticeHomepages(handshakeResponse.Homepages)
  229. serverContext.clientUpgradeVersion = handshakeResponse.UpgradeClientVersion
  230. if handshakeResponse.UpgradeClientVersion != "" {
  231. NoticeClientUpgradeAvailable(handshakeResponse.UpgradeClientVersion)
  232. } else {
  233. NoticeClientIsLatestVersion("")
  234. }
  235. if !ignoreStatsRegexps {
  236. var regexpsNotices []string
  237. serverContext.statsRegexps, regexpsNotices = transferstats.MakeRegexps(
  238. handshakeResponse.PageViewRegexes,
  239. handshakeResponse.HttpsRequestRegexes)
  240. for _, notice := range regexpsNotices {
  241. NoticeWarning(notice)
  242. }
  243. }
  244. serverContext.serverHandshakeTimestamp = handshakeResponse.ServerTimestamp
  245. NoticeServerTimestamp(serverContext.serverHandshakeTimestamp)
  246. NoticeActiveAuthorizationIDs(handshakeResponse.ActiveAuthorizationIDs)
  247. NoticeTrafficRateLimits(
  248. handshakeResponse.UpstreamBytesPerSecond, handshakeResponse.DownstreamBytesPerSecond)
  249. if doTactics && handshakeResponse.TacticsPayload != nil &&
  250. networkID == serverContext.tunnel.config.GetNetworkID() {
  251. var payload *tactics.Payload
  252. err := json.Unmarshal(handshakeResponse.TacticsPayload, &payload)
  253. if err != nil {
  254. return errors.Trace(err)
  255. }
  256. // handshakeResponse.TacticsPayload may be "null", and payload
  257. // will successfully unmarshal as nil. As a result, the previous
  258. // handshakeResponse.TacticsPayload != nil test is insufficient.
  259. if payload != nil {
  260. tacticsRecord, err := tactics.HandleTacticsPayload(
  261. GetTacticsStorer(serverContext.tunnel.config),
  262. networkID,
  263. payload)
  264. if err != nil {
  265. return errors.Trace(err)
  266. }
  267. if tacticsRecord != nil &&
  268. prng.FlipWeightedCoin(tacticsRecord.Tactics.Probability) {
  269. err := serverContext.tunnel.config.SetClientParameters(
  270. tacticsRecord.Tag, true, tacticsRecord.Tactics.Parameters)
  271. if err != nil {
  272. NoticeInfo("apply handshake tactics failed: %s", err)
  273. }
  274. // The error will be due to invalid tactics values from
  275. // the server. When ApplyClientParameters fails, all
  276. // previous tactics values are left in place.
  277. }
  278. }
  279. }
  280. return nil
  281. }
  282. // DoConnectedRequest performs the "connected" API request. This request is
  283. // used for statistics, including unique user counting; reporting the full
  284. // tunnel establishment duration including the handshake request; and updated
  285. // fragmentor metrics.
  286. //
  287. // Users are not assigned identifiers. Instead, daily unique users are
  288. // calculated by having clients submit their last connected timestamp
  289. // (truncated to an hour, as a privacy measure). As client clocks are
  290. // unreliable, the server returns new last_connected values for the client to
  291. // store and send next time it connects.
  292. func (serverContext *ServerContext) DoConnectedRequest() error {
  293. // Limitation: as currently implemented, the last_connected exchange isn't a
  294. // distributed, atomic operation. When clients send the connected request,
  295. // the server may receive the request, count a unique user based on the
  296. // client's last_connected, and then the tunnel fails before the client
  297. // receives the response, so the client will not update its last_connected
  298. // value and submit the same one again, resulting in an inflated unique user
  299. // count.
  300. //
  301. // The SetInFlightConnectedRequest mechanism mitigates one class of connected
  302. // request interruption, a commanded shutdown in the middle of a connected
  303. // request, by allowing some time for the request to complete before
  304. // terminating the tunnel.
  305. //
  306. // TODO: consider extending the connected request protocol with additional
  307. // "acknowledgment" messages so that the server does not commit its unique
  308. // user count until after the client has acknowledged receipt and durable
  309. // storage of the new last_connected value.
  310. requestDone := make(chan struct{})
  311. defer close(requestDone)
  312. if !serverContext.tunnel.SetInFlightConnectedRequest(requestDone) {
  313. return errors.TraceNew("tunnel is closing")
  314. }
  315. defer serverContext.tunnel.SetInFlightConnectedRequest(nil)
  316. params := serverContext.getBaseAPIParameters(
  317. baseParametersOnlyUpstreamFragmentorDialParameters)
  318. lastConnected, err := getLastConnected()
  319. if err != nil {
  320. return errors.Trace(err)
  321. }
  322. params["last_connected"] = lastConnected
  323. // serverContext.tunnel.establishDuration is nanoseconds; divide to get to milliseconds
  324. params["establishment_duration"] =
  325. fmt.Sprintf("%d", serverContext.tunnel.establishDuration/1000000)
  326. var response []byte
  327. if serverContext.psiphonHttpsClient == nil {
  328. request, err := serverContext.makeSSHAPIRequestPayload(params)
  329. if err != nil {
  330. return errors.Trace(err)
  331. }
  332. response, err = serverContext.tunnel.SendAPIRequest(
  333. protocol.PSIPHON_API_CONNECTED_REQUEST_NAME, request)
  334. if err != nil {
  335. return errors.Trace(err)
  336. }
  337. } else {
  338. // Legacy web service API request
  339. response, err = serverContext.doGetRequest(
  340. makeRequestUrl(serverContext.tunnel, "", "connected", params))
  341. if err != nil {
  342. return errors.Trace(err)
  343. }
  344. }
  345. var connectedResponse protocol.ConnectedResponse
  346. err = json.Unmarshal(response, &connectedResponse)
  347. if err != nil {
  348. return errors.Trace(err)
  349. }
  350. err = SetKeyValue(
  351. datastoreLastConnectedKey, connectedResponse.ConnectedTimestamp)
  352. if err != nil {
  353. return errors.Trace(err)
  354. }
  355. return nil
  356. }
  357. func getLastConnected() (string, error) {
  358. lastConnected, err := GetKeyValue(datastoreLastConnectedKey)
  359. if err != nil {
  360. return "", errors.Trace(err)
  361. }
  362. if lastConnected == "" {
  363. lastConnected = "None"
  364. }
  365. return lastConnected, nil
  366. }
  367. // StatsRegexps gets the Regexps used for the statistics for this tunnel.
  368. func (serverContext *ServerContext) StatsRegexps() *transferstats.Regexps {
  369. return serverContext.statsRegexps
  370. }
  371. // DoStatusRequest makes a "status" API request to the server, sending session stats.
  372. func (serverContext *ServerContext) DoStatusRequest(tunnel *Tunnel) error {
  373. params := serverContext.getBaseAPIParameters(baseParametersNoDialParameters)
  374. // Note: ensure putBackStatusRequestPayload is called, to replace
  375. // payload for future attempt, in all failure cases.
  376. statusPayload, statusPayloadInfo, err := makeStatusRequestPayload(
  377. serverContext.tunnel.config,
  378. tunnel.dialParams.ServerEntry.IpAddress)
  379. if err != nil {
  380. return errors.Trace(err)
  381. }
  382. // Skip the request when there's no payload to send.
  383. if len(statusPayload) == 0 {
  384. return nil
  385. }
  386. var response []byte
  387. if serverContext.psiphonHttpsClient == nil {
  388. rawMessage := json.RawMessage(statusPayload)
  389. params["statusData"] = &rawMessage
  390. var request []byte
  391. request, err = serverContext.makeSSHAPIRequestPayload(params)
  392. if err == nil {
  393. response, err = serverContext.tunnel.SendAPIRequest(
  394. protocol.PSIPHON_API_STATUS_REQUEST_NAME, request)
  395. }
  396. } else {
  397. // Legacy web service API request
  398. response, err = serverContext.doPostRequest(
  399. makeRequestUrl(serverContext.tunnel, "", "status", params),
  400. "application/json",
  401. bytes.NewReader(statusPayload))
  402. }
  403. if err != nil {
  404. // Resend the transfer stats and tunnel stats later
  405. // Note: potential duplicate reports if the server received and processed
  406. // the request but the client failed to receive the response.
  407. putBackStatusRequestPayload(statusPayloadInfo)
  408. return errors.Trace(err)
  409. }
  410. confirmStatusRequestPayload(statusPayloadInfo)
  411. var statusResponse protocol.StatusResponse
  412. err = json.Unmarshal(response, &statusResponse)
  413. if err != nil {
  414. return errors.Trace(err)
  415. }
  416. for _, serverEntryTag := range statusResponse.InvalidServerEntryTags {
  417. PruneServerEntry(serverContext.tunnel.config, serverEntryTag)
  418. }
  419. return nil
  420. }
  421. // statusRequestPayloadInfo is a temporary structure for data used to
  422. // either "clear" or "put back" status request payload data depending
  423. // on whether or not the request succeeded.
  424. type statusRequestPayloadInfo struct {
  425. serverId string
  426. transferStats *transferstats.AccumulatedStats
  427. persistentStats map[string][][]byte
  428. }
  429. func makeStatusRequestPayload(
  430. config *Config,
  431. serverId string) ([]byte, *statusRequestPayloadInfo, error) {
  432. transferStats := transferstats.TakeOutStatsForServer(serverId)
  433. hostBytes := transferStats.GetStatsForStatusRequest()
  434. persistentStats, err := TakeOutUnreportedPersistentStats(config)
  435. if err != nil {
  436. NoticeWarning(
  437. "TakeOutUnreportedPersistentStats failed: %s", errors.Trace(err))
  438. persistentStats = nil
  439. // Proceed with transferStats only
  440. }
  441. if len(hostBytes) == 0 && len(persistentStats) == 0 {
  442. // There is no payload to send.
  443. return nil, nil, nil
  444. }
  445. payloadInfo := &statusRequestPayloadInfo{
  446. serverId, transferStats, persistentStats}
  447. payload := make(map[string]interface{})
  448. payload["host_bytes"] = hostBytes
  449. // We're not recording these fields, but legacy servers require them.
  450. payload["bytes_transferred"] = 0
  451. payload["page_views"] = make([]string, 0)
  452. payload["https_requests"] = make([]string, 0)
  453. persistentStatPayloadNames := make(map[string]string)
  454. persistentStatPayloadNames[datastorePersistentStatTypeRemoteServerList] = "remote_server_list_stats"
  455. persistentStatPayloadNames[datastorePersistentStatTypeFailedTunnel] = "failed_tunnel_stats"
  456. for statType, stats := range persistentStats {
  457. // Persistent stats records are already in JSON format
  458. jsonStats := make([]json.RawMessage, len(stats))
  459. for i, stat := range stats {
  460. jsonStats[i] = json.RawMessage(stat)
  461. }
  462. payload[persistentStatPayloadNames[statType]] = jsonStats
  463. }
  464. jsonPayload, err := json.Marshal(payload)
  465. if err != nil {
  466. // Send the transfer stats and tunnel stats later
  467. putBackStatusRequestPayload(payloadInfo)
  468. return nil, nil, errors.Trace(err)
  469. }
  470. return jsonPayload, payloadInfo, nil
  471. }
  472. func putBackStatusRequestPayload(payloadInfo *statusRequestPayloadInfo) {
  473. transferstats.PutBackStatsForServer(
  474. payloadInfo.serverId, payloadInfo.transferStats)
  475. err := PutBackUnreportedPersistentStats(payloadInfo.persistentStats)
  476. if err != nil {
  477. // These persistent stats records won't be resent until after a
  478. // datastore re-initialization.
  479. NoticeWarning(
  480. "PutBackUnreportedPersistentStats failed: %s", errors.Trace(err))
  481. }
  482. }
  483. func confirmStatusRequestPayload(payloadInfo *statusRequestPayloadInfo) {
  484. err := ClearReportedPersistentStats(payloadInfo.persistentStats)
  485. if err != nil {
  486. // These persistent stats records may be resent.
  487. NoticeWarning(
  488. "ClearReportedPersistentStats failed: %s", errors.Trace(err))
  489. }
  490. }
  491. // RecordRemoteServerListStat records a completed common or OSL
  492. // remote server list resource download.
  493. //
  494. // The RSL download event could occur when the client is unable
  495. // to immediately send a status request to a server, so these
  496. // records are stored in the persistent datastore and reported
  497. // via subsequent status requests sent to any Psiphon server.
  498. //
  499. // Note that some common event field values may change between the
  500. // stat recording and reporting, including client geolocation and
  501. // host_id.
  502. //
  503. // Multiple "status" requests may be in flight at once (due
  504. // to multi-tunnel, asynchronous final status retry, and
  505. // aggressive status requests for pre-registered tunnels),
  506. // To avoid duplicate reporting, persistent stats records are
  507. // "taken-out" by a status request and then "put back" in
  508. // case the request fails.
  509. //
  510. // Duplicate reporting may also occur when a server receives and
  511. // processes a status request but the client fails to receive
  512. // the response.
  513. func RecordRemoteServerListStat(
  514. config *Config,
  515. tunneled bool,
  516. url string,
  517. etag string,
  518. authenticated bool) error {
  519. if !config.GetClientParameters().Get().WeightedCoinFlip(
  520. parameters.RecordRemoteServerListPersistentStatsProbability) {
  521. return nil
  522. }
  523. params := make(common.APIParameters)
  524. params["session_id"] = config.SessionID
  525. params["propagation_channel_id"] = config.PropagationChannelId
  526. params["sponsor_id"] = config.GetSponsorID()
  527. params["client_version"] = config.ClientVersion
  528. params["client_platform"] = config.ClientPlatform
  529. params["client_build_rev"] = buildinfo.GetBuildInfo().BuildRev
  530. if config.DeviceRegion != "" {
  531. params["device_region"] = config.DeviceRegion
  532. }
  533. params["client_download_timestamp"] = common.TruncateTimestampToHour(common.GetCurrentTimestamp())
  534. tunneledStr := "0"
  535. if tunneled {
  536. tunneledStr = "1"
  537. }
  538. params["tunneled"] = tunneledStr
  539. params["url"] = url
  540. params["etag"] = etag
  541. authenticatedStr := "0"
  542. if authenticated {
  543. authenticatedStr = "1"
  544. }
  545. params["authenticated"] = authenticatedStr
  546. remoteServerListStatJson, err := json.Marshal(params)
  547. if err != nil {
  548. return errors.Trace(err)
  549. }
  550. return StorePersistentStat(
  551. config, datastorePersistentStatTypeRemoteServerList, remoteServerListStatJson)
  552. }
  553. // RecordFailedTunnelStat records metrics for a failed tunnel dial, including
  554. // dial parameters and error condition (tunnelErr).
  555. //
  556. // This uses the same reporting facility, with the same caveats, as
  557. // RecordRemoteServerListStat.
  558. func RecordFailedTunnelStat(
  559. config *Config,
  560. dialParams *DialParameters,
  561. livenessTestMetrics *livenessTestMetrics,
  562. bytesUp int64,
  563. bytesDown int64,
  564. tunnelErr error) error {
  565. if !config.GetClientParameters().Get().WeightedCoinFlip(
  566. parameters.RecordFailedTunnelPersistentStatsProbability) {
  567. return nil
  568. }
  569. lastConnected, err := getLastConnected()
  570. if err != nil {
  571. return errors.Trace(err)
  572. }
  573. params := getBaseAPIParameters(baseParametersAll, config, dialParams)
  574. delete(params, "server_secret")
  575. params["server_entry_tag"] = dialParams.ServerEntry.Tag
  576. params["last_connected"] = lastConnected
  577. params["client_failed_timestamp"] = common.TruncateTimestampToHour(common.GetCurrentTimestamp())
  578. if livenessTestMetrics != nil {
  579. params["liveness_test_upstream_bytes"] = strconv.Itoa(livenessTestMetrics.UpstreamBytes)
  580. params["liveness_test_sent_upstream_bytes"] = strconv.Itoa(livenessTestMetrics.SentUpstreamBytes)
  581. params["liveness_test_downstream_bytes"] = strconv.Itoa(livenessTestMetrics.DownstreamBytes)
  582. params["liveness_test_received_downstream_bytes"] = strconv.Itoa(livenessTestMetrics.ReceivedDownstreamBytes)
  583. }
  584. if bytesUp >= 0 {
  585. params["bytes_up"] = fmt.Sprintf("%d", bytesUp)
  586. }
  587. if bytesDown >= 0 {
  588. params["bytes_down"] = fmt.Sprintf("%d", bytesDown)
  589. }
  590. // Ensure direct server IPs are not exposed in logs. The "net" package, and
  591. // possibly other 3rd party packages, will include destination addresses in
  592. // I/O error messages.
  593. tunnelError := StripIPAddressesString(tunnelErr.Error())
  594. params["tunnel_error"] = tunnelError
  595. failedTunnelStatJson, err := json.Marshal(params)
  596. if err != nil {
  597. return errors.Trace(err)
  598. }
  599. return StorePersistentStat(
  600. config, datastorePersistentStatTypeFailedTunnel, failedTunnelStatJson)
  601. }
  602. // doGetRequest makes a tunneled HTTPS request and returns the response body.
  603. func (serverContext *ServerContext) doGetRequest(
  604. requestUrl string) (responseBody []byte, err error) {
  605. request, err := http.NewRequest("GET", requestUrl, nil)
  606. if err != nil {
  607. return nil, errors.Trace(err)
  608. }
  609. request.Header.Set("User-Agent", MakePsiphonUserAgent(serverContext.tunnel.config))
  610. response, err := serverContext.psiphonHttpsClient.Do(request)
  611. if err == nil && response.StatusCode != http.StatusOK {
  612. response.Body.Close()
  613. err = fmt.Errorf("HTTP GET request failed with response code: %d", response.StatusCode)
  614. }
  615. if err != nil {
  616. // Trim this error since it may include long URLs
  617. return nil, errors.Trace(TrimError(err))
  618. }
  619. defer response.Body.Close()
  620. body, err := ioutil.ReadAll(response.Body)
  621. if err != nil {
  622. return nil, errors.Trace(err)
  623. }
  624. return body, nil
  625. }
  626. // doPostRequest makes a tunneled HTTPS POST request.
  627. func (serverContext *ServerContext) doPostRequest(
  628. requestUrl string, bodyType string, body io.Reader) (responseBody []byte, err error) {
  629. request, err := http.NewRequest("POST", requestUrl, body)
  630. if err != nil {
  631. return nil, errors.Trace(err)
  632. }
  633. request.Header.Set("User-Agent", MakePsiphonUserAgent(serverContext.tunnel.config))
  634. request.Header.Set("Content-Type", bodyType)
  635. response, err := serverContext.psiphonHttpsClient.Do(request)
  636. if err == nil && response.StatusCode != http.StatusOK {
  637. response.Body.Close()
  638. err = fmt.Errorf("HTTP POST request failed with response code: %d", response.StatusCode)
  639. }
  640. if err != nil {
  641. // Trim this error since it may include long URLs
  642. return nil, errors.Trace(TrimError(err))
  643. }
  644. defer response.Body.Close()
  645. responseBody, err = ioutil.ReadAll(response.Body)
  646. if err != nil {
  647. return nil, errors.Trace(err)
  648. }
  649. return responseBody, nil
  650. }
  651. // makeSSHAPIRequestPayload makes a JSON payload for an SSH API request.
  652. func (serverContext *ServerContext) makeSSHAPIRequestPayload(
  653. params common.APIParameters) ([]byte, error) {
  654. jsonPayload, err := json.Marshal(params)
  655. if err != nil {
  656. return nil, errors.Trace(err)
  657. }
  658. return jsonPayload, nil
  659. }
  660. type baseParametersFilter int
  661. const (
  662. baseParametersAll baseParametersFilter = iota
  663. baseParametersOnlyUpstreamFragmentorDialParameters
  664. baseParametersNoDialParameters
  665. )
  666. func (serverContext *ServerContext) getBaseAPIParameters(
  667. filter baseParametersFilter) common.APIParameters {
  668. params := getBaseAPIParameters(
  669. filter,
  670. serverContext.tunnel.config,
  671. serverContext.tunnel.dialParams)
  672. // Add a random amount of padding to defend against API call traffic size
  673. // fingerprints. The "pad_response" field instructs the server to pad its
  674. // response accordingly.
  675. p := serverContext.tunnel.config.GetClientParameters().Get()
  676. minUpstreamPadding := p.Int(parameters.APIRequestUpstreamPaddingMinBytes)
  677. maxUpstreamPadding := p.Int(parameters.APIRequestUpstreamPaddingMaxBytes)
  678. minDownstreamPadding := p.Int(parameters.APIRequestDownstreamPaddingMinBytes)
  679. maxDownstreamPadding := p.Int(parameters.APIRequestDownstreamPaddingMaxBytes)
  680. if maxUpstreamPadding > 0 {
  681. size := serverContext.paddingPRNG.Range(minUpstreamPadding, maxUpstreamPadding)
  682. params["padding"] = strings.Repeat(" ", size)
  683. }
  684. if maxDownstreamPadding > 0 {
  685. size := serverContext.paddingPRNG.Range(minDownstreamPadding, maxDownstreamPadding)
  686. params["pad_response"] = strconv.Itoa(size)
  687. }
  688. return params
  689. }
  690. // getBaseAPIParameters returns all the common API parameters that are
  691. // included with each Psiphon API request. These common parameters are used
  692. // for metrics.
  693. func getBaseAPIParameters(
  694. filter baseParametersFilter,
  695. config *Config,
  696. dialParams *DialParameters) common.APIParameters {
  697. params := make(common.APIParameters)
  698. params["session_id"] = config.SessionID
  699. params["client_session_id"] = config.SessionID
  700. params["server_secret"] = dialParams.ServerEntry.WebServerSecret
  701. params["propagation_channel_id"] = config.PropagationChannelId
  702. params["sponsor_id"] = config.GetSponsorID()
  703. params["client_version"] = config.ClientVersion
  704. params["client_platform"] = config.ClientPlatform
  705. params["client_build_rev"] = buildinfo.GetBuildInfo().BuildRev
  706. params["tunnel_whole_device"] = strconv.Itoa(config.TunnelWholeDevice)
  707. // Blank parameters must be omitted.
  708. if config.DeviceRegion != "" {
  709. params["device_region"] = config.DeviceRegion
  710. }
  711. if filter == baseParametersAll {
  712. params["relay_protocol"] = dialParams.TunnelProtocol
  713. params["network_type"] = dialParams.GetNetworkType()
  714. if dialParams.BPFProgramName != "" {
  715. params["client_bpf"] = dialParams.BPFProgramName
  716. }
  717. if dialParams.SelectedSSHClientVersion {
  718. params["ssh_client_version"] = dialParams.SSHClientVersion
  719. }
  720. if dialParams.UpstreamProxyType != "" {
  721. params["upstream_proxy_type"] = dialParams.UpstreamProxyType
  722. }
  723. if dialParams.UpstreamProxyCustomHeaderNames != nil {
  724. params["upstream_proxy_custom_header_names"] = dialParams.UpstreamProxyCustomHeaderNames
  725. }
  726. if dialParams.FrontingProviderID != "" {
  727. params["fronting_provider_id"] = dialParams.FrontingProviderID
  728. }
  729. if dialParams.MeekDialAddress != "" {
  730. params["meek_dial_address"] = dialParams.MeekDialAddress
  731. }
  732. meekResolvedIPAddress := dialParams.MeekResolvedIPAddress.Load().(string)
  733. if meekResolvedIPAddress != "" {
  734. params["meek_resolved_ip_address"] = meekResolvedIPAddress
  735. }
  736. if dialParams.MeekSNIServerName != "" {
  737. params["meek_sni_server_name"] = dialParams.MeekSNIServerName
  738. }
  739. if dialParams.MeekHostHeader != "" {
  740. params["meek_host_header"] = dialParams.MeekHostHeader
  741. }
  742. // MeekTransformedHostName is meaningful when meek is used, which is when
  743. // MeekDialAddress != ""
  744. if dialParams.MeekDialAddress != "" {
  745. transformedHostName := "0"
  746. if dialParams.MeekTransformedHostName {
  747. transformedHostName = "1"
  748. }
  749. params["meek_transformed_host_name"] = transformedHostName
  750. }
  751. if dialParams.SelectedUserAgent {
  752. params["user_agent"] = dialParams.UserAgent
  753. }
  754. if dialParams.SelectedTLSProfile {
  755. params["tls_profile"] = dialParams.TLSProfile
  756. params["tls_version"] = dialParams.GetTLSVersionForMetrics()
  757. }
  758. if dialParams.ServerEntry.Region != "" {
  759. params["server_entry_region"] = dialParams.ServerEntry.Region
  760. }
  761. if dialParams.ServerEntry.LocalSource != "" {
  762. params["server_entry_source"] = dialParams.ServerEntry.LocalSource
  763. }
  764. // As with last_connected, this timestamp stat, which may be a precise
  765. // handshake request server timestamp, is truncated to hour granularity to
  766. // avoid introducing a reconstructable cross-session user trace into server
  767. // logs.
  768. localServerEntryTimestamp := common.TruncateTimestampToHour(
  769. dialParams.ServerEntry.LocalTimestamp)
  770. if localServerEntryTimestamp != "" {
  771. params["server_entry_timestamp"] = localServerEntryTimestamp
  772. }
  773. params[tactics.APPLIED_TACTICS_TAG_PARAMETER_NAME] =
  774. config.GetClientParameters().Get().Tag()
  775. if dialParams.DialPortNumber != "" {
  776. params["dial_port_number"] = dialParams.DialPortNumber
  777. }
  778. if dialParams.QUICVersion != "" {
  779. params["quic_version"] = dialParams.QUICVersion
  780. }
  781. if dialParams.QUICDialSNIAddress != "" {
  782. params["quic_dial_sni_address"] = dialParams.QUICDialSNIAddress
  783. }
  784. isReplay := "0"
  785. if dialParams.IsReplay {
  786. isReplay = "1"
  787. }
  788. params["is_replay"] = isReplay
  789. if config.EgressRegion != "" {
  790. params["egress_region"] = config.EgressRegion
  791. }
  792. // dialParams.DialDuration is nanoseconds; divide to get to milliseconds
  793. params["dial_duration"] = fmt.Sprintf("%d", dialParams.DialDuration/1000000)
  794. params["candidate_number"] = strconv.Itoa(dialParams.CandidateNumber)
  795. params["established_tunnels_count"] = strconv.Itoa(dialParams.EstablishedTunnelsCount)
  796. if dialParams.NetworkLatencyMultiplier != 0.0 {
  797. params["network_latency_multiplier"] =
  798. fmt.Sprintf("%f", dialParams.NetworkLatencyMultiplier)
  799. }
  800. if dialParams.DialConnMetrics != nil {
  801. metrics := dialParams.DialConnMetrics.GetMetrics()
  802. for name, value := range metrics {
  803. params[name] = fmt.Sprintf("%v", value)
  804. }
  805. }
  806. if dialParams.ObfuscatedSSHConnMetrics != nil {
  807. metrics := dialParams.ObfuscatedSSHConnMetrics.GetMetrics()
  808. for name, value := range metrics {
  809. params[name] = fmt.Sprintf("%v", value)
  810. }
  811. }
  812. } else if filter == baseParametersOnlyUpstreamFragmentorDialParameters {
  813. if dialParams.DialConnMetrics != nil {
  814. names := fragmentor.GetUpstreamMetricsNames()
  815. metrics := dialParams.DialConnMetrics.GetMetrics()
  816. for name, value := range metrics {
  817. if common.Contains(names, name) {
  818. params[name] = fmt.Sprintf("%v", value)
  819. }
  820. }
  821. }
  822. }
  823. return params
  824. }
  825. // makeRequestUrl makes a URL for a web service API request.
  826. func makeRequestUrl(tunnel *Tunnel, port, path string, params common.APIParameters) string {
  827. var requestUrl bytes.Buffer
  828. if port == "" {
  829. port = tunnel.dialParams.ServerEntry.WebServerPort
  830. }
  831. requestUrl.WriteString("https://")
  832. requestUrl.WriteString(tunnel.dialParams.ServerEntry.IpAddress)
  833. requestUrl.WriteString(":")
  834. requestUrl.WriteString(port)
  835. requestUrl.WriteString("/")
  836. requestUrl.WriteString(path)
  837. if len(params) > 0 {
  838. queryParams := url.Values{}
  839. for name, value := range params {
  840. // Note: this logic skips the tactics.SPEED_TEST_SAMPLES_PARAMETER_NAME
  841. // parameter, which has a different type. This parameter is not recognized
  842. // by legacy servers.
  843. switch v := value.(type) {
  844. case string:
  845. queryParams.Set(name, v)
  846. case []string:
  847. // String array param encoded as JSON
  848. jsonValue, err := json.Marshal(v)
  849. if err != nil {
  850. break
  851. }
  852. queryParams.Set(name, string(jsonValue))
  853. }
  854. }
  855. requestUrl.WriteString("?")
  856. requestUrl.WriteString(queryParams.Encode())
  857. }
  858. return requestUrl.String()
  859. }
  860. // makePsiphonHttpsClient creates a Psiphon HTTPS client that tunnels web service API
  861. // requests and which validates the web server using the Psiphon server entry web server
  862. // certificate.
  863. func makePsiphonHttpsClient(tunnel *Tunnel) (httpsClient *http.Client, err error) {
  864. certificate, err := DecodeCertificate(
  865. tunnel.dialParams.ServerEntry.WebServerCertificate)
  866. if err != nil {
  867. return nil, errors.Trace(err)
  868. }
  869. tunneledDialer := func(_ context.Context, _, addr string) (conn net.Conn, err error) {
  870. return tunnel.sshClient.Dial("tcp", addr)
  871. }
  872. // Note: as with SSH API requests, there no dial context here. SSH port forward dials
  873. // cannot be interrupted directly. Closing the tunnel will interrupt both the dial and
  874. // the request. While it's possible to add a timeout here, we leave it with no explicit
  875. // timeout which is the same as SSH API requests: if the tunnel has stalled then SSH keep
  876. // alives will cause the tunnel to close.
  877. dialer := NewCustomTLSDialer(
  878. &CustomTLSConfig{
  879. ClientParameters: tunnel.config.clientParameters,
  880. Dial: tunneledDialer,
  881. VerifyLegacyCertificate: certificate,
  882. })
  883. transport := &http.Transport{
  884. DialTLS: func(network, addr string) (net.Conn, error) {
  885. return dialer(context.Background(), network, addr)
  886. },
  887. Dial: func(network, addr string) (net.Conn, error) {
  888. return nil, errors.TraceNew("HTTP not supported")
  889. },
  890. }
  891. return &http.Client{
  892. Transport: transport,
  893. }, nil
  894. }
  895. func HandleServerRequest(
  896. tunnelOwner TunnelOwner, tunnel *Tunnel, name string, payload []byte) error {
  897. switch name {
  898. case protocol.PSIPHON_API_OSL_REQUEST_NAME:
  899. return HandleOSLRequest(tunnelOwner, tunnel, payload)
  900. case protocol.PSIPHON_API_ALERT_REQUEST_NAME:
  901. return HandleAlertRequest(tunnelOwner, tunnel, payload)
  902. }
  903. return errors.Tracef("invalid request name: %s", name)
  904. }
  905. func HandleOSLRequest(
  906. tunnelOwner TunnelOwner, tunnel *Tunnel, payload []byte) error {
  907. var oslRequest protocol.OSLRequest
  908. err := json.Unmarshal(payload, &oslRequest)
  909. if err != nil {
  910. return errors.Trace(err)
  911. }
  912. if oslRequest.ClearLocalSLOKs {
  913. DeleteSLOKs()
  914. }
  915. seededNewSLOK := false
  916. for _, slok := range oslRequest.SeedPayload.SLOKs {
  917. duplicate, err := SetSLOK(slok.ID, slok.Key)
  918. if err != nil {
  919. // TODO: return error to trigger retry?
  920. NoticeWarning("SetSLOK failed: %s", errors.Trace(err))
  921. } else if !duplicate {
  922. seededNewSLOK = true
  923. }
  924. if tunnel.config.EmitSLOKs {
  925. NoticeSLOKSeeded(base64.StdEncoding.EncodeToString(slok.ID), duplicate)
  926. }
  927. }
  928. if seededNewSLOK {
  929. tunnelOwner.SignalSeededNewSLOK()
  930. }
  931. return nil
  932. }
  933. func HandleAlertRequest(
  934. tunnelOwner TunnelOwner, tunnel *Tunnel, payload []byte) error {
  935. var alertRequest protocol.AlertRequest
  936. err := json.Unmarshal(payload, &alertRequest)
  937. if err != nil {
  938. return errors.Trace(err)
  939. }
  940. if tunnel.config.EmitServerAlerts {
  941. NoticeServerAlert(alertRequest)
  942. }
  943. return nil
  944. }