LLM systems that keep working after the demo.

def complete(self, prompt, tier: str = "strong", temperature: float = 0.2,
             max_tokens: int = 800) -> str:
    """Call the pool with failover. Returns the completion text ("" on total
    failure). `prompt` is a string or a list of chat messages."""
    self._ensure()
    attempts = max(len(self.endpoints()), 1)
    messages = ([{"role": "user", "content": prompt}] if isinstance(prompt, str)
                else prompt)
    last_err = None
    for _ in range(attempts):
        ep = self._pick(tier)
        if ep is None:
            logger.warning("[llm_pool] no endpoints configured")
            return ""
        try:
            resp = ep.client().chat.completions.create(
                model=ep.model, messages=messages,
                temperature=temperature, max_tokens=max_tokens,
            )
            content = (resp.choices[0].message.content or "").strip()
            # An empty 200 (e.g. an invalid model name the API silently accepts)
            # is a soft failure — cool the endpoint down and fail over, don't
            # hand back a blank.
            if not content:
                last_err = f"{ep.name} returned empty content (check model id '{ep.model}')"
                ep.cooldown_until = time.time() + _COOLDOWN_SECS
                ep.fails += 1
                logger.debug(f"[llm_pool] {last_err}; failing over")
                continue
            ep.fails = 0
            return content
        except Exception as e:  # rate-limit, network, model error → cool down + next
            last_err = e
            ep.cooldown_until = time.time() + _COOLDOWN_SECS
            ep.fails += 1
            logger.debug(f"[llm_pool] {ep.name} failed ({e}); cooling down, failing over")
    logger.warning(f"[llm_pool] all endpoints exhausted: {last_err}")
    return ""

function Get-RunningProfileMap {
    # Maps a profile directory to the PID of the top-level Claude window process.
    # Child processes carry --type=renderer and friends, so they are filtered out. The
    # path check matters just as much: the Claude Code CLI is also called claude.exe,
    # the desktop app runs one per Code session, and WMI matches names case-insensitively.
    $map     = @{}
    $pattern = Get-DesktopExePattern
    $procs = Get-CimInstance Win32_Process -Filter "Name='Claude.exe'" -ErrorAction SilentlyContinue |
             Where-Object { $_.CommandLine -and $_.CommandLine -notmatch '--type=' -and
                            $_.ExecutablePath -and $_.ExecutablePath -match $pattern }

    foreach ($p in $procs) {
        # Quoted paths may contain spaces (C:\Users\John Doe\...), unquoted ones cannot.
        if ($p.CommandLine -match '--user-data-dir=(?:"([^"]+)"|(\S+))') {
            $key = $(if ($Matches[1]) { $Matches[1] } else { $Matches[2] }).TrimEnd('\')
        } else {
            $key = $script:DefaultProfilePath.TrimEnd('\')
        }
        if (-not $map.ContainsKey($key)) { $map[$key] = $p.ProcessId }
    }
    return $map
}

fn sd_segment(x: f32, y: f32, ax: f32, ay: f32, bx: f32, by: f32, r: f32) -> f32 {
    let (px, py, dx, dy) = (x - ax, y - ay, bx - ax, by - ay);
    let t = ((px * dx + py * dy) / (dx * dx + dy * dy)).clamp(0.0, 1.0);
    (px - dx * t).hypot(py - dy * t) - r
}

/// Sun glyph of overall `size`, centred on the origin. `rays` (0..=1) sets
/// the ray length, so the glyph can mirror the current brightness.
fn sun_sd(x: f32, y: f32, size: f32, rays: f32) -> f32 {
    let s = size / 2.0;
    let mut d = x.hypot(y) - s * 0.38;
    let t = s * 0.095;
    let r0 = s * 0.6;
    let r1 = r0 + s * (0.06 + 0.24 * rays.clamp(0.0, 1.0));
    for k in 0..8 {
        let (sn, cs) = (k as f32 * FRAC_PI_4).sin_cos();
        d = d.min(sd_segment(x, y, cs * r0, sn * r0, cs * r1, sn * r1, t));
    }
    d
}

/// Straight-alpha ARGB pixels for a `size`×`size` sun icon in colour `rgb`.
pub fn sun_icon(size: i32, rgb: u32) -> Vec<u32> {
    let c = size as f32 / 2.0;
    (0..size * size)
        .map(|i| {
            let (x, y) = ((i % size) as f32 + 0.5 - c, (i / size) as f32 + 0.5 - c);
            let a = cov(sun_sd(x, y, size as f32, 1.0));
            (((a * 255.0 + 0.5) as u32) << 24) | rgb
        })
        .collect()
}

Native.RECT rc;
Native.GetWindowRect(Root, out rc);
var pt = new Native.POINT { X = rc.Left + X, Y = rc.Top + Y };

IntPtr h = Root;
for (int depth = 0; depth < 32; depth++)
{
    Native.POINT c = pt;
    Native.ScreenToClient(h, ref c);
    IntPtr child = Native.ChildWindowFromPointEx(h, c, Native.CWP_SKIPINVISIBLE | Native.CWP_SKIPDISABLED | Native.CWP_SKIPTRANSPARENT);
    if (child == IntPtr.Zero || child == h) break;
    h = child;
}

Native.POINT cp = pt;
Native.ScreenToClient(h, ref cp);
IntPtr lp = (IntPtr)((cp.Y << 16) | (cp.X & 0xFFFF));
Native.PostMessage(h, Native.WM_MOUSEMOVE, IntPtr.Zero, lp);
Native.PostMessage(h, DownMsg, (IntPtr)MkFlag, lp);
Native.PostMessage(h, UpMsg, IntPtr.Zero, lp);
if (Double)
{
    Native.PostMessage(h, DblMsg, (IntPtr)MkFlag, lp);
    Native.PostMessage(h, UpMsg, IntPtr.Zero, lp);
}

// (a commit message, a grep pattern) is never mistaken for the command itself.
function words(segment) {
  const out = [];
  const re = /"((?:[^"\\]|\\.)*)"|'([^']*)'|(\S+)/g;
  let m;
  while ((m = re.exec(segment))) out.push({ text: m[1] != null ? m[1] : m[2] != null ? m[2] : m[3], quoted: m[3] == null });
  return out;
}

