Skip to content
Snippets Groups Projects
Commit 45f592cd authored by Jan Zickermann's avatar Jan Zickermann
Browse files

KOP-2139 KOP-2467 XtaClientITCase: Create extension for dev server setup

parent 56f41a0d
No related branches found
No related tags found
No related merge requests found
...@@ -68,6 +68,7 @@ class XtaClientITCase { ...@@ -68,6 +68,7 @@ class XtaClientITCase {
var result = client.getMessagesMetadata(CLIENT_IDENTIFIER2); var result = client.getMessagesMetadata(CLIENT_IDENTIFIER2);
assertThat(result.pendingMessageCount()).isOne(); assertThat(result.pendingMessageCount()).isOne();
} }
@DisplayName("should return no pending message for client1") @DisplayName("should return no pending message for client1")
...@@ -82,7 +83,5 @@ class XtaClientITCase { ...@@ -82,7 +83,5 @@ class XtaClientITCase {
} }
} }
...@@ -16,12 +16,15 @@ import de.ozgcloud.xta.client.model.Identifier; ...@@ -16,12 +16,15 @@ import de.ozgcloud.xta.client.model.Identifier;
import de.ozgcloud.xta.client.model.XtaMessageMetaData; import de.ozgcloud.xta.client.model.XtaMessageMetaData;
import de.ozgcloud.xta.client.model.XtaMessageMetaDataTestFactory; import de.ozgcloud.xta.client.model.XtaMessageMetaDataTestFactory;
import de.ozgcloud.xta.client.model.XtaMessageTestFactory; import de.ozgcloud.xta.client.model.XtaMessageTestFactory;
import genv3.de.xoev.transport.xta.x211.ParameterIsNotValidException;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
@Getter @Getter
@Setter @Setter
@Slf4j
public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEachCallback { public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEachCallback {
private XtaClient client; private XtaClient client;
...@@ -81,7 +84,7 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach ...@@ -81,7 +84,7 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
@SneakyThrows @SneakyThrows
void sendTestMessageToClient2(Identifier author, Identifier reader) { void sendTestMessageToClient2(Identifier author, Identifier reader) {
var messageId = service.createMessageId(author); var messageId = service.createMessageId(author);
try {
service.sendMessage(XtaMessageTestFactory.createBuilder() service.sendMessage(XtaMessageTestFactory.createBuilder()
.metaData(XtaMessageMetaDataTestFactory.createBuilder() .metaData(XtaMessageMetaDataTestFactory.createBuilder()
.authorIdentifier(author) .authorIdentifier(author)
...@@ -90,6 +93,10 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach ...@@ -90,6 +93,10 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
.build()) .build())
.build() .build()
); );
} catch (ParameterIsNotValidException e) {
log.error("Failed to send test message to client2: {}", e.getFaultInfo().getErrorCode().getName());
throw e;
}
} }
@SneakyThrows @SneakyThrows
...@@ -103,7 +110,6 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach ...@@ -103,7 +110,6 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
} }
} }
@SneakyThrows @SneakyThrows
private static byte[] readBytesFromFile(String path) { private static byte[] readBytesFromFile(String path) {
return Files.toByteArray(new File(path)); return Files.toByteArray(new File(path));
...@@ -117,5 +123,4 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach ...@@ -117,5 +123,4 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
return client.deriveIdentifier(CLIENT_IDENTIFIER2); return client.deriveIdentifier(CLIENT_IDENTIFIER2);
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment