diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-29 14:53:31 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-11-29 14:53:31 +0000 |
| commit | 86a4b3966504507afd6c3adbb6a1246cafd39d83 (patch) | |
| tree | 66208555ef2720799d7196d777172b390eaf6d8f /apps/web/components | |
| parent | e67c33e46626258b748eb492d124f263fb427d0d (diff) | |
| download | karakeep-86a4b3966504507afd6c3adbb6a1246cafd39d83.tar.zst | |
feat: Add automated bookmark backup feature (#2182)
* feat: Add automated bookmark backup system
Implements a comprehensive automated backup feature for user bookmarks with the following capabilities:
Database Schema:
- Add backupSettings table to store user backup preferences (enabled, frequency, retention)
- Add backups table to track backup records with status and metadata
- Add BACKUP asset type for storing compressed backup files
- Add migration 0066_add_backup_tables.sql
Background Workers:
- Implement BackupSchedulingWorker cron job (runs daily at midnight UTC)
- Create BackupWorker to process individual backup jobs
- Deterministic scheduling spreads backup jobs across 24 hours based on user ID hash
- Support for daily and weekly backup frequencies
- Automated retention cleanup to delete old backups based on user settings
Export & Compression:
- Reuse existing export functionality for bookmark data
- Compress exports using Node.js built-in zlib (gzip level 9)
- Store compressed backups as assets with proper metadata
- Track backup size and bookmark count for statistics
tRPC API:
- backups.getSettings - Retrieve user backup configuration
- backups.updateSettings - Update backup preferences
- backups.list - List all user backups with metadata
- backups.get - Get specific backup details
- backups.delete - Delete a backup
- backups.download - Download backup file (base64 encoded)
- backups.triggerBackup - Manually trigger backup creation
UI Components:
- BackupSettings component with configuration form
- Enable/disable automatic backups toggle
- Frequency selection (daily/weekly)
- Retention period configuration (1-365 days)
- Backup list table with download and delete actions
- Manual backup trigger button
- Display backup stats (size, bookmark count, status)
- Added backups page to settings navigation
Technical Details:
- Uses Restate queue system for distributed job processing
- Implements idempotency keys to prevent duplicate backups
- Background worker concurrency: 2 jobs at a time
- 10-minute timeout for large backup exports
- Proper error handling and logging throughout
- Type-safe implementation with Zod schemas
* refactor: simplify backup settings and asset handling
- Move backup settings from separate table to user table columns
- Update BackupSettings model to use static methods with users table
- Remove download mutation in favor of direct asset links
- Implement proper quota checks using QuotaService.checkStorageQuota
- Update UI to use new property names and direct asset downloads
- Update shared types to match new schema
Key changes:
- backupSettingsTable removed, settings now in users table
- Backup downloads use direct /api/assets/{id} links
- Quota properly validated before creating backup assets
- Cleaner separation of concerns in tRPC models
* migration
* use zip instead of gzip
* fix drizzle
* fix settings
* streaming json
* remove more dead code
* add e2e tests
* return backup
* poll for backups
* more fixes
* more fixes
* fix test
* fix UI
* fix delete asset
* fix ui
* redirect for backup download
* cleanups
* fix idempotency
* fix tests
* add ratelimit
* add error handling for background backups
* i18n
* model changes
---------
Co-authored-by: Claude <noreply@anthropic.com>
Diffstat (limited to 'apps/web/components')
| -rw-r--r-- | apps/web/components/settings/BackupSettings.tsx | 423 |
1 files changed, 423 insertions, 0 deletions
diff --git a/apps/web/components/settings/BackupSettings.tsx b/apps/web/components/settings/BackupSettings.tsx new file mode 100644 index 00000000..18a80993 --- /dev/null +++ b/apps/web/components/settings/BackupSettings.tsx @@ -0,0 +1,423 @@ +"use client"; + +import React from "react"; +import Link from "next/link"; +import { ActionButton } from "@/components/ui/action-button"; +import { + Form, + FormControl, + FormDescription, + FormField, + FormItem, + FormLabel, + FormMessage, +} from "@/components/ui/form"; +import { FullPageSpinner } from "@/components/ui/full-page-spinner"; +import { Input } from "@/components/ui/input"; +import { + Select, + SelectContent, + SelectItem, + SelectTrigger, + SelectValue, +} from "@/components/ui/select"; +import { Switch } from "@/components/ui/switch"; +import { toast } from "@/components/ui/use-toast"; +import { useTranslation } from "@/lib/i18n/client"; +import { api } from "@/lib/trpc"; +import { useUserSettings } from "@/lib/userSettings"; +import { zodResolver } from "@hookform/resolvers/zod"; +import { + CheckCircle, + Download, + Play, + Save, + Trash2, + XCircle, +} from "lucide-react"; +import { useForm } from "react-hook-form"; +import { z } from "zod"; + +import { useUpdateUserSettings } from "@karakeep/shared-react/hooks/users"; +import { zBackupSchema } from "@karakeep/shared/types/backups"; +import { zUpdateBackupSettingsSchema } from "@karakeep/shared/types/users"; +import { getAssetUrl } from "@karakeep/shared/utils/assetUtils"; + +import ActionConfirmingDialog from "../ui/action-confirming-dialog"; +import { Button } from "../ui/button"; +import { + Table, + TableBody, + TableCell, + TableHead, + TableHeader, + TableRow, +} from "../ui/table"; +import { Tooltip, TooltipContent, TooltipTrigger } from "../ui/tooltip"; + +function BackupConfigurationForm() { + const { t } = useTranslation(); + + const settings = useUserSettings(); + const { mutate: updateSettings, isPending: isUpdating } = + useUpdateUserSettings({ + onSuccess: () => { + toast({ + description: t("settings.info.user_settings.user_settings_updated"), + }); + }, + onError: () => { + toast({ + description: t("common.something_went_wrong"), + variant: "destructive", + }); + }, + }); + + const form = useForm<z.infer<typeof zUpdateBackupSettingsSchema>>({ + resolver: zodResolver(zUpdateBackupSettingsSchema), + values: settings + ? { + backupsEnabled: settings.backupsEnabled, + backupsFrequency: settings.backupsFrequency, + backupsRetentionDays: settings.backupsRetentionDays, + } + : undefined, + }); + + return ( + <div className="rounded-md border bg-background p-4"> + <h3 className="mb-4 text-lg font-medium"> + {t("settings.backups.configuration.title")} + </h3> + <Form {...form}> + <form + className="space-y-4" + onSubmit={form.handleSubmit((value) => { + updateSettings(value); + })} + > + <FormField + control={form.control} + name="backupsEnabled" + render={({ field }) => ( + <FormItem className="flex flex-row items-center justify-between rounded-lg border p-3"> + <div className="space-y-0.5"> + <FormLabel> + {t( + "settings.backups.configuration.enable_automatic_backups", + )} + </FormLabel> + <FormDescription> + {t( + "settings.backups.configuration.enable_automatic_backups_description", + )} + </FormDescription> + </div> + <FormControl> + <Switch + checked={field.value} + onCheckedChange={field.onChange} + /> + </FormControl> + </FormItem> + )} + /> + + <FormField + control={form.control} + name="backupsFrequency" + render={({ field }) => ( + <FormItem> + <FormLabel> + {t("settings.backups.configuration.backup_frequency")} + </FormLabel> + <FormControl> + <Select + onValueChange={field.onChange} + defaultValue={field.value} + {...field} + > + <SelectTrigger> + <SelectValue + placeholder={t( + "settings.backups.configuration.select_frequency", + )} + /> + </SelectTrigger> + <SelectContent> + <SelectItem value="daily"> + {t("settings.backups.configuration.frequency.daily")} + </SelectItem> + <SelectItem value="weekly"> + {t("settings.backups.configuration.frequency.weekly")} + </SelectItem> + </SelectContent> + </Select> + </FormControl> + <FormDescription> + {t( + "settings.backups.configuration.backup_frequency_description", + )} + </FormDescription> + <FormMessage /> + </FormItem> + )} + /> + + <FormField + control={form.control} + name="backupsRetentionDays" + render={({ field }) => ( + <FormItem> + <FormLabel> + {t("settings.backups.configuration.retention_period")} + </FormLabel> + <FormControl> + <Input + type="number" + min={1} + max={365} + {...field} + onChange={(e) => field.onChange(parseInt(e.target.value))} + /> + </FormControl> + <FormDescription> + {t( + "settings.backups.configuration.retention_period_description", + )} + </FormDescription> + <FormMessage /> + </FormItem> + )} + /> + + <ActionButton + type="submit" + loading={isUpdating} + className="items-center" + > + <Save className="mr-2 size-4" /> + {t("settings.backups.configuration.save_settings")} + </ActionButton> + </form> + </Form> + </div> + ); +} + +function BackupRow({ backup }: { backup: z.infer<typeof zBackupSchema> }) { + const { t } = useTranslation(); + const apiUtils = api.useUtils(); + + const { mutate: deleteBackup, isPending: isDeleting } = + api.backups.delete.useMutation({ + onSuccess: () => { + toast({ + description: t("settings.backups.toasts.backup_deleted"), + }); + apiUtils.backups.list.invalidate(); + }, + onError: (error) => { + toast({ + description: `Error: ${error.message}`, + variant: "destructive", + }); + }, + }); + + const formatSize = (bytes: number) => { + if (bytes < 1024) return `${bytes} B`; + if (bytes < 1024 * 1024) return `${(bytes / 1024).toFixed(2)} KB`; + return `${(bytes / (1024 * 1024)).toFixed(2)} MB`; + }; + + return ( + <TableRow> + <TableCell>{backup.createdAt.toLocaleString()}</TableCell> + <TableCell> + {backup.status === "pending" + ? "-" + : backup.bookmarkCount.toLocaleString()} + </TableCell> + <TableCell> + {backup.status === "pending" ? "-" : formatSize(backup.size)} + </TableCell> + <TableCell> + {backup.status === "success" ? ( + <span + title={t("settings.backups.list.status.success")} + className="flex items-center gap-1" + > + <CheckCircle className="size-4 text-green-600" /> + {t("settings.backups.list.status.success")} + </span> + ) : backup.status === "failure" ? ( + <Tooltip> + <TooltipTrigger asChild> + <span + title={ + backup.errorMessage || + t("settings.backups.list.status.failed") + } + className="flex items-center gap-1" + > + <XCircle className="size-4 text-red-600" /> + {t("settings.backups.list.status.failed")} + </span> + </TooltipTrigger> + <TooltipContent>{backup.errorMessage}</TooltipContent> + </Tooltip> + ) : ( + <span className="flex items-center gap-1"> + <div className="size-4 animate-spin rounded-full border-2 border-gray-300 border-t-gray-600" /> + {t("settings.backups.list.status.pending")} + </span> + )} + </TableCell> + <TableCell className="flex items-center gap-2"> + {backup.assetId && ( + <Tooltip> + <TooltipTrigger asChild> + <Button + asChild + variant="ghost" + className="items-center" + disabled={backup.status !== "success"} + > + <Link + href={getAssetUrl(backup.assetId)} + download + prefetch={false} + className={ + backup.status !== "success" + ? "pointer-events-none opacity-50" + : "" + } + > + <Download className="size-4" /> + </Link> + </Button> + </TooltipTrigger> + <TooltipContent> + {t("settings.backups.list.actions.download_backup")} + </TooltipContent> + </Tooltip> + )} + <ActionConfirmingDialog + title={t("settings.backups.dialogs.delete_backup_title")} + description={t("settings.backups.dialogs.delete_backup_description")} + actionButton={() => ( + <ActionButton + loading={isDeleting} + variant="destructive" + onClick={() => deleteBackup({ backupId: backup.id })} + className="items-center" + type="button" + > + <Trash2 className="mr-2 size-4" /> + {t("settings.backups.list.actions.delete_backup")} + </ActionButton> + )} + > + <Button variant="ghost" disabled={isDeleting}> + <Trash2 className="size-4" /> + </Button> + </ActionConfirmingDialog> + </TableCell> + </TableRow> + ); +} + +function BackupsList() { + const { t } = useTranslation(); + const apiUtils = api.useUtils(); + const { data: backups, isLoading } = api.backups.list.useQuery(undefined, { + refetchInterval: (query) => { + const data = query.state.data; + // Poll every 3 seconds if there's a pending backup, otherwise don't poll + return data?.backups.some((backup) => backup.status === "pending") + ? 3000 + : false; + }, + }); + + const { mutate: triggerBackup, isPending: isTriggering } = + api.backups.triggerBackup.useMutation({ + onSuccess: () => { + toast({ + description: t("settings.backups.toasts.backup_queued"), + }); + apiUtils.backups.list.invalidate(); + }, + onError: (error) => { + toast({ + description: `Error: ${error.message}`, + variant: "destructive", + }); + }, + }); + + return ( + <div className="rounded-md border bg-background p-4"> + <div className="flex flex-col gap-2"> + <div className="flex items-center justify-between"> + <span className="text-lg font-medium"> + {t("settings.backups.list.title")} + </span> + <ActionButton + onClick={() => triggerBackup()} + loading={isTriggering} + variant="default" + className="items-center" + > + <Play className="mr-2 size-4" /> + {t("settings.backups.list.create_backup_now")} + </ActionButton> + </div> + + {isLoading && <FullPageSpinner />} + + {backups && backups.backups.length === 0 && ( + <p className="rounded-md bg-muted p-2 text-sm text-muted-foreground"> + {t("settings.backups.list.no_backups")} + </p> + )} + + {backups && backups.backups.length > 0 && ( + <Table> + <TableHeader> + <TableRow> + <TableHead> + {t("settings.backups.list.table.created_at")} + </TableHead> + <TableHead> + {t("settings.backups.list.table.bookmarks")} + </TableHead> + <TableHead>{t("settings.backups.list.table.size")}</TableHead> + <TableHead>{t("settings.backups.list.table.status")}</TableHead> + <TableHead> + {t("settings.backups.list.table.actions")} + </TableHead> + </TableRow> + </TableHeader> + <TableBody> + {backups.backups.map((backup) => ( + <BackupRow key={backup.id} backup={backup} /> + ))} + </TableBody> + </Table> + )} + </div> + </div> + ); +} + +export default function BackupSettings() { + return ( + <div className="space-y-6"> + <BackupConfigurationForm /> + <BackupsList /> + </div> + ); +} |
