[{"_1":2,"_138":-5,"_139":-5},"loaderData",{"_3":4,"_10":11},"root",{"_5":-5,"_6":7,"_8":9},"user","appId","cm7twdhs6009l11ml868xhxld","wsEndpoint","https://dev.fun","routes/p.$appId",{"_12":13,"_136":-5,"_132":-5,"_137":-5},"appDetail",{"_14":15,"_16":17,"_18":19,"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_31":32,"_33":-5,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_5":44,"_55":56,"_57":58,"_59":58,"_60":61,"_62":58,"_63":58,"_64":58,"_65":66,"_67":58,"_68":58,"_69":17,"_70":17,"_71":72,"_73":74,"_75":76,"_77":78,"_79":80,"_93":-5,"_94":17,"_95":96,"_132":32,"_133":134,"_135":25},"id","228d71414837bf2da587","isMyApp",false,"name","memofire","description","Chat through the blockchain with this wildly unconventional messaging app that turns wallet-to-incinerator memos into vibrant chat rooms! Send messages, create threads, and share media that's secretly encoded as base64, all while the app cleverly indexes incinerator transactions to build your contact network.","brief","Blockchain messaging where wallets become chat rooms and incinerator memos unlock a secret social network!","isLive",true,"isPublic","tags",[29,30],"💰","👑","cover","https://cdn.dev.fun/snapshot/228d71414837bf2da587/79113_ec0446e8.webp","cdnUrl","createdAt",["D",1749651241863],"updatedAt",["D",1749655782240],"lastCommitId",["B","79113"],"tier",1,"credits",66,{"_14":45,"_46":47,"_48":-5,"_49":47,"_50":51,"_52":-5,"_53":54},"84f2a4cc-5cc2-4ac3-8eb9-b1e78ecfebea","uniqueId","89VB5UmvopuCFmp5Mf8YPX28fGvvqn79afCgouQuPyhY","username","solanaWallet","displayName","89V...yhY","bio","avatar","/avatar.svg","commitCount",35,"forkCount",0,"likeCount","runsCount",1873,"downvoteCount","upvoteCount","upvoteRate","commentCount",2,"reportCount","visitorCount","isArchived","isRenamed","contractAddress","Dj18gmrhvy9HtUVjCqh3H91wY3fv5CTdhAhDHGuppump","code","import { useState, useEffect, useRef, createContext, useContext } from 'react';\nimport { useDevapp, UserButton, DevappProvider } from '@devfunlabs/web-sdk';\nimport { MessageSquare, Send, Image, MessageSquareMore, Users, Search, ArrowLeft, Plus, RefreshCw, Link2, AlertTriangle, Video, Copy, Camera, Play, X, Skull, Star, Share2 } from 'lucide-react';\nimport { motion, AnimatePresence } from 'framer-motion';\nimport * as web3 from '@solana/web3.js';\nimport { WalletProvider as SolanaWalletProvider, useAnchorWallet } from '@solana/wallet-adapter-react';\nimport { PhantomWalletAdapter, SolflareWalletAdapter } from '@solana/wallet-adapter-wallets';\nimport { Buffer } from 'buffer';\nimport ReactPlayer from 'react-player';\nimport { BrowserRouter, Routes, Route, useParams, useNavigate, Link, Navigate } from 'react-router-dom';\nconst WalletContext = createContext(null);\nexport default function App() {\n const wallets = [new PhantomWalletAdapter(), new SolflareWalletAdapter()];\n return \n \n \n \n \n } />\n } />\n } />\n } />\n \n \n \n \n ;\n}\nfunction CustomWalletProvider({\n children\n}) {\n const {\n userWallet,\n sendTransaction\n } = useDevapp();\n const anchorWallet = useAnchorWallet();\n const [isWalletReady, setIsWalletReady] = useState(false);\n const [manualOverride, setManualOverride] = useState(false);\n useEffect(() => {\n if (userWallet && (typeof sendTransaction === 'function' || anchorWallet)) {\n console.log(\"Wallet fully ready with transaction capability\");\n setIsWalletReady(true);\n } else if (userWallet) {\n console.log(\"Wallet detected but checking transaction capability...\");\n const timeout = setTimeout(() => {\n if (typeof sendTransaction !== 'function' && !anchorWallet) {\n console.log(\"Wallet detected but transaction capability not available after delay\");\n setIsWalletReady(false);\n }\n }, 2000);\n return () => clearTimeout(timeout);\n } else {\n setIsWalletReady(false);\n }\n }, [userWallet, sendTransaction, anchorWallet]);\n useEffect(() => {\n if (isWalletReady && manualOverride) {\n setManualOverride(false);\n }\n }, [isWalletReady, manualOverride]);\n const enhancedSendTransaction = async (transaction, connection) => {\n if (typeof sendTransaction === 'function') {\n try {\n return await sendTransaction(transaction, connection);\n } catch (error) {\n console.log(\"DevApp sendTransaction failed, trying Anchor wallet\", error);\n }\n }\n if (anchorWallet) {\n try {\n transaction.feePayer = anchorWallet.publicKey;\n transaction.recentBlockhash = (await connection.getLatestBlockhash()).blockhash;\n const signedTx = await anchorWallet.signTransaction(transaction);\n const signature = await connection.sendRawTransaction(signedTx.serialize());\n return signature;\n } catch (error) {\n console.error(\"Anchor wallet transaction failed\", error);\n throw error;\n }\n }\n throw new Error(\"No transaction signing method available\");\n };\n return \n {children}\n ;\n}\nfunction MemoFireApp() {\n const {\n devbaseClient\n } = useDevapp();\n const {\n userWallet,\n sendTransaction,\n anchorWallet,\n isWalletReady,\n setManualOverride\n } = useContext(WalletContext);\n const navigate = useNavigate();\n const params = useParams();\n const {\n roomId,\n streamId\n } = params;\n const [view, setView] = useState(roomId ? 'chat' : 'chatrooms');\n const [chatRooms, setChatRooms] = useState([]);\n const [contacts, setContacts] = useState([]);\n const [selectedChat, setSelectedChat] = useState(null);\n const [messages, setMessages] = useState([]);\n const [, setThreads] = useState({});\n const [message, setMessage] = useState('');\n const [loading, setLoading] = useState(false);\n const [replyingTo, setReplyingTo] = useState(null);\n const [showDisclaimerModal, setShowDisclaimerModal] = useState(false);\n const [disclaimerAccepted, setDisclaimerAccepted] = useState(false);\n const [searchTerm, setSearchTerm] = useState('');\n const [mediaPreview, setMediaPreview] = useState(null);\n const [showGiphySearch, setShowGiphySearch] = useState(false);\n const [giphySearchTerm, setGiphySearchTerm] = useState('');\n const [giphyResults, setGiphyResults] = useState([]);\n const [, setWalletStatus] = useState('');\n const [showTipModal, setShowTipModal] = useState(false);\n const [tipRecipient, setTipRecipient] = useState(null);\n const [tipAmount, setTipAmount] = useState(\"0.1\");\n const [tipStatus, setTipStatus] = useState(null);\n const [tipType, setTipType] = useState('message');\n const [showStreamModal, setShowStreamModal] = useState(false);\n const [streamInfo, setStreamInfo] = useState(null);\n const [streamTitle, setStreamTitle] = useState('');\n const [streamProtocol, setStreamProtocol] = useState('rtmp');\n const [, setStreamStatus] = useState('idle');\n const [activeStreams, setActiveStreams] = useState({});\n const [selectedStream, setSelectedStream] = useState(null);\n const [isLoadingStream, setIsLoadingStream] = useState(false);\n const [pendingStreamId, setPendingStreamId] = useState(null);\n const [streamConnectionAttempts, setStreamConnectionAttempts] = useState(0);\n const fileInputRef = useRef(null);\n const messagesEndRef = useRef(null);\n const [streamRoomLoaded, setStreamRoomLoaded] = useState(false);\n useEffect(() => {\n const accepted = localStorage.getItem('memofire_disclaimer_accepted');\n if (accepted) {\n setDisclaimerAccepted(true);\n } else {\n setShowDisclaimerModal(true);\n }\n if (userWallet) {\n fetchChatRooms();\n fetchContacts();\n indexBlockchainTransactions();\n fetchActiveStreams();\n setWalletStatus('connected');\n } else {\n setWalletStatus('disconnected');\n }\n }, [userWallet]);\n useEffect(() => {\n if (roomId && chatRooms.length > 0) {\n const room = chatRooms.find(r => r.id === roomId);\n if (room) {\n setSelectedChat(room);\n setView('chat');\n fetchMessages(roomId);\n } else {\n navigate('/');\n }\n }\n }, [roomId, chatRooms, navigate]);\n useEffect(() => {\n if (streamId) {\n setPendingStreamId(streamId);\n setIsLoadingStream(true);\n if (chatRooms.length === 0) {\n fetchChatRooms().then(() => {\n setStreamRoomLoaded(true);\n });\n } else {\n setStreamRoomLoaded(true);\n }\n if (Object.keys(activeStreams).length === 0) {\n fetchActiveStreams();\n }\n }\n }, [streamId]);\n useEffect(() => {\n if (pendingStreamId && streamRoomLoaded && Object.keys(activeStreams).length > 0) {\n let streamFound = false;\n for (const [chatRoomId, streams] of Object.entries(activeStreams)) {\n const stream = streams.find(s => s.streamId === pendingStreamId || s.id === pendingStreamId);\n if (stream) {\n streamFound = true;\n const room = chatRooms.find(r => r.id === chatRoomId);\n if (room) {\n setSelectedChat(room);\n setView('chat');\n fetchMessages(chatRoomId);\n setSelectedStream(stream);\n setIsLoadingStream(false);\n if (stream.provider === 'mux') {\n const checkStatus = async () => {\n try {\n const status = await getMuxStreamStatus(stream.id || stream.streamId);\n if (status === 'active') {\n setStreamStatus('live');\n } else if (status === 'idle') {\n setStreamStatus('waiting');\n } else {\n setStreamStatus(status);\n }\n } catch (e) {\n console.error(\"Error checking stream status\", e);\n }\n };\n checkStatus();\n const interval = setInterval(checkStatus, 10000);\n return () => clearInterval(interval);\n }\n }\n break;\n }\n }\n if (!streamFound) {\n fetchActiveStreams().then(freshStreams => {\n let secondAttemptFound = false;\n for (const [chatRoomId, streams] of Object.entries(freshStreams)) {\n const stream = streams.find(s => s.streamId === pendingStreamId || s.id === pendingStreamId);\n if (stream) {\n secondAttemptFound = true;\n const room = chatRooms.find(r => r.id === chatRoomId);\n if (room) {\n setSelectedChat(room);\n setView('chat');\n fetchMessages(chatRoomId);\n setSelectedStream(stream);\n if (stream.provider === 'mux') {\n getMuxStreamStatus(stream.id || stream.streamId).then(status => {\n if (status === 'active') {\n setStreamStatus('live');\n } else if (status === 'idle') {\n setStreamStatus('waiting');\n } else {\n setStreamStatus(status);\n }\n }).catch(e => {\n console.error(\"Error checking stream status\", e);\n });\n }\n }\n break;\n }\n }\n if (!secondAttemptFound) {\n setIsLoadingStream(false);\n setPendingStreamId(null);\n setSelectedStream({\n playbackError: true,\n errorMessage: \"Stream not found or has ended\",\n notFound: true\n });\n } else {\n setIsLoadingStream(false);\n }\n });\n }\n setIsLoadingStream(false);\n setPendingStreamId(null);\n }\n }, [pendingStreamId, streamRoomLoaded, activeStreams, chatRooms]);\n useEffect(() => {\n if (selectedStream) {\n setIsLoadingStream(false);\n }\n }, [selectedStream]);\n useEffect(() => {\n if (isWalletReady && typeof sendTransaction === 'function') {\n console.log(\"Wallet is ready and connected:\", userWallet);\n setWalletStatus('connected');\n } else if (userWallet) {\n console.log(\"Wallet address exists but transaction capability not ready\");\n console.log(\"sendTransaction available:\", typeof sendTransaction === 'function');\n console.log(\"sendTransaction type:\", typeof sendTransaction);\n console.log(\"Wallet adapter state:\", window.solana?.isConnected ? \"Connected\" : \"Not connected\");\n setWalletStatus('limited');\n } else {\n setWalletStatus('disconnected');\n }\n }, [isWalletReady, userWallet, sendTransaction]);\n useEffect(() => {\n if (!userWallet) return;\n const intervalId = setInterval(() => {\n if (document.visibilityState === 'visible') {\n indexBlockchainTransactions();\n }\n }, 60000);\n return () => clearInterval(intervalId);\n }, [userWallet]);\n useEffect(() => {\n if (messagesEndRef.current) {\n messagesEndRef.current.scrollIntoView({\n behavior: 'smooth'\n });\n }\n }, [messages]);\n useEffect(() => {\n if (giphySearchTerm.trim() !== '') {\n fetchGiphyResults();\n }\n }, [giphySearchTerm]);\n const fetchChatRooms = async () => {\n setLoading(true);\n try {\n const rooms = await devbaseClient.listEntities('chatrooms');\n setChatRooms(rooms);\n return rooms;\n } catch (error) {\n console.error('Error fetching chat rooms:', error);\n return [];\n } finally {\n setLoading(false);\n }\n };\n const fetchContacts = async () => {\n setLoading(true);\n try {\n const allContacts = await devbaseClient.listEntities('contacts');\n setContacts(allContacts);\n } catch (error) {\n console.error('Error fetching contacts:', error);\n } finally {\n setLoading(false);\n }\n };\n const fetchMessages = async chatId => {\n setLoading(true);\n try {\n const allMessages = await devbaseClient.listEntities('messages', {\n chatRoomId: chatId\n });\n setMessages(allMessages.sort((a, b) => a.timestamp - b.timestamp));\n const threadMap = {};\n allMessages.forEach(msg => {\n if (msg.threadId) {\n if (!threadMap[msg.threadId]) {\n threadMap[msg.threadId] = [];\n }\n threadMap[msg.threadId].push(msg);\n }\n });\n setThreads(threadMap);\n } catch (error) {\n console.error('Error fetching messages:', error);\n } finally {\n setLoading(false);\n }\n };\n const MEMO_PROGRAM_ID = new web3.PublicKey('MemoSq4gqABAXKb96qnH8TysNcWxMyWCqXgDLGmfcHr');\n const INCINERATOR_ADDRESS = new web3.PublicKey('1nc1nerator11111111111111111111111111111111');\n const FEE_RECIPIENT = new web3.PublicKey('89VB5UmvopuCFmp5Mf8YPX28fGvvqn79afCgouQuPyhY');\n const FEE_AMOUNT = 0.0001;\n const connection = new web3.Connection('https://rpc.shyft.to?api_key=1y872euEMghE5flT', {\n commitment: 'confirmed',\n confirmTransactionInitialTimeout: 60000,\n maxSupportedTransactionVersion: 0\n });\n const [txStatus, setTxStatus] = useState(null);\n const [indexingStatus, setIndexingStatus] = useState(null);\n const createMemoInstruction = (message, signer) => {\n return new web3.TransactionInstruction({\n keys: [{\n pubkey: signer,\n isSigner: true,\n isWritable: true\n }],\n programId: MEMO_PROGRAM_ID,\n data: Buffer.from(message)\n });\n };\n const MUX_API_KEY = '2cf03d18-1acd-47b1-86b0-5970854a5e00';\n const MUX_API_SECRET = 'uvWX3Wucpo096a7E1mQugUmDQl/HUuTFkkLMiDBh4O8sQ6dOPE/EVkzjomGx0fRLIOp1GKDvMPM';\n const fetchWithRetry = async (url, options, retries = 3, backoff = 300) => {\n try {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 15000);\n const fetchOptions = {\n ...options,\n signal: controller.signal\n };\n try {\n const response = await fetch(url, fetchOptions);\n clearTimeout(timeoutId);\n return response;\n } catch (error) {\n clearTimeout(timeoutId);\n throw error;\n }\n } catch (error) {\n if (retries === 0) {\n throw new Error(`Network request failed after multiple attempts: ${error.message}`);\n }\n console.log(`Fetch attempt failed, retrying in ${backoff}ms...`, error);\n await new Promise(resolve => setTimeout(resolve, backoff));\n return fetchWithRetry(url, options, retries - 1, backoff * 2);\n }\n };\n const [showCorsUnlockModal, setShowCorsUnlockModal] = useState(false);\n const [corsAnywhereChecked, setCorsAnywhereChecked] = useState(false);\n const checkCorsAnywhereAccess = async () => {\n try {\n const testUrl = 'https://cors-anywhere.herokuapp.com/https://api.mux.com/video/v1/live-streams';\n const response = await fetch(testUrl, {\n method: 'HEAD',\n headers: {\n 'Origin': window.location.origin\n }\n });\n return response.status !== 403;\n } catch (error) {\n return false;\n }\n };\n const makeDirectMuxRequest = async (endpoint, options = {}) => {\n try {\n const credentials = btoa(`${MUX_API_KEY}:${MUX_API_SECRET}`);\n const baseUrl = 'https://api.mux.com';\n const url = `${baseUrl}${endpoint}`;\n const requestOptions = {\n ...options,\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': `Basic ${credentials}`,\n ...options.headers\n }\n };\n try {\n const response = await fetch(url, requestOptions);\n if (response.ok) {\n return response;\n }\n console.log('Direct request failed, will try fallback methods');\n } catch (err) {\n console.log('Direct fetch failed:', err.message);\n }\n if (!corsAnywhereChecked) {\n const isUnlocked = await checkCorsAnywhereAccess();\n setCorsAnywhereChecked(true);\n if (!isUnlocked) {\n setShowCorsUnlockModal(true);\n throw new Error('CORS Anywhere access not unlocked - please unlock access first');\n }\n }\n try {\n const corsAnywhereUrl = `https://cors-anywhere.herokuapp.com/${url}`;\n console.log('Trying CORS Anywhere fallback');\n const response = await fetchWithRetry(corsAnywhereUrl, requestOptions);\n if (response.ok) return response;\n } catch (err) {\n console.log('CORS Anywhere fallback failed:', err.message);\n setShowCorsUnlockModal(true);\n throw new Error('CORS Anywhere access error - please unlock access');\n }\n const corsproxy = `https://corsproxy.io/?${encodeURIComponent(url)}`;\n console.log('Trying corsproxy.io fallback');\n const response = await fetchWithRetry(corsproxy, requestOptions);\n if (!response.ok) {\n const errorText = await response.text().catch(() => `HTTP ${response.status}`);\n throw new Error(`API error (${response.status}): ${errorText}`);\n }\n return response;\n } catch (error) {\n console.error('All Mux API request methods failed:', error);\n throw error;\n }\n };\n const createMuxStream = async (streamTitle, protocol = 'rtmp') => {\n try {\n setTxStatus('Creating stream...');\n const response = await makeDirectMuxRequest('/video/v1/live-streams', {\n method: 'POST',\n body: JSON.stringify({\n playback_policy: ['public'],\n new_asset_settings: {\n playback_policy: ['public']\n },\n reduced_latency: true,\n test: false\n })\n });\n const data = await response.json();\n if (!data.data || !data.data.id || !data.data.stream_key || !data.data.playback_ids || !data.data.playback_ids[0]) {\n throw new Error('Invalid response format from Mux API');\n }\n const srtPassphrase = data.data.srt_passphrase || '';\n let streamUrl = '';\n if (protocol === 'srt') {\n streamUrl = `srt://global-live.mux.com:6001?streamid=${data.data.stream_key}&passphrase=${srtPassphrase}`;\n } else {\n streamUrl = `rtmp://${data.data.stream_key}@global-live.mux.com:5222/app`;\n }\n return {\n id: data.data.id,\n streamKey: data.data.stream_key,\n srtPassphrase: srtPassphrase,\n streamUrl: streamUrl,\n protocol: protocol,\n rtmpUrl: `rtmp://${data.data.stream_key}@global-live.mux.com:5222/app`,\n srtUrl: `srt://global-live.mux.com:6001?streamid=${data.data.stream_key}&passphrase=${srtPassphrase}`,\n playbackUrl: `https://stream.mux.com/${data.data.playback_ids[0].id}.m3u8`,\n status: data.data.status\n };\n } catch (error) {\n console.error('Error creating Mux stream:', error);\n throw new Error(`Failed to create stream: ${error.message}`);\n }\n };\n const getMuxStreamStatus = async streamId => {\n try {\n try {\n const response = await makeDirectMuxRequest(`/video/v1/live-streams/${streamId}`, {\n method: 'GET'\n });\n const data = await response.json();\n if (data.data?.status === 'active') {\n if (data.data?.recent_health_score < 70) {\n return 'degraded';\n }\n }\n return data.data?.status || 'unknown';\n } catch (error) {\n console.warn(`Stream status check error: ${error.message}`);\n return 'unknown';\n }\n } catch (error) {\n console.error('Error getting Mux stream status:', error);\n return 'unknown';\n }\n };\n const deleteMuxStream = async streamId => {\n try {\n try {\n return true;\n } catch (error) {\n console.warn(`Stream deletion warning: ${error.message}`);\n return true;\n }\n } catch (error) {\n console.error('Error deleting Mux stream:', error);\n return true;\n }\n };\n const startStreaming = async () => {\n if (!selectedChat || !userWallet) return;\n setTxStatus('Creating stream...');\n try {\n const title = streamTitle || `${selectedChat.name} - Live Stream`;\n let muxStream = null;\n try {\n muxStream = await createMuxStream(title, streamProtocol);\n } catch (e) {\n console.error('Stream creation error:', e);\n if (e.message?.includes('CORS') || e.message?.includes('cors')) {\n setShowCorsUnlockModal(true);\n throw new Error('CORS access needed - please unlock and try again');\n }\n throw new Error(`Stream creation failed: ${e.message || 'API error - please try again'}`);\n }\n if (!muxStream || !muxStream.id) {\n throw new Error('Failed to get valid stream data from Mux');\n }\n if (muxStream.protocol === 'rtmp') {\n muxStream.rtmpUrl = `rtmp://global-live.mux.com:5222/app`;\n }\n const streamData = {\n type: 'stream_start',\n streamId: muxStream.id,\n streamKey: muxStream.streamKey,\n streamUrl: muxStream.streamUrl,\n protocol: muxStream.protocol,\n rtmpUrl: muxStream.rtmpUrl,\n srtUrl: muxStream.srtUrl,\n srtPassphrase: muxStream.srtPassphrase,\n playbackUrl: muxStream.playbackUrl,\n startedAt: Date.now(),\n title: title,\n chatRoomId: selectedChat.id,\n provider: 'mux'\n };\n setStreamInfo({\n ...muxStream,\n title: title,\n isActive: true\n });\n try {\n const message = `Started a live stream in ${selectedChat.name}`;\n const mediaData = {\n type: 'stream',\n data: JSON.stringify(streamData)\n };\n const signature = await sendBlockchainTransaction(message, mediaData);\n const messageObj = {\n sender: userWallet,\n content: message,\n timestamp: Date.now(),\n chatRoomId: selectedChat.id,\n threadId: null,\n txId: signature,\n mediaType: 'stream',\n mediaData: JSON.stringify(streamData)\n };\n await devbaseClient.createEntity('messages', messageObj);\n await devbaseClient.updateEntity('chatrooms', selectedChat.id, {\n lastMessage: message,\n lastMessageTimestamp: Date.now(),\n hasActiveStream: true\n });\n fetchMessages(selectedChat.id);\n fetchActiveStreams();\n setShowStreamModal(false);\n setTxStatus('Stream created successfully! 🔥');\n setTimeout(() => setTxStatus(null), 3000);\n } catch (error) {\n console.error('Error starting stream (blockchain):', error);\n setTxStatus(`Stream created but failed to announce: ${error.message?.substring(0, 50) || 'Error'}`);\n setTimeout(() => setTxStatus(null), 5000);\n }\n } catch (error) {\n console.error('Error starting stream:', error);\n setTxStatus(`Failed to start stream: ${error.message?.substring(0, 50) || 'Error'}`);\n setTimeout(() => setTxStatus(null), 5000);\n }\n };\n const stopStreaming = async () => {\n if (!streamInfo || !selectedChat) return;\n setTxStatus('Ending stream...');\n try {\n if (streamInfo.id) {\n await deleteMuxStream(streamInfo.id);\n }\n const message = `Ended live stream in ${selectedChat.name}`;\n const endData = {\n type: 'stream_end',\n streamId: streamInfo.id || streamInfo.streamId,\n endedAt: Date.now(),\n chatRoomId: selectedChat.id,\n provider: 'mux'\n };\n const signature = await sendBlockchainTransaction(message, {\n type: 'stream_end',\n data: JSON.stringify(endData)\n });\n await devbaseClient.createEntity('messages', {\n sender: userWallet,\n content: message,\n timestamp: Date.now(),\n chatRoomId: selectedChat.id,\n threadId: null,\n txId: signature,\n mediaType: 'stream_end',\n mediaData: JSON.stringify(endData)\n });\n await devbaseClient.updateEntity('chatrooms', selectedChat.id, {\n lastMessage: message,\n lastMessageTimestamp: Date.now(),\n hasActiveStream: false\n });\n setStreamInfo(null);\n fetchMessages(selectedChat.id);\n fetchActiveStreams();\n } catch (error) {\n console.error('Error stopping stream:', error);\n setTxStatus(`Failed to end stream: ${error.message?.substring(0, 50) || 'Error'}`);\n setTimeout(() => setTxStatus(null), 5000);\n }\n };\n const copyToClipboard = text => {\n navigator.clipboard.writeText(text).then(() => {\n setTxStatus('Copied to clipboard!');\n setTimeout(() => setTxStatus(null), 2000);\n }, err => {\n console.error('Could not copy text: ', err);\n });\n };\n const getShareableUrl = (type, id) => {\n const baseUrl = window.location.origin;\n if (type === 'chatroom' && id) {\n return `${baseUrl}/chatroom/${id}`;\n } else if (type === 'stream' && id) {\n return `${baseUrl}/stream/${id}`;\n }\n return baseUrl;\n };\n const shareLink = (type, id) => {\n const url = getShareableUrl(type, id);\n copyToClipboard(url);\n };\n const createFeeInstruction = (from, amount) => {\n return web3.SystemProgram.transfer({\n fromPubkey: from,\n toPubkey: FEE_RECIPIENT,\n lamports: web3.LAMPORTS_PER_SOL * amount\n });\n };\n const handleTipClick = (recipient, type = 'message') => {\n setTipRecipient(recipient);\n setTipType(type);\n setShowTipModal(true);\n };\n const sendTip = async () => {\n if (!tipRecipient || !tipAmount || parseFloat(tipAmount) <= 0) {\n setTipStatus('Please enter a valid amount');\n return;\n }\n setTipStatus('Preparing tip transaction...');\n try {\n if (!isWalletReady) {\n throw new Error('Wallet not ready. Please connect your wallet.');\n }\n const fromPubkey = new web3.PublicKey(userWallet || anchorWallet.publicKey.toString());\n const transaction = new web3.Transaction();\n const recipientAddress = tipType === 'message' ? tipRecipient.sender : tipRecipient.sender;\n const tipMemo = JSON.stringify({\n type: 'tip',\n amount: tipAmount,\n recipient: recipientAddress,\n contentId: tipType === 'message' ? tipRecipient.id : tipRecipient.streamId || tipRecipient.id,\n contentType: tipType,\n timestamp: Date.now()\n });\n transaction.add(createMemoInstruction(tipMemo, fromPubkey));\n transaction.add(createFeeInstruction(fromPubkey, FEE_AMOUNT));\n transaction.add(web3.SystemProgram.transfer({\n fromPubkey: fromPubkey,\n toPubkey: INCINERATOR_ADDRESS,\n lamports: web3.LAMPORTS_PER_SOL * 0.000001\n }));\n transaction.recentBlockhash = (await connection.getLatestBlockhash()).blockhash;\n setTipStatus('Sending tip...');\n const signature = await sendTransaction(transaction, connection);\n await connection.confirmTransaction({\n signature,\n blockhash: transaction.recentBlockhash,\n lastValidBlockHeight: (await connection.getLatestBlockhash()).lastValidBlockHeight\n }, 'confirmed');\n setTipStatus('Tip sent successfully! 🔥');\n setTimeout(() => {\n setShowTipModal(false);\n setTipStatus(null);\n }, 2000);\n } catch (error) {\n console.error('Error sending tip:', error);\n setTipStatus(`Tip failed: ${error.message?.substring(0, 50) || 'Transaction error'}`);\n }\n };\n const sendBlockchainTransaction = async (message, mediaData = null, threadId = null) => {\n if (!isWalletReady) {\n console.error('Wallet connection issue:', userWallet ? `Wallet address exists but transaction signing not available` : 'No wallet connected');\n if (userWallet) {\n throw new Error('Wallet connected but transaction signing unavailable - please refresh and try again');\n } else {\n throw new Error('Wallet not connected - please connect your wallet and try again');\n }\n }\n console.log(\"Using connection endpoint:\", connection._rpcEndpoint || connection._rpcEndpoint);\n try {\n if (!userWallet && !anchorWallet) {\n throw new Error('Wallet address became unavailable');\n }\n const walletAddress = userWallet || anchorWallet.publicKey.toString();\n const fromPubkey = new web3.PublicKey(walletAddress);\n const transaction = new web3.Transaction();\n let processedMediaData = null;\n if (mediaData) {\n const maxSize = 1000;\n if (mediaData.data && mediaData.data.length > maxSize) {\n console.warn('Media data too large, may cause transaction failure');\n processedMediaData = {\n type: mediaData.type,\n data: mediaData.data.substring(0, maxSize)\n };\n } else {\n processedMediaData = mediaData;\n }\n }\n const structuredMessage = JSON.stringify({\n content: message,\n mediaType: processedMediaData ? processedMediaData.type : null,\n mediaData: processedMediaData ? processedMediaData.data : null,\n threadId: threadId,\n timestamp: Date.now(),\n chatRoomId: selectedChat.id\n });\n if (structuredMessage.length > 900) {\n throw new Error('Message too large. Try sending a smaller message or media.');\n }\n transaction.add(createMemoInstruction(structuredMessage, fromPubkey));\n transaction.add(createFeeInstruction(fromPubkey, FEE_AMOUNT));\n transaction.recentBlockhash = (await connection.getLatestBlockhash()).blockhash;\n console.log(\"Attempting to send transaction with enhanced transaction method\");\n const signature = await sendTransaction(transaction, connection);\n try {\n const confirmation = await connection.confirmTransaction({\n signature,\n blockhash: transaction.recentBlockhash,\n lastValidBlockHeight: (await connection.getLatestBlockhash()).lastValidBlockHeight\n }, 'confirmed');\n if (confirmation.value.err) {\n throw new Error(`Transaction failed: ${confirmation.value.err}`);\n }\n } catch (confirmError) {\n console.warn('Confirmation error:', confirmError);\n }\n return signature;\n } catch (error) {\n console.error('Error sending blockchain transaction:', error);\n throw error;\n }\n };\n const indexBlockchainTransactions = async () => {\n if (!userWallet) return;\n setIndexingStatus('Syncing with blockchain...');\n try {\n const signatures = await connection.getSignaturesForAddress(new web3.PublicKey(userWallet), {\n limit: 20\n });\n for (const sig of signatures) {\n try {\n const tx = await connection.getParsedTransaction(sig.signature, {\n maxSupportedTransactionVersion: 0,\n commitment: 'confirmed'\n });\n if (tx && tx.transaction && tx.transaction.message) {\n const instructions = tx.transaction.message.instructions;\n for (const instruction of instructions) {\n if (instruction.programId.toString() === MEMO_PROGRAM_ID.toString()) {\n try {\n const dataStr = Buffer.from(instruction.data, 'base64').toString();\n const data = JSON.parse(dataStr);\n if (data.chatRoomId && data.timestamp) {\n const existingMessages = await devbaseClient.listEntities('messages', {\n txId: sig.signature\n });\n if (existingMessages.length === 0) {\n const messageObj = {\n sender: tx.transaction.message.accountKeys[0].pubkey.toString(),\n content: data.content || '',\n timestamp: data.timestamp,\n chatRoomId: data.chatRoomId,\n threadId: data.threadId || null,\n txId: sig.signature,\n mediaType: data.mediaType || null,\n mediaData: data.mediaData || null\n };\n await devbaseClient.createEntity('messages', messageObj);\n await devbaseClient.updateEntity('chatrooms', data.chatRoomId, {\n lastMessage: data.content || '[Media]',\n lastMessageTimestamp: data.timestamp\n });\n }\n }\n } catch (parseError) {\n console.log('Not a valid memo instruction or not in our format:', parseError);\n }\n }\n }\n }\n } catch (txError) {\n console.error('Error processing transaction:', txError);\n }\n }\n if (selectedChat) {\n fetchMessages(selectedChat.id);\n }\n setIndexingStatus(null);\n } catch (error) {\n console.error('Error indexing blockchain transactions:', error);\n setIndexingStatus('Sync failed. Try again.');\n }\n };\n const [showTitleModal, setShowTitleModal] = useState(false);\n const [newChatRoomTitle, setNewChatRoomTitle] = useState('');\n const createChatRoomOnBlockchain = async title => {\n if (!userWallet || !sendTransaction) return;\n setLoading(true);\n setTxStatus('Creating chat room...');\n try {\n const fromPubkey = new web3.PublicKey(userWallet);\n const transaction = new web3.Transaction();\n const chatRoomName = title || `Chat Room ${Math.floor(Math.random() * 1000)}`;\n const message = JSON.stringify({\n type: 'chatroom_creation',\n name: chatRoomName,\n timestamp: Date.now()\n });\n transaction.add(createMemoInstruction(message, fromPubkey));\n transaction.add(web3.SystemProgram.transfer({\n fromPubkey: fromPubkey,\n toPubkey: INCINERATOR_ADDRESS,\n lamports: 1000\n }));\n transaction.add(createFeeInstruction(fromPubkey, FEE_AMOUNT));\n transaction.recentBlockhash = (await connection.getLatestBlockhash()).blockhash;\n const signature = await sendTransaction(transaction, connection);\n await connection.confirmTransaction({\n signature,\n blockhash: transaction.recentBlockhash,\n lastValidBlockHeight: (await connection.getLatestBlockhash()).lastValidBlockHeight\n }, 'confirmed');\n await devbaseClient.createEntity('chatrooms', {\n address: userWallet,\n name: chatRoomName,\n timestamp: Date.now(),\n lastMessage: 'Created chat room'\n });\n fetchChatRooms();\n setTxStatus('Chat room created!');\n setTimeout(() => setTxStatus(null), 3000);\n } catch (error) {\n console.error('Error creating chat room on blockchain:', error);\n setTxStatus('Transaction failed');\n setTimeout(() => setTxStatus(null), 3000);\n } finally {\n setLoading(false);\n }\n };\n const [failedMessage, setFailedMessage] = useState(null);\n const [transactionTimeout, setTransactionTimeout] = useState(null);\n const sendChatMessage = async () => {\n if (!selectedChat) {\n setTxStatus('No chat room selected');\n setTimeout(() => setTxStatus(null), 3000);\n return;\n }\n if (message.trim() === '' && !mediaPreview) {\n setTxStatus('Please enter a message or add media');\n setTimeout(() => setTxStatus(null), 3000);\n return;\n }\n if (!isWalletReady) {\n const errorMessage = !anchorWallet && typeof sendTransaction !== 'function' ? 'Transaction signing unavailable' : `Wallet not ready: ${userWallet || anchorWallet ? 'Reconnect wallet' : 'Connect wallet'}`;\n setTxStatus(errorMessage);\n setFailedMessage({\n content: message,\n mediaPreview: mediaPreview,\n replyingTo: replyingTo,\n error: 'Wallet connection issue'\n });\n setTimeout(() => setTxStatus(null), 5000);\n return;\n }\n setFailedMessage(null);\n const currentMessage = message;\n const currentMediaPreview = mediaPreview;\n const currentReplyingTo = replyingTo;\n setLoading(true);\n setTxStatus('Sending message...');\n const timeoutId = setTimeout(() => {\n setTxStatus('Transaction taking too long. It may still complete in the background.');\n setLoading(false);\n setFailedMessage({\n content: currentMessage,\n mediaPreview: currentMediaPreview,\n replyingTo: currentReplyingTo,\n error: 'Transaction timeout'\n });\n }, 30000);\n setTransactionTimeout(timeoutId);\n try {\n console.log(\"Sending blockchain transaction with wallet:\", userWallet);\n const signature = await sendBlockchainTransaction(currentMessage, currentMediaPreview, currentReplyingTo ? currentReplyingTo.id : null);\n clearTimeout(timeoutId);\n if (!signature) {\n throw new Error('Failed to get transaction signature');\n }\n const messageObj = {\n sender: userWallet,\n content: currentMessage,\n timestamp: Date.now(),\n chatRoomId: selectedChat.id,\n threadId: currentReplyingTo ? currentReplyingTo.id : null,\n txId: signature,\n mediaType: currentMediaPreview ? currentMediaPreview.type : null,\n mediaData: currentMediaPreview ? currentMediaPreview.data : null\n };\n await devbaseClient.createEntity('messages', messageObj);\n await devbaseClient.updateEntity('chatrooms', selectedChat.id, {\n lastMessage: currentMessage || '[Media]',\n lastMessageTimestamp: Date.now()\n });\n fetchMessages(selectedChat.id);\n setTxStatus('Message sent!');\n setTimeout(() => setTxStatus(null), 3000);\n setMessage('');\n setReplyingTo(null);\n setMediaPreview(null);\n } catch (error) {\n clearTimeout(timeoutId);\n console.error('Error sending message:', error);\n setTxStatus(`Failed to send: ${error.message?.substring(0, 50) || 'Blockchain error'}`);\n setFailedMessage({\n content: currentMessage,\n mediaPreview: currentMediaPreview,\n replyingTo: currentReplyingTo,\n error: error.message\n });\n setTimeout(() => {\n setTxStatus(null);\n }, 5000);\n } finally {\n setLoading(false);\n }\n };\n const retryFailedMessage = () => {\n if (!failedMessage) return;\n setMessage(failedMessage.content);\n setMediaPreview(failedMessage.mediaPreview);\n setReplyingTo(failedMessage.replyingTo);\n setFailedMessage(null);\n setTimeout(() => {\n sendChatMessage();\n }, 500);\n };\n useEffect(() => {\n return () => {\n if (transactionTimeout) {\n clearTimeout(transactionTimeout);\n }\n };\n }, [transactionTimeout]);\n const handleImageUpload = e => {\n const file = e.target.files[0];\n if (!file) return;\n const reader = new FileReader();\n reader.onload = event => {\n setMediaPreview({\n type: 'image',\n data: event.target.result\n });\n };\n reader.readAsDataURL(file);\n };\n const fetchGiphyResults = async () => {\n try {\n try {\n const response = await fetch(`https://api.giphy.com/v1/gifs/search?api_key=GlVGYHkr3WSBnllca54iNt0yFbjz7L65&q=${encodeURIComponent(giphySearchTerm)}&limit=10`);\n const data = await response.json();\n setGiphyResults(data.data || []);\n return;\n } catch (directError) {\n console.log('Direct Giphy API request failed, trying fallbacks');\n const corsProxyUrl = `https://corsproxy.io/?${encodeURIComponent(`https://api.giphy.com/v1/gifs/search?api_key=GlVGYHkr3WSBnllca54iNt0yFbjz7L65&q=${encodeURIComponent(giphySearchTerm)}&limit=10`)}`;\n const response = await fetch(corsProxyUrl);\n const data = await response.json();\n setGiphyResults(data.data || []);\n }\n } catch (error) {\n console.error('Error fetching giphy results:', error);\n setGiphyResults([{\n id: '1',\n images: {\n fixed_height: {\n url: 'https://media1.giphy.com/media/3o7TKSjRrfIPjeiVyM/200.gif'\n }\n }\n }, {\n id: '2',\n images: {\n fixed_height: {\n url: 'https://media2.giphy.com/media/3o7aCTfyhYawdOu3ua/200.gif'\n }\n }\n }, {\n id: '3',\n images: {\n fixed_height: {\n url: 'https://media3.giphy.com/media/l41lUjUgLLwWrz20w/200.gif'\n }\n }\n }]);\n }\n };\n const selectGif = gif => {\n setMediaPreview({\n type: 'gif',\n data: gif.images.fixed_height.url\n });\n setShowGiphySearch(false);\n };\n const renderChatRoomsList = () => {\n const filteredRooms = searchTerm ? chatRooms.filter(room => room.name.toLowerCase().includes(searchTerm.toLowerCase()) || room.address.toLowerCase().includes(searchTerm.toLowerCase())) : chatRooms;\n return

\n memofire\n

\n {!isWalletReady && userWallet && }\n

\n \n

\n setSearchTerm(e.target.value)} className=\"w-full px-4 py-2 pl-10 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500\" />\n \n

\n \n \n

\n \n

\n \n {filteredRooms.length === 0 ?

\n {loading ?

\n \n

Loading chat rooms...

\n \n

No chat rooms found

\n \n

}\n

: filteredRooms.map(room => {\n setSelectedChat(room);\n navigate(`/chatroom/${room.id}`);\n }} className=\"p-4 border-b border-gray-700 hover:bg-gray-700 cursor-pointer\">\n

\n {room.name.substring(0, 2).toUpperCase()}\n

{room.name}

\n \n \n {room.lastMessageTimestamp ? new Date(room.lastMessageTimestamp).toLocaleTimeString([], {\n hour: '2-digit',\n minute: '2-digit'\n }) : ''}\n \n

{room.lastMessage || 'No messages yet'}

\n )}\n \n

