catchign right code

Signed-off-by: abbyhu2000 <[email protected]>

Author: abbyhu2000

src/core/public/http/intercept.ts

@@ -115,6 +115,7 @@ export async function interceptResponse(
           checkHalt(controller, error);
 
           if (!interceptor.responseError) {
+            console.log('interceptor.responseError', error);
             throw error;
           }
 

src/plugins/data/common/data_frames/types.ts

@@ -105,6 +105,11 @@ export interface IDataFrameResponse extends SearchResponse<any> {
   took: number;
 }
 
+export interface IDataFrameResponseError {
+  status: number;
+  message: string;
+}
+
 export interface IDataFrameError extends IDataFrameResponse {
   error: Error;
 }

src/plugins/data/public/search/fetch/handle_response.tsx

@@ -38,6 +38,9 @@ import { getNotifications } from '../../services';
 import { SearchRequest } from '..';
 
 export function handleResponse(request: SearchRequest, response: SearchResponse<any>) {
+  if (response.cakecakecakecakecake) {
+    console.log('cakecakecakecakecake', response);
+  }
   if (response.timed_out) {
     getNotifications().toasts.addWarning({
       title: i18n.translate('data.search.searchSource.fetch.requestTimedOutNotificationMessage', {

src/plugins/discover/public/application/view_components/utils/use_search.ts

@@ -226,6 +226,8 @@ export const useSearch = (services: DiscoverViewServices) => {
         rows: [],
       });
 
+      console.log('error', error);
+
       data.search.showError(error as Error);
     } finally {
       initalSearchComplete.current = true;

src/plugins/query_enhancements/common/utils.ts

@@ -135,6 +135,12 @@ export const fetch = (context: EnhancedFetchContext, query: Query, aggConfig?: Q
       body,
       signal,
     })
+  ).pipe(
+    catchError((error) => {
+      console.log('fetch error', error.message);
+      // Handle the error as needed, e.g., rethrow, return a default value, etc.
+      throw error; // Rethrow the error if you want it to propagate
+    })
   );
 };
 

src/plugins/query_enhancements/public/search/ppl_search_interceptor.ts

@@ -54,6 +54,7 @@ export class PPLSearchInterceptor extends SearchInterceptor {
 
     return fetch(context, query, this.getAggConfig(searchRequest, query)).pipe(
       catchError((error) => {
+        console.log('search interceptor error', error);
         return throwError(error);
       })
     );

src/plugins/query_enhancements/server/routes/index.ts

@@ -15,6 +15,7 @@ import { ISearchStrategy } from '../../../data/server';
 import { API, SEARCH_STRATEGY } from '../../common';
 import { registerQueryAssistRoutes } from './query_assist';
 import { registerDataSourceConnectionsRoutes } from './data_source_connection';
+import { instance } from '../../../console/public/application/contexts/editor_context/editor_registry';
 
 /**
  * Defines a route for a specific search strategy.
@@ -85,10 +86,9 @@ function defineRoute(
         );
         return res.ok({ body: { ...queryRes } });
       } catch (err) {
-        logger.error(err);
         return res.custom({
-          statusCode: err.status ?? 500,
-          body: err,
+          statusCode: err.name,
+          body: err.message,
         });
       }
     }

src/plugins/query_enhancements/server/search/ppl_search_strategy.ts

@@ -10,6 +10,7 @@ import {
   DATA_FRAME_TYPES,
   IDataFrameError,
   IDataFrameResponse,
+  IDataFrameResponseError,
   IDataFrameWithAggs,
   IOpenSearchDashboardsSearchRequest,
   Query,
@@ -41,7 +42,9 @@ export const pplSearchStrategyProvider = (
         const rawResponse: any = await pplFacet.describeQuery(context, request);
 
         if (!rawResponse.success) {
-          throw new Error(rawResponse.data.body);
+          const error = new Error(rawResponse.data.body);
+          error.name = rawResponse.data.status;
+          throw error;
         }
 
         const dataFrame = createDataFrame({
@@ -75,7 +78,7 @@ export const pplSearchStrategyProvider = (
           took: rawResponse.took,
         } as IDataFrameResponse;
       } catch (e) {
-        logger.error(`pplSearchStrategy: ${e.message}`);
+        logger.error(`pplSearchStrategy: ${e}`);
         if (usage) usage.trackError();
         throw e;
       }