feat: add google calendar insert event task (#2)

Co-authored-by: Shruti Mantri <smantri@moveworks.ai>
Co-authored-by: Mathieu Gabelle <54168385+mgabelle@users.noreply.github.com>

Author: 3 people

build.gradle

@@ -14,122 +14,167 @@ plugins {
 
 def isBuildSnapshot = version.toString().endsWith("-SNAPSHOT")
 
-repositories {
-    mavenLocal()
-    mavenCentral()
-    if (isBuildSnapshot) {
-        maven { url "https://s01.oss.sonatype.org/content/repositories/snapshots/" }
+allprojects {
+    repositories {
+        mavenLocal()
+        mavenCentral()
+        if (isBuildSnapshot) {
+            maven { url "https://s01.oss.sonatype.org/content/repositories/snapshots/" }
+        }
+    }
+}
+
+subprojects {
+    group "io.kestra.plugin"
+    sourceCompatibility = 21
+    targetCompatibility = 21
+
+    apply plugin: "java-library"
+    apply plugin: "idea"
+
+    dependencies {
+        // Platform
+        annotationProcessor enforcedPlatform("io.kestra:platform:$kestraVersion")
+        implementation enforcedPlatform("io.kestra:platform:$kestraVersion")
+        api enforcedPlatform("io.kestra:platform:$kestraVersion")
+
+        // Lombok
+        annotationProcessor "org.projectlombok:lombok"
+        compileOnly "org.projectlombok:lombok"
+
+        // Micronaut
+        compileOnly "io.micronaut:micronaut-http"
+        compileOnly "io.micronaut.reactor:micronaut-reactor"
+
+        // Kestra
+        annotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
+        compileOnly group: "io.kestra", name: "core", version: kestraVersion
+
+        // Logs
+        compileOnly'org.slf4j:slf4j-api'
     }
 }
 
 sourceCompatibility = 21
 targetCompatibility = 21
 
 group "io.kestra.plugin"
-description 'Plugin template for Kestra'
+description 'Apache Camel plugin for Kestra'
 
 tasks.withType(JavaCompile) {
     options.encoding = "UTF-8"
     options.compilerArgs.add("-parameters")
 }
 
-dependencies {
-    // Platform
-    annotationProcessor enforcedPlatform("io.kestra:platform:$kestraVersion")
-    implementation enforcedPlatform("io.kestra:platform:$kestraVersion")
-    api enforcedPlatform("io.kestra:platform:$kestraVersion")
-
-    // lombok
-    annotationProcessor "org.projectlombok:lombok"
-    compileOnly "org.projectlombok:lombok"
-
-    // kestra
-    annotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
-    compileOnly group: "io.kestra", name: "core", version: kestraVersion
-    compileOnly group: "io.kestra", name: "script", version: kestraVersion
-}
-
 
 /**********************************************************************************************************************\
  * Test
  **********************************************************************************************************************/
-test {
-    useJUnitPlatform()
-}
+subprojects {
+    apply plugin: "com.adarshr.test-logger"
 
-testlogger {
-    theme "mocha-parallel"
-    showExceptions true
-    showFullStackTraces true
-    showStandardStreams true
-    showPassedStandardStreams false
-    showSkippedStandardStreams true
-}
+    test {
+        useJUnitPlatform()
 
-dependencies {
-    // Platform
-    testAnnotationProcessor enforcedPlatform("io.kestra:platform:$kestraVersion")
-    testImplementation enforcedPlatform("io.kestra:platform:$kestraVersion")
-
-    // lombok
-    testAnnotationProcessor "org.projectlombok:lombok"
-    testCompileOnly 'org.projectlombok:lombok'
-
-    // micronaut
-    testAnnotationProcessor "io.micronaut:micronaut-inject-java"
-    testAnnotationProcessor "io.micronaut.validation:micronaut-validation-processor"
-    testImplementation "io.micronaut.test:micronaut-test-junit5"
-    testImplementation "io.micronaut:micronaut-jackson-databind"
-
-    // test deps needed only for to have a runner
-    testAnnotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
-    testImplementation group: "io.kestra", name: "core", version: kestraVersion
-    testImplementation group: "io.kestra", name: "tests", version: kestraVersion
-    testImplementation group: "io.kestra", name: "script", version: kestraVersion
-    testImplementation group: "io.kestra", name: "repository-memory", version: kestraVersion
-    testImplementation group: "io.kestra", name: "runner-memory", version: kestraVersion
-    testImplementation group: "io.kestra", name: "storage-local", version: kestraVersion
-
-    // test
-    testImplementation "org.junit.jupiter:junit-jupiter-engine"
-    testImplementation "org.hamcrest:hamcrest"
-    testImplementation "org.hamcrest:hamcrest-library"
+        // configure en_US default locale for tests
+        systemProperty 'user.language', 'en'
+        systemProperty 'user.country', 'US'
+    }
+
+    testlogger {
+        theme "mocha-parallel"
+        showExceptions true
+        showFullStackTraces true
+        showStandardStreams true
+        showPassedStandardStreams false
+        showSkippedStandardStreams true
+    }
+
+    dependencies {
+        // Platform
+        testAnnotationProcessor enforcedPlatform("io.kestra:platform:$kestraVersion")
+        testImplementation enforcedPlatform("io.kestra:platform:$kestraVersion")
+
+        // lombok
+        testAnnotationProcessor "org.projectlombok:lombok"
+        testCompileOnly 'org.projectlombok:lombok'
+
+        // micronaut
+        testAnnotationProcessor "io.micronaut:micronaut-inject-java"
+        testAnnotationProcessor "io.micronaut.validation:micronaut-validation-processor"
+        testImplementation "io.micronaut.test:micronaut-test-junit5"
+        testImplementation "io.micronaut:micronaut-jackson-databind"
+        testImplementation "io.micronaut.reactor:micronaut-reactor"
+
+        // test deps needed only for to have a runner
+        testAnnotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
+        testImplementation group: "io.kestra", name: "core", version: kestraVersion
+        testImplementation group: "io.kestra", name: "tests", version: kestraVersion
+        testImplementation group: "io.kestra", name: "repository-memory", version: kestraVersion
+        testImplementation group: "io.kestra", name: "runner-memory", version: kestraVersion
+        testImplementation group: "io.kestra", name: "storage-local", version: kestraVersion
+
+        // test
+        testImplementation "org.junit.jupiter:junit-jupiter-engine"
+        testImplementation "org.junit.jupiter:junit-jupiter-params"
+        testImplementation "org.hamcrest:hamcrest"
+        testImplementation "org.hamcrest:hamcrest-library"
+
+        testImplementation group: 'com.h2database', name: 'h2'
+        testImplementation group: 'commons-codec', name: 'commons-codec', version: '1.17.1'
+    }
 }
 
 /**********************************************************************************************************************\
  * Allure Reports
  **********************************************************************************************************************/
-dependencies {
-    testImplementation enforcedPlatform("io.kestra:platform:$kestraVersion")
-    testImplementation "io.qameta.allure:allure-junit5"
-}
+subprojects {
+    dependencies {
+        testImplementation enforcedPlatform("io.kestra:platform:$kestraVersion")
+        testImplementation "io.qameta.allure:allure-junit5"
+    }
 
-configurations {
-    agent {
-        canBeResolved = true
-        canBeConsumed = true
+    configurations {
+        agent {
+            canBeResolved = true
+            canBeConsumed = true
+        }
     }
-}
+
 
 dependencies {
     agent "org.aspectj:aspectjweaver:1.9.23"
 }
 
-test {
-    jvmArgs = [ "-javaagent:${configurations.agent.singleFile}" ]
+    test {
+        jvmArgs = [ "-javaagent:${configurations.agent.singleFile}" ]
+    }
 }
 
 /**********************************************************************************************************************\
  * Jacoco
  **********************************************************************************************************************/
-test {
-    finalizedBy jacocoTestReport
+/*subprojects {
+    apply plugin: 'jacoco'
+
+    test {
+        finalizedBy jacocoTestReport
+    }
 }
 
-jacocoTestReport {
-    dependsOn test
+dependencies {
+    jacocoAggregation subprojects
+}
+
+tasks.named('testCodeCoverageReport') {
+    dependsOn = subprojects.test
 }
 
+tasks.named('check') {
+    dependsOn tasks.named('testCodeCoverageReport', JacocoReport)
+}*/
+
+
 /**********************************************************************************************************************\
  * Publish
  **********************************************************************************************************************/
@@ -144,40 +189,51 @@ nexusPublishing {
     }
 }
 
-tasks.withType(GenerateModuleMetadata).configureEach {
-    // Suppression this validation error as we want to enforce the Kestra platform
-    suppressedValidationErrors.add('enforced-platform')
+github {
+    user 'kestra-io'
+    repository 'plugin-camel'
+    license 'Apache'
 }
 
-jar {
-    manifest {
-        attributes(
-                "X-Kestra-Name": project.name,
-                "X-Kestra-Title": "Template",
-                "X-Kestra-Group": project.group + ".templates",
-                "X-Kestra-Description": project.description,
-                "X-Kestra-Version": project.version
-        )
+
+subprojects { Project subproject ->
+    apply plugin: "com.adarshr.test-logger"
+    apply plugin: "com.github.johnrengelman.shadow"
+    apply plugin: "maven-publish"
+    apply plugin: "signing"
+    apply plugin: 'ru.vyarus.github-info'
+    apply plugin: 'ru.vyarus.java-lib'
+
+    github {
+        user 'kestra-io'
+        repository 'plugin-camel'
+        license 'Apache'
     }
-}
 
-maven.pom {
-    developers {
-        developer {
-            id = "tchiotludo"
-            name = "Ludovic Dehon"
+    if (subproject.name != "plugin-camel") {
+        shadowJar {
+            dependsOn(":plugin-camel:shadowJar")
         }
     }
-}
 
-shadowJar {
-    archiveClassifier.set(null)
-    mergeServiceFiles()
-}
+    maven.pom {
+        developers {
+            developer {
+                id = "tchiotludo"
+                name = "Ludovic Dehon"
+            }
+        }
+    }
 
-github {
-    user 'kestra-io'
-    license 'Apache'
+    shadowJar {
+        archiveClassifier.set(null)
+        mergeServiceFiles()
+    }
+
+    tasks.withType(GenerateModuleMetadata).configureEach {
+        // Suppression this validation error as we want to enforce the Kestra platform
+        suppressedValidationErrors.add('enforced-platform')
+    }
 }
 
 /**********************************************************************************************************************\

gradle.properties

@@ -1,2 +1,2 @@
-version=0.18.0-SNAPSHOT
-kestraVersion=[0.18,)
+version=0.20.0-SNAPSHOT
+kestraVersion=[0.20,)

plugin-camel-google-calendar/build.gradle

@@ -0,0 +1,24 @@
+project.description = 'Connect to Google Calendar using Kestra\'s Apache Camel plugin.'
+
+jar {
+    manifest {
+        attributes(
+                "X-Kestra-Name": project.name,
+                "X-Kestra-Title": "Google Calendar",
+                "X-Kestra-Group": project.group + ".camel.googlecalendar",
+                "X-Kestra-Description": project.description,
+                "X-Kestra-Version": project.version
+        )
+    }
+}
+
+dependencies {
+    implementation("org.apache.camel:camel-google-calendar:4.8.1")
+    implementation("org.apache.camel:camel-core:4.8.1")
+    implementation("com.google.oauth-client:google-oauth-client-jetty:1.36.0")
+    implementation("com.google.apis:google-api-services-calendar:v3-rev411-1.25.0")
+    implementation("com.google.api-client:google-api-client-gson:2.7.0")
+    implementation project(':plugin-camel')
+
+    testImplementation project(':plugin-camel').sourceSets.test.output
+}

plugin-camel-google-calendar/src/main/java/io/kestra/plugin/camel/googlecalendar/AbstractTask.java

@@ -0,0 +1,27 @@
+package io.kestra.plugin.camel.googlecalendar;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+import io.kestra.core.exceptions.IllegalVariableEvaluationException;
+import io.kestra.core.models.tasks.Task;
+import io.kestra.core.runners.RunContext;
+import org.apache.camel.component.google.calendar.GoogleCalendarComponent;
+
+import java.io.IOException;
+
+@SuperBuilder
+@ToString
+@EqualsAndHashCode
+@Getter
+@NoArgsConstructor
+public abstract class AbstractTask extends Task implements GoogleCalendarInterface {
+    protected String clientId;
+    protected String clientSecret;
+    protected String refreshToken;
+    protected String serviceAccount;
+    protected String delegate;
+
+    public GoogleCalendarComponent calendarComponent(RunContext runContext) throws IllegalVariableEvaluationException, IOException {
+        return GoogleCalendarComponentService.component(runContext, this);
+    }
+}