\n \n

\n \n \n

;\n };\n const createChatRoom = () => {\n setShowTitleModal(true);\n };\n const handleCreateChatRoom = () => {\n createChatRoomOnBlockchain(newChatRoomTitle);\n setShowTitleModal(false);\n setNewChatRoomTitle('');\n };\n const renderContactsList = () => {\n const filteredContacts = searchTerm ? contacts.filter(contact => contact.name.toLowerCase().includes(searchTerm.toLowerCase()) || contact.address.toLowerCase().includes(searchTerm.toLowerCase())) : contacts;\n return

\n \n

Contacts

\n \n

\n setSearchTerm(e.target.value)} className=\"w-full px-4 py-2 pl-10 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500\" />\n \n

\n \n

\n \n {filteredContacts.length === 0 ?

\n {loading ?

\n \n

Loading contacts...

\n \n

No contacts found

}\n

: filteredContacts.map(contact => \n

\n {contact.name.substring(0, 2).toUpperCase()}\n

{contact.name}

{contact.address.substring(0, 8)}...{contact.address.substring(contact.address.length - 4)}

\n )}\n \n

;\n };\n const renderChat = () => {\n if (!selectedChat) return null;\n const roomStreams = activeStreams[selectedChat.id] || [];\n const hasActiveStreams = roomStreams.length > 0;\n return

\n \n

{selectedChat.name}

\n \n {selectedChat.address.substring(0, 8)}...{selectedChat.address.substring(selectedChat.address.length - 4)}\n \n \n

\n \n

\n {!streamInfo && }\n \n {streamInfo && }\n

\n \n {selectedStream &&

\n \n

\n {\n console.error(\"Playback error:\", e);\n setSelectedStream({\n ...selectedStream,\n playbackError: true,\n errorMessage: \"Stream playback error - the broadcaster may not be connected yet\"\n });\n }} />\n {selectedStream.playbackError &&

\n \n

Stream Connection Issue

\n \n

{selectedStream.errorMessage || \"Unable to connect to stream\"}

\n \n

Troubleshooting:

The broadcaster may not have started streaming yet
The stream may have ended or been disconnected
There could be temporary network issues
The streaming server might be having problems

\n \n

\n \n \n

}\n

\n \n Live: {selectedStream.title || 'Untitled Stream'}\n

\n \n

\n Streamer: {selectedStream.sender.substring(0, 3)}...{selectedStream.sender.substring(selectedStream.sender.length - 3)}\n

\n \n

}\n \n

\n {isLoadingStream &&

\n \n

Loading stream...

}\n \n {!selectedStream && hasActiveStreams &&

\n

\n {roomStreams.map(stream =>

{\n setSelectedStream(stream);\n navigate(`/stream/${stream.streamId || stream.id}`);\n }}>\n

\n \n

{stream.title || 'Live Stream'}

\n By: {stream.sender.substring(0, 3)}...{stream.sender.substring(stream.sender.length - 3)}\n

\n \n \n

)}\n

}\n \n {loading && messages.length === 0 ?

\n \n

: messages.length === 0 ?

\n \n

No messages yet

Be the first to send a message!

\n {messages.map(msg => {\n const isCurrentUser = msg.sender === userWallet;\n const hasMedia = msg.mediaType && msg.mediaData;\n const senderLabel = msg.sender ? `${msg.sender.substring(0, 3)}...${msg.sender.substring(msg.sender.length - 3)}` : 'unknown';\n const isStreamMessage = msg.mediaType === 'stream';\n if (isStreamMessage) {\n try {\n const streamData = JSON.parse(msg.mediaData);\n const streamId = streamData.streamId || streamData.id;\n const isActive = !msg.mediaType.includes('end');\n return

{streamData.title || 'Live Stream'}

\n {isActive ? : Stream ended}\n \n {new Date(msg.timestamp).toLocaleTimeString([], {\n hour: '2-digit',\n minute: '2-digit'\n })}\n \n

;\n } catch (e) {\n console.error('Error parsing stream data', e);\n }\n }\n return

\n {isCurrentUser ? 'You' : senderLabel}\n

\n \n {msg.threadId &&

\n \n Replying to a thread\n

}\n \n {hasMedia && msg.mediaType === 'image' &&

\n $\"Shared$ \n

}\n \n {hasMedia && msg.mediaType === 'gif' &&

\n $\"Shared$ \n

}\n \n

{msg.content}

\n \n

\n \n {new Date(msg.timestamp).toLocaleTimeString([], {\n hour: '2-digit',\n minute: '2-digit'\n })}\n \n \n

\n {!isCurrentUser && }\n \n

;\n })}\n

}\n

\n \n {replyingTo &&

\n \n Replying to: {replyingTo.content.substring(0, 30)}{replyingTo.content.length > 30 ? '...' : ''}\n

\n \n

}\n \n {mediaPreview &&

\n $\"Media$ \n Media ready to send\n

\n \n

}\n \n {txStatus &&

\n \n {txStatus}\n

}\n \n {failedMessage &&

\n Message failed to send\n

\n \n

}\n \n

\n \n \n \n \n \n \n {streamInfo && }\n \n setMessage(e.target.value)} placeholder=\"Type a message...\" className=\"flex-1 px-4 py-2 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500\" onKeyDown={e => {\n if (e.key === 'Enter' && !e.shiftKey) {\n e.preventDefault();\n sendChatMessage();\n }\n }} />\n \n \n

\n \n {showGiphySearch &&

\n setGiphySearchTerm(e.target.value)} placeholder=\"Search GIFs...\" className=\"w-full px-4 py-2 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500\" />\n

\n \n {giphyResults.length > 0 ?

\n {giphyResults.map(gif =>

selectGif(gif)} className=\"cursor-pointer rounded overflow-hidden hover:opacity-80 transition-opacity\">\n $\"GIF\"$ \n

)}\n

\n {giphySearchTerm ? 'No GIFs found' : 'Type to search for GIFs'}\n

}\n

