Skip to content

Commit dfd2f9d

Browse files
committed
For hooks. Get by project id instead of customer name and project naame
1 parent a1c6d49 commit dfd2f9d

File tree

10 files changed

+20
-22
lines changed

10 files changed

+20
-22
lines changed

src/main/java/com/redhat/labs/lodestar/model/pagination/PagedCategoryResults.java

Lines changed: 0 additions & 12 deletions
This file was deleted.

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ public Response removeEngagement(@HeaderParam(value = "x-notification-token") St
107107

108108
if(hook.wasProjectDeleted()) {
109109
LOGGER.debug("Remove engagement customer {} proj {}", hook.getCustomerName(), hook.getEngagementName());
110-
Engagement engagement = engagementService.getByCustomerAndProjectName( hook.getCustomerName(), hook.getEngagementName());
110+
Engagement engagement = engagementService.getByProjectId(hook.getProjectId());
111111

112112
engagementService.deleteEngagement(engagement.getUuid());
113113
return Response.status(204).build();

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,10 @@ public interface EngagementApiClient {
3636
@Path("{uuid}")
3737
Response getEngagementHead(@PathParam("uuid") String uuid);
3838

39+
@GET
40+
@Path("project/{id}")
41+
Engagement getEngagementByProject(@PathParam("id") int projectId);
42+
3943
@GET
4044
@Path("customer/{customer}/engagement/{engagement}")
4145
Engagement getEngagement(@PathParam("customer") String customer, @PathParam("engagement") String engagementName);

src/main/java/com/redhat/labs/lodestar/service/EngagementService.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,7 @@ public Response getBySubdomain(String engagementUuid, String subdomain) {
264264
public void updateStatusAndCommits(Hook hook) {
265265
LOGGER.debug("Hook for {} {}", hook.getCustomerName(), hook.getEngagementName());
266266

267-
Engagement engagement = getByCustomerAndProjectName(hook.getCustomerName(), hook.getEngagementName());
267+
Engagement engagement = engagementApiClient.getEngagementByProject(hook.getProjectId());
268268

269269
// send update status event
270270
if (hook.didFileChange(statusFile)) {
@@ -294,8 +294,7 @@ public void updateStatusAndCommits(Hook hook) {
294294

295295

296296
/**
297-
* Needed for webhooks that don't present uuids
298-
*
297+
*
299298
* @param customerName customer name
300299
* @param engagementName project name
301300
* @return engagement an engagement
@@ -304,6 +303,10 @@ public Engagement getByCustomerAndProjectName(String customerName, String engage
304303
return engagementApiClient.getEngagement(customerName, engagementName);
305304
}
306305

306+
public Engagement getByProjectId(int projectId) {
307+
return engagementApiClient.getEngagementByProject(projectId);
308+
}
309+
307310
public Map<EngagementState, Integer> getEngagementCountByStatus(Instant currentTime) {
308311
return engagementApiClient.getEngagementCounts();
309312
}

src/test/java/com/redhat/labs/lodestar/resource/EngagementResourceV2GetTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import com.google.common.collect.Lists;
1818
import com.redhat.labs.lodestar.model.filter.ListFilterOptions;
1919
import com.redhat.labs.lodestar.model.filter.SortOrder;
20-
import com.redhat.labs.lodestar.model.pagination.PagedCategoryResults;
2120
import com.redhat.labs.lodestar.model.pagination.PagedEngagementResults;
2221
import com.redhat.labs.lodestar.model.pagination.PagedStringResults;
2322
import com.redhat.labs.lodestar.utils.IntegrationTestHelper;

src/test/java/com/redhat/labs/lodestar/resource/StatusResourceTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,9 @@ void setUp() {
6666
String uuid1 = "uuid1";
6767
Engagement engagement = Engagement.builder().uuid(uuid1).customerName(customer).projectName(exists).build();
6868

69-
Mockito.when(engagementApiClient.getEngagement(customer, exists)).thenReturn(engagement);
69+
Mockito.when(engagementApiClient.getEngagementByProject(8675309)).thenReturn(engagement);
7070
Mockito.when(engagementApiClient.getEngagement(uuid1)).thenReturn(engagement);
71-
Mockito.when(engagementApiClient.getEngagement(customer, "doesnotexist")).thenThrow(
71+
Mockito.when(engagementApiClient.getEngagementByProject(999)).thenThrow(
7272
new WebApplicationException(404)
7373
);
7474

@@ -95,7 +95,7 @@ void testStatusValid() {
9595
.then()
9696
.statusCode(200);
9797

98-
Mockito.verify(engagementApiClient).getEngagement("jello", "exists");
98+
Mockito.verify(engagementApiClient).getEngagementByProject(8675309);
9999
Mockito.verify(engagementApiClient).getEngagement("uuid1");
100100
Mockito.verify(engagementStatusApiClient).updateEngagementStatus("uuid1");
101101
Mockito.verify(engagementStatusApiClient).getEngagementStatus("uuid1");
@@ -116,7 +116,7 @@ void testStatusActivityUpdate() {
116116
.then()
117117
.statusCode(200);
118118

119-
Mockito.verify(engagementApiClient).getEngagement("jello", "exists");
119+
Mockito.verify(engagementApiClient).getEngagementByProject(8675309);
120120
Mockito.verify(activityApiClient).postHook(Mockito.any(Hook.class), Mockito.eq("ttttt"));
121121

122122
// verify(exactly(1), getRequestedFor(urlEqualTo("/api/activity/uuid/uuid1")));
@@ -147,7 +147,7 @@ void testDeletedHook() {
147147
.then()
148148
.statusCode(204);
149149

150-
Mockito.verify(engagementApiClient).getEngagement("jello", "exists");
150+
Mockito.verify(engagementApiClient).getEngagementByProject(8675309);
151151
Mockito.verify(engagementApiClient).deleteEngagement("uuid1");
152152
}
153153

src/test/resources/StatusDeleted.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"object_kind": "push",
33
"event_name": "project_deleted",
4+
"project_id": 8675309,
45
"project": {
56
"path_with_namespace": "butter/chomp/sandbox/jello/exists/iac",
67
"name_with_namespace": "butter / chomp / sandbox / jello / exists / iac"

src/test/resources/StatusDeletedNoEngagement.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"object_kind": "push",
33
"event_name": "project_deleted",
4+
"project_id": "999",
45
"project": {
56
"path_with_namespace": "butter/chomp/sandbox/jello/doesnotexist/iac",
67
"name_with_namespace": "butter / chomp / sandbox / jello / doesnotexist / iac"

src/test/resources/StatusReqValid.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"object_kind": "push",
33
"event_name": "push",
4+
"project_id": 8675309,
45
"project": {
56
"path_with_namespace": "butter/chomp/sandbox/jello/exists/iac",
67
"name_with_namespace": "butter / chomp / sandbox / jello / exists / iac"

src/test/resources/StatusReqValidNoUpdate.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"object_kind": "push",
33
"event_name": "push",
4+
"project_id": 8675309,
45
"project": {
56
"path_with_namespace": "butter/chomp/sandbox/jello/exists/iac",
67
"name_with_namespace": "butter / chomp / sandbox / jello / exists / iac"

0 commit comments

Comments
 (0)