package com.hubspot.singularity;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;

import com.hubspot.singularity.client.SingularityClient;
import java.util.Optional;
import name.falgout.jeffrey.testing.junit.guice.GuiceExtension;
import name.falgout.jeffrey.testing.junit.guice.IncludeModule;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;

@ExtendWith(GuiceExtension.class)
@IncludeModule(DockerTestModule.class)
public class SingularityDeployIT {
  private static final String REQUEST_ID = "deploy-it-request-run-once";

  @Test
  public void testDeploy(SingularityClient singularityClient) throws Exception {
    final SingularityRequest request = new SingularityRequestBuilder(
      REQUEST_ID,
      RequestType.RUN_ONCE
    )
      .setInstances(Optional.of(2))
      .build();

    final String deployId = Long.toString(System.currentTimeMillis());

    singularityClient.createOrUpdateSingularityRequest(request);

    final Optional<SingularityRequestParent> requestParent = singularityClient.getSingularityRequest(
      REQUEST_ID
    );
    assertTrue(requestParent.isPresent());
    assertEquals(request, requestParent.get().getRequest());

    final SingularityDeploy deploy = new SingularityDeployBuilder(REQUEST_ID, deployId)
      .setCommand(Optional.of("sleep 10"))
      .build();

    singularityClient.createDeployForSingularityRequest(
      REQUEST_ID,
      deploy,
      Optional.<Boolean>empty(),
      Optional.<String>empty()
    );

    Optional<DeployState> deployState = Optional.empty();
    for (int i = 0; i < 10; i++) {
      final Optional<SingularityDeployHistory> deployHistory = singularityClient.getHistoryForRequestDeploy(
        REQUEST_ID,
        deployId
      );
      if (
        deployHistory.isPresent() && deployHistory.get().getDeployResult().isPresent()
      ) {
        deployState =
          Optional.ofNullable(
            deployHistory.get().getDeployResult().get().getDeployState()
          );

        if (deployState.get().isDeployFinished()) {
          break;
        }
      }

      Thread.sleep(2000); // ghetto, i know.
    }

    assertEquals(Optional.of(DeployState.SUCCEEDED), deployState);
  }
}

@@ -2182,27 +2182,8 @@
 00);
- // ghetto, i know.
 %0A   

Update SingularityDeployIT.java