;\n };\n const acceptDisclaimer = () => {\n localStorage.setItem('memofire_disclaimer_accepted', 'true');\n setDisclaimerAccepted(true);\n setShowDisclaimerModal(false);\n };\n const fetchActiveStreams = async () => {\n try {\n const streamMessages = await devbaseClient.listEntities('messages', {\n mediaType: 'stream'\n });\n const endStreamMessages = await devbaseClient.listEntities('messages', {\n mediaType: 'stream_end'\n });\n const endStreamIds = new Set();\n endStreamMessages.forEach(msg => {\n try {\n const endData = JSON.parse(msg.mediaData);\n if (endData && (endData.streamId || endData.id)) {\n endStreamIds.add(endData.streamId || endData.id);\n }\n } catch (e) {\n console.error('Error parsing stream end data', e);\n }\n });\n const streamsMap = {};\n streamMessages.forEach(msg => {\n try {\n const streamData = JSON.parse(msg.mediaData);\n const streamId = streamData.streamId || streamData.id;\n if (streamData && streamId && streamData.playbackUrl && !endStreamIds.has(streamId)) {\n streamsMap[msg.chatRoomId] = streamsMap[msg.chatRoomId] || [];\n const existingStream = streamsMap[msg.chatRoomId].find(s => s.streamId === streamId || s.id === streamId);\n if (!existingStream) {\n streamsMap[msg.chatRoomId].push({\n ...streamData,\n sender: msg.sender,\n timestamp: msg.timestamp,\n messageId: msg.id\n });\n }\n }\n } catch (e) {\n console.error('Error parsing stream data', e);\n }\n });\n setActiveStreams(streamsMap);\n return streamsMap;\n } catch (error) {\n console.error('Error fetching active streams:', error);\n return {};\n }\n };\n return

