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 881fa1f..666d265 100644 --- a/website/src/lib/server/db/schema.ts +++ b/website/src/lib/server/db/schema.ts @@ -83,8 +83,6 @@ 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(), @@ -111,8 +109,6 @@ 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 e73b2ce..3fb508c 100644 --- a/website/src/lib/types/market.ts +++ b/website/src/lib/types/market.ts @@ -8,8 +8,6 @@ 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 1466dd9..818bca8 100644 --- a/website/src/routes/api/coin/[coinSymbol]/+server.ts +++ b/website/src/routes/api/coin/[coinSymbol]/+server.ts @@ -130,8 +130,6 @@ 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, @@ -186,9 +184,7 @@ export async function GET({ params, url }) { poolCoinAmount: Number(coinData.poolCoinAmount), poolBaseCurrencyAmount: Number(coinData.poolBaseCurrencyAmount), circulatingSupply: Number(coinData.circulatingSupply), - initialSupply: Number(coinData.initialSupply), - pumpFeeRate: Number(coinData.pumpFeeRate), - burnRate: Number(coinData.burnRate) + 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 710bbcf..0696cea 100644 --- a/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts +++ b/website/src/routes/api/coin/[coinSymbol]/trade/+server.ts @@ -42,34 +42,6 @@ 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 @@ -155,13 +127,6 @@ 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(), @@ -203,25 +168,22 @@ export async function POST({ params, request }) { type: 'BUY', quantity: coinsBought.toString(), pricePerCoin: (totalCost / coinsBought).toString(), - totalBaseCurrencyAmount: totalCost.toString(), - pumpFeeApplied: autoPumpEffects.pumpFee.toString(), - tokensBurned: autoPumpEffects.tokensBurned.toString() + totalBaseCurrencyAmount: totalCost.toString() }); await tx.insert(priceHistory).values({ coinId: coinData.id, - price: finalPrice.toString() + price: newPrice.toString() }); - const metrics = await calculate24hMetrics(coinData.id, finalPrice); + const metrics = await calculate24hMetrics(coinData.id, newPrice); await tx.update(coin) .set({ - currentPrice: finalPrice.toString(), - marketCap: (autoPumpEffects.newCirculatingSupply * finalPrice).toString(), - poolCoinAmount: finalPoolCoin.toString(), - poolBaseCurrencyAmount: finalPoolBase.toString(), - circulatingSupply: autoPumpEffects.newCirculatingSupply.toString(), + 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() @@ -229,12 +191,12 @@ export async function POST({ params, request }) { .where(eq(coin.id, coinData.id)); const priceUpdateData = { - currentPrice: finalPrice, - marketCap: autoPumpEffects.newCirculatingSupply * finalPrice, + currentPrice: newPrice, + marketCap: Number(coinData.circulatingSupply) * newPrice, change24h: metrics.change24h, volume24h: metrics.volume24h, - poolCoinAmount: finalPoolCoin, - poolBaseCurrencyAmount: finalPoolBase + poolCoinAmount: newPoolCoin, + poolBaseCurrencyAmount: newPoolBaseCurrency }; const tradeData = { @@ -270,13 +232,9 @@ export async function POST({ params, request }) { type: 'BUY', coinsBought, totalCost, - newPrice: finalPrice, - priceImpact: ((finalPrice - currentPrice) / currentPrice) * 100, - newBalance: userBalance - totalCost, - autoPumpEffects: { - feeApplied: autoPumpEffects.pumpFee, - tokensBurned: autoPumpEffects.tokensBurned, - } + newPrice, + priceImpact, + newBalance: userBalance - totalCost }); } else { @@ -317,13 +275,6 @@ 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(), @@ -356,25 +307,22 @@ export async function POST({ params, request }) { type: 'SELL', quantity: amount.toString(), pricePerCoin: (totalCost / amount).toString(), - totalBaseCurrencyAmount: totalCost.toString(), - pumpFeeApplied: autoPumpEffects.pumpFee.toString(), - tokensBurned: autoPumpEffects.tokensBurned.toString() + totalBaseCurrencyAmount: totalCost.toString() }); await tx.insert(priceHistory).values({ coinId: coinData.id, - price: finalPrice.toString() + price: newPrice.toString() }); - const metrics = await calculate24hMetrics(coinData.id, finalPrice); + const metrics = await calculate24hMetrics(coinData.id, newPrice); await tx.update(coin) .set({ - currentPrice: finalPrice.toString(), - marketCap: (autoPumpEffects.newCirculatingSupply * finalPrice).toString(), - poolCoinAmount: finalPoolCoin.toString(), - poolBaseCurrencyAmount: finalPoolBase.toString(), - circulatingSupply: autoPumpEffects.newCirculatingSupply.toString(), + 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() @@ -382,12 +330,12 @@ export async function POST({ params, request }) { .where(eq(coin.id, coinData.id)); const priceUpdateData = { - currentPrice: finalPrice, - marketCap: autoPumpEffects.newCirculatingSupply * finalPrice, + currentPrice: newPrice, + marketCap: Number(coinData.circulatingSupply) * newPrice, change24h: metrics.change24h, volume24h: metrics.volume24h, - poolCoinAmount: finalPoolCoin, - poolBaseCurrencyAmount: finalPoolBase + poolCoinAmount: newPoolCoin, + poolBaseCurrencyAmount: newPoolBaseCurrency }; const tradeData = { @@ -423,13 +371,9 @@ export async function POST({ params, request }) { type: 'SELL', coinsSold: amount, totalReceived: totalCost, - newPrice: finalPrice, - priceImpact: ((finalPrice - currentPrice) / currentPrice) * 100, - newBalance: userBalance + totalCost, - autoPumpEffects: { - feeApplied: autoPumpEffects.pumpFee, - tokensBurned: autoPumpEffects.tokensBurned - } + newPrice, + priceImpact, + newBalance: userBalance + totalCost }); } });