Skip to content

Commit

Permalink
Remove Old Dev UI: Reactive messaging
Browse files Browse the repository at this point in the history
Signed-off-by: Phillip Kruger <phillip.kruger@gmail.com>
  • Loading branch information
phillip-kruger committed Jul 26, 2023
1 parent c00bbdb commit 148db53
Show file tree
Hide file tree
Showing 14 changed files with 31 additions and 242 deletions.
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.quarkus.smallrye.reactivemessaging.deployment.devconsole;
package io.quarkus.smallrye.reactivemessaging.deployment.devui;

import static io.quarkus.deployment.annotations.ExecutionTime.STATIC_INIT;

Expand All @@ -12,23 +12,17 @@
import io.quarkus.arc.processor.InjectionPointInfo;
import io.quarkus.deployment.IsDevelopment;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.annotations.Record;
import io.quarkus.deployment.pkg.builditem.CurateOutcomeBuildItem;
import io.quarkus.devconsole.spi.DevConsoleRuntimeTemplateInfoBuildItem;
import io.quarkus.devui.spi.JsonRPCProvidersBuildItem;
import io.quarkus.devui.spi.page.CardPageBuildItem;
import io.quarkus.devui.spi.page.Page;
import io.quarkus.smallrye.reactivemessaging.deployment.ReactiveMessagingDotNames;
import io.quarkus.smallrye.reactivemessaging.runtime.devconsole.Connectors;
import io.quarkus.smallrye.reactivemessaging.runtime.devconsole.DevConsoleRecorder;
import io.quarkus.smallrye.reactivemessaging.runtime.devconsole.DevReactiveMessagingInfosSupplier;
import io.quarkus.smallrye.reactivemessaging.runtime.devui.Connectors;
import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevConsoleRecorder;
import io.quarkus.smallrye.reactivemessaging.runtime.devui.ReactiveMessagingJsonRpcService;

public class ReactiveMessagingDevConsoleProcessor {
public class ReactiveMessagingDevUIProcessor {

@BuildStep(onlyIf = IsDevelopment.class)
public DevConsoleRuntimeTemplateInfoBuildItem collectInfos(CurateOutcomeBuildItem curateOutcomeBuildItem) {
return new DevConsoleRuntimeTemplateInfoBuildItem("reactiveMessagingInfos",
new DevReactiveMessagingInfosSupplier(), this.getClass(), curateOutcomeBuildItem);
}

@Record(STATIC_INIT)
@io.quarkus.deployment.annotations.Record(STATIC_INIT)
@BuildStep(onlyIf = IsDevelopment.class)
public void collectInjectionInfo(DevConsoleRecorder recorder, BeanDiscoveryFinishedBuildItem beanDiscoveryFinished) {
Map<String, String> emitters = new HashMap<>();
Expand Down Expand Up @@ -59,4 +53,19 @@ AdditionalBeanBuildItem beans() {
return AdditionalBeanBuildItem.unremovableOf(Connectors.class);
}

@BuildStep(onlyIf = IsDevelopment.class)
CardPageBuildItem create() {
CardPageBuildItem card = new CardPageBuildItem();
card.addPage(Page.webComponentPageBuilder()
.title("Channels")
.componentLink("qwc-smallrye-reactive-messaging-channels.js")
.icon("font-awesome-solid:diagram-project"));

return card;
}

@BuildStep(onlyIf = IsDevelopment.class)
JsonRPCProvidersBuildItem createJsonRPCServiceForCache() {
return new JsonRPCProvidersBuildItem(ReactiveMessagingJsonRpcService.class);
}
}

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ export class QwcSmallryeReactiveMessagingChannels extends LitElement {
`;

static properties = {
"_channels": {state: true, type: Array}
_channels: {state: true, type: Array}
}

/**
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.quarkus.smallrye.reactivemessaging.runtime.devconsole;
package io.quarkus.smallrye.reactivemessaging.runtime.devui;

import java.util.ArrayList;
import java.util.HashMap;
Expand All @@ -12,8 +12,8 @@
import org.eclipse.microprofile.config.Config;

import io.quarkus.runtime.StartupEvent;
import io.quarkus.smallrye.reactivemessaging.runtime.devconsole.DevReactiveMessagingInfos.Component;
import io.quarkus.smallrye.reactivemessaging.runtime.devconsole.DevReactiveMessagingInfos.ComponentType;
import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevReactiveMessagingInfos.Component;
import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevReactiveMessagingInfos.ComponentType;

// we use a separate component due to weird class loading issues that occur when accessing config properties
@Singleton
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.quarkus.smallrye.reactivemessaging.runtime.devconsole;
package io.quarkus.smallrye.reactivemessaging.runtime.devui;

import java.util.HashMap;
import java.util.Map;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.quarkus.smallrye.reactivemessaging.runtime.devconsole;
package io.quarkus.smallrye.reactivemessaging.runtime.devui;

import java.util.ArrayList;
import java.util.Collections;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.quarkus.smallrye.reactivemessaging.runtime.devconsole;
package io.quarkus.smallrye.reactivemessaging.runtime.devui;

import java.util.List;

Expand All @@ -10,8 +10,6 @@
@ApplicationScoped
public class ReactiveMessagingJsonRpcService {

// IMPORTANT: To avoid having to depend on jackson, we build a JSON array containing the description of the channels.

public JsonArray getInfo() {
JsonArray result = new JsonArray();

Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

0 comments on commit 148db53

Please sign in to comment.