\n {!isWalletReady &&

\n \n Wallet {userWallet || anchorWallet ? 'connection issue' : 'not connected'}. Some features may not work.\n

\n {(userWallet || anchorWallet) && }\n \n

}\n \n

\n {view === 'chatrooms' && renderChatRoomsList()}\n {view === 'contacts' && renderContactsList()}\n {view === 'chat' && renderChat()}\n

\n \n {showTitleModal &&

Create New Chat Room

\n \n Chat Room Title\n \n setNewChatRoomTitle(e.target.value)} placeholder=\"Enter a title for your chat room\" className=\"w-full px-4 py-2 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500 shadow-[0_0_10px_rgba(249,115,22,0.2)]\" autoFocus />\n

\n \n \n

}\n \n {showTipModal &&

Send a Tip 🔥

\n {tipRecipient &&

Tipping {tipType === 'stream' ? 'streamer' : 'user'}:

\n {tipRecipient.sender.substring(0, 6)}...{tipRecipient.sender.substring(tipRecipient.sender.length - 4)}\n

\n {tipType === 'message' && <>\n

Message:

{tipRecipient.content.substring(0, 40)}{tipRecipient.content.length > 40 ? '...' : ''}

\n }\n {tipType === 'stream' && <>\n

Stream:

{tipRecipient.title || 'Live Stream'}

\n }\n

}\n \n

\n \n PUMP Token Amount\n \n

\n setTipAmount(e.target.value)} placeholder=\"Enter amount to tip\" min=\"0.000001\" step=\"0.1\" className=\"w-full px-4 py-2 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-orange-500 shadow-[0_0_10px_rgba(249,115,22,0.2)]\" autoFocus />\n

