Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore(dependency): upgrade spring boot from 2.7.x to 3.0.x and spring cloud from 2021.0.x to 2022.0.x #1133

Draft
wants to merge 1 commit into
base: master
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion rosco-core/rosco-core.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ dependencies {
implementation "io.spinnaker.kork:kork-web"
implementation "com.squareup.retrofit2:converter-jackson"
implementation "com.squareup.retrofit2:retrofit"
implementation "io.reactivex:rxjava"
implementation "io.reactivex.rxjava3:rxjava"
implementation "org.apache.commons:commons-exec"
implementation "org.apache.groovy:groovy"
implementation "org.springframework.boot:spring-boot-starter-web"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,9 @@ import org.springframework.beans.factory.annotation.Value
import org.springframework.context.ApplicationListener
import org.springframework.context.event.ContextRefreshedEvent
import org.springframework.stereotype.Component
import rx.functions.Action0
import rx.schedulers.Schedulers
import io.reactivex.rxjava3.functions.Action
import io.reactivex.rxjava3.schedulers.Schedulers
import io.reactivex.rxjava3.core.Observable

import java.util.concurrent.TimeUnit

Expand Down Expand Up @@ -79,7 +80,7 @@ class BakePoller implements ApplicationListener<ContextRefreshedEvent> {
Schedulers.io().createWorker().schedulePeriodically(
{
try {
rx.Observable.from(bakeStore.thisInstanceIncompleteBakeIds)
Observable.fromIterable(bakeStore.thisInstanceIncompleteBakeIds)
.subscribe(
{ String incompleteBakeId ->
try {
Expand All @@ -91,27 +92,27 @@ class BakePoller implements ApplicationListener<ContextRefreshedEvent> {
{
log.error("Update Error: ${it.message}")
},
{} as Action0
{} as Action
)
} catch (Exception e) {
log.error("Update Polling Error:", e)
}
} as Action0, 0, pollingIntervalSeconds, TimeUnit.SECONDS
} as Runnable, 0, pollingIntervalSeconds, TimeUnit.SECONDS
)

// Check _all_ rosco instances' incomplete bakes for staleness.
Schedulers.io().createWorker().schedulePeriodically(
{
try {
rx.Observable.from(bakeStore.allIncompleteBakeIds.entrySet())
Observable.fromIterable(bakeStore.allIncompleteBakeIds.entrySet())
.subscribe(
{ Map.Entry<String, Set<String>> entry ->
String roscoInstanceId = entry.key
Set<String> incompleteBakeIds = entry.value

if (roscoInstanceId != this.roscoInstanceId) {
try {
rx.Observable.from(incompleteBakeIds)
Observable.fromIterable(incompleteBakeIds)
.subscribe(
{ String statusId ->
BakeStatus bakeStatus = bakeStore.retrieveBakeStatusById(statusId)
Expand Down Expand Up @@ -148,7 +149,7 @@ class BakePoller implements ApplicationListener<ContextRefreshedEvent> {
{
log.error("Error: ${it.message}")
},
{} as Action0
{} as Action
)
} catch (Exception e) {
log.error("Zombie Killer Polling Error:", e)
Expand All @@ -158,12 +159,12 @@ class BakePoller implements ApplicationListener<ContextRefreshedEvent> {
{
log.error("Zombie Killer Error: ${it.message}")
},
{} as Action0
{} as Action
)
} catch (Exception e) {
log.error("Zombie Killer Polling Error:", e)
}
} as Action0, 0, orphanedJobPollingIntervalSeconds, TimeUnit.SECONDS
} as Runnable, 0, orphanedJobPollingIntervalSeconds, TimeUnit.SECONDS
)
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,9 @@ import org.apache.commons.exec.PumpStreamHandler
import org.apache.commons.exec.Watchdog
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.beans.factory.annotation.Value
import rx.Scheduler
import rx.functions.Action0
import rx.schedulers.Schedulers

import javax.annotation.PostConstruct
import io.reactivex.rxjava3.schedulers.Schedulers
import io.reactivex.rxjava3.core.Scheduler
import jakarta.annotation.PostConstruct
import java.util.concurrent.ConcurrentHashMap
import java.util.function.ToDoubleFunction

Expand All @@ -56,9 +54,9 @@ class JobExecutorLocal implements JobExecutor {
String jobId = jobRequest.jobId

scheduler.createWorker().schedule(
new Action0() {
new Runnable() {
@Override
public void call() {
void run() {
PumpStreamHandler pumpStreamHandler
ByteArrayOutputStream stdOut
ByteArrayOutputStream stdErr
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
import com.netflix.spinnaker.rosco.api.BakeRequest;
import com.netflix.spinnaker.rosco.providers.alicloud.AliCloudBakeHandler;
import com.netflix.spinnaker.rosco.providers.registry.CloudProviderBakeHandlerRegistry;
import jakarta.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import javax.annotation.PostConstruct;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.ComponentScan
import org.springframework.context.annotation.Configuration

import javax.annotation.PostConstruct
import jakarta.annotation.PostConstruct

@Configuration
@ConditionalOnProperty('aws.enabled')
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.ComponentScan
import org.springframework.context.annotation.Configuration

import javax.annotation.PostConstruct
import jakarta.annotation.PostConstruct

@Configuration
@ConditionalOnProperty('azure.enabled')
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.ComponentScan
import org.springframework.context.annotation.Configuration

import javax.annotation.PostConstruct
import jakarta.annotation.PostConstruct

@Configuration
@ConditionalOnProperty('docker.enabled')
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.ComponentScan
import org.springframework.context.annotation.Configuration

import javax.annotation.PostConstruct
import jakarta.annotation.PostConstruct

@Configuration
@ConditionalOnProperty('google.enabled')
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
import com.netflix.spinnaker.rosco.api.BakeRequest;
import com.netflix.spinnaker.rosco.providers.huaweicloud.HuaweiCloudBakeHandler;
import com.netflix.spinnaker.rosco.providers.registry.CloudProviderBakeHandlerRegistry;
import jakarta.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import javax.annotation.PostConstruct;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
import com.netflix.spinnaker.rosco.api.BakeRequest;
import com.netflix.spinnaker.rosco.providers.oracle.OCIBakeHandler;
import com.netflix.spinnaker.rosco.providers.registry.CloudProviderBakeHandlerRegistry;
import javax.annotation.PostConstruct;
import jakarta.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.ComponentScan;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
import com.netflix.spinnaker.rosco.api.BakeRequest.CloudProviderType;
import com.netflix.spinnaker.rosco.providers.registry.CloudProviderBakeHandlerRegistry;
import com.netflix.spinnaker.rosco.providers.tencentcloud.TencentCloudBakeHandler;
import jakarta.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import javax.annotation.PostConstruct;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package com.netflix.spinnaker.rosco.manifests;

import com.fasterxml.jackson.annotation.JsonCreator;
import jakarta.annotation.Nullable;
import java.util.Map;
import javax.annotation.Nullable;
import lombok.Data;

@Data
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

import com.netflix.spinnaker.kork.artifacts.model.Artifact;
import com.netflix.spinnaker.rosco.manifests.BakeManifestRequest;
import jakarta.annotation.Nullable;
import java.util.List;
import javax.annotation.Nullable;
import lombok.Data;
import lombok.EqualsAndHashCode;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ import org.springframework.scheduling.annotation.EnableScheduling
import org.springframework.web.filter.ShallowEtagHeaderFilter
import com.netflix.spinnaker.kork.boot.DefaultPropertiesBuilder

import javax.servlet.Filter
import jakarta.servlet.Filter

@Configuration
@ComponentScan([
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
/*
/*
* Copyright 2016 Google, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License")
Expand Down Expand Up @@ -26,11 +26,11 @@ import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.core.Ordered
import org.springframework.web.servlet.config.annotation.InterceptorRegistry
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer

@Configuration
@CompileStatic
public class WebConfig extends WebMvcConfigurerAdapter {
public class WebConfig implements WebMvcConfigurer {

@Autowired
Registry registry
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@ package com.netflix.spinnaker.rosco.filters

import org.springframework.stereotype.Component

import javax.servlet.*
import javax.servlet.http.HttpServletResponse
import jakarta.servlet.*
import jakarta.servlet.http.HttpServletResponse

@Component
public class SimpleCORSFilter implements Filter {
Expand Down
Loading