-
-
CoinStorge
+
+
Rugplay
A crypto trading simulator where you can practice trading without losing real money. Create
diff --git a/website/src/routes/api/coin/[coinSymbol]/+server.ts b/website/src/routes/api/coin/[coinSymbol]/+server.ts
index 1e8c5af..1f5be80 100644
--- a/website/src/routes/api/coin/[coinSymbol]/+server.ts
+++ b/website/src/routes/api/coin/[coinSymbol]/+server.ts
@@ -134,9 +134,7 @@ export async function GET({ params, url }) {
creatorName: user.name,
creatorUsername: user.username,
creatorBio: user.bio,
- creatorImage: user.image,
- tradingUnlocksAt: coin.tradingUnlocksAt,
- isLocked: coin.isLocked
+ creatorImage: user.image
})
.from(coin)
.leftJoin(user, eq(coin.creatorId, user.id))
@@ -187,9 +185,7 @@ export async function GET({ params, url }) {
poolCoinAmount: Number(coinData.poolCoinAmount),
poolBaseCurrencyAmount: Number(coinData.poolBaseCurrencyAmount),
circulatingSupply: Number(coinData.circulatingSupply),
- initialSupply: Number(coinData.initialSupply),
- tradingUnlocksAt: coinData.tradingUnlocksAt,
- isLocked: coinData.isLocked
+ initialSupply: Number(coinData.initialSupply)
},
candlestickData,
volumeData,
diff --git a/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts b/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts
index a51b140..821e93e 100644
--- a/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts
+++ b/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts
@@ -5,7 +5,43 @@ import { coin, userPortfolio, user, transaction, priceHistory } from '$lib/serve
import { eq, and, gte } from 'drizzle-orm';
import { redis } from '$lib/server/redis';
import { createNotification } from '$lib/server/notification';
-import { calculate24hMetrics, executeSellTrade } from '$lib/server/amm';
+
+async function calculate24hMetrics(coinId: number, currentPrice: number) {
+ const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000);
+
+ // Get price from 24h ago
+ const [priceData] = await db
+ .select({ price: priceHistory.price })
+ .from(priceHistory)
+ .where(and(
+ eq(priceHistory.coinId, coinId),
+ gte(priceHistory.timestamp, twentyFourHoursAgo)
+ ))
+ .orderBy(priceHistory.timestamp)
+ .limit(1);
+
+ // Calculate 24h change
+ let change24h = 0;
+ if (priceData) {
+ const priceFrom24hAgo = Number(priceData.price);
+ if (priceFrom24hAgo > 0) {
+ change24h = ((currentPrice - priceFrom24hAgo) / priceFrom24hAgo) * 100;
+ }
+ }
+
+ // Calculate 24h volume
+ const volumeData = await db
+ .select({ totalBaseCurrencyAmount: transaction.totalBaseCurrencyAmount })
+ .from(transaction)
+ .where(and(
+ eq(transaction.coinId, coinId),
+ gte(transaction.timestamp, twentyFourHoursAgo)
+ ));
+
+ const volume24h = volumeData.reduce((sum, tx) => sum + Number(tx.totalBaseCurrencyAmount), 0);
+
+ return { change24h: Number(change24h.toFixed(4)), volume24h: Number(volume24h.toFixed(4)) };
+}
export async function POST({ params, request }) {
const session = await auth.api.getSession({
@@ -40,20 +76,7 @@ export async function POST({ params, request }) {
}
return await db.transaction(async (tx) => {
- const [coinData] = await tx.select({
- id: coin.id,
- symbol: coin.symbol,
- name: coin.name,
- icon: coin.icon,
- currentPrice: coin.currentPrice,
- poolCoinAmount: coin.poolCoinAmount,
- poolBaseCurrencyAmount: coin.poolBaseCurrencyAmount,
- circulatingSupply: coin.circulatingSupply,
- isListed: coin.isListed,
- creatorId: coin.creatorId,
- tradingUnlocksAt: coin.tradingUnlocksAt,
- isLocked: coin.isLocked
- }).from(coin).where(eq(coin.symbol, normalizedSymbol)).for('update').limit(1);
+ const [coinData] = await tx.select().from(coin).where(eq(coin.symbol, normalizedSymbol)).for('update').limit(1);
if (!coinData) {
throw error(404, 'Coin not found');
@@ -63,18 +86,6 @@ export async function POST({ params, request }) {
throw error(400, 'This coin is delisted and cannot be traded');
}
- if (coinData.isLocked && coinData.tradingUnlocksAt && userId !== coinData.creatorId) {
- const unlockTime = new Date(coinData.tradingUnlocksAt);
- if (new Date() < unlockTime) {
- const remainingSeconds = Math.ceil((unlockTime.getTime() - Date.now()) / 1000);
- throw error(400, `Trading is locked. Unlocks in ${remainingSeconds} seconds.`);
- }
-
- await tx.update(coin)
- .set({ isLocked: false })
- .where(eq(coin.id, coinData.id));
- }
-
const [userData] = await tx.select({
baseCurrencyBalance: user.baseCurrencyBalance,
username: user.username,
@@ -243,21 +254,24 @@ export async function POST({ params, request }) {
}
// Allow more aggressive selling for rug pull simulation - prevent only mathematical breakdown
- const maxSellable = Math.floor(Number(coinData.poolCoinAmount) * 0.995);
+ const maxSellable = Math.floor(poolCoinAmount * 0.995);
if (amount > maxSellable) {
throw error(400, `Cannot sell more than 99.5% of pool tokens. Max sellable: ${maxSellable} tokens`);
}
- const sellResult = await executeSellTrade(tx, coinData, userId, amount);
+ const k = poolCoinAmount * poolBaseCurrencyAmount;
+ const newPoolCoin = poolCoinAmount + amount;
+ const newPoolBaseCurrency = k / newPoolCoin;
+ const baseCurrencyReceived = poolBaseCurrencyAmount - newPoolBaseCurrency;
- if (!sellResult.success) {
- throw error(400, 'Trade failed - insufficient liquidity or invalid parameters');
+ totalCost = baseCurrencyReceived;
+ newPrice = newPoolBaseCurrency / newPoolCoin;
+ priceImpact = ((newPrice - currentPrice) / currentPrice) * 100;
+
+ if (newPoolBaseCurrency < 10) {
+ throw error(400, `Trade would drain pool below minimum liquidity (*10 BUSS). Try selling fewer tokens.`);
}
- totalCost = sellResult.baseCurrencyReceived ?? 0;
- newPrice = sellResult.newPrice;
- priceImpact = sellResult.priceImpact;
-
if (totalCost <= 0) {
throw error(400, 'Trade amount results in zero base currency received');
}
@@ -288,15 +302,71 @@ export async function POST({ params, request }) {
));
}
- const metrics = sellResult.metrics || await calculate24hMetrics(coinData.id, newPrice);
+ await tx.insert(transaction).values({
+ userId,
+ coinId: coinData.id,
+ type: 'SELL',
+ quantity: amount.toString(),
+ pricePerCoin: (totalCost / amount).toString(),
+ totalBaseCurrencyAmount: totalCost.toString()
+ });
+
+ await tx.insert(priceHistory).values({
+ coinId: coinData.id,
+ price: newPrice.toString()
+ });
+
+ const metrics = await calculate24hMetrics(coinData.id, newPrice);
+
+ await tx.update(coin)
+ .set({
+ currentPrice: newPrice.toString(),
+ marketCap: (Number(coinData.circulatingSupply) * newPrice).toString(),
+ poolCoinAmount: newPoolCoin.toString(),
+ poolBaseCurrencyAmount: newPoolBaseCurrency.toString(),
+ change24h: metrics.change24h.toString(),
+ volume24h: metrics.volume24h.toString(),
+ updatedAt: new Date()
+ })
+ .where(eq(coin.id, coinData.id));
+
+ const isRugPull = priceImpact < -20 && totalCost > 1000;
+
+ // Send rug pull notifications to affected users
+ if (isRugPull) {
+ (async () => {
+ const affectedUsers = await db
+ .select({
+ userId: userPortfolio.userId,
+ quantity: userPortfolio.quantity
+ })
+ .from(userPortfolio)
+ .where(eq(userPortfolio.coinId, coinData.id));
+
+ for (const holder of affectedUsers) {
+ if (holder.userId === userId) continue;
+
+ const holdingValue = Number(holder.quantity) * newPrice;
+ if (holdingValue > 10) {
+ const lossAmount = Number(holder.quantity) * (currentPrice - newPrice);
+ await createNotification(
+ holder.userId.toString(),
+ 'RUG_PULL',
+ 'Coin rugpulled!',
+ `A coin you owned, ${coinData.name} (*${normalizedSymbol}), crashed ${Math.abs(priceImpact).toFixed(1)}%!`,
+ );
+ }
+ }
+ })();
+ }
const priceUpdateData = {
currentPrice: newPrice,
marketCap: Number(coinData.circulatingSupply) * newPrice,
change24h: metrics.change24h,
volume24h: metrics.volume24h,
- poolCoinAmount: sellResult.newPoolCoin,
- poolBaseCurrencyAmount: sellResult.newPoolBaseCurrency
+ poolCoinAmount: newPoolCoin,
+ poolBaseCurrencyAmount: newPoolBaseCurrency
};
const tradeData = {
@@ -338,4 +408,4 @@ export async function POST({ params, request }) {
});
}
});
-}
\ No newline at end of file
+}
diff --git a/website/src/routes/api/coin/create/+server.ts b/website/src/routes/api/coin/create/+server.ts
index 02ac0aa..c89bee3 100644
--- a/website/src/routes/api/coin/create/+server.ts
+++ b/website/src/routes/api/coin/create/+server.ts
@@ -114,9 +114,7 @@ export async function POST({ request }) {
currentPrice: STARTING_PRICE.toString(),
marketCap: (FIXED_SUPPLY * STARTING_PRICE).toString(),
poolCoinAmount: FIXED_SUPPLY.toString(),
- poolBaseCurrencyAmount: INITIAL_LIQUIDITY.toString(),
- tradingUnlocksAt: new Date(Date.now() + 60 * 1000), // 1 minute from now
- isLocked: true
+ poolBaseCurrencyAmount: INITIAL_LIQUIDITY.toString()
}).returning();
createdCoin = newCoin;
diff --git a/website/src/routes/api/notifications/+server.ts b/website/src/routes/api/notifications/+server.ts
index 08a6443..1438ef1 100644
--- a/website/src/routes/api/notifications/+server.ts
+++ b/website/src/routes/api/notifications/+server.ts
@@ -25,7 +25,6 @@ export const GET: RequestHandler = async ({ url, request }) => {
type: notifications.type,
title: notifications.title,
message: notifications.message,
- link: notifications.link,
isRead: notifications.isRead,
createdAt: notifications.createdAt,
})
@@ -55,22 +54,24 @@ export const PATCH: RequestHandler = async ({ request }) => {
if (!session?.user) throw error(401, 'Not authenticated');
const userId = Number(session.user.id);
- const { markAsRead } = await request.json();
+ const { ids, markAsRead } = await request.json();
- if (typeof markAsRead !== 'boolean') {
+ if (!Array.isArray(ids) || typeof markAsRead !== 'boolean') {
throw error(400, 'Invalid request body');
}
try {
- if (markAsRead) {
- await db.update(notifications)
- .set({ isRead: true })
- .where(eq(notifications.userId, userId));
- }
+ await db
+ .update(notifications)
+ .set({ isRead: markAsRead })
+ .where(and(
+ eq(notifications.userId, userId),
+ inArray(notifications.id, ids)
+ ));
return json({ success: true });
} catch (e) {
console.error('Failed to update notifications:', e);
throw error(500, 'Failed to update notifications');
}
-};
\ No newline at end of file
+};
diff --git a/website/src/routes/api/prestige/+server.ts b/website/src/routes/api/prestige/+server.ts
index e60bb73..4564278 100644
--- a/website/src/routes/api/prestige/+server.ts
+++ b/website/src/routes/api/prestige/+server.ts
@@ -5,7 +5,6 @@ import { user, userPortfolio, transaction, notifications, coin } from '$lib/serv
import { eq, sql } from 'drizzle-orm';
import type { RequestHandler } from './$types';
import { formatValue, getPrestigeCost, getPrestigeName } from '$lib/utils';
-import { executeSellTrade } from '$lib/server/amm';
export const POST: RequestHandler = async ({ request, locals }) => {
const session = await auth.api.getSession({ headers: request.headers });
@@ -45,10 +44,7 @@ export const POST: RequestHandler = async ({ request, locals }) => {
coinId: userPortfolio.coinId,
quantity: userPortfolio.quantity,
currentPrice: coin.currentPrice,
- symbol: coin.symbol,
- poolCoinAmount: coin.poolCoinAmount,
- poolBaseCurrencyAmount: coin.poolBaseCurrencyAmount,
- circulatingSupply: coin.circulatingSupply
+ symbol: coin.symbol
})
.from(userPortfolio)
.leftJoin(coin, eq(userPortfolio.coinId, coin.id))
@@ -62,37 +58,18 @@ export const POST: RequestHandler = async ({ request, locals }) => {
for (const holding of holdings) {
const quantity = Number(holding.quantity);
- const currentPrice = Number(holding.currentPrice);
+ const price = Number(holding.currentPrice);
+ const saleValue = quantity * price;
+ totalSaleValue += saleValue;
- if (Number(holding.poolCoinAmount) <= 0 || Number(holding.poolBaseCurrencyAmount) <= 0) {
- const fallbackValue = quantity * currentPrice;
- totalSaleValue += fallbackValue;
-
- await tx.insert(transaction).values({
- userId,
- coinId: holding.coinId!,
- type: 'SELL',
- quantity: holding.quantity,
- pricePerCoin: holding.currentPrice || '0',
- totalBaseCurrencyAmount: fallbackValue.toString(),
- timestamp: new Date()
- });
- continue;
- }
-
- const sellResult = await executeSellTrade(tx, {
- id: holding.coinId,
- poolCoinAmount: holding.poolCoinAmount,
- poolBaseCurrencyAmount: holding.poolBaseCurrencyAmount,
- currentPrice: holding.currentPrice,
- circulatingSupply: holding.circulatingSupply
- }, userId, quantity);
-
- if (sellResult.success && sellResult.baseCurrencyReceived) {
- totalSaleValue += sellResult.baseCurrencyReceived;
- } else {
- totalSaleValue += sellResult.fallbackValue || (quantity * currentPrice);
- }
+ await tx.insert(transaction).values({
+ coinId: holding.coinId!,
+ type: 'SELL',
+ quantity: holding.quantity,
+ pricePerCoin: holding.currentPrice || '0',
+ totalBaseCurrencyAmount: saleValue.toString(),
+ timestamp: new Date()
+ });
}
await tx
@@ -117,7 +94,6 @@ export const POST: RequestHandler = async ({ request, locals }) => {
type: 'SYSTEM',
title: `${prestigeName} Achieved!`,
message: `Congratulations! You have successfully reached ${prestigeName}. Your portfolio has been reset, daily reward cooldown has been cleared, and you can now start fresh with your new prestige badge and enhanced daily rewards.`,
- link: `/user/${userId}`
});
return json({
diff --git a/website/src/routes/api/rewards/claim/+server.ts b/website/src/routes/api/rewards/claim/+server.ts
index 1b34447..58994a1 100644
--- a/website/src/routes/api/rewards/claim/+server.ts
+++ b/website/src/routes/api/rewards/claim/+server.ts
@@ -13,32 +13,10 @@ const REWARD_TIERS = [
1500, // Day 2
1800, // Day 3
2100, // Day 4
- 2500, // Day 5
- 3000, // Day 6
- 3500, // Day 7
- 4000, // Day 8
- 4200, // Day 9
- 4400, // Day 10
- 4600, // Day 11
- 4800, // Day 12
- 5000, // Day 13
- 5200, // Day 14
- 5400, // Day 15
- 5600, // Day 16
- 5800, // Day 17
- 6000, // Day 18
- 6200, // Day 19
- 6400, // Day 20
- 6600, // Day 21
- 6800, // Day 22
- 7000, // Day 23
- 7200, // Day 24
- 7400, // Day 25
- 7600, // Day 26
- 7800, // Day 27
- 8000, // Day 28
- 8200, // Day 29
- 8500 // Day 30+
+ 2500, // Day 5
+ 3000, // Day 6
+ 3500, // Day 7
+ 4000, // Day 8+
];
const PRESTIGE_MULTIPLIERS = {
diff --git a/website/src/routes/api/transfer/+server.ts b/website/src/routes/api/transfer/+server.ts
index 7c1f225..726d345 100644
--- a/website/src/routes/api/transfer/+server.ts
+++ b/website/src/routes/api/transfer/+server.ts
@@ -131,7 +131,6 @@ export const POST: RequestHandler = async ({ request }) => {
'TRANSFER',
'Money received!',
`You received ${formatValue(amount)} from @${senderData.username}`,
- `/user/${senderData.id}`
);
})();
@@ -265,7 +264,6 @@ export const POST: RequestHandler = async ({ request }) => {
'TRANSFER',
'Coins received!',
`You received ${amount.toFixed(6)} *${coinData.symbol} from @${senderData.username}`,
- `/coin/${normalizedSymbol}`
);
})();
diff --git a/website/src/routes/coin/[coinSymbol]/+page.svelte b/website/src/routes/coin/[coinSymbol]/+page.svelte
index bcdb565..980159f 100644
--- a/website/src/routes/coin/[coinSymbol]/+page.svelte
+++ b/website/src/routes/coin/[coinSymbol]/+page.svelte
@@ -43,8 +43,6 @@
let shouldSignIn = $state(false);
let previousCoinSymbol = $state(null);
- let countdown = $state(null);
- let countdownInterval = $state(null);
const timeframeOptions = [
{ value: '1m', label: '1 minute' },
@@ -91,41 +89,6 @@
}
});
- $effect(() => {
- if (coin?.isLocked && coin?.tradingUnlocksAt) {
- const unlockTime = new Date(coin.tradingUnlocksAt).getTime();
-
- const updateCountdown = () => {
- const now = Date.now();
- const remaining = Math.max(0, Math.ceil((unlockTime - now) / 1000));
- countdown = remaining;
-
- if (remaining === 0 && countdownInterval) {
- clearInterval(countdownInterval);
- countdownInterval = null;
- if (coin) {
- coin = { ...coin, isLocked: false };
- }
- }
- };
-
- updateCountdown();
- countdownInterval = setInterval(updateCountdown, 1000);
- } else {
- countdown = null;
- if (countdownInterval) {
- clearInterval(countdownInterval);
- countdownInterval = null;
- }
- }
-
- return () => {
- if (countdownInterval) {
- clearInterval(countdownInterval);
- }
- };
- });
-
async function loadCoinData() {
try {
loading = true;
@@ -393,17 +356,6 @@
};
});
}
-
- function formatCountdown(seconds: number): string {
- const mins = Math.floor(seconds / 60);
- const secs = seconds % 60;
- return `${mins}:${secs.toString().padStart(2, '0')}`;
- }
-
- let isCreator = $derived(coin && $USER_DATA && coin.creatorId === Number($USER_DATA.id));
- let isTradingLocked = $derived(coin?.isLocked && countdown !== null && countdown > 0);
- let canTrade = $derived(!isTradingLocked || isCreator);
-
{/if}
- {#if isTradingLocked}
-
- 🔒 LOCKED {countdown !== null ? formatCountdown(countdown) : ''}
-
- {/if}
{#if !coin.isListed}
Delisted
{/if}
@@ -582,15 +529,6 @@
{coin.symbol}
{/if}
- {#if isTradingLocked}
-
- {#if isCreator}
- 🔒 Creator-only period: {countdown !== null ? formatCountdown(countdown) : ''} remaining
- {:else}
- 🔒 Trading unlocks in: {countdown !== null ? formatCountdown(countdown) : ''}
- {/if}
-
- {/if}
{#if $USER_DATA}
@@ -600,7 +538,7 @@
variant="default"
size="lg"
onclick={() => (buyModalOpen = true)}
- disabled={!coin.isListed || !canTrade}
+ disabled={!coin.isListed}
>
Buy {coin.symbol}
@@ -610,7 +548,7 @@
variant="outline"
size="lg"
onclick={() => (sellModalOpen = true)}
- disabled={!coin.isListed || userHolding <= 0 || !canTrade}
+ disabled={!coin.isListed || userHolding <= 0}
>
Sell {coin.symbol}
diff --git a/website/src/routes/coin/create/+page.svelte b/website/src/routes/coin/create/+page.svelte
index 38fbe9b..f8c463f 100644
--- a/website/src/routes/coin/create/+page.svelte
+++ b/website/src/routes/coin/create/+page.svelte
@@ -238,9 +238,9 @@
• Starting Price: $0.000001 per token
• You receive 100% of the supply
• Initial Market Cap: $1,000
- • Trading Lock: 1 minute creator-only period
- After creation, you'll have 1 minute of exclusive trading time before others can trade. This allows you to purchase your initial supply.
+ These settings ensure a fair start for all traders. The price will increase
+ naturally as people buy tokens.
diff --git a/website/src/routes/gambling/+page.svelte b/website/src/routes/gambling/+page.svelte
index 1ad6f35..996aeb4 100644
--- a/website/src/routes/gambling/+page.svelte
+++ b/website/src/routes/gambling/+page.svelte
@@ -40,8 +40,8 @@
diff --git a/website/src/routes/hopium/[id]/+page.svelte b/website/src/routes/hopium/[id]/+page.svelte
index ff92890..2e54c3a 100644
--- a/website/src/routes/hopium/[id]/+page.svelte
+++ b/website/src/routes/hopium/[id]/+page.svelte
@@ -224,7 +224,7 @@