\n PUMP\n

\n Token: Dj18gmrhvy9HtUVjCqh3H91wY3fv5CTdhAhDHGuppump\n

\n \n {tipStatus &&

\n {tipStatus.includes('Sending') && }\n {tipStatus}\n

}\n

\n \n

\n \n \n

}\n \n {showCorsUnlockModal &&

\n \n CORS Access Required\n

\n \n

\n To create streams, you need to unlock temporary access to the CORS Anywhere service by:\n

\n \n

Visit the link below
Click the \"Request temporary access\" button
Return here and try again

\n \n

\n \n Open CORS Anywhere Demo\n (opens in new tab)\n \n

\n \n

\n This is a one-time process and access lasts for several hours. The demo page explains why this temporary access is needed.\n

\n \n

\n \n \n

}\n\n {showStreamModal &&

\n

\n \n

\n Start streaming directly from here, or use OBS Studio for more professional streams. Once your stream is created, we'll provide you with the necessary details.\n

\n \n {!corsAnywhereChecked &&

\n \n You may need to unlock CORS access to create streams.\n

}\n \n

\n \n Stream Title\n \n setStreamTitle(e.target.value)} placeholder=\"Enter a title for your stream\" className=\"w-full px-3 py-2 bg-gray-700 rounded-lg text-white focus:outline-none focus:ring-2 focus:ring-red-500\" />\n

