|
2 | 2 |
|
3 | 3 | import de.tum.cit.aet.helios.github.GitHubMessageHandler; |
4 | 4 | import de.tum.cit.aet.helios.gitrepo.github.GitHubRepositorySyncService; |
| 5 | +import de.tum.cit.aet.helios.releaseinfo.release.ReleaseRepository; |
| 6 | +import lombok.RequiredArgsConstructor; |
5 | 7 | import lombok.extern.log4j.Log4j2; |
6 | 8 | import org.kohsuke.github.GHEvent; |
7 | 9 | import org.kohsuke.github.GHEventPayload; |
| 10 | +import org.kohsuke.github.GHEventPayload.Release; |
8 | 11 | import org.springframework.stereotype.Component; |
9 | 12 |
|
10 | 13 | @Component |
11 | 14 | @Log4j2 |
| 15 | +@RequiredArgsConstructor |
12 | 16 | public class GitHubReleaseMessageHandler extends GitHubMessageHandler<GHEventPayload.Release> { |
13 | 17 |
|
14 | 18 | private final GitHubReleaseSyncService releaseSyncService; |
15 | 19 | private final GitHubRepositorySyncService repositorySyncService; |
16 | | - |
17 | | - private GitHubReleaseMessageHandler( |
18 | | - GitHubReleaseSyncService releaseSyncService, |
19 | | - GitHubRepositorySyncService repositorySyncService) { |
20 | | - super(GHEventPayload.Release.class); |
21 | | - this.releaseSyncService = releaseSyncService; |
22 | | - this.repositorySyncService = repositorySyncService; |
23 | | - } |
| 20 | + private final ReleaseRepository releaseRepository; |
24 | 21 |
|
25 | 22 | @Override |
26 | | - protected void handleEvent(GHEventPayload.Release eventPayload) { |
27 | | - if (eventPayload.getAction().equals("created")) { |
28 | | - return; |
29 | | - } |
| 23 | + protected void handleInstalledRepositoryEvent(GHEventPayload.Release eventPayload) { |
30 | 24 | log.info( |
31 | 25 | "Received release event for repository: {}, release: {}, action: {}", |
32 | 26 | eventPayload.getRepository().getFullName(), |
33 | 27 | eventPayload.getRelease().getName(), |
34 | 28 | eventPayload.getAction()); |
35 | | - repositorySyncService.processRepository(eventPayload.getRepository()); |
36 | | - // We don't need to handle the deleted action here, as pull requests are not deleted |
37 | | - releaseSyncService.processRelease(eventPayload.getRelease()); |
| 29 | + if (eventPayload.getAction().equals("created") |
| 30 | + || eventPayload.getAction().equals("edited") |
| 31 | + || eventPayload.getAction().equals("published")) { |
| 32 | + if (eventPayload.getRelease().isDraft()) { |
| 33 | + return; |
| 34 | + } |
| 35 | + repositorySyncService.processRepository(eventPayload.getRepository()); |
| 36 | + releaseSyncService.processRelease(eventPayload.getRelease()); |
| 37 | + } else if (eventPayload.getAction().equals("deleted")) { |
| 38 | + releaseRepository.deleteById(eventPayload.getRelease().getId()); |
| 39 | + } |
| 40 | + } |
| 41 | + |
| 42 | + @Override |
| 43 | + protected Class<Release> getPayloadClass() { |
| 44 | + return GHEventPayload.Release.class; |
38 | 45 | } |
39 | 46 |
|
40 | 47 | @Override |
41 | | - protected GHEvent getHandlerEvent() { |
| 48 | + protected GHEvent getPayloadType() { |
42 | 49 | return GHEvent.RELEASE; |
43 | 50 | } |
44 | 51 | } |
0 commit comments