-
-
-
RedCalibur
-
Red Teaming AI — Recon, Scan, Report
-
-
- API
-
+const Header = ({ palette, setPalette, fx, setFx, apiStatus }) => {
+ const [openFx, setOpenFx] = useState(false)
+ return (
+
+
+
+
+
RedCalibur
+
Red Teaming AI — Recon, Scan, Report
+
+
+
+ API: {apiStatus}
+
+
+
+
+ {openFx && (
+
+
Effects
+
+ {Object.keys(fx).map(key => (
+
+ ))}
+
+
+
+
+
+ )}
+
+
-
-)
+
+ )
+}
export default function App() {
const [loading, setLoading] = useState(false)
@@ -35,115 +66,128 @@ export default function App() {
const [logs, setLogs] = useState([])
const [apiStatus, setApiStatus] = useState('unknown')
- const api = useMemo(() => ({
- post: async (path, body, { updateResult = true } = {}) => {
+ const defaultFx = { matrix:true,constellation:true,ripple:true,mouseTrail:true,noise:true,scanlines:true,sweep:true,vignette:true,parallax:true }
+ const [palette, setPalette] = useState(() => (typeof window==='undefined' ? 'red' : (localStorage.getItem('rc_palette')||'red')))
+ const [fx, setFx] = useState(() => {
+ if (typeof window==='undefined') return defaultFx
+ try {
+ const saved = JSON.parse(localStorage.getItem('rc_fx')||'null')
+ return saved && typeof saved==='object' ? { ...defaultFx, ...saved } : defaultFx
+ } catch { return defaultFx }
+ })
+ const [showSummary, setShowSummary] = useState(false)
+ const [summaryText, setSummaryText] = useState('')
+ const [summaryLoading, setSummaryLoading] = useState(false)
+
+ useEffect(() => {
+ const root = document.documentElement
+ if (palette==='blue') {
+ root.style.setProperty('--primary-rgb','59,130,246')
+ root.style.setProperty('--secondary-rgb','244,63,94')
+ } else {
+ root.style.setProperty('--primary-rgb','244,63,94')
+ root.style.setProperty('--secondary-rgb','59,130,246')
+ }
+ try { localStorage.setItem('rc_palette', palette) } catch {}
+ }, [palette])
+
+ useEffect(() => { try { localStorage.setItem('rc_fx', JSON.stringify(fx)) } catch {} }, [fx])
+
+ const api = useMemo(()=>({
+ post: async (path, body, {updateResult=true}={}) => {
setLoading(true)
const start = performance.now()
try {
- const res = await fetch(`${API_BASE}${path}`, {
- method: 'POST',
- headers: { 'Content-Type': 'application/json' },
- body: JSON.stringify(body)
- })
- const json = await res.json()
- if (!res.ok) throw new Error(json?.detail || 'Request failed')
+ const res = await fetch(`${API_BASE}${path}`, { method:'POST', headers:{'Content-Type':'application/json'}, body: JSON.stringify(body) })
+ const json = await res.json(); if (!res.ok) throw new Error(json?.detail||'Request failed')
if (updateResult) setResult(json)
- setLogs(l => [{ time: new Date().toLocaleTimeString(), path, ok: true, ms: Math.round(performance.now() - start) }, ...l])
+ setLogs(l=>[{ time:new Date().toLocaleTimeString(), path, ok:true, ms:Math.round(performance.now()-start) }, ...l])
return json
- } catch (e) {
- setLogs(l => [{ time: new Date().toLocaleTimeString(), path, ok: false, error: e.message }, ...l])
+ } catch(e) {
+ setLogs(l=>[{ time:new Date().toLocaleTimeString(), path, ok:false, error:e.message }, ...l])
throw e
- } finally {
- setLoading(false)
- }
+ } finally { setLoading(false) }
}
}), [])
- // API health probe
- useEffect(() => {
- let mounted = true
- const ping = async () => {
- try {
- const res = await fetch(`${API_BASE}/health`)
- if (!mounted) return
- setApiStatus(res.ok ? 'ok' : 'down')
- } catch {
- if (!mounted) return
- setApiStatus('down')
- }
- }
- ping()
- const id = setInterval(ping, 10000)
- return () => { mounted = false; clearInterval(id) }
- }, [])
+ useEffect(()=>{
+ let mounted=true
+ const ping=async()=>{ try{ const res=await fetch(`${API_BASE}/health`); if(!mounted) return; setApiStatus(res.ok?'ok':'down') } catch { if(!mounted) return; setApiStatus('down') } }
+ ping(); const id=setInterval(ping,10000); return ()=>{mounted=false; clearInterval(id)}
+ },[])
return (
-
-
+
+
+
-
- api.post('/domain', data)} loading={loading} />
-
-
- api.post('/scan', data)} loading={loading} />
-
-
- api.post('/username', data)} loading={loading} />
-
-
- api.post('/urlscan', data)} loading={loading} />
-
+ api.post('/domain', data)} loading={loading} />
+ api.post('/scan', data)} loading={loading} />
+ api.post('/username', data)} loading={loading} />
+ api.post('/urlscan', data)} loading={loading} />
-
{result ? : }
{result && (
-
+
)}
-
+
+ {showSummary && (
+
+
setShowSummary(false)} />
+
+
+
AI Summary
+
+
+
+
+
+
+ {summaryLoading ? 'Summarizing…' : (summaryText ? (
+
,
+ h2:({node,...props})=> ,
+ h3:({node,...props})=> ,
+ p: ({node,...props})=> ,
+ ul:({node,...props})=> ,
+ ol:({node,...props})=>
,
+ code:({inline,...props})=> inline?
+ ) : 'No content')}
+
+
+
+ )}
)
}
+
diff --git a/frontend/src/components/FX.jsx b/frontend/src/components/FX.jsx
new file mode 100644
index 0000000..9fac26c
--- /dev/null
+++ b/frontend/src/components/FX.jsx
@@ -0,0 +1,481 @@
+import React, { useEffect, useMemo, useRef, useState } from 'react'
+
+// helper to build rgba from an "r,g,b" base string
+function rgba(base, a) {
+ return `rgba(${base},${a})`
+}
+
+export function CursorGlow({ color = 'rgba(244,63,94,0.35)' }) {
+ const ref = useRef(null)
+ useEffect(() => {
+ const el = ref.current
+ if (!el) return
+ let raf
+ const onMove = (e) => {
+ const x = e.clientX
+ const y = e.clientY
+ // slight easing for smoothness
+ cancelAnimationFrame(raf)
+ raf = requestAnimationFrame(() => {
+ el.style.transform = `translate(${x - 150}px, ${y - 150}px)`
+ })
+ }
+ window.addEventListener('mousemove', onMove, { passive: true })
+ return () => {
+ cancelAnimationFrame(raf)
+ window.removeEventListener('mousemove', onMove)
+ }
+ }, [])
+ return (
+
+ )
+}
+
+// Draw a smooth line trail that follows the mouse and fades over time
+export function MouseTrail({ enabled = true, colorBase = '244,63,94', glowBase = '59,130,246' }) {
+ const canvasRef = useRef(null)
+ const reduced = usePrefersReducedMotionBool()
+ useEffect(() => {
+ if (!enabled || reduced) return
+ const canvas = canvasRef.current
+ if (!canvas) return
+ const ctx = canvas.getContext('2d')
+ let width = (canvas.width = window.innerWidth)
+ let height = (canvas.height = window.innerHeight)
+
+ // trail points with timestamp
+ const points = []
+ const MAX_AGE = 700 // ms
+ const SMOOTHING = 0.15 // interpolation for the virtual cursor
+ const MAX_POINTS = 120 // cap for performance
+ let vx = width / 2,
+ vy = height / 2
+
+ const onResize = () => {
+ width = canvas.width = window.innerWidth
+ height = canvas.height = window.innerHeight
+ }
+ const onMove = (e) => {
+ // ease a virtual cursor towards the actual cursor for smoothness
+ const tx = e.clientX
+ const ty = e.clientY
+ vx += (tx - vx) * SMOOTHING
+ vy += (ty - vy) * SMOOTHING
+ points.push({ x: vx, y: vy, t: performance.now() })
+ if (points.length > MAX_POINTS) points.shift()
+ }
+ window.addEventListener('resize', onResize)
+ window.addEventListener('mousemove', onMove, { passive: true })
+
+ let raf
+ const draw = () => {
+ const now = performance.now()
+ // fade previous strokes by reducing alpha, without painting any color
+ ctx.save()
+ ctx.globalCompositeOperation = 'destination-out'
+ ctx.fillStyle = 'rgba(0,0,0,0.06)'
+ ctx.fillRect(0, 0, width, height)
+ ctx.restore()
+
+ // remove old points
+ for (let i = points.length - 1; i >= 0; i--) {
+ if (now - points[i].t > MAX_AGE) points.splice(i, 1)
+ }
+
+ if (points.length > 1) {
+ // draw a smoothed polyline using quadratic curves
+ ctx.lineCap = 'round'
+ ctx.lineJoin = 'round'
+
+ for (let i = 1; i < points.length; i++) {
+ const p0 = points[i - 1]
+ const p1 = points[i]
+ const age = now - p1.t
+ const life = 1 - Math.min(age / MAX_AGE, 1)
+ const alpha = life * 0.9
+ const widthScale = 1 + life * 3 // thicker when fresh
+ ctx.strokeStyle = rgba(colorBase, alpha)
+ ctx.lineWidth = 1.2 * widthScale
+ ctx.beginPath()
+ // control point halfway for a smooth curve
+ const cx = (p0.x + p1.x) / 2
+ const cy = (p0.y + p1.y) / 2
+ ctx.moveTo(p0.x, p0.y)
+ ctx.quadraticCurveTo(cx, cy, p1.x, p1.y)
+ ctx.stroke()
+ }
+
+ // subtle outer glow pass using additive blend
+ ctx.save()
+ ctx.globalCompositeOperation = 'lighter'
+ for (let i = 1; i < points.length; i++) {
+ const p0 = points[i - 1]
+ const p1 = points[i]
+ const age = now - p1.t
+ const life = 1 - Math.min(age / MAX_AGE, 1)
+ const alpha = life * 0.25
+ ctx.strokeStyle = rgba(glowBase, alpha)
+ ctx.lineWidth = 2.5
+ ctx.beginPath()
+ const cx = (p0.x + p1.x) / 2
+ const cy = (p0.y + p1.y) / 2
+ ctx.moveTo(p0.x, p0.y)
+ ctx.quadraticCurveTo(cx, cy, p1.x, p1.y)
+ ctx.stroke()
+ }
+ ctx.restore()
+ }
+
+ raf = requestAnimationFrame(draw)
+ }
+ draw()
+
+ return () => {
+ cancelAnimationFrame(raf)
+ window.removeEventListener('resize', onResize)
+ window.removeEventListener('mousemove', onMove)
+ }
+ }, [enabled])
+
+ return (
+
+ )
+}
+
+export function Scanlines() {
+ return (
+
+ )
+}
+
+export function Noise() {
+ // CSS-animated noise using background-position jitter
+ return (
+
+ )
+}
+
+function usePrefersReducedMotion() {
+ return useMemo(() =>
+ typeof window !== 'undefined' && window.matchMedia && window.matchMedia('(prefers-reduced-motion: reduce)').matches
+ , [])
+}
+
+export function MatrixRain({ enabled = true }) {
+ const canvasRef = useRef(null)
+ const reduced = usePrefersReducedMotion()
+ const colorBase = arguments[0]?.colorBase || '244,63,94'
+
+ useEffect(() => {
+ if (!enabled || reduced) return
+ const canvas = canvasRef.current
+ if (!canvas) return
+ const ctx = canvas.getContext('2d')
+ let width = canvas.width = window.innerWidth
+ let height = canvas.height = window.innerHeight
+ let animationFrame
+ const fontSize = 14
+ const columns = Math.floor(width / fontSize)
+ const drops = new Array(columns).fill(1)
+
+ const onResize = () => {
+ width = canvas.width = window.innerWidth
+ height = canvas.height = window.innerHeight
+ }
+ window.addEventListener('resize', onResize)
+
+ const draw = () => {
+ // translucent background for trail effect
+ ctx.fillStyle = 'rgba(0,0,0,0.08)'
+ ctx.fillRect(0, 0, width, height)
+ ctx.fillStyle = rgba(colorBase, 0.65)
+ ctx.font = `${fontSize}px monospace`
+ for (let i = 0; i < drops.length; i++) {
+ const text = String.fromCharCode(0x30A0 + Math.random() * 96)
+ const x = i * fontSize
+ const y = drops[i] * fontSize
+ ctx.fillText(text, x, y)
+ if (y > height && Math.random() > 0.975) drops[i] = 0
+ drops[i]++
+ }
+ animationFrame = requestAnimationFrame(draw)
+ }
+ draw()
+
+ return () => {
+ cancelAnimationFrame(animationFrame)
+ window.removeEventListener('resize', onResize)
+ }
+ }, [enabled, reduced])
+
+ return (
+
+ )
+}
+
+function usePrefersReducedMotionBool() {
+ if (typeof window === 'undefined' || !window.matchMedia) return false
+ return window.matchMedia('(prefers-reduced-motion: reduce)').matches
+}
+
+export function Constellation({ enabled = true, colorBase = '244,63,94' }) {
+ const canvasRef = useRef(null)
+ const reduced = usePrefersReducedMotionBool()
+ useEffect(() => {
+ if (!enabled || reduced) return
+ const canvas = canvasRef.current
+ if (!canvas) return
+ const ctx = canvas.getContext('2d')
+ let width = canvas.width = window.innerWidth
+ let height = canvas.height = window.innerHeight
+ const particles = []
+ const count = Math.min(120, Math.floor((width * height) / 18000))
+ const mouse = { x: width / 2, y: height / 2 }
+ for (let i = 0; i < count; i++) {
+ particles.push({
+ x: Math.random() * width,
+ y: Math.random() * height,
+ vx: (Math.random() - 0.5) * 0.3,
+ vy: (Math.random() - 0.5) * 0.3
+ })
+ }
+ const onMove = (e) => { mouse.x = e.clientX; mouse.y = e.clientY }
+ const onResize = () => { width = canvas.width = window.innerWidth; height = canvas.height = window.innerHeight }
+ window.addEventListener('mousemove', onMove, { passive: true })
+ window.addEventListener('resize', onResize)
+ let raf
+ const draw = () => {
+ ctx.clearRect(0, 0, width, height)
+ // draw lines
+ for (let i = 0; i < particles.length; i++) {
+ const p = particles[i]
+ // slight attraction to mouse
+ const dx = mouse.x - p.x
+ const dy = mouse.y - p.y
+ p.vx += (dx / 50000)
+ p.vy += (dy / 50000)
+ p.x += p.vx
+ p.y += p.vy
+ if (p.x < 0 || p.x > width) p.vx *= -1
+ if (p.y < 0 || p.y > height) p.vy *= -1
+ }
+ ctx.lineWidth = 1
+ for (let i = 0; i < particles.length; i++) {
+ for (let j = i + 1; j < particles.length; j++) {
+ const a = particles[i], b = particles[j]
+ const dx = a.x - b.x, dy = a.y - b.y
+ const dist2 = dx * dx + dy * dy
+ const maxDist2 = 90 * 90
+ if (dist2 < maxDist2) {
+ const alpha = 1 - dist2 / maxDist2
+ ctx.strokeStyle = rgba(colorBase, alpha * 0.35)
+ ctx.beginPath()
+ ctx.moveTo(a.x, a.y)
+ ctx.lineTo(b.x, b.y)
+ ctx.stroke()
+ }
+ }
+ }
+ // draw points
+ for (let i = 0; i < particles.length; i++) {
+ const p = particles[i]
+ ctx.fillStyle = rgba(colorBase, 0.7)
+ ctx.fillRect(p.x, p.y, 2, 2)
+ }
+ raf = requestAnimationFrame(draw)
+ }
+ draw()
+ return () => { cancelAnimationFrame(raf); window.removeEventListener('mousemove', onMove); window.removeEventListener('resize', onResize) }
+ }, [enabled])
+ return
+}
+
+export function ParallaxLayer() {
+ const ref = useRef(null)
+ useEffect(() => {
+ const el = ref.current
+ if (!el) return
+ let raf
+ const onMove = (e) => {
+ const x = (e.clientX / window.innerWidth - 0.5) * 8
+ const y = (e.clientY / window.innerHeight - 0.5) * 8
+ cancelAnimationFrame(raf)
+ raf = requestAnimationFrame(() => {
+ el.style.transform = `translate3d(${x}px, ${y}px, 0)`
+ })
+ }
+ window.addEventListener('mousemove', onMove, { passive: true })
+ return () => { cancelAnimationFrame(raf); window.removeEventListener('mousemove', onMove) }
+ }, [])
+ return (
+
+ )
+}
+
+export function SweepGlow() {
+ return (
+
+ )
+}
+
+export function Vignette() {
+ return (
+
+ )
+}
+
+export function RippleFX({ enabled = true }) {
+ const canvasRef = useRef(null)
+ const reduced = usePrefersReducedMotionBool()
+ useEffect(() => {
+ if (!enabled || reduced) return
+ const canvas = canvasRef.current
+ if (!canvas) return
+ const ctx = canvas.getContext('2d')
+ let width = canvas.width = window.innerWidth
+ let height = canvas.height = window.innerHeight
+ const ripples = []
+ const MAX_AGE = 1200 // ms
+ const SPEED = 0.6 // pixels per ms
+
+ const onResize = () => {
+ width = canvas.width = window.innerWidth
+ height = canvas.height = window.innerHeight
+ }
+ const onClick = (e) => {
+ ripples.push({ x: e.clientX, y: e.clientY, t: performance.now() })
+ }
+ window.addEventListener('resize', onResize)
+ window.addEventListener('mousedown', onClick)
+
+ let raf
+ const draw = () => {
+ const now = performance.now()
+ ctx.clearRect(0, 0, width, height)
+ ctx.globalCompositeOperation = 'lighter'
+ for (let i = ripples.length - 1; i >= 0; i--) {
+ const r = ripples[i]
+ const age = now - r.t
+ if (age > MAX_AGE) { ripples.splice(i, 1); continue }
+ const prog = age / MAX_AGE
+ const radius = age * SPEED
+ const alpha = (1 - prog) * 0.35
+
+ // outer soft glow
+ const grad = ctx.createRadialGradient(r.x, r.y, Math.max(radius - 40, 0), r.x, r.y, radius + 60)
+ grad.addColorStop(0, `rgba(244,63,94,${alpha * 0.35})`)
+ grad.addColorStop(0.5, `rgba(59,130,246,${alpha * 0.25})`)
+ grad.addColorStop(1, 'rgba(0,0,0,0)')
+ ctx.fillStyle = grad
+ ctx.beginPath()
+ ctx.arc(r.x, r.y, radius + 60, 0, Math.PI * 2)
+ ctx.fill()
+
+ // ring ripples
+ ctx.lineWidth = 2
+ const rings = 3
+ for (let k = 0; k < rings; k++) {
+ const ringR = radius - k * 24
+ if (ringR <= 0) continue
+ const a = Math.max(alpha - k * 0.08, 0)
+ ctx.strokeStyle = `rgba(244,63,94,${a})`
+ ctx.beginPath()
+ ctx.arc(r.x, r.y, ringR, 0, Math.PI * 2)
+ ctx.stroke()
+ }
+ }
+ ctx.globalCompositeOperation = 'source-over'
+ raf = requestAnimationFrame(draw)
+ }
+ draw()
+
+ return () => {
+ cancelAnimationFrame(raf)
+ window.removeEventListener('resize', onResize)
+ window.removeEventListener('mousedown', onClick)
+ }
+ }, [enabled])
+ return (
+
+ )
+}
+
+export default function VisualFX({
+ palette = 'red',
+ flags = {},
+ matrix = true,
+ noise = true,
+ scanlines = true,
+}) {
+ // color bases are simple "r,g,b" strings to combine with varying alpha
+ const colors = palette === 'blue'
+ ? { primary: '59,130,246', secondary: '244,63,94' }
+ : { primary: '244,63,94', secondary: '59,130,246' }
+ const [enableMatrix, setEnableMatrix] = useState(() => typeof window !== 'undefined' ? window.innerWidth >= 768 : true)
+ useEffect(() => {
+ const onResize = () => setEnableMatrix(window.innerWidth >= 768)
+ window.addEventListener('resize', onResize)
+ return () => window.removeEventListener('resize', onResize)
+ }, [])
+ return (
+ <>
+ {/* Base layers (furthest back) */}
+ {flags.parallax !== false &&
}
+ {flags.vignette !== false &&
}
+ {flags.sweep !== false &&
}
+ {(flags.matrix !== false && matrix) &&
}
+ {flags.constellation !== false &&
}
+ {flags.ripple !== false &&
}
+ {flags.mouseTrail !== false && (
+
+ )}
+ {(flags.noise !== false && noise) &&
}
+ {(flags.scanlines !== false && scanlines) &&
}
+
+ )
+}
diff --git a/frontend/src/styles.css b/frontend/src/styles.css
index 09a4198..ff583a7 100644
--- a/frontend/src/styles.css
+++ b/frontend/src/styles.css
@@ -2,9 +2,18 @@
@tailwind components;
@tailwind utilities;
+:root {
+ /* default palette = red primary, blue secondary */
+ --primary-rgb: 244,63,94; /* red */
+ --secondary-rgb: 59,130,246;/* blue */
+}
+
body {
- background-image: radial-gradient(circle at 1px 1px, rgba(244,63,94,0.2) 1px, transparent 0);
- background-size: 24px 24px;
+ background-image:
+ radial-gradient(circle at 1px 1px, rgba(var(--primary-rgb),0.18) 1px, transparent 0),
+ radial-gradient(1200px 800px at 80% -10%, rgba(var(--primary-rgb),0.08), transparent 60%),
+ radial-gradient(800px 600px at 10% 110%, rgba(var(--secondary-rgb),0.06), transparent 60%);
+ background-size: 24px 24px, auto, auto;
}
.card {
@@ -18,3 +27,68 @@ body {
.input {
@apply w-full px-3 py-2 bg-zinc-800 border border-zinc-700 rounded-lg text-gray-100 placeholder-gray-400 focus:outline-none focus:ring-2 focus:ring-redcalibur-600;
}
+
+/* glitch title effect */
+.glitch {
+ position: relative;
+ text-shadow: 0 0 12px rgba(244,63,94,0.5);
+}
+.glitch::before,
+.glitch::after {
+ content: attr(data-text);
+ position: absolute;
+ top: 0; left: 0;
+ width: 100%; height: 100%;
+ overflow: hidden;
+}
+.glitch::before {
+ left: 1px; text-shadow: -1px 0 rgba(59,130,246,0.6);
+ animation: glitch-shift 3s infinite linear alternate-reverse;
+}
+.glitch::after {
+ left: -1px; text-shadow: 1px 0 rgba(244,63,94,0.6);
+ animation: glitch-shift 2.2s infinite linear alternate;
+}
+@keyframes glitch-shift {
+ 0% { clip-path: inset(0 0 85% 0); }
+ 20% { clip-path: inset(0 0 20% 0); }
+ 40% { clip-path: inset(60% 0 0 0); }
+ 60% { clip-path: inset(0 0 65% 0); }
+ 80% { clip-path: inset(30% 0 0 0); }
+ 100% { clip-path: inset(0 0 0 0); }
+}
+
+/* animated noise overlay */
+.noise-overlay {
+ background-image: url('data:image/svg+xml;utf8,
');
+ animation: noise-move 1.5s steps(10) infinite;
+}
+@keyframes noise-move { from { background-position: 0 0; } to { background-position: 100% 100%; } }
+
+/* sweeping glow accent */
+.sweep-glow {
+ position: fixed;
+ inset: -20% -10% -20% -10%;
+ pointer-events: none;
+ z-index: 0;
+ background: conic-gradient(
+ from 0deg at 50% 50%,
+ transparent 0deg,
+ rgba(var(--primary-rgb),0.08) 90deg,
+ transparent 180deg,
+ rgba(var(--secondary-rgb),0.06) 270deg,
+ transparent 360deg
+ );
+ animation: sweep 14s linear infinite;
+ filter: blur(40px);
+}
+@keyframes sweep { to { transform: rotate(360deg); } }
+
+/* soft vignette to focus center */
+.vignette {
+ position: fixed;
+ inset: 0;
+ pointer-events: none;
+ z-index: 0;
+ background: radial-gradient(circle at 50% 50%, transparent 60%, rgba(0,0,0,0.6) 100%);
+}
diff --git a/frontend/vite.config.js b/frontend/vite.config.js
index 610e72e..faca8c7 100644
--- a/frontend/vite.config.js
+++ b/frontend/vite.config.js
@@ -5,6 +5,7 @@ export default defineConfig({
plugins: [react()],
server: {
port: 5173,
+ host: '::',
proxy: {
'/api': {
target: 'http://127.0.0.1:8000',
diff --git a/package.json b/package.json
new file mode 100644
index 0000000..e9b657b
--- /dev/null
+++ b/package.json
@@ -0,0 +1,9 @@
+{
+ "name": "redcalibur-monorepo",
+ "private": true,
+ "scripts": {
+ "dev": "npm run dev --prefix frontend",
+ "build": "npm run build --prefix frontend",
+ "preview": "npm run preview --prefix frontend"
+ }
+}
diff --git a/redcalibur/osint/domain_infrastructure/dns_enumeration.py b/redcalibur/osint/domain_infrastructure/dns_enumeration.py
index c5d96f0..24f0204 100755
--- a/redcalibur/osint/domain_infrastructure/dns_enumeration.py
+++ b/redcalibur/osint/domain_infrastructure/dns_enumeration.py
@@ -4,6 +4,7 @@
def _resolver(nameservers=None, timeout=5.0):
r = dns.resolver.Resolver(configure=True)
+ r.timeout = float(timeout)
r.lifetime = float(timeout)
if nameservers:
r.nameservers = nameservers
diff --git a/redcalibur/osint/domain_infrastructure/port_scanning.py b/redcalibur/osint/domain_infrastructure/port_scanning.py
index 5786c11..c17eff1 100755
--- a/redcalibur/osint/domain_infrastructure/port_scanning.py
+++ b/redcalibur/osint/domain_infrastructure/port_scanning.py
@@ -15,8 +15,11 @@ def perform_port_scan(target, ports):
for port in ports:
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
- s.settimeout(1)
- result = s.connect_ex((target, port))
- port_status[port] = "Open" if result == 0 else "Closed"
+ s.settimeout(0.6)
+ try:
+ result = s.connect_ex((target, port))
+ port_status[port] = "Open" if result == 0 else "Closed"
+ except Exception as e:
+ port_status[port] = f"Error: {e}"
return port_status
diff --git a/redcalibur/osint/domain_infrastructure/subdomain_discovery.py b/redcalibur/osint/domain_infrastructure/subdomain_discovery.py
index c986172..a319403 100755
--- a/redcalibur/osint/domain_infrastructure/subdomain_discovery.py
+++ b/redcalibur/osint/domain_infrastructure/subdomain_discovery.py
@@ -1,25 +1,45 @@
import requests
+from concurrent.futures import ThreadPoolExecutor, as_completed
-def discover_subdomains(domain, subdomain_list):
+def discover_subdomains(domain, subdomain_list, timeout: float = 2.0, workers: int = 8):
"""
Discover subdomains for the given domain using a wordlist.
Args:
domain (str): The domain name to search.
subdomain_list (list): A list of potential subdomains.
+ timeout (float): Per-request timeout seconds.
+ workers (int): Number of parallel workers.
Returns:
- list: A list of discovered subdomains.
+ list: A list of discovered subdomains (URLs).
"""
discovered_subdomains = []
- for subdomain in subdomain_list:
- url = f"http://{subdomain}.{domain}"
+ def probe(sub: str):
+ url = f"http://{sub}.{domain}"
try:
- response = requests.get(url)
- if response.status_code == 200:
- discovered_subdomains.append(url)
- except requests.ConnectionError:
- pass
+ # HEAD is lighter; some hosts may not support it, so fallback to GET
+ resp = requests.head(url, timeout=timeout, allow_redirects=True)
+ if resp.status_code < 400:
+ return url
+ # Fallback to GET if HEAD inconclusive
+ resp = requests.get(url, timeout=timeout, allow_redirects=True)
+ if resp.status_code < 400:
+ return url
+ except requests.RequestException:
+ return None
+ return None
+
+ with ThreadPoolExecutor(max_workers=max(1, workers)) as ex:
+ futures = {ex.submit(probe, sub): sub for sub in subdomain_list}
+ for fut in as_completed(futures):
+ try:
+ res = fut.result()
+ if res:
+ discovered_subdomains.append(res)
+ except Exception:
+ # ignore individual probe failures
+ pass
return discovered_subdomains
diff --git a/redcalibur/osint/domain_infrastructure/whois_lookup.py b/redcalibur/osint/domain_infrastructure/whois_lookup.py
index e93f168..e2576b7 100755
--- a/redcalibur/osint/domain_infrastructure/whois_lookup.py
+++ b/redcalibur/osint/domain_infrastructure/whois_lookup.py
@@ -2,7 +2,7 @@
import whois
import requests
-def perform_whois_lookup(domain):
+def perform_whois_lookup(domain, timeout: float = 6.0):
"""
Perform a WHOIS lookup for the given domain.
@@ -13,6 +13,7 @@ def perform_whois_lookup(domain):
dict: A dictionary containing WHOIS information.
"""
try:
+ # whois module doesn't support timeout directly; rely on its internal defaults
whois_info = whois.whois(domain)
if isinstance(whois_info, dict):
return whois_info
@@ -20,7 +21,7 @@ def perform_whois_lookup(domain):
except Exception as e:
# Fallback to RDAP if whois fails
try:
- resp = requests.get(f"https://rdap.org/domain/{domain}", timeout=8)
+ resp = requests.get(f"https://rdap.org/domain/{domain}", timeout=max(2.0, timeout))
if resp.ok:
data = resp.json()
return {"rdap": data, "whois_error": str(e)}
diff --git a/redcalibur/osint/shodan_integration.py b/redcalibur/osint/shodan_integration.py
index 55d89c9..782a0b0 100755
--- a/redcalibur/osint/shodan_integration.py
+++ b/redcalibur/osint/shodan_integration.py
@@ -12,10 +12,14 @@ def search_shodan(api_key: str, query: str):
try:
results = api.search(query)
- print(f"Results found: {results['total']}")
- for result in results['matches']:
- print(f"IP: {result['ip_str']}")
- print(result['data'])
+ total = results.get('total', 0) if isinstance(results, dict) else 0
+ print(f"Results found: {total}")
+ for result in results.get('matches', []) if isinstance(results, dict) else []:
+ ip = result.get('ip_str', 'unknown')
+ print(f"IP: {ip}")
+ banner = result.get('data')
+ if banner:
+ print(banner)
print("")
return results
@@ -35,13 +39,13 @@ def get_host_info(api_key: str, ip: str):
try:
host = api.host(ip)
- print(f"IP: {host['ip_str']}")
+ print(f"IP: {host.get('ip_str', ip)}")
print(f"Organization: {host.get('org', 'n/a')}")
print(f"Operating System: {host.get('os', 'n/a')}")
- for item in host['data']:
- print(f"Port: {item['port']}")
- print(f"Banner: {item['data']}")
+ for item in host.get('data', []) if isinstance(host, dict) else []:
+ print(f"Port: {item.get('port', 'n/a')}")
+ print(f"Banner: {item.get('data', '')}")
return host
except shodan.APIError as e:
diff --git a/redcalibur/osint/url_health_check.py b/redcalibur/osint/url_health_check.py
new file mode 100644
index 0000000..afaa80a
--- /dev/null
+++ b/redcalibur/osint/url_health_check.py
@@ -0,0 +1,31 @@
+import requests
+from urllib.parse import urlparse
+
+DEFAULT_TIMEOUT = 6.0
+
+
+def normalize_url(url: str) -> str:
+ if not url.lower().startswith(("http://", "https://")):
+ return "http://" + url
+ return url
+
+
+def basic_url_health(url: str) -> dict:
+ """
+ Lightweight URL health check used when VirusTotal is unavailable.
+ Returns status code, final URL, and a small set of headers.
+ """
+ out = {"input": url}
+ try:
+ url = normalize_url(url)
+ resp = requests.get(url, timeout=DEFAULT_TIMEOUT, allow_redirects=True, headers={
+ "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127 Safari/537.36"
+ })
+ out.update({
+ "status": resp.status_code,
+ "final_url": resp.url,
+ "headers": {k: v for k, v in resp.headers.items() if k.lower() in {"server", "content-type", "x-frame-options", "strict-transport-security"}},
+ })
+ except requests.RequestException as e:
+ out["error"] = str(e)
+ return out
diff --git a/redcalibur/osint/user_identity/username_lookup.py b/redcalibur/osint/user_identity/username_lookup.py
index ed25e7c..bae7919 100755
--- a/redcalibur/osint/user_identity/username_lookup.py
+++ b/redcalibur/osint/user_identity/username_lookup.py
@@ -1,45 +1,72 @@
-import requests
-import subprocess
-import json
import logging
+from concurrent.futures import ThreadPoolExecutor, as_completed
+from typing import Dict, List
+import requests
# Initialize logger
logger = logging.getLogger("username_lookup")
-logging.basicConfig(level=logging.DEBUG)
+if not logger.handlers:
+ logging.basicConfig(level=logging.INFO)
+
+USER_AGENT = (
+ "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 "
+ "(KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36"
+)
+
+# Simple platform URL patterns; can be extended
+PLATFORM_URLS: Dict[str, str] = {
+ "twitter": "https://twitter.com/{username}",
+ "instagram": "https://www.instagram.com/{username}/",
+ "github": "https://github.com/{username}",
+ "linkedin": "https://www.linkedin.com/in/{username}/",
+ "reddit": "https://www.reddit.com/user/{username}/",
+ "medium": "https://medium.com/@{username}",
+}
-def lookup_username(username, platforms):
+def _probe_profile(url: str, timeout: float = 3.0) -> bool:
+ try:
+ resp = requests.get(url, headers={"User-Agent": USER_AGENT}, timeout=timeout, allow_redirects=True)
+ # Basic heuristic: 200 => exists; certain platforms (LinkedIn) may return 999/other codes for blocked
+ if resp.status_code == 200:
+ return True
+ # Handle GitHub not found page (404)
+ if resp.status_code == 404:
+ return False
+ # Treat other codes as not found/blocked without failing
+ return False
+ except requests.RequestException as e:
+ logger.debug(f"Probe error for {url}: {e}")
+ return False
+
+def lookup_username(username: str, platforms: List[str]) -> Dict[str, str]:
"""
- Lookup a username across multiple platforms using Sherlock.
+ Lookup a username across multiple platforms via HTTP probes (no external CLI).
Args:
- username (str): The username to search for.
- platforms (list): A list of platforms to search on.
+ username: Username to check
+ platforms: List of platform keys, e.g., ["twitter","github"]
Returns:
- dict: A dictionary with platform names as keys and URLs as values.
+ dict mapping platform -> profile URL if found; otherwise 'not found'.
"""
- results = {}
+ results: Dict[str, str] = {}
- try:
- # Run Sherlock as a subprocess
- command = ["sherlock", username, "--print-found"]
- logger.debug(f"Running command: {' '.join(command)}")
- process = subprocess.run(command, capture_output=True, text=True)
-
- if process.returncode == 0:
- logger.debug("Sherlock executed successfully.")
- # Parse Sherlock's output
- for line in process.stdout.splitlines():
- logger.debug(f"Processing line: {line}")
- for platform in platforms:
- if platform in line:
- results[platform] = line.strip()
- else:
- logger.error(f"Sherlock error: {process.stderr.strip()}")
- results["error"] = process.stderr.strip()
-
- except Exception as e:
- logger.exception("Exception occurred during username lookup.")
- results["error"] = str(e)
+ tasks = {}
+ with ThreadPoolExecutor(max_workers=min(8, max(1, len(platforms)))) as ex:
+ for p in platforms:
+ template = PLATFORM_URLS.get(p.lower())
+ if not template:
+ results[p] = "unsupported platform"
+ continue
+ url = template.format(username=username)
+ tasks[ex.submit(_probe_profile, url)] = (p, url)
+
+ for fut in as_completed(tasks):
+ p, url = tasks[fut]
+ try:
+ exists = fut.result()
+ results[p] = url if exists else "not found"
+ except Exception as e:
+ results[p] = f"error: {e}"
return results
diff --git a/redcalibur/osint/virustotal_integration.py b/redcalibur/osint/virustotal_integration.py
index 8df8082..2c5d200 100755
--- a/redcalibur/osint/virustotal_integration.py
+++ b/redcalibur/osint/virustotal_integration.py
@@ -1,5 +1,7 @@
import requests
+DEFAULT_TIMEOUT = 8.0
+
def scan_url(api_key: str, url: str):
"""
Scan a URL using the VirusTotal API.
@@ -16,12 +18,13 @@ def scan_url(api_key: str, url: str):
"url": url
}
- response = requests.post(vt_url, headers=headers, data=data)
- if response.status_code == 200:
- return response.json()
- else:
- print(f"Error: {response.status_code} - {response.text}")
- return None
+ try:
+ response = requests.post(vt_url, headers=headers, data=data, timeout=DEFAULT_TIMEOUT)
+ if response.status_code == 200:
+ return response.json()
+ return {"error": "virustotal_error", "status": response.status_code, "body": response.text}
+ except Exception as e:
+ return {"error": str(e)}
def get_url_report(api_key: str, url_id: str):
"""
@@ -36,9 +39,10 @@ def get_url_report(api_key: str, url_id: str):
"x-apikey": api_key
}
- response = requests.get(vt_url, headers=headers)
- if response.status_code == 200:
- return response.json()
- else:
- print(f"Error: {response.status_code} - {response.text}")
- return None
+ try:
+ response = requests.get(vt_url, headers=headers, timeout=DEFAULT_TIMEOUT)
+ if response.status_code == 200:
+ return response.json()
+ return {"error": "virustotal_error", "status": response.status_code, "body": response.text}
+ except Exception as e:
+ return {"error": str(e)}
diff --git a/scripts/start_api.sh b/scripts/start_api.sh
new file mode 100755
index 0000000..a396cd0
--- /dev/null
+++ b/scripts/start_api.sh
@@ -0,0 +1,27 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")"/.. && pwd)"
+PID_FILE="/tmp/redcalibur_api.pid"
+LOG_FILE="/tmp/redcalibur_api.log"
+VENV_BIN="$ROOT_DIR/.venv/bin"
+PY="$VENV_BIN/python"
+
+if [ ! -x "$PY" ]; then
+ echo "Python venv not found at $PY. Create it and install deps first." >&2
+ exit 1
+fi
+
+if [ -f "$PID_FILE" ] && kill -0 "$(cat "$PID_FILE")" 2>/dev/null; then
+ echo "API already running with PID $(cat "$PID_FILE")." >&2
+ exit 0
+fi
+
+cd "$ROOT_DIR"
+# Load .env if present for environment variables
+set -a
+[ -f .env ] && source .env || true
+set +a
+
+nohup "$PY" -m uvicorn api.app:app --host 0.0.0.0 --port 8000 --workers 2 >"$LOG_FILE" 2>&1 & echo $! >"$PID_FILE"
+echo "API started. PID $(cat "$PID_FILE"). Logs: $LOG_FILE"
diff --git a/scripts/stop_api.sh b/scripts/stop_api.sh
new file mode 100755
index 0000000..5852dbd
--- /dev/null
+++ b/scripts/stop_api.sh
@@ -0,0 +1,22 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+PID_FILE="/tmp/redcalibur_api.pid"
+
+if [ ! -f "$PID_FILE" ]; then
+ echo "No PID file at $PID_FILE. Is the API running?" >&2
+ exit 0
+fi
+
+PID=$(cat "$PID_FILE")
+if kill -0 "$PID" 2>/dev/null; then
+ kill "$PID" || true
+ sleep 1
+ if kill -0 "$PID" 2>/dev/null; then
+ kill -9 "$PID" || true
+ fi
+ echo "Stopped API (PID $PID)."
+else
+ echo "Process $PID not running. Cleaning up PID file."
+fi
+rm -f "$PID_FILE"
diff --git a/tests/conftest.py b/tests/conftest.py
new file mode 100644
index 0000000..e3e249d
--- /dev/null
+++ b/tests/conftest.py
@@ -0,0 +1,8 @@
+import os
+import sys
+from pathlib import Path
+
+# Ensure project root is on sys.path so `import redcalibur` works
+ROOT = Path(__file__).resolve().parents[1]
+if str(ROOT) not in sys.path:
+ sys.path.insert(0, str(ROOT))
diff --git a/tests/test_basic_functionality.py b/tests/test_basic_functionality.py
index de660b1..fcb568e 100755
--- a/tests/test_basic_functionality.py
+++ b/tests/test_basic_functionality.py
@@ -2,8 +2,10 @@
import sys
import os
-# Add the package to the path
-sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..', 'redcalibur')))
+# Add project root to path so `import redcalibur` works
+ROOT = os.path.abspath(os.path.join(os.path.dirname(__file__), '..'))
+if ROOT not in sys.path:
+ sys.path.insert(0, ROOT)
from redcalibur.osint.domain_infrastructure.whois_lookup import perform_whois_lookup, is_valid_domain
from redcalibur.osint.domain_infrastructure.dns_enumeration import enumerate_dns_records