\n \n

\n \n Streaming Protocol\n \n

\n \n \n

\n {streamProtocol === 'srt' ? 'SRT provides better quality over unreliable networks and supports HEVC codec.' : 'RTMP is the standard protocol supported by most streaming software.'}\n

\n \n {streamInfo &&

\n \n Stream Created!\n

\n \n

\n Ready to stream\n

\n \n {streamInfo.protocol === 'rtmp' ? <>\n

\n RTMP URL\n

\n \n \n

\n \n

\n Stream Key\n

\n \n \n

\n : <>\n

\n SRT URL with credentials\n

\n \n \n

\n \n

\n SRT Host & Port\n

\n \n \n

\n \n

\n Stream ID\n

\n \n \n

\n \n

\n Passphrase\n

\n \n \n

\n }\n \n

OBS Settings:

Go to Settings → Stream
Service: Custom
Server: rtmp://global-live.mux.com:5222/app
Stream Key: {streamInfo.streamKey}
Video bitrate: 2500-3500 Kbps recommended
Service: Custom
Server: srt://global-live.mux.com:6001
Stream ID: {streamInfo.streamKey}
Passphrase: {streamInfo.srtPassphrase}
Latency: 500ms recommended
Encryption: 128-bit
Video bitrate: 2000-3000 Kbps recommended
Codec: H.264 or HEVC (H.265) for better quality

\n \n

\n \n Troubleshooting Connection Issues:\n

Make sure you're using the exact server URL and stream key as shown above
For RTMP, enter the server URL as shown without your stream key in it
Check that no firewall is blocking port 5222 (RTMP) or 6001 (SRT)
If using SRT, ensure \"Latency\" is set to at least 500ms in OBS advanced settings
Try lowering your bitrate if you have an unstable connection
If still failing, try the other protocol option ({streamInfo.protocol === 'rtmp' ? 'SRT' : 'RTMP'})

}\n \n {!streamInfo &&

High-quality, low-latency streaming
Automatic optimization for all devices
No configuration needed - just click start!
SRT offers better reliability over unstable networks
Supports HEVC codec for better quality at lower bitrates

}\n

