Add guard clauses to improve readability
Refactor fetchRefsForEvent removing nested clauses to improve
readability
Change-Id: Ic926fd6da0964d6ca47495b67467837e55025d6b
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/StreamEventListener.java b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/StreamEventListener.java
index c1ffa44..a2cb7c1 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/StreamEventListener.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/StreamEventListener.java
@@ -79,33 +79,36 @@
}
public void fetchRefsForEvent(Event event) throws AuthException, PermissionBackendException {
- if (!instanceId.equals(event.instanceId)) {
- PullReplicationApiRequestMetrics metrics = metricsProvider.get();
- metrics.start(event);
- if (event instanceof RefUpdatedEvent) {
- RefUpdatedEvent refUpdatedEvent = (RefUpdatedEvent) event;
- if (!isProjectDelete(refUpdatedEvent)) {
- fetchRefsAsync(
- refUpdatedEvent.getRefName(),
- refUpdatedEvent.instanceId,
- refUpdatedEvent.getProjectNameKey(),
- metrics);
- }
+ if (instanceId.equals(event.instanceId)) {
+ return;
+ }
+
+ PullReplicationApiRequestMetrics metrics = metricsProvider.get();
+ metrics.start(event);
+ if (event instanceof RefUpdatedEvent) {
+ RefUpdatedEvent refUpdatedEvent = (RefUpdatedEvent) event;
+ if (isProjectDelete(refUpdatedEvent)) {
+ return;
}
- if (event instanceof ProjectCreatedEvent) {
- ProjectCreatedEvent projectCreatedEvent = (ProjectCreatedEvent) event;
- try {
- projectInitializationAction.initProject(getProjectRepositoryName(projectCreatedEvent));
- fetchRefsAsync(
- FetchOne.ALL_REFS,
- projectCreatedEvent.instanceId,
- projectCreatedEvent.getProjectNameKey(),
- metrics);
- } catch (AuthException | PermissionBackendException e) {
- logger.atSevere().withCause(e).log(
- "Cannot initialise project:%s", projectCreatedEvent.projectName);
- throw e;
- }
+
+ fetchRefsAsync(
+ refUpdatedEvent.getRefName(),
+ refUpdatedEvent.instanceId,
+ refUpdatedEvent.getProjectNameKey(),
+ metrics);
+ } else if (event instanceof ProjectCreatedEvent) {
+ ProjectCreatedEvent projectCreatedEvent = (ProjectCreatedEvent) event;
+ try {
+ projectInitializationAction.initProject(getProjectRepositoryName(projectCreatedEvent));
+ fetchRefsAsync(
+ FetchOne.ALL_REFS,
+ projectCreatedEvent.instanceId,
+ projectCreatedEvent.getProjectNameKey(),
+ metrics);
+ } catch (AuthException | PermissionBackendException e) {
+ logger.atSevere().withCause(e).log(
+ "Cannot initialise project:%s", projectCreatedEvent.projectName);
+ throw e;
}
}
}