add migration api (#173)

Author: mcanoy

src/main/java/com/redhat/labs/lodestar/resource/EngagementResource.java

@@ -26,7 +26,6 @@
 import javax.ws.rs.core.UriInfo;
 
 import com.redhat.labs.lodestar.model.EngagementUserSummary;
-import com.redhat.labs.lodestar.service.ActivityService;
 import com.redhat.labs.lodestar.service.ParticipantService;
 import org.eclipse.microprofile.jwt.JsonWebToken;
 import org.eclipse.microprofile.openapi.annotations.Operation;
@@ -71,9 +70,6 @@ public class EngagementResource {
 
     @Inject
     EngagementService engagementService;
-
-    @Inject
-    ActivityService activityService;
 
     @Inject
     ConfigService configService;

src/main/java/com/redhat/labs/lodestar/resource/MigrationResource.java

@@ -0,0 +1,49 @@
+package com.redhat.labs.lodestar.resource;
+
+import com.redhat.labs.lodestar.rest.client.GitApiApiClient;
+import org.eclipse.microprofile.openapi.annotations.security.SecurityRequirement;
+import org.eclipse.microprofile.openapi.annotations.tags.Tag;
+import org.eclipse.microprofile.rest.client.inject.RestClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.inject.Inject;
+import javax.ws.rs.PUT;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.QueryParam;
+import javax.ws.rs.core.Response;
+import java.util.List;
+
+@Path("/engagements/migrate")
+@Tag(name = "Migration", description = "Migration services")
+public class MigrationResource {
+    private static final Logger LOGGER = LoggerFactory.getLogger(MigrationResource.class);
+
+    @Inject
+    @RestClient
+    GitApiApiClient migrationApiClient;
+
+    @PUT
+    @SecurityRequirement(name = "jwt")
+    @Produces("application/json")
+    public Response migrate(@QueryParam(value = "participants") boolean migrateParticipants,
+                            @QueryParam("artifacts") boolean migrateArtifacts,
+                            @QueryParam("projects") boolean migrateUuids,
+                            @QueryParam("hosting") boolean migrateHosting,
+                            @QueryParam("engagements") boolean migrateEngagements,
+                            @QueryParam("overwrite") boolean overwrite,
+                            @QueryParam("dryRun") boolean dryRun,
+                            @QueryParam("uuids") List<String> uuids) {
+
+        try {
+            migrationApiClient.migrate(migrateUuids, migrateParticipants, migrateArtifacts, migrateHosting, migrateEngagements,
+                    overwrite, dryRun, uuids);
+        } catch (Exception ex) {
+            LOGGER.error("Migration did not complete successfully", ex);
+            return Response.status(Response.Status.BAD_REQUEST).entity("{ \"message\": \"Migration did not complete successfully\"}").build();
+        }
+
+        return Response.ok().build();
+    }
+}

src/main/java/com/redhat/labs/lodestar/rest/client/GitApiApiClient.java

@@ -0,0 +1,29 @@
+package com.redhat.labs.lodestar.rest.client;
+
+import com.redhat.labs.lodestar.exception.mapper.ServiceResponseMapper;
+import org.eclipse.microprofile.rest.client.annotation.RegisterProvider;
+import org.eclipse.microprofile.rest.client.inject.RegisterRestClient;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.ws.rs.*;
+import javax.ws.rs.core.Response;
+import java.util.List;
+
+@ApplicationScoped
+@RegisterRestClient(configKey = "lodestar.git.api")
+@RegisterProvider(value = ServiceResponseMapper.class, priority = 50)
+@Produces("application/json")
+@Consumes("application/json")
+@Path("/api/migrate")
+public interface GitApiApiClient {
+
+    @PUT
+    Response migrate(@QueryParam(value = "participants") boolean migrateParticipants,
+                     @QueryParam("artifacts") boolean migrateArtifacts,
+                     @QueryParam("projects") boolean migrateUuids,
+                     @QueryParam("hosting") boolean migrateHosting,
+                     @QueryParam("engagements") boolean migrateEngagements,
+                     @QueryParam("overwrite") boolean overwrite,
+                     @QueryParam("dryRun") boolean dryRun,
+                     @QueryParam("uuids") List<String> uuids);
+}

src/main/resources/application.properties

@@ -49,7 +49,7 @@ quarkus.cache.caffeine.rbac-cache.expire-after-write=600S
 # Quarkus build properties
 quarkus.package.type=uber-jar
 
-lodestar.git.api/mp-rest/url=${GITLAB_API_URL:http://lodestar-git-api:8080}
+lodestar.git.api/mp-rest/url=${GIT_API_URL:http://lodestar-git-api:8080}
 lodestar.status.api/mp-rest/url=${STATUS_API_URL:http://lodestar-status:8080}
 lodestar.config.api/mp-rest/url=${CONFIG_API_URL:http://lodestar-config:8080}
 lodestar.activity.api/mp-rest/url=${ACTIVITY_API_URL:http://lodestar-activity:8080}

src/test/resources/application.properties

@@ -36,7 +36,6 @@ event.max.retries=2
 event.retry.delay.factor=1
 # git api
 
-lodestar.git.api/mp-rest/url=${LODESTAR_GITLAB_API_URL:http://lodestar-git-api:8080}
 lodestar.status.api/mp-rest/url=${LODESTAR_STATUS_API_URL:http://lodestar-status:8080}
 lodestar.config.api/mp-rest/url=${LODESTAR_CONFIG_API_URL:http://lodestar-config:8080}
 lodestar.activity.api/mp-rest/url=${LODESTAR_ACTIVITY_API_URL:http://lodestar-activity:8080}