| 1 | package fr.sii.ogham.testing.extension.junit.sms; | |
| 2 | ||
| 3 | import org.junit.Rule; | |
| 4 | import org.junit.rules.TestRule; | |
| 5 | import org.junit.runner.Description; | |
| 6 | import org.junit.runners.model.Statement; | |
| 7 | import org.slf4j.Logger; | |
| 8 | import org.slf4j.LoggerFactory; | |
| 9 | ||
| 10 | import fr.sii.ogham.testing.extension.junit.sms.config.ServerConfig; | |
| 11 | import fr.sii.ogham.testing.extension.junit.sms.config.SmppServerConfig; | |
| 12 | import fr.sii.ogham.testing.sms.simulator.config.SimulatorConfiguration; | |
| 13 | ||
| 14 | /** | |
| 15 | * JUnit {@link Rule} for starting a local SMPP server for integration tests. | |
| 16 | * | |
| 17 | * <p> | |
| 18 | * The rule starts the server before every test, execute the test and stops the | |
| 19 | * server. | |
| 20 | * </p> | |
| 21 | * <p> | |
| 22 | * The server stores the received messages (raw messages). These messages are | |
| 23 | * available in testing through {@link #getReceivedMessages()}. | |
| 24 | * </p> | |
| 25 | * | |
| 26 | * @param <M> | |
| 27 | * The type of the received messages | |
| 28 | * | |
| 29 | * @author Aurélien Baudet | |
| 30 | * | |
| 31 | */ | |
| 32 | public abstract class SmppServerRule<M> extends AbstractJUnitSmppServerExt<M> implements TestRule { | |
| 33 | private static final Logger LOG = LoggerFactory.getLogger(SmppServerRule.class); | |
| 34 | ||
| 35 | /** | |
| 36 | * Initializes with the default configuration to use for the SMPP server: | |
| 37 | * <ul> | |
| 38 | * <li>Starts on random port</li> | |
| 39 | * <li>No delay</li> | |
| 40 | * <li>No credentials</li> | |
| 41 | * <li>Do not keep messages between tests</li> | |
| 42 | * </ul> | |
| 43 | */ | |
| 44 | public SmppServerRule() { | |
| 45 | super(); | |
| 46 | } | |
| 47 | ||
| 48 | /** | |
| 49 | * Initializes with the configuration to use for the SMPP server | |
| 50 | * | |
| 51 | * @param builder | |
| 52 | * the configuration for the server | |
| 53 | */ | |
| 54 | public SmppServerRule(ServerConfig builder) { | |
| 55 | super(builder); | |
| 56 | } | |
| 57 | ||
| 58 | @Override | |
| 59 | public Statement apply(final Statement base, final Description description) { | |
| 60 | SmppServerConfig config = description.getAnnotation(SmppServerConfig.class); | |
| 61 | SimulatorConfiguration serverConfig = builder.annotationConfig(config).build(); | |
| 62 | server = initServer(serverConfig); | |
| 63 |
5
1. apply : replaced return value with null for fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::apply → NO_COVERAGE 2. apply : replaced return value with null for fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::apply → TIMED_OUT 3. apply : replaced return value with null for fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::apply → KILLED 4. apply : replaced return value with null for fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::apply → KILLED 5. apply : replaced return value with null for fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::apply → KILLED |
return new StartServerStatement(base); |
| 64 | } | |
| 65 | ||
| 66 | private final class StartServerStatement extends Statement { | |
| 67 | private final Statement base; | |
| 68 | ||
| 69 | private StartServerStatement(Statement base) { | |
| 70 | this.base = base; | |
| 71 | } | |
| 72 | ||
| 73 | @Override | |
| 74 | public void evaluate() throws Throwable { | |
| 75 | LOG.info("starting SMPP server on port {}...", getPort()); | |
| 76 |
3
1. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::before → NO_COVERAGE 2. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::before → SURVIVED 3. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::before → TIMED_OUT |
before(); |
| 77 |
5
1. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::start → NO_COVERAGE 2. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::start → TIMED_OUT 3. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::start → KILLED 4. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::start → KILLED 5. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::start → KILLED |
server.start(); |
| 78 | LOG.info("SMPP server started on port {}", getPort()); | |
| 79 | try { | |
| 80 |
3
1. evaluate : removed call to org/junit/runners/model/Statement::evaluate → SURVIVED 2. evaluate : removed call to org/junit/runners/model/Statement::evaluate → NO_COVERAGE 3. evaluate : removed call to org/junit/runners/model/Statement::evaluate → TIMED_OUT |
base.evaluate(); |
| 81 | } finally { | |
| 82 | LOG.info("stopping SMPP server..."); | |
| 83 |
3
1. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::stop → NO_COVERAGE 2. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::stop → SURVIVED 3. evaluate : removed call to fr/sii/ogham/testing/sms/simulator/SmppServerSimulator::stop → TIMED_OUT |
server.stop(); |
| 84 |
3
1. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::after → NO_COVERAGE 2. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::after → SURVIVED 3. evaluate : removed call to fr/sii/ogham/testing/extension/junit/sms/SmppServerRule::after → TIMED_OUT |
after(); |
| 85 | LOG.info("SMPP server stopped"); | |
| 86 | } | |
| 87 | } | |
| 88 | } | |
| 89 | ||
| 90 | protected void before() { | |
| 91 | // extension point | |
| 92 | } | |
| 93 | ||
| 94 | protected void after() { | |
| 95 | // extension point | |
| 96 | } | |
| 97 | ||
| 98 | } | |
Mutations | ||
| 63 |
1.1 2.2 3.3 4.4 5.5 |
|
| 76 |
1.1 2.2 3.3 |
|
| 77 |
1.1 2.2 3.3 4.4 5.5 |
|
| 80 |
1.1 2.2 3.3 |
|
| 83 |
1.1 2.2 3.3 |
|
| 84 |
1.1 2.2 3.3 |