Skip to content

Commit

Permalink
chore(spotless): upgrade spinnaker gradle plugin (#984)
Browse files Browse the repository at this point in the history
This includes updates to google-java-format and ktlint, so requires some
formatting changes. These were made with a simple `./gradlew spotlessApply`.
  • Loading branch information
plumpy authored Jul 29, 2020
1 parent b344d33 commit bfaf991
Show file tree
Hide file tree
Showing 8 changed files with 60 additions and 37 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,8 @@ public List<Pipeline> getMatchingPipelines(T event, PipelineCache pipelineCache)
return supportedTriggerTypes().stream()
.flatMap(
triggerType ->
Optional.ofNullable(triggers.get(triggerType)).orElse(Collections.emptyList())
Optional.ofNullable(triggers.get(triggerType))
.orElse(Collections.emptyList())
.stream())
.filter(this::isValidTrigger)
.filter(matchTriggerFor(event))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,7 @@ protected Function<Trigger, Trigger> buildTrigger(PluginEvent event) {
return trigger -> {
String pluginEventType = getPluginEventType(event);

return trigger
.toBuilder()
return trigger.toBuilder()
.pluginEventType(pluginEventType)
.pluginId(event.getContent().getPluginId())
.description(event.getContent().getDescription())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,19 +45,15 @@ public class GooglePubsubMonitor implements PollingMonitor {
@PreDestroy
private void closeAsyncConnections() {
log.info("Closing async connections for Google Pubsub subscribers");
pubsubSubscribers
.subscribersMatchingType(PubsubSystem.GOOGLE)
.parallelStream()
pubsubSubscribers.subscribersMatchingType(PubsubSystem.GOOGLE).parallelStream()
.forEach(this::closeConnection);
}

@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
// TODO(jacobkiefer): Register Echo as enabled on startup.
log.info("Starting async connections for Google Pubsub subscribers");
pubsubSubscribers
.subscribersMatchingType(PubsubSystem.GOOGLE)
.parallelStream()
pubsubSubscribers.subscribersMatchingType(PubsubSystem.GOOGLE).parallelStream()
.forEach(this::openConnection);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,5 +68,6 @@ class SpinnakerInstanceDataProvider(private val config: TelemetryConfigProps, pr

private fun getProtoDeploymentType(type: String): DeploymentMethod.Type =
DeploymentMethod.Type.valueOf(
DeploymentMethod.Type.getDescriptor().findMatchingValue(type))
DeploymentMethod.Type.getDescriptor().findMatchingValue(type)
)
}
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,8 @@ class ExecutionDataProviderTest {

val echoEvent = createLoggableEvent()
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.id).isEmpty()
expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.UNKNOWN)
Expand All @@ -59,7 +60,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.id).isNotEmpty()
expectThat(statsEvent.execution.id).isNotEqualTo("myExecutionId")
Expand All @@ -74,7 +76,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.PIPELINE)
}
Expand All @@ -88,7 +91,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.ORCHESTRATION)
}
Expand All @@ -102,7 +106,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.UNKNOWN)
}
Expand All @@ -120,7 +125,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.MANAGED_PIPELINE_TEMPLATE_V1)
}
Expand All @@ -138,7 +144,8 @@ class ExecutionDataProviderTest {
val echoEvent = createEventWithExecutionData(executionData)

val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.type).isEqualTo(Execution.Type.MANAGED_PIPELINE_TEMPLATE_V2)
}
Expand All @@ -154,7 +161,8 @@ class ExecutionDataProviderTest {
)
val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.status).isEqualTo(status)
}
Expand All @@ -172,7 +180,8 @@ class ExecutionDataProviderTest {
)
val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.trigger.type).isEqualTo(triggerType)
}
Expand All @@ -194,14 +203,16 @@ class ExecutionDataProviderTest {

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(1)
val stage = statsEvent.execution.stagesList[0]
expectThat(stage.status).isEqualTo(Status.BUFFERED)
expectThat(stage.type).isEqualTo("myStageType")
expectThat(stage.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build()
)
}

