src/containers/Tenant/TopicFormDialog/utils.ts - main - githubmirror/ydb-embedded-ui

src/containers/Tenant/TopicFormDialog/utils.ts
139 строк4 KB
Максим
feat: add topic and table forms (#3909)
28 июл 2026, 12:49
28 июл 2026, 12:497477f07
import type {TopicFormValues} from '../../../store/reducers/topic/utils';
import {AutoPartitioningStrategy} from '../../../store/reducers/topic/utils';
import {UNBREAKABLE_GAP} from '../../../utils/constants';

export const TOPIC_FORM_DIALOG = 'topic-form-dialog';

const KILOBYTE = 1024;
const MEGABYTE = KILOBYTE * 1024;

export const DEFAULT_TOPIC_FORM_VALUES: TopicFormValues = {
    shards: 1,
    writeQuotaBytes: 1024 * 1024,
    autoPartitioning: {
        enabled: false,
        mode: AutoPartitioningStrategy.ScaleUp,
        minPartitions: 1,
        maxPartitions: 2,
        stabilizationWindow: 300,
        upUtilization: 90,
    },
};

export function acceptNumber(value: string) {
    return value === '' || (/^[0-9]+$/.test(value) && Number(value) <= Number.MAX_SAFE_INTEGER);
}

export function parseNumberInput(value: string): number {
    return value ? Number.parseInt(value, 10) : NaN;
}

export function formatNumberInput(value: number | undefined): string {
    return typeof value === 'number' && !Number.isNaN(value) ? value.toString() : '';
}

export function formatBandwidthBytes(value: number | undefined) {
    if (typeof value !== 'number' || Number.isNaN(value)) {
        return '';
    }

    if (value >= MEGABYTE) {
        return `${value / MEGABYTE}${UNBREAKABLE_GAP}MB/s`;
    }

    if (value >= KILOBYTE) {
        return `${value / KILOBYTE}${UNBREAKABLE_GAP}KB/s`;
    }

    return `${value}${UNBREAKABLE_GAP}byte/s`;
}

export function formatWriteQuotaSelectValue(value: number | undefined) {
    if (typeof value !== 'number' || Number.isNaN(value)) {
        return '';
    }

    if (value >= MEGABYTE && value % MEGABYTE === 0) {
        return `${value / MEGABYTE}${UNBREAKABLE_GAP}MB/s`;
    }

    if (value >= KILOBYTE && value % KILOBYTE === 0) {
        return `${value / KILOBYTE}${UNBREAKABLE_GAP}KB/s`;
    }

    return `${value}${UNBREAKABLE_GAP}byte/s`;
}

function normalizePath(path: string) {
    return path.replace(/^\/+|\/+$/g, '');
}

function getRelativePath(path: string, databaseFullPath: string): string | undefined {
    const normalizedPath = normalizePath(path);
    const normalizedDatabase = normalizePath(databaseFullPath);

    if (!normalizedPath || normalizedPath === normalizedDatabase) {
        return undefined;
    }

    if (normalizedPath.startsWith(`${normalizedDatabase}/`)) {
        return normalizedPath.slice(normalizedDatabase.length + 1) || undefined;
    }

    return normalizedPath;
}

function splitTopicPath(topicPath: string, databaseFullPath: string) {
    const relativePath = getRelativePath(topicPath, databaseFullPath);
    const pathSegments = relativePath?.split('/').filter(Boolean) ?? [];
    const name = pathSegments.pop() ?? '';
    const path = pathSegments.join('/');

    return {path: path || undefined, name};
}

export function buildFullTopicPath(formData: TopicFormValues, databaseFullPath: string) {
    const databasePath = databaseFullPath.startsWith('/')
        ? databaseFullPath
        : `/${databaseFullPath}`;
    const relativeTopicPath = [formData.path, formData.name].filter(Boolean).join('/');

    return relativeTopicPath ? `${databasePath}/${relativeTopicPath}` : databasePath;
}

export function getCreateTopicInitialValues({
    databaseFullPath,
    parentPath,
}: {
    databaseFullPath: string;
    parentPath?: string;
}): TopicFormValues {
    return {
        ...DEFAULT_TOPIC_FORM_VALUES,
        path: parentPath ? getRelativePath(parentPath, databaseFullPath) : undefined,
        autoPartitioning: {...DEFAULT_TOPIC_FORM_VALUES.autoPartitioning},
    };
}

export function getUpdateTopicInitialValues({
    databaseFullPath,
    formData,
    topicPath,
}: {
    databaseFullPath: string;
    formData: TopicFormValues;
    topicPath: string;
}): TopicFormValues {
    const topicPathData = splitTopicPath(topicPath, databaseFullPath);

    return {
        ...DEFAULT_TOPIC_FORM_VALUES,
        ...formData,
        path: topicPathData.path,
        name: topicPathData.name || formData.name,
        autoPartitioning: {
            ...DEFAULT_TOPIC_FORM_VALUES.autoPartitioning,
            ...formData.autoPartitioning,
        },
    };
}