Fiber
This guide adds Bunkhouse to a server-rendered Fiber application. Every file shown below is part of a runnable example app that is tested end to end against the real Bunkhouse API and embed.
Tested setup
Section titled “Tested setup”| Framework | Fiber 3.6.1 (github.com/gofiber/fiber/v3), html/template views through gofiber/template/html v3.0.12 |
| Runtime | Go 1.26 (go1.26.10 in the tested image) |
| Example | apps/docs/integrations/fiber/ in the Bunkhouse repository |
You need:
- Your application’s exact origin registered on the site (for example
https://app.example.com). - The site’s public key (
pk_...). - For identity tokens (recommended): a signing secret (
ss_...) and its key ID from the site’s Keys page. - For server mint instead: a mint key (
sk_...). - Existing sign-in. The example uses a
gorilla/securecookiesession cookie with two demo users; your own authentication takes its place. Bunkhouse only needs one thing from it: the signed-in user’s stable ID on the server.
| File | Purpose |
|---|---|
config.go |
Validates the public Bunkhouse configuration at startup |
agent.go |
GET /api/agent-identity and POST /api/agent-session |
csp.go |
Your Content-Security-Policy with the Bunkhouse sources added |
templates/agent-embed-*.html |
The script tags for one installation mode |
public/agent-identity.js, public/agent-auth-headers.js |
Page hooks, loaded before the loader |
Identity token (recommended)
Section titled “Identity token (recommended)”Set the server environment. Only AGENT_PUBLIC_KEY and the origins ever reach the browser:
AGENT_PUBLIC_KEY=pk_...AGENT_SIGNING_SECRET=ss_... # server onlyAGENT_SIGNING_KID=... # key ID shown with the signing secretAGENT_ALLOWED_ORIGINS='["https://app.example.com"]'# AGENT_API_BASE and AGENT_EMBED_ORIGIN default to https://api.bunkhouse.ai and https://embed.bunkhouse.ai// Bunkhouse public configuration, validated once at startup. Signing and mint credentials are read// only by the endpoints that use them, so each mode needs only its own secret.package main
import ( "encoding/json" "errors" "fmt" "net/url" "os" "strconv" "strings")
type AgentConfig struct { PublicKey string AllowedOrigins []string APIBase string EmbedOrigin string}
// exactOrigin accepts only the canonical form browsers send in Origin: scheme://host[:port], lowercase// host, no default port, no userinfo, path, query or fragment.func exactOrigin(name, value string) (string, error) { u, err := url.Parse(value) if err != nil || (u.Scheme != "https" && u.Scheme != "http") || u.User != nil || u.Hostname() == "" { return "", fmt.Errorf("%s must be an exact origin like https://app.example.com", name) } host := strings.ToLower(u.Hostname()) if strings.Contains(host, ":") { host = "[" + host + "]" } if p := u.Port(); p != "" { n, err := strconv.Atoi(p) if err != nil { return "", fmt.Errorf("%s must be an exact origin like https://app.example.com", name) } if !(u.Scheme == "https" && n == 443) && !(u.Scheme == "http" && n == 80) { host += ":" + strconv.Itoa(n) } } if u.Scheme+"://"+host != value { return "", fmt.Errorf("%s must be an exact origin like https://app.example.com", name) } return value, nil}
func envOr(name, fallback string) string { if v := os.Getenv(name); v != "" { return v } return fallback}
func loadAgentConfig() (AgentConfig, error) { cfg := AgentConfig{PublicKey: os.Getenv("AGENT_PUBLIC_KEY")} if !strings.HasPrefix(cfg.PublicKey, "pk_") { return cfg, errors.New("AGENT_PUBLIC_KEY must be the site's public key (pk_...)") } var origins []string if json.Unmarshal([]byte(envOr("AGENT_ALLOWED_ORIGINS", "[]")), &origins) != nil || len(origins) == 0 { return cfg, errors.New(`AGENT_ALLOWED_ORIGINS must be a JSON array such as ["https://app.example.com"]`) } for _, o := range origins { origin, err := exactOrigin("AGENT_ALLOWED_ORIGINS", o) if err != nil { return cfg, err } cfg.AllowedOrigins = append(cfg.AllowedOrigins, origin) } var err error if cfg.APIBase, err = exactOrigin("AGENT_API_BASE", envOr("AGENT_API_BASE", "https://api.bunkhouse.ai")); err != nil { return cfg, err } if cfg.EmbedOrigin, err = exactOrigin("AGENT_EMBED_ORIGIN", envOr("AGENT_EMBED_ORIGIN", "https://embed.bunkhouse.ai")); err != nil { return cfg, err } return cfg, nil}The routes sign a ten-minute HS256 token with Go’s crypto/hmac for the user your session already authenticated. They reject other methods (405 with Allow), requests whose Sec-Fetch-Site is not same-origin (403) and signed-out users (401, never a login redirect), and mark every response Cache-Control: no-store. The subject comes only from the server session, never from the query, body or headers. The same file contains the server mint endpoint used by the alternative below.
// Bunkhouse endpoints: GET /api/agent-identity (identity token mode) and POST /api/agent-session// (server mint mode). Both vouch only for the user your existing session already authenticated.package main
import ( "bytes" "crypto/hmac" "crypto/sha256" "encoding/base64" "encoding/json" "io" "log" "net/http" "os" "slices" "time"
"github.com/gofiber/fiber/v3")
// CurrentUser is your existing authentication: the signed-in user's stable opaque ID, or "" when signed out.type CurrentUser func(c fiber.Ctx) string
func base64url(value any) string { data, _ := json.Marshal(value) return base64.RawURLEncoding.EncodeToString(data)}
// signIdentityToken returns an HS256 identity token: kid header, sub = stable opaque user ID, aud = public key, 10 minutes.func signIdentityToken(userID, publicKey, secret, kid string) string { iat := time.Now().Unix() header := base64url(struct { Alg string `json:"alg"` Typ string `json:"typ"` Kid string `json:"kid"` }{"HS256", "JWT", kid}) payload := base64url(struct { Sub string `json:"sub"` Aud string `json:"aud"` Iat int64 `json:"iat"` Exp int64 `json:"exp"` }{userID, publicKey, iat, iat + 600}) mac := hmac.New(sha256.New, []byte(secret)) mac.Write([]byte(header + "." + payload)) return header + "." + payload + "." + base64.RawURLEncoding.EncodeToString(mac.Sum(nil))}
func methodNotAllowed(allow string) fiber.Handler { return func(c fiber.Ctx) error { c.Set(fiber.HeaderAllow, allow) c.Set(fiber.HeaderCacheControl, "no-store") return c.Status(fiber.StatusMethodNotAllowed).JSON(fiber.Map{"error": "method_not_allowed"}) }}
func notConfigured(c fiber.Ctx, variable string) error { log.Printf("Bunkhouse: %s is not set", variable) return c.Status(fiber.StatusServiceUnavailable).JSON(fiber.Map{"error": "not_configured"})}
var sessionClient = &http.Client{Timeout: 15 * time.Second}
func agentRoutes(router fiber.Router, cfg AgentConfig, currentUser CurrentUser) { router.Get("/api/agent-identity", func(c fiber.Ctx) error { c.Set(fiber.HeaderCacheControl, "no-store") if c.Get("Sec-Fetch-Site") != "same-origin" { return c.Status(fiber.StatusForbidden).JSON(fiber.Map{"error": "forbidden"}) } userID := currentUser(c) if userID == "" { return c.Status(fiber.StatusUnauthorized).JSON(fiber.Map{"error": "unauthorized"}) } secret, kid := os.Getenv("AGENT_SIGNING_SECRET"), os.Getenv("AGENT_SIGNING_KID") if secret == "" { return notConfigured(c, "AGENT_SIGNING_SECRET") } if kid == "" { return notConfigured(c, "AGENT_SIGNING_KID") } return c.JSON(fiber.Map{"identityToken": signIdentityToken(userID, cfg.PublicKey, secret, kid)}) }) router.All("/api/agent-identity", methodNotAllowed("GET"))
router.Post("/api/agent-session", func(c fiber.Ctx) error { c.Set(fiber.HeaderCacheControl, "no-store") // The embed's POST carries no CSRF token; these three checks are this route's CSRF defense. origin := c.Get(fiber.HeaderOrigin) if !slices.Contains(cfg.AllowedOrigins, origin) || c.Get("X-Agent-Embed") != "1" || c.Get("Sec-Fetch-Site") != "same-origin" { return c.Status(fiber.StatusForbidden).JSON(fiber.Map{"error": "forbidden"}) } userID := currentUser(c) if userID == "" { return c.Status(fiber.StatusUnauthorized).JSON(fiber.Map{"error": "unauthorized"}) } key := os.Getenv("AGENT_EMBED_SECRET_KEY") if key == "" { return notConfigured(c, "AGENT_EMBED_SECRET_KEY") } body, _ := json.Marshal(map[string]string{"publicKey": cfg.PublicKey, "mode": "signed", "userId": userID, "origin": origin}) req, _ := http.NewRequest(http.MethodPost, cfg.APIBase+"/v1/embed/sessions", bytes.NewReader(body)) req.Header.Set("Authorization", "Bearer "+key) req.Header.Set("Content-Type", "application/json") res, err := sessionClient.Do(req) if err != nil { return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{"error": "session_service_unavailable"}) } defer res.Body.Close() upstream, err := io.ReadAll(res.Body) if err != nil { return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{"error": "session_service_unavailable"}) } contentType := res.Header.Get("Content-Type") if contentType == "" { contentType = fiber.MIMEApplicationJSON } c.Set(fiber.HeaderContentType, contentType) return c.Status(res.StatusCode).Send(upstream) }) router.All("/api/agent-session", methodNotAllowed("POST"))}Register the routes after your session middleware. currentUser is the seam to your authentication: return the signed-in user’s ID from what your middleware stored in c.Locals, or "".
// The signed-in user of this request (your existing authentication), or "".currentUser := func(c fiber.Ctx) string { if user := fiber.Locals[*session](c, "user"); user != nil { return user.ID } return ""}
// Bunkhouse endpoints, registered after the session middleware so they see the signed-in user.agentRoutes(app, agentConfig, currentUser)In the page head, load the identity hook and the auth-headers hook (see Auth headers), then the loader, all before your application’s own scripts: window.AgentEmbedConfig must be defined before the loader runs. The hooks are external same-origin scripts, so no inline script needs a CSP exception:
{{/* Identity token mode (recommended): both page hooks, then the loader, before the app's scripts. */}}<script src="/agent-identity.js" nonce="{{.Nonce}}"></script><script src="/agent-auth-headers.js" nonce="{{.Nonce}}"></script><script src="{{.Agent.EmbedOrigin}}/embed.js" nonce="{{.Nonce}}" data-public-key="{{.Agent.PublicKey}}" data-hints-url="/agent-hints.json"></script>// Identity token mode: the embed calls this hook whenever it starts a session for the signed-in user.window.AgentEmbedConfig = { ...window.AgentEmbedConfig, getIdentityToken: async () => { const res = await fetch("/api/agent-identity", { credentials: "same-origin", cache: "no-store" }); if (!res.ok) throw new Error("Not signed in"); return (await res.json()).identityToken; },};{{if .CSRFToken}}<meta name="csrf-token" content="{{.CSRFToken}}" />{{end}}{{/* Page hooks, then the loader (one installation mode), before the application's own JavaScript. */}}{{if eq .Mode "mint"}}{{template "agent-embed-mint" .}}{{else if eq .Mode "anonymous"}}{{template "agent-embed-anonymous" .}}{{else}}{{template "agent-embed-identity" .}}{{end}}<script src="/app.js" nonce="{{.Nonce}}" defer></script>The example layout includes one of the three agent-embed-* templates, selected by a test-only ?mode= switch. Your application uses exactly one.
Server mint alternative
Section titled “Server mint alternative”Instead of the identity hook, add data-session-endpoint to the loader. Do not keep agent-identity.js on the page: when getIdentityToken is defined it takes precedence.
{{/* Server mint mode: no identity hook; the embed posts to the same-origin session endpoint. */}}<script src="/agent-auth-headers.js" nonce="{{.Nonce}}"></script><script src="{{.Agent.EmbedOrigin}}/embed.js" nonce="{{.Nonce}}" data-public-key="{{.Agent.PublicKey}}" data-hints-url="/agent-hints.json" data-session-endpoint="/api/agent-session"></script>POST /api/agent-session in agent.go above accepts only requests with an Origin from AGENT_ALLOWED_ORIGINS, X-Agent-Embed: 1 and Sec-Fetch-Site: same-origin (403 otherwise), authenticates the session (401), then creates the session with the mint key and returns the API’s status and body unchanged with Cache-Control: no-store. If the API is unreachable it returns 502 without details. Set AGENT_EMBED_SECRET_KEY=sk_... on the server; the identity endpoint does not need it.
Fiber does not enable CSRF protection by default. If you use its middleware/csrf, exempt only /api/agent-session (for example with the middleware’s Next function): the embed’s POST carries no CSRF token, and the three header checks are that route’s protection.
Anonymous alternative
Section titled “Anonymous alternative”Anonymous sessions need only the loader. Enable anonymous access for the site in the dashboard first and set its monthly token and spend limits; usage is charged to your account’s credit and stops at a limit. Anyone who can load your page can start one, so it is not proof of identity.
{{/* Anonymous mode (enable it for the site first): no identity hook; the auth-headers hook, then the loader. */}}<script src="/agent-auth-headers.js" nonce="{{.Nonce}}"></script><script src="{{.Agent.EmbedOrigin}}/embed.js" nonce="{{.Nonce}}" data-public-key="{{.Agent.PublicKey}}" data-hints-url="/agent-hints.json"></script>Sign-in, sign-out and navigation
Section titled “Sign-in, sign-out and navigation”The example signs in and out with ordinary form posts that redirect back to the same page. Every account change therefore loads a new document, and a new document starts a new embed with no session, so the previous user’s session can never carry over. The session cookie is signed and encrypted, HttpOnly and SameSite, decoded by a middleware that puts the user in c.Locals, and replaced with a fresh CSRF token on every login:
deriveKey := func(label string) []byte { mac := hmac.New(sha256.New, []byte(secret)) mac.Write([]byte(label)) return mac.Sum(nil)}// Signed and encrypted session cookie; a cookie that fails to decode is no session.cookies := securecookie.New(deriveKey("session-hash"), deriveKey("session-block"))app.Use(func(c fiber.Ctx) error { var s session if raw := c.Cookies(sessionCookie); raw != "" && cookies.Decode(sessionCookie, raw, &s) == nil { c.Locals("user", &s) } return c.Next()})setSession := func(c fiber.Ctx, s session) error { value, err := cookies.Encode(sessionCookie, s) if err != nil { return err } // Secure everywhere except the loopback HTTP test origin. c.Cookie(&fiber.Cookie{Name: sessionCookie, Value: value, Path: "/", HTTPOnly: true, SameSite: fiber.CookieSameSiteLaxMode, Secure: strings.HasPrefix(appOrigin, "https://")}) return nil}If your Fiber app changes the signed-in user without a full page load (a fetch login, a single-page frontend), call window.AgentEmbed?.resetSession() right after the login, logout or account switch succeeds and before the new user’s requests. Render the loader once in the layout, not in per-page templates.
Auth headers, user IDs and CSP
Section titled “Auth headers, user IDs and CSP”The assistant calls your API with the page’s cookies; supply any extra header your API requires with getAuthHeaders. The example’s session owns a random CSRF token, rendered into a <meta> tag for signed-in users and checked as X-CSRF-Token on every write:
// The app's own CSRF token (rendered by the server for the signed-in session) for the assistant's calls// to this app's API. Values never reach the model or the sandbox.window.AgentEmbedConfig = { ...window.AgentEmbedConfig, getAuthHeaders: () => { const token = document.querySelector('meta[name="csrf-token"]')?.content; return token ? { "X-CSRF-Token": token } : {}; },};Every mode’s template loads it before the loader. The hook merges into window.AgentEmbedConfig, so it works with the identity hook in either order. Its values never reach the model or the sandbox.
Send a stable, opaque user ID (the example’s fixture-alice), not a name or email address.
Add the Bunkhouse sources to your existing policy rather than replacing it. The example’s middleware sets a fresh nonce per response in c.Locals and the templates put it on their script tags; no 'unsafe-inline' or 'unsafe-eval' is needed:
// The app's existing Content-Security-Policy with the Bunkhouse sources added: the embed origin to// script-src and frame-src, the API to connect-src. A fresh nonce per response (c.Locals("cspNonce"))// goes on the page's script tags.package main
import ( "crypto/rand" "strings"
"github.com/gofiber/fiber/v3")
func contentSecurityPolicy(cfg AgentConfig) fiber.Handler { return func(c fiber.Ctx) error { nonce := rand.Text() c.Locals("cspNonce", nonce) c.Set(fiber.HeaderContentSecurityPolicy, strings.Join([]string{ "default-src 'self'", "script-src 'self' 'nonce-" + nonce + "' " + cfg.EmbedOrigin, "style-src 'self' 'nonce-" + nonce + "'", "frame-src " + cfg.EmbedOrigin, "connect-src 'self' " + cfg.APIBase, "img-src 'self' data:", "object-src 'none'", "base-uri 'self'", "form-action 'self'", "frame-ancestors 'self'", }, "; ")) return c.Next() }}Verify
Section titled “Verify”From a checkout of the Bunkhouse repository, with Docker and local Supabase running:
node tests/framework-integrations/run.ts fiberThe run builds the example image, starts it against a fresh local site and drives the real pane in Chromium: identity, mint and anonymous sessions, endpoint guards, sign-out and account switches, discovery of the page’s startup request, a CSRF-protected write through getAuthHeaders, CSP and secret checks. In your own app, sign in and open the Assistant launcher: the first message creates a signed session.
| Symptom | Check |
|---|---|
/api/agent-identity returns 401 |
The routes are registered before your session middleware, or currentUser does not find the user in c.Locals. |
| 403 from either endpoint | The request is cross-site or missing Sec-Fetch-Site; for mint, Origin must exactly match AGENT_ALLOWED_ORIGINS and the loader must carry data-session-endpoint. A CSRF middleware must exempt only /api/agent-session. |
| 503 | The signing secret, key ID or mint key for the mode you use is not set. |
| The pane reports a CSP block | Add the embed origin to script-src and frame-src and the API to connect-src. |
| Startup requests are not discovered | The loader must come before your application’s scripts in the head. |
| Two launchers | Render the loader once, in the layout. |
| A secret in page source | Only AGENT_PUBLIC_KEY and origins belong in templates; keep ss_ and sk_ values in server environment variables. |
Related
Section titled “Related”- Installation, Security and the Page API
- Fiber: Routing, Templates