From dfb729600fcd2f9caecc3b94757b15762f328d03 Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Fri, 5 Dec 2025 01:46:40 +0000
Subject: [PATCH 1/8] Adds new tile on the admin home page with system data.
 Also fixes the active users bug in the pie chart

---
 components/PieChart/PieChart.vue          |  2 +-
 components/SourceTable.vue                |  4 +-
 composables/admin-home.ts                 | 21 ++++++
 i18n/locales/en_us.json                   |  4 ++
 pages/admin/index.vue                     | 53 +++++++++++++++
 server/api/v1/admin/system-data/ws.get.ts | 42 ++++++++++++
 server/internal/acls/descriptions.ts      |  5 ++
 server/internal/acls/index.ts             |  4 ++
 server/internal/notifications/index.ts    |  4 +-
 server/internal/system-data/index.ts      | 81 +++++++++++++++++++++++
 server/internal/userstats/index.ts        |  7 +-
 utils/utils.ts                            |  7 ++
 12 files changed, 224 insertions(+), 10 deletions(-)
 create mode 100644 composables/admin-home.ts
 create mode 100644 server/api/v1/admin/system-data/ws.get.ts
 create mode 100644 server/internal/system-data/index.ts
 create mode 100644 utils/utils.ts

diff --git a/components/PieChart/PieChart.vue b/components/PieChart/PieChart.vue
index c878a5de..374e8d4e 100644
--- a/components/PieChart/PieChart.vue
+++ b/components/PieChart/PieChart.vue
@@ -11,7 +11,7 @@
       </svg>
       <div class="absolute inset-0 bg-zinc-900 rounded-full m-12" />
     </div>
-    <ul class="flex flex-col gap-y-1 justify-center text-left">
+    <ul class="flex flex-col gap-y-1 my-auto text-left">
       <li
         v-for="slice in slices"
         :key="slice.value"
diff --git a/components/SourceTable.vue b/components/SourceTable.vue
index b794eebd..5842823d 100644
--- a/components/SourceTable.vue
+++ b/components/SourceTable.vue
@@ -148,6 +148,7 @@ import { BackwardIcon, CheckIcon, XMarkIcon } from "@heroicons/vue/24/outline";
 import { DropLogo } from "#components";
 import { formatBytes } from "~/server/internal/utils/files";
 import { getBarColor } from "~/utils/colors";
+import { getPercentage } from "~/utils/utils";
 
 const {
   sources,
@@ -183,7 +184,4 @@ const optionsMetadata: {
     icon: BackwardIcon,
   },
 };
-
-const getPercentage = (value: number, total: number) =>
-  ((total - value) * 100) / total;
 </script>
diff --git a/composables/admin-home.ts b/composables/admin-home.ts
new file mode 100644
index 00000000..0d14597a
--- /dev/null
+++ b/composables/admin-home.ts
@@ -0,0 +1,21 @@
+import type { SerializeObject } from "nitropack";
+import type { SystemData } from "~/server/internal/system-data";
+
+const ws = new WebSocketHandler("/api/v1/admin/system-data/ws");
+
+export const useSystemData = () =>
+  useState<SerializeObject<SystemData>>(
+    "system-data",
+    (): SystemData => ({
+      totalRam: 0,
+      freeRam: 0,
+      cpuLoad: 0,
+      cpuCores: 0,
+    }),
+  );
+
+ws.listen((systemDataString) => {
+  const data = JSON.parse(systemDataString) as SerializeObject<SystemData>;
+  const systemData = useSystemData();
+  systemData.value = data;
+});
diff --git a/i18n/locales/en_us.json b/i18n/locales/en_us.json
index da77b364..797f733b 100644
--- a/i18n/locales/en_us.json
+++ b/i18n/locales/en_us.json
@@ -280,13 +280,17 @@
       "activeInactiveUsers": "Active/inactive users",
       "activeUsers": "Active users",
       "allVersionsCombined": "All versions combined",
+      "availableRam": "({freeRam} / {totalRam})",
       "biggestGamesOnServer": "Biggest games on server",
       "biggestGamesToDownload": "Biggest games to download",
+      "cpuUsage": "CPU usage",
       "games": "Games",
       "goToUsers": "Go to users",
       "inactiveUsers": "Inactive users",
       "latestVersionOnly": "Latest version only",
       "librarySources": "Library sources",
