import React, { useState, useEffect, useRef } from "react"; import { callAI } from "call-ai"; import { useFireproof } from "use-fireproof"; export default function AuroraSafe() { const { database, useLiveQuery, useDocument } = useFireproof("aurora-safe-ai"); const [currentStep, setCurrentStep] = useState(0); const [breathCount, setBreathCount] = useState(0); const [isBreathing, setIsBreathing] = useState(false); const [chatMessages, setChatMessages] = useState([]); const [userInput, setUserInput] = useState(""); const [isTyping, setIsTyping] = useState(false); const [threatLevel, setThreatLevel] = useState(null); const [actionPlan, setActionPlan] = useState(null); const [analysisComplete, setAnalysisComplete] = useState(false); const canvasRef = useRef(null); const chatEndRef = useRef(null); const fileInputRef = useRef(null); const { doc: activeSession, merge: mergeSession, save: saveSession } = useDocument({ type: "session", startTime: Date.now(), completed: false, threatLevel: null, actionItems: [], }); const { docs: sessions } = useLiveQuery("type", { key: "session", descending: true, limit: 10 }) || { docs: [] }; const { docs: evidence } = useLiveQuery("type", { key: "evidence" }) || { docs: [] }; const { docs: aiInsights } = useLiveQuery("type", { key: "ai-insight", descending: true, limit: 5 }) || { docs: [] }; // Animated aurora background with particle system useEffect(() => { const canvas = canvasRef.current; if (!canvas) return; const ctx = canvas.getContext("2d"); const setCanvasSize = () => { canvas.width = window.innerWidth; canvas.height = window.innerHeight; }; setCanvasSize(); window.addEventListener("resize", setCanvasSize); let animationId; let time = 0; const particles = []; // Create floating particles for (let i = 0; i < 30; i++) { particles.push({ x: Math.random() * canvas.width, y: Math.random() * canvas.height, radius: Math.random() * 3 + 1, speedX: (Math.random() - 0.5) * 0.5, speedY: (Math.random() - 0.5) * 0.5, opacity: Math.random() * 0.5 + 0.3, }); } const animate = () => { time += 0.003; ctx.clearRect(0, 0, canvas.width, canvas.height); // Gradient base const gradient = ctx.createLinearGradient(0, 0, canvas.width, canvas.height); gradient.addColorStop(0, `rgba(255, 182, 193, ${0.15 + Math.sin(time) * 0.05})`); gradient.addColorStop(0.5, `rgba(221, 160, 221, ${0.2 + Math.cos(time * 0.8) * 0.05})`); gradient.addColorStop(1, `rgba(147, 112, 219, ${0.15 + Math.sin(time * 1.2) * 0.05})`); ctx.fillStyle = gradient; ctx.fillRect(0, 0, canvas.width, canvas.height); // Flowing waves for (let i = 0; i < 3; i++) { ctx.beginPath(); const offset = i * 120; const waveHeight = canvas.height * 0.3; const waveY = canvas.height * 0.5 + Math.sin(time + i * 0.5) * 50; for (let x = 0; x <= canvas.width; x += 10) { const y = waveY + Math.sin(x * 0.01 + time + offset) * waveHeight; if (x === 0) ctx.moveTo(x, y); else ctx.lineTo(x, y); } ctx.lineTo(canvas.width, canvas.height); ctx.lineTo(0, canvas.height); ctx.closePath(); const waveGradient = ctx.createLinearGradient(0, waveY - waveHeight, 0, waveY + waveHeight); waveGradient.addColorStop(0, `rgba(255, 182, 193, ${0.1 - i * 0.02})`); waveGradient.addColorStop(1, `rgba(147, 112, 219, ${0.15 - i * 0.03})`); ctx.fillStyle = waveGradient; ctx.fill(); } // Animated particles particles.forEach((particle) => { particle.x += particle.speedX; particle.y += particle.speedY; if (particle.x < 0 || particle.x > canvas.width) particle.speedX *= -1; if (particle.y < 0 || particle.y > canvas.height) particle.speedY *= -1; ctx.beginPath(); ctx.arc(particle.x, particle.y, particle.radius, 0, Math.PI * 2); ctx.fillStyle = `rgba(221, 160, 221, ${particle.opacity})`; ctx.fill(); }); animationId = requestAnimationFrame(animate); }; animate(); return () => { cancelAnimationFrame(animationId); window.removeEventListener("resize", setCanvasSize); }; }, []); // Auto-scroll chat useEffect(() => { chatEndRef.current?.scrollIntoView({ behavior: "smooth" }); }, [chatMessages]); // Breathing exercise useEffect(() => { if (!isBreathing) return; const timer = setInterval(() => { setBreathCount((prev) => { if (prev >= 5) { setIsBreathing(false); return prev; } return prev + 1; }); }, 4000); return () => clearInterval(timer); }, [isBreathing]); const startSession = async () => { await saveSession(); setCurrentStep(1); }; const startBreathing = () => { setIsBreathing(true); setBreathCount(0); }; const getBreathingPhase = () => { const totalTime = breathCount * 4000; const phase = (Date.now() % 4000) / 1000; if (phase < 1) return "Breathe in slowly..."; if (phase < 2) return "Hold gently..."; if (phase < 3) return "Breathe out completely..."; return "Rest..."; }; // AI Chat System const sendMessage = async (message) => { if (!message.trim() && !fileInputRef.current?.files.length) return; const newMessage = { role: "user", content: message.trim(), timestamp: Date.now(), }; setChatMessages((prev) => [...prev, newMessage]); setUserInput(""); setIsTyping(true); try { const conversationHistory = chatMessages.map((msg) => ({ role: msg.role, content: msg.content, })); conversationHistory.push({ role: "user", content: message.trim(), }); // Get AI response with empathetic crisis counseling const aiResponse = await callAI( [ { role: "system", content: `You are Aurora, an empathetic AI crisis counselor specializing in digital blackmail and sextortion cases. Your role is to: 1. Provide immediate emotional support and validation 2. Ask clarifying questions to understand the situation 3. Offer practical, actionable advice 4. NEVER judge or blame the victim 5. Prioritize safety and evidence preservation 6. Speak warmly but professionally, like a trusted friend 7. Keep responses concise (2-3 sentences max) unless providing detailed steps 8. If user shares specific threats, acknowledge the seriousness and guide them toward documentation Remember: The person is scared and vulnerable. Be their anchor of calm and strength.`, }, ...conversationHistory, ], { stream: false } ); const assistantMessage = { role: "assistant", content: aiResponse, timestamp: Date.now(), }; setChatMessages((prev) => [...prev, assistantMessage]); // Save the conversation await database.put({ type: "chat-message", sessionId: activeSession._id, messages: [newMessage, assistantMessage], timestamp: Date.now(), }); } catch (error) { const errorMessage = { role: "assistant", content: "I'm here with you, even though I'm having trouble connecting right now. Let's try again, or you can reach out to the crisis hotline at 988.", timestamp: Date.now(), }; setChatMessages((prev) => [...prev, errorMessage]); } finally { setIsTyping(false); } }; // AI Threat Analysis const analyzeThreat = async () => { setIsTyping(true); setAnalysisComplete(false); try { const conversationText = chatMessages .filter((m) => m.role === "user") .map((m) => m.content) .join(" "); const analysisPrompt = `Based on this situation: "${conversationText}" Analyze the threat level and provide structured guidance:`; const analysis = await callAI(analysisPrompt, { schema: { properties: { threatLevel: { type: "string", description: "LOW, MODERATE, HIGH, or CRITICAL", }, riskFactors: { type: "array", items: { type: "string" }, description: "List of identified risk factors", }, immediateActions: { type: "array", items: { type: "string" }, description: "Prioritized action steps", }, recommendedResources: { type: "array", items: { type: "string" }, description: "Specific organizations or hotlines", }, legalConsiderations: { type: "string", description: "Brief legal guidance", }, emotionalSupport: { type: "string", description: "Validating message for the user", }, }, }, }); const parsedAnalysis = JSON.parse(analysis); setThreatLevel(parsedAnalysis.threatLevel); setActionPlan(parsedAnalysis); // Save AI insight await database.put({ type: "ai-insight", sessionId: activeSession._id, analysis: parsedAnalysis, timestamp: Date.now(), }); setAnalysisComplete(true); } catch (error) { console.error("Analysis error:", error); setThreatLevel("MODERATE"); setActionPlan({ threatLevel: "MODERATE", riskFactors: ["Unable to complete analysis"], immediateActions: ["Contact crisis support at 988", "Document evidence", "Block contact"], recommendedResources: ["Crisis Text Line", "RAINN", "Cyber Civil Rights Initiative"], legalConsiderations: "Consider consulting with a lawyer about your options.", emotionalSupport: "You're taking important steps to protect yourself.", }); setAnalysisComplete(true); } finally { setIsTyping(false); } }; // Evidence capture with screenshot const handleFileUpload = async (e) => { const files = e.target.files; if (!files.length) return; for (const file of files) { await database.put({ type: "evidence", sessionId: activeSession._id, _files: { screenshot: file }, timestamp: Date.now(), description: "Evidence screenshot", }); } setChatMessages((prev) => [ ...prev, { role: "assistant", content: `I've securely saved ${files.length} evidence file(s). They're encrypted and stored only on your device. Well done taking this important step.`, timestamp: Date.now(), }, ]); }; const getThreatColor = (level) => { switch (level) { case "LOW": return "from-[#9370db] to-[#dda0dd]"; case "MODERATE": return "from-[#ffb6c1] to-[#dda0dd]"; case "HIGH": return "from-[#ff8fa3] to-[#ffb6c1]"; case "CRITICAL": return "from-[#ff6b9d] to-[#ff8fa3]"; default: return "from-[#9370db] to-[#dda0dd]"; } }; return (

You're safe now

AI Analysis

Real-Time Support

Evidence Vault

📊 Your Journey

💡 Latest AI Insight

Let's Pause Together

Talk to Aurora AI

Hi, I'm Aurora

🧠 AI Analysis Complete

⚠️ Risk Factors

⚖️ Legal Notes

✓ Your Action Plan

You Don't Have to Face This Alone

🎯 Recommended For You

🚨 CRISIS: Call 988 Now

🛡️ Cyber Civil Rights Initiative

💪 RAINN

🔍 FBI Sextortion Resources

💬 What to Tell Them

You're Taking Your Power Back

Remember: