diff --git a/.zscripts/dev.pid b/.zscripts/dev.pid
index eb8e831..9437b2f 100755
--- a/.zscripts/dev.pid
+++ b/.zscripts/dev.pid
@@ -1 +1 @@
-1127
+1106
diff --git a/bin/yt-dlp b/bin/yt-dlp
new file mode 100755
index 0000000..a385dc1
Binary files /dev/null and b/bin/yt-dlp differ
diff --git a/src/app/api/audio/stream/route.ts b/src/app/api/audio/stream/route.ts
new file mode 100755
index 0000000..177c674
--- /dev/null
+++ b/src/app/api/audio/stream/route.ts
@@ -0,0 +1,92 @@
+import { NextRequest, NextResponse } from 'next/server'
+import { assertPublicHttpUrl } from '@/lib/server/ssrf'
+import { getStreamEntry, refreshStreamEntry } from '@/lib/server/stream-store'
+
+export const runtime = 'nodejs'
+export const dynamic = 'force-dynamic'
+
+/**
+ * GET /api/audio/stream?token=<hex32>
+ * Same-origin byte proxy for a resolved upstream audio URL. Same-origin is
+ * what keeps the Web Audio analyser untainted (a cross-origin <audio> source
+ * zeroes the FFT data). Forwards Range requests, passes the upstream status
+ * and media headers through, slides the token's TTL on each success.
+ */
+
+const UPSTREAM_UA =
+  'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36'
+
+const EXACT_MEDIA_TYPES = new Set(['application/octet-stream', 'application/ogg'])
+
+const PASSTHROUGH_HEADERS = ['content-type', 'content-length', 'content-range', 'accept-ranges']
+
+function fail(status: number, error: string): NextResponse {
+  return NextResponse.json({ ok: false, error }, { status })
+}
+
+export async function GET(request: NextRequest) {
+  const token = request.nextUrl.searchParams.get('token')
+  if (!token) {
+    return fail(404, 'Unknown or expired stream token')
+  }
+
+  const entry = getStreamEntry(token)
+  if (!entry) {
+    return fail(404, 'Unknown or expired stream token')
+  }
+
+  // Re-run the SSRF gate — a re-resolved host that now points private is refused.
+  try {
+    await assertPublicHttpUrl(entry.remoteUrl)
+  } catch (err) {
+    return fail(502, err instanceof Error ? err.message : 'That stream host is not allowed.')
+  }
+
+  const range = request.headers.get('range')
+  const upstreamHeaders: Record<string, string> = { 'User-Agent': UPSTREAM_UA }
+  if (range) upstreamHeaders.Range = range
+
+  // Upstreams occasionally reset mid-handshake — one immediate retry on a
+  // network-level failure (HTTP error statuses are NOT retried).
+  let upstream: Response | null = null
+  for (let attempt = 0; attempt < 2; attempt++) {
+    try {
+      upstream = await fetch(entry.remoteUrl, {
+        headers: upstreamHeaders,
+        redirect: 'follow',
+        cache: 'no-store',
+      })
+      break
+    } catch {
+      // network error — fall through to retry / 502
+    }
+  }
+  if (!upstream) {
+    return fail(502, 'Upstream could not be reached.')
+  }
+
+  if (!upstream.ok) {
+    return fail(502, `Upstream failed (HTTP ${upstream.status}).`)
+  }
+
+  const contentType = upstream.headers.get('content-type') ?? ''
+  const mediaOk =
+    contentType.startsWith('audio/') ||
+    contentType.startsWith('video/') ||
+    EXACT_MEDIA_TYPES.has(contentType)
+  if (!mediaOk) {
+    return fail(502, 'Upstream did not return audio.')
+  }
+
+  // successful GET — slide the TTL window forward
+  refreshStreamEntry(token)
+
+  const headers = new Headers()
+  for (const name of PASSTHROUGH_HEADERS) {
+    const value = upstream.headers.get(name)
+    if (value) headers.set(name, value)
+  }
+  headers.set('Cache-Control', 'public, max-age=1800')
+
+  return new Response(upstream.body, { status: upstream.status, headers })
+}
diff --git a/src/app/api/resolve/route.ts b/src/app/api/resolve/route.ts
new file mode 100755
index 0000000..f736428
--- /dev/null
+++ b/src/app/api/resolve/route.ts
@@ -0,0 +1,366 @@
+import { spawn } from 'node:child_process'
+import { existsSync } from 'node:fs'
+import { join } from 'node:path'
+import { NextRequest, NextResponse } from 'next/server'
+import { assertPublicHttpUrl } from '@/lib/server/ssrf'
+import { createStreamEntry } from '@/lib/server/stream-store'
+
+export const runtime = 'nodejs'
+export const dynamic = 'force-dynamic'
+
+/**
+ * POST /api/resolve
+ * Body: { "url": string } — a YouTube / SoundCloud / Bandcamp / direct-file link.
+ * Resolves it (yt-dlp for extractors, bypass for direct audio files) to a
+ * same-origin proxy URL: { ok, streamUrl, title, source, durationSec }.
+ */
+
+const MAX_URL_LENGTH = 2048
+const EXTRACT_TIMEOUT_MS = 30_000
+const RESOLVE_CACHE_TTL_MS = 10 * 60_000
+const MAX_STDOUT_BYTES = 32 * 1024 * 1024
+
+const YT_DLP_ARGS = [
+  '-J',
+  '--no-warnings',
+  '--no-playlist',
+  '--no-progress',
+  '--socket-timeout',
+  '15',
+  '-f',
+  'bestaudio[protocol^=http]/bestaudio/best',
+]
+
+const DIRECT_AUDIO_RE = /\.(mp3|m4a|aac|ogg|oga|opus|wav|flac|mp4|webm)$/i
+const ADAPTIVE_EXT_RE = /\.(m3u8|mpd)$/i
+const ADAPTIVE_PROTO_RE = /m3u8|mpd|dash/i
+const UNSUPPORTED_RE = /unsupported url/i
+/** YouTube's datacenter-IP wall: "Sign in to confirm you're not a bot". */
+const BOT_WALL_RE = /sign in to confirm|not a bot|cookies for the authentication/i
+
+interface ResolveSuccess {
+  ok: true
+  streamUrl: string
+  title: string
+  source: string
+  durationSec: number | null
+}
+
+interface YtDlpFormat {
+  url?: unknown
+  protocol?: unknown
+}
+
+interface YtDlpInfo {
+  url?: unknown
+  protocol?: unknown
+  title?: unknown
+  duration?: unknown
+  extractor?: unknown
+  extractor_key?: unknown
+  formats?: YtDlpFormat[] | null
+  requested_formats?: YtDlpFormat[] | null
+}
+
+interface YtDlpResult {
+  code: number | null
+  signal: string | null
+  stdout: string
+  stderr: string
+  timedOut: boolean
+  spawnError: string | null
+}
+
+// ---- success cache (globalThis so dev-mode module reloads keep it) ----
+
+interface ResolveCacheEntry {
+  payload: ResolveSuccess
+  expires: number
+}
+
+interface AvaResolveGlobal {
+  __avaResolveCache?: Map<string, ResolveCacheEntry>
+}
+
+function resolveCache(): Map<string, ResolveCacheEntry> {
+  const g = globalThis as AvaResolveGlobal
+  g.__avaResolveCache ??= new Map<string, ResolveCacheEntry>()
+  return g.__avaResolveCache
+}
+
+function cacheGet(key: string): ResolveSuccess | null {
+  const map = resolveCache()
+  const now = Date.now()
+  for (const [k, v] of map) {
+    if (v.expires <= now) map.delete(k)
+  }
+  const hit = map.get(key)
+  return hit ? hit.payload : null
+}
+
+function cacheSet(key: string, payload: ResolveSuccess): void {
+  resolveCache().set(key, { payload, expires: Date.now() + RESOLVE_CACHE_TTL_MS })
+}
+
+// ---- helpers ----
+
+function fail(status: number, error: string): NextResponse {
+  return NextResponse.json({ ok: false, error }, { status })
+}
+
+/** yt-dlp binary: env override → project-local bin/ → PATH. */
+function ytdlpPath(): string {
+  const fromEnv = process.env.AVA_YTDLP
+  if (typeof fromEnv === 'string' && fromEnv.trim() !== '') return fromEnv
+  const local = join(process.cwd(), 'bin', 'yt-dlp')
+  if (existsSync(local)) return local
+  return 'yt-dlp'
+}
+
+/** Strip ANSI escapes + all other control chars (user-safe text). */
+function stripControlChars(input: string): string {
+  let out = ''
+  let i = 0
+  while (i < input.length) {
+    const code = input.charCodeAt(i)
+    if (code === 0x1b) {
+      const next = input[i + 1] ?? ''
+      if (next === '[') {
+        let j = i + 2
+        while (j < input.length && '0123456789;?'.includes(input[j] ?? '')) j++
+        j++ // final byte of the CSI sequence
+        i = j
+      } else {
+        i += next === '' ? 1 : 2 // lone ESC or ESC <char>
+      }
+      continue
+    }
+    if (code < 0x20 || code === 0x7f) {
+      i++
+      continue
+    }
+    out += input[i]
+    i++
+  }
+  return out
+}
+
+function cleanText(input: string, max: number): string {
+  return stripControlChars(input).trim().slice(0, max)
+}
+
+/** Last path segment, decodeURIComponent'd; hostname as fallback. */
+function directTitle(url: URL): string {
+  const segments = url.pathname.split('/').filter((s) => s.length > 0)
+  const last = segments.length > 0 ? segments[segments.length - 1] : ''
+  let decoded = last
+  if (last) {
+    try {
+      decoded = decodeURIComponent(last)
+    } catch {
+      decoded = last
+    }
+  }
+  const cleaned = cleanText(decoded, 140)
+  return cleaned.length > 0 ? cleaned : url.hostname
+}
+
+/** data.url → requested_formats[0] → last http-protocol format. */
+function pickStream(data: YtDlpInfo): { url: string; protocol: string } | null {
+  if (typeof data.url === 'string' && data.url) {
+    return { url: data.url, protocol: typeof data.protocol === 'string' ? data.protocol : '' }
+  }
+  const requested = Array.isArray(data.requested_formats) ? data.requested_formats : []
+  const first = requested[0]
+  if (first && typeof first.url === 'string' && first.url) {
+    return { url: first.url, protocol: typeof first.protocol === 'string' ? first.protocol : '' }
+  }
+  const formats = Array.isArray(data.formats) ? data.formats : []
+  let last: { url: string; protocol: string } | null = null
+  for (const f of formats) {
+    const u = typeof f.url === 'string' ? f.url : ''
+    const p = typeof f.protocol === 'string' ? f.protocol : ''
+    if (u && p.startsWith('http')) last = { url: u, protocol: p }
+  }
+  return last
+}
+
+function ytdlpSource(data: YtDlpInfo, fallbackHost: string): string {
+  const key = typeof data.extractor_key === 'string' ? data.extractor_key : ''
+  const ex = typeof data.extractor === 'string' ? data.extractor : ''
+  return (key || ex || fallbackHost).toLowerCase()
+}
+
+/** Run yt-dlp, killing it after EXTRACT_TIMEOUT_MS. */
+function runYtDlp(url: string, extraArgs: string[]): Promise<YtDlpResult> {
+  return new Promise((resolve) => {
+    let stdout = ''
+    let stderr = ''
+    let timedOut = false
+    let settled = false
+    let timer: ReturnType<typeof setTimeout> | undefined
+
+    const done = (code: number | null, signal: string | null, spawnError: string | null): void => {
+      if (settled) return
+      settled = true
+      if (timer !== undefined) clearTimeout(timer)
+      resolve({ code, signal, stdout, stderr, timedOut, spawnError })
+    }
+
+    let child: ReturnType<typeof spawn>
+    try {
+      child = spawn(ytdlpPath(), [...YT_DLP_ARGS, ...extraArgs, url], {
+        stdio: ['ignore', 'pipe', 'pipe'],
+      })
+    } catch (err) {
+      done(null, null, err instanceof Error ? err.message : 'failed to start yt-dlp')
+      return
+    }
+
+    timer = setTimeout(() => {
+      timedOut = true
+      try {
+        child.kill('SIGKILL')
+      } catch {
+        // already gone — 'close' will still fire
+      }
+    }, EXTRACT_TIMEOUT_MS)
+
+    child.stdout?.on('data', (chunk: Buffer) => {
+      stdout += chunk.toString('utf8')
+      if (stdout.length > MAX_STDOUT_BYTES) {
+        try {
+          child.kill('SIGKILL')
+        } catch {
+          // ignore
+        }
+      }
+    })
+    child.stderr?.on('data', (chunk: Buffer) => {
+      stderr += chunk.toString('utf8')
+    })
+    child.on('error', (err: Error) => done(null, null, err.message))
+    child.on('close', (code: number | null, signal: string | null) => done(code, signal, null))
+  })
+}
+
+// ---- route ----
+
+export async function POST(request: NextRequest) {
+  // 1. body
+  let body: unknown
+  try {
+    body = await request.json()
+  } catch {
+    return fail(400, 'Expected { url } JSON body.')
+  }
+  if (body === null || typeof body !== 'object') {
+    return fail(400, 'Expected { url } JSON body.')
+  }
+  const urlField = (body as { url?: unknown }).url
+  if (typeof urlField !== 'string') {
+    return fail(400, 'Expected { url } JSON body.')
+  }
+  const raw = urlField.trim()
+  if (raw.length > MAX_URL_LENGTH) {
+    return fail(400, 'That link is too long.')
+  }
+
+  // 2. SSRF gate on the input URL
+  let target: URL
+  try {
+    target = await assertPublicHttpUrl(raw)
+  } catch (err) {
+    return fail(400, err instanceof Error ? err.message : 'That link is not allowed.')
+  }
+
+  // 3. success cache
+  const cached = cacheGet(target.href)
+  if (cached) return NextResponse.json(cached)
+
+  // 4. direct-audio bypass
+  if (DIRECT_AUDIO_RE.test(target.pathname)) {
+    const title = directTitle(target)
+    const token = createStreamEntry(target.href, title, 'direct')
+    const payload: ResolveSuccess = {
+      ok: true,
+      streamUrl: `/api/audio/stream?token=${token}`,
+      title,
+      source: 'direct',
+      durationSec: null,
+    }
+    cacheSet(target.href, payload)
+    return NextResponse.json(payload)
+  }
+
+  // 5. yt-dlp extraction
+  const result = await runYtDlp(target.href, [])
+  if (result.spawnError !== null) {
+    return fail(500, 'Audio extractor unavailable (yt-dlp not found or failed to start).')
+  }
+  if (result.timedOut) {
+    return fail(504, 'Extraction timed out — try again or use a direct audio link.')
+  }
+  if (result.code !== 0) {
+    const cleanedStderr = stripControlChars(result.stderr).trim()
+    const tail = cleanedStderr.slice(-300)
+    if (UNSUPPORTED_RE.test(cleanedStderr)) {
+      return fail(422, 'That site is not supported — try YouTube, SoundCloud, or a direct MP3 link.')
+    }
+    if (BOT_WALL_RE.test(cleanedStderr)) {
+      return fail(
+        422,
+        'YouTube is asking this server to sign in to confirm it is not a bot — datacenter IPs are often rate-limited. Try a SoundCloud, Bandcamp or direct-file link instead, or run the native client on your own machine.',
+      )
+    }
+    return fail(422, `Could not extract audio from that link: ${tail || 'extraction failed.'}`)
+  }
+
+  let data: YtDlpInfo
+  try {
+    data = JSON.parse(result.stdout) as YtDlpInfo
+  } catch {
+    return fail(422, 'Could not extract audio from that link: extractor returned unexpected output.')
+  }
+
+  const pick = pickStream(data)
+  if (!pick) {
+    return fail(422, 'Could not extract audio from that link: no direct stream URL found.')
+  }
+
+  let upstream: URL
+  try {
+    upstream = new URL(pick.url)
+  } catch {
+    return fail(422, 'Could not extract audio from that link: no direct stream URL found.')
+  }
+
+  if (ADAPTIVE_EXT_RE.test(upstream.pathname) || ADAPTIVE_PROTO_RE.test(pick.protocol)) {
+    return fail(
+      422,
+      "This source only provides an adaptive (HLS/DASH) stream, which browsers can't play directly — try another link or a direct audio file."
+    )
+  }
+
+  // 6. SSRF gate on the resolved stream URL (public CDNs pass)
+  try {
+    await assertPublicHttpUrl(upstream.href)
+  } catch (err) {
+    return fail(422, err instanceof Error ? err.message : 'That stream host is not allowed.')
+  }
+
+  // 7. build response
+  const title = cleanText(typeof data.title === 'string' ? data.title : '', 140) || 'Stream'
+  const source = ytdlpSource(data, target.hostname)
+  const durationSec = typeof data.duration === 'number' ? data.duration : null
+  const token = createStreamEntry(upstream.href, title, source)
+  const payload: ResolveSuccess = {
+    ok: true,
+    streamUrl: `/api/audio/stream?token=${token}`,
+    title,
+    source,
+    durationSec,
+  }
+  cacheSet(target.href, payload)
+  return NextResponse.json(payload)
+}
diff --git a/src/components/ava/audio-source.ts b/src/components/ava/audio-source.ts
index f02cb3c..38cb53e 100755
--- a/src/components/ava/audio-source.ts
+++ b/src/components/ava/audio-source.ts
@@ -39,6 +39,56 @@ export function applyScriptText(text: string): { ok: boolean; error: ScriptError
   return { ok: false, error: v.error }
 }
 