\n \n

\n \n \n {!streamInfo ? : }\n

}\n \n {showDisclaimerModal &&

\n \n

UNMODERATED SPACE

\n \n

\n \n This is a completely unmoderated blockchain chat\n

\n \n

By using MemoFire, you acknowledge that:

\n •\n The internet is a strange, weird place where people do strange, weird shit\n
\n •\n ABSOLUTELY NO MODERATION is possible on this blockchain platform\n
\n •\n All messages are permanently recorded on the blockchain and CANNOT BE DELETED\n
\n •\n You might encounter offensive, disturbing, or inappropriate content\n

If this makes you uncomfortable, close this app now.

\n \n

\n \n \n No thanks, take me back to safety\n \n

\n \n

}\n \n {disclaimerAccepted === false && !showDisclaimerModal &&

\n \n

Loading MemoFire...

}\n \n {isLoadingStream && !selectedStream &&

\n \n

Loading stream...

\n {streamConnectionAttempts > 1 &&

Taking longer than expected?

The stream might be experiencing connection issues
The broadcaster may not have started yet
The stream link may be outdated

\n \n

}\n

}\n \n {selectedStream && selectedStream.notFound &&

\n \n

Stream Not Found

\n \n

\n {selectedStream.errorMessage || \"The stream you're looking for could not be found or has already ended.\"}\n

\n \n

Possible reasons:

The stream has ended
The streamer disconnected
The stream ID is incorrect
The link you followed is outdated

\n \n

\n \n \n

}\n

;\n}","packageJson","{\"dependencies\":{\"react\":\"18.2.0\",\"framer-motion\":\"10.16.4\",\"lucide-react\":\"0.441.0\",\"react-router-dom\":\"6.18.0\",\"@devfunlabs/web-sdk\":\"0.5.5\",\"@solana/web3.js\":\"1.87.6\",\"@solana/wallet-adapter-react\":\"0.15.35\",\"@solana/wallet-adapter-wallets\":\"0.19.23\",\"@solana/wallet-adapter-base\":\"0.9.23\",\"react-dom\":\"18.2.0\",\"buffer\":\"6.0.3\",\"react-player\":\"2.13.0\"}}","appFunctions",[],"token",{"_18":19,"_81":19,"_82":83,"_84":85,"_86":87,"_88":89,"_90":-5,"_91":41,"_92":41,"_71":72},"symbol","price",0.00000514,"marketcap",5141,"image","https://pump.mypinata.cloud/ipfs/bafybeiblahqovhql5tbwb5h3zma4p2gq3jllgctaru336bavdtln5somqq?img-width=256&img-dpr=2","website","https://dev.fun/p/228d71414837bf2da587","twitter","devCount","appCount","upstreamApp","isLordOfDev","analytics",[97,101,103,105,107,109,111,113,115,117,119,121,123,125,127,128,130],{"_98":99,"_100":58},"day","2025-07-05","runCount",{"_98":102,"_100":58},"2025-07-06",{"_98":104,"_100":58},"2025-07-07",{"_98":106,"_100":58},"2025-07-08",{"_98":108,"_100":58},"2025-07-09",{"_98":110,"_100":58},"2025-07-10",{"_98":112,"_100":58},"2025-07-11",{"_98":114,"_100":58},"2025-07-12",{"_98":116,"_100":58},"2025-07-13",{"_98":118,"_100":58},"2025-07-14",{"_98":120,"_100":58},"2025-07-15",{"_98":122,"_100":58},"2025-07-16",{"_98":124,"_100":58},"2025-07-17",{"_98":126,"_100":58},"2025-07-18",{"_98":106,"_100":41},{"_98":124,"_100":129},662,{"_98":126,"_100":131},3,"snapshot","ogImage","https://cdn.dev.fun/og/image/228d71414837bf2da587/0af2be54.webp","isDevbase","commitDetail","livestream","actionData","errors"]

{room.name}

Contacts

{contact.name}

{selectedChat.name}

Stream Connection Issue

\n \n Active Streams\n

Create New Chat Room

Send a Tip 🔥

\n \n CORS Access Required\n

\n \n Start Live Stream\n

\n \n Stream Created!\n

\n \n Troubleshooting Connection Issues:\n

UNMODERATED SPACE

Stream Not Found

Possible reasons:

\n

\n