Store
@@ -30,7 +29,7 @@ const StoreItemView = (props: {
))}
diff --git a/src/app/layout.tsx b/src/app/layout.tsx
index 6e5a2cb..89c2d68 100644
--- a/src/app/layout.tsx
+++ b/src/app/layout.tsx
@@ -1,14 +1,80 @@
+"use client";
+import { useEffect, useState } from "react";
+import type { PublicKey } from "@solana/web3.js";
+
import "./globals.css";
+import { PhantomProvider } from "typings";
export default function RootLayout({
children,
}: {
children: React.ReactNode;
}) {
+ const [provider, setProvider] = useState
();
+ const [walletAddress, setWalletAddress] = useState("");
+ const [showErrorMessage, setShowErrorMessage] = useState(false);
+
+ useEffect(() => {
+ const provider = getProvider();
+ setProvider(provider);
+ if (!provider) return;
+ provider.on("connect", async (publicKey: PublicKey) => {
+ const body = { publicKey: publicKey };
+ const res = await fetch("/api/user/login", {
+ method: "POST",
+ body: JSON.stringify(body),
+ headers: { "Content-Type": "application/json" },
+ });
+ if (res.status === 200) {
+ setWalletAddress(publicKey.toBase58());
+ }
+ if (res.status === 404) {
+ setShowErrorMessage(true);
+ setTimeout(() => {
+ setShowErrorMessage(false);
+ }, 3000);
+ }
+ });
+ }, []);
+
+ const getProvider = () => {
+ if ("phantom" in window) {
+ const anyWindow: any = window;
+ const provider = anyWindow.phantom.solana;
+ if (provider.isPhantom) return provider;
+ }
+ };
+
+ const connectWallet = () => {
+ if (!provider) return console.log("no provider");
+ provider.connect();
+ };
+
return (
- {children}
+
+
+ {children}
+
);
}
diff --git a/src/app/page.tsx b/src/app/page.tsx
index 07060b0..d502da5 100644
--- a/src/app/page.tsx
+++ b/src/app/page.tsx
@@ -6,12 +6,14 @@ import StakingSourcesView from "./Components/StakingSourcesView";
import BankAccountsView from "./Components/BankAccountsView";
import StoreItemView from "./Components/StoreItemView";
import ResourceStore from "./Components/ResourceStore";
+import ErrorPopover from "./Components/ErrorPopover";
+import { gameConfig } from "@/utils/gameLogic";
import {
IStoreItem,
IInventoryItem,
IStakingSource,
IBankAccount,
- IClaimableResource,
+ IStake,
} from "typings";
export default function Home() {
@@ -21,176 +23,220 @@ export default function Home() {
const [stakingSources, setStakingSources] = useState
(
[]
);
- const [bankAccounts, setBankAccounts] = useState([]);
+ const [bankAccount, setBankAccount] = useState();
const [storeItems, setStoreItems] = useState([]);
+ const [userStakes, setUserStakes] = useState([]);
const [lightBoxIsActive, setLightBoxIsActive] = useState(false);
+ const [userId, setUserId] = useState(null);
+ const [error, setError] = useState(null);
+ const [errorTime, setErrorTime] = useState(3);
+
+ // EMIL
+ // It should be possible to add infinite drills on each resource (however many the user has)
+
+ // JOE
+ // Transaction table
+ // Add dev buttons to prototype
+
+ // DONE POST /user/login check if user exists
+ // DONE GET /user/USER_ID/stakes get stake event
+ // DONE POST /user/USER_ID/stakes/claim claim stake
+ // DONE POST /user/USER_ID/stakes/start start stake
+ // DONE GET /user/USER_ID/bank-account get balance
+ // DONE PUT /user/USER_ID/bank-account sell resource
+ // DONE GET /user/USER_ID/inventory-items get inventory items
+ // DONE POST /user/USER_ID/inventory-items buy item
+ // DONE GET /user/USER_ID/staking-sources get staking sources
+ // DONE POST /user/USER_ID/staking-sources create staking source
- // Connect to DB here
useEffect(() => {
- // get the user who is currently logged in
- const loggedInUser = 1;
+ const fetchUser = async (wallet: string) => {
+ const response = await fetch(`/api/user/login`, {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ wallet: wallet,
+ }),
+ });
+ if (response.status === 200) {
+ console.log("Logged in");
+ const { userId } = await response.json();
+ setUserId(userId);
+ }
+ };
- const fetchInventoryItems = async () => {
- const response = await fetch(`/api/user/${loggedInUser}/inventory-items`);
- const DBInventoryItems = await response.json();
- setInventoryItems(DBInventoryItems.message);
+ const fetchBankAccount = async () => {
+ const response = await fetch(`/api/user/${userId}/bank-account`);
+ const bankAccount = await response.json();
+ setBankAccount(bankAccount);
};
const fetchStakingSources = async () => {
- const response = await fetch(`/api/user/${loggedInUser}/staking-sources`);
- const DBStakingSources = await response.json();
- setStakingSources(DBStakingSources.message);
+ const response = await fetch(`/api/user/${userId}/staking-sources`);
+ const sources = await response.json();
+ setStakingSources(sources);
};
- const fetchBankAccounts = async () => {
- const response = await fetch(`/api/user/${loggedInUser}/bank-accounts`);
- const DBBankAccounts = await response.json();
- setBankAccounts(DBBankAccounts.message);
- };
+ const fetchInventoryItems = async () => {
+ const response = await fetch(`/api/user/${userId}/inventory-items`);
+ const DBInventoryItems = await response.json();
- const fetchStoreItems = async () => {
- const response = await fetch(`/api/store/items`);
- const DBStoreItems = await response.json();
- setStoreItems(DBStoreItems.message);
- };
-
- fetchBankAccounts();
- fetchStakingSources();
- fetchInventoryItems();
- fetchStoreItems();
- }, []);
-
- // Use effect to update the items on staking sources when inventoryItems are updated
- useEffect(() => {
- const updateItemsOnStakingSources = () => {
- const updatedStakingSources = stakingSources?.map((source) => {
- const item = inventoryItems?.find(
- (item) => source.inventoryItem?.id === item.id
+ for (const invItem of DBInventoryItems) {
+ invItem.storeItem = gameConfig.store.find(
+ (item) => item.id === invItem.storeItemId
);
- if (item) {
- return { ...source, inventoryItem: item };
- } else {
- return source;
- }
+ }
+
+ setInventoryItems(DBInventoryItems);
+ };
+
+ const fetchStakes = async () => {
+ const response = await fetch(`/api/user/${userId}/stakes`);
+ const stakes = await response.json();
+ setUserStakes(
+ stakes.map((stake: IStake) => ({
+ ...stake,
+ unclaimed: stake.unclaimed == 1,
+ }))
+ );
+ };
+
+ fetchUser("abcdefg"); // Public key goes here
+ // Nico is there a better way of checking if a user is logged in?
+ if (userId) {
+ setStoreItems(gameConfig.store);
+ fetchBankAccount();
+ fetchStakingSources();
+ fetchInventoryItems();
+ fetchStakes();
+ }
+ }, [userId]);
+
+ // Hide error automatically
+ useEffect(() => {
+ if (error) {
+ const intervalId = setInterval(() => {
+ setErrorTime((prev) => prev - 1);
+ }, 1000);
+ if (errorTime === 0) {
+ setError(null);
+ clearInterval(intervalId);
+ setErrorTime(3);
+ }
+
+ return () => {
+ clearInterval(intervalId);
+ };
+ }
+ }, [error, errorTime]);
+
+ const claimStake = async (stakingEventId: number) => {
+ const response = await fetch(`/api/user/${userId}/stakes/claim`, {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({ stakingEventId: stakingEventId }),
+ });
+ return await response.json();
+ };
+
+ const startStake = async (inventoryItemId: number, wellId: number) => {
+ const response = await fetch(`/api/user/${userId}/stakes/start`, {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ inventoryItemId: inventoryItemId,
+ wellId: wellId,
+ }),
+ });
+ return await response.json();
+ };
+
+ // Which object is it?
+ const sellResource = async (obj: any) => {
+ const response = await fetch(`/api/user/${userId}/bank-account`, {
+ method: "PUT",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ obj: obj,
+ }),
+ });
+ return await response.json();
+ };
+
+ const buyStoreItem = async (itemId: string) => {
+ try {
+ const response = await fetch(`/api/user/${userId}/inventory-items`, {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ itemId: itemId,
+ }),
});
- updatedStakingSources && setStakingSources(updatedStakingSources);
- };
- if (stakingSources && stakingSources?.length > 0) {
- updateItemsOnStakingSources();
- }
- }, [inventoryItems]);
- const handleAddItem = (
- inventoryItem: IInventoryItem,
- stakingSource: IStakingSource
- ) => {
- const newStakingSources = stakingSources?.map((source) => {
- if (source.id === stakingSource.id) {
- return { ...source, inventoryItem: inventoryItem };
- } else {
- return source;
+ if (!response.ok) {
+ const error = await response.text();
+ setError(new Error(error));
+ return;
}
- });
- if (newStakingSources) {
- setStakingSources(newStakingSources);
+ const data = await response.json();
+
+ if (response.status == 200) {
+ // Return success message
+ console.log(data.message);
+ }
+ } catch (error) {
+ if (error instanceof Error) {
+ setError(error);
+ } else {
+ setError(new Error("An unknown error occurred."));
+ }
}
};
- const handleBuy = (storeItem: IStoreItem) => {
- const hasItem = inventoryItems?.some((item) => {
- item.storeItem.id === storeItem.id;
- });
+ const upgradeInventoryItem = async (itemId: number) => {
+ try {
+ const response = await fetch(`/api/user/${userId}/inventory-items`, {
+ method: "PUT",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ itemId: itemId,
+ }),
+ });
- if (hasItem) return;
+ if (!response.ok) {
+ const error = await response.text();
+ setError(new Error(error));
+ return;
+ }
- const getNewIndex = () => {
- if (!inventoryItems) return 0;
- return inventoryItems.length;
- };
+ const data = await response.json();
- const newInventoryItem = {
- id: getNewIndex(),
- stakingSource: null,
- storeItem: storeItem,
- currentTierIndex: 0,
- };
+ if (response.status == 200) {
+ // Return success message
+ console.log(data.message);
+ }
- if (inventoryItems && inventoryItems !== undefined) {
- setInventoryItems([...inventoryItems, newInventoryItem]);
+ if (response.status == 400) {
+ // return error message
+ setError(data.error);
+ }
+ } catch (error) {
+ if (error instanceof Error) {
+ setError(error);
+ } else {
+ setError(new Error("An unknown error occurred."));
+ }
}
};
- const claimResource = (
- stakingSource: IStakingSource,
- claimedResource: IClaimableResource
- ): boolean => {
- const bankAccount = bankAccounts.find(
- (obj) => obj["resourceType"]["name"] === claimedResource.resourceType.name
- );
-
- if (!bankAccount) return false;
- decrementResourceWell(stakingSource, claimedResource);
- incrementBalance(bankAccount, claimedResource.balance);
-
- return true;
- };
-
- const decrementResourceWell = (
- stakingSource: IStakingSource,
- claimedResource: IClaimableResource
- ) => {
- const updatedResourceWells = stakingSource.resourceWells.map((well) => {
- if (well.resourceType.name === claimedResource.resourceType.name) {
- return { ...well, supply: well.supply - claimedResource.balance };
- } else {
- return well;
- }
+ const createStakingSource = async () => {
+ const response = await fetch(`/api/user/${userId}/staking-sources`, {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({}),
});
-
- const updatedStakingSources = stakingSources?.map((source) => {
- if (source.id === stakingSource.id) {
- return { ...source, resourceWells: updatedResourceWells };
- } else {
- return source;
- }
- });
-
- updatedStakingSources && setStakingSources(updatedStakingSources);
- };
-
- const decrementBalance = () => {};
-
- const incrementBalance = (bankAccount: IBankAccount, amount: number) => {
- const updatedBankAccounts = bankAccounts.map((account) => {
- if (account.id === bankAccount.id) {
- return { ...account, balance: account.balance + amount };
- } else {
- return account;
- }
- });
- setBankAccounts(updatedBankAccounts);
- };
-
- const getStoreItemConfiguration = () => {};
-
- const handleIncrementTier = (inventoryItem: IInventoryItem) => {
- console.log("Incrementing Tier");
- // Check user has balance
- // Decrement user balance
-
- if (inventoryItem.currentTierIndex === 4) return;
-
- const updatedInventoryItems = inventoryItems?.map((item) => {
- if (item.id === inventoryItem.id) {
- return { ...item, currentTierIndex: item.currentTierIndex + 1 };
- } else {
- return item;
- }
- });
-
- if (updatedInventoryItems !== undefined)
- setInventoryItems(updatedInventoryItems);
+ return await response.json();
};
const handleSetLightBox = () => {
@@ -206,8 +252,11 @@ export default function Home() {
return (
<>
+ {error && (
+
+ )}
{lightBoxIsActive && (
@@ -220,18 +269,17 @@ export default function Home() {
diff --git a/src/pages/api/drop.ts b/src/pages/api/drop.ts
new file mode 100644
index 0000000..9a0d4d2
--- /dev/null
+++ b/src/pages/api/drop.ts
@@ -0,0 +1,39 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "GET") {
+ const db = await dbConnection;
+ const users = "DROP TABLE users";
+ await db.all(users);
+ const resource = "DROP TABLE resource";
+ await db.all(resource);
+ const staking_source = "DROP TABLE staking_source";
+ await db.all(staking_source);
+ const resource_well = "DROP TABLE resource_well";
+ await db.all(resource_well);
+ const staking_event = "DROP TABLE staking_event";
+ await db.all(staking_event);
+ const claim_event = "DROP TABLE claim_event";
+ await db.all(claim_event);
+ const upgrade_event = "DROP TABLE upgrade_event";
+ await db.all(upgrade_event);
+ const store_item = "DROP TABLE store_item";
+ await db.all(store_item);
+ const inventory_item = "DROP TABLE inventory_item";
+ await db.all(inventory_item);
+ const bank_account = "DROP TABLE bank_account";
+ await db.all(bank_account);
+ const resource_account = "DROP TABLE resource_account";
+ await db.all(resource_account);
+
+ res.status(200).json("Tables dropped");
+ }
+ } catch (error) {
+ res.status(500).json(error);
+ }
+}
diff --git a/src/pages/api/seed.ts b/src/pages/api/seed.ts
new file mode 100644
index 0000000..e5ae080
--- /dev/null
+++ b/src/pages/api/seed.ts
@@ -0,0 +1,27 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+import * as fs from 'fs';
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "GET") {
+ const db = await dbConnection;
+
+ // Read SQL queries from file
+ const sql1 = fs.readFileSync('sql/tables.sql', 'utf-8');
+
+ // Execute the SQL queries
+ await db.exec(sql1);
+
+ const sql2 = fs.readFileSync('sql/data.sql', 'utf-8');
+ await db.exec(sql2);
+
+ res.status(200).json("Database seeded");
+ }
+ } catch (error) {
+ res.status(500).json(error.message);
+ }
+}
diff --git a/src/pages/api/store/items.ts b/src/pages/api/store/items.ts
deleted file mode 100644
index ac4f044..0000000
--- a/src/pages/api/store/items.ts
+++ /dev/null
@@ -1,80 +0,0 @@
-import type { NextApiRequest, NextApiResponse } from "next";
-import { IStoreItem } from "typings";
-
-export default function handler(req: NextApiRequest, res: NextApiResponse) {
- try {
- if (req.method === "GET") {
- // query all store items
- const storeItems: IStoreItem[] = [
- {
- id: 1,
- name: "Eclipse Drill",
- description:
- "A compact and lightweight drill designed for use in tight and narrow mining tunnels.",
- price: 225,
- timeToClaim: 3,
- tiers: [
- {
- tier: 500,
- price: 50,
- },
- {
- tier: 600,
- price: 75,
- },
- {
- tier: 700,
- price: 100,
- },
- {
- tier: 800,
- price: 150,
- },
- {
- tier: 900,
- price: 200,
- },
- ],
- },
- {
- id: 2,
- name: "Moon Saw 2000",
- description:
- "A compact and lightweight drill designed for use in tight and narrow mining tunnels.",
- price: 100,
- timeToClaim: 3,
- tiers: [
- {
- tier: 500,
- price: 50,
- },
- {
- tier: 550,
- price: 75,
- },
- {
- tier: 600,
- price: 100,
- },
- {
- tier: 650,
- price: 150,
- },
- {
- tier: 700,
- price: 200,
- },
- ],
- },
- ];
-
- // if no store items send empty array
- if (!storeItems) return res.status(200).json({ message: [] });
-
- // if store items found send store items
- return res.status(200).json({ message: storeItems });
- }
- } catch (error) {
- res.status(500).json({ message: "Unexpexted server error" });
- }
-}
diff --git a/src/pages/api/user/[userId]/add-balance/[amount].ts b/src/pages/api/user/[userId]/add-balance/[amount].ts
new file mode 100644
index 0000000..08f3a13
--- /dev/null
+++ b/src/pages/api/user/[userId]/add-balance/[amount].ts
@@ -0,0 +1,27 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ // http://127.0.0.1:3000/api/user/1/add-balance/100
+ // Remember to change to POST
+ try {
+ if (req.method === "GET") {
+ const { userId, amount } = req.query;
+ const db = await dbConnection;
+ const sql = `
+ UPDATE bank_account SET balance = balance + ?
+ WHERE user_id = ?`;
+ const result = await db.run(sql, [amount, userId])
+ if (result.changes == 0) {
+ return res.status(400).json({error: `User ${userId} was not found`});
+ } else {
+ return res.status(200).json({message: result});
+ }
+ }
+ } catch (error) {
+ return res.status(500).json(error);
+ }
+}
diff --git a/src/pages/api/user/[userId]/bank-account.ts b/src/pages/api/user/[userId]/bank-account.ts
new file mode 100644
index 0000000..94ff324
--- /dev/null
+++ b/src/pages/api/user/[userId]/bank-account.ts
@@ -0,0 +1,48 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "GET") {
+ const { userId } = req.query;
+ const db = await dbConnection;
+ const userSql = `SELECT * FROM users WHERE id = ?`;
+ const user = await db.all(userSql, [userId]);
+ if (user.length === 0) return res.status(404).json("User not found");
+
+ const resourceAccountsSql = `
+ SELECT id,resname as resourceType,balance
+ FROM resource_account
+ WHERE user_id = ?`;
+ // need resourceName or at least a way to map together with gameConfiq
+ const resourceAccounts = await db.all(resourceAccountsSql, [userId]);
+
+ const bankAccountSql = `SELECT * FROM bank_account WHERE user_id = ?`;
+ const bankAccount = await db.all(bankAccountSql, [userId]);
+
+ const bankAccountObj = {
+ id: bankAccount[0].id,
+ primaryBalance: bankAccount[0].balance,
+ resourceAccounts: resourceAccounts,
+ };
+
+ return res.status(200).json(bankAccountObj);
+ }
+
+ if (req.method === "PUT") {
+ // sell resource
+ // payload userId, key:resourceName/value:amount
+ const { userId } = req.query;
+ const { obj } = req.body;
+ // make sure they have each resource they say they have
+ // calculate conversion rates
+ // increment balance
+ // decrement resources
+ }
+ } catch (error) {
+ res.status(500).json(error);
+ }
+}
diff --git a/src/pages/api/user/[userId]/bank-accounts.ts b/src/pages/api/user/[userId]/bank-accounts.ts
deleted file mode 100644
index 131a35e..0000000
--- a/src/pages/api/user/[userId]/bank-accounts.ts
+++ /dev/null
@@ -1,73 +0,0 @@
-import type { NextApiRequest, NextApiResponse } from "next";
-import { IBankAccount, IResourceType } from "typings";
-
-export default function handler(req: NextApiRequest, res: NextApiResponse) {
- try {
- if (req.method === "GET") {
- const { userId } = req.query;
-
- // query db for user ID
- const user = true;
- // if user not found send error
- if (!user) return res.status(404).json({ message: "User not found" });
-
- // if user found query all bank accounts attached to this user
- const DBresourceTypes: IResourceType[] = [
- {
- id: 1,
- name: "Moonstone",
- fontColorClass: "text-teal-400",
- bgColorClass: "from-teal-800 to-teal-900",
- },
- {
- id: 2,
- name: "Lunarite",
- fontColorClass: "text-cyan-400",
- bgColorClass: "from-cyan-800 to-cyan-900",
- },
- {
- id: 3,
- name: "Selenite",
- fontColorClass: "text-purple-300",
- bgColorClass: "from-purple-800 to-purple-900",
- },
- {
- id: 4,
- name: "Heliogem",
- fontColorClass: "text-rose-300",
- bgColorClass: "from-rose-800 to-rose-900",
- },
- ];
- const bankAccounts: IBankAccount[] = [
- {
- id: 1,
- resourceType: DBresourceTypes[0],
- balance: 0,
- },
- {
- id: 2,
- resourceType: DBresourceTypes[1],
- balance: 0,
- },
- {
- id: 3,
- resourceType: DBresourceTypes[2],
- balance: 0,
- },
- {
- id: 4,
- resourceType: DBresourceTypes[3],
- balance: 0,
- },
- ];
-
- // if bank accounts not found send empty array
- if (!bankAccounts) return res.status(200).json({ message: [] });
-
- // if bank accounts found send bank accounts
- return res.status(200).json({ message: bankAccounts });
- }
- } catch (error) {
- res.status(500).json({ message: "Unexpexted server error" });
- }
-}
diff --git a/src/pages/api/user/[userId]/inventory-items.ts b/src/pages/api/user/[userId]/inventory-items.ts
index 25ebc04..d693f63 100644
--- a/src/pages/api/user/[userId]/inventory-items.ts
+++ b/src/pages/api/user/[userId]/inventory-items.ts
@@ -1,26 +1,91 @@
+import { dbConnection } from "db";
import type { NextApiRequest, NextApiResponse } from "next";
-import { IInventoryItem } from "typings";
+import { gameConfig } from "@/utils/gameLogic";
-export default function handler(req: NextApiRequest, res: NextApiResponse) {
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
try {
if (req.method === "GET") {
+ // Get all owned items
+
const { userId } = req.query;
+ const db = await dbConnection;
+ const inventorySql = `
+ SELECT id, store_item_id as storeItemId, tier as currentTierIndex
+ FROM inventory_item WHERE user_id = ?`;
+ const inventoryItems = await db.all(inventorySql, [userId]);
+ return res.status(200).json(inventoryItems);
- // query db for user ID
- const user = true;
- // if user not found send error
- if (!user) return res.status(404).json({ message: "User not found" });
+ } else if (req.method === "POST") {
+ // Buy a new item
+ const { userId } = req.query;
+ const { itemId } = req.body;
+ const db = await dbConnection;
- // if user found query all inventory items attached to this user
- const inventoryItems: IInventoryItem[] = [];
+ const storeItem = gameConfig.store.find((item) => item.id == itemId);
- // if inventory items not found send empty array
- if (!inventoryItems) return res.status(200).json({ message: [] });
+ if (storeItem == undefined) {
+ return res.status(400).json({ error: "Item does not exist" });
+ }
+ const itemPrice = storeItem.price;
+ // TODO: Split the try catch to report already owned item error
+ try {
+ await db.run("BEGIN");
+ await db.run(`UPDATE bank_account SET balance = balance - ?
+ WHERE user_id = ?`, [itemPrice, userId]);
+ await db.run(`INSERT INTO inventory_item (user_id, store_item_id)
+ VALUES (?, ?)`, [userId, itemId]);
+ await db.run("COMMIT");
+ } catch (error) {
+ await db.exec("ROLLBACK");
+ return res.status(400).json({ error: "Either Insufficient funds or item is already owned" });
+ }
+ return res.status(200).json({ message: "Item purchased successfully" });
- // if inventory items found send inventory items
- return res.status(200).json({ message: inventoryItems });
+ } else if (req.method === "PUT") {
+ // Upgrade an existing item
+ const { userId } = req.query;
+ const { itemId } = req.body;
+ const db = await dbConnection;
+
+ const invSql = "SELECT id,tier,store_item_id FROM inventory_item WHERE id = ? AND user_id = ?";
+
+ const invItem = await db.get(invSql, [itemId, userId]);
+
+ const storeItem = gameConfig.store.find((item) => item.id == invItem.store_item_id);
+ if (storeItem == undefined) {
+ return res.status(400).json({ error: "Item does not exist" });
+ }
+
+ const tier = invItem.tier;
+ if (tier == undefined) {
+ return res.status(400).json({ error: "Item does not exist" });
+ }
+ if (tier >= storeItem.upgrades.length) {
+ return res.status(400).json({ error: "Max upgrade reached" });
+ }
+ const upgradePrice = storeItem.upgrades[tier].price;
+ try {
+ await db.run("BEGIN");
+ await db.run(`UPDATE bank_account SET balance = balance - ?
+ WHERE user_id = ?`, [upgradePrice, userId]);
+ await db.run(`UPDATE inventory_item SET tier = tier + 1
+ WHERE user_id = ? AND store_item_id = ?;`, [userId, itemId]);
+ await db.run("INSERT INTO upgrade_event(inventory_item_id) VALUES ( ? )", [invItem.store_item_id]);
+ await db.run("COMMIT");
+ } catch (error) {
+ await db.exec("ROLLBACK");
+ return res.status(400).json({ error: "Insufficient funds" });
+ }
+ return res.status(200).json({ message: "Successfully upgraded item" });
}
} catch (error) {
- res.status(500).json({ message: "Unexpexted server error" });
+ if(error instanceof Error){
+ res.status(500).json(error.message);
+ }else {
+ res.status(500).json("Unknow Error");
+ }
}
}
diff --git a/src/pages/api/user/[userId]/stakes/claim.ts b/src/pages/api/user/[userId]/stakes/claim.ts
new file mode 100644
index 0000000..3be1da5
--- /dev/null
+++ b/src/pages/api/user/[userId]/stakes/claim.ts
@@ -0,0 +1,60 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+import { IInventoryItem } from "typings";
+import {
+ calculateRemainingTime,
+} from "../../../../../utils/helpers";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "POST") {
+ const { userId } = req.query;
+ const { stakingEventId } = req.body;
+
+ const db = await dbConnection;
+ try {
+ const stake = await db.get("SELECT * FROM staking_event WHERE id = ? AND user_id = ?",
+ [stakingEventId, userId]);
+
+ if (stake == undefined) {
+ return res.status(400).json({error: "Could not find stake"});
+ }
+
+ const claim = await db.get("SELECT id FROM claim_event WHERE staking_event_id = ?",
+ [stakingEventId])
+ if (claim != undefined) {
+ return res.status(400).json({error: "Stake already claimed"});
+ }
+
+ const timeRemaining = calculateRemainingTime(stake.created_at, stake.duration_in_mins);
+ if (timeRemaining > 0) {
+ return res.status(400).json({error: "Staking period has not ended"});
+ }
+ const well = await db.get("SELECT id,resname,supply FROM resource_well WHERE id = ?",
+ [stake.well_id])
+
+ const claimAmount = stake.stake_amount > well.supply ? well.supply : stake.stake_amount;
+
+ await db.run("BEGIN");
+ await db.run("INSERT INTO claim_event(staking_event_id, claim_amount) VALUES (?, ?)",
+ [stake.id, claimAmount])
+ console.log(well.id);
+ const r1 = await db.run(`UPDATE resource_well SET supply = supply - ? WHERE id = ?`,
+ [claimAmount, well.id]);
+ console.log(stake.user_id, well.resname);
+ const r2 = await db.run(`UPDATE resource_account SET balance = balance + ?
+ WHERE user_id = ? AND resname = ?`, [claimAmount, stake.user_id, well.resname]);
+ await db.run("COMMIT");
+ } catch (error) {
+ await db.exec("ROLLBACK");
+ return res.status(400).json({ error: error.message});
+ }
+ return res.status(200).json({result: "Successfully claimed stake"});
+ }
+ } catch (error) {
+ res.status(500).json(error);
+ }
+}
diff --git a/src/pages/api/user/[userId]/stakes/index.ts b/src/pages/api/user/[userId]/stakes/index.ts
new file mode 100644
index 0000000..e6f9291
--- /dev/null
+++ b/src/pages/api/user/[userId]/stakes/index.ts
@@ -0,0 +1,28 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+import { IInventoryItem } from "typings";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "GET") {
+ const { userId } = req.query;
+ const db = await dbConnection;
+ const inventorySql = `
+ SELECT staking_event.id, staking_source.id as sourceId, resname as resourceType,
+ inventory_item_id, duration_in_mins, stake_amount, staking_event.created_at,
+ CASE WHEN claim_event.staking_event_id IS NULL THEN 1 ELSE 0 END AS unclaimed
+ FROM staking_event
+ INNER JOIN resource_well ON well_id = resource_well.id
+ INNER JOIN staking_source ON source_id = staking_source.id
+ LEFT JOIN claim_event ON staking_event.id = claim_event.staking_event_id
+ WHERE staking_event.user_id = ?`;
+ const inventoryItems = await db.all(inventorySql, [userId]);
+ return res.status(200).json(inventoryItems);
+ }
+ } catch (error) {
+ res.status(500).json(error);
+ }
+}
diff --git a/src/pages/api/user/[userId]/stakes/start.ts b/src/pages/api/user/[userId]/stakes/start.ts
new file mode 100644
index 0000000..d882caf
--- /dev/null
+++ b/src/pages/api/user/[userId]/stakes/start.ts
@@ -0,0 +1,79 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+import {
+ calculateRemainingTime,
+} from "../../../../../utils/helpers";
+
+import { gameConfig } from "@/utils/gameLogic";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "POST") {
+ const { userId } = req.query;
+ const {
+ inventoryItemId,
+ wellId,
+ } = req.body;
+
+ const db = await dbConnection;
+ try {
+ const inventorySql = `
+ SELECT inventory_item.id, tier, store_item_id, staking_event.id as stakeId,
+ staking_event.created_at as stakeTime, duration_in_mins, stake_amount
+ FROM inventory_item
+ LEFT JOIN staking_event ON inventory_item_id = inventory_item.id
+ WHERE inventory_item.store_item_id = ? AND inventory_item.user_id = ?
+ ORDER BY staking_event.created_at;
+ `;
+
+ const invItem = await db.get(inventorySql, [inventoryItemId, userId]);
+ const well = await db.get(`
+ SELECT resource_well.id, resname, source_id, supply as wellId FROM resource_well
+ INNER JOIN staking_source ON source_id = staking_source.id
+ WHERE resource_well.id = ? AND user_id = ?;
+ `, [wellId, userId]);
+
+ if (well == undefined) {
+ return res.status(400).json({error: `Well ${wellId} not found`});
+ }
+
+ const item = gameConfig.store.find((i) => i.id == invItem.store_item_id);
+ if (invItem == undefined || well == undefined || item == undefined) {
+ return res.status(400).json({ error: "A resource was not found" });
+ }
+
+ if (invItem.stakeId != undefined) {
+ const timeRemaining = calculateRemainingTime(invItem.stakeTime, invItem.duration_in_mins);
+ console.log(timeRemaining);
+ if (timeRemaining > 0) {
+ return res.status(400).json({error: `Item is still in use ${timeRemaining}`});
+ }
+ }
+
+ const boost = invItem.tier > 0 ? item.upgrades[invItem.tier - 1].claimBoost : 0;
+ const totalClaim = item.claimAmount + boost;
+ console.log(userId + " " + well.id + " " + invItem.id)
+ await db.run(`INSERT INTO staking_event(user_id, well_id, inventory_item_id, duration_in_mins, stake_amount)
+ VALUES (?,?,?,?,?)`,
+ [userId, well.id, invItem.id, item.completionTimeInMins, totalClaim]);
+ } catch (error) {
+ if(error instanceof Error){
+ return res.status(400).json({ error: error.message});
+ }else {
+ return res.status(400).json({ error: "Unknown Error"});
+ }
+ }
+
+ return res.status(200).json({result: "Successfully started a stake"});
+ }
+ } catch (error) {
+ if(error instanceof Error){
+ res.status(500).json(error.message);
+ }else {
+ res.status(500).json({ error: "Unknown Error"});
+ }
+ }
+}
diff --git a/src/pages/api/user/[userId]/staking-sources.ts b/src/pages/api/user/[userId]/staking-sources.ts
index 8a6f4ce..5c1e531 100644
--- a/src/pages/api/user/[userId]/staking-sources.ts
+++ b/src/pages/api/user/[userId]/staking-sources.ts
@@ -1,46 +1,93 @@
+import { dbConnection } from "db";
import type { NextApiRequest, NextApiResponse } from "next";
import { IStakingSource } from "typings";
+import { gameConfig } from "@/utils/gameLogic";
+import {
+ generateRandomBase64String,
+} from "../../../../utils/helpers";
-export default function handler(req: NextApiRequest, res: NextApiResponse) {
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
try {
if (req.method === "GET") {
const { userId } = req.query;
+ const db = await dbConnection;
+ const sourcesSql = `
+ SELECT id, name, description FROM staking_source
+ WHERE staking_source.user_id = ?`;
+ const stakingSources = await db.all(sourcesSql, [userId]);
+ for (const source of stakingSources) {
+ const wellsSql = `
+ SELECT id, resname as resourceType, supply FROM resource_well
+ WHERE source_id = ?`;
+ const resourceWells = await db.all(wellsSql, [source.id]);
+ source.resourceWells = resourceWells;
+ const stakesSql = `
+ SELECT staking_event.id, resname as resourceType, source_id as stakingSourceId,
+ inventory_item_id, duration_in_mins, stake_amount,
+ staking_event.created_at as startTime
+ FROM staking_event
+ INNER JOIN resource_well ON well_id = resource_well.id
+ INNER JOIN staking_source ON source_id = staking_source.id
+ LEFT JOIN claim_event ON staking_event.id = claim_event.staking_event_id
+ WHERE staking_source.id = ? AND claim_event.staking_event_id IS NULL;`;
+ const activeStakes = await db.all(stakesSql, [source.id]);
+ source.activeStakes = activeStakes;
+ }
+ const typedStakingSources: IStakingSource[] = stakingSources.map(source => ({
+ ...source,
+ // Emil: The variable names are messed up so i'm renaming them
+ activeStakes: source.activeStakes.map((stake) => ({
+ ...stake,
+ inventoryItemId: stake.inventory_item_id,
+ durationInMins: stake.duration_in_mins,
+ stakeAmount: stake.stake_amount
+ }))
+ }))
- // query db for user ID
- const user = true;
- // if user not found send error
- if (!user) return res.status(404).json({ message: "User not found" });
+ return res.status(200).json(typedStakingSources);
+ }
+ if (req.method === "POST") {
+ const { userId } = req.query;
+ const db = await dbConnection;
- // if user found query all staking sources attached to this user
- const stakingSources: IStakingSource[] = [
- {
- id: 1,
- name: "Selene's Eye",
- description:
- "Selene's Eye is a large and mysterious moon, named for its distinctive appearance - a bright, glowing eye that seems to stare out from the void of space",
- resourceWells:[
- {
- id: 1,
- resourceType: {
- id: 1,
- name: "Moonstone",
- fontColorClass: "text-teal-400",
- bgColorClass: "from-teal-800 to-teal-900",
- },
- supply: 10000,
- }
- ],
- inventoryItem: null,
- },
- ];
+ try {
+ const randomName = "Moon 1";
+ const randomDescription = "This is a moon orbiting Selene's planet";
+ const randomKey = "0x" + generateRandomBase64String(16);
+ const resMax = gameConfig.moons.resourceMaxStartAmount;
+ const resMin = gameConfig.moons.resourceMinStartAmount;
+ const moonPrice = gameConfig.moons.price;
- // if staking sources not found send empty array
- if (!stakingSources) return res.status(200).json({ message: [] });
-
- // if staking sources found send staking sources
- return res.status(200).json({ message: stakingSources });
+ await db.run("BEGIN");
+ await db.run(`UPDATE bank_account SET balance = balance - ?
+ WHERE user_id = ?`, [moonPrice, userId]);
+ const result = await db.run(`INSERT INTO staking_source(user_id, name, description, address)
+ VALUES (?, ?, ?, ?)`, [userId, randomName, randomDescription, randomKey]);
+ const sourceId = result.lastID;
+ for (const resname of gameConfig.resources) {
+ if (Math.random() < gameConfig.moons.resourceChance) {
+ const randomNumber = Math.random();
+ const range = resMax - resMin + 1;
+ const initSupply = Math.floor(Math.random() * range + resMin);
+ await db.run(`INSERT INTO resource_well (source_id, resname, supply)
+ VALUES (?, ?, ?)`, [sourceId, resname, initSupply]);
+ }
+ }
+ await db.run("COMMIT");
+ return res.status(200).json({"stakingSourceId": sourceId});
+ } catch (error) {
+ await db.exec("ROLLBACK");
+ if (error.message.includes("CHECK constraint failed")) {
+ return res.status(400).json({ "error": "Insuficcient funds" });
+ } else {
+ return res.status(400).json({ "error": error.message });
+ }
+ }
}
} catch (error) {
- res.status(500).json({ message: "Unexpexted server error" });
+ res.status(500).json(error.message);
}
}
diff --git a/src/pages/api/user/login.ts b/src/pages/api/user/login.ts
new file mode 100644
index 0000000..25e44ea
--- /dev/null
+++ b/src/pages/api/user/login.ts
@@ -0,0 +1,26 @@
+import { dbConnection } from "db";
+import type { NextApiRequest, NextApiResponse } from "next";
+
+export default async function handler(
+ req: NextApiRequest,
+ res: NextApiResponse
+) {
+ try {
+ if (req.method === "POST") {
+ const { wallet } = req.body;
+ // const db = await dbConnection;
+ // const user = await db.get("SELECT id FROM users WHERE wallet = ?", [wallet]);
+
+ // Comment me out
+ return res.status(200).json({ userId: 1});
+
+ /* if (user != undefined) {
+ return res.status(200).json({ userId: user.id});
+ } else {
+ return res.status(404).json({ message: "User not found" });
+ } */
+ }
+ } catch (error) {
+ res.status(500).json(error);
+ }
+}
diff --git a/src/utils/gameLogic.ts b/src/utils/gameLogic.ts
new file mode 100644
index 0000000..2d4587c
--- /dev/null
+++ b/src/utils/gameLogic.ts
@@ -0,0 +1,3 @@
+import { IGameConfig } from "typings";
+
+export const gameConfig = process.env.gameConfig as unknown as IGameConfig;
\ No newline at end of file
diff --git a/src/utils/helpers.ts b/src/utils/helpers.ts
index f500bbc..6281890 100644
--- a/src/utils/helpers.ts
+++ b/src/utils/helpers.ts
@@ -1,3 +1,6 @@
+import { TimeDuration } from "typings";
+import crypto from 'crypto';
+
export function getObjectFromArray