function segments(command) {
  const out = [];
  let cur = '';
  let quote = null;
  for (let i = 0; i < command.length; i++) {
    const c = command[i];
    if (quote) { cur += c; if (c === '\\' && quote === '"') cur += command[++i] || ''; else if (c === quote) quote = null; continue; }
    if (c === '"' || c === "'") { quote = c; cur += c; continue; }
    if (c === ';' || c === '\n' || c === '|' || c === '&') { out.push(cur); cur = ''; continue; }
    cur += c;
  }
  out.push(cur);
  return out;
}

// A root, home folder, drive, the current or a parent folder, optionally with a trailing
// slash or wildcard:  /  /*  ~  ~/  $HOME/  .  ./*  ../..  *  C:\  C:\*

export async function syncBookingToCrm(
  booking: BookingForCrm,
): Promise<{ contactId: number; dealId: number } | null> {
  if (!env.crm.enabled) return null;
  if (!env.crm.supabaseUrl || !env.crm.serviceRoleKey) {
    // eslint-disable-next-line no-console
    console.warn('[crm] enabled but SUPABASE_URL / SERVICE_ROLE_KEY missing — skipping sync');
    return null;
  }

  try {
    const { first, last } = splitName(booking.customerName);

    const contact = await crmPost<CrmContactResult>('contacts', {
      first_name: first,
      last_name: last,
      // Atomic CRM stores email/phone as JSONB arrays of { type, value }
      email_jsonb: [{ type: 'Work', email: booking.customerEmail }],
      phone_jsonb: [{ type: 'Work', number: booking.customerPhone }],
      background: `Inbound booking ${booking.reference} from namanpuja.com`,
      sales_id: env.crm.defaultSalesId,
      tags: [],
      status: 'hot',
    });

    const dealName = [booking.pujaName, booking.cityName].filter(Boolean).join(' — ') ||
      `Booking ${booking.reference}`;

    const deal = await crmPost<CrmDealResult>('deals', {
      name: dealName,
      contact_ids: [contact.id],
      category: booking.serviceType,
      stage: 'opportunity',
      amount: booking.amount ?? 0,
      description:
        `Reference: ${booking.reference}\n` +
        `Service: ${booking.serviceType}\n` +
        (booking.preferredDate ? `Preferred date: ${booking.preferredDate.toISOString()}\n` : '') +
        (booking.notes ? `Notes: ${booking.notes}` : ''),
      sales_id: env.crm.defaultSalesId,