Homec4science
Diffusion SHRINE MedCo Fork (release/1.22.0) Browse

shrine-medco/apps/shrine-app/src/test/scala/net/shrine/wiring/NodeHandleSourceTest.scala
461ac3a5d061release/1.22.0

Last Change
Raw File

NodeHandleSourceTest.scala
View Options

package net.shrine.wiring
import java.net.URL
import scala.concurrent.duration.DurationInt
import org.junit.Test
import net.shrine.util.ShouldMatchersForJUnit
import javax.ws.rs.core.MediaType
import net.shrine.adapter.client.InJvmAdapterClient
import net.shrine.adapter.client.RemoteAdapterClient
import net.shrine.adapter.service.AdapterRequestHandler
import net.shrine.broadcaster.{IdAndUrl, NodeHandle}
import net.shrine.client.JerseyHttpClient
import net.shrine.client.Poster
import net.shrine.crypto.TrustParam.AcceptAllCerts
import net.shrine.protocol.BroadcastMessage
import net.shrine.protocol.NodeId
import net.shrine.protocol.Result
import net.shrine.protocol.DefaultBreakdownResultOutputTypes
/**
* @author clint
* @since Dec 11, 2013
*/
final class NodeHandleSourceTest extends ShouldMatchersForJUnit {
@Test
def testMakeNodeHandles {
val trustParam = AcceptAllCerts
val myId = NodeId("me")
val xId = NodeId("x")
val yId = NodeId("y")
val xUrl = "http://example.com/x/requests"
val yUrl = "http://example.com/y"
val nodes = Seq(
IdAndUrl(xId, new URL(xUrl)),
IdAndUrl(yId, new URL(yUrl)))
import scala.concurrent.duration._
val timeout = 1.minute
val breakdownTypes = DefaultBreakdownResultOutputTypes.toSet
{
val handles = NodeHandleSource.makeNodeHandles(trustParam, timeout, nodes, myId, None, breakdownTypes)
handles should equal {
Set(
NodeHandle(xId, RemoteAdapterClient(xId,Poster(xUrl, JerseyHttpClient(trustParam, timeout, MediaType.APPLICATION_XML)), breakdownTypes)),
NodeHandle(yId, RemoteAdapterClient(yId,Poster(yUrl + "/requests", JerseyHttpClient(trustParam, timeout, MediaType.APPLICATION_XML)), breakdownTypes)))
}
}
{
val mockAdapter: AdapterRequestHandler = new AdapterRequestHandler {
override def handleRequest(request: BroadcastMessage): Result = ???
}
val handles = NodeHandleSource.makeNodeHandles(trustParam, timeout, nodes, myId, Some(mockAdapter), breakdownTypes)
handles should equal {
Set(
NodeHandle(xId, RemoteAdapterClient(xId,Poster(xUrl, JerseyHttpClient(trustParam, timeout, MediaType.APPLICATION_XML)), breakdownTypes)),
NodeHandle(yId, RemoteAdapterClient(yId,Poster(yUrl + "/requests", JerseyHttpClient(trustParam, timeout, MediaType.APPLICATION_XML)), breakdownTypes)),
NodeHandle(myId, new InJvmAdapterClient(mockAdapter)))
}
}
}
}
c4science · Help