+      "numberCores": "{count} cores | {count} core | {count} cores",
+      "ramUsage": "RAM usage",
       "subheader": "Instance summary",
       "title": "Home",
       "users": "Users",
diff --git a/pages/admin/index.vue b/pages/admin/index.vue
index 0c85fd14..44342510 100644
--- a/pages/admin/index.vue
+++ b/pages/admin/index.vue
@@ -105,6 +105,55 @@
             <PieChart :data="pieChartData" />
           </TileWithLink>
         </div>
+
+        <div class="col-span-6 row-span-1 lg:col-span-2 lg:row-span-2">
+          <TileWithLink title="System">
+            <div class="h-full pb-15 content-center">
+              <div class="grid grid-cols-1 text-center gap-4">
+                <h3 class="col-span-1 text-lg font-semibold flex">
+                  <div class="flex-1 text-left">
+                    {{ $t("home.admin.cpuUsage") }}
+                  </div>
+                  <div class="flex-1 text-sm grow text-right self-center">
+                    {{ $t("home.admin.numberCores", systemData.cpuCores) }}
+                  </div>
+                </h3>
+                <div class="col-span-1">
+                  <ProgressBar
+                    :color="getBarColor(systemData.cpuLoad)"
+                    :percentage="systemData.cpuLoad"
+                  />
+                </div>
+                <h3 class="col-span-1 text-lg font-semibold my-2 flex">
+                  <div class="flex-none text-left">
+                    {{ $t("home.admin.ramUsage") }}
+                  </div>
+                  <div class="flex-1 text-sm grow text-right self-center">
+                    {{
+                      $t("home.admin.availableRam", {
+                        freeRam: formatBytes(systemData.freeRam),
+                        totalRam: formatBytes(systemData.totalRam),
+                      })
+                    }}
+                  </div>
+                </h3>
+                <div class="col-span-1">
+                  <ProgressBar
+                    :color="
+                      getBarColor(
+                        getPercentage(systemData.freeRam, systemData.totalRam),
+                      )
+                    "
+                    :percentage="
+                      getPercentage(systemData.freeRam, systemData.totalRam)
+                    "
+                  />
+                </div>
+              </div>
+            </div>
+          </TileWithLink>
+        </div>
+
         <div class="col-span-6">
           <TileWithLink
             title="Library"
@@ -139,6 +188,8 @@ import { formatBytes } from "~/server/internal/utils/files";
 import GamepadIcon from "~/components/Icons/GamepadIcon.vue";
 import DropLogo from "~/components/DropLogo.vue";
 import { ServerStackIcon, UserGroupIcon } from "@heroicons/vue/24/outline";
+import { getPercentage } from "~/utils/utils";
+import { getBarColor } from "~/utils/colors";
 import type { GameSize } from "~/server/internal/gamesize";
 import type { RankItem } from "~/components/RankingList.vue";
 
