remove console.log

Signed-off-by: Kaituo Li <[email protected]>

Author: kaituo

public/pages/DefineForecaster/components/Datasource/DataSource.tsx

@@ -113,8 +113,6 @@ export function DataSource(props: DataSourceProps) {
         ) {
           getIndicesAndAliasesBasedOnCluster([], localClusterExists);
           setLocalClusterName(selectedClusters[0].cluster);
-          console.log('Cluster useEffect triggered:', props.formikProps.values.clusters);
-          console.log('visibleIndices', visibleIndices);
         } else {
           getIndicesAndAliasesBasedOnCluster(
             selectedClusters,
@@ -126,7 +124,6 @@ export function DataSource(props: DataSourceProps) {
   }, [props.formikProps.values.clusters]);
 
   const handleClusterUpdate = (clusters: ClusterInfo[]) => {
-    console.log('handleClusterUpdate', clusters, isEdit);
     if (!clusters || clusters.length === 0) return;
 
     const visibleClusters: ClusterOption[] | undefined = props.formikProps.values.clusters ? props.formikProps.values.clusters :  getVisibleClusterOptions(getLocalCluster(clusters));
@@ -228,7 +225,6 @@ export function DataSource(props: DataSourceProps) {
   const visibleClusters = get(opensearchState, 'clusters', []) as ClusterInfo[];
   const visibleIndices = get(opensearchState, 'indices', []) as CatIndex[];
   const visibleAliases = get(opensearchState, 'aliases', []) as IndexAlias[];
-  console.log('visibleIndices', visibleIndices);
   return (
     <Fragment>
       {props.isEdit && isSelectedOptionIndexRemoved() ? (
@@ -289,7 +285,6 @@ export function DataSource(props: DataSourceProps) {
       )}
       <Field name="index" validate={validateIndex}>
         {({ field, form }: FieldProps) => {
-          console.log('index field value:', field.value);
           return (
             <FormattedFormRow
               title="Index or wildcard pattern"

public/pages/DefineForecaster/components/ForecastCategory/ForecastCategory.tsx

@@ -50,8 +50,6 @@ export function ForecastCategoryField(props: ForecastCategoryFieldProps) {
     setEnabled(props.isHCForecaster);
   }, [props.isHCForecaster]);
 
-  console.log("enabled", enabled, props.isHCForecaster);
-
   const noCategoryFields = isEmpty(props.categoryFieldOptions);
   const convertedOptions = props.categoryFieldOptions.map((option: string) => ({
     label: option,

public/pages/DefineForecaster/components/NameAndDescription/NameAndDescription.tsx

@@ -23,7 +23,6 @@ interface NameAndDescriptionProps {
 }
 
 function NameAndDescription({ onValidateForecasterName, omitTitle = false, isEditable = true }: NameAndDescriptionProps) {
-  console.log('isEditable', isEditable);
   return (
     <Fragment>
       {!omitTitle && (

public/pages/DefineForecaster/containers/DefineForecaster.tsx

@@ -107,8 +107,6 @@ export const validateForecasterNameTemplate = async (
     return undefined;
   }
 
-  console.log("isEdit", isEdit, match);
-
   if (!isEdit && match) {
     return 'Duplicate forecaster name';
   }
@@ -245,7 +243,6 @@ export const DefineForecaster = (props: DefineForecasterProps) => {
       formikProps.validateForm().then((errors) => {
         if (isEmpty(errors)) {
           // only used for define forecaster
-          console.log("formikProps.values", formikProps.values);
           optionallySaveValues(formikProps.values);
           //@ts-ignore
           props.setStep(2);

public/pages/ForecastDetail/containers/ForecasterDetail.tsx

@@ -304,9 +304,6 @@ export const ForecasterDetail = (props: ForecasterDetailProps) => {
 
     // Reset forecast point selection
     setForecastFrom(undefined);
-
-    // debugging msg
-    console.log('Chart state reset after forecaster operation');
   };
 
   const handleStartTest = async () => {
@@ -417,8 +414,6 @@ export const ForecasterDetail = (props: ForecasterDetailProps) => {
           ? 60000  // 1 minute for INITIALIZING_FORECAST
           : 1000;  // 1 second for other states
 
-        console.log(`Setting polling interval to ${pollingInterval}ms for state: ${forecaster.curState}`);
-
         const intervalId = setInterval(() => {
           dispatch(getForecaster(forecasterId, dataSourceId));
         }, pollingInterval);
@@ -441,9 +436,7 @@ export const ForecasterDetail = (props: ForecasterDetailProps) => {
 
       // Set up polling interval
       const intervalId = setInterval(() => {
-        console.log('forecaster.forecastInterval.period.interval', forecaster.forecastInterval.period.interval);
         dispatch(getForecaster(forecasterId, dataSourceId));
-        console.log('checkLatestResults');
         checkLatestResults();
       }, forecaster.forecastInterval.period.interval * 60000); // 60000ms = 1 minute
 
@@ -498,7 +491,6 @@ export const ForecasterDetail = (props: ForecasterDetailProps) => {
     // Convert the new date range to epoch for comparison
     const { startDate: newStartEpoch } = convertToEpochRange(newDateRange);
 
-    console.log('newStartEpoch', newStartEpoch, earliestAllowedTime, lastUiBreakingTime);
     // Check if the start date is earlier than allowed
     if (lastUiBreakingTime > 0 && newStartEpoch < earliestAllowedTime) {
       if (!initialFetchExecutedRef.current) {
@@ -594,7 +586,6 @@ export const ForecasterDetail = (props: ForecasterDetailProps) => {
     while (isTest && currentRetry < maxRetries && 
           (currentRetry === 0 || (rawResults.length - prevResultsCount) >= MIN_NEW_RESULTS_THRESHOLD)) {
       currentRetry++;
-      console.log(`Retry attempt ${currentRetry}/${maxRetries}, previous results: ${prevResultsCount}, current results: ${rawResults.length}, delta: ${rawResults.length - prevResultsCount}`);
 
       // Wait for the current delay
       await new Promise(resolve => setTimeout(resolve, currentDelay));
@@ -677,11 +668,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
     isResultsLoadingRef.current = true;
     setIsResultsLoading(true);
 
-    console.log('fetchForecasterResults call', {
-      source,
-      callTime: new Date().toISOString()
-    });
-
     try {
       if (!forecaster) {
         console.warn('No forecaster available');
@@ -702,8 +688,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
       const active = isActiveState(forecaster?.curState);
       const testComplete = forecaster?.curState === FORECASTER_STATE.TEST_COMPLETE && forecaster?.taskId !== '';
 
-      console.log('currentDateRange', currentDateRange, startEpoch, endEpoch, active, testComplete, forecaster?.curState);
-
       // Early return if conditions aren't met
       if (!active && !testComplete) {
         console.log('Skipping fetch: forecaster not active or test not complete');
@@ -735,7 +719,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
             throw new Error('No forecast data end time found in response');
           }
           const params = buildVisualizationParams(forecaster, effectiveOptions, maxPlotTime, maxEntities);
-          console.log('params', params);
 
           const topResultsResponse = await dispatch(
             getTopForecastResults(forecaster.id, dataSourceId, !active, params)
@@ -766,8 +749,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
         selectedEntityList
       );
 
-      console.log('requestParams', requestParams);
-
       // Choose the correct id and test flag based on the forecaster state
       const id = active ? forecasterId : forecaster.taskId;
       const isTest = !active;
@@ -789,8 +770,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
           forecaster.resultIndex || ''
         );
 
-      console.log('rawForecastResults', rawForecastResults);
-
       // Update state with the new forecast results
       setAtomicForecastResults(rawForecastResults);
 
@@ -823,8 +802,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
 
       // Only fetch if we detect the specific transition
       if (isCompletingTest) {
-        console.log('Test completed - fetching results');
-
         fetchForecasterResults({ source: "useEffect - test complete" });
       }
 
@@ -837,8 +814,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
     // Only proceed if forecaster is loaded and curState is defined
     if (!forecaster || forecaster.curState === undefined) return;
 
-    console.log('Forecaster available with state', forecaster.id, forecaster.curState);
-
     // If this is the first time we've seen the forecaster and we haven't fetched yet
     if (!initialFetchExecutedRef.current) {
       // Fetch results directly
@@ -851,8 +826,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
 
   // Keep the dateRange effect, but make it only respond to out of range changes
   useEffect(() => {
-    console.log('User changed dateRange', dateRange, initialFetchExecutedRef.current);
-
     // Skip if we haven't done the initial fetch yet
     if (!initialFetchExecutedRef.current) {
       // Just update the ref and return
@@ -902,7 +875,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
     // Now we know this is a user-initiated change that requires new data
     dateRangeRef.current = dateRange;
     if (forecaster) {
-      console.log('Fetching new data for date range change');
       fetchForecasterResults({ source: "useEffect - date range change" });
     }
   }, [dateRange]);
@@ -1162,7 +1134,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
         validateForecaster(validationForecaster, 'model', dataSourceId)
       )
         .then((resp: any) => {
-          console.log('validateForecaster resp', resp);
           if (isEmpty(Object.keys(resp.response))) {
             setValidForecasterSettings(true);
             setValidModelConfigurations(true);
@@ -1339,7 +1310,6 @@ const [visualizationOptions, setVisualizationOptions] = useState<VisualizationOp
   // get all index mappings based on forecaster's selected index
   useEffect(() => {
     if (forecaster) {
-      console.log('setIsHCForecaster from forecaster check', Date.now());
       if (get(forecaster, 'categoryField', []).length > 0) {
         setIsHCForecaster(true);
       } else {

public/pages/utils/helpers.ts

@@ -103,7 +103,6 @@ export function getVisibleOptions(
     items.length > 0
       ? groupIndicesOrAliasesByCluster(items, localClusterName, label)
       : [{ label, options: items }];
-  console.log('getVisibleOptions', indices, aliases, localClusterName);
 
   const visibleIndices = mapToVisibleOptions(indices, 'index');
   const visibleAliases = mapToVisibleOptions(aliases, 'alias');
@@ -166,7 +165,6 @@ export const filterAndSortForecasters = (
   selectedIndices: string[],
   selectedForecasterStates: FORECASTER_STATE[]
 ) => {
-  console.log('filterAndSortForecasters', search, selectedIndices, selectedForecasterStates);
   let filteredBySearch =
     search == ''
       ? forecasters
@@ -177,14 +175,12 @@ export const filterAndSortForecasters = (
       : filteredBySearch.filter((forecaster) =>
           selectedForecasterStates.includes(forecaster.curState)
         );
-  console.log('filteredBySearchAndState', filteredBySearchAndState, selectedIndices);
   let filteredBySearchAndStateAndIndex =
     selectedIndices == ALL_INDICES
       ? filteredBySearchAndState
       : filteredBySearchAndState.filter((forecaster) =>
           forecaster.indices.some((index) => selectedIndices.includes(index))
         );
-  console.log('filteredBySearchAndStateAndIndex', filteredBySearchAndStateAndIndex);
   return filteredBySearchAndStateAndIndex;
 };
 
@@ -332,7 +328,6 @@ export function getVisibleForecasterOptions(
     items.length > 0
       ? groupForecasterIndicesOrAliasesByCluster(items, localClusterName, label)
       : [{ label, options: items }];
-  console.log('getVisibleOptions', indices, aliases, localClusterName);
 
   const visibleIndices = mapToVisibleOptions(indices, 'index');
   const visibleAliases = mapToVisibleOptions(aliases, 'alias');

public/redux/reducers/forecastResults.ts

@@ -142,8 +142,6 @@ export const getForecasterResults = (
     url += `/${dataSourceId}`;
   }
 
-  console.log("getForecasterResults url", url);
-
   return {
     type: FORECASTER_RESULTS,
     request: (client: HttpSetup) => client.get(url, { query: queryParams }),

server/routes/forecast.ts

@@ -304,8 +304,6 @@ export default class ForecastService {
         convertForecastKeysToSnakeCase(request.body)
       );
 
-      console.log('create forecaster requestBody', requestBody);
-
       let params: PutForecasterParams = {
         forecasterId: forecasterId,
         ifSeqNo: ifSeqNo,
@@ -322,8 +320,6 @@ export default class ForecastService {
         this.client
       );
 
-      console.log('params', params);
-
       if (isNumber(ifSeqNo) && isNumber(ifPrimaryTerm)) {
         response = await callWithRequest('forecast.updateForecaster', params);
       } else {
@@ -376,7 +372,6 @@ export default class ForecastService {
       const requestBody = JSON.stringify(
         convertForecastKeysToSnakeCase(request.body)
       );
-      console.log('requestBody', requestBody);
       const response = await callWithRequest(
         'forecast.validateForecaster', {
         body: requestBody,
@@ -728,7 +723,6 @@ export default class ForecastService {
     opensearchDashboardsResponse: OpenSearchDashboardsResponseFactory
   ): Promise<IOpenSearchDashboardsResponse<any>> => {
     try {
-      console.log("request.query", request.query);
       const {
         dataSourceId = '',
       } = request.params as { dataSourceId?: string };
@@ -743,7 +737,6 @@ export default class ForecastService {
       const response = await callWithRequest('forecast.searchForecaster', {
         body: {},
       });
-      console.log('response', JSON.stringify(response));
       const totalForecasters = get(response, 'hits.total.value', 0);
 
       //Get all forecasters from search forecaster API
@@ -759,7 +752,6 @@ export default class ForecastService {
         }),
         {}
       );
-      console.log('allForecasters', JSON.stringify(allForecasters));
 
       // Fetch the latest realtime and runOnce tasks for all forecasters
       // using terms aggregations
@@ -863,7 +855,6 @@ export default class ForecastService {
         isRunOnce: any;
         resultIndex: string;
       };
-    console.log("getForecastResults request.params", request.params);
     const { dataSourceId = '' } = request.params as { dataSourceId?: string };
 
     if (!resultIndex) {
@@ -996,7 +987,6 @@ export default class ForecastService {
       if (maxEntities > 0) {
         const entityListAsObj =
           entityList.length === 0 ? {} : JSON.parse(entityList);
-        console.log('entityListAsObj', entityList, entityListAsObj);
 
         const entityFilters = isEmpty(entityListAsObj)
           ? {}
@@ -1123,8 +1113,6 @@ export default class ForecastService {
           this.client
         );
 
-        console.log('getForecastResults aggregatorRequestBody', JSON.stringify(aggregatorRequestBody));
-
         const aggResponse = !resultIndex
           ? await callWithRequest('forecast.searchResults', {
             body: aggregatorRequestBody,
@@ -1140,7 +1128,6 @@ export default class ForecastService {
         // Extract top entity_ids
         const topEntityBuckets = get(aggResponse, 'aggregations.top_entities.buckets', []);
         restrictedEntityIds = topEntityBuckets.map((b: any) => b.key);
-        console.log('Found top entities:', restrictedEntityIds);
 
         // If no entities matched, return empty
         if (!restrictedEntityIds.length) {
@@ -1177,8 +1164,6 @@ export default class ForecastService {
         this.client
       );
 
-      console.log('getForecastResults requestBody', JSON.stringify(requestBody));
-
       // Add pagination with search_after
       let allResults = [];
       let lastSort = null;
@@ -1206,8 +1191,6 @@ export default class ForecastService {
           paginatedRequestBody.search_after = lastSort;
         }
 
-        console.log('getForecastResults paginatedRequestBody', JSON.stringify(paginatedRequestBody));
-
         // Your existing API call, but with our paginated request body
         const response = !resultIndex
           ? await callWithRequest('forecast.searchResults', {
@@ -1238,8 +1221,6 @@ export default class ForecastService {
         }
       }
 
-      console.log('getForecastResults allResults', allResults.length);
-
       const groupedResults = new Map();
       allResults.forEach((result) => {
         const source = result._source;
@@ -1259,10 +1240,6 @@ export default class ForecastService {
         }
       });
 
-      // Convert Map to object for logging
-      // const groupedResultsObj = Object.fromEntries(groupedResults);
-      // console.log('groupedResults:', JSON.stringify(groupedResultsObj));
-
       const forecastResult: ForecastResult[] = [];
 
       // Process each group
@@ -1275,7 +1252,6 @@ export default class ForecastService {
         if (hasHorizonIndex) {
           // Sort forecasts by horizon_index and combine into arrays
           const sortedForecasts = orderBy(forecasts, ['_source.horizon_index'], ['asc']);
-          // console.log('sortedForecasts', sortedForecasts);
 
           const forecastValues: number[] = [];
           const forecastLowerBounds: number[] = [];