Added support for Opensearch Dashboards

src/Plugin/EmulateElastic/AddTemplateHandler.php

@@ -47,12 +47,7 @@ public function run(): Task {
 				throw new \Exception('Cannot parse request');
 			}
 			$patterns = json_encode($request['index_patterns']);
-			foreach (['index_patterns', 'settings', 'mappings'] as $removeProp) {
-				if (!isset($request[$removeProp])) {
-					continue;
-				}
-				unset($request[$removeProp]);
-			}
+			unset($request['index_patterns']);
 			$content = json_encode($request);
 			$templateTable = self::TEMPLATE_TABLE;
 

src/Plugin/EmulateElastic/CatHandler.php

@@ -15,14 +15,15 @@
 use Manticoresearch\Buddy\Core\Plugin\BaseHandlerWithClient;
 use Manticoresearch\Buddy\Core\Task\Task;
 use Manticoresearch\Buddy\Core\Task\TaskResult;
+
 use RuntimeException;
 
 /**
  * Handling requests to extract and build info on Kibana entities, like templates, dashboards, etc.
  */
 class CatHandler extends BaseHandlerWithClient {
 
-	const CAT_ENTITIES = ['templates'];
+	const CAT_ENTITIES = ['templates', 'plugins'];
 
 	/**
 	 *  Initialize the executor
@@ -58,11 +59,10 @@ public function run(): Task {
 
 			$catInfo = [];
 			foreach ($queryResult[0]['data'] as $entityInfo) {
-				$catInfo[] = [
-					'name' => $entityInfo['name'],
-					'order' => 0,
-					'index_patterns' => simdjson_decode($entityInfo['patterns'], true),
-				] + simdjson_decode($entityInfo['content'], true);
+				$catInfo[] = match ($entityTable) {
+					'_templates' => self::buildCatTemplateRow($entityInfo),
+					default => [],
+				};
 			}
 
 			return TaskResult::raw($catInfo);
@@ -72,4 +72,18 @@ public function run(): Task {
 			$taskFn, [$this->payload, $this->manticoreClient]
 		)->run();
 	}
+
+	/**
+	 *
+	 * @param array{name:string,patterns:string,content:string} $entityInfo
+	 * @return array<string,mixed>
+	 */
+	private static function buildCatTemplateRow(array $entityInfo): array {
+		return [
+			'name' => $entityInfo['name'],
+			'order' => 0,
+			'index_patterns' => simdjson_decode($entityInfo['patterns'], true),
+		] + simdjson_decode($entityInfo['content'], true);
+	}
+
 }

src/Plugin/EmulateElastic/InitKibanaHandler.php

@@ -11,6 +11,7 @@
 
 namespace Manticoresearch\Buddy\Base\Plugin\EmulateElastic;
 
+use Manticoresearch\Buddy\Core\Error\GenericError;
 use Manticoresearch\Buddy\Core\ManticoreSearch\Client as HTTPClient;
 use Manticoresearch\Buddy\Core\Task\Task;
 use Manticoresearch\Buddy\Core\Task\TaskResult;
@@ -65,15 +66,20 @@ public function run(): Task {
 					],
 					'status' => 404,
 				];
-			} else {
-				$resp = [];
-				foreach ($queryResult[0]['data'] as $entity) {
-					$resp[$entity['_index']] = [
-						'aliases' => [
-							$alias => [],
-						],
-					] + simdjson_decode($entity['_source'], true);
-				}
+				$customError = GenericError::create('', false);
+				$customError->setResponseErrorBody($resp);
+				$customError->setResponseErrorCode(404);
+
+				throw $customError;
+			}
+
+			$resp = [];
+			foreach ($queryResult[0]['data'] as $entity) {
+				$resp[$entity['_index']] = [
+					'aliases' => [
+						$alias => [],
+					],
+				] + simdjson_decode($entity['_source'], true);
 			}
 
 			return TaskResult::raw($resp);

src/Plugin/EmulateElastic/NodesInfoKibanaHandler.php

@@ -24,6 +24,8 @@
  */
 class NodesInfoKibanaHandler extends BaseHandlerWithClient {
 
+	const DEFAULT_KIBANA_VERSION = '7.6.0';
+
 	/**
 	 *  Initialize the executor
 	 *
@@ -58,7 +60,7 @@ public function run(): Task {
 								'publish_address' => "$ip:$port",
 							],
 							'ip' => $ip,
-							'version' => '7.6.0',
+							'version' => $settings->searchdKibanaVersionString ?? self::DEFAULT_KIBANA_VERSION,
 						],
 					],
 				]