Micronaut4 module

micronaut/shedlock-micronaut/pom.xml

@@ -17,7 +17,7 @@
             <dependency>
                 <groupId>io.micronaut</groupId>
                 <artifactId>micronaut-bom</artifactId>
-                <version>${micronaut.ver}</version>
+                <version>${micronaut3.version}</version>
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
@@ -104,12 +104,12 @@
                             <path>
                                 <groupId>io.micronaut</groupId>
                                 <artifactId>micronaut-inject-java</artifactId>
-                                <version>${micronaut.ver}</version>
+                                <version>${micronaut3.version}</version>
                             </path>
                             <path>
                                 <groupId>io.micronaut</groupId>
                                 <artifactId>micronaut-validation</artifactId>
-                                <version>${micronaut.ver}</version>
+                                <version>${micronaut3.version}</version>
                             </path>
                         </annotationProcessorPaths>
                     </configuration>
@@ -127,12 +127,12 @@
                                     <path>
                                         <groupId>io.micronaut</groupId>
                                         <artifactId>micronaut-inject-java</artifactId>
-                                        <version>${micronaut.ver}</version>
+                                        <version>${micronaut3.version}</version>
                                     </path>
                                     <path>
                                         <groupId>io.micronaut</groupId>
                                         <artifactId>micronaut-validation</artifactId>
-                                        <version>${micronaut.ver}</version>
+                                        <version>${micronaut3.version}</version>
                                     </path>
                                 </annotationProcessorPaths>
                             </configuration>

micronaut/shedlock-micronaut4/micronaut-cli.yml

@@ -0,0 +1,5 @@
+profile: service
+defaultPackage: net.javacrumbs.shedlock.micronaut.internal
+---
+testFramework: junit
+sourceLanguage: java

micronaut/shedlock-micronaut4/pom.xml

@@ -0,0 +1,150 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <artifactId>shedlock-parent</artifactId>
+        <groupId>net.javacrumbs.shedlock</groupId>
+        <version>5.7.1-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>shedlock-micronaut4</artifactId>
+    <version>5.7.1-SNAPSHOT</version>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>io.micronaut.platform</groupId>
+                <artifactId>micronaut-platform</artifactId>
+                <version>${micronaut4.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+    <dependencies>
+        <dependency>
+            <groupId>net.javacrumbs.shedlock</groupId>
+            <artifactId>shedlock-core</artifactId>
+            <version>${project.version}</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.micronaut</groupId>
+            <artifactId>micronaut-inject</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.micronaut</groupId>
+            <artifactId>micronaut-runtime</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.yaml</groupId>
+            <artifactId>snakeyaml</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>${logback.ver}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.micronaut.test</groupId>
+            <artifactId>micronaut-test-junit5</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>${mockito.ver}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj.ver}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-jar-plugin</artifactId>
+                    <configuration>
+                        <archive>
+                            <manifestEntries>
+                                <Automatic-Module-Name>
+                                    net.javacrumbs.shedlock.micronaut4
+                                </Automatic-Module-Name>
+                            </manifestEntries>
+                        </archive>
+                    </configuration>
+                </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-compiler-plugin</artifactId>
+                    <configuration>
+                        <source>${jdk.version}</source>
+                        <target>${jdk.version}</target>
+                        <encoding>${project.build.sourceEncoding}</encoding>
+                        <compilerArgs>
+                            <arg>-parameters</arg>
+                        </compilerArgs>
+                        <annotationProcessorPaths>
+                            <path>
+                                <groupId>io.micronaut</groupId>
+                                <artifactId>micronaut-inject-java</artifactId>
+                                <version>${micronaut4.version}</version>
+                            </path>
+                            <path>
+                                <groupId>io.micronaut.validation</groupId>
+                                <artifactId>micronaut-validation</artifactId>
+                                <version>${micronaut4.validation.version}</version>
+                            </path>
+                        </annotationProcessorPaths>
+                    </configuration>
+                    <executions>
+                        <execution>
+                            <id>test-compile</id>
+                            <goals>
+                                <goal>testCompile</goal>
+                            </goals>
+                            <configuration>
+                                <compilerArgs>
+                                    <arg>-parameters</arg>
+                                </compilerArgs>
+                                <annotationProcessorPaths>
+                                    <path>
+                                        <groupId>io.micronaut</groupId>
+                                        <artifactId>micronaut-inject-java</artifactId>
+                                        <version>${micronaut4.version}</version>
+                                    </path>
+                                    <path>
+                                        <groupId>io.micronaut.validation</groupId>
+                                        <artifactId>micronaut-validation</artifactId>
+                                        <version>${micronaut4.validation.version}</version>
+                                    </path>
+                                </annotationProcessorPaths>
+                            </configuration>
+                        </execution>
+                    </executions>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+    </build>
+</project>

micronaut/shedlock-micronaut4/src/main/java/net/javacrumbs/shedlock/micronaut/SchedulerLock.java

