fix typo

.github/workflows/docker.yml

@@ -26,10 +26,6 @@ jobs:
 
       - uses: docker/setup-buildx-action@v3
 
-      - name: Set image date
-        id: args
-        run: echo "date=$(date -d yesterday +'%Y-%m-%d')" >> "$GITHUB_OUTPUT"
-
       - name: Login to docker hub
         uses: docker/login-action@v3
         with:
@@ -57,8 +53,6 @@ jobs:
       - name: Build an image and push
         uses: docker/build-push-action@v6
         with:
-          build-args: |
-            BUILD_DATE=${{ steps.args.outputs.date }}
           file: docker/Dockerfile
           push: true
           tags: ${{ steps.meta.outputs.tags }}

.github/workflows/release.yml

@@ -26,7 +26,7 @@ jobs:
 
       - name: Extract version
         id: version
-        run: echo "version=${GITHUB_REF#refs/tags/}" >> "$GITHUB_OUTPUT"
+        run: echo ::set-output name=VERSION::${GITHUB_REF#refs/tags/}
 
       - name: Create changelog
         id: changelog
@@ -38,7 +38,7 @@ jobs:
       - name: Create archive
         run: tox -e archive
         env:
-          VERSION: ${{ steps.version.outputs.version }}
+          VERSION: ${{ steps.version.outputs.VERSION }}
 
       - name: Publish release
         uses: softprops/action-gh-release@v2

.github/workflows/setup.sh

@@ -16,7 +16,7 @@ pacman -S --noconfirm --asdeps base-devel python-build python-flit python-instal
 # optional dependencies
 if [[ -z $MINIMAL_INSTALL ]]; then
     # web server
-    pacman -S --noconfirm python-aioauth-client python-aiohttp python-aiohttp-apispec-git python-aiohttp-cors python-aiohttp-jinja2 python-aiohttp-security python-aiohttp-session python-aiohttp-sse-git python-cryptography python-jinja
+    pacman -S --noconfirm python-aioauth-client python-aiohttp python-aiohttp-apispec-git python-aiohttp-cors python-aiohttp-jinja2 python-aiohttp-security python-aiohttp-session python-cryptography python-jinja
     # additional features
     pacman -S --noconfirm gnupg ipython python-boto3 python-cerberus python-matplotlib rsync
 fi

.readthedocs.yml

@@ -3,7 +3,7 @@ version: 2
 build:
   os: ubuntu-lts-latest
   tools:
-    python: "3.13"
+    python: "3.12"
   apt_packages:
     - graphviz
 

docker/Dockerfile

@@ -1,15 +1,13 @@
 # build image
 FROM archlinux:base AS build
 
-ARG BUILD_DATE
-
 # install environment
 ## create build user
 RUN useradd -m -d "/home/build" -s "/usr/bin/nologin" build
 
 ## extract container creation date and set mirror for this timestamp, set PKGEXT and refresh database next
-RUN echo "Server = https://archive.archlinux.org/repos/${BUILD_DATE//-/\/}/\$repo/os/\$arch" > "/etc/pacman.d/mirrorlist" && \
-    pacman -Syyuu --noconfirm
+RUN echo "Server = https://archive.archlinux.org/repos/$(stat -c "%y" "/var/lib/pacman" | cut -d " " -f 1 | sed "s,-,/,g")/\$repo/os/\$arch" > "/etc/pacman.d/mirrorlist" && \
+    pacman -Sy
 ## setup package cache
 RUN runuser -u build -- mkdir "/tmp/pkg" && \
     echo "PKGDEST=/tmp/pkg" >> "/etc/makepkg.conf" && \
@@ -110,7 +108,7 @@ RUN cp "/etc/pacman.d/mirrorlist" "/etc/pacman.d/mirrorlist.orig" && \
     echo "Server = file:///var/cache/pacman/pkg" > "/etc/pacman.d/mirrorlist" && \
     cp "/etc/pacman.conf" "/etc/pacman.conf.orig" && \
     sed -i "s/SigLevel *=.*/SigLevel = Optional/g" "/etc/pacman.conf" && \
-    pacman -Syyuu --noconfirm
+    pacman -Sy
 ## install package and its optional dependencies
 RUN pacman -S --noconfirm ahriman
 RUN pacman -S --noconfirm --asdeps \

docker/install-aur-package.sh

@@ -7,10 +7,8 @@ for PACKAGE in "$@"; do
     # clone the remote source
     git clone https://aur.archlinux.org/"$PACKAGE".git "$BUILD_DIR"
     cd "$BUILD_DIR"
-    # FIXME monkey patch PKGBUILD for python
-    sed -i 's/python -m build/python -m build --skip-dependency-check/g' "PKGBUILD"
     # checkout to the image date
-    git checkout "$(git rev-list -1 --before="$BUILD_DATE" master)"
+    git checkout "$(git rev-list -1 --before="$(stat -c "%y" "/var/lib/pacman" | cut -d " " -f 1)" master)"
     # build and install the package
     makepkg --nocheck --noconfirm --install --rmdeps --syncdeps
     cd /

frontend/package.json

@@ -5,7 +5,7 @@
         "@mui/icons-material": ">=7.3.0 <7.4.0",
         "@mui/material": ">=7.3.0 <7.4.0",
         "@mui/x-data-grid": ">=8.28.0 <8.29.0",
-        "@tanstack/react-query": ">=5.101.0 <5.102.0",
+        "@tanstack/react-query": ">=5.94.0 <5.95.0",
         "chart.js": ">=4.5.0 <4.6.0",
         "react": ">=19.2.0 <19.3.0",
         "react-chartjs-2": ">=5.3.0 <5.4.0",
@@ -22,12 +22,12 @@
         "@vitejs/plugin-react": ">=6.0.0 <6.1.0",
         "eslint": ">=9.39.0 <9.40.0",
         "eslint-plugin-react": ">=7.37.0 <7.38.0",
-        "eslint-plugin-react-hooks": ">=7.1.0 <7.2.0",
+        "eslint-plugin-react-hooks": ">=7.0.0 <7.1.0",
         "eslint-plugin-react-refresh": ">=0.5.0 <0.6.0",
         "eslint-plugin-simple-import-sort": ">=12.1.0 <12.2.0",
         "typescript": ">=5.9.0 <5.10.0",
         "typescript-eslint": ">=8.57.0 <8.58.0",
-        "vite": ">=8.1.0 <8.2.0"
+        "vite": ">=8.0.0 <8.1.0"
     },
     "name": "ahriman-frontend",
     "private": true,

frontend/src/App.tsx

@@ -21,7 +21,6 @@ import { QueryClient, QueryClientProvider } from "@tanstack/react-query";
 import AppLayout from "components/layout/AppLayout";
 import { AuthProvider } from "contexts/AuthProvider";
 import { ClientProvider } from "contexts/ClientProvider";
-import { EventStreamProvider } from "contexts/EventStreamProvider";
 import { NotificationProvider } from "contexts/NotificationProvider";
 import { RepositoryProvider } from "contexts/RepositoryProvider";
 import { ThemeProvider } from "contexts/ThemeProvider";
