29
29
import java .util .concurrent .TimeUnit ;
30
30
31
31
import static java .util .Objects .requireNonNull ;
32
+ import static org .junit .jupiter .api .Assertions .assertEquals ;
32
33
import static org .junit .jupiter .api .Assertions .assertNotNull ;
33
34
import static org .mockito .Mockito .*;
34
35
35
36
@ QuarkusTest
36
37
@ TestSecurity (user = "test-user" )
37
38
class AsyncWebsocketResourceTest {
38
- private static final LinkedBlockingDeque <ValidationError > errors = new LinkedBlockingDeque <>();
39
+ private static final LinkedBlockingDeque <ValidationError > validationErrors = new LinkedBlockingDeque <>();
39
40
40
41
@ InjectMock
41
42
private SclValidatorService sclValidatorService ;
42
43
43
- @ TestHTTPResource ("/validate-ws/v1/SCD" )
44
+ @ TestHTTPResource ("/compas-scl-validator/ validate-ws/v1/SCD" )
44
45
private URI uri ;
45
46
46
47
@ Test
@@ -56,7 +57,8 @@ public void updateSCL_WhenCalled_ThenExpectedResponseIsRetrieved() throws Except
56
57
try (Session session = ContainerProvider .getWebSocketContainer ().connectToServer (Client .class , uri )) {
57
58
session .getAsyncRemote ().sendText (encoder .encode (request ));
58
59
59
- assertNotNull (errors .poll (10 , TimeUnit .SECONDS ));
60
+ assertNotNull (validationErrors .poll (10 , TimeUnit .SECONDS ));
61
+ assertEquals (0 , validationErrors .size ());
60
62
verify (sclValidatorService , times (1 )).validate (sclFileTye , request .getSclData ());
61
63
}
62
64
}
@@ -65,7 +67,7 @@ public void updateSCL_WhenCalled_ThenExpectedResponseIsRetrieved() throws Except
65
67
public static class Client {
66
68
@ OnMessage
67
69
public void onMessage (SclValidateResponse response ) {
68
- errors .addAll (response .getValidationErrorList ());
70
+ validationErrors .addAll (response .getValidationErrorList ());
69
71
}
70
72
}
71
73
0 commit comments