import React from 'react';

import {skipToken} from '@reduxjs/toolkit/query';

import {ResponseError} from '../../../../components/Errors/ResponseError';
import {ResizeableDataTable} from '../../../../components/ResizeableDataTable/ResizeableDataTable';
import {TableColumnSetup} from '../../../../components/TableColumnSetup/TableColumnSetup';
import {TableWithControlsLayout} from '../../../../components/TableWithControlsLayout/TableWithControlsLayout';
import {useClusterWithProxy} from '../../../../store/reducers/cluster/cluster';
import {nodesListApi, selectNodesMap} from '../../../../store/reducers/nodesList';
import {partitionsApi, setSelectedConsumer} from '../../../../store/reducers/partitions/partitions';
import {selectConsumersNames, topicApi} from '../../../../store/reducers/topic/topic';
import {cn} from '../../../../utils/cn';
import {DEFAULT_TABLE_SETTINGS} from '../../../../utils/constants';
import {useAutoRefreshInterval, useTypedDispatch, useTypedSelector} from '../../../../utils/hooks';

import {PartitionsControls} from './PartitionsControls/PartitionsControls';
import {PARTITIONS_COLUMNS_WIDTH_LS_KEY} from './columns';
import i18n from './i18n';
import {addHostToPartitions} from './utils';
import type {PreparedPartitionDataWithHosts} from './utils/types';
import {useGetPartitionsColumns} from './utils/useGetPartitionsColumns';

import './Partitions.scss';

export const b = cn('ydb-diagnostics-partitions');

interface PartitionsProps {
    path: string;
    database: string;
    databaseFullPath: string;
}

export const Partitions = ({path, database, databaseFullPath}: PartitionsProps) => {
    const dispatch = useTypedDispatch();
    const useMetaProxy = useClusterWithProxy();

    const [partitionsToRender, setPartitionsToRender] = React.useState<
        PreparedPartitionDataWithHosts[]
    >([]);

    const consumers = useTypedSelector((state) =>
        selectConsumersNames(state, path, database, databaseFullPath, useMetaProxy),
    );
    const [autoRefreshInterval] = useAutoRefreshInterval();
    const {selectedConsumer} = useTypedSelector((state) => state.partitions);
    const {
        currentData: topicData,
        isFetching: topicIsFetching,
        error: topicError,
    } = topicApi.useGetTopicQuery({path, database, databaseFullPath, useMetaProxy});
    const topicLoading = topicIsFetching && topicData === undefined;
    const {
        currentData: nodesData,
        isFetching: nodesIsFetching,
        error: nodesError,
    } = nodesListApi.useGetNodesListQuery({database}, undefined);
    const nodesLoading = nodesIsFetching && nodesData === undefined;
    const nodeHostsMap = useTypedSelector((state) => selectNodesMap(state, database));

    const {columnsToShow, columnsToSelect, setColumns} = useGetPartitionsColumns(selectedConsumer);

    const params = topicLoading
        ? skipToken
        : {path, database, consumerName: selectedConsumer, databaseFullPath, useMetaProxy};
    const {
        currentData: partitionsData,
        isFetching: partitionsIsFetching,
        error: partitionsError,
    } = partitionsApi.useGetPartitionsQuery(params, {pollingInterval: autoRefreshInterval});
    const partitionsLoading = partitionsIsFetching && partitionsData === undefined;
    const rawPartitions = partitionsData;

    const partitionsWithHosts = React.useMemo(() => {
        return addHostToPartitions(rawPartitions, nodeHostsMap);
    }, [rawPartitions, nodeHostsMap]);

    // Wrong consumer could be passed in search query
    // Reset consumer if it doesn't exist for current topic
    React.useEffect(() => {
        const isTopicWithoutConsumers = !topicLoading && !consumers;
        const wrongSelectedConsumer =
            selectedConsumer && consumers && !consumers.includes(selectedConsumer);

        if (isTopicWithoutConsumers || wrongSelectedConsumer) {
            dispatch(setSelectedConsumer(undefined));
        }
    }, [dispatch, topicLoading, selectedConsumer, consumers]);

    const handleSelectedConsumerChange = (value?: string) => {
        dispatch(setSelectedConsumer(value));
    };

    const loading = topicLoading || nodesLoading || partitionsLoading;

    const error = nodesError || topicError || partitionsError;

    const renderControls = () => {
        return (
            <PartitionsControls
                consumers={consumers}
                selectedConsumer={selectedConsumer}
                onSelectedConsumerChange={handleSelectedConsumerChange}
                selectDisabled={Boolean(error) || loading}
                partitions={partitionsWithHosts}
                onSearchChange={setPartitionsToRender}
            />
        );
    };

    const renderExtraControls = () => {
        return <TableColumnSetup items={columnsToSelect} showStatus onUpdate={setColumns} />;
    };

    const renderContent = () => {
        return (
            <ResizeableDataTable
                columnsWidthLSKey={PARTITIONS_COLUMNS_WIDTH_LS_KEY}
                wrapperClassName={b('table')}
                data={partitionsToRender}
                columns={columnsToShow}
                isLoading={loading}
                settings={DEFAULT_TABLE_SETTINGS}
                emptyDataMessage={i18n('table.emptyDataMessage')}
            />
        );
    };

    return (
        <TableWithControlsLayout className={b()}>
            <TableWithControlsLayout.Controls renderExtraControls={renderExtraControls}>
                {renderControls()}
            </TableWithControlsLayout.Controls>
            <TableWithControlsLayout.Table>
                {error ? <ResponseError error={error} /> : null}
                {partitionsData ? renderContent() : null}
            </TableWithControlsLayout.Table>
        </TableWithControlsLayout>
    );
};