[GitHub] [incubator-dlab] bhliva commented on a change in pull request #489: Added project feature

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@dlab.apache.org
For additional commands, e-mail: dev-help@dlab.apache.org