"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.initialState = void 0;
exports.streamReducer = streamReducer;
var _log_rate_analysis = require("./log_rate_analysis");
/*
 * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
 * or more contributor license agreements. Licensed under the Elastic License
 * 2.0; you may not use this file except in compliance with the Elastic License
 * 2.0.
 */

const initialState = {
  ccsWarning: false,
  significantTerms: [],
  significantTermsGroups: [],
  errors: [],
  loaded: 0,
  loadingState: ''
};
exports.initialState = initialState;
function streamReducer(state, action) {
  if (Array.isArray(action)) {
    return action.reduce(streamReducer, state);
  }
  switch (action.type) {
    case _log_rate_analysis.API_ACTION_NAME.ADD_SIGNIFICANT_TERMS:
      return {
        ...state,
        significantTerms: [...state.significantTerms, ...action.payload]
      };
    case _log_rate_analysis.API_ACTION_NAME.ADD_SIGNIFICANT_TERMS_HISTOGRAM:
      const significantTerms = state.significantTerms.map(cp => {
        const cpHistogram = action.payload.find(h => h.fieldName === cp.fieldName && h.fieldValue === cp.fieldValue);
        if (cpHistogram) {
          cp.histogram = cpHistogram.histogram;
        }
        return cp;
      });
      return {
        ...state,
        significantTerms
      };
    case _log_rate_analysis.API_ACTION_NAME.ADD_SIGNIFICANT_TERMS_GROUP:
      return {
        ...state,
        significantTermsGroups: action.payload
      };
    case _log_rate_analysis.API_ACTION_NAME.ADD_SIGNIFICANT_TERMS_GROUP_HISTOGRAM:
      const significantTermsGroups = state.significantTermsGroups.map(cpg => {
        const cpHistogram = action.payload.find(h => h.id === cpg.id);
        if (cpHistogram) {
          cpg.histogram = cpHistogram.histogram;
        }
        return cpg;
      });
      return {
        ...state,
        significantTermsGroups
      };
    case _log_rate_analysis.API_ACTION_NAME.ADD_ERROR:
      return {
        ...state,
        errors: [...state.errors, action.payload]
      };
    case _log_rate_analysis.API_ACTION_NAME.RESET_ERRORS:
      return {
        ...state,
        errors: []
      };
    case _log_rate_analysis.API_ACTION_NAME.RESET_GROUPS:
      return {
        ...state,
        significantTermsGroups: []
      };
    case _log_rate_analysis.API_ACTION_NAME.RESET_ALL:
      return initialState;
    case _log_rate_analysis.API_ACTION_NAME.UPDATE_LOADING_STATE:
      return {
        ...state,
        ...action.payload
      };
    default:
      return state;
  }
}