2 files changed, 94 insertions, 0 deletions
diff --git a/packages/shared-server/src/index.ts b/packages/shared-server/src/index.ts
index a17576ad..ff3c6abc 100644
--- a/packages/shared-server/src/index.ts
+++ b/packages/shared-server/src/index.ts
@@ -1 +1,2 @@
 export { loadAllPlugins } from "./plugins";
+export { QuotaService, StorageQuotaError } from "./services/quotaService";
diff --git a/packages/shared-server/src/services/quotaService.ts b/packages/shared-server/src/services/quotaService.ts
new file mode 100644
index 00000000..a09b76bf
--- /dev/null
+++ b/packages/shared-server/src/services/quotaService.ts
@@ -0,0 +1,93 @@
+import { count, eq, sum } from "drizzle-orm";
+
+import type { DB, KarakeepDBTransaction } from "@karakeep/db";
+import { assets, bookmarks, users } from "@karakeep/db/schema";
+import { QuotaApproved } from "@karakeep/shared/storageQuota";
+
+export class StorageQuotaError extends Error {
+  constructor(
+    public readonly currentUsage: number,
+    public readonly quota: number,
+    public readonly requestedSize: number,
+  ) {
+    super(
+      `Storage quota exceeded. Current usage: ${Math.round(currentUsage / 1024 / 1024)}MB, Quota: ${Math.round(quota / 1024 / 1024)}MB, Requested: ${Math.round(requestedSize / 1024 / 1024)}MB`,
+    );
+    this.name = "StorageQuotaError";
+  }
+}
+
+// TODO: Change the API of this class to either return a boolean
+// or throw an exception on lack of quota because now, it's inconsistent.
+export class QuotaService {
+  // TODO: Use quota approval tokens for bookmark creation when
+  // bookmark creation logic is in the model.
+  static async canCreateBookmark(db: DB, userId: string) {
+    const user = await db.query.users.findFirst({
+      where: eq(users.id, userId),
+      columns: {
+        bookmarkQuota: true,
+      },
+    });
+
+    if (user?.bookmarkQuota !== null && user?.bookmarkQuota !== undefined) {
+      const currentBookmarkCount = await db
+        .select({ count: count() })
+        .from(bookmarks)
+        .where(eq(bookmarks.userId, userId));
+
+      if (currentBookmarkCount[0].count >= user.bookmarkQuota) {
+        return {
+          result: false,
+          error: `Bookmark quota exceeded. You can only have ${user.bookmarkQuota} bookmarks.`,
+        } as const;
+      }
+    }
+    return {
+      result: true,
+    } as const;
+  }
+
+  static async checkStorageQuota(
+    db: DB | KarakeepDBTransaction,
+    userId: string,
+    requestedSize: number,
+  ): Promise<QuotaApproved> {
+    const user = await db.query.users.findFirst({
+      where: eq(users.id, userId),
+      columns: {
+        storageQuota: true,
+      },
+    });
+
+    if (user?.storageQuota === null || user?.storageQuota === undefined) {
+      // No quota limit - approve the request
+      return QuotaApproved._create(userId, requestedSize);
+    }
+
+    const currentUsage = await this.getCurrentStorageUsage(db, userId);
+
+    if (currentUsage + requestedSize > user.storageQuota) {
+      throw new StorageQuotaError(
+        currentUsage,
+        user.storageQuota,
+        requestedSize,
+      );
+    }
+
+    // Quota check passed - return approval token
+    return QuotaApproved._create(userId, requestedSize);
+  }
+
+  static async getCurrentStorageUsage(
+    db: DB | KarakeepDBTransaction,
+    userId: string,
+  ): Promise<number> {
+    const currentUsageResult = await db
+      .select({ totalSize: sum(assets.size) })
+      .from(assets)
+      .where(eq(assets.userId, userId));
+
+    return Number(currentUsageResult[0]?.totalSize ?? 0);
+  }
+}