diff --git a/app/src/server/api/routers/jutsu/transfer.ts b/app/src/server/api/routers/jutsu/transfer.ts index b5fce7c8..5f610930 100644 --- a/app/src/server/api/routers/jutsu/transfer.ts +++ b/app/src/server/api/routers/jutsu/transfer.ts @@ -1,8 +1,8 @@ import { z } from "zod"; import { TRPCError } from "@trpc/server"; import { eq, and } from "drizzle-orm"; -import { db } from "@/server/db"; -import { jutsu, users } from "@/drizzle/schema"; +import { drizzleDB } from "@/server/db"; +import { jutsu, userData } from "@/drizzle/schema"; import { createTRPCRouter, protectedProcedure } from "@/server/api/trpc"; import { JUTSU_TRANSFER_FREE_AMOUNT, JUTSU_TRANSFER_FREE_NORMAL, JUTSU_TRANSFER_FREE_SILVER, JUTSU_TRANSFER_FREE_GOLD } from "@/drizzle/constants"; import type { FederalStatus } from "@/drizzle/constants"; @@ -16,8 +16,8 @@ export const jutsuTransferRouter = createTRPCRouter({ const { userId } = ctx.auth; // Get user's last transfer date and federal status - const user = await db.query.users.findFirst({ - where: eq(users.id, userId), + const user = await drizzleDB.query.userData.findFirst({ + where: eq(userData.userId, userId), columns: { lastJutsuTransfer: true, federalStatus: true, @@ -71,10 +71,10 @@ export const jutsuTransferRouter = createTRPCRouter({ // Get source and target jutsu const [sourceJutsu, targetJutsu] = await Promise.all([ - db.query.jutsu.findFirst({ + drizzleDB.query.jutsu.findFirst({ where: eq(jutsu.id, input.sourceId), }), - db.query.jutsu.findFirst({ + drizzleDB.query.jutsu.findFirst({ where: eq(jutsu.id, input.targetId), }), ]); @@ -103,8 +103,8 @@ export const jutsuTransferRouter = createTRPCRouter({ } // Get user's transfer info - const user = await db.query.users.findFirst({ - where: eq(users.id, userId), + const user = await drizzleDB.query.userData.findFirst({ + where: eq(userData.userId, userId), columns: { lastJutsuTransfer: true, federalStatus: true, @@ -150,7 +150,7 @@ export const jutsuTransferRouter = createTRPCRouter({ } // Perform the transfer - await db.transaction(async (tx) => { + await drizzleDB.transaction(async (tx) => { // Update jutsu levels await Promise.all([ tx.update(jutsu) @@ -162,12 +162,12 @@ export const jutsuTransferRouter = createTRPCRouter({ ]); // Update user's transfer info and reputation if needed - await tx.update(users) + await tx.update(userData) .set({ lastJutsuTransfer: freeTransfersLeft > 0 ? new Date() : user.lastJutsuTransfer, - reputation: freeTransfersLeft > 0 ? user.reputation : user.reputation - REPUTATION_COST, + reputationPoints: freeTransfersLeft > 0 ? user.reputation : user.reputation - REPUTATION_COST, }) - .where(eq(users.id, userId)); + .where(eq(userData.userId, userId)); }); return {