scala - Route akka-http request through a proxy -


i rewriting application layer code in scala using scalaj akka-http in order reduce number of third party dependencies in project (we use akka other things in same project.) code wraps common types of request underlying general request provided library

mostly has been fine, stuck on problem of optionally adding proxy request.

requests should either direct destination or via proxy, determined parameter @ runtime.

in scalaj implementation, have following helper class , methods

object httputils {   private def request(                host: host,                method: httpmethod,                params: map[string, string],                postdata: option[string],                timeout: duration,                headers: seq[(string, string)],                proxy: option[proxyconfig]              ): httpresponse[string] = {     // general request builder. other methods in object fill in parameters , wrap in future     val baserequest = http(host.url)     val proxiedrequest = addproxy(proxy, baserequest)     val fullrequest = addpostdata(postdata)(proxiedrequest)       .method(method.tostring)       .params(params)       .headers(headers)       .option(httpoptions.conntimeout(timeout.tomillis.toint))       .option(httpoptions.readtimeout(timeout.tomillis.toint))     fullrequest.asstring  // scalaj send off request , block until response   }        // other methods ...     private def addproxy(proxy: option[proxyconfig], request: httprequest): httprequest =      proxy.fold(request)((p: proxyconfig) => request.proxy(p.host, p.port)) }  case class proxyconfig(host: string, port: int)

is there way build similar construct akka-http?

akka http have proxy support that, of version 10.0.9, still unstable. keeping in mind api change, following handle optional proxy settings:

import java.net.inetsocketaddress  import akka.actor.actorsystem import akka.stream.actormaterializer import akka.http.scaladsl.{clienttransport, http}  implicit val system = actorsystem() implicit val materializer = actormaterializer()  case class proxyconfig(host: string, port: int)  val proxyconfig = option(proxyconfig("localhost", 8888)) val clienttransport =   proxyconfig.map(p => clienttransport.httpsproxy(inetsocketaddress.createunresolved(p.host, p.port)))              .getorelse(clienttransport.tcp)  val settings = connectionpoolsettings(system).withtransport(clienttransport) http().singlerequest(httprequest(uri = "https://google.com"), settings = settings)

Comments

Post a Comment

Popular posts from this blog

php - Vagrant up error - Uncaught Reflection Exception: Class DOMDocument does not exist -

i've set bento/ubuntu-16.04 vagrant box using php 5.6, , getting following error quite few times when try , run shell script: "uncaught reflection exception: class domdocument not exist". i've tried adding following top of script (not together), each no success: "sudo apt-get install php5.6-xml", "sudo apt-get install php5-xml", "sudo apt-get install php-dom" i've tried resetting server "sudo service apache2 restart". does have suggestions?
Read more

vue.js - Create hooks for automated testing -

Image
qa guys complained can't automate frontend testing. because our html looks same outside. lazy hack did this <template> <div :role="$options.name"> ... </div> </template> <script> export default { name: 'vmcomponentname' } </script> which takes name script , applies html. in browser get: <div role="vmcomponentname"> ... </div> line :role="$options.name" goes in every component. is there dry er solutions? please share. additional details i'll explain in details looking for. imagine have vmusercreate form creates user. test case can create user . to automatically test without role, have use following selector: .wrapper > .wrapper > .wrapper > .submit-button the test extremely brittle (will break lot). if use roles can use [role="vmusercreateform"] .submit-button selector. many folds less brittle. so basically, i'm ...
Read more

Add new key value to json node in java -

i have json file : { "id":1, "name":"abc", "addressdetails": { "city":"newyork" } } i wanted add 1 more key-value ("pincode" : "414141") node 'addressdetails'. i tried using : objectmapper mapper = new objectmapper(); jsonnode root = mapper.readtree(new file("d://test.json")); objectnode node = mapper.createobjectnode(); node.with("addressdetails").put("pincode", "414141"); but it's not getting added, there way can ? you can try you should modify file path objectmapper mapper = new objectmapper(); objectnode nodes = mapper.readvalue(new file("d:\\test.txt"), objectnode.class); nodes.with("addressdetails").put("pincode", "414141"); mapper.writer().writevalue(new file("d:\\test.txt"), nodes);
Read more