New Token Created: {data.name} ({data.symbol})

\n Mint Address:{\" \"}\n \n {data.mint}\n \n

\n Creator: {data.traderPublicKey}\n

\n Initial Buy: {data.initialBuy.toLocaleString()} tokens\n

\n SOL Amount: {data.solAmount} SOL\n

\n Tokens in Bonding Curve: {data.vTokensInBondingCurve.toLocaleString()}\n

\n SOL in Bonding Curve: {data.vSolInBondingCurve.toFixed(4)} SOL\n

\n );\n}\n\nfunction SubscriptionControl({ type, isConnected, isSubscribed, onSubscribe, onUnsubscribe }) {\n return (\n

{type}

\n \n \n

\n Status: {isSubscribed ? \"Subscribed\" : \"Not Subscribed\"}\n

\n );\n}\n\nfunction App() {\n const [messages, setMessages] = useState({\n newToken: [],\n });\n const [socket, setSocket] = useState(null);\n const [isConnected, setIsConnected] = useState(false);\n const [subscriptions, setSubscriptions] = useState({\n subscribeNewToken: false,\n });\n const [error, setError] = useState(null);\n\n const connectWebSocket = useCallback(() => {\n const ws = new WebSocket(\"wss://pumpportal.fun/api/data\");\n\n ws.onopen = () => {\n console.log(\"WebSocket connected to PumpPortal\");\n setSocket(ws);\n setIsConnected(true);\n setError(null);\n };\n\n ws.onmessage = (event) => {\n const message = JSON.parse(event.data);\n console.log(\"Received message:\", message);\n setMessages((prevMessages) => {\n if (message.txType === \"create\") {\n return { ...prevMessages, newToken: [message, ...prevMessages.newToken] };\n }\n return prevMessages;\n });\n };\n\n ws.onclose = () => {\n console.log(\"WebSocket disconnected from PumpPortal\");\n setIsConnected(false);\n setSubscriptions({\n subscribeNewToken: false,\n });\n setTimeout(connectWebSocket, 5000); // Attempt to reconnect after 5 seconds\n };\n\n ws.onerror = (error) => {\n console.error(\"WebSocket error:\", error);\n setError(\"WebSocket error occurred. Please try again.\");\n };\n }, []);\n\n useEffect(() => {\n connectWebSocket();\n return () => {\n if (socket) {\n socket.close();\n }\n };\n }, [connectWebSocket]);\n\n const handleSubscription = useCallback((type, subscribe) => {\n if (socket && socket.readyState === WebSocket.OPEN) {\n const method = subscribe ? type : type.replace(\"subscribe\", \"unsubscribe\");\n console.log(`Sending subscription request: ${method}`);\n socket.send(JSON.stringify({ method }));\n setSubscriptions(prev => ({ ...prev, [type]: subscribe }));\n console.log(`Subscription status updated: ${type} - ${subscribe}`);\n } else {\n setError(\"WebSocket is not connected. Please wait and try again.\");\n }\n }, [socket]);\n\n return (\n

PumpPortal Data Stream

\n handleSubscription(\"subscribeNewToken\", true)}\n onUnsubscribe={() => handleSubscription(\"subscribeNewToken\", false)}\n />\n

\n {error &&

{error}

}\n

Status: {isConnected ? \"Connected\" : \"Disconnected\"}

New Tokens

\n {messages.newToken.filter((_, index) => index % 3 === 0).map((msg, index) => (\n \n ))}\n

\n {messages.newToken.filter((_, index) => index % 3 === 1).map((msg, index) => (\n \n ))}\n

\n {messages.newToken.filter((_, index) => index % 3 === 2).map((msg, index) => (\n \n ))}\n

\n \n View source: Val Town\n \n

\n );\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\n\nif (typeof document !== \"undefined\") {\n client();\n}\n\nexport default async function server(req: Request): Promise {\n return new Response(\n `\n \n \n \n \n \n PumpPortal Data Stream\n \n \n \n

\n \n \n \n \n `,\n {\n headers: { \"Content-Type\": \"text/html\" },\n },\n );\n}\n\nconst css = `\n body {\n font-family: 'Fira Code', monospace;\n max-width: 1200px;\n margin: 0 auto;\n padding: 20px;\n background-color: #282a36;\n color: #f8f8f2;\n }\n h1, h2 {\n color: #ff79c6;\n text-align: center;\n }\n .subscription-controls {\n display: flex;\n justify-content: center;\n margin-bottom: 20px;\n }\n .subscription-control {\n text-align: center;\n }\n button {\n padding: 8px 15px;\n margin: 0 5px;\n background-color: #6272a4;\n color: #f8f8f2;\n border: none;\n border-radius: 4px;\n cursor: pointer;\n transition: background-color 0.3s;\n }\n button:hover:not(:disabled) {\n background-color: #44475a;\n }\n button:disabled {\n background-color: #44475a;\n cursor: not-allowed;\n opacity: 0.6;\n }\n .subscription-status {\n margin-top: 5px;\n font-weight: bold;\n color: #8be9fd;\n }\n .new-tokens-container {\n width: 100%;\n }\n .new-tokens-columns {\n display: flex;\n justify-content: space-between;\n }\n .column {\n flex: 1;\n margin: 0 10px;\n }\n .new-token {\n background-color: #44475a;\n padding: 15px;\n border-radius: 4px;\n box-shadow: 0 2px 4px rgba(0,0,0,0.3);\n margin-bottom: 10px;\n }\n .new-token h3 {\n margin-top: 0;\n color: #50fa7b;\n }\n .token-details {\n display: grid;\n grid-template-columns: 1fr;\n gap: 5px;\n }\n .token-details p {\n margin: 5px 0;\n font-size: 0.9em;\n }\n .token-details a {\n color: #8be9fd;\n text-decoration: none;\n word-break: break-all;\n }\n .token-details a:hover {\n text-decoration: underline;\n }\n pre {\n white-space: pre-wrap;\n word-wrap: break-word;\n font-size: 0.8em;\n background-color: #282a36;\n padding: 10px;\n border-radius: 4px;\n }\n .error {\n color: #ff5555;\n font-weight: bold;\n text-align: center;\n }\n .status {\n text-align: center;\n font-weight: bold;\n color: #bd93f9;\n }\n ::-webkit-scrollbar {\n width: 10px;\n }\n ::-webkit-scrollbar-track {\n background: #44475a;\n }\n ::-webkit-scrollbar-thumb {\n background: #6272a4;\n border-radius: 5px;\n }\n ::-webkit-scrollbar-thumb:hover {\n background: #8be9fd;\n }\n`;","deleted","label",[99],"permalink","https://www.val.town/x/gigmx/subtleAmaranthWasp/code/main.tsx","extension","actionData","errors"]