@@ -0,0 +1,59 @@
+/**
+ * Copyright 2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package net.javacrumbs.shedlock.micronaut;
+
+
+import io.micronaut.aop.Around;
+import io.micronaut.context.annotation.Executable;
+import io.micronaut.context.annotation.Type;
+import net.javacrumbs.shedlock.micronaut.internal.SchedulerLockInterceptor;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+@Documented
+@Retention(RUNTIME)
+@Target({ElementType.TYPE, ElementType.METHOD})
+@Around
+@Executable
+@Type(SchedulerLockInterceptor.class)
+public @interface SchedulerLock {
+    /**
+     * Lock name.
+     */
+    String name();
+
+    /**
+     * How long the lock should be kept in case the machine which obtained the lock died before releasing it.
+     * This is just a fallback, under normal circumstances the lock is released as soon the tasks finishes. Can be any format
+     * supported by <a href="https://docs.micronaut.io/latest/guide/config.html#_duration_conversion">Duration Conversion</a>
+     * <p>
+     */
+    String lockAtMostFor() default "";
+
+    /**
+     * The lock will be held at least for this period of time. Can be used if you really need to execute the task
+     * at most once in given period of time. If the duration of the task is shorter than clock difference between nodes, the task can
+     * be theoretically executed more than once (one node after another). By setting this parameter, you can make sure that the
+     * lock will be kept at least for given period of time. Can be any format
+     * supported by <a href="https://docs.micronaut.io/latest/guide/config.html#_duration_conversion">Duration Conversion</a>
+     */
+    String lockAtLeastFor() default "";
+}

micronaut/shedlock-micronaut4/src/main/java/net/javacrumbs/shedlock/micronaut/internal/LockingNotSupportedException.java

@@ -0,0 +1,24 @@
+/**
+ * Copyright 2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package net.javacrumbs.shedlock.micronaut.internal;
+
+import net.javacrumbs.shedlock.support.LockException;
+
+class LockingNotSupportedException extends LockException {
+    LockingNotSupportedException() {
+        super("Can not lock method returning value (do not know what to return if it's locked)");
+    }
+}

micronaut/shedlock-micronaut4/src/main/java/net/javacrumbs/shedlock/micronaut/internal/MicronautLockConfigurationExtractor.java

@@ -0,0 +1,92 @@
+/**
+ * Copyright 2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package net.javacrumbs.shedlock.micronaut.internal;
+
+import io.micronaut.core.annotation.AnnotationValue;
+import io.micronaut.core.convert.ConversionService;
+import io.micronaut.core.util.StringUtils;
+import io.micronaut.inject.ExecutableMethod;
+import net.javacrumbs.shedlock.core.ClockProvider;
+import net.javacrumbs.shedlock.core.LockConfiguration;
+import net.javacrumbs.shedlock.micronaut.SchedulerLock;
+
+import java.time.Duration;
+import java.util.Optional;
+
+import static java.util.Objects.requireNonNull;
+
+class MicronautLockConfigurationExtractor {
+    private final Duration defaultLockAtMostFor;
+    private final Duration defaultLockAtLeastFor;
+    private final ConversionService conversionService;
+
+    MicronautLockConfigurationExtractor(Duration defaultLockAtMostFor, Duration defaultLockAtLeastFor, ConversionService conversionService) {
+        this.defaultLockAtMostFor = requireNonNull(defaultLockAtMostFor);
+        this.defaultLockAtLeastFor = requireNonNull(defaultLockAtLeastFor);
+        this.conversionService = conversionService;
+    }
+
+
+    Optional<LockConfiguration> getLockConfiguration(ExecutableMethod<Object, Object> method) {
+        Optional<AnnotationValue<SchedulerLock>> annotation = findAnnotation(method);
+        return annotation.map(this::getLockConfiguration);
+    }
+
+    private LockConfiguration getLockConfiguration(AnnotationValue<SchedulerLock> annotation) {
+        return new LockConfiguration(
+            ClockProvider.now(),
+            getName(annotation),
+            getLockAtMostFor(annotation),
+            getLockAtLeastFor(annotation)
+        );
+    }
+
+    private String getName(AnnotationValue<SchedulerLock> annotation) {
+        return annotation.getRequiredValue("name", String.class);
+    }
+
+    Duration getLockAtMostFor(AnnotationValue<SchedulerLock> annotation) {
+        return getValue(
+            annotation,
+            this.defaultLockAtMostFor,
+            "lockAtMostFor"
+        );
+    }
+
+    Duration getLockAtLeastFor(AnnotationValue<SchedulerLock> annotation) {
+        return getValue(
+            annotation,
+            this.defaultLockAtLeastFor,
+            "lockAtLeastFor"
+        );
+    }
+
+    private Duration getValue(AnnotationValue<SchedulerLock> annotation, Duration defaultValue, String paramName) {
+        String stringValueFromAnnotation = annotation.get(paramName, String.class).orElse("");
+        if (StringUtils.hasText(stringValueFromAnnotation)) {
+            return conversionService.convert(stringValueFromAnnotation, Duration.class)
+                .orElseThrow(() -> new IllegalArgumentException("Invalid " + paramName + " value \"" + stringValueFromAnnotation + "\" - cannot parse into duration"));
+        } else {
+            return defaultValue;
+        }
+    }
+
+    Optional<AnnotationValue<SchedulerLock>> findAnnotation(ExecutableMethod<Object, Object> method) {
+        return method.findAnnotation(SchedulerLock.class);
+    }
+}
+
+