bhliva commented on a change in pull request #489: Added project feature
URL: https://github.com/apache/incubator-dlab/pull/489#discussion_r357061110
##########
File path:
integration-tests-cucumber/src/test/java/dlab/project/ProjectSteps.java
##########
@@ -1,35 +1,117 @@
package dlab.project;
+
+import com.jayway.restassured.http.ContentType;
+import com.jayway.restassured.response.Response;
+import com.jayway.restassured.specification.RequestSpecification;
import cucumber.api.java.en.And;
import cucumber.api.java.en.Given;
import cucumber.api.java.en.Then;
import cucumber.api.java.en.When;
+import dlab.util.KeycloakUtil;
+import org.apache.dlab.dto.CreateProjectDTO;
+import org.apache.dlab.dto.EndpointStatusDTO;
+import org.apache.dlab.dto.ProjectKeyDTO;
+import org.apache.dlab.dto.ProjectStatusDTO;
+import org.apache.dlab.util.JacksonMapper;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.time.LocalDateTime;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Optional;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+import static com.jayway.restassured.RestAssured.given;
+import static dlab.Constants.API_URI;
+import static dlab.Constants.LOCAL_ENDPOINT;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.core.IsEqual.equalTo;
import static org.junit.Assert.fail;
public class ProjectSteps {
- @Then("User wait maximum {string} minutes while project is creating")
- public void userWaitMaximumMinutesWhileProjectIsCreating(String arg0) {
- fail("Not implemented");
+ private RequestSpecification createProjectRequest;
+ private RequestSpecification generateKeysRequest;
+ private Response response;
+ private String projectName;
+
+
+ @Given("There is no project with name {string} in DLab")
+ public void thereIsNoProjectWithNameInDLab(String projectName) throws
URISyntaxException {
+ assertThat(authenticatedRequest()
+ .get(new URI(API_URI + "project/" +
projectName))
+ .getStatusCode(), equalTo(404));
}
@When("User send create new project request")
public void userSendCreateNewProjectRequest() {
+ response = createProjectRequest.post(API_URI + "project");
}
- @And("User try to create new project with name {string}, endpoints
{string}, groups {string} " +
- "and key {string}")
- public void
userTryToCreateNewProjectWithNameEndpointsGroupsAndKey(String arg0, String
arg1, String arg2,
-
String arg3) {
- }
+ @And("User try to create new project with name {string}, endpoints
{string}, groups {string} and publicKey")
+ public void
userTryToCreateNewProjectWithNameEndpointsGroupsAndKey(String projectName,
String endpoints,
+
String groups) {
+ this.projectName = projectName;
+ String publicKey = generateKeysRequest.post(API_URI +
"project/keys")
+ .getBody().as(ProjectKeyDTO.class)
+ .getPublicKey();
+ Set<String> endpointSet = getSetFromString(endpoints);
+ Set<String> groupSet = getSetFromString(groups);
+
+ createProjectRequest = given()
+ .body(JacksonMapper.marshall(new
CreateProjectDTO(projectName, groupSet, endpointSet, publicKey, projectName)))
+ .auth()
+ .oauth2(KeycloakUtil.getToken())
+ .contentType(ContentType.JSON);
- @Given("There is no project with name {string} in DLab")
- public void thereIsNoProjectWithNameInDLab(String arg0) {
}
@Then("Status code is {int}")
- public void statusCodeIs(int arg0) {
+ public void statusCodeIs(int code) {
+ assertThat(response.getStatusCode(), equalTo(code));
+ }
+
+ @Then("User wait maximum {int} minutes while project is creating")
+ public void userWaitMaximumMinutesWhileProjectIsCreating(int timeout)
throws URISyntaxException, InterruptedException {
+ boolean isRunning = false;
+ LocalDateTime withTimeout =
LocalDateTime.now().plusMinutes(timeout);
+ while (!isRunning && LocalDateTime.now().isBefore(withTimeout))
{
+ ProjectStatusDTO projectDTO = authenticatedRequest()
+ .get(new URI(API_URI + "project/" +
projectName))
+ .getBody().as(ProjectStatusDTO.class);
+
+ assertThat(projectDTO.getName(), equalTo(projectName));
+
+ Optional<EndpointStatusDTO> localEndpoint =
projectDTO.getEndpoints()
+ .stream()
+ .filter(e ->
LOCAL_ENDPOINT.equals(e.getName()))
+ .findAny();
+ isRunning = localEndpoint.isPresent() &&
EndpointStatusDTO.Status.RUNNING == localEndpoint.get().getStatus();
+ TimeUnit.MINUTES.sleep(1);
+ }
+
+ if (!isRunning) {
+ fail("Timeout for project status check reached!");
+ }
+ }
+
+ @And("User try to generate new publicKey")
+ public void userTryToGenerateNewPublicKey() {
+ generateKeysRequest = given().auth()
Review comment:
make a call here
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
