stawros/http-mock-server
1
0
Fork 0
Code Releases Packages Activity

Add mock validation

Browse source
This commit is contained in:
Dominik Adam Przybysz 2014-12-13 20:33:22 +01:00
parent fda5b6ca5c
commit 88bb4f3067
6 changed files with 78 additions and 51 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/main/groovy/pl/touk/mockserver/server/ContextExecutor.groovy
View file

@ -13,7 +13,7 @@ class ContextExecutor {
ContextExecutor(HttpServerWraper httpServerWraper, Mock initialMock) { ContextExecutor(HttpServerWraper httpServerWraper, Mock initialMock) {
this.httpServerWraper = httpServerWraper this.httpServerWraper = httpServerWraper
this.path = initialMock.path this.path = '/' + initialMock.path
this.mocks = new CopyOnWriteArrayList<>([initialMock]) this.mocks = new CopyOnWriteArrayList<>([initialMock])
httpServerWraper.createContext(path, { httpServerWraper.createContext(path, {
HttpExchange ex -> HttpExchange ex ->
@ -36,6 +36,14 @@ class ContextExecutor {
}) })
} }
String getPath() {
return path.substring(1)
}
String getContextPath() {
return path
}
private static void fillExchange(HttpExchange httpExchange, MockResponse response) { private static void fillExchange(HttpExchange httpExchange, MockResponse response) {
response.headers.each { response.headers.each {
httpExchange.responseHeaders.add(it.key, it.value) httpExchange.responseHeaders.add(it.key, it.value)
@ -60,4 +68,7 @@ class ContextExecutor {
void addMock(Mock mock) { void addMock(Mock mock) {
mocks << mock mocks << mock
} }
void stop(){
}
} }

2
src/main/groovy/pl/touk/mockserver/server/HttpServerWraper.groovy
View file

@ -38,7 +38,7 @@ class HttpServerWraper {
} }
void stop() { void stop() {
executors.each { httpServer.removeContext(it.path) } executors.each { httpServer.removeContext(it.contextPath) }
httpServer.stop(0) httpServer.stop(0)
} }

3
src/main/groovy/pl/touk/mockserver/server/Mock.groovy
View file

@ -18,6 +18,9 @@ class Mock {
int counter = 0 int counter = 0
Mock(String name, String path, int port) { Mock(String name, String path, int port) {
if (!(name)) {
throw new RuntimeException("Mock name must be given")
}
this.name = name this.name = name
this.path = path this.path = path
this.port = port this.port = port

2
src/test/groovy/pl/touk/mockserver/client/ControlServerClient.groovy
View file

@ -26,7 +26,7 @@ class ControlServerClient {
throw new MockAlreadyExists() throw new MockAlreadyExists()
} }
throw new InvalidMockDefinitionException(responseXml.text()) throw new InvalidMockDefinition(responseXml.text())
} }
} }

4
src/test/groovy/pl/touk/mockserver/client/InvalidMockDefinitionException.groovy → src/test/groovy/pl/touk/mockserver/client/InvalidMockDefinition.groovy
View file

@ -5,8 +5,8 @@ import groovy.transform.TypeChecked
@CompileStatic @CompileStatic
@TypeChecked @TypeChecked
class InvalidMockDefinitionException extends RuntimeException { class InvalidMockDefinition extends RuntimeException {
InvalidMockDefinitionException(String s) { InvalidMockDefinition(String s) {
super(s) super(s)
} }
} }

91
src/test/groovy/pl/touk/mockserver/server/MockServerIntegrationTest.groovy
View file

@ -34,7 +34,7 @@ class MockServerIntegrationTest extends Specification {
expect: expect:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseRest-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseRest-${req.xml.name()}/>"}''',
@ -55,7 +55,7 @@ class MockServerIntegrationTest extends Specification {
expect: expect:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.soap.name() == 'request'}''', predicate: '''{req -> req.soap.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.soap.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.soap.name()}/>"}''',
@ -81,7 +81,7 @@ class MockServerIntegrationTest extends Specification {
expect: expect:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''',
@ -99,7 +99,7 @@ class MockServerIntegrationTest extends Specification {
expect: expect:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''',
@ -108,7 +108,7 @@ class MockServerIntegrationTest extends Specification {
when: when:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint2', path: 'testEndpoint2',
port: 9998, port: 9998,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''',
@ -118,11 +118,25 @@ class MockServerIntegrationTest extends Specification {
thrown(MockAlreadyExists) thrown(MockAlreadyExists)
} }
def "should not add mock with empty name"() {
when:
controlServerClient.addMock(new AddMockRequestData(
name: '',
path: 'testEndpoint2',
port: 9998,
predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''',
soap: true
))
then:
thrown(InvalidMockDefinition)
}
def "should add mock after deleting old mock with the same name"() { def "should add mock after deleting old mock with the same name"() {
expect: expect:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.name()}/>"}''',
@ -133,7 +147,7 @@ class MockServerIntegrationTest extends Specification {
and: and:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request2'}''', predicate: '''{req -> req.xml.name() == 'request2'}''',
response: '''{req -> "<goodResponseSoap2-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseSoap2-${req.xml.name()}/>"}''',
@ -145,14 +159,14 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{req -> "<goodResponseRest-${req.xml.name()}/>"}''' response: '''{req -> "<goodResponseRest-${req.xml.name()}/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.soap.name() == 'request'}''', predicate: '''{req -> req.soap.name() == 'request'}''',
response: '''{req -> "<goodResponseSoap-${req.soap.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.soap.name()}/>"}''',
@ -180,7 +194,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest1', name: 'testRest1',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request1'}''', predicate: '''{req -> req.xml.name() == 'request1'}''',
response: '''{req -> "<goodResponseRest1/>"}''' response: '''{req -> "<goodResponseRest1/>"}'''
@ -194,7 +208,7 @@ class MockServerIntegrationTest extends Specification {
)) ))
HttpPost firstRequest = new HttpPost('http://localhost:9999/test1') HttpPost firstRequest = new HttpPost('http://localhost:9999/test1')
firstRequest.entity = new StringEntity('<request1/>', ContentType.create("text/xml", "UTF-8")) firstRequest.entity = new StringEntity('<request1/>', ContentType.create("text/xml", "UTF-8"))
HttpPost secondRequest = new HttpPost("http://localhost:${secondPort}${secondPath}") HttpPost secondRequest = new HttpPost("http://localhost:${secondPort}/${secondPath}")
secondRequest.entity = new StringEntity('<request2/>', ContentType.create("text/xml", "UTF-8")) secondRequest.entity = new StringEntity('<request2/>', ContentType.create("text/xml", "UTF-8"))
when: when:
CloseableHttpResponse firstResponse = client.execute(firstRequest) CloseableHttpResponse firstResponse = client.execute(firstRequest)
@ -208,10 +222,10 @@ class MockServerIntegrationTest extends Specification {
secondXmlResponse.name() == 'goodResponseRest2' secondXmlResponse.name() == 'goodResponseRest2'
where: where:
secondPort | secondPath | name secondPort | secondPath | name
9999 | '/test1' | 'the same port and path' 9999 | 'test1' | 'the same port and path'
9998 | '/test1' | 'the same path and another port' 9998 | 'test1' | 'the same path and another port'
9999 | '/test2' | 'the same port and another path' 9999 | 'test2' | 'the same port and another path'
9998 | '/test2' | 'another port and path' 9998 | 'test2' | 'another port and path'
} }
@Unroll @Unroll
@ -219,7 +233,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest1', name: 'testRest1',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
statusCode: statusCode statusCode: statusCode
)) ))
@ -241,7 +255,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest1', name: 'testRest1',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request2'}''', predicate: '''{req -> req.xml.name() == 'request2'}''',
response: '''{req -> "<goodResponseRest2/>"}''' response: '''{req -> "<goodResponseRest2/>"}'''
@ -260,27 +274,27 @@ class MockServerIntegrationTest extends Specification {
when: when:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testSoap', name: 'testSoap',
path: '/testEndpoint2', path: 'testEndpoint2',
port: -1, port: -1,
predicate: '''{_ -> true}''', predicate: '''{_ -> true}''',
response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''', response: '''{req -> "<goodResponseSoap-${req.xml.name()}/>"}''',
soap: true soap: true
)) ))
then: then:
thrown(InvalidMockDefinitionException) thrown(InvalidMockDefinition)
} }
def "should dispatch rest mock with get method"() { def "should dispatch rest mock with get method"() {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<getResponse/>"}''', response: '''{_ -> "<getResponse/>"}''',
method: AddMockRequestData.Method.GET method: AddMockRequestData.Method.GET
@ -297,13 +311,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<traceResponse/>"}''', response: '''{_ -> "<traceResponse/>"}''',
method: AddMockRequestData.Method.TRACE method: AddMockRequestData.Method.TRACE
@ -320,13 +334,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
method: AddMockRequestData.Method.HEAD method: AddMockRequestData.Method.HEAD
)) ))
@ -342,13 +356,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
method: AddMockRequestData.Method.OPTIONS method: AddMockRequestData.Method.OPTIONS
)) ))
@ -364,13 +378,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request1'}''', predicate: '''{req -> req.xml.name() == 'request1'}''',
response: '''{_ -> "<goodResponseRest1/>"}''', response: '''{_ -> "<goodResponseRest1/>"}''',
@ -389,13 +403,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
response: '''{_ -> "<goodResponseRest1/>"}''', response: '''{_ -> "<goodResponseRest1/>"}''',
method: AddMockRequestData.Method.DELETE method: AddMockRequestData.Method.DELETE
@ -412,13 +426,13 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
response: '''{_ -> "<defaultResponse/>"}''' response: '''{_ -> "<defaultResponse/>"}'''
)) ))
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest2', name: 'testRest2',
path: '/test1', path: 'test1',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request1'}''', predicate: '''{req -> req.xml.name() == 'request1'}''',
response: '''{_ -> "<goodResponseRest1/>"}''', response: '''{_ -> "<goodResponseRest1/>"}''',
@ -437,7 +451,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.xml.name() == 'request'}''', predicate: '''{req -> req.xml.name() == 'request'}''',
response: '''{_ -> "<goodResponse/>"}''', response: '''{_ -> "<goodResponse/>"}''',
@ -457,7 +471,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{ req -> req.headers['user-agent']?.startsWith('Mozilla') && predicate: '''{ req -> req.headers['user-agent']?.startsWith('Mozilla') &&
req.headers.pragma == 'no-cache'}''', req.headers.pragma == 'no-cache'}''',
@ -486,7 +500,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{ req -> req.query['q'] == '15' && predicate: '''{ req -> req.query['q'] == '15' &&
req.query.id == '1'}''', req.query.id == '1'}''',
@ -510,7 +524,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.text == 'hello=world&id=3'}''', predicate: '''{req -> req.text == 'hello=world&id=3'}''',
response: '''{_ -> "<goodResponse/>"}''' response: '''{_ -> "<goodResponse/>"}'''
@ -535,7 +549,7 @@ class MockServerIntegrationTest extends Specification {
given: given:
controlServerClient.addMock(new AddMockRequestData( controlServerClient.addMock(new AddMockRequestData(
name: 'testRest', name: 'testRest',
path: '/testEndpoint', path: 'testEndpoint',
port: 9999, port: 9999,
predicate: '''{req -> req.json.id == 1 && req.json.ar == ["a", true]}''', predicate: '''{req -> req.json.id == 1 && req.json.ar == ["a", true]}''',
response: '''{req -> """{"name":"goodResponse-${req.json.id}"}"""}''' response: '''{req -> """{"name":"goodResponse-${req.json.id}"}"""}'''
@ -558,5 +572,4 @@ class MockServerIntegrationTest extends Specification {
//TODO def "should get mock report"(){} //TODO def "should get mock report"(){}
//TODO def "should get list mocks"(){} //TODO def "should get list mocks"(){}
//TODO def "should validate mock when creating"
} }