kafka-ui/kafka-ui-react-app/src/redux/reducers/topicMessages/reducer.ts

import { Action, TopicMessagesState } from 'redux/interfaces';
import { getType } from 'typesafe-actions';
import * as actions from 'redux/actions';

export const initialState: TopicMessagesState = {
  messages: [],
  meta: {
    bytesConsumed: 0,
    elapsedMs: 0,
    messagesConsumed: 0,
    isCancelled: false,
  },
  isFetching: false,
};

// eslint-disable-next-line @typescript-eslint/default-param-last
const reducer = (state = initialState, action: Action): TopicMessagesState => {
  switch (action.type) {
    case getType(actions.addTopicMessage): {
      return {
        ...state,
        messages: [action.payload, ...state.messages],
      };
    }
    case getType(actions.resetTopicMessages):
      return initialState;
    case getType(actions.updateTopicMessagesPhase):
      return {
        ...state,
        phase: action.payload,
      };
    case getType(actions.updateTopicMessagesMeta):
      return {
        ...state,
        meta: action.payload,
      };
    case getType(actions.setTopicMessagesFetchingStatus):
      return {
        ...state,
        isFetching: action.payload,
      };
    case getType(actions.clearMessagesTopicAction.success):
      return {
        ...state,
        messages: [],
      };
    default:
      return state;
  }
};

export default reducer;