@Test
Expand Down Expand Up @@ -235,27 +246,31 @@ class ExecutionDataProviderTest {

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(3)

val stage1 = statsEvent.execution.stagesList[0]
expectThat(stage1.status).isEqualTo(Status.BUFFERED)
expectThat(stage1.type).isEqualTo("myStageType1")
expectThat(stage1.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build()
)

val stage2 = statsEvent.execution.stagesList[1]
expectThat(stage2.status).isEqualTo(Status.REDIRECT)
expectThat(stage2.type).isEqualTo("myStageType2")
expectThat(stage2.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.AWS).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.AWS).build()
)

val stage3 = statsEvent.execution.stagesList[2]
expectThat(stage3.status).isEqualTo(Status.PAUSED)
expectThat(stage3.type).isEqualTo("myStageType3")
expectThat(stage3.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.APPENGINE).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.APPENGINE).build()
)
}

@Test
Expand All @@ -277,27 +292,31 @@ class ExecutionDataProviderTest {

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(3)

val stage1 = statsEvent.execution.stagesList[0]
expectThat(stage1.status).isEqualTo(Status.BUFFERED)
expectThat(stage1.type).isEqualTo("myStageType")
expectThat(stage1.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.GCE).build()
)

val stage2 = statsEvent.execution.stagesList[1]
expectThat(stage2.status).isEqualTo(Status.BUFFERED)
expectThat(stage2.type).isEqualTo("myStageType")
expectThat(stage2.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.AWS).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.AWS).build()
)

val stage3 = statsEvent.execution.stagesList[2]
expectThat(stage3.status).isEqualTo(Status.BUFFERED)
expectThat(stage3.type).isEqualTo("myStageType")
expectThat(stage3.cloudProvider).isEqualTo(
CloudProvider.newBuilder().setId(CloudProvider.ID.APPENGINE).build())
CloudProvider.newBuilder().setId(CloudProvider.ID.APPENGINE).build()
)
}

@Test
Expand All @@ -314,7 +333,8 @@ class ExecutionDataProviderTest {

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(1)
val stage = statsEvent.execution.stagesList[0]
Expand All @@ -335,7 +355,8 @@ class ExecutionDataProviderTest {

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(1)
val stage = statsEvent.execution.stagesList[0]
Expand All @@ -351,13 +372,15 @@ class ExecutionDataProviderTest {
val executionData = mapOf(
"stages" to listOf(
mapOf(
"context" to mapOf("cloudProvider" to cloudProviderId.toString()))
"context" to mapOf("cloudProvider" to cloudProviderId.toString())
)
)
)

val echoEvent = createEventWithExecutionData(executionData)
val statsEvent = ExecutionDataProvider().populateData(
echoEvent, StatsEvent.getDefaultInstance())
echoEvent, StatsEvent.getDefaultInstance()
)

expectThat(statsEvent.execution.stagesList).hasSize(1)
val stage = statsEvent.execution.stagesList[0]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,8 @@ class PipelineCountsDataProviderTest {

val result = dataProvider.populateData(
echoEventForApplication("app2"),
StatsEvent.getDefaultInstance())
StatsEvent.getDefaultInstance()
)

expectThat(result.spinnakerInstance.pipelineCount).isEqualTo(5)
expectThat(result.application.pipelineCount).isEqualTo(3)
Expand All @@ -94,7 +95,8 @@ class PipelineCountsDataProviderTest {

val result = dataProvider.populateData(
echoEventForApplication("app2"),
StatsEvent.getDefaultInstance())
StatsEvent.getDefaultInstance()
)

// I don't particularly care if it counts the broken pipeline or not.
expectThat(result.spinnakerInstance.pipelineCount)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,8 @@ public GitlabWehbookEventHandler() {

public boolean handles(String source) {
return "gitlab".equals(source);
};
}
;

public boolean shouldSendEvent(Event event) {
return true;
Expand Down
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ fiatVersion=1.22.0
korkVersion=7.56.0
kotlinVersion=1.3.71
org.gradle.parallel=true
spinnakerGradleVersion=8.3.0
spinnakerGradleVersion=8.4.0

# To enable a composite reference to a project, set the
# project property `'<projectName>Composite=true'`.
Expand Down

0 comments on commit bfaf991

Please sign in to comment.