Framework Recipes

// src/routes/search/+page.server.ts
import { env } from "$env/dynamic/private";
import type { PageServerLoad } from "./$types";

export const load: PageServerLoad = async ({ url, fetch }) => {
  const q = url.searchParams.get("q") ?? "";
  const res = await fetch("https://headband.dev/v1/search", {
    method: "POST",
    headers: {
      Authorization: `Bearer ${env.HEADBAND_SEARCH_KEY}`, // hb_src_..., stays on the server
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ index: "products", q, limit: 20 }),
  });
  if (!res.ok) throw new Error(`Headband search failed: ${res.status} ${await res.text()}`);
  const { hits, estimatedTotalHits } = await res.json();
  return { q, hits, total: estimatedTotalHits };
};

// app/routes/search.tsx (React Router 7, or Remix 2)
import { Form, useLoaderData } from "react-router"; // Remix 2: "@remix-run/react"

export async function loader({ request }: { request: Request }) {
  const q = new URL(request.url).searchParams.get("q") ?? "";
  const res = await fetch("https://headband.dev/v1/search", {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.HEADBAND_SEARCH_KEY}`, // hb_src_..., stays on the server
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ index: "products", q, limit: 20 }),
  });
  if (!res.ok) throw new Error(`Headband search failed: ${res.status} ${await res.text()}`);
  const { hits, estimatedTotalHits } = await res.json();
  return { q, hits, total: estimatedTotalHits };
}

export default function Search() {
  const { q, hits, total } = useLoaderData<typeof loader>();
  return (
    <>
      <Form>
        <input name="q" defaultValue={q} />
      </Form>
      <p>{total} results</p>
      <ul>
        {hits.map((hit: { id: string; title: string }) => (
          <li key={hit.id}>{hit.title}</li>
        ))}
      </ul>
    </>
  );
}

---
// src/pages/search.astro. Needs an SSR adapter, so the page runs on each request.
export const prerender = false;

const q = Astro.url.searchParams.get("q") ?? "";
const res = await fetch("https://headband.dev/v1/search", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${import.meta.env.HEADBAND_SEARCH_KEY}`, // hb_src_..., stays on the server
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ index: "products", q, limit: 20 }),
});
if (!res.ok) throw new Error(`Headband search failed: ${res.status} ${await res.text()}`);
const { hits, estimatedTotalHits } = await res.json();
---
<form><input name="q" value={q} /></form>
<p>{estimatedTotalHits} results</p>
<ul>{hits.map((hit) => <li>{hit.title}</li>)}</ul>

# app/controllers/search_controller.rb
require "net/http"
require "json"

class SearchController < ApplicationController
  HEADBAND_SEARCH = URI("https://headband.dev/v1/search")

  def index
    @query = params[:q].to_s
    res = Net::HTTP.post(
      HEADBAND_SEARCH,
      { index: "products", q: @query, limit: 20 }.to_json,
      "Authorization" => "Bearer #{ENV.fetch("HEADBAND_SEARCH_KEY")}", # hb_src_..., server only
      "Content-Type" => "application/json"
    )
    raise "Headband search failed: #{res.code} #{res.body}" unless res.is_a?(Net::HTTPSuccess)

    body = JSON.parse(res.body)
    @hits = body["hits"]
    @total = body["estimatedTotalHits"]
  end
end

<?php
// app/Http/Controllers/SearchController.php
// config/services.php: 'headband' => ['search_key' => env('HEADBAND_SEARCH_KEY')],

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use Illuminate\Support\Facades\Http;

class SearchController extends Controller
{
    public function index(Request $request)
    {
        $q = (string) $request->query('q', '');

        // hb_src_..., read on the server only. Http::post sends the array as JSON.
        $body = Http::withToken(config('services.headband.search_key'))
            ->post('https://headband.dev/v1/search', [
                'index' => 'products',
                'q' => $q,
                'limit' => 20,
            ])
            ->throw()
            ->json();

        return view('search', [
            'q' => $q,
            'hits' => $body['hits'],
            'total' => $body['estimatedTotalHits'] ?? 0,
        ]);
    }
}

# search/views.py
import json
import os
import urllib.request

from django.shortcuts import render


def search(request):
    q = request.GET.get("q", "")
    req = urllib.request.Request(
        "https://headband.dev/v1/search",
        data=json.dumps({"index": "products", "q": q, "limit": 20}).encode(),
        headers={
            # hb_src_..., read on the server only
            "Authorization": f"Bearer {os.environ['HEADBAND_SEARCH_KEY']}",
            "Content-Type": "application/json",
        },
        method="POST",
    )
    with urllib.request.urlopen(req, timeout=10) as res:  # raises on 4xx and 5xx
        body = json.load(res)
    return render(
        request,
        "search/results.html",
        {"q": q, "hits": body["hits"], "total": body.get("estimatedTotalHits", 0)},
    )

name: Headband sync
on:
  schedule:
    - cron: "*/15 * * * *"
  workflow_dispatch: {}
concurrency:
  group: headband-sync
  cancel-in-progress: false
jobs:
  sync:
    runs-on: ubuntu-latest
    timeout-minutes: 10
    steps:
      - uses: actions/checkout@v4
      - uses: actions/setup-node@v4
        with:
          node-version: 20
      - run: npm ci
      - run: node postgres.mjs
        env:
          POSTGRES_DATABASE_URL: ${{ secrets.POSTGRES_DATABASE_URL }}
          HEADBAND_ADMIN_KEY: ${{ secrets.HEADBAND_ADMIN_KEY }}
          POSTGRES_TABLE: products
          HEADBAND_RECONCILE: "true"
          HEADBAND_REPORT_RUNS: "true"