Implemented faster search endpoint

docker/latest/management/management.yaml

@@ -4,15 +4,13 @@ zookeeper:
 storage:
   pathPrefix: /run/hermes
   clusters:
-    -
-      datacenter: dc
-      clusterName: zk
+    - datacenter: dc
+      root: /run/hermes
       connectionString: zk:2181
 
 kafka:
   clusters:
-    -
-      datacenter: dc
+    - datacenter: dc
       clusterName: primary
       connectionTimeout: 3000
       bootstrapKafkaServer: kafka:29092

hermes-api/src/main/java/pl/allegro/tech/hermes/api/SearchItem.java

@@ -0,0 +1,15 @@
+package pl.allegro.tech.hermes.api;
+
+import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type")
+@JsonSubTypes({
+  @JsonSubTypes.Type(value = TopicSearchItem.class, name = "TOPIC"),
+  @JsonSubTypes.Type(value = SubscriptionSearchItem.class, name = "SUBSCRIPTION"),
+})
+public interface SearchItem {
+  SearchItemType type();
+
+  String name();
+}

hermes-api/src/main/java/pl/allegro/tech/hermes/api/SearchItemType.java

@@ -0,0 +1,6 @@
+package pl.allegro.tech.hermes.api;
+
+public enum SearchItemType {
+  TOPIC,
+  SUBSCRIPTION
+}

hermes-api/src/main/java/pl/allegro/tech/hermes/api/SearchResults.java

@@ -0,0 +1,11 @@
+package pl.allegro.tech.hermes.api;
+
+import static java.util.Collections.emptyList;
+
+import java.util.List;
+
+public record SearchResults(List<SearchItem> results, long totalCount) {
+  public static SearchResults empty() {
+    return new SearchResults(emptyList(), 0);
+  }
+}

hermes-api/src/main/java/pl/allegro/tech/hermes/api/SubscriptionSearchItem.java

@@ -0,0 +1,12 @@
+package pl.allegro.tech.hermes.api;
+
+public record SubscriptionSearchItem(String name, Subscription subscription) implements SearchItem {
+  @Override
+  public SearchItemType type() {
+    return SearchItemType.SUBSCRIPTION;
+  }
+
+  public record Subscription(String endpoint, Topic topic) {}
+
+  public record Topic(String name, String qualifiedName, String groupName) {}
+}

hermes-api/src/main/java/pl/allegro/tech/hermes/api/TopicSearchItem.java

@@ -0,0 +1,12 @@
+package pl.allegro.tech.hermes.api;
+
+public record TopicSearchItem(String name, Topic topic) implements SearchItem {
+  @Override
+  public SearchItemType type() {
+    return SearchItemType.TOPIC;
+  }
+
+  public record Topic(String groupName, Owner owner) {}
+
+  public record Owner(String id) {}
+}

hermes-console/.nvmrc

@@ -1 +1 @@
-22.12.0
+22.20.0

hermes-console/README.md

@@ -4,7 +4,7 @@ Hermes console written in Vue 3.
 
 ## Requirements
 
-* node >=22.12.0
+* node >=22.20.0
 * yarn
 
 ## Node setup

hermes-console/json-server/db.json

@@ -768,4 +768,4 @@
       "avroSubscriptionCount": 100
     }
   }
-}
+}

hermes-console/json-server/routes.json

@@ -30,5 +30,6 @@
   "/owners/sources/*?search=:searchPhrase": "/topicsOwners?name_like=:searchPhrase",
   "/dashboards/topics/:topicName": "/topicDashboardUrl",
   "/dashboards/topics/:topicName/subscriptions/:id": "/subscriptionDashboardUrl",
-  "/inactive-topics": "/inactiveTopics"
+  "/inactive-topics": "/inactiveTopics",
+  "/search/query?q=:searchPhrase": "/search"
 }

hermes-console/json-server/search.json

