import React, { useMemo, useState } from 'react'; import { useAsyncEffect } from 'ahooks'; import { Badge, Button, Card, Drawer, Empty, Modal, message, Spin } from 'antd'; import FormDialog from '@/components/database/form-dialog'; import { apiInterceptors, getDbList, getDbSupportType, postDbDelete, postDbRefresh } from '@/client/api'; import { DeleteFilled, EditFilled, PlusOutlined, RedoOutlined } from '@ant-design/icons'; import { DBOption, DBType, DbListResponse, DbSupportTypeResponse } from '@/types/db'; import MuiLoading from '@/components/common/loading'; import { dbMapper } from '@/utils'; import GPTCard from '@/components/common/gpt-card'; import { useTranslation } from 'react-i18next'; type DBItem = DbListResponse[0]; export function isFileDb(dbTypeList: DBOption[], dbType: DBType) { return dbTypeList.find((item) => item.value === dbType)?.isFileDb; } function Database() { const { t } = useTranslation(); const [dbList, setDbList] = useState([]); const [dbSupportList, setDbSupportList] = useState([]); const [loading, setLoading] = useState(false); const [modal, setModal] = useState<{ open: boolean; info?: DBItem; dbType?: DBType }>({ open: false }); const [draw, setDraw] = useState<{ open: boolean; dbList?: DbListResponse; name?: string; type?: DBType }>({ open: false }); const [refreshLoading, setRefreshLoading] = useState(false); const getDbSupportList = async () => { const [, data] = await apiInterceptors(getDbSupportType()); setDbSupportList(data ?? []); }; const refreshDbList = async () => { setLoading(true); const [, data] = await apiInterceptors(getDbList()); setDbList(data ?? []); setLoading(false); }; const dbTypeList = useMemo(() => { const supportDbList = dbSupportList.map((item) => { const { db_type, is_file_db } = item; return { ...dbMapper[db_type], value: db_type, isFileDb: is_file_db }; }) as DBOption[]; const unSupportDbList = Object.keys(dbMapper) .filter((item) => !supportDbList.some((db) => db.value === item)) .map((item) => ({ ...dbMapper[item], value: dbMapper[item].label, disabled: true })) as DBOption[]; return [...supportDbList, ...unSupportDbList]; }, [dbSupportList]); const onModify = (item: DBItem) => { setModal({ open: true, info: item }); }; const onDelete = (item: DBItem) => { Modal.confirm({ title: 'Tips', content: `Do you Want to delete the ${item.db_name}?`, onOk() { return new Promise(async (resolve, reject) => { try { const [err] = await apiInterceptors(postDbDelete(item.db_name)); if (err) { message.error(err.message); reject(); return; } message.success('success'); refreshDbList(); resolve(); } catch (e: any) { reject(); } }); }, }); }; const onRefresh = async (item: DBItem) => { setRefreshLoading(true); const [, res] = await apiInterceptors(postDbRefresh({ db_name: item.db_name, db_type: item.db_type })); if (res) message.success(t('refreshSuccess')); setRefreshLoading(false); }; const dbListByType = useMemo(() => { const mapper = dbTypeList.reduce((acc, item) => { acc[item.value] = dbList.filter((dbConn) => dbConn.db_type === item.value); return acc; }, {} as Record); return mapper; }, [dbList, dbTypeList]); useAsyncEffect(async () => { await refreshDbList(); await getDbSupportList(); }, []); const handleDbTypeClick = (info: DBOption) => { const dbItems = dbList.filter((item) => item.db_type === info.value); setDraw({ open: true, dbList: dbItems, name: info.label, type: info.value }); }; return (
{dbTypeList.map((item) => ( { if (item.disabled) return; handleDbTypeClick(item); }} /> ))}
item.db_name)} onSuccess={() => { setModal({ open: false }); refreshDbList(); }} onClose={() => { setModal({ open: false }); }} /> { setDraw({ open: false }); }} open={draw.open} > {draw.type && dbListByType[draw.type] && dbListByType[draw.type].length ? ( {dbListByType[draw.type].map((item) => ( { onRefresh(item); }} /> { onModify(item); }} /> { onDelete(item); }} />
} className="mb-4" > {item.db_path ? (

path: {item.db_path}

) : ( <>

host: {item.db_host}

username: {item.db_user}

port: {item.db_port}

)}

remark: {item.comment}

))} ) : ( )} ); } export default Database;