Merge branch 'main' into chore/update-plugin-categories

Author: Malaydewangan09

build.gradle

@@ -1,5 +1,5 @@
 plugins {
-    id "com.vanniktech.maven.publish" version "0.34.0"
+    id "com.vanniktech.maven.publish" version "0.36.0"
     id "io.kestra.gradle.inject-bom-versions" version "1.0.0"
     id 'java-library'
     id "idea"
@@ -114,7 +114,7 @@ configurations {
 }
 
 dependencies {
-    agent "org.aspectj:aspectjweaver:1.9.24"
+    agent "org.aspectj:aspectjweaver:1.9.25.1"
 }
 
 test {

gradle.properties

@@ -1,2 +1,2 @@
-version=1.1.0-SNAPSHOT
+version=1.0.1-SNAPSHOT
 kestraVersion=1.2.3

src/main/java/io/kestra/plugin/templates/Example.java

@@ -0,0 +1,49 @@
+package io.kestra.plugin.trello;
+import io.kestra.core.http.HttpRequest;
+import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
+import io.kestra.core.models.tasks.Task;
+import io.kestra.core.runners.RunContext;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.Builder;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@SuperBuilder
+@EqualsAndHashCode
+@Getter
+@NoArgsConstructor
+public abstract class AbstractTrelloTask extends Task implements RunnableTask<io.kestra.core.models.tasks.Output> {
+
+    @Schema(title = "Trello API Key", description = "Your Trello API key")
+    @NotNull
+    protected Property<String> apiKey;
+
+    @Schema(title = "Trello API Token", description = "Your Trello API token")
+    @NotNull
+    protected Property<String> apiToken;
+
+    @Schema(title = "API Version", description = "Trello API version to use", defaultValue = "1")
+    @Builder.Default
+    protected Property<String> apiVersion = Property.ofValue("1");
+
+    @Schema(title = "Base API URL", description = "The base URL for the Trello API")
+    @Builder.Default
+    protected Property<String> apiBaseUrl = Property.ofValue("https://api.trello.com");
+
+    protected String buildApiUrl(RunContext runContext, String endpoint) throws Exception {
+        String rVersion = runContext.render(this.apiVersion).as(String.class).orElse("1");
+        String rBaseUrl = runContext.render(this.apiBaseUrl).as(String.class).orElse("https://api.trello.com");
+        return String.format("%s/%s/%s", rBaseUrl, rVersion, endpoint);
+    }
+
+    protected HttpRequest.HttpRequestBuilder addAuthHeaders(RunContext runContext, HttpRequest.HttpRequestBuilder builder) throws Exception {
+        String rApiKey = runContext.render(this.apiKey).as(String.class).orElseThrow();
+        String rApiToken = runContext.render(this.apiToken).as(String.class).orElseThrow();
+        String authHeader = String.format("OAuth oauth_consumer_key=\"%s\", oauth_token=\"%s\"", rApiKey, rApiToken);
+        return builder.addHeader("Authorization", authHeader);
+    }
+}

src/main/java/io/kestra/plugin/templates/Trigger.java

@@ -0,0 +1,102 @@
+package io.kestra.plugin.trello.cards;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import io.kestra.core.http.HttpRequest;
+import io.kestra.core.http.HttpResponse;
+import io.kestra.core.http.client.HttpClient;
+import io.kestra.core.models.annotations.Example;
+import io.kestra.core.models.annotations.Plugin;
+import io.kestra.core.models.property.Property;
+import io.kestra.core.runners.RunContext;
+import io.kestra.core.serializers.JacksonMapper;
+import io.kestra.plugin.trello.AbstractTrelloTask;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.net.URI;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
+
+@SuperBuilder
+@NoArgsConstructor
+@Getter
+@ToString
+@EqualsAndHashCode
+
+@Schema(
+    title = "Add a comment to a Trello card",
+    description = "Add a comment/action to an existing Trello card"
+)
+@Plugin(
+    examples = {
+        @Example(
+            title = "Add a comment to a Trello card",
+            full = true,
+            code = """
+                id: trello_add_comment
+                namespace: company.team
+
+                tasks:
+                  - id: add_comment
+                    type: io.kestra.plugin.trello.cards.Comment
+                    apiKey: "{{ secret('TRELLO_API_KEY') }}"
+                    apiToken: "{{ secret('TRELLO_API_TOKEN') }}"
+                    cardId: "5abbe4b7ddc1b351ef961414"
+                    text: "This is my comment on the card"
+                """
+        )
+    }
+)
+public class Comment extends AbstractTrelloTask {
+
+    @Schema(title = "Card ID", description = "The ID of the card to add a comment to")
+    @NotNull
+    protected Property<String> cardId;
+
+    @Schema(title = "Comment Text", description = "The text of the comment")
+    @NotNull
+    protected Property<String> text;
+
+    @Override
+    public io.kestra.core.models.tasks.Output run(RunContext runContext) throws Exception {
+        String rId = runContext.render(this.cardId).as(String.class).orElseThrow();
+        String rText = runContext.render(this.text).as(String.class).orElseThrow();
+
+        String url = buildApiUrl(runContext, "cards/" + rId + "/actions/comments") + "?text="
+            + URLEncoder.encode(rText, StandardCharsets.UTF_8);
+
+        HttpRequest.HttpRequestBuilder requestBuilder = HttpRequest.builder()
+            .method("POST")
+            .uri(URI.create(url))
+            .addHeader("Accept", "application/json");
+
+        HttpRequest request = addAuthHeaders(runContext, requestBuilder).build();
+
+        try (HttpClient httpClient = HttpClient.builder()
+            .runContext(runContext)
+            .build()) {
+            HttpResponse<String> response = httpClient.request(request, String.class);
+
+            if (response.getStatus().getCode() != 200) {
+                throw new RuntimeException(
+                    "Failed to add comment: " + response.getStatus().getCode() + " - "
+                        + response.getBody());
+            }
+
+            JsonNode jsonNode = JacksonMapper.ofJson().readTree(response.getBody());
+
+            return Output.builder()
+                .commentId(jsonNode.has("id")?jsonNode.get("id").asText():null)
+                .build();
+        }
+    }
+
+    @Builder
+    @Getter
+    public static class Output implements io.kestra.core.models.tasks.Output {
+        @Schema(title = "Comment ID")
+        private final String commentId;
+    }
+}