mirror of
https://github.com/labring/FastGPT.git
synced 2026-01-21 01:15:42 +08:00
* feat: migrate chat files to s3 (#5802) * feat: migrate chat files to s3 * feat: add delete jobs for deleting s3 files * chore: improvements * fix: lockfile * fix: imports * feat: add ttl for those uploaded files but not send yet * feat: init bullmq worker * fix: s3 key * perf: s3 internal url * remove env * fix: re-sign a new url * fix: re-sign a new url * perf: s3 code --------- Co-authored-by: archer <545436317@qq.com> * update pacakge * feat: add more file type for uploading (#5807) * fix: re-sign a new url * wip: file selector * feat: add more file type for uploading * feat: migrate chat files to s3 (#5802) * feat: migrate chat files to s3 * feat: add delete jobs for deleting s3 files * chore: improvements * fix: lockfile * fix: imports * feat: add ttl for those uploaded files but not send yet * feat: init bullmq worker * fix: s3 key * perf: s3 internal url * remove env * fix: re-sign a new url * fix: re-sign a new url * perf: s3 code --------- Co-authored-by: archer <545436317@qq.com> * fix: limit minmax available file upload number * perf: file select modal code * fix: fileselect refresh * fix: ts --------- Co-authored-by: archer <545436317@qq.com> * bugfix: chat page (#5809) * fix: upload avatar * fix: chat page username display issue and setting button visibility * doc * Markdown match base64 performance * feat: improve global variables(time, file, dataset) (#5804) * feat: improve global variables(time, file, dataset) * feat: optimize code * perf: time variables code * fix: model, file * fix: hide file upload * fix: ts * hide dataset select --------- Co-authored-by: archer <545436317@qq.com> * perf: insert training queue * perf: s3 upload error i18n * fix: share page s3 * fix: timeselector ui error * var update node * Timepicker ui * feat: plugin support password * fix: password disabled UX * fix: button size * fix: no model cache for chat page (#5820) * rename function * fix: workflow bug * fix: interactive loop * fix test * perf: common textare no richtext * move system plugin config (#5803) (#5813) * move system plugin config (#5803) * move system plugin config * extract tag bar * filter * tool detail temp * marketplace * params * fix * type * search * tags render * status * ui * code * connect to backend (#5815) * feat: marketplace apis & type definitions (#5817) * chore: marketplace init * chore: marketplace list api type * chore: detail api * marketplace & import * feat: marketplace ui (#5826) * temp * marketplace * import * feat: detail return readme * chore: cache data expire 10 mins * chore: update docs * feat: marketplace ui --------- Co-authored-by: heheer <zhiyu44@qq.com> * feat: marketplace (#5830) * temp * marketplace * chore: tool list tag filter * chore: adjust --------- Co-authored-by: heheer <zhiyu44@qq.com> * tool detail drawer * remove tag filter * fix * fix * fix build * update pnpm-lock * fix type * perf code * marketplace router * fix build * navbar icon * fix ui * fix init * docs: marketplace/plugin (#5832) * temp * marketplace * docs(plugin): system tool docs --------- Co-authored-by: heheer <zhiyu44@qq.com> * default url * feat: i18n/ docker build (#5833) * chore: docker build * feat: i18n selector * fix * fix * fix: i18n parse * fix: i18n parse --------- Co-authored-by: heheer <heheer@sealos.io> Co-authored-by: Finley Ge <32237950+FinleyGe@users.noreply.github.com> Co-authored-by: heheer <zhiyu44@qq.com> * marketplace url * update action * market place code * market place code * title * fix: nextconfig * fix: copilot review * Remove bypassable regex-based XSS sanitization from marketplace search (#5835) * Initial plan * Remove problematic regex-based XSS sanitization from search inputs Co-authored-by: c121914yu <50446880+c121914yu@users.noreply.github.com> --------- Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com> Co-authored-by: c121914yu <50446880+c121914yu@users.noreply.github.com> * feat: tool tag openapi * api check * fix: tsc * fix: ts * fix: lock * sdk version * ts * sdk version * remove invalid tip * perf: export data add timezone * perf: admin plugin api move * perf: tool code * move tag code * perf: marketplace and team plugin code * remove workflow invalid request * rename global tool code * rename global tool code * rename api * fix some bugs (#5841) * fix some bugs * fix * perf: Tag filter * fix: ts * fix: ts --------- Co-authored-by: archer <545436317@qq.com> * perf: Concat function * fix: workflow snapshot push * fix: ts type * fix: login to config/* * fix: ts * fix: model avatar (#5848) * fix: model avatar * fix: ts * fix: avatar migration to s3 * update lock * fix: avatar redirect --------- Co-authored-by: archer <545436317@qq.com> * fix tool detail (#5847) * fix tool detail * init script * fix build * perf: plugin detail modal * change tooltags to tags * fix icon --------- Co-authored-by: archer <545436317@qq.com> * fix tag filter scroll (#5852) * fix create app plugin & import info (#5853) * tag size * rename toolkit * download url * import plugin status (#5854) * init doc * fix: init shell --------- Co-authored-by: 伍闲犬 <whoeverimf5@gmail.com> Co-authored-by: Zeng Qingwen <143274079+fishwww-ww@users.noreply.github.com> Co-authored-by: heheer <heheer@sealos.io> Co-authored-by: Finley Ge <32237950+FinleyGe@users.noreply.github.com> Co-authored-by: heheer <zhiyu44@qq.com> Co-authored-by: Copilot <198982749+Copilot@users.noreply.github.com>
385 lines
10 KiB
TypeScript
385 lines
10 KiB
TypeScript
import {
|
|
useRef,
|
|
useState,
|
|
useCallback,
|
|
type RefObject,
|
|
type ReactNode,
|
|
useMemo,
|
|
useEffect
|
|
} from 'react';
|
|
import type { FlexProps } from '@chakra-ui/react';
|
|
import { Flex, Box, type BoxProps } from '@chakra-ui/react';
|
|
import MyIcon from '../components/common/Icon';
|
|
import type { IconNameType } from '../components/common/Icon/type';
|
|
import { useTranslation } from 'next-i18next';
|
|
import { useToast } from './useToast';
|
|
import { getErrText } from '@fastgpt/global/common/error/utils';
|
|
import {
|
|
useBoolean,
|
|
useCreation,
|
|
useMemoizedFn,
|
|
useRequest,
|
|
useScroll,
|
|
useThrottleEffect
|
|
} from 'ahooks';
|
|
|
|
import { type PaginationProps, type PaginationResponse } from '../common/fetch/type';
|
|
import MyMenu from '../components/common/MyMenu';
|
|
import { useSystem } from './useSystem';
|
|
import { useRouter } from 'next/router';
|
|
|
|
const thresholdVal = 200;
|
|
|
|
export function usePagination<DataT, ResT = {}>(
|
|
api: (data: PaginationProps<DataT>) => Promise<PaginationResponse<ResT>>,
|
|
{
|
|
defaultPageSize = 10,
|
|
pageSizeOptions: defaultPageSizeOptions,
|
|
params,
|
|
type = 'button',
|
|
onChange,
|
|
refreshDeps,
|
|
scrollLoadType = 'bottom',
|
|
EmptyTip,
|
|
pollingInterval,
|
|
pollingWhenHidden = false,
|
|
storeToQuery = false
|
|
}: {
|
|
defaultPageSize?: number;
|
|
pageSizeOptions?: number[];
|
|
params?: DataT;
|
|
type?: 'button' | 'scroll';
|
|
onChange?: (pageNum: number) => void;
|
|
refreshDeps?: any[];
|
|
throttleWait?: number;
|
|
scrollLoadType?: 'top' | 'bottom';
|
|
EmptyTip?: React.JSX.Element;
|
|
pollingInterval?: number;
|
|
pollingWhenHidden?: boolean;
|
|
storeToQuery?: boolean;
|
|
}
|
|
) {
|
|
const router = useRouter();
|
|
let { page = '1' } = router.query as { page: string };
|
|
const numPage = Number(page);
|
|
|
|
const { toast } = useToast();
|
|
const { isPc } = useSystem();
|
|
const { t } = useTranslation();
|
|
|
|
const [isLoading, { setTrue, setFalse }] = useBoolean(false);
|
|
const [error, setError] = useState<Error | null>(null);
|
|
|
|
const [pageNum, setPageNum] = useState(numPage);
|
|
const [pageSize, setPageSize] = useState(defaultPageSize);
|
|
const pageSizeOptions = useCreation(
|
|
() => defaultPageSizeOptions || [10, 20, 50, 100],
|
|
[defaultPageSizeOptions]
|
|
);
|
|
|
|
const [total, setTotal] = useState(0);
|
|
const [data, setData] = useState<ResT[]>([]);
|
|
const totalDataLength = useMemo(() => Math.max(total, data.length), [total, data.length]);
|
|
|
|
const isEmpty = total === 0 && !isLoading;
|
|
const noMore = data.length > 0 && data.length >= totalDataLength;
|
|
|
|
const fetchData = useMemoizedFn(
|
|
async (num: number = pageNum, ScrollContainerRef?: RefObject<HTMLDivElement>) => {
|
|
if (noMore && num !== 1) return;
|
|
|
|
setTrue();
|
|
setError(null);
|
|
|
|
try {
|
|
const res = await api({
|
|
pageNum: num,
|
|
pageSize,
|
|
...params
|
|
});
|
|
|
|
setPageNum(num);
|
|
if (storeToQuery && num !== pageNum) {
|
|
router.replace({
|
|
pathname: router.pathname,
|
|
query: {
|
|
...router.query,
|
|
page: num
|
|
}
|
|
});
|
|
}
|
|
|
|
res.total !== undefined && setTotal(res.total);
|
|
|
|
if (type === 'scroll') {
|
|
if (scrollLoadType === 'top') {
|
|
const prevHeight = ScrollContainerRef?.current?.scrollHeight || 0;
|
|
const prevScrollTop = ScrollContainerRef?.current?.scrollTop || 0;
|
|
// 使用 requestAnimationFrame 来调整滚动位置
|
|
function adjustScrollPosition() {
|
|
requestAnimationFrame(
|
|
ScrollContainerRef?.current
|
|
? () => {
|
|
if (ScrollContainerRef?.current) {
|
|
const newHeight = ScrollContainerRef.current.scrollHeight;
|
|
const heightDiff = newHeight - prevHeight;
|
|
ScrollContainerRef.current.scrollTop = prevScrollTop + heightDiff;
|
|
}
|
|
}
|
|
: adjustScrollPosition
|
|
);
|
|
}
|
|
|
|
setData((prevData) => (num === 1 ? res.list : [...res.list, ...prevData]));
|
|
adjustScrollPosition();
|
|
} else {
|
|
setData((prevData) => (num === 1 ? res.list : [...prevData, ...res.list]));
|
|
}
|
|
} else {
|
|
setData(res.list);
|
|
}
|
|
|
|
onChange?.(num);
|
|
} catch (error: any) {
|
|
setError(error);
|
|
if (error.code !== 'ERR_CANCELED') {
|
|
toast({
|
|
title: getErrText(error, t('common:core.chat.error.data_error')),
|
|
status: 'error'
|
|
});
|
|
}
|
|
}
|
|
|
|
setFalse();
|
|
}
|
|
);
|
|
|
|
// Button pagination
|
|
const Pagination = useCallback(() => {
|
|
const maxPage = Math.ceil(totalDataLength / pageSize);
|
|
|
|
const IconButton = ({
|
|
icon,
|
|
isDisabled,
|
|
onClick,
|
|
...props
|
|
}: {
|
|
icon: IconNameType;
|
|
isDisabled?: boolean;
|
|
onClick: () => void;
|
|
} & FlexProps) => {
|
|
isDisabled = isDisabled || isLoading;
|
|
return (
|
|
<Flex
|
|
alignItems={'center'}
|
|
justifyContent={'center'}
|
|
borderRadius={'full'}
|
|
w={'24px'}
|
|
h={'24px'}
|
|
cursor={'pointer'}
|
|
bg={'myGray.150'}
|
|
{...(isDisabled
|
|
? {
|
|
opacity: 0.5
|
|
}
|
|
: {
|
|
onClick
|
|
})}
|
|
{...props}
|
|
>
|
|
<MyIcon name={icon} w={'6px'} color={'myGray.900'} />
|
|
</Flex>
|
|
);
|
|
};
|
|
|
|
return (
|
|
<Flex alignItems={'center'} justifyContent={'center'} fontSize={'sm'} userSelect={'none'}>
|
|
{isPc && <Box color={'myGray.500'}>{t('common:total_num', { num: totalDataLength })}</Box>}
|
|
|
|
<Flex alignItems={'center'} ml={6} mr={4}>
|
|
{isPc && (
|
|
<IconButton
|
|
mr={2}
|
|
isDisabled={pageNum === 1}
|
|
icon="common/first_page"
|
|
onClick={() => fetchData(1)}
|
|
/>
|
|
)}
|
|
<IconButton
|
|
isDisabled={pageNum === 1}
|
|
icon="common/leftArrowLight"
|
|
onClick={() => fetchData(pageNum - 1)}
|
|
/>
|
|
<Box ml={4} color={'myGray.500'}>
|
|
{pageNum}
|
|
</Box>
|
|
<Box mx={1} color={'myGray.500'}>
|
|
/
|
|
</Box>
|
|
<Box mr={4} color={'myGray.900'}>
|
|
{maxPage}
|
|
</Box>
|
|
|
|
<IconButton
|
|
isDisabled={pageNum === maxPage}
|
|
icon="common/rightArrow"
|
|
onClick={() => fetchData(pageNum + 1)}
|
|
/>
|
|
{isPc && (
|
|
<IconButton
|
|
ml={2}
|
|
isDisabled={pageNum === maxPage}
|
|
icon="common/latest_page"
|
|
onClick={() => fetchData(maxPage)}
|
|
/>
|
|
)}
|
|
</Flex>
|
|
|
|
{isPc && (
|
|
<MyMenu
|
|
menuList={[
|
|
{
|
|
label: '',
|
|
children: pageSizeOptions.map((item) => ({
|
|
label: `${item}`,
|
|
isActive: pageSize === item,
|
|
onClick: () => setPageSize(item)
|
|
}))
|
|
}
|
|
]}
|
|
Button={
|
|
<Flex alignItems={'center'} cursor={'pointer'}>
|
|
<Box color={'myGray.900'}>{pageSize}</Box>
|
|
<Box mx={1} color={'myGray.500'}>
|
|
/
|
|
</Box>
|
|
<Box color={'myGray.500'}>{t('common:page')}</Box>
|
|
<MyIcon ml={1} name={'core/chat/chevronDown'} w={'14px'} color={'myGray.900'} />
|
|
</Flex>
|
|
}
|
|
/>
|
|
)}
|
|
</Flex>
|
|
);
|
|
}, [totalDataLength, isPc, pageSize, t, pageNum, pageSizeOptions, isLoading, fetchData]);
|
|
|
|
// Scroll pagination
|
|
const DefaultRef = useRef<HTMLDivElement>(null);
|
|
const ScrollData = useMemoizedFn(
|
|
({
|
|
children,
|
|
ScrollContainerRef,
|
|
...props
|
|
}: {
|
|
children: ReactNode;
|
|
ScrollContainerRef?: RefObject<HTMLDivElement>;
|
|
} & BoxProps) => {
|
|
const ref = ScrollContainerRef || DefaultRef;
|
|
const loadText = (() => {
|
|
if (isLoading) return t('common:is_requesting');
|
|
if (noMore) return t('common:request_end');
|
|
return t('common:request_more');
|
|
})();
|
|
|
|
const scroll = useScroll(ref);
|
|
|
|
// Watch scroll position
|
|
useThrottleEffect(
|
|
() => {
|
|
if (!ref?.current || type !== 'scroll' || noMore || isLoading || data.length === 0)
|
|
return;
|
|
const { scrollTop, scrollHeight, clientHeight } = ref.current;
|
|
|
|
if (
|
|
(scrollLoadType === 'bottom' &&
|
|
scrollTop + clientHeight >= scrollHeight - thresholdVal) ||
|
|
(scrollLoadType === 'top' && scrollTop < thresholdVal)
|
|
) {
|
|
fetchData(pageNum + 1, ref);
|
|
}
|
|
},
|
|
[scroll, isLoading],
|
|
{ wait: 50 }
|
|
);
|
|
|
|
return (
|
|
<Box {...props} ref={ref} overflow={'overlay'}>
|
|
{scrollLoadType === 'top' && total > 0 && isLoading && (
|
|
<Box mt={2} fontSize={'xs'} color={'blackAlpha.500'} textAlign={'center'}>
|
|
{t('common:is_requesting')}
|
|
</Box>
|
|
)}
|
|
{children}
|
|
{scrollLoadType === 'bottom' && !isEmpty && (
|
|
<Box
|
|
mt={2}
|
|
fontSize={'xs'}
|
|
color={'blackAlpha.500'}
|
|
textAlign={'center'}
|
|
cursor={loadText === t('common:request_more') ? 'pointer' : 'default'}
|
|
onClick={() => {
|
|
if (loadText !== t('common:request_more')) return;
|
|
fetchData(pageNum + 1);
|
|
}}
|
|
>
|
|
{loadText}
|
|
</Box>
|
|
)}
|
|
{isEmpty && EmptyTip}
|
|
</Box>
|
|
);
|
|
}
|
|
);
|
|
|
|
// Reload data
|
|
const isFirstLoad = useRef(true);
|
|
const { runAsync: refresh } = useRequest(
|
|
async () => {
|
|
if (isFirstLoad.current) {
|
|
isFirstLoad.current = false;
|
|
fetchData(numPage);
|
|
return;
|
|
}
|
|
|
|
fetchData(1);
|
|
},
|
|
{
|
|
manual: false,
|
|
refreshDeps,
|
|
throttleWait: 100
|
|
}
|
|
);
|
|
// Page size refresh
|
|
useEffect(() => {
|
|
data.length > 0 && fetchData();
|
|
}, [pageSize]);
|
|
|
|
useRequest(
|
|
async () => {
|
|
if (!pollingInterval) return;
|
|
await fetchData(pageNum);
|
|
},
|
|
{
|
|
pollingInterval,
|
|
pollingWhenHidden,
|
|
manual: false,
|
|
refreshDeps: [pollingInterval]
|
|
}
|
|
);
|
|
|
|
return {
|
|
pageNum,
|
|
setPageNum,
|
|
pageSize,
|
|
total: totalDataLength,
|
|
data,
|
|
setData,
|
|
isLoading,
|
|
error,
|
|
Pagination,
|
|
ScrollData,
|
|
getData: fetchData,
|
|
refresh
|
|
};
|
|
}
|