Fix/prevent already member to be invited again (#189)

* FEAT/isPgError utils added

* REFACTOR/transaction added

* CHORE/updated

* FIX/prevent already member to be invited again

src/app/page.tsx

@@ -462,8 +462,6 @@ const FeaturesGridBackground = () => {
   );
 };
 
-//TODO: leaving team
-//TODO: leaving team
 //TODO: renaming team
 //TODO: deleting team
 //TODO: add random facts to team page eg heavier lifter or most active in team

src/app/teams/[id]/_inviteUserForm/inviteUserForm.tsx

@@ -98,10 +98,7 @@ const useFormSchema = () => {
       const team = utils.team.get.getData({ id: pageParams.id });
 
       const userAcceptedInvite = team?.usersToTeams.find((userToTeam) => {
-        return (
-          userToTeam.team?.teamInvite?.accepted &&
-          userToTeam.user.email === vals.email
-        );
+        return userToTeam.user.email === vals.email;
       });
 
       return !userAcceptedInvite;

src/server/api/routers/team.router.ts

@@ -119,15 +119,17 @@ export const teamRouter = createTRPCRouter({
         .merge(teamInviteSchema.pick({ token: true })),
     )
     .mutation(async ({ ctx, input }) => {
-      await ctx.db.insert(usersToTeams).values({
-        memberId: ctx.session.user.id,
-        teamId: input.id,
-      });
+      await ctx.db.transaction(async (tx) => {
+        await tx.insert(usersToTeams).values({
+          memberId: ctx.session.user.id,
+          teamId: input.id,
+        });
 
-      await ctx.db
-        .update(teamInvites)
-        .set({ accepted: true })
-        .where(eq(teamInvites.token, input.token));
+        await tx
+          .update(teamInvites)
+          .set({ accepted: true })
+          .where(eq(teamInvites.token, input.token));
+      });
     }),
 
   getInvite: protectedProcedure

src/server/db/utils.ts

@@ -0,0 +1,9 @@
+import type { PostgresError } from "postgres";
+
+export const isPgError = (error: unknown): error is PostgresError => {
+  if (!(error instanceof Error)) {
+    return false;
+  }
+
+  return error.constructor.name === "PostgresError";
+};