"use client"; import { ColumnFilterButton } from "@app/components/ColumnFilterButton"; import { DateTimeValue } from "@app/components/DateTimePicker"; import { LogDataTable } from "@app/components/LogDataTable"; import { PaidFeaturesAlert } from "@app/components/PaidFeaturesAlert"; import SettingsSectionTitle from "@app/components/SettingsSectionTitle"; import { useEnvContext } from "@app/hooks/useEnvContext"; import { usePaidStatus } from "@app/hooks/usePaidStatus"; import { useStoredPageSize } from "@app/hooks/useStoredPageSize"; import { toast } from "@app/hooks/useToast"; import { createApiClient } from "@app/lib/api"; import { getSevenDaysAgo } from "@app/lib/getSevenDaysAgo"; import { logQueries } from "@app/lib/queries"; import { build } from "@server/build"; import { tierMatrix } from "@server/lib/billing/tierMatrix"; import type { QueryActionAuditLogResponse } from "@server/routers/auditLogs/types"; import { useQuery } from "@tanstack/react-query"; import { ColumnDef } from "@tanstack/react-table"; import axios from "axios"; import { Key, User } from "lucide-react"; import { useTranslations } from "next-intl"; import { useParams, useRouter, useSearchParams } from "next/navigation"; import { useMemo, useState, useTransition } from "react"; export default function GeneralPage() { const router = useRouter(); const api = createApiClient(useEnvContext()); const t = useTranslations(); const { orgId } = useParams(); const searchParams = useSearchParams(); const { isPaidUser } = usePaidStatus(); const [isExporting, startTransition] = useTransition(); const [filters, setFilters] = useState<{ action?: string; actor?: string; }>({ action: searchParams.get("action") || undefined, actor: searchParams.get("actor") || undefined }); const [currentPage, setCurrentPage] = useState(0); const [pageSize, setPageSize] = useStoredPageSize("action-audit-logs", 20); const getDefaultDateRange = () => { const startParam = searchParams.get("start"); const endParam = searchParams.get("end"); if (startParam && endParam) { return { startDate: { date: new Date(startParam) }, endDate: { date: new Date(endParam) } }; } return { startDate: { date: getSevenDaysAgo() }, endDate: { date: new Date() } }; }; const [dateRange, setDateRange] = useState<{ startDate: DateTimeValue; endDate: DateTimeValue; }>(getDefaultDateRange()); const queryFilters = useMemo(() => { let timeStart: string | undefined; let timeEnd: string | undefined; if (dateRange.startDate?.date) { const dt = new Date(dateRange.startDate.date); if (dateRange.startDate.time) { const [h, m, s] = dateRange.startDate.time .split(":") .map(Number); dt.setHours(h, m, s || 0); } timeStart = dt.toISOString(); } if (dateRange.endDate?.date) { const dt = new Date(dateRange.endDate.date); if (dateRange.endDate.time) { const [h, m, s] = dateRange.endDate.time.split(":").map(Number); dt.setHours(h, m, s || 0); } else { const now = new Date(); dt.setHours( now.getHours(), now.getMinutes(), now.getSeconds(), now.getMilliseconds() ); } timeEnd = dt.toISOString(); } return { timeStart, timeEnd, page: currentPage, pageSize, ...filters }; }, [dateRange, currentPage, pageSize, filters]); const { data, isFetching, isLoading, refetch } = useQuery({ ...logQueries.action({ orgId: orgId as string, filters: queryFilters }), enabled: isPaidUser(tierMatrix.actionLogs) && build !== "oss" }); const rows = isLoading ? generateSampleActionLogs() : (data?.log ?? []); const totalCount = data?.pagination?.total ?? 0; const filterAttributes = { actors: data?.filterAttributes?.actors ?? [] }; const handleDateRangeChange = ( startDate: DateTimeValue, endDate: DateTimeValue ) => { setDateRange({ startDate, endDate }); setCurrentPage(0); updateUrlParamsForAllFilters({ start: startDate.date?.toISOString() || "", end: endDate.date?.toISOString() || "" }); }; const handlePageChange = (newPage: number) => { setCurrentPage(newPage); }; const handleRefresh = () => { // When the end date has no explicit time, it represents an // open-ended "up to now" upper bound. Since dateRange is only // recomputed on user interaction, that upper bound otherwise stays // frozen at whenever the page first loaded, so refreshing would // never surface logs created since then. Bump it to the current // time so the query key changes and refetches the latest window. if (dateRange.endDate?.date && !dateRange.endDate.time) { setDateRange((prev) => ({ ...prev, endDate: { date: new Date() } })); } else { refetch(); } }; const handlePageSizeChange = (newPageSize: number) => { setPageSize(newPageSize); setCurrentPage(0); }; const handleFilterChange = ( filterType: keyof typeof filters, value: string | undefined ) => { const newFilters = { ...filters, [filterType]: value }; setFilters(newFilters); setCurrentPage(0); updateUrlParamsForAllFilters(newFilters); }; const updateUrlParamsForAllFilters = ( newFilters: | typeof filters | { start: string; end: string; } ) => { const params = new URLSearchParams(searchParams); Object.entries(newFilters).forEach(([key, value]) => { if (value) { params.set(key, value); } else { params.delete(key); } }); router.replace(`?${params.toString()}`, { scroll: false }); }; const exportData = async () => { try { const params: any = { timeStart: dateRange.startDate?.date ? new Date(dateRange.startDate.date).toISOString() : undefined, timeEnd: dateRange.endDate?.date ? new Date(dateRange.endDate.date).toISOString() : undefined, ...filters }; const response = await api.get(`/org/${orgId}/logs/action/export`, { responseType: "blob", params }); const url = window.URL.createObjectURL(new Blob([response.data])); const link = document.createElement("a"); link.href = url; const epoch = Math.floor(Date.now() / 1000); link.setAttribute( "download", `action-audit-logs-${orgId}-${epoch}.csv` ); document.body.appendChild(link); link.click(); link.parentNode?.removeChild(link); } catch (error) { let apiErrorMessage: string | null = null; if (axios.isAxiosError(error) && error.response) { const data = error.response.data; if (data instanceof Blob && data.type === "application/json") { const text = await data.text(); const errorData = JSON.parse(text); apiErrorMessage = errorData.message; } } toast({ title: t("error"), description: apiErrorMessage ?? t("exportError"), variant: "destructive" }); } }; const columns: ColumnDef[] = [ { accessorKey: "timestamp", header: () => {t("timestamp")}, cell: ({ row }) => { return (
{new Date( row.original.timestamp * 1000 ).toLocaleString()}
); } }, { accessorKey: "action", header: () => { return (
handleFilterChange("action", value) } searchPlaceholder={t("searchPlaceholder")} emptyMessage={t("emptySearchOptions")} />
); }, cell: ({ row }) => { return ( {row.original.action.charAt(0).toUpperCase() + row.original.action.slice(1)} ); } }, { accessorKey: "actor", header: () => { return (
({ value: actor, label: actor }))} label={t("actor")} selectedValue={filters.actor} onValueChange={(value) => handleFilterChange("actor", value) } searchPlaceholder={t("searchPlaceholder")} emptyMessage={t("emptySearchOptions")} />
); }, cell: ({ row }) => { return ( {row.original.actorType == "user" ? ( ) : ( )} {row.original.actor || ( - )} ); } }, { accessorKey: "actorId", header: () => {t("actorId")}, cell: ({ row }) => { return ( {row.original.actorId || ( - )} ); } } ]; const renderExpandedRow = (row: any) => { return (
Metadata:
                            {row.metadata
                                ? JSON.stringify(
                                      JSON.parse(row.metadata),
                                      null,
                                      2
                                  )
                                : "N/A"}
                        
); }; return ( <> startTransition(exportData)} isExporting={isExporting} onDateRangeChange={handleDateRangeChange} dateRange={{ start: dateRange.startDate, end: dateRange.endDate }} defaultSort={{ id: "timestamp", desc: true }} totalCount={totalCount} currentPage={currentPage} pageSize={pageSize} onPageChange={handlePageChange} onPageSizeChange={handlePageSizeChange} isLoading={isLoading} expandable={true} renderExpandedRow={renderExpandedRow} disabled={!isPaidUser(tierMatrix.actionLogs) || build === "oss"} /> ); } function generateSampleActionLogs(): QueryActionAuditLogResponse["log"] { const actions = [ "createResource", "deleteResource", "updateResource", "createSite", "deleteSite", "inviteUser", "removeUser" ]; const actors = [ "alice@example.com", "bob@example.com", "carol@example.com" ]; const now = Math.floor(Date.now() / 1000); const sevenDaysAgo = now - 7 * 24 * 60 * 60; return Array.from({ length: 10 }, (_, i) => { const actor = actors[Math.floor(Math.random() * actors.length)]; return { timestamp: Math.floor( sevenDaysAgo + Math.random() * (now - sevenDaysAgo) ), action: actions[Math.floor(Math.random() * actions.length)], orgId: "sample-org", actorType: "user", actor, actorId: `user-${i}`, metadata: null }; }); }