@@ -152,6 +203,8 @@ useHead({
 
 const { t } = useI18n();
 
+const systemData = useSystemData();
+
 const {
   version,
   gameCount,
diff --git a/server/api/v1/admin/system-data/ws.get.ts b/server/api/v1/admin/system-data/ws.get.ts
new file mode 100644
index 00000000..4473f748
--- /dev/null
+++ b/server/api/v1/admin/system-data/ws.get.ts
@@ -0,0 +1,42 @@
+import systemManager from "~/server/internal/system-data";
+import aclManager from "~/server/internal/acls";
+import { logger } from "~/server/internal/logging";
+
+// TODO add web socket sessions for horizontal scaling
+// Peer ID to user ID
+const socketSessions = new Map<string, string>();
+
+export default defineWebSocketHandler({
+  async open(peer) {
+    const h3 = { headers: peer.request?.headers ?? new Headers() };
+    const userId = await aclManager.getUserIdACL(h3, ["system-data:listen"]);
+    if (!userId) {
+      peer.send("unauthenticated");
+      return;
+    }
+
+    const acls = await aclManager.fetchAllACLs(h3);
+    if (!acls) {
+      peer.send("unauthenticated");
+      return;
+    }
+
+    socketSessions.set(peer.id, userId);
+
+    systemManager.listen(userId, acls, peer.id, (systemData) => {
+      peer.send(JSON.stringify(systemData));
+    });
+  },
+
+  async close(peer, _details) {
+    const userId = socketSessions.get(peer.id);
+    if (!userId) {
+      logger.info(`skipping websocket close for ${peer.id}`);
+      return;
+    }
+
+    systemManager.unlisten(userId, peer.id);
+    systemManager.unlisten("system", peer.id); // In case we were listening as 'system'
+    socketSessions.delete(peer.id);
+  },
+});
diff --git a/server/internal/acls/descriptions.ts b/server/internal/acls/descriptions.ts
index 5e4a7091..c46e5fcc 100644
--- a/server/internal/acls/descriptions.ts
+++ b/server/internal/acls/descriptions.ts
@@ -43,6 +43,8 @@ export const userACLDescriptions: ObjectFromList<typeof userACLs> = {
   "emoji:read": "Read built in emojis",
 
   "settings:read": "Read system settings.",
+  "system-data:listen":
+    "Connect to a websocket to receive system data updates.",
 };
 
 export const systemACLDescriptions: ObjectFromList<typeof systemACLs> = {
@@ -108,4 +110,7 @@ export const systemACLDescriptions: ObjectFromList<typeof systemACLs> = {
 
   "depot:new": "Create a new download depot",
   "depot:delete": "Remove a download depot",
+
+  "system-data:listen":
+    "Connect to a websocket to receive system data updates.",
 };
diff --git a/server/internal/acls/index.ts b/server/internal/acls/index.ts
index 2aca8f02..80d2b189 100644
--- a/server/internal/acls/index.ts
+++ b/server/internal/acls/index.ts
@@ -37,6 +37,8 @@ export const userACLs = [
   "news:read",
 
   "settings:read",
+
+  "system-data:listen",
 ] as const;
 const userACLPrefix = "user:";
 
@@ -100,6 +102,8 @@ export const systemACLs = [
   "maintenance:read",
 
   "settings:update",
+
+  "system-data:listen",
 ] as const;
 const systemACLPrefix = "system:";
 
diff --git a/server/internal/notifications/index.ts b/server/internal/notifications/index.ts
index 5585087f..db84a96b 100644
--- a/server/internal/notifications/index.ts
+++ b/server/internal/notifications/index.ts
@@ -56,7 +56,7 @@ class NotificationSystem {
       },
     });
     for (const notification of notifications) {
-      await listener.callback(notification);
+      listener.callback(notification);
     }
   }
 
@@ -69,7 +69,7 @@ class NotificationSystem {
         notification.acls.findIndex(
           (e) => listener.acls.findIndex((v) => v === e) != -1,
         ) != -1;
-      if (hasSome) await listener.callback(notification);
+      if (hasSome) listener.callback(notification);
     }
   }
 
