import React, { useMemo, useState, useEffect } from 'react'; import { useTranslation } from 'react-i18next'; import { useParams, Link } from 'react-router-dom'; import { useAccountSubplebbits, useFeed, Comment, usePublishCommentModeration } from '@plebbit/plebbit-react-hooks'; import { Virtuoso } from 'react-virtuoso'; import { formatDistanceToNow } from 'date-fns'; import styles from './mod-queue.module.css'; import useModQueueStore from '../../stores/use-mod-queue-store'; import { useAccountSubplebbitsWithMetadata } from '../../hooks/use-account-subplebbits-with-metadata'; import LoadingEllipsis from '../../components/loading-ellipsis'; import { useFeedStateString } from '../../hooks/use-state-string'; import { getSubplebbitAddress, getBoardPath } from '../../lib/utils/route-utils'; import { useDefaultSubplebbits, MultisubSubplebbit } from '../../hooks/use-default-subplebbits'; import { useBoardPath } from '../../hooks/use-resolved-subplebbit-address'; import { getHasThumbnail, getCommentMediaInfo } from '../../lib/utils/media-utils'; import useFeedResetStore from '../../stores/use-feed-reset-store'; import useChallengesStore from '../../stores/use-challenges-store'; import { alertChallengeVerificationFailed } from '../../lib/utils/challenge-utils'; const { addChallenge } = useChallengesStore.getState(); interface ModQueueViewProps { boardIdentifier?: string; // If provided, shows queue for single board } interface ModQueueFooterProps { hasMore: boolean; loadingStateString: string; } // Defined outside ModQueueView to preserve component identity across renders (Virtuoso optimization) const ModQueueFooter = ({ hasMore, loadingStateString }: ModQueueFooterProps) => { return hasMore ? (
) : null; }; interface ModQueueRowProps { comment: Comment; showBoardColumn?: boolean; } // Track which action was initiated to show appropriate completion message type ModerationAction = 'approve' | 'reject' | null; const ModQueueRow = ({ comment, showBoardColumn = false }: ModQueueRowProps) => { const { t } = useTranslation(); const { alertThresholdHours } = useModQueueStore(); const [initiatedAction, setInitiatedAction] = useState(null); const { content, title, timestamp, subplebbitAddress, cid, threadCid, link, thumbnailUrl, linkWidth, linkHeight, removed, approved } = comment; // Check if already moderated (from previous session or API update) // Note: `approved` and `removed` are direct fields on the comment from CommentUpdate, // not nested under commentModeration (which is the options object for publishing moderation actions) const alreadyApproved = approved === true; const alreadyRejected = removed === true; const boardPath = useBoardPath(subplebbitAddress); const timeWaiting = Date.now() / 1000 - timestamp; const isOverThreshold = timeWaiting > alertThresholdHours * 3600; const { publishCommentModeration: approve, state: approveState, error: approveError, } = usePublishCommentModeration({ commentCid: cid, subplebbitAddress, commentModeration: { approved: true }, onChallenge: async (...args: any) => { addChallenge([...args, comment]); }, onChallengeVerification: async (challengeVerification, comment) => { alertChallengeVerificationFailed(challengeVerification, comment); }, onError: (error: Error) => { console.error('Approve failed:', error); }, }); const { publishCommentModeration: reject, state: rejectState, error: rejectError, } = usePublishCommentModeration({ commentCid: cid, subplebbitAddress, commentModeration: { removed: true }, onChallenge: async (...args: any) => { addChallenge([...args, comment]); }, onChallengeVerification: async (challengeVerification, comment) => { alertChallengeVerificationFailed(challengeVerification, comment); }, onError: (error: Error) => { console.error('Reject failed:', error); }, }); const handleApprove = async () => { setInitiatedAction('approve'); try { await approve(); } catch (e) { console.error(e); } }; const handleReject = async () => { setInitiatedAction('reject'); try { await reject(); } catch (e) { console.error(e); } }; // Determine the current moderation state based on which action was initiated const isApproving = initiatedAction === 'approve' && approveState !== 'initializing' && approveState !== 'succeeded' && approveState !== 'failed'; const isRejecting = initiatedAction === 'reject' && rejectState !== 'initializing' && rejectState !== 'succeeded' && rejectState !== 'failed'; const isPublishing = isApproving || isRejecting; const approveSucceeded = initiatedAction === 'approve' && approveState === 'succeeded'; const rejectSucceeded = initiatedAction === 'reject' && rejectState === 'succeeded'; const approveFailed = initiatedAction === 'approve' && approveState === 'failed'; const rejectFailed = initiatedAction === 'reject' && rejectState === 'failed'; const excerpt = title || content || (getHasThumbnail(getCommentMediaInfo(link, thumbnailUrl, linkWidth, linkHeight), link) ? t('image') : t('no_content')); const threadTargetCid = threadCid || cid; const postUrl = boardPath && threadTargetCid ? `/${boardPath}/thread/${threadTargetCid}` : undefined; // Render the status or action buttons const renderActions = () => { // Check existing moderation state first (from API/previous sessions) if (alreadyApproved || approveSucceeded) { return {t('approved')}; } if (alreadyRejected || rejectSucceeded) { return {t('rejected')}; } if (approveFailed) { return ( {t('failed')}: {approveError?.message} ); } if (rejectFailed) { return ( {t('failed')}: {rejectError?.message} ); } if (isPublishing) { return ; } return ( <> [ ] [ ] ); }; return (
{showBoardColumn &&
{boardPath ? /{boardPath}/ : }
}
{postUrl ? ( {excerpt} ) : ( {excerpt} )}
{formatDistanceToNow(timestamp * 1000, { addSuffix: false })}
{renderActions()}
); }; interface ModQueueBoardFilterProps { subplebbits: MultisubSubplebbit[]; } const ModQueueBoardFilter = ({ subplebbits }: ModQueueBoardFilterProps) => { const { t } = useTranslation(); const { selectedBoardFilter, setSelectedBoardFilter } = useModQueueStore(); const handleChange = (e: React.ChangeEvent) => { const value = e.target.value; setSelectedBoardFilter(value === '' ? null : value); }; if (!subplebbits || subplebbits.length === 0) { return null; } return (
); }; interface ModQueueButtonProps { boardIdentifier?: string; isMobile?: boolean; } export const ModQueueButton = ({ boardIdentifier, isMobile }: ModQueueButtonProps) => { const { t } = useTranslation(); const { alertThresholdHours } = useModQueueStore(); const { accountSubplebbits } = useAccountSubplebbits(); const accountSubplebbitAddresses = useMemo(() => Object.keys(accountSubplebbits || {}), [accountSubplebbits]); const defaultSubplebbits = useDefaultSubplebbits(); // Resolve boardIdentifier to address if it exists const resolvedAddress = useMemo(() => { if (boardIdentifier) { return getSubplebbitAddress(boardIdentifier, defaultSubplebbits); } return undefined; }, [boardIdentifier, defaultSubplebbits]); const subplebbitAddresses = useMemo(() => { if (resolvedAddress) { return [resolvedAddress]; } return accountSubplebbitAddresses; }, [resolvedAddress, accountSubplebbitAddresses]); // If specific board, check if user is mod using resolved address const isModOfBoard = resolvedAddress ? accountSubplebbitAddresses.includes(resolvedAddress) : true; // Only fetch if we have addresses to check and permissions const shouldFetch = subplebbitAddresses.length > 0 && isModOfBoard; const { feed } = useFeed({ subplebbitAddresses: shouldFetch ? subplebbitAddresses : [], modQueue: ['pendingApproval'], postsPerPage: 100, // Fetch enough to check timestamps }); if (!shouldFetch || subplebbitAddresses.length === 0) { return null; } // Sort feed by timestamp (oldest first) to match ModQueueView sorting const sortedFeed = useMemo(() => { return [...feed].sort((a, b) => a.timestamp - b.timestamp); }, [feed]); // Separate comments into normal and urgent based on threshold // Match ModQueueRow logic: use > (strictly greater) to be consistent const { normalCount, urgentCount } = useMemo(() => { const thresholdSeconds = alertThresholdHours * 3600; const now = Date.now() / 1000; let normal = 0; let urgent = 0; for (const item of sortedFeed) { const timeWaiting = now - item.timestamp; if (timeWaiting > thresholdSeconds) { urgent++; } else { normal++; } } return { normalCount: normal, urgentCount: urgent }; }, [sortedFeed, alertThresholdHours]); const totalCount = normalCount + urgentCount; // Use boardIdentifier for the route, but resolvedAddress for mod check const to = boardIdentifier ? `/${boardIdentifier}/queue` : '/mod/queue'; const buttonContent = ( ); return isMobile ? buttonContent : <>[{buttonContent}]; }; export const ModQueueView = ({ boardIdentifier: propBoardIdentifier }: ModQueueViewProps) => { const { t } = useTranslation(); const params = useParams(); const { selectedBoardFilter, alertThresholdHours, setAlertThresholdHours } = useModQueueStore(); const { accountSubplebbits } = useAccountSubplebbits(); const accountSubplebbitAddresses = Object.keys(accountSubplebbits); const defaultSubplebbits = useDefaultSubplebbits(); const boardIdentifier = propBoardIdentifier || params.boardIdentifier; // Resolve boardIdentifier to address if it exists const resolvedAddress = useMemo(() => { if (boardIdentifier) { return getSubplebbitAddress(boardIdentifier, defaultSubplebbits); } return undefined; }, [boardIdentifier, defaultSubplebbits]); // Get metadata for filter dropdown const subplebbitsWithMetadata = useAccountSubplebbitsWithMetadata(); const subplebbitAddresses = useMemo(() => { if (resolvedAddress) { return [resolvedAddress]; } if (selectedBoardFilter) { return [selectedBoardFilter]; } return accountSubplebbitAddresses; }, [resolvedAddress, selectedBoardFilter, accountSubplebbitAddresses]); const { feed, hasMore, loadMore, reset } = useFeed({ subplebbitAddresses, modQueue: ['pendingApproval'], postsPerPage: 50, }); // Sort feed by timestamp (oldest first) to show items waiting longest at the top const sortedFeed = useMemo(() => { return [...feed].sort((a, b) => a.timestamp - b.timestamp); }, [feed]); // Register reset function with feed reset store so refresh button works const setResetFunction = useFeedResetStore((state) => state.setResetFunction); useEffect(() => { setResetFunction(reset); }, [reset, setResetFunction]); const loadingStateString = useFeedStateString(subplebbitAddresses) || t('loading'); const showBoardColumn = !resolvedAddress && !selectedBoardFilter; // Memoize footer components object to preserve identity across renders (Virtuoso optimization) const footerComponents = useMemo( () => ({ Footer: () => , }), [hasMore, loadingStateString], ); return (
{t('moderation_queue')}
{!resolvedAddress && } {sortedFeed.length === 0 && !hasMore ? (
{t('queue_is_empty')}
) : ( <>
{showBoardColumn &&
{t('board')}
}
{t('excerpt')}
{t('waiting')}
{t('actions')}
} components={footerComponents} /> )}
); }; export default ModQueueView;