+export interface LinkLoadResult {
+  ok: boolean
+  title?: string
+  source?: string
+  error?: string
+}
+
+/**
+ * Resolve a music link (YouTube / SoundCloud / direct MP3 …) through the
+ * server, then play the proxied same-origin stream. Never throws — the
+ * caller (LinkDialog) shows the error inline.
+ */
+export async function resolveAndPlayLink(url: string): Promise<LinkLoadResult> {
+  const engine = getEngine()
+  const trimmed = url.trim()
+  if (!/^https?:\/\/\S+$/i.test(trimmed)) {
+    return { ok: false, error: 'Paste a full http(s) link — e.g. https://www.youtube.com/watch?v=…' }
+  }
+  try {
+    const res = await fetch('/api/resolve', {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ url: trimmed }),
+    })
+    const data = (await res.json().catch(() => null)) as
+      | { ok?: boolean; streamUrl?: string; title?: string; source?: string; error?: string }
+      | null
+    if (!res.ok || !data?.ok || !data.streamUrl) {
+      return { ok: false, error: data?.error ?? `The server could not resolve that link (HTTP ${res.status}).` }
+    }
+    const title = data.title ?? trimmed
+    await engine.audio.startUrl(data.streamUrl, title)
+    const store = useAvaStore.getState()
+    store.setSource('link')
+    store.setSourceTitle(engine.audio.sourceLabel)
+    return { ok: true, title, source: data.source ?? 'link' }
+  } catch (err) {
+    try {
+      engine.audio.stop()
+    } catch {
+      /* noop */
+    }
+    const store = useAvaStore.getState()
+    store.setSource('idle')
+    store.setSourceTitle(null)
+    const message = err instanceof Error ? err.message : String(err)
+    return { ok: false, error: `Playback failed: ${message}` }
+  }
+}
+
 function micErrorMessage(err: unknown): string {
   const name = (err as DOMException | null)?.name ?? ''
   if (name === 'NotAllowedError' || name === 'PermissionDeniedError') {
@@ -69,7 +119,9 @@ export function useAudioSource() {
   const syncSource = useCallback(() => {
     const engine = getEngine()
     const kind = engine.audio.kind
-    useAvaStore.getState().setSource(kind === 'idle' ? 'idle' : (kind as 'demo' | 'mic' | 'file'))
+    const store = useAvaStore.getState()
+    store.setSource(kind === 'idle' ? 'idle' : (kind as 'demo' | 'mic' | 'file' | 'link'))
+    store.setSourceTitle(engine.audio.sourceLabel)
   }, [])
 
   const startDemo = useCallback(async () => {
diff --git a/src/components/ava/footer-bar.tsx b/src/components/ava/footer-bar.tsx
index d26b75e..698ae23 100755
--- a/src/components/ava/footer-bar.tsx
+++ b/src/components/ava/footer-bar.tsx
@@ -8,6 +8,7 @@ import { cn } from '@/lib/utils'
 export function FooterBar() {
   const stats = useAvaStore((s) => s.stats)
   const source = useAvaStore((s) => s.source)
+  const sourceTitle = useAvaStore((s) => s.sourceTitle)
 
   const fps = stats?.fps ?? 0
   const points = stats?.points ?? 0
@@ -18,8 +19,18 @@ export function FooterBar() {
   return (
     <footer className="mt-auto border-t border-zinc-800/80 bg-zinc-950/90 backdrop-blur">
       <div className="mx-auto flex max-w-[1800px] items-center gap-3 overflow-hidden px-4 py-2 font-mono text-[11px] tabular-nums text-zinc-500 sm:gap-4">
-        <span className="hidden sm:inline">
+        <span className="hidden min-w-0 items-center gap-1 sm:inline-flex">
           SRC: <span className="text-zinc-300">{source.toUpperCase()}</span>
+          {sourceTitle && (
+            <>
+              <span className="text-zinc-600" aria-hidden>
+                ·
+              </span>
+              <span className="max-w-[220px] truncate text-zinc-500" title={sourceTitle}>
+                {sourceTitle}
+              </span>
+            </>
+          )}
         </span>
         <span>
           FPS: <span className="text-zinc-300">{fps}</span>
diff --git a/src/components/ava/header.tsx b/src/components/ava/header.tsx
index b96e190..7b86997 100755
--- a/src/components/ava/header.tsx
+++ b/src/components/ava/header.tsx
@@ -5,10 +5,11 @@
 'use client'
 
 import { useRef } from 'react'
-import { AudioWaveform, Disc3, FileAudio, Mic, Square, Timer } from 'lucide-react'
+import { AudioWaveform, Disc3, FileAudio, Link2, Mic, Square, Timer } from 'lucide-react'
 import { Button } from '@/components/ui/button'
 import { Slider } from '@/components/ui/slider'
 import { BeatDot } from '@/components/ava/beat-dot'
+import { LinkDialog } from '@/components/ava/link-dialog'
 import { tapBeat, useAudioSource } from '@/components/ava/audio-source'
 import { useAvaStore } from '@/lib/store'
 import { cn } from '@/lib/utils'
@@ -53,6 +54,7 @@ function SourceControls() {
   const source = useAvaStore((s) => s.source)
   const setDemoBpm = useAvaStore((s) => s.setDemoBpm)
   const demoBpm = useAvaStore((s) => s.demoBpm)
+  const openLinkDialog = useAvaStore((s) => s.setLinkDialogOpen)
   const { startDemo, startMic, startFile, stop } = useAudioSource()
   const fileInputRef = useRef<HTMLInputElement>(null)
 
@@ -84,6 +86,13 @@ function SourceControls() {
           label="File"
           title="Play an audio file (loops)"
         />
+        <SourceSegmentButton
+          active={source === 'link'}
+          onClick={() => openLinkDialog(true)}
+          icon={Link2}
+          label="Link"
+          title="Stream from a link (YouTube, SoundCloud, direct MP3…)"
+        />
         <SourceSegmentButton active={false} onClick={stop} icon={Square} label="Stop" title="Stop audio" tone="stop" />
       </div>
 
@@ -167,6 +176,8 @@ export function AppHeader() {
           </Button>
         </div>
       </div>
+
+      <LinkDialog />
     </header>
   )
 }
diff --git a/src/components/ava/link-dialog.tsx b/src/components/ava/link-dialog.tsx
new file mode 100755
index 0000000..7e8c260
--- /dev/null
+++ b/src/components/ava/link-dialog.tsx
@@ -0,0 +1,219 @@
+// AVA — "Stream a link" dialog.
+//
+// Paste a music link (YouTube / SoundCloud / Bandcamp / direct MP3 …), it is
+// resolved through POST /api/resolve and played from the same-origin proxy so
+// the Web Audio analyser can read it. Inline errors, and the last few links
+// are kept in localStorage (club use: one click to re-load a track).
+//
+// Structure note: the body REMOUNTS every time the dialog opens (fresh local
+// state — no reset effects), and results that arrive after the user closed
+// the dialog surface as toasts instead of inline errors.
+
+'use client'
+
+import { useEffect, useRef, useState } from 'react'
+import { Link2, Loader2 } from 'lucide-react'
+import {
+  Dialog,
+  DialogContent,
+  DialogDescription,
+  DialogHeader,
+  DialogTitle,
+} from '@/components/ui/dialog'
+import { Button } from '@/components/ui/button'
+import { Input } from '@/components/ui/input'
+import { resolveAndPlayLink } from '@/components/ava/audio-source'
+import { useAvaStore } from '@/lib/store'
+import { useToast } from '@/hooks/use-toast'
+import { thinScrollbar } from '@/components/ava/shared'
+import { cn } from '@/lib/utils'
+
+interface RecentLink {
+  url: string
+  title: string
+  source: string
+}
+
+const LS_RECENT = 'ava.recentLinks'
+const MAX_RECENT = 5
+
+function loadRecent(): RecentLink[] {
+  try {
+    const raw = localStorage.getItem(LS_RECENT)
+    const list = raw ? (JSON.parse(raw) as RecentLink[]) : []
+    return Array.isArray(list)
+      ? list.filter((r) => r && typeof r.url === 'string' && typeof r.title === 'string')
+      : []
+  } catch {
+    return []
+  }
+}
+
+function pushRecent(item: RecentLink): RecentLink[] {
+  const list = loadRecent().filter((r) => r.url !== item.url)
+  list.unshift(item)
+  const trimmed = list.slice(0, MAX_RECENT)
+  try {
+    localStorage.setItem(LS_RECENT, JSON.stringify(trimmed))
+  } catch {
+    /* private mode — ignore */
+  }
+  return trimmed
+}
+
+/** Extra hint when YouTube blocks the server but the server message didn't already explain it. */
+function botWallHint(error: string): string | null {
+  if (/native client|datacenter/i.test(error)) return null
+  return /bot|sign in|confirm/i.test(error)
+    ? 'The hosting server\u2019s IP may be rate-limited by YouTube — a SoundCloud, Bandcamp or direct-file link usually works, or run the native client on your own machine.'
+    : null
+}
+
+function LinkDialogBody() {
+  const setOpen = useAvaStore((s) => s.setLinkDialogOpen)
+  const [url, setUrl] = useState('')
+  const [busy, setBusy] = useState(false)
+  const [error, setError] = useState<string | null>(null)
+  // lazy initializer: fresh from localStorage on every mount (= every open)
+  const [recent, setRecent] = useState<RecentLink[]>(() => loadRecent())
+  const inputRef = useRef<HTMLInputElement>(null)
+  const { toast } = useToast()
+
+  useEffect(() => {
+    const t = setTimeout(() => inputRef.current?.focus(), 80)
+    return () => clearTimeout(t)
+  }, [])
+
+  const submit = async (value: string) => {
+    const v = value.trim()
+    if (!v || busy) return
+    setBusy(true)
+    setError(null)
+    const result = await resolveAndPlayLink(v)
+    setBusy(false)
+
+    // user closed the dialog while resolving → report as a toast instead
+    if (!useAvaStore.getState().linkDialogOpen) {
+      if (result.ok) toast({ title: 'Streaming link', description: result.title ?? v })
+      else
+        toast({
+          title: 'Link failed',
+          description: result.error ?? 'Could not load that link.',
+          variant: 'destructive',
+        })
+      return
+    }
+
+    if (result.ok) {
+      setRecent(
+        pushRecent({ url: v, title: result.title ?? v, source: (result.source ?? 'link').toUpperCase() }),
+      )
+      setUrl('')
+      setOpen(false)
+      toast({ title: 'Streaming link', description: result.title ?? v })
+    } else {
+      setError(result.error ?? 'Could not load that link.')
+    }
+  }
+
+  return (
+    <DialogContent className="sm:max-w-md">
+      <DialogHeader>
+        <DialogTitle className="flex items-center gap-2">
+          <Link2 className="size-4 text-emerald-400" aria-hidden />
+          Stream a music link
+        </DialogTitle>
+        <DialogDescription>
+          YouTube, SoundCloud, Bandcamp, a direct MP3 — the audio is resolved through this
+          server, then analyzed and rendered live on your machine.
+        </DialogDescription>
+      </DialogHeader>
+
+      <form
+        onSubmit={(e) => {
+          e.preventDefault()
+          void submit(url)
+        }}
+        className="flex gap-2"
+      >
+        <Input
+          ref={inputRef}
+          value={url}
+          onChange={(e) => setUrl(e.target.value)}
+          placeholder="https://www.youtube.com/watch?v=…"
+          disabled={busy}
+          aria-label="Music link"
+          spellCheck={false}
+          autoComplete="off"
+          className="font-mono text-xs"
+        />
+        <Button
+          type="submit"
+          disabled={busy || !url.trim()}
+          className="shrink-0 gap-1.5 bg-emerald-400 font-semibold text-zinc-950 hover:bg-emerald-300"
+        >
+          {busy ? <Loader2 className="size-4 animate-spin" aria-hidden /> : null}
+          {busy ? 'Loading' : 'Load'}
+        </Button>
+      </form>
+
+      {error && (
+        <div
+          role="alert"
+          className="space-y-1 rounded-md border border-rose-500/30 bg-rose-500/10 px-3 py-2 text-xs leading-relaxed text-rose-300"
+        >
+          <p>{error}</p>
+          {botWallHint(error) && <p className="text-rose-300/70">{botWallHint(error)}</p>}
+        </div>
+      )}
+
+      {recent.length > 0 && (
+        <div>
+          <p className="mb-1.5 font-mono text-[10px] tracking-[0.2em] text-zinc-500">
+            RECENT LINKS
+          </p>
+          <div className={cn('max-h-28 space-y-1 overflow-y-auto pr-1', thinScrollbar)}>
+            {recent.map((r) => (
+              <button
+                key={r.url}
+                type="button"
+                onClick={() => {
+                  setUrl(r.url)
+                  void submit(r.url)
+                }}
+                disabled={busy}
+                title={r.url}
+                className="flex w-full items-center gap-2 rounded-md border border-zinc-800 bg-zinc-900/60 px-2.5 py-1.5 text-left text-xs text-zinc-300 transition-colors hover:border-emerald-500/40 hover:text-zinc-100 disabled:opacity-50"
+              >
+                <span className="shrink-0 font-mono text-[9px] uppercase tracking-wider text-emerald-400/80">
+                  {r.source}
+                </span>
+                <span className="min-w-0 flex-1 truncate">{r.title}</span>
+              </button>
+            ))}
+          </div>
+        </div>
+      )}
+
+      <p className="text-[11px] leading-relaxed text-zinc-500">
+        Everything after the link resolves — FFT analysis, beat tracking and rendering — runs
+        locally in your browser.
+      </p>
+    </DialogContent>
+  )
+}
+
+export function LinkDialog() {
+  const open = useAvaStore((s) => s.linkDialogOpen)
+  const setOpen = useAvaStore((s) => s.setLinkDialogOpen)
+  return (
+    <Dialog
+      open={open}
+      onOpenChange={(o) => {
+        setOpen(o)
+      }}
+    >
+      {open && <LinkDialogBody />}
+    </Dialog>
+  )
+}
diff --git a/src/components/ava/visual-stage.tsx b/src/components/ava/visual-stage.tsx
index 3b6c388..6897068 100755
--- a/src/components/ava/visual-stage.tsx
+++ b/src/components/ava/visual-stage.tsx
@@ -9,7 +9,7 @@
 
 import { useEffect, useRef, useState } from 'react'
 import { AnimatePresence, motion } from 'framer-motion'
-import { AudioWaveform, Disc3, FileAudio, Maximize, Mic, Minimize } from 'lucide-react'
+import { AudioWaveform, Disc3, FileAudio, Link2, Maximize, Mic, Minimize } from 'lucide-react'
 import { Button } from '@/components/ui/button'
 import { getEngine } from '@/lib/ava/engine'
 import { useAvaStore } from '@/lib/store'
@@ -24,6 +24,7 @@ export function VisualStage({ className }: { className?: string }) {
   const fps = useAvaStore((s) => s.stats?.fps ?? 0)
   const points = useAvaStore((s) => s.stats?.points ?? 0)
   const [isFullscreen, setIsFullscreen] = useState(false)
+  const openLinkDialog = useAvaStore((s) => s.setLinkDialogOpen)
   const { startDemo, startMic, startFile } = useAudioSource()
 
   // engine lifecycle — the one place the render loop is owned
@@ -102,7 +103,7 @@ export function VisualStage({ className }: { className?: string }) {
               <AudioWaveform className="mx-auto mb-3 size-8 text-emerald-400" aria-hidden />
               <h2 className="text-lg font-semibold">Select an audio source to begin</h2>
               <p className="mb-5 mt-1 text-xs text-zinc-500">
-                Demo track, live microphone, or your own audio file.
+                Demo track, live microphone, your own audio file — or paste a link.
               </p>
               <div className="grid gap-2.5">
                 <Button
@@ -117,6 +118,9 @@ export function VisualStage({ className }: { className?: string }) {
                 <Button onClick={() => fileInputRef.current?.click()} variant="secondary" className="h-12 gap-2">
                   <FileAudio className="size-4" /> Audio File
                 </Button>
+                <Button onClick={() => openLinkDialog(true)} variant="secondary" className="h-12 gap-2">
+                  <Link2 className="size-4" /> Stream a Link
+                </Button>
               </div>
             </motion.div>
           </motion.div>
diff --git a/src/lib/ava/audio.ts b/src/lib/ava/audio.ts
index 3c45bc4..eefd669 100755
--- a/src/lib/ava/audio.ts
+++ b/src/lib/ava/audio.ts
@@ -5,6 +5,8 @@
 //          so the app is fully demonstrable without any audio hardware
 //   mic  — live microphone / line-in (club audio feed into an interface)
 //   file — drop any audio file (mp3/wav/…) and loop it
+//   link — remote stream (YouTube / SoundCloud / direct MP3 …) resolved via
+//          /api/resolve and proxied same-origin so the analyser can tap it
 //
 // Band analysis: AnalyserNode FFT (8192 bins → ~5.4 Hz resolution at 44.1 kHz)
 // averaged over the user-tunable Hz ranges, with fast-attack / slow-release
@@ -20,6 +22,8 @@ const RELEASE_TAU = 0.22 // seconds
 export class AudioEngine {
   kind: AudioSourceKind = 'idle'
   demoBpm = 124
+  /** Human label for the active source (file name / stream title). */
+  sourceLabel: string | null = null
 
   private ctx: AudioContext | null = null
   private analyser: AnalyserNode | null = null
@@ -93,6 +97,7 @@ export class AudioEngine {
       try { this.analyser.disconnect() } catch { /* noop */ }
     }
     this.kind = 'idle'
+    this.sourceLabel = null
     this.levels = { ...ZERO_LEVELS }
   }
 
@@ -102,6 +107,7 @@ export class AudioEngine {
     await ctx.resume()
     this.stopSources()
     this.kind = 'demo'
+    this.sourceLabel = null
 
     if (!this.noiseBuf) {
       const len = Math.floor(ctx.sampleRate * 1.5)
@@ -211,6 +217,7 @@ export class AudioEngine {
     })
     this.stopSources()
     this.kind = 'mic'
+    this.sourceLabel = null
     this.micStream = stream
     this.micSource = ctx.createMediaStreamSource(stream)
     this.micSource.connect(this.analyser!) // analysis only — no destination
@@ -222,6 +229,7 @@ export class AudioEngine {
     await ctx.resume()
     this.stopSources()
     this.kind = 'file'
+    this.sourceLabel = file.name
     this.objectUrl = URL.createObjectURL(file)
     this.audioEl = new Audio()
     this.audioEl.src = this.objectUrl
@@ -232,6 +240,30 @@ export class AudioEngine {
     await this.audioEl.play()
   }
 
+  /**
+   * Remote stream playback (YouTube / SoundCloud / direct MP3 …).
+   * The URL comes from POST /api/resolve — a same-origin proxy route — so the
+   * MediaElementSource is NOT cross-origin-tainted and the analyser can read
+   * it. Loops by default (seeking back to 0 is a cheap Range request through
+   * the proxy).
+   */
+  async startUrl(streamUrl: string, title: string): Promise<void> {
+    const ctx = this.ensureCtx()
+    await ctx.resume()
+    this.stopSources()
+    this.kind = 'link'
+    this.sourceLabel = title
+    const el = new Audio()
+    el.preload = 'auto'
+    el.src = streamUrl
+    el.loop = true
+    this.audioEl = el
+    this.mediaSource = ctx.createMediaElementSource(el)
+    this.mediaSource.connect(this.analyser!)
+    this.analyser!.connect(ctx.destination)
+    await el.play()
+  }
+
   setDemoBpm(bpm: number): void {
     this.demoBpm = Math.min(Math.max(bpm, 60), 200)
   }
diff --git a/src/lib/ava/types.ts b/src/lib/ava/types.ts
index d92714d..9184853 100755
--- a/src/lib/ava/types.ts
+++ b/src/lib/ava/types.ts
@@ -2,7 +2,7 @@
 
 export type RenderMode = 'lines' | 'dots' | 'solid'
 export type BlendMode = 'additive' | 'alpha'
-export type AudioSourceKind = 'idle' | 'demo' | 'mic' | 'file'
+export type AudioSourceKind = 'idle' | 'demo' | 'mic' | 'file' | 'link'
 
 /** Fine-tunable band detection configuration (Hz ranges + gains). */
 export interface BandConfig {
diff --git a/src/lib/server/ssrf.ts b/src/lib/server/ssrf.ts
new file mode 100755
index 0000000..64b8d43
--- /dev/null
+++ b/src/lib/server/ssrf.ts
@@ -0,0 +1,142 @@
+import { promises as dns } from 'node:dns'
+import { isIPv4, isIPv6 } from 'node:net'
+
+/**
+ * SSRF guard for user-supplied links.
+ *
+ * `assertPublicHttpUrl` parses the raw string as an http(s) URL and verifies
+ * that the host (and every address it resolves to) is a public network host.
+ * It throws `Error` with a user-safe message on any failure — callers map the
+ * message onto a 400/422 response.
+ */
+
+const HOST_SUFFIX_BANS = ['.localhost', '.local', '.internal']
+
+/** True when the dotted-quad IPv4 string sits in a private / reserved range. */
+function isPrivateIPv4(ip: string): boolean {
+  const parts = ip.split('.')
+  if (parts.length !== 4) return true
+  const octets: number[] = []
+  for (const part of parts) {
+    const n = Number.parseInt(part, 10)
+    if (!Number.isInteger(n) || n < 0 || n > 255) return true
+    octets.push(n)
+  }
+  const a = octets[0]
+  const b = octets[1]
+  if (a === 0) return true // 0/8
+  if (a === 10) return true // 10/8
+  if (a === 100 && b !== undefined && b >= 64 && b <= 127) return true // 100.64/10 (CGNAT)
+  if (a === 127) return true // 127/8 (loopback)
+  if (a === 169 && b === 254) return true // 169.254/16 (link-local incl. cloud metadata)
+  if (a === 172 && b !== undefined && b >= 16 && b <= 31) return true // 172.16/12
+  if (a === 192 && b === 168) return true // 192.168/16
+  return false
+}
+
+/**
+ * Expand an IPv6 textual form (validated by net.isIPv6, so well-formed) into
+ * eight numeric groups. Embedded IPv4 tails (`::ffff:1.2.3.4`) are folded
+ * into their two hex groups. Zone ids (`fe80::1%eth0`) are dropped.
+ */
+function ipv6Groups(addr: string): number[] | null {
+  const noZone = addr.split('%')[0] ?? addr
+  let s = noZone
+  const lastColon = s.lastIndexOf(':')
+  if (lastColon >= 0) {
+    const tail = s.slice(lastColon + 1)
+    if (tail.includes('.')) {
+      if (!isIPv4(tail)) return null
+      const o = tail.split('.').map((x) => Number.parseInt(x, 10))
+      if (o.length !== 4 || o.some((x) => !Number.isInteger(x) || x < 0 || x > 255)) return null
+      const g1 = ((o[0] ?? 0) << 8) | (o[1] ?? 0)
+      const g2 = ((o[2] ?? 0) << 8) | (o[3] ?? 0)
+      s = `${s.slice(0, lastColon + 1)}${g1.toString(16)}:${g2.toString(16)}`
+    }
+  }
+  const halves = s.split('::')
+  if (halves.length > 2) return null
+  const parseChunk = (chunk: string): number[] | null => {
+    if (chunk === '') return []
+    const groups: number[] = []
+    for (const part of chunk.split(':')) {
+      if (!/^[0-9a-fA-F]{1,4}$/.test(part)) return null
+      groups.push(Number.parseInt(part, 16))
+    }
+    return groups
+  }
+  if (halves.length === 2) {
+    const head = parseChunk(halves[0] ?? '')
+    const tail = parseChunk(halves[1] ?? '')
+    if (!head || !tail) return null
+    if (head.length + tail.length > 7) return null
+    const filler = new Array<number>(8 - head.length - tail.length).fill(0)
+    return [...head, ...filler, ...tail]
+  }
+  const flat = parseChunk(halves[0] ?? '')
+  if (!flat || flat.length !== 8) return null
+  return flat
+}
+
+/** True when the address string is a public host address (not loopback / private / link-local …). */
+function isPublicAddress(addr: string): boolean {
+  if (isIPv4(addr)) return !isPrivateIPv4(addr)
+  if (isIPv6(addr)) {
+    const groups = ipv6Groups(addr)
+    if (!groups) return false
+    const g = (i: number): number => groups[i] ?? -1
+    // IPv4-mapped ::ffff:a.b.c.d — the embedded v4 decides.
+    if (g(5) === 0xffff && g(0) === 0 && g(1) === 0 && g(2) === 0 && g(3) === 0 && g(4) === 0) {
+      const embedded = `${g(6) >> 8}.${g(6) & 0xff}.${g(7) >> 8}.${g(7) & 0xff}`
+      return !isPrivateIPv4(embedded)
+    }
+    if (groups.every((x) => x === 0)) return false // :: unspecified
+    if (g(7) === 1 && groups.slice(0, 7).every((x) => x === 0)) return false // ::1 loopback
+    if ((g(0) & 0xfe00) === 0xfc00) return false // fc00::/7 ULA
+    if ((g(0) & 0xffc0) === 0xfe80) return false // fe80::/10 link-local
+    return true
+  }
+  return false
+}
+
+/**
+ * Validate that `raw` is an http(s) URL pointing at a public host.
+ * Resolves DNS and requires *every* resulting address to pass the same
+ * private-range checks (defeats DNS rebinding / nip.io style tricks).
+ * Returns the parsed URL; throws Error with a user-safe message otherwise.
+ */
+export async function assertPublicHttpUrl(raw: string): Promise<URL> {
+  let url: URL
+  try {
+    url = new URL(raw)
+  } catch {
+    throw new Error('Only http(s) links are supported.')
+  }
+  if (url.protocol !== 'http:' && url.protocol !== 'https:') {
+    throw new Error('Only http(s) links are supported.')
+  }
+  if (url.port !== '' && url.port !== '80' && url.port !== '443') {
+    throw new Error('That port is not allowed.')
+  }
+  const host = url.hostname.toLowerCase().replace(/^\[/, '').replace(/\]$/, '')
+  if (host === '' || host === 'localhost') {
+    throw new Error('That host is not allowed.')
+  }
+  if (HOST_SUFFIX_BANS.some((suffix) => host.endsWith(suffix))) {
+    throw new Error('That host is not allowed.')
+  }
+  if (isIPv4(host) || isIPv6(host)) {
+    if (!isPublicAddress(host)) throw new Error('That host is not allowed.')
+    return url
+  }
+  let addresses: { address: string; family: number }[]
+  try {
+    addresses = await dns.lookup(host, { all: true })
+  } catch {
+    throw new Error('Could not resolve that host.')
+  }
+  if (addresses.length === 0 || !addresses.every((a) => isPublicAddress(a.address))) {
+    throw new Error('That host is not allowed.')
+  }
+  return url
+}
diff --git a/src/lib/server/stream-store.ts b/src/lib/server/stream-store.ts
new file mode 100755
index 0000000..b86dd5a
--- /dev/null
+++ b/src/lib/server/stream-store.ts
@@ -0,0 +1,61 @@
+import { randomBytes } from 'node:crypto'
+
+/**
+ * In-memory store mapping single-use-capable stream tokens to the resolved
+ * upstream URL + metadata. Lives for the life of the dev server process —
+ * kept on `globalThis` so Next.js module reloads in dev never orphan it.
+ */
+
+export interface StreamEntry {
+  remoteUrl: string
+  title: string
+  source: string
+  expires: number
+}
+
+const STREAM_TTL_MS = 30 * 60 * 1000
+
+interface AvaStreamsGlobal {
+  __avaStreams?: Map<string, StreamEntry>
+}
+
+function store(): Map<string, StreamEntry> {
+  const g = globalThis as AvaStreamsGlobal
+  g.__avaStreams ??= new Map<string, StreamEntry>()
+  return g.__avaStreams
+}
+
+/** Drop every entry whose TTL has lapsed. Called on every store access. */
+function prune(): void {
+  const map = store()
+  const now = Date.now()
+  for (const [token, entry] of map) {
+    if (entry.expires <= now) map.delete(token)
+  }
+}
+
+/** Register a resolved stream; returns the opaque hex token for /api/audio/stream. */
+export function createStreamEntry(remoteUrl: string, title: string, source: string): string {
+  prune()
+  const token = randomBytes(16).toString('hex')
+  store().set(token, { remoteUrl, title, source, expires: Date.now() + STREAM_TTL_MS })
+  return token
+}
+
+/** Fetch a token's entry (prunes expired entries first). null = unknown/expired. */
+export function getStreamEntry(token: string): StreamEntry | null {
+  prune()
+  const entry = store().get(token)
+  if (!entry) return null
+  return { remoteUrl: entry.remoteUrl, title: entry.title, source: entry.source, expires: entry.expires }
+}
+
+/** Slide a live entry's TTL forward (called on each successful stream GET). */
+export function refreshStreamEntry(token: string): void {
+  prune()
+  const map = store()
+  const entry = map.get(token)
+  if (entry && entry.expires > Date.now()) {
+    entry.expires = Date.now() + STREAM_TTL_MS
+  }
+}
diff --git a/src/lib/store.ts b/src/lib/store.ts
index 90a4f83..b2860f1 100755
--- a/src/lib/store.ts
+++ b/src/lib/store.ts
@@ -23,7 +23,7 @@ export interface PresetItem {
   updatedAt: string
 }
 
-export type AudioSourceState = 'idle' | 'demo' | 'mic' | 'file'
+export type AudioSourceState = 'idle' | 'demo' | 'mic' | 'file' | 'link'
 
 /** EngineStats augmented with the beat counter (read alongside the callback). */
 export interface AvaStats extends EngineStats {
@@ -159,6 +159,10 @@ interface AvaState {
   lastTap: TapResult | null
   /** Mirrors engine.audio.kind — kept in sync by the audio-source helpers. */
   source: AudioSourceState
+  /** File name / stream title for the active source (footer display). */
+  sourceTitle: string | null
+  /** "Stream a link" dialog visibility (opened from header + idle overlay). */
+  linkDialogOpen: boolean
   demoBpm: number
   /** Editor content (the live script text). */
   scriptText: string
@@ -171,6 +175,8 @@ interface AvaState {
   flashBeat: (source: BeatSource) => void
   setLastTap: (t: TapResult) => void
   setSource: (s: AudioSourceState) => void
+  setSourceTitle: (t: string | null) => void
+  setLinkDialogOpen: (b: boolean) => void
   setDemoBpm: (bpm: number) => void
   setScriptText: (t: string) => void
   /** Apply a full config (initial load) — engine + store, no persist. */
@@ -192,6 +198,8 @@ export const useAvaStore = create<AvaState>()((set, get) => ({
   beatFlash: null,
   lastTap: null,
   source: 'idle',
+  sourceTitle: null,
+  linkDialogOpen: false,
   demoBpm: 124,
   scriptText: '',
   bandConfig: { ...DEFAULT_BAND_CONFIG },
@@ -207,6 +215,10 @@ export const useAvaStore = create<AvaState>()((set, get) => ({
 
   setSource: (s) => set({ source: s }),
 
+  setSourceTitle: (t) => set({ sourceTitle: t }),
+
+  setLinkDialogOpen: (b) => set({ linkDialogOpen: b }),
+
   setDemoBpm: (bpm) => {
     const v = Math.min(200, Math.max(60, Math.round(bpm)))
     getEngine().audio.setDemoBpm(v)
diff --git a/tool-results/ava-link-desktop.png b/tool-results/ava-link-desktop.png
new file mode 100755
index 0000000..24542e4
Binary files /dev/null and b/tool-results/ava-link-desktop.png differ
diff --git a/tool-results/ava-link-mobile.png b/tool-results/ava-link-mobile.png
new file mode 100755
index 0000000..1f5137b
Binary files /dev/null and b/tool-results/ava-link-mobile.png differ
diff --git a/tool-results/ava-link-playing.png b/tool-results/ava-link-playing.png
new file mode 100755
index 0000000..f4d95ca
Binary files /dev/null and b/tool-results/ava-link-playing.png differ
diff --git a/worklog.md b/worklog.md
index 14a6d93..577033f 100755
--- a/worklog.md
+++ b/worklog.md
@@ -294,3 +294,165 @@ Stage Summary:
 - ALL acceptance criteria verified in-browser. Zero console errors. The application is
   fully interactive: 3-band detection, beat detection + prediction + tap learning, AVS-style
   scripting with editor/help/save/load, 5 authentic presets (adapted), Rust scaffold export.
+
+---
+Task ID: 6
+Agent: general-purpose
+Task: "Stream a link" backend — yt-dlp link resolution + same-origin audio byte proxy (POST /api/resolve, GET /api/audio/stream)
+
+Work Log:
+- Read worklog (Tasks 1–5) and existing routes; confirmed dev server already running on :3000
+  (Node, next-server v16.1.3) — never restarted it; no build, no new deps, no git
+- Installed yt-dlp standalone binary: bin/yt-dlp (GitHub latest yt-dlp_linux), chmod +x,
+  --version prints 2026.10.21
+- src/lib/server/ssrf.ts — assertPublicHttpUrl(raw): http(s) only, explicit port must be 80/443,
+  localhost/.localhost/.local/.internal banned, IPv4 privates (0/8, 10/8, 100.64/10, 127/8,
+  169.254/16, 172.16/12, 192.168/16), IPv6 ::/::1/fc00::/7/fe80::/10 plus IPv4-mapped
+  ::ffff:a.b.c.d (embedded v4 checked; hand-written IPv6 expander handles v4 tails + zone ids),
+  then dns.promises.lookup(all:true) with EVERY result re-checked by the same rules (kills
+  nip.io / DNS-rebind tricks). Throws user-safe messages; returns the parsed URL.
+- src/lib/server/stream-store.ts — Map on globalThis.__avaStreams via a typed interface with an
+  optional property + `??=` (no `any`): token = randomBytes(16).hex (32 chars), entries
+  { remoteUrl, title, source, expires }, 30-min sliding TTL, prune-on-every-access; exports
+  createStreamEntry / getStreamEntry / refreshStreamEntry.
+- src/app/api/resolve/route.ts — JSON body { url } (≤2048, trim) → 400s; SSRF gate → 400;
+  10-min success cache on globalThis.__avaResolveCache (repeat links replay instantly);
+  direct-audio bypass for .mp3 .m4a .aac .ogg .oga .opus .wav .flac .mp4 .webm (source "direct",
+  title = decoded last path segment, fallback hostname); otherwise yt-dlp
+  -J --no-warnings --no-playlist --no-progress --socket-timeout 15
+  -f "bestaudio[protocol^=http]/bestaudio/best" with a 30 s kill → 504; non-zero exit →
+  ANSI/control-stripped stderr tail (300 chars) → 422 ("Unsupported URL" gets its own message);
+  stream URL pick = data.url ?? requested_formats[0].url ?? last http-protocol format;
+  .m3u8/.mpd path or m3u8/mpd/dash protocol → 422 adaptive message; SSRF re-check on the
+  RESOLVED stream URL (public CDNs like googlevideo pass) → 422 if not; title control-stripped +
+  clamped 140 (fallback "Stream"), source = extractor_key|extractor|hostname lowercase,
+  durationSec = numeric duration or null.
+- src/app/api/audio/stream/route.ts — token → entry (prune first) else 404; SSRF re-check of the
+  stored remoteUrl; forwards the client Range header, Chrome UA, redirect follow, no-store;
+  !ok → 502 `Upstream failed (HTTP n).`; content-type must be audio/*, video/*,
+  application/octet-stream or application/ogg else 502 "Upstream did not return audio.";
+  refreshes sliding TTL, then passes through the upstream status with content-type/-length/
+  -range/accept-ranges (only when upstream provided them) + Cache-Control: public, max-age=1800.
+- FIX found while testing: the upstream host intermittently RST/ETIMEDOUTs full (non-ranged)
+  fetches — verified against raw node fetch (1/6 ETIMEDOUT) — added ONE immediate retry on
+  network-level failure only (HTTP error statuses are never retried); after that: 2× full GET
+  200 audio/mpeg 8,945,229 bytes.
+- tsc --noEmit: zero errors in the new files (the project's 8 pre-existing errors are all in
+  src/lib/ava, examples/, skills/, rust-scaffold — untouched).
+
+Stage Summary:
+- yt-dlp: /home/z/my-project/bin/yt-dlp, version 2026.10.21 (runtime order: $AVA_YTDLP →
+  <cwd>/bin/yt-dlp if existsSync → "yt-dlp" on PATH)
+- Files created (nothing else touched, no frontend files): bin/yt-dlp, src/lib/server/ssrf.ts,
+  src/lib/server/stream-store.ts, src/app/api/resolve/route.ts, src/app/api/audio/stream/route.ts
+- Test 1 MUST-PASS direct MP3 (soundhelix Song-1): resolve → ok:true, source:"direct",
+  title:"SoundHelix-Song-1.mp3"; full stream GET → 200 audio/mpeg 8,945,229 B (>1 MB; takes ~30 s
+  because the origin throttles at ~300 KB/s — proxy adds ~0); Range 0-1023 → 206 with
+  content-range "bytes 0-1023/8945229", accept-ranges, cache-control all verified
+- Test 2 MUST-PASS SSRF: http://127.0.0.1/x → 400, http://169.254.169.254/latest/meta-data → 400,
+  ftp://example.com/a.mp3 → 400. Extras: localhost:8080 → 400 (port), foo.bar.local → 400,
+  [::1] → 400, [::ffff:10.0.0.5] → 400 (v4-mapped), 127.0.0.1.nip.io → 400 (DNS-result check),
+  "not a url" / {} / {"url":5} / bad JSON → 400 "Expected { url } JSON body."
+- Test 3 YouTube jNQXAC9IVRw: bot-blocked from this datacenter IP ("Sign in to confirm you're not
+  a bot"). Tried the 2 extractor-args variants (youtube:player_client=web_embedded, then =tv)
+  within the 5-minute budget — still blocked. Surfaces as a clean 422 with the sanitized tail:
+  "Could not extract audio from that link: …Sign in to confirm you're not a bot…". Honest
+  outcome: blocked here, ACCEPTABLE per spec (would work from residential IPs / with cookies).
+- Test 4 SoundCloud forss/flickermood: yt-dlp extracts fine (title "Flickermood", 213.9 s) but
+  this serve only exposes m3u8_native formats (hls_aac_96k/160k — confirmed in raw -J JSON) →
+  clean 422 adaptive(HLS/DASH) message, exactly the manifest-only contract case.
+- Test 5 https://example.com/ → clean 422 "That site is not supported — try YouTube, SoundCloud,
+  or a direct MP3 link."; example.com/stream.m3u8 → 422 (does NOT hit the direct bypass).
+- Extractor SUCCESS path proven end-to-end with archive.org: resolve → ok:true,
+  title:"mp3 test file", source:"archiveorg", durationSec:12.42; stream → 200 audio/mpeg
+  198,658 B + 206 ranged; cache replay 16 ms.
+- Stream negatives: unknown/missing token → 404 "Unknown or expired stream token"; upstream 500
+  (missing file) → 502 "Upstream failed (HTTP 500)."
+- lint: my 4 files pass eslint clean; `bun run lint` overall reports exactly 1 remaining error in
+  src/components/ava/link-dialog.tsx:72 (set-state-in-effect) — that file is owned by the parallel
+  frontend agent and was NOT touched by me per the ownership rules.
+- dev.log: no exceptions/stack traces from the new routes — only expected
+  200/206/400/404/422/502 request lines.
+- Deviations from spec (all deliberate): (1) one network-error retry in the proxy (upstream RSTs,
+  never retries HTTP statuses); (2) third store helper refreshStreamEntry() — the two required
+  helpers plus this one implements the specified "refresh sliding expiry AFTER upstream success";
+  (3) proxy fetch uses cache:'no-store'; (4) 500 wording "Audio extractor unavailable (yt-dlp not
+  found or failed to start)."; (5) success cache keyed by the normalized URL href (target.href).
+
+---
+Task ID: 7
+Agent: main (Z.ai Code)
+Task: Frontend integration of the "Link" audio source (YouTube / SoundCloud / direct MP3)
+
+Work Log:
+- Read worklog + all relevant files (audio.ts, store.ts, audio-source.ts, header.tsx,
+  visual-stage.tsx, footer-bar.tsx, types.ts) before editing.
+- src/lib/ava/types.ts — AudioSourceKind += 'link'
+- src/lib/ava/audio.ts — new startUrl(streamUrl, title): same-origin proxied <audio> element →
+  MediaElementAudioSourceNode → analyser (NOT cross-origin-tainted, so FFT works) → speakers;
+  loops by default; public sourceLabel field (file name / stream title) maintained by all
+  start* methods + stopSources
+- src/lib/store.ts — AudioSourceState += 'link'; new sourceTitle + linkDialogOpen state
+- src/components/ava/audio-source.ts — new resolveAndPlayLink(url): POST /api/resolve →
+  engine.audio.startUrl → store sync; never throws (returns {ok,title,source,error}); on
+  playback failure stops the engine and resets store; syncSource now also syncs sourceTitle
+- src/components/ava/link-dialog.tsx — NEW: dialog with URL input + Load button (spinner),
+  inline error box with YouTube bot-wall hint, RECENT LINKS chips (localStorage, max 5,
+  one-click reload); body REMOUNTS on every open (fresh state — no setState-in-effect, fixes
+  the lint error the Task 6 agent saw mid-build); results arriving after the user closed the
+  dialog surface as toasts
+- src/components/ava/header.tsx — "Link" segment button between File and Stop (opens dialog);
+  <LinkDialog /> mounted in the header
+- src/components/ava/visual-stage.tsx — idle overlay gains a 4th button "Stream a Link" +
+  updated copy
+- src/components/ava/footer-bar.tsx — SRC now shows "LINK · <title>" (truncated) for the
+  active source; title also shown for File sources
+- src/app/api/resolve/route.ts (main-agent touch-up, coordinated with Task 6's file): added
+  BOT_WALL_RE mapping so YouTube's "Sign in to confirm you're not a bot" stderr returns a
+  clean actionable 422 instead of a raw yt-dlp tail; client hint suppressed when the server
+  message already explains the fix (no duplication)
+
+Stage Summary:
+- Full link-source flow wired: header/idle-overlay → dialog → resolve → proxied playback →
+  band analysis + beat detection + visuals, all client-side after resolution. Zero layout
+  changes beyond the additive bits; lint clean.
+
+---
+Task ID: 8
+Agent: main (Z.ai Code)
+Task: E2E verification (agent-browser) of the link source + regression checks
+
+Work Log:
+- bun run lint → zero errors; dev.log clean (no exceptions)
+- Initial load: header shows Demo/Mic/File/LINK/Stop; idle overlay has 4 buttons incl.
+  "Stream a Link"; presets/tabs intact
+- Link dialog: opens from idle overlay AND header; invalid input ("not a url") → inline
+  client-side error "Paste a full http(s) link…"
+- Direct MP3 (SoundHelix Song 1): resolve → dialog closes → toast → footer shows
+  "SRC: LINK · SoundHelix-Song-1.mp3, FPS: 60, PTS: 480, BPM: 131.2" (real tempo ≈131 —
+  beat detection locks from the STREAMED audio, proving the same-origin proxy keeps the
+  analyser untainted); canvas luminance/bright-pixel counts change frame-to-frame (live
+  animation); screenshot ava-link-playing.png
+- Failed YouTube attempt while SoundHelix playing: music KEEPS playing (failed resolve
+  never touches the engine) — verified footer still LINK @60fps after closing dialog
+- RECENT LINKS: chip "DIRECT · SoundHelix-Song-1.mp3" appears on re-open; one-click reload
+- YouTube jNQXAC9IVRw from this datacenter IP: clean 422 bot-wall message + actionable hint
+  (verified twice — before/after the BOT_WALL_RE improvement)
+- Beat predictor regression check: tap-tempo path (6×500 ms taps on the real Set Beat
+  button) → "120.0 BPM, 98% confidence" → Stop → beat count 54→63 over 4.5 s, PRED badge,
+  confidence decays 98→80% — "keeps the beat when the bass drops out" confirmed. (Note:
+  auto-detect confidence on the 124 BPM demo stays low with the leftover test beatConfig
+  ×1.35/210 ms — interval spread from the demo bassline; the designed learning path
+  (Set Beat) locks instantly.)
+- Console: zero errors (only HMR messages)
+- Mobile 390×844: no horizontal scroll; footer pushed naturally by content and STICKS to
+  viewport bottom when scrolled to end; VLM inspection of desktop + mobile screenshots
+  confirms clean layout, no breakage
+
+Stage Summary:
+- Link source fully verified in-browser: resolve → stream → analyze → visualize at 60 fps,
+  beat detection on streamed audio, graceful YouTube bot-wall, recent-links, predictor
+  regression pass. The only environmental limitation: YouTube blocks this datacenter IP
+  (honest 422; works from residential IPs or with server-side cookies). SoundCloud/Bandcamp/
+  archive.org/direct files all resolve; SoundCloud serves HLS-only for some tracks → clean
+  adaptive-stream error.