diff --git a/server/internal/system-data/index.ts b/server/internal/system-data/index.ts
new file mode 100644
index 00000000..8a4c05e9
--- /dev/null
+++ b/server/internal/system-data/index.ts
@@ -0,0 +1,81 @@
+/*
+The notification system handles the receiving, creation and sending of notifications in Drop
+
+Design goals:
+1. Nonce-based notifications; notifications should only be created once
+2. Real-time; use websocket listeners to keep clients up-to-date
+*/
+
+import os from "os";
+import type { GlobalACL } from "../acls";
+
+// type Optional<T, K extends keyof T> = Pick<Partial<T>, K> & Omit<T, K>;
+
+export type SystemData = {
+  totalRam: number;
+  freeRam: number;
+  cpuLoad: number;
+  cpuCores: number;
+};
+
+export type SystemDataCreateArgs = SystemData & { acls: Array<GlobalACL> };
+
+class SystemManager {
+  // userId to acl to listenerId
+  private listeners = new Map<
+    string,
+    Map<
+      string,
+      { callback: (systemData: SystemData) => void; acls: GlobalACL[] }
+    >
+  >();
+
+  listen(
+    userId: string,
+    acls: Array<GlobalACL>,
+    id: string,
+    callback: (systemData: SystemData) => void,
+  ) {
+    if (!this.listeners.has(userId)) this.listeners.set(userId, new Map());
+    // eslint-disable-next-line @typescript-eslint/no-extra-non-null-assertion
+    this.listeners.get(userId)!!.set(id, { callback, acls });
+
+    this.catchupListener(userId, id);
+  }
+
+  unlisten(userId: string, id: string) {
+    this.listeners.get(userId)?.delete(id);
+  }
+
+  private async catchupListener(userId: string, id: string) {
+    console.log("catchupListener");
+    const listener = this.listeners.get(userId)?.get(id);
+    if (!listener) {
+      console.log("===========================================");
+      console.log("userId: ", userId);
+      console.log("id: ", id);
+      console.log("listers: ", this.listeners);
+      throw new Error("Failed to catch-up listener: callback does not exist");
+    }
+    listener.callback(this.getSystemData());
+    setTimeout(() => this.catchupListener(userId, id), 10000);
+  }
+
+  getSystemData(): SystemData {
+    return {
+      cpuLoad: this.cpuLoad(),
+      totalRam: os.totalmem(),
+      freeRam: os.freemem(),
+      cpuCores: os.cpus().length,
+    };
+  }
+
+  private cpuLoad() {
+    const [oneMinLoad, _fiveMinLoad, _fiftenMinLoad] = os.loadavg();
+    const numberCpus = os.cpus().length;
+    return 100 - ((numberCpus - oneMinLoad) / numberCpus) * 100;
+  }
+}
+
+export const systemManager = new SystemManager();
+export default systemManager;
diff --git a/server/internal/userstats/index.ts b/server/internal/userstats/index.ts
index 799933ac..b286d2b6 100644
--- a/server/internal/userstats/index.ts
+++ b/server/internal/userstats/index.ts
@@ -13,12 +13,11 @@ class UserStatsManager {
   async cacheUserSessions() {
     const activeSessions =
       (
-        await prisma.client.groupBy({
+        await prisma.session.groupBy({
           by: ["userId"],
           where: {
-            id: { not: "system" },
-            lastConnected: {
-              gt: DateTime.now().minus({ months: 1 }).toISO(),
+            expiresAt: {
+              gt: DateTime.now().toJSDate(),
             },
           },
         })
diff --git a/utils/utils.ts b/utils/utils.ts
new file mode 100644
index 00000000..74b13412
--- /dev/null
+++ b/utils/utils.ts
@@ -0,0 +1,7 @@
+export const getPercentage = (value: number, total: number) => {
+  const percentage = ((total - value) * 100) / total;
+  if (!isNaN(percentage)) {
+    return percentage;
+  }
+  return 0;
+};

From 2e2249cc76da420020023a18f54346ab6da88e26 Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Fri, 5 Dec 2025 02:15:06 +0000
Subject: [PATCH 2/8] Fixes missing parentheses

---
 i18n/locales/en_us.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/i18n/locales/en_us.json b/i18n/locales/en_us.json
index 797f733b..ed7a803f 100644
--- a/i18n/locales/en_us.json
+++ b/i18n/locales/en_us.json
@@ -289,7 +289,7 @@
       "inactiveUsers": "Inactive users",
       "latestVersionOnly": "Latest version only",
       "librarySources": "Library sources",
-      "numberCores": "{count} cores | {count} core | {count} cores",
+      "numberCores": "({count} cores) | ({count} core) | ({count} cores)",
       "ramUsage": "RAM usage",
       "subheader": "Instance summary",
       "title": "Home",

From a13ed5a2a00fef8314eb566c0e233ca58b58fb1d Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Fri, 5 Dec 2025 03:45:23 +0000
Subject: [PATCH 3/8] Updates user stats cache when signing in

---
 server/api/v1/auth/odic/callback.get.ts  | 3 +++
 server/api/v1/auth/signin/simple.post.ts | 1 +
 2 files changed, 4 insertions(+)

diff --git a/server/api/v1/auth/odic/callback.get.ts b/server/api/v1/auth/odic/callback.get.ts
index 04d7a8e5..0bc196e9 100644
--- a/server/api/v1/auth/odic/callback.get.ts
+++ b/server/api/v1/auth/odic/callback.get.ts
@@ -1,6 +1,7 @@
 import sessionHandler from "~/server/internal/session";
 import authManager from "~/server/internal/auth";
 import type { Session } from "~/server/internal/session/types";
+import userStatsManager from "~/server/internal/userstats";
 
 defineRouteMeta({
   openAPI: {
@@ -61,6 +62,8 @@ export default defineEventHandler(async (h3) => {
       `/auth/mfa?redirect=${result.options.redirect ? encodeURIComponent(result.options.redirect) : "/"}`,
     );
   }
+  await sessionHandler.signin(h3, result.user.id, true);
+  await userStatsManager.cacheUserSessions();
 
   if (result.options.redirect) {
     return sendRedirect(h3, result.options.redirect);
diff --git a/server/api/v1/auth/signin/simple.post.ts b/server/api/v1/auth/signin/simple.post.ts
index 8d40085a..7d638275 100644
--- a/server/api/v1/auth/signin/simple.post.ts
+++ b/server/api/v1/auth/signin/simple.post.ts
@@ -8,6 +8,7 @@ import authManager, {
   checkHashBcrypt,
 } from "~/server/internal/auth";
 import { logger } from "~/server/internal/logging";
+import userStatsManager from "~/server/internal/userstats";
 
 const signinValidator = type({
   username: "string",

From c7c766488b284d059a8a6fb247c2dc4092cf5362 Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Wed, 21 Jan 2026 02:58:55 +0000
Subject: [PATCH 4/8] Reads active number of users from session provider

---
 components/SourceTable.vue              |  4 ++--
 pages/admin/index.vue                   | 10 ++++++++--
 server/api/v1/auth/odic/callback.get.ts |  2 +-
 server/internal/session/cache.ts        |  5 +++++
 server/internal/session/db.ts           | 16 ++++++++++++++++
 server/internal/session/index.ts        | 10 ++++++++--
 server/internal/session/memory.ts       |  9 +++++++++
 server/internal/session/types.d.ts      |  1 +
 server/internal/system-data/index.ts    | 16 +---------------
 server/internal/userstats/index.ts      | 14 ++------------
 utils/utils.ts                          |  2 +-
 11 files changed, 54 insertions(+), 35 deletions(-)

diff --git a/components/SourceTable.vue b/components/SourceTable.vue
index 5842823d..0cd51559 100644
--- a/components/SourceTable.vue
+++ b/components/SourceTable.vue
@@ -92,14 +92,14 @@
                   v-if="source.fsStats"
                   :percentage="
                     getPercentage(
-                      source.fsStats.freeSpace,
+                      source.fsStats.totalSpace - source.fsStats.freeSpace,
                       source.fsStats.totalSpace,
                     )
                   "
                   :color="
                     getBarColor(
                       getPercentage(
-                        source.fsStats.freeSpace,
+                        source.fsStats.totalSpace - source.fsStats.freeSpace,
                         source.fsStats.totalSpace,
                       ),
                     )
diff --git a/pages/admin/index.vue b/pages/admin/index.vue
index 44342510..8d28871c 100644
--- a/pages/admin/index.vue
+++ b/pages/admin/index.vue
@@ -141,11 +141,17 @@
                   <ProgressBar
                     :color="
                       getBarColor(
-                        getPercentage(systemData.freeRam, systemData.totalRam),
+                        getPercentage(
+                          systemData.totalRam - systemData.freeRam,
+                          systemData.totalRam,
+                        ),
                       )
                     "
                     :percentage="
-                      getPercentage(systemData.freeRam, systemData.totalRam)
+                      getPercentage(
+                        systemData.totalRam - systemData.freeRam,
+                        systemData.totalRam,
+                      )
                     "
                   />
                 </div>
diff --git a/server/api/v1/auth/odic/callback.get.ts b/server/api/v1/auth/odic/callback.get.ts
index 0bc196e9..76940dc4 100644
--- a/server/api/v1/auth/odic/callback.get.ts
+++ b/server/api/v1/auth/odic/callback.get.ts
@@ -62,7 +62,7 @@ export default defineEventHandler(async (h3) => {
       `/auth/mfa?redirect=${result.options.redirect ? encodeURIComponent(result.options.redirect) : "/"}`,
     );
   }
-  await sessionHandler.signin(h3, result.user.id, true);
+  await sessionHandler.signin(h3, result.user.id);
   await userStatsManager.cacheUserSessions();
 
   if (result.options.redirect) {
diff --git a/server/internal/session/cache.ts b/server/internal/session/cache.ts
index fd6387f0..1fff5d8d 100644
--- a/server/internal/session/cache.ts
+++ b/server/internal/session/cache.ts
@@ -23,6 +23,11 @@ export default function createCacheSessionProvider() {
       const session = await sessions.get(token);
       return session ? (session as T) : undefined; // Ensure undefined is returned if session is not found
     },
+    async getNumberActiveSessions() {
+      const now = new Date();
+      const allSessions = await sessions.getItems(await sessions.getKeys());
+      return allSessions.filter(({ value }) => value.expiresAt > now).length;
+    },
     async updateSession(token, data) {
       return (await this.setSession(token, data)) !== undefined;
     },
diff --git a/server/internal/session/db.ts b/server/internal/session/db.ts
index aa53fbcb..743875a9 100644
--- a/server/internal/session/db.ts
+++ b/server/internal/session/db.ts
@@ -1,3 +1,5 @@
+import { DateTime } from "luxon";
+
 import prisma from "../db/database";
 import type { SessionProvider, SessionWithToken } from "./types";
 import cacheHandler from "../cache";
@@ -76,6 +78,20 @@ export default function createDBSessionHandler(): SessionProvider {
         },
       });
     },
+    async getNumberActiveSessions() {
+      return (
+        (
+          await prisma.session.groupBy({
+            by: ["userId"],
+            where: {
+              expiresAt: {
+                gt: DateTime.now().toJSDate(),
+              },
+            },
+          })
+        ).length || 0
+      );
+    },
     async findSessions(options) {
       const search: SessionWhereInput[] = [];
       if (options.userId) {
diff --git a/server/internal/session/index.ts b/server/internal/session/index.ts
index a96a0183..a50da598 100644
--- a/server/internal/session/index.ts
+++ b/server/internal/session/index.ts
@@ -10,8 +10,10 @@ import { parse as parseCookies } from "cookie-es";
 import type { MinimumRequestObject } from "~/server/h3";
 import type { DurationLike } from "luxon";
 import { DateTime } from "luxon";
-import createDBSessionHandler from "./db";
 import prisma from "../db/database";
+// import createMemorySessionHandler from "./memory";
+import createDBSessionHandler from "./db";
+// import createCacheSessionProvider from "./cache";
 
 /*
 This implementation may need work.
@@ -49,7 +51,7 @@ export class SessionHandler {
     // Create a new provider
     // this.sessionProvider = createCacheSessionProvider();
     this.sessionProvider = createDBSessionHandler();
-    // this.sessionProvider = createMemorySessionProvider();
+    // this.sessionProvider = createMemorySessionHandler();
   }
 
   async signin(
@@ -217,6 +219,10 @@ export class SessionHandler {
     return await this.sessionProvider.findSessions(terms);
   }
 
+  async getNumberActiveSessions() {
+    return this.sessionProvider.getNumberActiveSessions();
+  }
+
   /**
    * Update session info
    * @param token session token
diff --git a/server/internal/session/memory.ts b/server/internal/session/memory.ts
index 7f808980..9cd7d46d 100644
--- a/server/internal/session/memory.ts
+++ b/server/internal/session/memory.ts
@@ -22,6 +22,15 @@ export default function createMemorySessionHandler() {
       sessions.delete(token);
       return true;
     },
+    async getNumberActiveSessions() {
+      let activeSessions = 0;
+      for (const [_key, session] of sessions) {
+        if (session.expiresAt.getDate() > Date.now()) {
+          activeSessions += 1;
+        }
+      }
+      return activeSessions;
+    },
     async cleanupSessions() {
       const now = new Date();
       for (const [token, session] of sessions) {
diff --git a/server/internal/session/types.d.ts b/server/internal/session/types.d.ts
index 88a941b6..88558cd6 100644
--- a/server/internal/session/types.d.ts
+++ b/server/internal/session/types.d.ts
@@ -50,4 +50,5 @@ export interface SessionProvider {
   removeSession: (token: string) => Promise<boolean>;
   cleanupSessions: () => Promise<void>;
   findSessions: (options: SessionSearchTerms) => Promise<SessionWithToken[]>;
+  getNumberActiveSessions: () => Promise<number>;
 }
diff --git a/server/internal/system-data/index.ts b/server/internal/system-data/index.ts
index 8a4c05e9..e3da0d25 100644
--- a/server/internal/system-data/index.ts
+++ b/server/internal/system-data/index.ts
@@ -1,11 +1,3 @@
-/*
-The notification system handles the receiving, creation and sending of notifications in Drop
-
-Design goals:
-1. Nonce-based notifications; notifications should only be created once
-2. Real-time; use websocket listeners to keep clients up-to-date
-*/
-
 import os from "os";
 import type { GlobalACL } from "../acls";
 
@@ -40,7 +32,7 @@ class SystemManager {
     // eslint-disable-next-line @typescript-eslint/no-extra-non-null-assertion
     this.listeners.get(userId)!!.set(id, { callback, acls });
 
-    this.catchupListener(userId, id);
+    setInterval(() => this.catchupListener(userId, id), 10000);
   }
 
   unlisten(userId: string, id: string) {
@@ -48,17 +40,11 @@ class SystemManager {
   }
 
   private async catchupListener(userId: string, id: string) {
-    console.log("catchupListener");
     const listener = this.listeners.get(userId)?.get(id);
     if (!listener) {
-      console.log("===========================================");
-      console.log("userId: ", userId);
-      console.log("id: ", id);
-      console.log("listers: ", this.listeners);
       throw new Error("Failed to catch-up listener: callback does not exist");
     }
     listener.callback(this.getSystemData());
-    setTimeout(() => this.catchupListener(userId, id), 10000);
   }
 
   getSystemData(): SystemData {
diff --git a/server/internal/userstats/index.ts b/server/internal/userstats/index.ts
index b286d2b6..12345791 100644
--- a/server/internal/userstats/index.ts
+++ b/server/internal/userstats/index.ts
@@ -4,24 +4,14 @@ Handles managing collections
 
 import cacheHandler from "../cache";
 import prisma from "../db/database";
-import { DateTime } from "luxon";
+import sessionHandler from "../session";
 
 class UserStatsManager {
   // Caches the user's core library
   private userStatsCache = cacheHandler.createCache<number>("userStats");
 
   async cacheUserSessions() {
-    const activeSessions =
-      (
-        await prisma.session.groupBy({
-          by: ["userId"],
-          where: {
-            expiresAt: {
-              gt: DateTime.now().toJSDate(),
-            },
-          },
-        })
-      ).length || 0;
+    const activeSessions = await sessionHandler.getNumberActiveSessions();
     await this.userStatsCache.set("activeSessions", activeSessions);
   }
 
diff --git a/utils/utils.ts b/utils/utils.ts
index 74b13412..1ee8e3f6 100644
--- a/utils/utils.ts
+++ b/utils/utils.ts
@@ -1,5 +1,5 @@
 export const getPercentage = (value: number, total: number) => {
-  const percentage = ((total - value) * 100) / total;
+  const percentage = (value * 100) / total;
   if (!isNaN(percentage)) {
     return percentage;
   }

From c0a78052941352838972c9873e90b087f8e8ae27 Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Wed, 21 Jan 2026 03:03:39 +0000
Subject: [PATCH 5/8] Removes unused variable

---
 server/api/v1/auth/signin/simple.post.ts | 1 -
 1 file changed, 1 deletion(-)

diff --git a/server/api/v1/auth/signin/simple.post.ts b/server/api/v1/auth/signin/simple.post.ts
index 7d638275..8d40085a 100644
--- a/server/api/v1/auth/signin/simple.post.ts
+++ b/server/api/v1/auth/signin/simple.post.ts
@@ -8,7 +8,6 @@ import authManager, {
   checkHashBcrypt,
 } from "~/server/internal/auth";
 import { logger } from "~/server/internal/logging";
-import userStatsManager from "~/server/internal/userstats";
 
 const signinValidator = type({
   username: "string",

From bb2b149b10a2a231c4f3be9dc47d821f9f6fb5d7 Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Wed, 21 Jan 2026 04:15:04 +0000
Subject: [PATCH 6/8] Small improvements

---
 server/api/v1/auth/odic/callback.get.ts | 1 -
 server/internal/system-data/index.ts    | 4 ++--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/server/api/v1/auth/odic/callback.get.ts b/server/api/v1/auth/odic/callback.get.ts
index 76940dc4..b302925e 100644
--- a/server/api/v1/auth/odic/callback.get.ts
+++ b/server/api/v1/auth/odic/callback.get.ts
@@ -62,7 +62,6 @@ export default defineEventHandler(async (h3) => {
       `/auth/mfa?redirect=${result.options.redirect ? encodeURIComponent(result.options.redirect) : "/"}`,
     );
   }
-  await sessionHandler.signin(h3, result.user.id);
   await userStatsManager.cacheUserSessions();
 
   if (result.options.redirect) {
diff --git a/server/internal/system-data/index.ts b/server/internal/system-data/index.ts
index e3da0d25..4c731e11 100644
--- a/server/internal/system-data/index.ts
+++ b/server/internal/system-data/index.ts
@@ -32,14 +32,14 @@ class SystemManager {
     // eslint-disable-next-line @typescript-eslint/no-extra-non-null-assertion
     this.listeners.get(userId)!!.set(id, { callback, acls });
 
-    setInterval(() => this.catchupListener(userId, id), 10000);
+    setInterval(() => this.pushUpdate(userId, id), 10000);
   }
 
   unlisten(userId: string, id: string) {
     this.listeners.get(userId)?.delete(id);
   }
 
-  private async catchupListener(userId: string, id: string) {
+  private async pushUpdate(userId: string, id: string) {
     const listener = this.listeners.get(userId)?.get(id);
     if (!listener) {
       throw new Error("Failed to catch-up listener: callback does not exist");

From a6900995d8a698ac342bdf3d6765814e9b98d10a Mon Sep 17 00:00:00 2001
From: Francois Ribemont <ribemont.francois@gmail.com>
Date: Wed, 21 Jan 2026 23:46:00 +0000
Subject: [PATCH 7/8] Removes acl properties from system data websocket and
 performs initial push of data

---
 server/api/v1/admin/system-data/ws.get.ts |  2 +-
 server/internal/system-data/index.ts      | 17 ++++-------------
 2 files changed, 5 insertions(+), 14 deletions(-)

diff --git a/server/api/v1/admin/system-data/ws.get.ts b/server/api/v1/admin/system-data/ws.get.ts
index 4473f748..e7c45f18 100644
--- a/server/api/v1/admin/system-data/ws.get.ts
+++ b/server/api/v1/admin/system-data/ws.get.ts
@@ -23,7 +23,7 @@ export default defineWebSocketHandler({
 
     socketSessions.set(peer.id, userId);
 
-    systemManager.listen(userId, acls, peer.id, (systemData) => {
+    systemManager.listen(userId, peer.id, (systemData) => {
       peer.send(JSON.stringify(systemData));
     });
   },
diff --git a/server/internal/system-data/index.ts b/server/internal/system-data/index.ts
index 4c731e11..3347fead 100644
--- a/server/internal/system-data/index.ts
+++ b/server/internal/system-data/index.ts
@@ -1,7 +1,4 @@
 import os from "os";
-import type { GlobalACL } from "../acls";
-
-// type Optional<T, K extends keyof T> = Pick<Partial<T>, K> & Omit<T, K>;
 
 export type SystemData = {
   totalRam: number;
@@ -10,29 +7,23 @@ export type SystemData = {
   cpuCores: number;
 };
 
-export type SystemDataCreateArgs = SystemData & { acls: Array<GlobalACL> };
-
 class SystemManager {
   // userId to acl to listenerId
   private listeners = new Map<
     string,
-    Map<
-      string,
-      { callback: (systemData: SystemData) => void; acls: GlobalACL[] }
-    >
+    Map<string, { callback: (systemData: SystemData) => void }>
   >();
 
   listen(
     userId: string,
-    acls: Array<GlobalACL>,
     id: string,
     callback: (systemData: SystemData) => void,
   ) {
     if (!this.listeners.has(userId)) this.listeners.set(userId, new Map());
     // eslint-disable-next-line @typescript-eslint/no-extra-non-null-assertion
-    this.listeners.get(userId)!!.set(id, { callback, acls });
-
-    setInterval(() => this.pushUpdate(userId, id), 10000);
+    this.listeners.get(userId)!!.set(id, { callback });
+    this.pushUpdate(userId, id);
+    setInterval(() => this.pushUpdate(userId, id), 3000);
   }
 
   unlisten(userId: string, id: string) {

From 7ff05e571ef8f0cba47f409cb2d91068d8ef8894 Mon Sep 17 00:00:00 2001
From: DecDuck <declanahofmeyr@gmail.com>
Date: Thu, 22 Jan 2026 10:57:39 +1100
Subject: [PATCH 8/8] fix: remove acl fetch

---
 server/api/v1/admin/system-data/ws.get.ts | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/server/api/v1/admin/system-data/ws.get.ts b/server/api/v1/admin/system-data/ws.get.ts
index e7c45f18..ca495b98 100644
--- a/server/api/v1/admin/system-data/ws.get.ts
+++ b/server/api/v1/admin/system-data/ws.get.ts
@@ -15,12 +15,6 @@ export default defineWebSocketHandler({
       return;
     }
 
-    const acls = await aclManager.fetchAllACLs(h3);
-    if (!acls) {
-      peer.send("unauthenticated");
-      return;
-    }
-
     socketSessions.set(peer.id, userId);
 
     systemManager.listen(userId, peer.id, (systemData) => {