mirror of
https://github.com/hibiken/asynqmon.git
synced 2025-04-19 23:30:12 +08:00
203 lines
6.1 KiB
TypeScript
203 lines
6.1 KiB
TypeScript
import React, { useCallback, useState } from "react";
|
|
import { connect, ConnectedProps } from "react-redux";
|
|
import { makeStyles } from "@material-ui/core/styles";
|
|
import Table from "@material-ui/core/Table";
|
|
import TableBody from "@material-ui/core/TableBody";
|
|
import TableCell from "@material-ui/core/TableCell";
|
|
import Alert from "@material-ui/lab/Alert";
|
|
import AlertTitle from "@material-ui/lab/AlertTitle";
|
|
import TableContainer from "@material-ui/core/TableContainer";
|
|
import TableHead from "@material-ui/core/TableHead";
|
|
import TableRow from "@material-ui/core/TableRow";
|
|
import Tooltip from "@material-ui/core/Tooltip";
|
|
import Paper from "@material-ui/core/Paper";
|
|
import Box from "@material-ui/core/Box";
|
|
import Collapse from "@material-ui/core/Collapse";
|
|
import IconButton from "@material-ui/core/IconButton";
|
|
import KeyboardArrowUpIcon from "@material-ui/icons/KeyboardArrowUp";
|
|
import KeyboardArrowDownIcon from "@material-ui/icons/KeyboardArrowDown";
|
|
import Typography from "@material-ui/core/Typography";
|
|
import TableFooter from "@material-ui/core/TableFooter";
|
|
import TablePagination from "@material-ui/core/TablePagination";
|
|
import SyntaxHighlighter from "./SyntaxHighlighter";
|
|
import TablePaginationActions, {
|
|
defaultPageSize,
|
|
rowsPerPageOptions,
|
|
} from "./TablePaginationActions";
|
|
import { listPendingTasksAsync } from "../actions/tasksActions";
|
|
import { AppState } from "../store";
|
|
import { PendingTask } from "../api";
|
|
import { usePolling } from "../hooks";
|
|
import { uuidPrefix } from "../utils";
|
|
import { TableColumn } from "../types/table";
|
|
|
|
const useStyles = makeStyles((theme) => ({
|
|
table: {
|
|
minWidth: 650,
|
|
},
|
|
stickyHeaderCell: {
|
|
background: theme.palette.background.paper,
|
|
},
|
|
}));
|
|
|
|
function mapStateToProps(state: AppState) {
|
|
return {
|
|
loading: state.tasks.pendingTasks.loading,
|
|
tasks: state.tasks.pendingTasks.data,
|
|
pollInterval: state.settings.pollInterval,
|
|
};
|
|
}
|
|
|
|
const mapDispatchToProps = { listPendingTasksAsync };
|
|
|
|
const connector = connect(mapStateToProps, mapDispatchToProps);
|
|
|
|
type ReduxProps = ConnectedProps<typeof connector>;
|
|
|
|
interface Props {
|
|
queue: string;
|
|
totalTaskCount: number; // total number of pending tasks
|
|
}
|
|
|
|
function PendingTasksTable(props: Props & ReduxProps) {
|
|
const { pollInterval, listPendingTasksAsync, queue } = props;
|
|
const classes = useStyles();
|
|
const [page, setPage] = useState(0);
|
|
const [pageSize, setPageSize] = useState(defaultPageSize);
|
|
|
|
const handleChangePage = (
|
|
event: React.MouseEvent<HTMLButtonElement> | null,
|
|
newPage: number
|
|
) => {
|
|
setPage(newPage);
|
|
};
|
|
|
|
const handleChangeRowsPerPage = (
|
|
event: React.ChangeEvent<HTMLInputElement | HTMLTextAreaElement>
|
|
) => {
|
|
setPageSize(parseInt(event.target.value, 10));
|
|
setPage(0);
|
|
};
|
|
|
|
const fetchData = useCallback(() => {
|
|
const pageOpts = { page: page + 1, size: pageSize };
|
|
listPendingTasksAsync(queue, pageOpts);
|
|
}, [page, pageSize, queue, listPendingTasksAsync]);
|
|
|
|
usePolling(fetchData, pollInterval);
|
|
|
|
if (props.tasks.length === 0) {
|
|
return (
|
|
<Alert severity="info">
|
|
<AlertTitle>Info</AlertTitle>
|
|
No pending tasks at this time.
|
|
</Alert>
|
|
);
|
|
}
|
|
|
|
const columns: TableColumn[] = [
|
|
{ key: "icon", label: "", align: "left" },
|
|
{ key: "id", label: "ID", align: "left" },
|
|
{ key: "type", label: "Type", align: "left" },
|
|
];
|
|
|
|
return (
|
|
<TableContainer component={Paper}>
|
|
<Table
|
|
stickyHeader={true}
|
|
className={classes.table}
|
|
aria-label="pending tasks table"
|
|
size="small"
|
|
>
|
|
<TableHead>
|
|
<TableRow>
|
|
{columns.map((col) => (
|
|
<TableCell
|
|
key={col.key}
|
|
align={col.align}
|
|
classes={{ stickyHeader: classes.stickyHeaderCell }}
|
|
>
|
|
{col.label}
|
|
</TableCell>
|
|
))}
|
|
</TableRow>
|
|
</TableHead>
|
|
<TableBody>
|
|
{props.tasks.map((task) => (
|
|
<Row key={task.id} task={task} />
|
|
))}
|
|
</TableBody>
|
|
<TableFooter>
|
|
<TableRow>
|
|
<TablePagination
|
|
rowsPerPageOptions={rowsPerPageOptions}
|
|
colSpan={columns.length}
|
|
count={props.totalTaskCount}
|
|
rowsPerPage={pageSize}
|
|
page={page}
|
|
SelectProps={{
|
|
inputProps: { "aria-label": "rows per page" },
|
|
native: true,
|
|
}}
|
|
onChangePage={handleChangePage}
|
|
onChangeRowsPerPage={handleChangeRowsPerPage}
|
|
ActionsComponent={TablePaginationActions}
|
|
/>
|
|
</TableRow>
|
|
</TableFooter>
|
|
</Table>
|
|
</TableContainer>
|
|
);
|
|
}
|
|
|
|
const useRowStyles = makeStyles({
|
|
root: {
|
|
"& > *": {
|
|
borderBottom: "unset",
|
|
},
|
|
},
|
|
});
|
|
|
|
function Row(props: { task: PendingTask }) {
|
|
const { task } = props;
|
|
const [open, setOpen] = React.useState(false);
|
|
const classes = useRowStyles();
|
|
return (
|
|
<React.Fragment>
|
|
<TableRow key={task.id} className={classes.root}>
|
|
<TableCell>
|
|
<Tooltip title={open ? "Hide Details" : "Show Details"}>
|
|
<IconButton
|
|
aria-label="expand row"
|
|
size="small"
|
|
onClick={() => setOpen(!open)}
|
|
>
|
|
{open ? <KeyboardArrowUpIcon /> : <KeyboardArrowDownIcon />}
|
|
</IconButton>
|
|
</Tooltip>
|
|
</TableCell>
|
|
<TableCell component="th" scope="row">
|
|
{uuidPrefix(task.id)}
|
|
</TableCell>
|
|
<TableCell>{task.type}</TableCell>
|
|
</TableRow>
|
|
<TableRow>
|
|
<TableCell style={{ paddingBottom: 0, paddingTop: 0 }} colSpan={8}>
|
|
<Collapse in={open} timeout="auto" unmountOnExit>
|
|
<Box margin={1}>
|
|
<Typography variant="h6" gutterBottom component="div">
|
|
Payload
|
|
</Typography>
|
|
<SyntaxHighlighter language="json">
|
|
{JSON.stringify(task.payload, null, 2)}
|
|
</SyntaxHighlighter>
|
|
</Box>
|
|
</Collapse>
|
|
</TableCell>
|
|
</TableRow>
|
|
</React.Fragment>
|
|
);
|
|
}
|
|
|
|
export default connector(PendingTasksTable);
|