Fix/emoji

.vscode/settings.json

@@ -0,0 +1,8 @@
+{
+    "cSpell.words": [
+        "arcjet",
+        "Kinde",
+        "openrouter",
+        "orpc"
+    ]
+}

app/(dashboard)/workspace/[workspaceId]/channel/[channelId]/_components/reaction/ReactionBar.tsx

@@ -48,15 +48,23 @@ const ReactionBar = ({ messageId, reactions, context }: ReactionBarProps) => {
     const found = rxns.find((r) => r.emoji === emoji);
 
     if (found) {
-      const newCount = found.count - 1;
-
-      return newCount <= 0
-        ? rxns.filter((r) => r.emoji !== emoji)
-        : rxns.map((r) =>
-            r.emoji === emoji
-              ? { ...r, count: newCount, reactedByMe: false }
-              : r
-          );
+      if (found.reactedByMe) {
+        const newCount = found.count - 1;
+
+        return newCount <= 0
+          ? rxns.filter((r) => r.emoji !== emoji)
+          : rxns.map((r) =>
+              r.emoji === emoji
+                ? { ...r, count: newCount, reactedByMe: false }
+                : r
+            );
+      }
+
+      return rxns.map((r) =>
+        r.emoji === emoji
+          ? { ...r, count: r.count + 1, reactedByMe: true }
+          : r
+      );
     }
 
     return [...rxns, { emoji, count: 1, reactedByMe: true }];

app/middleware/arcjet/heavy-write.ts

@@ -30,11 +30,11 @@ export const heavyWriteSecurityMiddleware = base
     });
 
     if (decision.isDenied()) {
-      if (decision.reason.isRateLimit()) {
-        throw errors.RATE_LIMITED({
-          message: "Too many impactual changes. Please slow down",
-        });
-      }
+      // if (decision.reason.isRateLimit()) {
+      //   throw errors.RATE_LIMITED({
+      //     message: "Too many impactual changes. Please slow down",
+      //   });
+      // }
 
       if (decision.reason.isRateLimit()) {
         throw errors.BAD_REQUEST({
@@ -47,4 +47,4 @@ export const heavyWriteSecurityMiddleware = base
     }
 
     return next();
-  });
+  });

app/middleware/arcjet/write.ts

