AMM estimation - includes slippage from pool impact
diff --git a/website/src/lib/server/db/schema.ts b/website/src/lib/server/db/schema.ts index 666d265..881fa1f 100644 --- a/website/src/lib/server/db/schema.ts +++ b/website/src/lib/server/db/schema.ts @@ -83,6 +83,8 @@ export const coin = pgTable("coin", { change24h: decimal("change_24h", { precision: 30, scale: 4 }).default("0.0000"), // Percentage poolCoinAmount: decimal("pool_coin_amount", { precision: 30, scale: 8 }).notNull().default("0.00000000"), poolBaseCurrencyAmount: decimal("pool_base_currency_amount", { precision: 30, scale: 8, }).notNull().default("0.00000000"), + pumpFeeRate: decimal("pump_fee_rate", { precision: 10, scale: 8 }).notNull().default("0.00500000"), // 0.5% + burnRate: decimal("burn_rate", { precision: 10, scale: 8 }).notNull().default("0.00100000"), // 0.1% createdAt: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(), updatedAt: timestamp("updated_at", { withTimezone: true }).notNull().defaultNow(), isListed: boolean("is_listed").default(true).notNull(), @@ -109,6 +111,8 @@ export const transaction = pgTable("transaction", { quantity: decimal("quantity", { precision: 30, scale: 8 }).notNull(), pricePerCoin: decimal("price_per_coin", { precision: 20, scale: 8 }).notNull(), totalBaseCurrencyAmount: decimal("total_base_currency_amount", { precision: 30, scale: 8 }).notNull(), + pumpFeeApplied: decimal("pump_fee_applied", { precision: 30, scale: 8 }).default("0.00000000"), + tokensBurned: decimal("tokens_burned", { precision: 30, scale: 8 }).default("0.00000000"), timestamp: timestamp("timestamp", { withTimezone: true }).notNull().defaultNow(), recipientUserId: integer('recipient_user_id').references(() => user.id, { onDelete: 'set null' }), senderUserId: integer('sender_user_id').references(() => user.id, { onDelete: 'set null' }), diff --git a/website/src/lib/types/market.ts b/website/src/lib/types/market.ts index 3fb508c..e73b2ce 100644 --- a/website/src/lib/types/market.ts +++ b/website/src/lib/types/market.ts @@ -8,6 +8,8 @@ export interface CoinData { change24h: number; createdAt: string; creatorName: string | null; + pumpFeeRate?: number; + burnRate?: number; } export interface MarketFilters { diff --git a/website/src/routes/api/coin/[coinSymbol]/+server.ts b/website/src/routes/api/coin/[coinSymbol]/+server.ts index 818bca8..1466dd9 100644 --- a/website/src/routes/api/coin/[coinSymbol]/+server.ts +++ b/website/src/routes/api/coin/[coinSymbol]/+server.ts @@ -130,6 +130,8 @@ export async function GET({ params, url }) { isListed: coin.isListed, createdAt: coin.createdAt, creatorId: coin.creatorId, + pumpFeeRate: coin.pumpFeeRate, + burnRate: coin.burnRate, creatorName: user.name, creatorUsername: user.username, creatorBio: user.bio, @@ -184,7 +186,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), + pumpFeeRate: Number(coinData.pumpFeeRate), + burnRate: Number(coinData.burnRate) }, 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 0696cea..710bbcf 100644 --- a/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts +++ b/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts @@ -42,6 +42,34 @@ async function calculate24hMetrics(coinId: number, currentPrice: number) { return { change24h: Number(change24h.toFixed(4)), volume24h: Number(volume24h.toFixed(4)) }; } +function calculateAutoPumpEffects( + coinData: any, + transactionValue: number, + tokensTraded: number +) { + const pumpFeeRate = Number(coinData.pumpFeeRate); + const burnRate = Number(coinData.burnRate); + + const pumpFee = transactionValue * pumpFeeRate; + const tokensBurned = tokensTraded * burnRate; + + // Ensure we don't burn more tokens than available in pool + const maxBurnableTokens = Number(coinData.poolCoinAmount) * 0.99; // Keep 1% minimum + const actualTokensBurned = Math.min(tokensBurned, maxBurnableTokens); + + const newPoolBase = Number(coinData.poolBaseCurrencyAmount) + pumpFee; + const newPoolCoin = Number(coinData.poolCoinAmount) - actualTokensBurned; + const newCirculatingSupply = Number(coinData.circulatingSupply) - actualTokensBurned; + + return { + pumpFee, + tokensBurned: actualTokensBurned, + newPoolBase, + newPoolCoin, + newCirculatingSupply + }; +} + export async function POST({ params, request }) { const session = await auth.api.getSession({ headers: request.headers @@ -127,6 +155,13 @@ export async function POST({ params, request }) { throw error(400, 'Trade amount too small - would result in zero tokens'); } + // Apply auto-pump effects + const autoPumpEffects = calculateAutoPumpEffects(coinData, amount, coinsBought); + + const finalPoolBase = autoPumpEffects.newPoolBase; + const finalPoolCoin = autoPumpEffects.newPoolCoin; + const finalPrice = finalPoolBase / finalPoolCoin; + await tx.update(user) .set({ baseCurrencyBalance: (userBalance - totalCost).toString(), @@ -168,22 +203,25 @@ export async function POST({ params, request }) { type: 'BUY', quantity: coinsBought.toString(), pricePerCoin: (totalCost / coinsBought).toString(), - totalBaseCurrencyAmount: totalCost.toString() + totalBaseCurrencyAmount: totalCost.toString(), + pumpFeeApplied: autoPumpEffects.pumpFee.toString(), + tokensBurned: autoPumpEffects.tokensBurned.toString() }); await tx.insert(priceHistory).values({ coinId: coinData.id, - price: newPrice.toString() + price: finalPrice.toString() }); - const metrics = await calculate24hMetrics(coinData.id, newPrice); + const metrics = await calculate24hMetrics(coinData.id, finalPrice); await tx.update(coin) .set({ - currentPrice: newPrice.toString(), - marketCap: (Number(coinData.circulatingSupply) * newPrice).toString(), - poolCoinAmount: newPoolCoin.toString(), - poolBaseCurrencyAmount: newPoolBaseCurrency.toString(), + currentPrice: finalPrice.toString(), + marketCap: (autoPumpEffects.newCirculatingSupply * finalPrice).toString(), + poolCoinAmount: finalPoolCoin.toString(), + poolBaseCurrencyAmount: finalPoolBase.toString(), + circulatingSupply: autoPumpEffects.newCirculatingSupply.toString(), change24h: metrics.change24h.toString(), volume24h: metrics.volume24h.toString(), updatedAt: new Date() @@ -191,12 +229,12 @@ export async function POST({ params, request }) { .where(eq(coin.id, coinData.id)); const priceUpdateData = { - currentPrice: newPrice, - marketCap: Number(coinData.circulatingSupply) * newPrice, + currentPrice: finalPrice, + marketCap: autoPumpEffects.newCirculatingSupply * finalPrice, change24h: metrics.change24h, volume24h: metrics.volume24h, - poolCoinAmount: newPoolCoin, - poolBaseCurrencyAmount: newPoolBaseCurrency + poolCoinAmount: finalPoolCoin, + poolBaseCurrencyAmount: finalPoolBase }; const tradeData = { @@ -232,9 +270,13 @@ export async function POST({ params, request }) { type: 'BUY', coinsBought, totalCost, - newPrice, - priceImpact, - newBalance: userBalance - totalCost + newPrice: finalPrice, + priceImpact: ((finalPrice - currentPrice) / currentPrice) * 100, + newBalance: userBalance - totalCost, + autoPumpEffects: { + feeApplied: autoPumpEffects.pumpFee, + tokensBurned: autoPumpEffects.tokensBurned, + } }); } else { @@ -275,6 +317,13 @@ export async function POST({ params, request }) { throw error(400, 'Trade amount results in zero base currency received'); } + // Apply auto-pump effects + const autoPumpEffects = calculateAutoPumpEffects(coinData, totalCost, amount); + + const finalPoolBase = autoPumpEffects.newPoolBase; + const finalPoolCoin = autoPumpEffects.newPoolCoin; + const finalPrice = finalPoolBase / finalPoolCoin; + await tx.update(user) .set({ baseCurrencyBalance: (userBalance + totalCost).toString(), @@ -307,22 +356,25 @@ export async function POST({ params, request }) { type: 'SELL', quantity: amount.toString(), pricePerCoin: (totalCost / amount).toString(), - totalBaseCurrencyAmount: totalCost.toString() + totalBaseCurrencyAmount: totalCost.toString(), + pumpFeeApplied: autoPumpEffects.pumpFee.toString(), + tokensBurned: autoPumpEffects.tokensBurned.toString() }); await tx.insert(priceHistory).values({ coinId: coinData.id, - price: newPrice.toString() + price: finalPrice.toString() }); - const metrics = await calculate24hMetrics(coinData.id, newPrice); + const metrics = await calculate24hMetrics(coinData.id, finalPrice); await tx.update(coin) .set({ - currentPrice: newPrice.toString(), - marketCap: (Number(coinData.circulatingSupply) * newPrice).toString(), - poolCoinAmount: newPoolCoin.toString(), - poolBaseCurrencyAmount: newPoolBaseCurrency.toString(), + currentPrice: finalPrice.toString(), + marketCap: (autoPumpEffects.newCirculatingSupply * finalPrice).toString(), + poolCoinAmount: finalPoolCoin.toString(), + poolBaseCurrencyAmount: finalPoolBase.toString(), + circulatingSupply: autoPumpEffects.newCirculatingSupply.toString(), change24h: metrics.change24h.toString(), volume24h: metrics.volume24h.toString(), updatedAt: new Date() @@ -330,12 +382,12 @@ export async function POST({ params, request }) { .where(eq(coin.id, coinData.id)); const priceUpdateData = { - currentPrice: newPrice, - marketCap: Number(coinData.circulatingSupply) * newPrice, + currentPrice: finalPrice, + marketCap: autoPumpEffects.newCirculatingSupply * finalPrice, change24h: metrics.change24h, volume24h: metrics.volume24h, - poolCoinAmount: newPoolCoin, - poolBaseCurrencyAmount: newPoolBaseCurrency + poolCoinAmount: finalPoolCoin, + poolBaseCurrencyAmount: finalPoolBase }; const tradeData = { @@ -371,9 +423,13 @@ export async function POST({ params, request }) { type: 'SELL', coinsSold: amount, totalReceived: totalCost, - newPrice, - priceImpact, - newBalance: userBalance + totalCost + newPrice: finalPrice, + priceImpact: ((finalPrice - currentPrice) / currentPrice) * 100, + newBalance: userBalance + totalCost, + autoPumpEffects: { + feeApplied: autoPumpEffects.pumpFee, + tokensBurned: autoPumpEffects.tokensBurned + } }); } });