Merge pull request #14 from ishaandhyani/stake

Stake

Author: ishaandhyani

695650-U2Q38ZH2/backend/package-lock.json

@@ -12,15 +12,21 @@
   "license": "ISC",
   "dependencies": {
     "@prisma/client": "^5.0.0",
+    "@taquito/signer": "^17.2.0",
+    "@taquito/taquito": "^17.2.0",
+    "cors": "^2.8.5",
     "express": "^4.18.2",
-    "socket.io": "^4.7.1",
-    "cors": "^2.8.5"
-
+    "socket.io": "^4.7.2"
   },
   "devDependencies": {
+    "@babel/plugin-transform-runtime": "^7.22.10",
+    "@babel/preset-env": "^7.22.10",
+    "@babel/preset-typescript": "^7.22.5",
+    "@babel/runtime": "^7.22.10",
     "@types/express": "^4.17.17",
     "@types/node": "^20.4.5",
     "@types/socket.io": "^3.0.2",
+    "babel-cli": "^6.26.0",
     "nodemon": "^3.0.1",
     "prisma": "^5.0.0",
     "ts-node": "^10.9.1",

695650-U2Q38ZH2/backend/package.json

@@ -8,12 +8,23 @@ generator client {
 datasource db {
   provider = "postgresql"
   url      = env("DATABASE_URL")
-  
 }
 
 model User {
-  id            Int      @id @default(autoincrement())
-  walletAddress String   @unique
+  id            Int        @id @default(autoincrement())
+  walletAddress String     @unique
   avatarName    String
-  // add other fields as necessary
+  createdAt     DateTime   @default(now())
+  updatedAt     DateTime?  @updatedAt
+  gameStats     GameStats?
+}
+
+model GameStats {
+  id          Int  @id @default(autoincrement())
+  gamesPlayed Int  @default(0)
+  gamesWon    Int  @default(0)
+  gamesLost   Int  @default(0)
+  gamesDrawn  Int  @default(0)
+  userId      Int  @unique
+  user        User @relation(fields: [userId], references: [id])
 }

695650-U2Q38ZH2/backend/prisma/schema.prisma

@@ -0,0 +1,23 @@
+import { Request, Response } from 'express';
+import * as GameStatsService from './gameStats.service';
+
+export const getGameStatsByUserId = async (req: Request, res: Response) => {
+  try {
+    const gameStats = await GameStatsService.getGameStatsByUserId(parseInt(req.params.userId, 10));
+    res.json(gameStats);
+  } catch (err) {
+    console.error(err);
+    res.sendStatus(500);
+  }
+};
+
+export const updateGameStats = async (req: Request, res: Response) => {
+  try {
+    const { userId, result } = req.body;
+    const updatedStats = await GameStatsService.updateGameStats(userId, result);
+    res.json(updatedStats);
+  } catch (err) {
+    console.error(err);
+    res.sendStatus(500);
+  }
+};

695650-U2Q38ZH2/backend/src/api/gameStats/gameStats.controller.ts

@@ -0,0 +1,9 @@
+import express from 'express';
+import * as GameStatsController from './gameStats.controller';
+
+const router = express.Router();
+
+router.get('/gameStats/:userId', GameStatsController.getGameStatsByUserId);
+router.post('/gameStats/update', GameStatsController.updateGameStats);
+
+export default router;

695650-U2Q38ZH2/backend/src/api/gameStats/gameStats.routes.ts

@@ -0,0 +1,39 @@
+import { prisma } from '../../config/prisma';
+
+
+export const getGameStatsByUserId = async (userId: number) => {
+  return prisma.gameStats.findUnique({
+    where: { userId }
+  });
+};
+
+export const updateGameStats = async (userId: number, result: 'win' | 'loss' | 'draw') => {
+  const userStats = await getGameStatsByUserId(userId);
+
+  if (!userStats) {
+    throw new Error('User stats not found');
+  }
+
+  switch (result) {
+    case 'win':
+      return prisma.gameStats.update({
+        where: { userId },
+        data: { gamesPlayed: userStats.gamesPlayed + 1, gamesWon: userStats.gamesWon + 1 }
+      });
+
+    case 'loss':
+      return prisma.gameStats.update({
+        where: { userId },
+        data: { gamesPlayed: userStats.gamesPlayed + 1, gamesLost: userStats.gamesLost + 1 }
+      });
+
+    case 'draw':
+      return prisma.gameStats.update({
+        where: { userId },
+        data: { gamesPlayed: userStats.gamesPlayed + 1, gamesDrawn: userStats.gamesDrawn + 1 }
+      });
+
+    default:
+      throw new Error('Invalid game result');
+  }
+};

695650-U2Q38ZH2/backend/src/api/gameStats/gameStats.service.ts

@@ -1,12 +1,11 @@
 import { Request, Response } from 'express';
 import * as UserService from './user.service';
 
-export const createUser = async (req: Request, res: Response) => {
+export const upsertUser = async (req: Request, res: Response) => {
   try {
-    const user = await UserService.createUser(req.body);
+    const user = await UserService.upsertUser(req.body);
     res.json(user);
   } catch (err) {
-    // Handle error
     console.error(err);
     res.sendStatus(500);
   }

695650-U2Q38ZH2/backend/src/api/user/user.controller.ts

@@ -1,9 +1,9 @@
-import express from 'express';
-import * as UserController from './user.controller';
+import express from "express";
+import * as UserController from "./user.controller";
 
 const router = express.Router();
 
-router.post('/user', UserController.createUser);
-router.get('/user/:walletAddress', UserController.getUserByWallet);
+router.post("/user/upsert", UserController.upsertUser);
+router.get("/user/:walletAddress", UserController.getUserByWallet);
 
 export default router;

695650-U2Q38ZH2/backend/src/api/user/user.routes.ts

@@ -1,12 +1,21 @@
-import { PrismaClient, Prisma } from '@prisma/client';
-import { prisma } from '../../config/prisma';
+import { PrismaClient, Prisma } from "@prisma/client";
+import { prisma } from "../../config/prisma";
 
-export const createUser = async (userData: Prisma.UserCreateInput) => {
-  return prisma.user.create({ data: userData });
+export const upsertUser = async (userData: Prisma.UserCreateInput) => {
+  return prisma.user.upsert({
+    where: { walletAddress: userData.walletAddress },
+    update: userData,
+    create: {
+      ...userData,
+      gameStats: {
+        create: {}
+      }
+    },
+  });
 };
 
 export const getUserByWallet = async (walletAddress: string) => {
   return prisma.user.findUnique({
-    where: { walletAddress }
+    where: { walletAddress },
   });
 };

695650-U2Q38ZH2/backend/src/api/user/user.service.ts

@@ -1,5 +1,5 @@
 function generateId(l: number = 10): string {
-  const s = "abcdefghijklmnopqrstuvwxyz0123456789";
+  const s = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
   return new Array(l).fill('_').map(() => {
     let e = s[Math.floor(Math.random() * s.length)];
     if (Math.random() < 0.5) {