feat(spring): Add an option to monitor all @Scheduled methods in Spring Boot 3

CHANGELOG.md

@@ -9,6 +9,7 @@
 
 ### Features
 
+- Monitor every Spring `@Scheduled` method with Sentry Crons by setting `sentry.monitor-scheduled-tasks=true`, without adding `@SentryCheckIn` to each method. Sentry creates each monitor from the method's `@Scheduled` schedule. Exclude methods with `sentry.exclude-scheduled-tasks` ([#6275](https://github.com/getsentry/sentry-java/pull/6275))
 - Quartz `SentryJobListener` can send a monitor config derived from the trigger with check-ins, so Sentry creates or updates the monitor from code. Set the `sentry-upsert-monitor-config` job or trigger data key to `"true"` to send the schedule ([#6216](https://github.com/getsentry/sentry-java/pull/6216))
 - Send a monitor config derived from Spring `@Scheduled` with `@SentryCheckIn` check-ins, so Sentry creates or updates the monitor from code. Set `@SentryCheckIn(upsertMonitorConfig = true)` to send the schedule ([#6215](https://github.com/getsentry/sentry-java/pull/6215))
 

sentry-spring-boot-jakarta/api/sentry-spring-boot-jakarta.api

@@ -43,19 +43,23 @@ public class io/sentry/spring/boot/jakarta/SentryProperties : io/sentry/SentryOp
 	public fun <init> ()V
 	public fun getClients ()Lio/sentry/spring/boot/jakarta/SentryProperties$Clients;
 	public fun getExceptionResolverOrder ()I
+	public fun getExcludeScheduledTasks ()Ljava/util/List;
 	public fun getGraphql ()Lio/sentry/spring/boot/jakarta/SentryProperties$Graphql;
 	public fun getLogging ()Lio/sentry/spring/boot/jakarta/SentryProperties$Logging;
 	public fun getReactive ()Lio/sentry/spring/boot/jakarta/SentryProperties$Reactive;
 	public fun getUserFilterOrder ()Ljava/lang/Integer;
 	public fun isEnableAotCompatibility ()Z
 	public fun isKeepTransactionsOpenForAsyncResponses ()Z
+	public fun isMonitorScheduledTasks ()Z
 	public fun isUseGitCommitIdAsRelease ()Z
 	public fun setClients (Lio/sentry/spring/boot/jakarta/SentryProperties$Clients;)V
 	public fun setEnableAotCompatibility (Z)V
 	public fun setExceptionResolverOrder (I)V
+	public fun setExcludeScheduledTasks (Ljava/util/List;)V
 	public fun setGraphql (Lio/sentry/spring/boot/jakarta/SentryProperties$Graphql;)V
 	public fun setKeepTransactionsOpenForAsyncResponses (Z)V
 	public fun setLogging (Lio/sentry/spring/boot/jakarta/SentryProperties$Logging;)V
+	public fun setMonitorScheduledTasks (Z)V
 	public fun setReactive (Lio/sentry/spring/boot/jakarta/SentryProperties$Reactive;)V
 	public fun setUseGitCommitIdAsRelease (Z)V
 	public fun setUserFilterOrder (Ljava/lang/Integer;)V

sentry-spring-boot-jakarta/src/main/java/io/sentry/spring/boot/jakarta/SentryAutoConfiguration.java

@@ -26,9 +26,11 @@
 import io.sentry.spring.jakarta.SpringProfilesEventProcessor;
 import io.sentry.spring.jakarta.SpringSecuritySentryUserProvider;
 import io.sentry.spring.jakarta.cache.SentryCacheBeanPostProcessor;
+import io.sentry.spring.jakarta.checkin.SentryCheckInAdvice;
 import io.sentry.spring.jakarta.checkin.SentryCheckInAdviceConfiguration;
 import io.sentry.spring.jakarta.checkin.SentryCheckInPointcutConfiguration;
 import io.sentry.spring.jakarta.checkin.SentryQuartzConfiguration;
+import io.sentry.spring.jakarta.checkin.SentryScheduledCheckInPointcut;
 import io.sentry.spring.jakarta.exception.SentryCaptureExceptionParameterPointcutConfiguration;
 import io.sentry.spring.jakarta.exception.SentryExceptionParameterAdviceConfiguration;
 import io.sentry.spring.jakarta.kafka.SentryKafkaConsumerBeanPostProcessor;
@@ -49,11 +51,16 @@
 import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
+import org.aopalliance.aop.Advice;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.jetbrains.annotations.NotNull;
 import org.quartz.core.QuartzScheduler;
 import org.slf4j.MDC;
+import org.springframework.aop.Advisor;
+import org.springframework.aop.support.DefaultPointcutAdvisor;
 import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.config.BeanDefinition;
 import org.springframework.boot.autoconfigure.AutoConfigureBefore;
 import org.springframework.boot.autoconfigure.condition.AnyNestedCondition;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
@@ -73,6 +80,7 @@
 import org.springframework.context.annotation.Conditional;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
+import org.springframework.context.annotation.Role;
 import org.springframework.core.Ordered;
 import org.springframework.core.annotation.Order;
 import org.springframework.core.env.Environment;
@@ -309,6 +317,27 @@ static class SentryCheckInAspectsConfiguration {
       @Import(SentryCheckInPointcutConfiguration.class)
       @Open
       static class SentryCheckInPointcutAutoConfiguration {}
+
+      @Configuration(proxyBeanMethods = false)
+      @ConditionalOnProperty(name = "sentry.monitor-scheduled-tasks", havingValue = "true")
+      @Open
+      static class SentryScheduledCheckInConfiguration {
+        @Bean
+        @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
+        public @NotNull Advice sentryScheduledCheckInAdvice() {
+          return new SentryCheckInAdvice(ScopesAdapter.getInstance(), true);
+        }
+
+        @Bean
+        @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
+        public @NotNull Advisor sentryScheduledCheckInAdvisor(
+            final @NotNull @Qualifier("sentryScheduledCheckInAdvice") Advice advice,
+            final @NotNull SentryProperties sentryProperties) {
+          return new DefaultPointcutAdvisor(
+              new SentryScheduledCheckInPointcut(sentryProperties.getExcludeScheduledTasks()),
+              advice);
+        }
+      }
     }
 
     /** Registers beans specific to Spring MVC. */

sentry-spring-boot-jakarta/src/main/java/io/sentry/spring/boot/jakarta/SentryProperties.java

@@ -50,6 +50,15 @@ public class SentryProperties extends SentryOptions {
   /** Clients integration properties. */
   private @NotNull Clients clients = new Clients();
 
+  /** Monitor every {@code @Scheduled} method with Sentry Crons. */
+  private boolean monitorScheduledTasks = false;
+
+  /**
+   * {@code @Scheduled} methods not to monitor when {@code monitorScheduledTasks} is on, as {@code
+   * ClassName.methodName} or a regex matching it.
+   */
+  private @NotNull List<String> excludeScheduledTasks = new ArrayList<>();
+
   public boolean isUseGitCommitIdAsRelease() {
     return useGitCommitIdAsRelease;
   }
@@ -135,6 +144,22 @@ public void setClients(@NotNull Clients clients) {
     this.clients = clients;
   }
 
+  public boolean isMonitorScheduledTasks() {
+    return monitorScheduledTasks;
+  }
+
+  public void setMonitorScheduledTasks(boolean monitorScheduledTasks) {
+    this.monitorScheduledTasks = monitorScheduledTasks;
+  }
+
+  public @NotNull List<String> getExcludeScheduledTasks() {
+    return excludeScheduledTasks;
+  }
+
+  public void setExcludeScheduledTasks(@NotNull List<String> excludeScheduledTasks) {
+    this.excludeScheduledTasks = excludeScheduledTasks;
+  }
+
   @Open
   public static class Clients {
     /** Enable automatic instrumentation of Spring-managed OkHttp clients. Disabled by default. */

sentry-spring-boot-jakarta/src/test/kotlin/io/sentry/spring/boot/jakarta/SentryAutoConfigurationTest.kt

@@ -20,6 +20,7 @@ import io.sentry.NoOpTransportFactory
 import io.sentry.ProfileLifecycle
 import io.sentry.SamplingContext
 import io.sentry.Sentry
+import io.sentry.SentryEnvelope
 import io.sentry.SentryEvent
 import io.sentry.SentryIntegrationPackageStorage
 import io.sentry.SentryLevel
@@ -51,16 +52,20 @@ import io.sentry.transport.apache.ApacheHttpClientTransportFactory
 import jakarta.servlet.Filter
 import java.io.File
 import java.lang.RuntimeException
+import java.util.concurrent.TimeUnit
 import kotlin.test.Test
 import kotlin.test.assertEquals
 import kotlin.test.assertFalse
 import kotlin.test.assertTrue
 import org.aspectj.lang.ProceedingJoinPoint
 import org.assertj.core.api.Assertions.assertThat
 import org.mockito.internal.util.MockUtil.isMock
+import org.mockito.kotlin.after
 import org.mockito.kotlin.any
 import org.mockito.kotlin.anyOrNull
+import org.mockito.kotlin.argumentCaptor
 import org.mockito.kotlin.mock
+import org.mockito.kotlin.timeout
 import org.mockito.kotlin.verify
 import org.mockito.kotlin.whenever
 import org.quartz.JobExecutionContext
@@ -71,6 +76,7 @@ import org.quartz.core.QuartzScheduler
 import org.slf4j.MDC
 import org.springframework.aop.support.NameMatchMethodPointcut
 import org.springframework.boot.autoconfigure.AutoConfigurations
+import org.springframework.boot.autoconfigure.aop.AopAutoConfiguration
 import org.springframework.boot.autoconfigure.quartz.QuartzAutoConfiguration
 import org.springframework.boot.autoconfigure.quartz.SchedulerFactoryBeanCustomizer
 import org.springframework.boot.autoconfigure.web.servlet.WebMvcAutoConfiguration
@@ -85,6 +91,8 @@ import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.core.Ordered
 import org.springframework.core.annotation.Order
+import org.springframework.scheduling.annotation.EnableScheduling
+import org.springframework.scheduling.annotation.Scheduled
 import org.springframework.scheduling.quartz.SchedulerFactoryBean
 import org.springframework.security.core.context.SecurityContextHolder
 import org.springframework.web.client.RestClient
@@ -1089,6 +1097,44 @@ class SentryAutoConfigurationTest {
       }
   }
 
+  @Test
+  fun `does not monitor @Scheduled methods by default`() {
+    contextRunner.withPropertyValues("sentry.dsn=http://key@localhost/proj").run {
+      assertThat(it).doesNotHaveBean("sentryScheduledCheckInAdvisor")
+    }
+  }
+
+  @Test
+  fun `monitors @Scheduled methods when monitor-scheduled-tasks is enabled`() {
+    baseContextRunner
+      .withPropertyValues(
+        "sentry.dsn=http://key@localhost/proj",
+        "sentry.monitor-scheduled-tasks=true",
+        "sentry.exclude-scheduled-tasks[0]=SentryAutoConfigurationTest.ScheduledJobs.excluded",
+      )
+      .withConfiguration(AutoConfigurations.of(AopAutoConfiguration::class.java))
+      .withUserConfiguration(
+        MockTransportConfiguration::class.java,
+        ScheduledJobsConfiguration::class.java,
+      )
+      .run {
+        assertThat(it).hasBean("sentryScheduledCheckInAdvisor")
+        val transport = it.getBean(ITransport::class.java)
+        val captor = argumentCaptor<SentryEnvelope>()
+        verify(transport, timeout(5000).times(2)).send(any(), anyOrNull())
+        verify(transport, after(500).times(2)).send(captor.capture(), anyOrNull())
+        val payloads =
+          captor.allValues.map { envelope -> String(envelope.items.first().data, Charsets.UTF_8) }
+        assertThat(payloads).allMatch { payload ->
+          payload.contains(
+            "\"monitor_slug\":\"sentry-auto-configuration-test-scheduled-jobs-sync\""
+          )
+        }
+        assertThat(payloads[0]).contains("\"value\":1,\"unit\":\"hour\"")
+        assertThat(payloads[1]).contains("\"status\":\"ok\"")
+      }
+  }
+
   @Test
   fun `Sentry quartz job listener is added`() {
     contextRunner
@@ -1308,6 +1354,18 @@ class SentryAutoConfigurationTest {
     @Bean open fun sentryTransport() = transport
   }
 
+  @Configuration(proxyBeanMethods = false)
+  @EnableScheduling
+  open class ScheduledJobsConfiguration {
+    @Bean open fun scheduledJobs() = ScheduledJobs()
+  }
+
+  open class ScheduledJobs {
+    @Scheduled(fixedRate = 1, timeUnit = TimeUnit.HOURS) open fun sync() {}
+
+    @Scheduled(fixedRate = 1, timeUnit = TimeUnit.HOURS) open fun excluded() {}
+  }
+
   @Configuration(proxyBeanMethods = false)
   open class NoOpTransportConfiguration {
 

sentry-spring-jakarta/api/sentry-spring-jakarta.api

@@ -148,6 +148,7 @@ public abstract interface annotation class io/sentry/spring/jakarta/checkin/Sent
 public class io/sentry/spring/jakarta/checkin/SentryCheckInAdvice : org/aopalliance/intercept/MethodInterceptor, org/springframework/context/EmbeddedValueResolverAware {
 	public fun <init> ()V
 	public fun <init> (Lio/sentry/IScopes;)V
+	public fun <init> (Lio/sentry/IScopes;Z)V
 	public fun invoke (Lorg/aopalliance/intercept/MethodInvocation;)Ljava/lang/Object;
 	public fun setEmbeddedValueResolver (Lorg/springframework/util/StringValueResolver;)V
 }
@@ -168,6 +169,11 @@ public class io/sentry/spring/jakarta/checkin/SentryQuartzConfiguration {
 	public fun schedulerFactoryBeanCustomizer ()Lorg/springframework/boot/autoconfigure/quartz/SchedulerFactoryBeanCustomizer;
 }
 
+public final class io/sentry/spring/jakarta/checkin/SentryScheduledCheckInPointcut : org/springframework/aop/support/StaticMethodMatcherPointcut {
+	public fun <init> (Ljava/util/List;)V
+	public fun matches (Ljava/lang/reflect/Method;Ljava/lang/Class;)Z
+}
+
 public final class io/sentry/spring/jakarta/checkin/SentrySchedulerFactoryBeanCustomizer : org/springframework/boot/autoconfigure/quartz/SchedulerFactoryBeanCustomizer {
 	public fun <init> ()V
 	public fun customize (Lorg/springframework/scheduling/quartz/SchedulerFactoryBean;)V