-
-
Rugplay
+
+
CoinStorge
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 1f5be80..1e8c5af 100644
--- a/website/src/routes/api/coin/[coinSymbol]/+server.ts
+++ b/website/src/routes/api/coin/[coinSymbol]/+server.ts
@@ -134,7 +134,9 @@ export async function GET({ params, url }) {
creatorName: user.name,
creatorUsername: user.username,
creatorBio: user.bio,
- creatorImage: user.image
+ creatorImage: user.image,
+ tradingUnlocksAt: coin.tradingUnlocksAt,
+ isLocked: coin.isLocked
})
.from(coin)
.leftJoin(user, eq(coin.creatorId, user.id))
@@ -185,7 +187,9 @@ export async function GET({ params, url }) {
poolCoinAmount: Number(coinData.poolCoinAmount),
poolBaseCurrencyAmount: Number(coinData.poolBaseCurrencyAmount),
circulatingSupply: Number(coinData.circulatingSupply),
- initialSupply: Number(coinData.initialSupply)
+ initialSupply: Number(coinData.initialSupply),
+ tradingUnlocksAt: coinData.tradingUnlocksAt,
+ isLocked: coinData.isLocked
},
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 821e93e..a51b140 100644
--- a/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts
+++ b/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts
@@ -5,43 +5,7 @@ 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';
-
-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)) };
-}
+import { calculate24hMetrics, executeSellTrade } from '$lib/server/amm';
export async function POST({ params, request }) {
const session = await auth.api.getSession({
@@ -76,7 +40,20 @@ export async function POST({ params, request }) {
}
return await db.transaction(async (tx) => {
- const [coinData] = await tx.select().from(coin).where(eq(coin.symbol, normalizedSymbol)).for('update').limit(1);
+ 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);
if (!coinData) {
throw error(404, 'Coin not found');
@@ -86,6 +63,18 @@ 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,
@@ -254,24 +243,21 @@ export async function POST({ params, request }) {
}
// Allow more aggressive selling for rug pull simulation - prevent only mathematical breakdown
- const maxSellable = Math.floor(poolCoinAmount * 0.995);
+ const maxSellable = Math.floor(Number(coinData.poolCoinAmount) * 0.995);
if (amount > maxSellable) {
throw error(400, `Cannot sell more than 99.5% of pool tokens. Max sellable: ${maxSellable} tokens`);
}
- const k = poolCoinAmount * poolBaseCurrencyAmount;
- const newPoolCoin = poolCoinAmount + amount;
- const newPoolBaseCurrency = k / newPoolCoin;
- const baseCurrencyReceived = poolBaseCurrencyAmount - newPoolBaseCurrency;
+ const sellResult = await executeSellTrade(tx, coinData, userId, amount);
- 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.`);
+ if (!sellResult.success) {
+ throw error(400, 'Trade failed - insufficient liquidity or invalid parameters');
}
+ totalCost = sellResult.baseCurrencyReceived ?? 0;
+ newPrice = sellResult.newPrice;
+ priceImpact = sellResult.priceImpact;
+
if (totalCost <= 0) {
throw error(400, 'Trade amount results in zero base currency received');
}
@@ -302,71 +288,15 @@ export async function POST({ params, request }) {
));
}
- 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 metrics = sellResult.metrics || await calculate24hMetrics(coinData.id, newPrice);
const priceUpdateData = {
currentPrice: newPrice,
marketCap: Number(coinData.circulatingSupply) * newPrice,
change24h: metrics.change24h,
volume24h: metrics.volume24h,
- poolCoinAmount: newPoolCoin,
- poolBaseCurrencyAmount: newPoolBaseCurrency
+ poolCoinAmount: sellResult.newPoolCoin,
+ poolBaseCurrencyAmount: sellResult.newPoolBaseCurrency
};
const tradeData = {
@@ -408,4 +338,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 c89bee3..02ac0aa 100644
--- a/website/src/routes/api/coin/create/+server.ts
+++ b/website/src/routes/api/coin/create/+server.ts
@@ -114,7 +114,9 @@ export async function POST({ request }) {
currentPrice: STARTING_PRICE.toString(),
marketCap: (FIXED_SUPPLY * STARTING_PRICE).toString(),
poolCoinAmount: FIXED_SUPPLY.toString(),
- poolBaseCurrencyAmount: INITIAL_LIQUIDITY.toString()
+ poolBaseCurrencyAmount: INITIAL_LIQUIDITY.toString(),
+ tradingUnlocksAt: new Date(Date.now() + 60 * 1000), // 1 minute from now
+ isLocked: true
}).returning();
createdCoin = newCoin;
diff --git a/website/src/routes/api/notifications/+server.ts b/website/src/routes/api/notifications/+server.ts
index 1438ef1..08a6443 100644
--- a/website/src/routes/api/notifications/+server.ts
+++ b/website/src/routes/api/notifications/+server.ts
@@ -25,6 +25,7 @@ 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,
})
@@ -54,24 +55,22 @@ export const PATCH: RequestHandler = async ({ request }) => {
if (!session?.user) throw error(401, 'Not authenticated');
const userId = Number(session.user.id);
- const { ids, markAsRead } = await request.json();
+ const { markAsRead } = await request.json();
- if (!Array.isArray(ids) || typeof markAsRead !== 'boolean') {
+ if (typeof markAsRead !== 'boolean') {
throw error(400, 'Invalid request body');
}
try {
- await db
- .update(notifications)
- .set({ isRead: markAsRead })
- .where(and(
- eq(notifications.userId, userId),
- inArray(notifications.id, ids)
- ));
+ if (markAsRead) {
+ await db.update(notifications)
+ .set({ isRead: true })
+ .where(eq(notifications.userId, userId));
+ }
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 4564278..e60bb73 100644
--- a/website/src/routes/api/prestige/+server.ts
+++ b/website/src/routes/api/prestige/+server.ts
@@ -5,6 +5,7 @@ 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 });
@@ -44,7 +45,10 @@ export const POST: RequestHandler = async ({ request, locals }) => {
coinId: userPortfolio.coinId,
quantity: userPortfolio.quantity,
currentPrice: coin.currentPrice,
- symbol: coin.symbol
+ symbol: coin.symbol,
+ poolCoinAmount: coin.poolCoinAmount,
+ poolBaseCurrencyAmount: coin.poolBaseCurrencyAmount,
+ circulatingSupply: coin.circulatingSupply
})
.from(userPortfolio)
.leftJoin(coin, eq(userPortfolio.coinId, coin.id))
@@ -58,18 +62,37 @@ export const POST: RequestHandler = async ({ request, locals }) => {
for (const holding of holdings) {
const quantity = Number(holding.quantity);
- const price = Number(holding.currentPrice);
- const saleValue = quantity * price;
- totalSaleValue += saleValue;
+ const currentPrice = Number(holding.currentPrice);
- await tx.insert(transaction).values({
- coinId: holding.coinId!,
- type: 'SELL',
- quantity: holding.quantity,
- pricePerCoin: holding.currentPrice || '0',
- totalBaseCurrencyAmount: saleValue.toString(),
- timestamp: new Date()
- });
+ 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
@@ -94,6 +117,7 @@ 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 58994a1..1b34447 100644
--- a/website/src/routes/api/rewards/claim/+server.ts
+++ b/website/src/routes/api/rewards/claim/+server.ts
@@ -13,10 +13,32 @@ const REWARD_TIERS = [
1500, // Day 2
1800, // Day 3
2100, // Day 4
- 2500, // Day 5
- 3000, // Day 6
- 3500, // Day 7
- 4000, // Day 8+
+ 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+
];
const PRESTIGE_MULTIPLIERS = {
diff --git a/website/src/routes/api/transfer/+server.ts b/website/src/routes/api/transfer/+server.ts
index 726d345..7c1f225 100644
--- a/website/src/routes/api/transfer/+server.ts
+++ b/website/src/routes/api/transfer/+server.ts
@@ -131,6 +131,7 @@ export const POST: RequestHandler = async ({ request }) => {
'TRANSFER',
'Money received!',
`You received ${formatValue(amount)} from @${senderData.username}`,
+ `/user/${senderData.id}`
);
})();
@@ -264,6 +265,7 @@ 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 980159f..bcdb565 100644
--- a/website/src/routes/coin/[coinSymbol]/+page.svelte
+++ b/website/src/routes/coin/[coinSymbol]/+page.svelte
@@ -43,6 +43,8 @@
let shouldSignIn = $state(false);
let previousCoinSymbol = $state(null);
+ let countdown = $state(null);
+ let countdownInterval = $state(null);
const timeframeOptions = [
{ value: '1m', label: '1 minute' },
@@ -89,6 +91,41 @@
}
});
+ $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;
@@ -356,6 +393,17 @@
};
});
}
+
+ 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}
@@ -529,6 +582,15 @@
{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}
@@ -538,7 +600,7 @@
variant="default"
size="lg"
onclick={() => (buyModalOpen = true)}
- disabled={!coin.isListed}
+ disabled={!coin.isListed || !canTrade}
>
Buy {coin.symbol}
@@ -548,7 +610,7 @@
variant="outline"
size="lg"
onclick={() => (sellModalOpen = true)}
- disabled={!coin.isListed || userHolding <= 0}
+ disabled={!coin.isListed || userHolding <= 0 || !canTrade}
>
Sell {coin.symbol}
diff --git a/website/src/routes/coin/create/+page.svelte b/website/src/routes/coin/create/+page.svelte
index f8c463f..38fbe9b 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
- These settings ensure a fair start for all traders. The price will increase
- naturally as people buy tokens.
+ After creation, you'll have 1 minute of exclusive trading time before others can trade. This allows you to purchase your initial supply.
diff --git a/website/src/routes/gambling/+page.svelte b/website/src/routes/gambling/+page.svelte
index 996aeb4..1ad6f35 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 2e54c3a..ff92890 100644
--- a/website/src/routes/hopium/[id]/+page.svelte
+++ b/website/src/routes/hopium/[id]/+page.svelte
@@ -224,7 +224,7 @@