Hi Thomas,
as I said, I don't have access to a REPL right now.
What does "but i cannot use atop on top of the tlsHandler" mean? What did
you try, what did the compiler say? How did you adapt the code?
Were you able to understand what I meant with my solution?
On Mon, Jul 20, 2015 at 5:32 PM, Thomas Zimmer <t.zim...@eslgaming.com>
wrote:
> hey do you have any code-examples? I tried:
>
> val wrappedFlow = BidiFlow.wrap(inboundFlow, outboundFlow)
>
>
> but i cannot use atop on top of the tlsHandler
>
>
> val tlsHandler = SslTls(sslContext, session, akka.stream.io.Role.server,
> closing)
>
>
>
> On Monday, July 20, 2015 at 5:01:46 PM UTC+2, √ wrote:
>>
>> Hi Thomas,
>>
>> I don't have access to a REPL at the moment,
>>
>> what I'd suggest is to use BidiFlow.wrap on your inboundFlow and
>> outboundFlow, then you put that atop the sslbidiflow, and if/when you need
>> to short-circuit the "business end" of the bidiflow you get from the
>> previous steps, add a join with the identity flow (Flow[Out1, In2]) or use
>> a Flow.apply with a builder to manually connect the ports.
>>
>> On Mon, Jul 20, 2015 at 4:36 PM, Thomas Zimmer <t.zi...@eslgaming.com>
>> wrote:
>>
>>> Can you tell me how to setup the correct workflow here?
>>>
>>> I would like to have:
>>>
>>> incoming data (tcp) -> tls -> logicFlow.in
>>> logicFlow.out -> tls -> outgoing (tcp)
>>>
>>> Cheers and thanks for the help
>>>
>>>
>>>
>>> On Monday, July 20, 2015 at 3:17:49 PM UTC+2, √ wrote:
>>>>
>>>> A Flow is a graph with 1 input and 1 output, you are connecting the
>>>> bidiflow (2 inputs and 2 outputs) to eachother, leaving no inputs nor
>>>> outputs open, which means it cannot be a Flow.
>>>>
>>>> On Mon, Jul 20, 2015 at 2:58 PM, Thomas Zimmer <t.zi...@eslgaming.com>
>>>> wrote:
>>>>
>>>>> Hey,
>>>>>
>>>>> I really have problems understanding the TLS Bidi-Flows. The specs are
>>>>> not very helpful as they only do "echo" the input as fas as I understood
>>>>> and there is not official documentation. What I have so far:
>>>>>
>>>>> * A TCP flow (Flow[ByteString, ByteString])
>>>>> * A logical flow (Flow[ByteString, ByteString])
>>>>>
>>>>> How can i connect this to the TLS Bidi-Flow. Here is the code I tried:
>>>>>
>>>>> val session =
>>>>> NegotiateNewSession.withDefaults.withCipherSuites("TLS_RSA_WITH_AES_128_CBC_SHA")
>>>>>
>>>>>
>>>>> .withCipherSuites("TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256","TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA",
>>>>>
>>>>> "TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384","TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA",
>>>>> "TLS_DHE_RSA_WITH_AES_256_CBC_SHA",
>>>>> "TLS_DHE_RSA_WITH_AES_128_CBC_SHA","TLS_RSA_WITH_AES_128_CBC_SHA256","TLS_RSA_WITH_AES_128_CBC_SHA",
>>>>> "TLS_RSA_WITH_AES_256_CBC_SHA256", "TLS_RSA_WITH_AES_256_CBC_SHA")
>>>>> .withProtocols("TLSv1.2")
>>>>> .withClientAuth(ClientAuth.None)
>>>>>
>>>>>
>>>>> val closing = IgnoreComplete
>>>>> val tlsHandler = SslTls(sslContext, session, akka.stream.io.Role.server,
>>>>> closing)
>>>>> val logicalFlow = getLogicalFlow
>>>>>
>>>>> // SslTlsInbound to bytes
>>>>> val inboundFlow: Flow[SslTlsInbound, ByteString, Unit] =
>>>>> Flow[SslTlsInbound].map {
>>>>> case SessionBytes(_, bytes: ByteString) =>
>>>>> log.info("Received bytes")
>>>>> bytes
>>>>> case SessionTruncated => sys.error("Truncated")
>>>>> }
>>>>>
>>>>> // bytes to SslTlsOutbound
>>>>> val outboundFlow: Flow[ByteString, SslTlsOutbound, Unit] =
>>>>> Flow[ByteString].map {
>>>>> case bytes: ByteString =>
>>>>> log.info("Sending bytes")
>>>>> SendBytes(bytes)
>>>>> }
>>>>>
>>>>> val tlsFlow = Flow() { implicit builder =>
>>>>> import FlowGraph.Implicits._
>>>>>
>>>>> val tls = builder.add(tlsHandler)
>>>>>
>>>>> // Define outbound/inbound flows
>>>>> tls.out2 ~> inboundFlow ~> tls.in2
>>>>> // tls.out1 ~> outboundFlow ~> tls.in1
>>>>> tls.in1 <~ outboundFlow <~ tls.out1
>>>>>
>>>>> // Define in/outlet
>>>>> (tls.in2, tls.out1)
>>>>> }
>>>>>
>>>>>
>>>>> // conn = Tcp.IncomingConnection
>>>>>
>>>>> conn.handleWith(tlsFlow)
>>>>>
>>>>>
>>>>>
>>>>> As soon as I start the application I get this error-message:
>>>>>
>>>>>
>>>>> Cannot build Flow with open inputs () and outputs ()
>>>>> info] akka.actor.ActorInitializationException: exception during creation
>>>>> info] at akka.actor.ActorInitializationException$.apply(Actor.scala:166)
>>>>> info] at akka.actor.ActorCell.create(ActorCell.scala:596)
>>>>> info] at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
>>>>> info] at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
>>>>> info] at
>>>>> akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
>>>>> info] at akka.dispatch.Mailbox.run(Mailbox.scala:219)
>>>>> info] at
>>>>> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
>>>>> info] at
>>>>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>>>>> info] at
>>>>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
>>>>> info] at
>>>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>>>>> info] at
>>>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>>>>> info] Caused by: java.lang.IllegalArgumentException: Cannot build Flow
>>>>> with open inputs () and outputs ()
>>>>> info] at
>>>>> akka.stream.scaladsl.FlowGraph$Builder.buildFlow(Graph.scala:427)
>>>>> info] at akka.stream.scaladsl.FlowApply$class.apply(FlowApply.scala:18)
>>>>> info] at akka.stream.scaladsl.Flow$.apply(Flow.scala:313)
>>>>>
>>>>>
>>>>> I do not understand where I should have open inputs or outputs? All the
>>>>> BIDI-Flow inputs should be in use?
>>>>>
>>>>> --
>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>> >>>>>>>>>> Check the FAQ:
>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>> >>>>>>>>>> Search the archives:
>>>>> https://groups.google.com/group/akka-user
>>>>> ---
>>>>> You received this message because you are subscribed to the Google
>>>>> Groups "Akka User List" group.
>>>>> To unsubscribe from this group and stop receiving emails from it, send
>>>>> an email to akka-user+...@googlegroups.com.
>>>>> To post to this group, send email to akka...@googlegroups.com.
>>>>> Visit this group at http://groups.google.com/group/akka-user.
>>>>> For more options, visit https://groups.google.com/d/optout.
>>>>>
>>>>
>>>>
>>>>
>>>> --
>>>> Cheers,
>>>> √
>>>>
>>> --
>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>> >>>>>>>>>> Check the FAQ:
>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>> >>>>>>>>>> Search the archives:
>>> https://groups.google.com/group/akka-user
>>> ---
>>> You received this message because you are subscribed to the Google
>>> Groups "Akka User List" group.
>>> To unsubscribe from this group and stop receiving emails from it, send
>>> an email to akka-user+...@googlegroups.com.
>>> To post to this group, send email to akka...@googlegroups.com.
>>> Visit this group at http://groups.google.com/group/akka-user.
>>> For more options, visit https://groups.google.com/d/optout.
>>>
>>
>>
>>
>> --
>> Cheers,
>> √
>>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
--
Cheers,
√
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