@@ -32,7 +32,7 @@ export const writeSecurityMiddleware = base
     if (decision.isDenied()) {
       if (decision.reason.isRateLimit()) {
         throw errors.RATE_LIMITED({
-          message: "Too many impactual changes. Please slow down",
+          message: "Too many impactful changes. Please slow down",
         });
       }
 

app/router/ai.ts

@@ -13,8 +13,8 @@ const openrouter = createOpenRouter({
   apiKey: process.env.OPENROUTER_LLM_KEY,
 });
 
-const MODEL_ID = "amazon/nova-2-lite-v1:free";
-
+// const MODEL_ID = "amazon/nova-2-lite-v1:free";
+const MODEL_ID =  "nvidia/nemotron-nano-9b-v2:free"
 const model = openrouter.chat(MODEL_ID);
 
 export const generateThreadSummary = base

app/router/index.ts

@@ -12,12 +12,13 @@ import {
   toggleMessageReaction,
   updateMessage,
 } from "./message";
-import { createWorkspace, listWorkspace } from "./workspace";
+import { createWorkspace, listWorkspace, debugSession } from "./workspace";
 
 export const router = {
   workspace: {
     list: listWorkspace,
     create: createWorkspace,
+    debug: debugSession,
     member: {
       list: listMembers,
       invite: inviteMember,

app/router/member.ts

@@ -6,6 +6,7 @@ import { base } from "../middleware/base";
 import { requiredWorkspaceMiddleware } from "../middleware/workspace";
 import { inviteMemberSchema } from "../schemas/member";
 import {
+  ApiError,
   init,
   organization_user,
   Organizations,
@@ -14,6 +15,48 @@ import {
 import { getAvatar } from "@/lib/get-avatar";
 import { readSecurityMiddleware } from "../middleware/arcjet/read";
 
+function getKindeErrorMessage(error: unknown): string {
+  if (!error) return "Unknown Kinde error";
+
+  const maybeError = error as {
+    message?: string;
+    body?: unknown;
+  };
+
+  const body = maybeError.body;
+  if (body && typeof body === "object") {
+    const record = body as Record<string, unknown>;
+    const message =
+      (typeof record.message === "string" && record.message) ||
+      (typeof record.error === "string" && record.error) ||
+      (typeof record.error_description === "string" &&
+        record.error_description);
+
+    if (message) return message;
+  }
+
+  if (maybeError.message) return maybeError.message;
+  return "Unknown Kinde error";
+}
+
+function ensureKindeManagementEnv() {
+  const missing: string[] = [];
+
+  if (!process.env.KINDE_MANAGEMENT_CLIENT_ID) {
+    missing.push("KINDE_MANAGEMENT_CLIENT_ID");
+  }
+  if (!process.env.KINDE_MANAGEMENT_CLIENT_SECRET) {
+    missing.push("KINDE_MANAGEMENT_CLIENT_SECRET");
+  }
+  if (!process.env.KINDE_DOMAIN) {
+    missing.push("KINDE_DOMAIN");
+  }
+
+  if (missing.length > 0) {
+    throw new Error(`Missing required Kinde env vars: ${missing.join(", ")}`);
+  }
+}
+
 export const inviteMember = base
   .use(requiredAuthMiddleware)
   .use(requiredWorkspaceMiddleware)
@@ -29,6 +72,7 @@ export const inviteMember = base
   .output(z.void())
   .handler(async ({ input, context, errors }) => {
     try {
+      ensureKindeManagementEnv();
       init();
 
       await Users.createUser({
@@ -48,8 +92,41 @@ export const inviteMember = base
           ],
         },
       });
-    } catch {
-      throw errors.INTERNAL_SERVER_ERROR();
+    } catch (error: unknown) {
+      if (error instanceof ApiError) {
+        const reason = getKindeErrorMessage(error);
+
+        if (error.status === 401 || error.status === 403) {
+          throw errors.FORBIDDEN({
+            message:
+              `Kinde Management API denied this request (${error.status}). ` +
+              "Check M2M scopes (e.g. create:users) and credentials. " +
+              `Reason: ${reason}`,
+          });
+        }
+
+        if (error.status === 409) {
+          throw errors.BAD_REQUEST({
+            message:
+              "A user with this email already exists. Invite flow requires existing-user handling.",
+          });
+        }
+
+        if (error.status === 429) {
+          throw errors.RATE_LIMITED({
+            message: `Kinde rate limit hit. Reason: ${reason}`,
+          });
+        }
+
+        throw errors.INTERNAL_SERVER_ERROR({
+          message: `Kinde invite failed (${error.status}): ${reason}`,
+        });
+      }
+
+      const reason = getKindeErrorMessage(error);
+      throw errors.INTERNAL_SERVER_ERROR({
+        message: `Invite failed before Kinde call completed: ${reason}`,
+      });
     }
   });
 
@@ -68,6 +145,7 @@ export const listMembers = base
   .output(z.array(z.custom<organization_user>()))
   .handler(async ({ context, errors }) => {
     try {
+      ensureKindeManagementEnv();
       init();
 
       const data = await Organizations.getOrganizationUsers({
@@ -80,7 +158,28 @@ export const listMembers = base
       }
 
       return data.organization_users;
-    } catch {
-      throw errors.INTERNAL_SERVER_ERROR();
+    } catch (error: unknown) {
+      if (error instanceof ApiError) {
+        const reason = getKindeErrorMessage(error);
+
+        if (error.status === 401 || error.status === 403) {
+          throw errors.FORBIDDEN({
+            message:
+              `Kinde Management API denied member listing (${error.status}). ` +
+              "Check M2M scopes (e.g. read:organization_users). " +
+              `Reason: ${reason}`,
+          });
+        }
+
+        if (error.status === 429) {
+          throw errors.RATE_LIMITED({
+            message: `Kinde rate limit hit. Reason: ${reason}`,
+          });
+        }
+      }
+
+      throw errors.INTERNAL_SERVER_ERROR({
+        message: `Failed to list members: ${getKindeErrorMessage(error)}`,
+      });
     }
   });