feat: add support for user avatars (#2296)

* feat: add support for user avatars

* more fixes

* more fixes

* more fixes

* more fixes

1 files changed, 101 insertions, 1 deletions

diff --git a/packages/trpc/models/users.ts b/packages/trpc/models/users.ts
index 4c7272b1..0653349b 100644
--- a/packages/trpc/models/users.ts
+++ b/packages/trpc/models/users.ts
@@ -7,6 +7,7 @@ import { z } from "zod";
 import { SqliteError } from "@karakeep/db";
 import {
   assets,
+  AssetTypes,
   bookmarkLinks,
   bookmarkLists,
   bookmarks,
@@ -17,7 +18,7 @@ import {
   users,
   verificationTokens,
 } from "@karakeep/db/schema";
-import { deleteUserAssets } from "@karakeep/shared/assetdb";
+import { deleteAsset, deleteUserAssets } from "@karakeep/shared/assetdb";
 import serverConfig from "@karakeep/shared/config";
 import {
   zResetPasswordSchema,
@@ -491,6 +492,104 @@ export class User {
       .where(eq(users.id, this.user.id));
   }
 
+  async updateAvatar(assetId: string | null): Promise<void> {
+    const previousImage = this.user.image ?? null;
+    const [asset, previousAsset] = await Promise.all([
+      assetId
+        ? this.ctx.db.query.assets.findFirst({
+            where: and(eq(assets.id, assetId), eq(assets.userId, this.user.id)),
+            columns: {
+              id: true,
+              bookmarkId: true,
+              contentType: true,
+              assetType: true,
+            },
+          })
+        : Promise.resolve(null),
+      previousImage && previousImage !== assetId
+        ? this.ctx.db.query.assets.findFirst({
+            where: and(
+              eq(assets.id, previousImage),
+              eq(assets.userId, this.user.id),
+            ),
+            columns: {
+              id: true,
+              bookmarkId: true,
+            },
+          })
+        : Promise.resolve(null),
+    ]);
+
+    if (assetId) {
+      if (!asset) {
+        throw new TRPCError({
+          code: "NOT_FOUND",
+          message: "Avatar asset not found",
+        });
+      }
+
+      if (asset.bookmarkId) {
+        throw new TRPCError({
+          code: "BAD_REQUEST",
+          message: "Avatar asset must not be attached to a bookmark",
+        });
+      }
+
+      if (asset.contentType && !asset.contentType.startsWith("image/")) {
+        throw new TRPCError({
+          code: "BAD_REQUEST",
+          message: "Avatar asset must be an image",
+        });
+      }
+
+      if (
+        asset.assetType !== AssetTypes.AVATAR &&
+        asset.assetType !== AssetTypes.UNKNOWN
+      ) {
+        throw new TRPCError({
+          code: "BAD_REQUEST",
+          message: "Avatar asset type is not supported",
+        });
+      }
+
+      if (asset.assetType !== AssetTypes.AVATAR) {
+        await this.ctx.db
+          .update(assets)
+          .set({ assetType: AssetTypes.AVATAR })
+          .where(eq(assets.id, asset.id));
+      }
+    }
+    if (previousImage === assetId) {
+      return;
+    }
+
+    await this.ctx.db.transaction(async (tx) => {
+      await tx
+        .update(users)
+        .set({ image: assetId })
+        .where(eq(users.id, this.user.id));
+
+      if (!previousImage || previousImage === assetId) {
+        return;
+      }
+
+      if (previousAsset && !previousAsset.bookmarkId) {
+        await tx.delete(assets).where(eq(assets.id, previousAsset.id));
+      }
+    });
+
+    this.user.image = assetId;
+
+    if (!previousImage || previousImage === assetId) {
+      return;
+    }
+
+    await deleteAsset({
+      userId: this.user.id,
+      assetId: previousImage,
+    }).catch(() => ({}));
+  }
+
   async getStats(): Promise<z.infer<typeof zUserStatsResponseSchema>> {
     const userObj = await this.ctx.db.query.users.findFirst({
       where: eq(users.id, this.user.id),
@@ -770,6 +869,7 @@ export class User {
       id: this.user.id,
       name: this.user.name,
       email: this.user.email,
+      image: this.user.image,
       localUser: this.user.password !== null,
     };
   }