@@ -0,0 +1,37 @@
+{
+  "results": [
+    {
+      "type": "TOPIC",
+      "name": "pl.allegro.public.group.DummyEvent",
+      "topic": {
+        "groupName": "pl.allegro.public.group",
+        "owner": {
+          "id": "1234"
+        }
+      }
+    },
+    {
+      "type": "SUBSCRIPTION",
+      "name": "foobar-service",
+      "subscription": {
+        "topic": {
+          "name": "foobar-service",
+          "groupName": "pl.allegro.public.group",
+          "qualifiedName": "pl.allegro.public.group.DummyEvent"
+        }
+      }
+    },
+    {
+      "type": "SUBSCRIPTION",
+      "name": "barbaz-service",
+      "subscription": {
+        "topic": {
+          "name": "barbaz-service",
+          "groupName": "pl.allegro.public.group",
+          "qualifiedName": "pl.allegro.public.group.DummyEvent"
+        }
+      }
+    }
+  ],
+  "totalCount": 3
+}

hermes-console/json-server/server.ts

@@ -3,6 +3,7 @@ const activeOfflineRetransmissionTasks = require('./active-offline-retransmissio
 const subscriptions = require('./subscriptions.json');
 const routes = require('./routes.json');
 const filterDebug = require('./filter-debug.json');
+const search = require('./search.json');
 
 const jsonServer = require('json-server');
 const server = jsonServer.create();
@@ -21,6 +22,10 @@ server.post('/query/subscriptions', (req, res) => {
   res.jsonp(subscriptions);
 });
 
+server.get('search/query', (req, res) => {
+  res.jsonp(search);
+});
+
 server.post('/topicSubscriptions', (req, res) => {
   res.sendStatus(200);
 });

hermes-console/package.json

@@ -3,7 +3,7 @@
   "description": "Console for Hermes Management",
   "license": "Apache-2.0",
   "engines": {
-    "node": ">=22.12.0"
+    "node": ">=22.20.0"
   },
   "scripts": {
     "dev": "vite",
@@ -29,7 +29,7 @@
     "vue-i18n": "11.1.10",
     "vue-router": "4.3.2",
     "vue3-ace-editor": "2.2.4",
-    "vuetify": "3.10.5"
+    "vuetify": "3.11.0"
   },
   "devDependencies": {
     "@mdi/font": "7.4.47",

hermes-console/src/api/SearchResults.ts

@@ -0,0 +1,39 @@
+export interface SearchResults {
+  totalCount: number;
+  results: SearchResultItem[];
+}
+
+export type SearchResultItem =
+  | SearchResultTopicItem
+  | SearchResultSubscriptionItem;
+
+export interface SearchResultTopicItem {
+  type: 'TOPIC';
+  name: string;
+  topic: TopicItemDetails;
+}
+
+export interface TopicItemDetails {
+  groupName: string;
+  owner: TopicOwnerDetails;
+}
+
+export interface TopicOwnerDetails {
+  id: string;
+}
+
+export interface SearchResultSubscriptionItem {
+  type: 'SUBSCRIPTION';
+  name: string;
+  subscription: SubscriptionItemDetails;
+}
+
+export interface SubscriptionItemDetails {
+  topic: SubscriptionTopicDetails;
+}
+
+export interface SubscriptionTopicDetails {
+  name: string;
+  qualifiedName: string;
+  groupName: string;
+}

hermes-console/src/api/hermes-client/index.ts

@@ -43,6 +43,7 @@ import type { Owner, OwnerSource } from '@/api/owner';
 import type { ResponsePromise } from '@/utils/axios/axios-utils';
 import type { RetransmissionDate } from '@/api/OffsetRetransmissionDate';
 import type { Role } from '@/api/role';
+import type { SearchResults } from '@/api/SearchResults';
 import type { SentMessageTrace } from '@/api/subscription-undelivered';
 import type { Stats } from '@/api/stats';
 import type { SubscriptionHealth } from '@/api/subscription-health';
@@ -305,6 +306,12 @@ export function querySubscriptions(
   });
 }
 
+export function search(query: string): ResponsePromise<SearchResults> {
+  return axios.get<SearchResults>(
+    `/search/query?q=${encodeURIComponent(query)}`,
+  );
+}
+
 export function fetchRoles(path: string): ResponsePromise<Role[]> {
   return axios.get<Role[]>(path);
 }