Support log pattern if there is dsl and index passed for alert summary.

CHANGELOG.md

@@ -45,4 +45,5 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 - Support insight with RAG in alert analysis assistant and refine the UX ([#266](https://github.com/opensearch-project/dashboards-assistant/pull/266))
 - Add assistant enabled capabilities to control rendering component([#267](https://github.com/opensearch-project/dashboards-assistant/pull/267))
 - Add data to summary API([#295](https://github.com/opensearch-project/dashboards-assistant/pull/295))
-- Refactor popover to add message action bar and add metrics to thumb-up and thumb-down([#304](https://github.com/opensearch-project/dashboards-assistant/pull/304))
+- Refactor popover to add message action bar and add metrics to thumb-up and thumb-down([#304](https://github.com/opensearch-project/dashboards-assistant/pull/304))
+- Support log pattern analysis ([#339](https://github.com/opensearch-project/dashboards-assistant/pull/339))

public/components/incontext_insight/generate_popover_body.tsx

@@ -102,6 +102,8 @@ export const GeneratePopoverBody: React.FC<{
             ? 'os_insight'
             : 'user_insight'
           : undefined;
+      const index = contextObj?.additionalInfo?.index;
+      const dsl = contextObj?.additionalInfo?.dsl;
 
       await httpSetup
         ?.post(SUMMARY_ASSISTANT_API.SUMMARIZE, {
@@ -110,6 +112,8 @@ export const GeneratePopoverBody: React.FC<{
             insightType,
             question: summarizationQuestion,
             context: contextContent,
+            index,
+            dsl,
           }),
           query: dataSourceQuery,
         })

server/routes/summary_routes.ts

@@ -11,6 +11,7 @@ import { getAgentIdByConfigName, searchAgent } from './get_agent';
 import { AssistantServiceSetup } from '../services/assistant_service';
 
 const SUMMARY_AGENT_CONFIG_ID = 'os_summary';
+const LOG_PATTERN_SUMMARY_AGENT_CONFIG_ID = 'os_summary_with_logPattern';
 const OS_INSIGHT_AGENT_CONFIG_ID = 'os_insight';
 const DATA2SUMMARY_AGENT_CONFIG_ID = 'os_data2summary';
 let osInsightAgentId: string | undefined;
@@ -29,6 +30,8 @@ export function registerSummaryAssistantRoutes(
           insightType: schema.maybe(schema.string()),
           question: schema.string(),
           context: schema.maybe(schema.string()),
+          index: schema.maybe(schema.string()),
+          dsl: schema.maybe(schema.string()),
         }),
         query: schema.object({
           dataSourceId: schema.maybe(schema.string()),
@@ -41,9 +44,15 @@ export function registerSummaryAssistantRoutes(
         dataSourceId: req.query.dataSourceId,
       });
       const assistantClient = assistantService.getScopedClient(req, context);
-      const response = await assistantClient.executeAgentByConfigName(SUMMARY_AGENT_CONFIG_ID, {
+      const agentConfigId =
+        req.body.index && req.body.dsl
+          ? LOG_PATTERN_SUMMARY_AGENT_CONFIG_ID
+          : SUMMARY_AGENT_CONFIG_ID;
+      const response = await assistantClient.executeAgentByConfigName(agentConfigId, {
         context: req.body.context,
         question: req.body.question,
+        index: req.body.index,
+        input: req.body.dsl,
       });
       let summary;
       let insightAgentIdExists = false;
@@ -114,14 +123,13 @@ export function registerSummaryAssistantRoutes(
         question: req.body.question,
       });
       try {
-        let result = response.body.inference_results[0].output[0].result;
-        result = JSON.parse(result).output.text;
-        return res.ok({ body: result });
+        return res.ok({ body: response.body.inference_results[0].output[0].result });
       } catch (e) {
         return res.internalError();
       } finally {
-        // Reset userInsightAgentId in case users update their insight agent.
+        // Reset both agents id in case of update
         userInsightAgentId = undefined;
+        osInsightAgentId = undefined;
       }
     })
   );