Skip to content

Commit

Permalink
fix(core): add de app block to plugin controller (kestra-io/kestra-ee…
Browse files Browse the repository at this point in the history
  • Loading branch information
fhussonnois committed Jan 29, 2025
1 parent 3194a89 commit 1de2a3b
Showing 1 changed file with 18 additions and 3 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,15 @@
package io.kestra.webserver.controllers.api;

import io.kestra.core.docs.*;
import io.kestra.core.docs.ClassInputDocumentation;
import io.kestra.core.docs.ClassPluginDocumentation;
import io.kestra.core.docs.DocumentationGenerator;
import io.kestra.core.docs.DocumentationWithSchema;
import io.kestra.core.docs.InputType;
import io.kestra.core.docs.JsonSchemaGenerator;
import io.kestra.core.docs.Plugin;
import io.kestra.core.docs.PluginIcon;
import io.kestra.core.docs.Schema;
import io.kestra.core.docs.SchemaType;
import io.kestra.core.models.dashboards.Dashboard;
import io.kestra.core.models.flows.Flow;
import io.kestra.core.models.flows.Input;
Expand Down Expand Up @@ -30,7 +39,11 @@
import jakarta.inject.Inject;

import java.io.IOException;
import java.util.*;
import java.util.AbstractMap;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.stream.Collectors;
import java.util.stream.Stream;

Expand Down Expand Up @@ -146,7 +159,9 @@ public MutableHttpResponse<Map<String, PluginIcon>> icons() {
plugin.getTriggers().stream(),
plugin.getConditions().stream(),
plugin.getTaskRunners().stream(),
plugin.getLogExporters().stream()
plugin.getLogExporters().stream(),
plugin.getApps().stream(),
plugin.getAppBlocks().stream()
)
.flatMap(i -> i)
.map(e -> new AbstractMap.SimpleEntry<>(
Expand Down

0 comments on commit 1de2a3b

Please sign in to comment.