@@ -31,6 +30,7 @@ const queryClient = new QueryClient({
     defaultOptions: {
         queries: {
             retry: 1,
+            staleTime: 30_000,
         },
     },
 });
@@ -42,9 +42,7 @@ export default function App(): React.JSX.Element {
                 <ClientProvider>
                     <AuthProvider>
                         <RepositoryProvider>
-                            <EventStreamProvider>
-                                <AppLayout />
-                            </EventStreamProvider>
+                            <AppLayout />
                         </RepositoryProvider>
                     </AuthProvider>
                 </ClientProvider>

frontend/src/components/common/AutoRefreshControl.tsx

@@ -0,0 +1,91 @@
+/*
+ * Copyright (c) 2021-2026 ahriman team.
+ *
+ * This file is part of ahriman
+ * (see https://github.com/arcan1s/ahriman).
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+import CheckIcon from "@mui/icons-material/Check";
+import TimerIcon from "@mui/icons-material/Timer";
+import TimerOffIcon from "@mui/icons-material/TimerOff";
+import { IconButton, ListItemIcon, ListItemText, Menu, MenuItem, Tooltip } from "@mui/material";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
+import React, { useState } from "react";
+
+interface AutoRefreshControlProps {
+    currentInterval: number;
+    intervals: AutoRefreshInterval[];
+    onIntervalChange: (interval: number) => void;
+}
+
+export default function AutoRefreshControl({
+    currentInterval,
+    intervals,
+    onIntervalChange,
+}: AutoRefreshControlProps): React.JSX.Element | null {
+    const [anchorEl, setAnchorEl] = useState<HTMLElement | null>(null);
+
+    if (intervals.length === 0) {
+        return null;
+    }
+
+    const enabled = currentInterval > 0;
+
+    return <>
+        <Tooltip title="Auto-refresh">
+            <IconButton
+                aria-label="Auto-refresh"
+                color={enabled ? "primary" : "default"}
+                onClick={event => setAnchorEl(event.currentTarget)}
+                size="small"
+            >
+                {enabled ? <TimerIcon fontSize="small" /> : <TimerOffIcon fontSize="small" />}
+            </IconButton>
+        </Tooltip>
+        <Menu
+            anchorEl={anchorEl}
+            onClose={() => setAnchorEl(null)}
+            open={Boolean(anchorEl)}
+        >
+            <MenuItem
+                onClick={() => {
+                    onIntervalChange(0);
+                    setAnchorEl(null);
+                }}
+                selected={!enabled}
+            >
+                <ListItemIcon>
+                    {!enabled && <CheckIcon fontSize="small" />}
+                </ListItemIcon>
+                <ListItemText>Off</ListItemText>
+            </MenuItem>
+            {intervals.map(interval =>
+                <MenuItem
+                    key={interval.interval}
+                    onClick={() => {
+                        onIntervalChange(interval.interval);
+                        setAnchorEl(null);
+                    }}
+                    selected={enabled && interval.interval === currentInterval}
+                >
+                    <ListItemIcon>
+                        {enabled && interval.interval === currentInterval && <CheckIcon fontSize="small" />}
+                    </ListItemIcon>
+                    <ListItemText>{interval.text}</ListItemText>
+                </MenuItem>,
+            )}
+        </Menu>
+    </>;
+}

frontend/src/components/dialogs/PackageInfoDialog.tsx

@@ -32,22 +32,27 @@ import PkgbuildTab from "components/package/PkgbuildTab";
 import { type TabKey, tabs } from "components/package/TabKey";
 import { QueryKeys } from "hooks/QueryKeys";
 import { useAuth } from "hooks/useAuth";
+import { useAutoRefresh } from "hooks/useAutoRefresh";
 import { useClient } from "hooks/useClient";
 import { useNotification } from "hooks/useNotification";
 import { useRepository } from "hooks/useRepository";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { Dependencies } from "models/Dependencies";
 import type { PackageStatus } from "models/PackageStatus";
 import type { Patch } from "models/Patch";
 import React, { useState } from "react";
 import { StatusHeaderStyles } from "theme/StatusColors";
+import { defaultInterval } from "utils";
 
 interface PackageInfoDialogProps {
+    autoRefreshIntervals: AutoRefreshInterval[];
     onClose: () => void;
     open: boolean;
     packageBase: string | null;
 }
 
 export default function PackageInfoDialog({
+    autoRefreshIntervals,
     onClose,
     open,
     packageBase,
@@ -72,11 +77,14 @@ export default function PackageInfoDialog({
         onClose();
     };
 
+    const autoRefresh = useAutoRefresh("package-info-autoreload-button", defaultInterval(autoRefreshIntervals));
+
     const { data: packageData } = useQuery<PackageStatus[]>({
         enabled: open,
         queryFn: localPackageBase && currentRepository ?
             () => client.fetch.fetchPackage(localPackageBase, currentRepository) : skipToken,
         queryKey: localPackageBase && currentRepository ? QueryKeys.package(localPackageBase, currentRepository) : ["packages"],
+        refetchInterval: autoRefresh.interval > 0 ? autoRefresh.interval : false,
     });
 
     const { data: dependencies } = useQuery<Dependencies>({
@@ -174,6 +182,7 @@ export default function PackageInfoDialog({
                     {activeTab === "logs" && localPackageBase && currentRepository &&
                         <BuildLogsTab
                             packageBase={localPackageBase}
+                            refreshInterval={autoRefresh.interval}
                             repository={currentRepository}
                         />
                     }
@@ -198,8 +207,11 @@ export default function PackageInfoDialog({
         </DialogContent>
 
         <PackageInfoActions
+            autoRefreshInterval={autoRefresh.interval}
+            autoRefreshIntervals={autoRefreshIntervals}
             isAuthorized={isAuthorized}
             isHeld={status?.is_held ?? false}
+            onAutoRefreshIntervalChange={autoRefresh.setInterval}
             onHoldToggle={() => void handleHoldToggle()}
             onRefreshDatabaseChange={setRefreshDatabase}
             onRemove={() => void handleRemove()}

frontend/src/components/layout/AppLayout.tsx

@@ -69,7 +69,7 @@ export default function AppLayout(): React.JSX.Element {
             </Tooltip>
         </Box>
 
-        <PackageTable />
+        <PackageTable autoRefreshIntervals={info?.autorefresh_intervals ?? []} />
 
         <Footer
             docsEnabled={info?.docs_enabled ?? false}

frontend/src/components/package/BuildLogsTab.tsx

@@ -23,7 +23,6 @@ import { keepPreviousData, skipToken, useQuery } from "@tanstack/react-query";
 import CodeBlock from "components/common/CodeBlock";
 import { QueryKeys } from "hooks/QueryKeys";
 import { useAutoScroll } from "hooks/useAutoScroll";
-import { useBuildLogStream } from "hooks/useBuildLogStream";
 import { useClient } from "hooks/useClient";
 import type { LogRecord } from "models/LogRecord";
 import type { RepositoryId } from "models/RepositoryId";
@@ -38,6 +37,7 @@ interface Logs {
 
 interface BuildLogsTabProps {
     packageBase: string;
+    refreshInterval: number;
     repository: RepositoryId;
 }
 
@@ -50,10 +50,10 @@ function convertLogs(records: LogRecord[], filter?: (record: LogRecord) => boole
 
 export default function BuildLogsTab({
     packageBase,
+    refreshInterval,
     repository,
 }: BuildLogsTabProps): React.JSX.Element {
     const client = useClient();
-    useBuildLogStream(packageBase, repository);
     const [selectedVersionKey, setSelectedVersionKey] = useState<string | null>(null);
     const [anchorEl, setAnchorEl] = useState<HTMLElement | null>(null);
 
@@ -61,6 +61,7 @@ export default function BuildLogsTab({
         enabled: !!packageBase,
         queryFn: () => client.fetch.fetchPackageLogs(packageBase, repository),
         queryKey: QueryKeys.logs(packageBase, repository),
+        refetchInterval: refreshInterval > 0 ? refreshInterval : false,
     });
 
     // Build version selectors from all logs
@@ -116,6 +117,7 @@ export default function BuildLogsTab({
             )
             : skipToken,
         queryKey: QueryKeys.logsVersion(packageBase, repository, activeVersion?.version ?? "", activeVersion?.processId ?? ""),
+        refetchInterval: refreshInterval > 0 ? refreshInterval : false,
     });
 
     // Derive displayed logs: prefer fresh polled data when available

frontend/src/components/package/PackageDetailsGrid.tsx

@@ -98,7 +98,7 @@ export default function PackageDetailsGrid({ dependencies, pkg }: PackageDetails
             <Grid size={{ md: 5, xs: 8 }}>
                 <Typography variant="body2">
                     {aurUrl &&
-                        <Link href={aurUrl} rel="noopener noreferrer" target="_blank" underline="hover">{aurUrl}</Link>
+                        <Link href={aurUrl} rel="noopener noreferrer" target="_blank" underline="hover">AUR link</Link>
                     }
                 </Typography>
             </Grid>

frontend/src/components/package/PackageInfoActions.tsx

@@ -22,11 +22,16 @@ import PauseCircleIcon from "@mui/icons-material/PauseCircle";
 import PlayArrowIcon from "@mui/icons-material/PlayArrow";
 import PlayCircleIcon from "@mui/icons-material/PlayCircle";
 import { Button, Checkbox, DialogActions, FormControlLabel } from "@mui/material";
+import AutoRefreshControl from "components/common/AutoRefreshControl";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type React from "react";
 
 interface PackageInfoActionsProps {
+    autoRefreshInterval: number;
+    autoRefreshIntervals: AutoRefreshInterval[];
     isAuthorized: boolean;
     isHeld: boolean;
+    onAutoRefreshIntervalChange: (interval: number) => void;
     onHoldToggle: () => void;
     onRefreshDatabaseChange: (checked: boolean) => void;
     onRemove: () => void;
@@ -35,8 +40,11 @@ interface PackageInfoActionsProps {
 }
 
 export default function PackageInfoActions({
+    autoRefreshInterval,
+    autoRefreshIntervals,
     isAuthorized,
     isHeld,
+    onAutoRefreshIntervalChange,
     onHoldToggle,
     onRefreshDatabaseChange,
     onRemove,
@@ -61,5 +69,10 @@ export default function PackageInfoActions({
                 </Button>
             </>
         }
+        <AutoRefreshControl
+            currentInterval={autoRefreshInterval}
+            intervals={autoRefreshIntervals}
+            onIntervalChange={onAutoRefreshIntervalChange}
+        />
     </DialogActions>;
 }

frontend/src/components/table/PackageTable.tsx

@@ -35,9 +35,14 @@ import PackageTableToolbar from "components/table/PackageTableToolbar";
 import StatusCell from "components/table/StatusCell";
 import { useDebounce } from "hooks/useDebounce";
 import { usePackageTable } from "hooks/usePackageTable";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { PackageRow } from "models/PackageRow";
 import React, { useMemo } from "react";
 
+interface PackageTableProps {
+    autoRefreshIntervals: AutoRefreshInterval[];
+}
+
 function createListColumn(
     field: keyof PackageRow,
     headerName: string,
@@ -54,8 +59,8 @@ function createListColumn(
     };
 }
 
-export default function PackageTable(): React.JSX.Element {
-    const table = usePackageTable();
+export default function PackageTable({ autoRefreshIntervals }: PackageTableProps): React.JSX.Element {
+    const table = usePackageTable(autoRefreshIntervals);
     const apiRef = useGridApiRef();
     const debouncedSearch = useDebounce(table.searchText, 300);
 
@@ -113,6 +118,11 @@ export default function PackageTable(): React.JSX.Element {
                 onRemoveClick: () => void table.handleRemove(),
                 onUpdateClick: () => void table.handleUpdate(),
             }}
+            autoRefresh={{
+                autoRefreshIntervals,
+                currentInterval: table.autoRefreshInterval,
+                onIntervalChange: table.onAutoRefreshIntervalChange,
+            }}
             isAuthorized={table.isAuthorized}
             hasSelection={table.selectionModel.length > 0}
             onSearchChange={table.setSearchText}
@@ -165,6 +175,7 @@ export default function PackageTable(): React.JSX.Element {
         <PackageRebuildDialog onClose={() => table.setDialogOpen(null)} open={table.dialogOpen === "rebuild"} />
         <KeyImportDialog onClose={() => table.setDialogOpen(null)} open={table.dialogOpen === "keyImport"} />
         <PackageInfoDialog
+            autoRefreshIntervals={autoRefreshIntervals}
             onClose={() => table.setSelectedPackage(null)}
             open={table.selectedPackage !== null}
             packageBase={table.selectedPackage}

frontend/src/components/table/PackageTableToolbar.tsx

@@ -30,10 +30,18 @@ import ReplayIcon from "@mui/icons-material/Replay";
 import SearchIcon from "@mui/icons-material/Search";
 import VpnKeyIcon from "@mui/icons-material/VpnKey";
 import { Box, Button, Divider, IconButton, InputAdornment, Menu, MenuItem, TextField, Tooltip } from "@mui/material";
+import AutoRefreshControl from "components/common/AutoRefreshControl";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { BuildStatus } from "models/BuildStatus";
 import React, { useState } from "react";
 import { StatusColors } from "theme/StatusColors";
 
+export interface AutoRefreshProps {
+    autoRefreshIntervals: AutoRefreshInterval[];
+    currentInterval: number;
+    onIntervalChange: (interval: number) => void;
+}
+
 export interface ToolbarActions {
     onAddClick: () => void;
     onDashboardClick: () => void;
@@ -48,6 +56,7 @@ export interface ToolbarActions {
 
 interface PackageTableToolbarProps {
     actions: ToolbarActions;
+    autoRefresh: AutoRefreshProps;
     hasSelection: boolean;
     isAuthorized: boolean;
     onSearchChange: (text: string) => void;
@@ -57,6 +66,7 @@ interface PackageTableToolbarProps {
 
 export default function PackageTableToolbar({
     actions,
+    autoRefresh,
     hasSelection,
     isAuthorized,
     onSearchChange,
@@ -133,6 +143,12 @@ export default function PackageTableToolbar({
             reload
         </Button>
 
+        <AutoRefreshControl
+            currentInterval={autoRefresh.currentInterval}
+            intervals={autoRefresh.autoRefreshIntervals}
+            onIntervalChange={autoRefresh.onIntervalChange}
+        />
+
         <Box sx={{ flexGrow: 1 }} />
 
         <TextField

frontend/src/hooks/useAutoRefresh.ts

@@ -0,0 +1,49 @@
+/*
+ * Copyright (c) 2021-2026 ahriman team.
+ *
+ * This file is part of ahriman
+ * (see https://github.com/arcan1s/ahriman).
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+import { useLocalStorage } from "hooks/useLocalStorage";
+import { type Dispatch, type SetStateAction, useEffect, useState } from "react";
+
+interface AutoRefreshResult {
+    interval: number;
+    setInterval: Dispatch<SetStateAction<number>>;
+    setPaused: Dispatch<SetStateAction<boolean>>;
+}
+
+export function useAutoRefresh(key: string, defaultInterval: number): AutoRefreshResult {
+    const storageKey = `ahriman-${key}`;
+    const [interval, setInterval] = useLocalStorage<number>(storageKey, defaultInterval);
+    const [paused, setPaused] = useState(false);
+
+    // Apply defaultInterval when it becomes available (e.g. after info endpoint loads)
+    // but only if the user hasn't explicitly set a preference
+    useEffect(() => {
+        if (defaultInterval > 0 && window.localStorage.getItem(storageKey) === null) {
+            setInterval(defaultInterval);
+        }
+    }, [storageKey, defaultInterval, setInterval]);
+
+    const effectiveInterval = paused ? 0 : interval;
+
+    return {
+        interval: effectiveInterval,
+        setInterval,
+        setPaused,
+    };
+}

frontend/src/hooks/useBuildLogStream.ts

@@ -1,96 +0,0 @@
-/*
- * Copyright (c) 2021-2026 ahriman team.
- *
- * This file is part of ahriman
- * (see https://github.com/arcan1s/ahriman).
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-import type { QueryClient } from "@tanstack/react-query";
-import { useQueryClient } from "@tanstack/react-query";
-import { buildEventStreamUrl } from "hooks/useEventStream";
-import { useNotification } from "hooks/useNotification";
-import type { LogRecord } from "models/LogRecord";
-import type { RepositoryId } from "models/RepositoryId";
-import { useEffect } from "react";
-
-interface BuildLogEvent {
-    created: number;
-    message: string;
-    process_id: string;
-    version: string;
-}
-
-function appendLogRecord(existing: LogRecord[] | undefined, record: LogRecord): LogRecord[] {
-    return [...existing ?? [], record];
-}
-
-function invalidateLogs(queryClient: QueryClient, repository: RepositoryId, packageBase: string): void {
-    void queryClient.invalidateQueries({ queryKey: ["logs", repository.key, packageBase] });
-}
-
-export function useBuildLogStream(packageBase: string, repository: RepositoryId): void {
-    const queryClient = useQueryClient();
-    const { showError } = useNotification();
-
-    useEffect(() => {
-        const source = new EventSource(buildEventStreamUrl(repository, ["build-log"], packageBase));
-        let needsRefresh = false;
-
-        source.addEventListener("error", () => {
-            needsRefresh = true;
-        });
-
-        source.addEventListener("open", () => {
-            if (needsRefresh) {
-                invalidateLogs(queryClient, repository, packageBase);
-                needsRefresh = false;
-            }
-        });
-
-        source.addEventListener("build-log", (event: MessageEvent<string>) => {
-            let data: BuildLogEvent;
-            try {
-                data = JSON.parse(event.data) as BuildLogEvent;
-            } catch {
-                showError("Live updates failed", "Could not parse build log event; refreshing logs.");
-                invalidateLogs(queryClient, repository, packageBase);
-                return;
-            }
-
-            const record: LogRecord = {
-                created: data.created,
-                message: data.message,
-                process_id: data.process_id,
-                version: data.version,
-            };
-
-            // Append to the all-logs cache
-            queryClient.setQueryData<LogRecord[]>(
-                ["logs", repository.key, packageBase],
-                existing => appendLogRecord(existing, record),
-            );
-
-            // Append to the version-specific cache
-            queryClient.setQueryData<LogRecord[]>(
-                ["logs", repository.key, packageBase, record.version, record.process_id],
-                existing => appendLogRecord(existing, record),
-            );
-        });
-
-        return () => {
-            source.close();
-        };
-    }, [queryClient, packageBase, repository, showError]);
-}

frontend/src/hooks/useEventStream.ts

@@ -1,127 +0,0 @@
-/*
- * Copyright (c) 2021-2026 ahriman team.
- *
- * This file is part of ahriman
- * (see https://github.com/arcan1s/ahriman).
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-import type { QueryClient } from "@tanstack/react-query";
-import { useNotification } from "hooks/useNotification";
-import type { RepositoryId } from "models/RepositoryId";
-import { useEffect } from "react";
-
-const GLOBAL_EVENT_TYPES = [
-    "package-held",
-    "package-outdated",
-    "package-removed",
-    "package-status-changed",
-    "package-update-failed",
-    "package-updated",
-    "service-status-changed",
-] as const;
-
-function invalidateForEvent(
-    queryClient: QueryClient,
-    repositoryKey: string,
-    eventType: string,
-    objectId?: string,
-): void {
-    switch (eventType) {
-        case "package-status-changed":
-        case "package-updated":
-        case "package-removed":
-        case "package-held":
-            void queryClient.invalidateQueries({ queryKey: ["packages", repositoryKey] });
-            void queryClient.invalidateQueries({ queryKey: ["status", repositoryKey] });
-            if (objectId) {
-                void queryClient.invalidateQueries({ queryKey: ["packages", repositoryKey, objectId] });
-                void queryClient.invalidateQueries({ queryKey: ["events", repositoryKey, objectId] });
-            }
-            break;
-        case "service-status-changed":
-            void queryClient.invalidateQueries({ queryKey: ["status", repositoryKey] });
-            break;
-        case "package-outdated":
-        case "package-update-failed":
-            void queryClient.invalidateQueries({ queryKey: ["packages", repositoryKey] });
-            if (objectId) {
-                void queryClient.invalidateQueries({ queryKey: ["packages", repositoryKey, objectId] });
-            }
-            break;
-    }
-}
-
-function invalidateRepository(queryClient: QueryClient, repositoryKey: string): void {
-    void queryClient.invalidateQueries({ queryKey: ["packages", repositoryKey] });
-    void queryClient.invalidateQueries({ queryKey: ["status", repositoryKey] });
-    void queryClient.invalidateQueries({ queryKey: ["events", repositoryKey] });
-}
-
-export function buildEventStreamUrl(
-    repository: RepositoryId,
-    events?: readonly string[],
-    objectId?: string,
-): string {
-    const params = new URLSearchParams(repository.toQuery());
-    if (events) {
-        for (const event of events) {
-            params.append("event", event);
-        }
-    }
-    if (objectId) {
-        params.set("object_id", objectId);
-    }
-    return `/api/v1/events/stream?${params.toString()}`;
-}
-
-export function useEventStream(queryClient: QueryClient, repository: RepositoryId | null): void {
-    const { showError } = useNotification();
-
-    useEffect(() => {
-        if (!repository) {
-            return;
-        }
-
-        const source = new EventSource(buildEventStreamUrl(repository, GLOBAL_EVENT_TYPES));
-        let needsRefresh = false;
-
-        source.addEventListener("error", () => {
-            needsRefresh = true;
-        });
-
-        source.addEventListener("open", () => {
-            if (needsRefresh) {
-                invalidateRepository(queryClient, repository.key);
-                needsRefresh = false;
-            }
-        });
-
-        for (const eventType of GLOBAL_EVENT_TYPES) {
-            source.addEventListener(eventType, (event: MessageEvent<string>) => {
-                try {
-                    const data = JSON.parse(event.data) as { object_id?: string };
-                    invalidateForEvent(queryClient, repository.key, eventType, data.object_id ?? undefined);
-                } catch {
-                    showError("Live updates failed", "Could not parse server event; refreshing data.");
-                    invalidateRepository(queryClient, repository.key);
-                }
-            });
-        }
-
-        return () => {
-            source.close();
-        };
-    }, [queryClient, repository, showError]);
-}

frontend/src/hooks/usePackageData.ts

@@ -20,37 +20,46 @@
 import { skipToken, useQuery } from "@tanstack/react-query";
 import { QueryKeys } from "hooks/QueryKeys";
 import { useAuth } from "hooks/useAuth";
+import { useAutoRefresh } from "hooks/useAutoRefresh";
 import { useClient } from "hooks/useClient";
 import { useRepository } from "hooks/useRepository";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { BuildStatus } from "models/BuildStatus";
 import { PackageRow } from "models/PackageRow";
 import { useMemo } from "react";
+import { defaultInterval } from "utils";
 
 export interface UsePackageDataResult {
+    autoRefresh: ReturnType<typeof useAutoRefresh>;
     isAuthorized: boolean;
     isLoading: boolean;
     rows: PackageRow[];
     status: BuildStatus | undefined;
 }
 
-export function usePackageData(): UsePackageDataResult {
+export function usePackageData(autoRefreshIntervals: AutoRefreshInterval[]): UsePackageDataResult {
     const client = useClient();
     const { currentRepository } = useRepository();
     const { isAuthorized } = useAuth();
 
+    const autoRefresh = useAutoRefresh("table-autoreload-button", defaultInterval(autoRefreshIntervals));
+
     const { data: packages = [], isLoading } = useQuery({
         queryFn: currentRepository ? () => client.fetch.fetchPackages(currentRepository) : skipToken,
         queryKey: currentRepository ? QueryKeys.packages(currentRepository) : ["packages"],
+        refetchInterval: autoRefresh.interval > 0 ? autoRefresh.interval : false,
     });
 
     const { data: status } = useQuery({
         queryFn: currentRepository ? () => client.fetch.fetchServerStatus(currentRepository) : skipToken,
         queryKey: currentRepository ? QueryKeys.status(currentRepository) : ["status"],
+        refetchInterval: autoRefresh.interval > 0 ? autoRefresh.interval : false,
     });
 
     const rows = useMemo(() => packages.map(descriptor => new PackageRow(descriptor)), [packages]);
 
     return {
+        autoRefresh,
         isLoading,
         isAuthorized,
         rows,

frontend/src/hooks/usePackageTable.ts

@@ -21,10 +21,13 @@ import type { GridFilterModel } from "@mui/x-data-grid";
 import { usePackageActions } from "hooks/usePackageActions";
 import { usePackageData } from "hooks/usePackageData";
 import { useTableState } from "hooks/useTableState";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { BuildStatus } from "models/BuildStatus";
 import type { PackageRow } from "models/PackageRow";
+import { useEffect } from "react";
 
 export interface UsePackageTableResult {
+    autoRefreshInterval: number;
     columnVisibility: Record<string, boolean>;
     dialogOpen: "dashboard" | "add" | "rebuild" | "keyImport" | null;
     filterModel: GridFilterModel;
@@ -34,6 +37,7 @@ export interface UsePackageTableResult {
     handleUpdate: () => Promise<void>;
     isAuthorized: boolean;
     isLoading: boolean;
+    onAutoRefreshIntervalChange: (interval: number) => void;
     paginationModel: { page: number; pageSize: number };
     rows: PackageRow[];
     searchText: string;
@@ -49,14 +53,23 @@ export interface UsePackageTableResult {
     status: BuildStatus | undefined;
 }
 
-export function usePackageTable(): UsePackageTableResult {
-    const { rows, isLoading, isAuthorized, status } = usePackageData();
+export function usePackageTable(autoRefreshIntervals: AutoRefreshInterval[]): UsePackageTableResult {
+    const { rows, isLoading, isAuthorized, status, autoRefresh } = usePackageData(autoRefreshIntervals);
     const tableState = useTableState();
     const actions = usePackageActions(tableState.selectionModel, tableState.setSelectionModel);
 
+    // Pause auto-refresh when dialog is open
+    const isDialogOpen = tableState.dialogOpen !== null || tableState.selectedPackage !== null;
+    const setPaused = autoRefresh.setPaused;
+    useEffect(() => {
+        setPaused(isDialogOpen);
+    }, [isDialogOpen, setPaused]);
+
     return {
+        autoRefreshInterval: autoRefresh.interval,
         isLoading,
         isAuthorized,
+        onAutoRefreshIntervalChange: autoRefresh.setInterval,
         rows,
         status,
         ...actions,

frontend/src/models/AutoRefreshInterval.ts

@@ -17,16 +17,8 @@
  * You should have received a copy of the GNU General Public License
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
-import { useQueryClient } from "@tanstack/react-query";
-import { useEventStream } from "hooks/useEventStream";
-import { useRepository } from "hooks/useRepository";
-import type { ReactNode } from "react";
-
-export function EventStreamProvider({ children }: { children: ReactNode }): ReactNode {
-    const queryClient = useQueryClient();
-    const { currentRepository } = useRepository();
-
-    useEventStream(queryClient, currentRepository);
-
-    return children;
+export interface AutoRefreshInterval {
+    interval: number;
+    is_active: boolean;
+    text: string;
 }

frontend/src/models/InfoResponse.ts

@@ -18,10 +18,12 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 import type { AuthInfo } from "models/AuthInfo";
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
 import type { RepositoryId } from "models/RepositoryId";
 
 export interface InfoResponse {
     auth: AuthInfo;
+    autorefresh_intervals: AutoRefreshInterval[];
     docs_enabled: boolean;
     index_url?: string;
     repositories: RepositoryId[];

frontend/src/utils.ts

@@ -17,6 +17,8 @@
  * You should have received a copy of the GNU General Public License
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
+import type { AutoRefreshInterval } from "models/AutoRefreshInterval";
+
 export const DETAIL_TABLE_PROPS = {
     density: "compact" as const,
     disableColumnSorting: true,
@@ -25,6 +27,10 @@ export const DETAIL_TABLE_PROPS = {
     sx: { height: 400, mt: 1 },
 };
 
+export function defaultInterval(intervals: AutoRefreshInterval[]): number {
+    return intervals.find(interval => interval.is_active)?.interval ?? 0;
+}
+
 declare global {
     interface Array<T> {
         unique(): T[];

pyproject.toml

@@ -8,7 +8,8 @@ name = "ahriman"
 description = "ArcH linux ReposItory MANager"
 readme = "README.md"
 
-requires-python = ">=3.13"
+# Actually we are using features from the latest python, however, ubuntu, which is used for CI doesn't have it
+requires-python = ">=3"
 
 license = {file = "COPYING"}
 authors = [

src/ahriman/core/build_tools/package_archive.py

@@ -72,17 +72,17 @@ class PackageArchive:
             if not PackageArchive.is_elf(binary_file):
                 return []
 
-            elf_file = ELFFile(binary_file)
+            elf_file = ELFFile(binary_file)  # type: ignore[no-untyped-call]
             dynamic_section = next(
-                (section for section in elf_file.iter_sections()
+                (section for section in elf_file.iter_sections()  # type: ignore[no-untyped-call]
                  if isinstance(section, DynamicSection)),
                 None)
             if dynamic_section is None:
                 return []
 
             return [
-                tag.needed  # type: ignore[attr-defined]
-                for tag in dynamic_section.iter_tags()
+                tag.needed
+                for tag in dynamic_section.iter_tags()  # type: ignore[no-untyped-call]
                 if tag.entry.d_tag == "DT_NEEDED"
             ]
 

src/ahriman/core/configuration/configuration.py

@@ -80,7 +80,7 @@ class Configuration(configparser.RawConfigParser):
         """
         configparser.RawConfigParser.__init__(
             self,
-            dict_type=ConfigurationMultiDict if allow_multi_key else dict,
+            dict_type=ConfigurationMultiDict if allow_multi_key else dict,  # type: ignore[arg-type]
             allow_no_value=allow_no_value,
             strict=False,
             empty_lines_in_values=not allow_multi_key,

src/ahriman/core/configuration/shell_template.py

@@ -150,6 +150,6 @@ class ShellTemplate(Template):
                         break
 
         kwargs.update(mapping)
-        kwargs.update(dict(generator(kwargs)))
+        substituted = dict(generator(kwargs))
 
-        return self.safe_substitute(kwargs)
+        return self.safe_substitute(kwargs | substituted)

src/ahriman/core/status/event_bus.py

@@ -19,8 +19,7 @@
 #
 import uuid
 
-from asyncio import Lock, Queue, QueueFull, QueueShutDown
-from dataclasses import dataclass
+from asyncio import Lock, Queue, QueueFull
 from typing import Any
 
 from ahriman.core.log import LazyLogging
@@ -30,22 +29,6 @@ from ahriman.models.event import EventType
 SSEvent = tuple[str, dict[str, Any]]
 
 
-@dataclass(frozen=True)
-class _Subscription:
-    """
-    internal event bus subscription record
-
-    Attributes:
-        topics(list[EventType] | None): event type filter, ``None`` means all
-        object_id(str | None): object identifier filter, ``None`` means all
-        queue(Queue[SSEvent]): per-subscriber event queue
-    """
-
-    topics: list[EventType] | None
-    object_id: str | None
-    queue: Queue[SSEvent]
-
-
 class EventBus(LazyLogging):
     """
     event bus implementation
@@ -62,7 +45,7 @@ class EventBus(LazyLogging):
         self.max_size = max_size
 
         self._lock = Lock()
-        self._subscribers: dict[str, _Subscription] = {}
+        self._subscribers: dict[str, tuple[list[EventType] | None, Queue[SSEvent | None]]] = {}
 
     async def broadcast(self, event_type: EventType, object_id: str | None, **kwargs: Any) -> None:
         """
@@ -77,49 +60,42 @@ class EventBus(LazyLogging):
         event.update(kwargs)
 
         async with self._lock:
-            snapshot = list(self._subscribers.items())
-
-        for subscriber_id, subscription in snapshot:
-            if subscription.topics is not None and event_type not in subscription.topics:
-                continue
-            if subscription.object_id is not None and object_id != subscription.object_id:
-                continue
-
-            try:
-                subscription.queue.put_nowait((event_type, event))
-            except QueueFull:
-                self.logger.warning("discard message to slow subscriber %s", subscriber_id)
-            except QueueShutDown:
-                pass
+            for subscriber_id, (topics, queue) in self._subscribers.items():
+                if topics is not None and event_type not in topics:
+                    continue
+                try:
+                    queue.put_nowait((event_type, event))
+                except QueueFull:
+                    self.logger.warning("discard message to slow subscriber %s", subscriber_id)
 
     async def shutdown(self) -> None:
         """
         gracefully shutdown all subscribers
         """
         async with self._lock:
-            for subscription in self._subscribers.values():
-                subscription.queue.shutdown()
-            self._subscribers.clear()
+            for _, queue in self._subscribers.values():
+                try:
+                    queue.put_nowait(None)
+                except QueueFull:
+                    pass
+                queue.shutdown()
 
-    async def subscribe(self, topics: list[EventType] | None = None,
-                        object_id: str | None = None) -> tuple[str, Queue[SSEvent]]:
+    async def subscribe(self, topics: list[EventType] | None = None) -> tuple[str, Queue[SSEvent | None]]:
         """
         register new subscriber
 
         Args:
             topics(list[EventType] | None, optional): list of event types to filter by. If ``None`` is set,
                 all events will be delivered (Default value = None)
-            object_id(str | None, optional): object identifier to filter by. If ``None`` is set,
-                events for all objects will be delivered (Default value = None)
 
         Returns:
-            tuple[str, Queue[SSEvent]]: subscriber identifier and associated queue
+            tuple[str, Queue[SSEvent | None]]: subscriber identifier and associated queue
         """
         subscriber_id = str(uuid.uuid4())
-        queue: Queue[SSEvent] = Queue(self.max_size)
+        queue: Queue[SSEvent | None] = Queue(self.max_size)
 
         async with self._lock:
-            self._subscribers[subscriber_id] = _Subscription(topics=topics, object_id=object_id, queue=queue)
+            self._subscribers[subscriber_id] = (topics, queue)
 
         return subscriber_id, queue
 
@@ -131,6 +107,7 @@ class EventBus(LazyLogging):
             subscriber_id(str): subscriber unique identifier
         """
         async with self._lock:
-            subscription = self._subscribers.pop(subscriber_id, None)
-        if subscription is not None:
-            subscription.queue.shutdown()
+            result = self._subscribers.pop(subscriber_id, None)
+        if result is not None:
+            _, queue = result
+            queue.shutdown()

src/ahriman/web/schemas/event_bus_filter_schema.py

@@ -31,7 +31,3 @@ class EventBusFilterSchema(RepositoryIdSchema):
         "description": "Event type filter",
         "example": [EventType.PackageUpdated],
     })
-    object_id = fields.String(metadata={
-        "description": "Object identifier filter",
-        "example": "ahriman",
-    })

src/ahriman/web/views/base.py

@@ -209,8 +209,8 @@ class BaseView(View, CorsViewMixin):
             HTTPBadRequest: if supplied parameters are invalid
         """
         try:
-            limit = int(self.request.query.get("limit", -1))
-            offset = int(self.request.query.get("offset", 0))
+            limit = int(self.request.query.get("limit", default=-1))
+            offset = int(self.request.query.get("offset", default=0))
         except ValueError as ex:
             raise HTTPBadRequest(reason=str(ex))
 

src/ahriman/web/views/v1/auditlog/event_bus.py

@@ -19,7 +19,7 @@
 #
 import json
 
-from aiohttp.web import HTTPBadRequest, Request, Response, StreamResponse
+from aiohttp.web import HTTPBadRequest, StreamResponse
 from aiohttp_sse import EventSourceResponse, sse_response
 from asyncio import Queue, QueueShutDown, wait_for
 from typing import ClassVar
@@ -37,89 +37,38 @@ class EventBusView(BaseView):
     event bus SSE view
 
     Attributes:
-        READ_EVENTS(set[EventType]): (class attribute) events which are allowed for read-only users
+        GET_PERMISSION(UserAccess): (class attribute) get permissions of self
     """
 
-    READ_EVENTS: ClassVar[set[EventType]] = {
-        EventType.PackageHeld,
-        EventType.PackageOutdated,
-        EventType.PackageRemoved,
-        EventType.PackageStatusChanged,
-        EventType.PackageUpdateFailed,
-        EventType.PackageUpdated,
-        EventType.ServiceStatusChanged,
-    }
+    GET_PERMISSION: ClassVar[UserAccess] = UserAccess.Full
     ROUTES = ["/api/v1/events/stream"]
 
-    @classmethod
-    async def get_permission(cls, request: Request) -> UserAccess:
-        """
-        retrieve user permission from the request
-
-        Args:
-            request(Request): request object
-
-        Returns:
-            UserAccess: extracted permission
-        """
-        if request.method.upper() not in ("GET", "HEAD"):
-            return await BaseView.get_permission(request)
-
-        permission = UserAccess.Full
-        try:
-            topics = cls(request)._topics()
-        except HTTPBadRequest:
-            topics = None
-
-        if topics is not None and set(topics).issubset(cls.READ_EVENTS):
-            permission = UserAccess.Read
-
-        return permission
-
     @staticmethod
-    async def _run(response: EventSourceResponse, queue: Queue[SSEvent]) -> None:
+    async def _run(response: EventSourceResponse, queue: Queue[SSEvent | None]) -> None:
         """
         read events from queue and send them to the client
 
         Args:
             response(EventSourceResponse): SSE response instance
-            queue(Queue[SSEvent]): subscriber queue
+            queue(Queue[SSEvent | None]): subscriber queue
         """
         while response.is_connected():
             try:
-                event_type, data = await wait_for(queue.get(), timeout=response.ping_interval)
+                message = await wait_for(queue.get(), timeout=response.ping_interval)
             except TimeoutError:
                 continue
-            except QueueShutDown:
-                break
+
+            if message is None:
+                break  # terminate queue on sentinel event
+            event_type, data = message
 
             await response.send(json.dumps(data), event=event_type)
 
-    def _topics(self) -> list[EventType] | None:
-        """
-        parse event filter from request query
-
-        Returns:
-            list[EventType] | None: event filter if any
-
-        Raises:
-            HTTPBadRequest: if invalid event type is supplied
-        """
-        if self.request.query is None:
-            return None
-
-        try:
-            return [EventType(event) for event in self.request.query.getall("event", [])] or None
-        except ValueError as ex:
-            raise HTTPBadRequest(reason=str(ex))
-
     @apidocs(
         tags=["Audit log"],
         summary="Live updates",
-        description="Stream live updates via SSE. Read-only users may subscribe only when all requested event filters "
-                    "belong to read-safe package and service status events; build log or unfiltered streams require "
-                    "full access. Streams are live-only and do not replay missed events after reconnect.",
-        permission=UserAccess.Full,
+        description="Stream live updates via SSE",
+        permission=GET_PERMISSION,
         error_400_enabled=True,
         error_404_description="Repository is unknown",
         schema=SSESchema(many=True),
@@ -131,13 +80,18 @@ class EventBusView(BaseView):
 
         Returns:
             StreamResponse: 200 with streaming updates
+
+        Raises:
+            HTTPBadRequest: if invalid event type is supplied
         """
-        topics = self._topics()
-        object_id = self.request.query.get("object_id")
+        try:
+            topics = [EventType(event) for event in self.request.query.getall("event", [])] or None
+        except ValueError as ex:
+            raise HTTPBadRequest(reason=str(ex))
         event_bus = self.service().event_bus
 
         async with sse_response(self.request) as response:
-            subscription_id, queue = await event_bus.subscribe(topics, object_id=object_id)
+            subscription_id, queue = await event_bus.subscribe(topics)
 
             try:
                 await self._run(response, queue)
@@ -147,18 +101,3 @@ class EventBusView(BaseView):
                 await event_bus.unsubscribe(subscription_id)
 
         return response
-
-    async def head(self) -> StreamResponse:
-        """
-        HEAD method implementation based on the result of GET method
-
-        Returns:
-            StreamResponse: generated response for the request
-        """
-        self._topics()
-        self.service()
-
-        return Response(headers={
-            "Cache-Control": "no-cache",
-            "Content-Type": "text/event-stream",
-        })

tests/ahriman/core/status/test_event_bus.py

@@ -1,7 +1,5 @@
 import pytest
 
-from asyncio import QueueShutDown
-
 from ahriman.core.status.event_bus import EventBus
 from ahriman.models.event import EventType
 from ahriman.models.package import Package
@@ -51,26 +49,15 @@ async def test_broadcast_queue_full(event_bus: EventBus, package_ahriman: Packag
     assert queue.qsize() == 1
 
 
-async def test_broadcast_queue_shutdown(event_bus: EventBus, package_ahriman: Package) -> None:
-    """
-    must skip subscriber whose queue was shutdown concurrently
-    """
-    _, queue = await event_bus.subscribe()
-    queue.shutdown()
-
-    await event_bus.broadcast(EventType.PackageUpdated, package_ahriman.base)
-
-
 async def test_shutdown(event_bus: EventBus) -> None:
     """
-    must shutdown all subscriber queues on shutdown
+    must send sentinel to all subscribers on shutdown
     """
-    subscriber_id, queue = await event_bus.subscribe()
+    _, queue = await event_bus.subscribe()
 
     await event_bus.shutdown()
-    assert subscriber_id not in event_bus._subscribers
-    with pytest.raises(QueueShutDown):
-        queue.get_nowait()
+    message = queue.get_nowait()
+    assert message is None
 
 
 async def test_shutdown_queue_full(event_bus: EventBus, package_ahriman: Package) -> None:
@@ -95,38 +82,13 @@ async def test_subscribe(event_bus: EventBus) -> None:
     assert subscriber_id in event_bus._subscribers
 
 
-async def test_broadcast_with_object_id(event_bus: EventBus, package_ahriman: Package) -> None:
-    """
-    must broadcast event to subscribers with matching object_id
-    """
-    _, queue = await event_bus.subscribe(object_id=package_ahriman.base)
-    await event_bus.broadcast(EventType.PackageUpdated, package_ahriman.base)
-    assert not queue.empty()
-
-
-async def test_broadcast_object_id_isolation(event_bus: EventBus, package_ahriman: Package) -> None:
-    """
-    must not broadcast event to subscribers with non-matching object_id
-    """
-    _, queue = await event_bus.subscribe(object_id="other-package")
-    await event_bus.broadcast(EventType.PackageUpdated, package_ahriman.base)
-    assert queue.empty()
-
-
 async def test_subscribe_with_topics(event_bus: EventBus) -> None:
     """
     must register subscriber with topic filter
     """
     subscriber_id, _ = await event_bus.subscribe([EventType.BuildLog])
-    assert event_bus._subscribers[subscriber_id].topics == [EventType.BuildLog]
-
-
-async def test_subscribe_with_object_id(event_bus: EventBus, package_ahriman: Package) -> None:
-    """
-    must register subscriber with object_id filter
-    """
-    subscriber_id, _ = await event_bus.subscribe(object_id=package_ahriman.base)
-    assert event_bus._subscribers[subscriber_id].object_id == package_ahriman.base
+    topics, _ = event_bus._subscribers[subscriber_id]
+    assert topics == [EventType.BuildLog]
 
 
 async def test_unsubscribe(event_bus: EventBus) -> None:

tests/ahriman/web/views/v1/auditlog/test_view_v1_auditlog_event_bus.py

@@ -2,9 +2,7 @@ import asyncio
 import pytest
 
 from aiohttp.test_utils import TestClient
-from aiohttp.web import HTTPBadRequest
 from asyncio import Queue
-from multidict import MultiDict
 from pytest_mock import MockerFixture
 from unittest.mock import AsyncMock
 
@@ -13,7 +11,6 @@ from ahriman.models.event import EventType
 from ahriman.models.package import Package
 from ahriman.models.user_access import UserAccess
 from ahriman.web.keys import WatcherKey
-from ahriman.web.views.base import BaseView
 from ahriman.web.views.v1.auditlog.event_bus import EventBusView
 
 
@@ -41,51 +38,6 @@ async def test_get_permission() -> None:
         assert await EventBusView.get_permission(request) == UserAccess.Full
 
 
-async def test_get_permission_build_log() -> None:
-    """
-    must return full permission for build log stream
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict(event=EventType.BuildLog))
-    assert await EventBusView.get_permission(request) == UserAccess.Full
-
-
-async def test_get_permission_build_log_with_read_events() -> None:
-    """
-    must return full permission for mixed build log and read event stream
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict([
-        ("event", EventType.BuildLog),
-        ("event", EventType.PackageUpdated),
-    ]))
-    assert await EventBusView.get_permission(request) == UserAccess.Full
-
-
-async def test_get_permission_invalid_event() -> None:
-    """
-    must return full permission for invalid event type
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict(event="invalid"))
-    assert await EventBusView.get_permission(request) == UserAccess.Full
-
-
-async def test_get_permission_post() -> None:
-    """
-    must use default permission for non-get requests
-    """
-    request = pytest.helpers.request("", "", "POST", params=MultiDict(event=EventType.PackageUpdated))
-    assert await EventBusView.get_permission(request) == await BaseView.get_permission(request)
-
-
-async def test_get_permission_read_events() -> None:
-    """
-    must return read permission for package and status streams
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict(
-        ("event", event_type) for event_type in EventBusView.READ_EVENTS
-    ))
-    assert await EventBusView.get_permission(request) == UserAccess.Read
-
-
 def test_routes() -> None:
     """
     must return correct routes
@@ -101,7 +53,7 @@ async def test_run_timeout() -> None:
 
     async def _shutdown() -> None:
         await asyncio.sleep(0.05)
-        queue.shutdown()
+        await queue.put(None)
 
     response = AsyncMock()
     response.is_connected = lambda: True
@@ -111,37 +63,6 @@ async def test_run_timeout() -> None:
     await EventBusView._run(response, queue)
 
 
-def test_topics() -> None:
-    """
-    must parse event filters
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict([
-        ("event", EventType.PackageUpdated),
-        ("event", EventType.PackageRemoved),
-    ]))
-
-    assert EventBusView(request)._topics() == [EventType.PackageUpdated, EventType.PackageRemoved]
-
-
-def test_topics_empty() -> None:
-    """
-    must return None for missing event filters
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict())
-
-    assert EventBusView(request)._topics() is None
-
-
-def test_topics_invalid() -> None:
-    """
-    must raise bad request for invalid event filters
-    """
-    request = pytest.helpers.request("", "", "GET", params=MultiDict(event="invalid"))
-
-    with pytest.raises(HTTPBadRequest):
-        EventBusView(request)._topics()
-
-
 async def test_get(client: TestClient, package_ahriman: Package) -> None:
     """
     must stream events via SSE
@@ -178,23 +99,6 @@ async def test_get_with_topic_filter(client: TestClient, package_ahriman: Packag
     assert EventType.PackageRemoved not in body
 
 
-async def test_get_with_object_id_filter(client: TestClient, package_ahriman: Package) -> None:
-    """
-    must filter events by object_id
-    """
-    watcher = next(iter(client.app[WatcherKey].values()))
-    asyncio.create_task(_producer(watcher, package_ahriman))
-    request_schema = pytest.helpers.schema_request(EventBusView.get, location="querystring")
-
-    payload = {"object_id": "non-existent-package"}
-    assert not request_schema.validate(payload)
-    response = await client.get("/api/v1/events/stream", params=payload)
-    assert response.status == 200
-
-    body = await response.text()
-    assert "ahriman" not in body
-
-
 async def test_get_bad_request(client: TestClient) -> None:
     """
     must return bad request for invalid event type
@@ -224,31 +128,3 @@ async def test_get_connection_reset(client: TestClient, mocker: MockerFixture) -
     mocker.patch.object(EventBusView, "_run", side_effect=ConnectionResetError)
     response = await client.get("/api/v1/events/stream")
     assert response.status == 200
-
-
-async def test_head(client: TestClient) -> None:
-    """
-    must check stream availability without opening SSE stream
-    """
-    response = await client.head("/api/v1/events/stream", params={"event": EventType.PackageUpdated})
-    assert response.status == 200
-    assert response.headers["Content-Type"] == "text/event-stream"
-    assert not await response.text()
-
-
-async def test_head_bad_request(client: TestClient) -> None:
-    """
-    must return bad request for invalid event type
-    """
-    response = await client.head("/api/v1/events/stream", params={"event": "invalid"})
-    assert response.status == 400
-    assert not await response.text()
-
-
-async def test_head_not_found(client: TestClient) -> None:
-    """
-    must return not found for unknown repository
-    """
-    response = await client.head("/api/v1/events/stream", params={"architecture": "unknown", "repository": "unknown"})
-    assert response.status == 404
-    assert not await response.text()