1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
package com.softwaremill.sttp
import java.net.InetSocketAddress
import scala.concurrent.duration._
import com.softwaremill.sttp.SttpBackendOptions._
case class SttpBackendOptions(
connectionTimeout: FiniteDuration,
proxy: Option[Proxy]
) {
def connectionTimeout(ct: FiniteDuration): SttpBackendOptions =
this.copy(connectionTimeout = ct)
def httpProxy(host: String, port: Int): SttpBackendOptions =
this.copy(proxy = Some(Proxy(host, port, ProxyType.Http)))
def socksProxy(host: String, port: Int): SttpBackendOptions =
this.copy(proxy = Some(Proxy(host, port, ProxyType.Socks)))
}
object SttpBackendOptions {
case class Proxy(host: String, port: Int, proxyType: ProxyType) {
def asJava = new java.net.Proxy(proxyType.asJava, inetSocketAddress)
def inetSocketAddress: InetSocketAddress =
InetSocketAddress.createUnresolved(host, port)
}
sealed trait ProxyType {
def asJava: java.net.Proxy.Type
}
object ProxyType {
case object Http extends ProxyType {
override def asJava: java.net.Proxy.Type = java.net.Proxy.Type.HTTP
}
case object Socks extends ProxyType {
override def asJava: java.net.Proxy.Type = java.net.Proxy.Type.SOCKS
}
}
val Default: SttpBackendOptions = SttpBackendOptions(30.seconds, None)
def connectionTimeout(ct: FiniteDuration): SttpBackendOptions = Default.connectionTimeout(ct)
def httpProxy(host: String, port: Int): SttpBackendOptions = Default.httpProxy(host, port)
def socksProxy(host: String, port: Int): SttpBackendOptions = Default.socksProxy(host, port)
}
|
