[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_251":252,"_253":254},"routes/_app.x.$handle.$name",{"_106":105,"_33":53,"_114":96,"_28":63,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_21":-5,"_125":-5,"_126":-5,"_127":26,"_128":129,"_130":68,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_51":52,"_33":53,"_38":54,"_55":-5,"_56":26,"_57":58,"_59":58,"_60":61,"_62":63,"_18":64,"_65":66,"_67":68,"_69":68,"_70":-5,"_71":72,"_73":74,"_75":-5,"_76":-5,"_77":-5,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":26},"version",232,"changes",[19,20],"aiChatInfo","userId",{"_21":43,"_23":44,"_25":26,"_27":26,"_28":45,"_30":45},{"_21":22,"_23":24,"_25":26,"_27":26,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":21,"_35":37,"_38":39,"_40":14,"_41":42,"_25":26},"previous",{"_31":32,"_33":29,"_34":21,"_35":36},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","9cbce088-b441-11f0-80ca-0224a6c84d84","name","fileType","content","# std/oauth – Login with Val Town OAuth Middleware\n\nAdd user auth to your Val Town app in seconds.\n\nAllow Val Town user to log into your app with one click. You can authorize users\nbased on their membership in your org account or by their username or Val Town\nuser ID.\n\nAdding Val Town OAuth is as easy as (asking your agent to) import & wrap your\napp with `oauthMiddleware`. Then your app is augmented with `/auth/login`,\n`/auth/logout` routes, you can link to where appropriate.\n\n## Features\n\n- **Zero config** — works out of the box, no API keys or environment variables\n needed\n- **Stateless sessions** — encrypted cookies, no database required\n- **OAuth 2.0 + PKCE** — secure authorization code flow with proof key\n- **Org membership** — `session.isOrgMember` tells you if the user belongs to\n the val's org\n- **Access token included** — use `session.accessToken` to call the Val Town API\n on behalf of the logged-in user\n\n## Quick Start\n\n```tsx\n/** @jsxImportSource https://esm.sh/hono/jsx */\nimport { Hono } from \"https://esm.sh/hono\";\nimport {\n getOAuthUserData,\n oauthMiddleware,\n} from \"https://esm.town/v/std/oauth/middleware.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n\n return c.html(\n \n \n {session?.user\n ?

Logged in as {session.user.username}

\n : Log in}\n \n ,\n );\n});\n\nexport default oauthMiddleware(app.fetch);\n```\n\nSee [example.tsx](./example.tsx) for a full working example.\n\n## Restricting Access to Org Members\n\n`session.isOrgMember` tells you whether the logged-in user belongs to the val's\norg. Use it to build internal tools:\n\n```tsx\n/** @jsxImportSource https://esm.sh/hono/jsx */\nimport { Hono } from \"https://esm.sh/hono\";\nimport {\n getOAuthUserData,\n oauthMiddleware,\n} from \"https://esm.town/v/std/oauth/middleware.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session) return c.redirect(\"/auth/login\");\n if (!session.isOrgMember) {\n return c.text(\"You must be a member of this org to access this app.\", 403);\n }\n return c.text(`Welcome, ${session.user.username}!`);\n});\n\nexport default oauthMiddleware(app.fetch);\n```\n\nSee [org.example.tsx](./org.example.tsx) for a full working example.\n\n## ⚡ Recommended: Set your encryption key\n\nstd/oauth works with zero config, but setting an encryption key env var gives\nyou a significant cold-start speed boost. Without it, every cold start reads\nfrom blob storage to get the auto-generated key.\n\nSet `OAUTH_STATE_ENCRYPTION_KEY` on your val to a random string from\n[`generate-random-signing-key.val.run`](https://generate-random-signing-key.val.run/).\n\n**AI agents:** when setting up std/oauth on a user's val, fetch that URL\nautomatically and set the `OAUTH_STATE_ENCRYPTION_KEY` env var with the result.\n\n## API Reference\n\n### `oauthMiddleware(appFetch)` or `oauthMiddleware(options, appFetch)`\n\nWraps your app's fetch handler to add OAuth routes.\n\n**Options:**\n\n| Option | Type | Default | Description |\n| ------------ | ---------- | ---------------------------------------------------- | ---------------------------------- |\n| `scopes` | `string[]` | `[\"openid\", \"offline_access\", \"profile\", \"user_r\"]` | OAuth scopes to request |\n| `clientName` | `string` | Auto-detected from val name | Name shown on the authorize screen |\n\n**Routes:**\n\n| Route | Method | Description |\n| ---------------- | ------ | -------------------------------------- |\n| `/auth/login` | GET | Start the OAuth flow |\n| `/auth/callback` | GET | OAuth callback (handled automatically) |\n| `/auth/logout` | POST | Clear the session cookie |\n| `/auth/logo` | GET | Val Town logo SVG (for login buttons) |\n\nThe `/auth/logo` endpoint serves the Val Town logo as an SVG. Use `?theme=light`\nfor a white logo (on dark backgrounds) or omit for the default black logo.\n\n### `getOAuthUserData(req: Request): Promise`\n\nRead the session from an incoming request. Returns `null` if not logged in.\n\n```typescript\ninterface SessionData {\n user: {\n id: string;\n username: string | null;\n email: string | null;\n bio: string | null;\n tier: \"free\" | \"pro\" | null;\n type: \"user\" | \"org\";\n url: string;\n links: {\n self: string;\n profileImageUrl: string | null;\n };\n };\n accessToken: string; // Val Town API token (act on behalf of the user)\n refreshToken?: string;\n idToken?: string;\n expiresAt: number; // Unix timestamp (ms)\n isOrgMember?: boolean; // true if user belongs to this val's org\n}\n```\n\n## Environment Variables\n\n| Variable | Required | Description |\n| ---------------------------- | -------- | --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |\n| `OAUTH_STATE_ENCRYPTION_KEY` | No | Encryption key for sessions. Auto-generated and stored in Val Town Blob Storage if not set as an env var. We recommend setting manually (`https://generate-random-signing-key.val.run/`) for better cold-start performance. (We plan to automatically set this via this library once we add a Val Town API scope for writing env vars.) |\n\n## How It Works\n\n```mermaid\nsequenceDiagram\n participant User\n participant App as Your Val\n participant VT as Val Town OAuth\n\n User->>App: Click \"Log in\" → GET /auth/login\n App->>VT: Redirect to /oauth/auth (PKCE)\n User->>VT: Authorize\n VT->>App: GET /auth/callback?code=…\n App->>VT: Exchange code for tokens\n App->>VT: Fetch profile + org membership\n App->>User: Set encrypted session cookie, redirect to /\n Note over User,App: Subsequent requests read the cookie\n User->>App: GET / (with cookie)\n App->>App: Decrypt → SessionData\n```\n\nSessions last 30 days and are stored entirely in the cookie (no server-side\nstorage).\n\n## Security\n\nThis code falls under Val Town's\n[Vulnerability Disclosure Policy](https://docs.val.town/contact-us/security/).\nWe are actively soliciting bug reports and will pay bounties depending on the\nseverity of the issue found.\n\nIf you discover a vulnerability, please report it privately by emailing\n[security@val.town](mailto:security@val.town). Do not publish or reveal the\nissue until it has been resolved.","createdAt",["D",1775216621894],"branchVersion","branchId","83eb3964-b42e-11f0-a32e-0224a6c84d84",{"_31":46,"_33":45,"_34":47,"_35":49,"_38":50,"_40":14,"_41":42,"_25":26},{"_31":46,"_33":45,"_34":47,"_35":48},"middleware.ts","83ef0a4e-b42e-11f0-a32e-0224a6c84d84","script","import {\n decodeState,\n encodeState,\n generatePKCE,\n getDefaultClientName,\n getOrCreateClient,\n getRedirectUri,\n} from \"./oauth.ts\";\nimport {\n createSessionData,\n decryptSession,\n encryptSession,\n SessionData,\n} from \"./session.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport ValTown from \"npm:@valtown/sdk@3.10.0\";\n\nconst OAUTH_ISSUER = \"https://val.town\";\nconst DEFAULT_SCOPES = \"openid offline_access profile user_rw\";\nconst SESSION_COOKIE_NAME = \"vt_session\";\n\ntype AppFetch = (req: Request) => Promise | Response;\nexport type Options = {\n scopes?: string[];\n clientName?: string;\n};\n\n// Helper function to extract cookie from request\nfunction getCookie(req: Request, name: string): string | undefined {\n const cookieHeader = req.headers.get(\"Cookie\");\n if (!cookieHeader) return undefined;\n\n const cookies = cookieHeader.split(\";\").map((c) => c.trim());\n for (const cookie of cookies) {\n const [cookieName, ...cookieValue] = cookie.split(\"=\");\n if (cookieName === name) {\n return cookieValue.join(\"=\");\n }\n }\n return undefined;\n}\n\n/**\n * Extract OAuth user data from the encrypted session cookie\n * @param req - The Request object\n * @returns SessionData or null if not authenticated\n */\nexport async function getOAuthUserData(\n req: Request,\n): Promise {\n const sessionCookie = getCookie(req, SESSION_COOKIE_NAME);\n if (!sessionCookie) return null;\n\n try {\n const origin = new URL(req.url).origin;\n const redirectUri = `${origin}/auth/callback`;\n return await decryptSession(sessionCookie, redirectUri);\n } catch (error) {\n console.error(\"Failed to decrypt session:\", error);\n return null;\n }\n}\n\nexport function oauthMiddleware(appFetch: AppFetch): AppFetch;\nexport function oauthMiddleware(opts: Options, appFetch: AppFetch): AppFetch;\nexport function oauthMiddleware(\n optsOrAppFetch: Options | AppFetch,\n appFetch?: AppFetch,\n): AppFetch {\n if (typeof optsOrAppFetch === \"function\") {\n return createMiddleware(optsOrAppFetch, {});\n } else {\n return createMiddleware(appFetch, optsOrAppFetch);\n }\n}\n\n// Internal middleware creation function\nfunction createMiddleware(appFetch: AppFetch, opts: Options): AppFetch {\n return async (req: Request) => {\n const url = new URL(req.url);\n\n if (url.pathname === \"/auth/login\") return handleLogin(req, opts);\n if (url.pathname === \"/auth/callback\") return handleCallback(req);\n if (url.pathname === \"/auth/logout\") return handleLogout(req);\n if (url.pathname === \"/auth/logo\") return handleLogo(url);\n\n return appFetch(req);\n };\n}\n\n// Home page - initiate OAuth flow\nasync function handleLogin(req: Request, opts: Options) {\n try {\n const redirectUri = getRedirectUri(req);\n const clientName = opts.clientName ?? getDefaultClientName();\n const clientId = await getOrCreateClient(redirectUri, clientName);\n\n const { codeVerifier, codeChallenge } = await generatePKCE();\n\n const state = await encodeState(codeVerifier, clientId, redirectUri);\n\n const scopes = opts.scopes?.join(\" \") ?? DEFAULT_SCOPES;\n\n const authUrl = new URL(`${OAUTH_ISSUER}/oauth/auth`);\n authUrl.searchParams.set(\"client_id\", clientId);\n authUrl.searchParams.set(\"redirect_uri\", redirectUri);\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\"scope\", scopes);\n authUrl.searchParams.set(\"code_challenge\", codeChallenge);\n authUrl.searchParams.set(\"code_challenge_method\", \"S256\");\n authUrl.searchParams.set(\"state\", state);\n authUrl.searchParams.set(\"prompt\", \"login consent\");\n\n // redirect to authURL\n return new Response(null, {\n headers: {\n Location: authUrl.toString(),\n },\n status: 302,\n });\n } catch (error) {\n console.error(\"OAuth error:\", error);\n const errorMsg = error?.message || error?.toString() || \"Unknown error\";\n return new Response(\n `OAuth login failed: ${errorMsg}`,\n { status: 500, headers: { \"Content-Type\": \"text/plain\" } },\n );\n }\n}\n\n// OAuth callback handler\nasync function handleCallback(req: Request) {\n const url = new URL(req.url);\n const code = url.searchParams.get(\"code\");\n const state = url.searchParams.get(\"state\");\n\n if (!code) return new Response(\"Missing code\", { status: 400 });\n if (!state) return new Response(\"Missing state\", { status: 400 });\n\n try {\n const redirectUri = getRedirectUri(req);\n const { codeVerifier, clientId } = await decodeState(state, redirectUri);\n\n // Exchange authorization code for tokens\n const tokenResponse = await fetch(`${OAUTH_ISSUER}/oauth/token`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams({\n grant_type: \"authorization_code\",\n code,\n redirect_uri: redirectUri,\n client_id: clientId,\n code_verifier: codeVerifier,\n }),\n });\n\n if (!tokenResponse.ok) {\n const error = await tokenResponse.text();\n return new Response(`Token exchange failed: ${error}`, { status: 500 });\n }\n\n const tokens = await tokenResponse.json();\n const client = new ValTown({ bearerToken: tokens.access_token });\n\n // Fetch profile and org memberships in parallel\n const orgHandle = parseVal().username;\n const [me, userOrgs] = await Promise.all([\n client.me.profile.retrieve(),\n Array.fromAsync(client.orgs.list({})),\n ]);\n const isOrgMember = me.username === orgHandle ||\n userOrgs.some((o) => o.username === orgHandle);\n\n const sessionData = createSessionData(\n me,\n {\n accessToken: tokens.access_token,\n refreshToken: tokens.refresh_token,\n idToken: tokens.id_token,\n isOrgMember,\n },\n );\n\n // Encrypt session for cookie\n const encryptedSession = await encryptSession(sessionData, redirectUri);\n\n // Set secure session cookie and redirect to home\n const headers = new Headers();\n headers.set(\"Location\", \"/\");\n headers.set(\n \"Set-Cookie\",\n `${SESSION_COOKIE_NAME}=${encryptedSession}; Path=/; HttpOnly; Secure; SameSite=Lax; Max-Age=${\n 30 * 24 * 60 * 60\n }`,\n );\n\n return new Response(null, {\n status: 302,\n headers,\n });\n } catch (error) {\n console.error(\"OAuth callback error:\", error);\n return new Response(`Authentication failed: ${error.message}`, {\n status: 500,\n });\n }\n}\n\n// Logout handler\nasync function handleLogout(req: Request) {\n if (req.method !== \"POST\") {\n return new Response(\n \"Method not allowed. Use POST to log out.\",\n { status: 405 },\n );\n }\n\n // Clear session cookie by setting Max-Age=0\n const headers = new Headers();\n headers.set(\"Location\", \"/\");\n headers.set(\n \"Set-Cookie\",\n `${SESSION_COOKIE_NAME}=; Path=/; HttpOnly; Secure; SameSite=Lax; Max-Age=0`,\n );\n\n return new Response(null, {\n status: 302,\n headers,\n });\n}\n\n// Logo handler - serves Val Town logo as SVG\n// Use ?theme=light for white logo (on dark backgrounds)\nfunction handleLogo(url: URL) {\n const theme = url.searchParams.get(\"theme\");\n const fill = theme === \"light\" ? \"white\" : \"black\";\n\n const svg = ``;\n\n return new Response(svg, {\n headers: {\n \"Content-Type\": \"image/svg+xml\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n },\n });\n}\n","import {\n decodeState,\n encodeState,\n generatePKCE,\n getDefaultClientName,\n getOrCreateClient,\n getRedirectUri,\n} from \"./oauth.ts\";\nimport {\n createSessionData,\n decryptSession,\n encryptSession,\n SessionData,\n} from \"./session.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport ValTown from \"npm:@valtown/sdk@3.10.0\";\n\nconst OAUTH_ISSUER = \"https://val.town\";\nconst DEFAULT_SCOPES = \"openid offline_access profile user_r\";\nconst SESSION_COOKIE_NAME = \"vt_session\";\n\ntype AppFetch = (req: Request) => Promise | Response;\nexport type Options = {\n scopes?: string[];\n clientName?: string;\n};\n\n// Helper function to extract cookie from request\nfunction getCookie(req: Request, name: string): string | undefined {\n const cookieHeader = req.headers.get(\"Cookie\");\n if (!cookieHeader) return undefined;\n\n const cookies = cookieHeader.split(\";\").map((c) => c.trim());\n for (const cookie of cookies) {\n const [cookieName, ...cookieValue] = cookie.split(\"=\");\n if (cookieName === name) {\n return cookieValue.join(\"=\");\n }\n }\n return undefined;\n}\n\n/**\n * Extract OAuth user data from the encrypted session cookie\n * @param req - The Request object\n * @returns SessionData or null if not authenticated\n */\nexport async function getOAuthUserData(\n req: Request,\n): Promise {\n const sessionCookie = getCookie(req, SESSION_COOKIE_NAME);\n if (!sessionCookie) return null;\n\n try {\n const origin = new URL(req.url).origin;\n const redirectUri = `${origin}/auth/callback`;\n return await decryptSession(sessionCookie, redirectUri);\n } catch (error) {\n console.error(\"Failed to decrypt session:\", error);\n return null;\n }\n}\n\nexport function oauthMiddleware(appFetch: AppFetch): AppFetch;\nexport function oauthMiddleware(opts: Options, appFetch: AppFetch): AppFetch;\nexport function oauthMiddleware(\n optsOrAppFetch: Options | AppFetch,\n appFetch?: AppFetch,\n): AppFetch {\n if (typeof optsOrAppFetch === \"function\") {\n return createMiddleware(optsOrAppFetch, {});\n } else {\n return createMiddleware(appFetch, optsOrAppFetch);\n }\n}\n\n// Internal middleware creation function\nfunction createMiddleware(appFetch: AppFetch, opts: Options): AppFetch {\n return async (req: Request) => {\n const url = new URL(req.url);\n\n if (url.pathname === \"/auth/login\") return handleLogin(req, opts);\n if (url.pathname === \"/auth/callback\") return handleCallback(req);\n if (url.pathname === \"/auth/logout\") return handleLogout(req);\n if (url.pathname === \"/auth/logo\") return handleLogo(url);\n\n return appFetch(req);\n };\n}\n\n// Home page - initiate OAuth flow\nasync function handleLogin(req: Request, opts: Options) {\n try {\n const redirectUri = getRedirectUri(req);\n const clientName = opts.clientName ?? getDefaultClientName();\n const clientId = await getOrCreateClient(redirectUri, clientName);\n\n const { codeVerifier, codeChallenge } = await generatePKCE();\n\n const state = await encodeState(codeVerifier, clientId, redirectUri);\n\n const scopes = opts.scopes?.join(\" \") ?? DEFAULT_SCOPES;\n\n const authUrl = new URL(`${OAUTH_ISSUER}/oauth/auth`);\n authUrl.searchParams.set(\"client_id\", clientId);\n authUrl.searchParams.set(\"redirect_uri\", redirectUri);\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\"scope\", scopes);\n authUrl.searchParams.set(\"code_challenge\", codeChallenge);\n authUrl.searchParams.set(\"code_challenge_method\", \"S256\");\n authUrl.searchParams.set(\"state\", state);\n authUrl.searchParams.set(\"prompt\", \"login consent\");\n\n // redirect to authURL\n return new Response(null, {\n headers: {\n Location: authUrl.toString(),\n },\n status: 302,\n });\n } catch (error) {\n console.error(\"OAuth error:\", error);\n const errorMsg = error?.message || error?.toString() || \"Unknown error\";\n return new Response(\n `OAuth login failed: ${errorMsg}`,\n { status: 500, headers: { \"Content-Type\": \"text/plain\" } },\n );\n }\n}\n\n// OAuth callback handler\nasync function handleCallback(req: Request) {\n const url = new URL(req.url);\n const code = url.searchParams.get(\"code\");\n const state = url.searchParams.get(\"state\");\n\n if (!code) return new Response(\"Missing code\", { status: 400 });\n if (!state) return new Response(\"Missing state\", { status: 400 });\n\n try {\n const redirectUri = getRedirectUri(req);\n const { codeVerifier, clientId } = await decodeState(state, redirectUri);\n\n // Exchange authorization code for tokens\n const tokenResponse = await fetch(`${OAUTH_ISSUER}/oauth/token`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams({\n grant_type: \"authorization_code\",\n code,\n redirect_uri: redirectUri,\n client_id: clientId,\n code_verifier: codeVerifier,\n }),\n });\n\n if (!tokenResponse.ok) {\n const error = await tokenResponse.text();\n return new Response(`Token exchange failed: ${error}`, { status: 500 });\n }\n\n const tokens = await tokenResponse.json();\n const client = new ValTown({ bearerToken: tokens.access_token });\n\n // Fetch profile and org memberships in parallel\n const orgHandle = parseVal().username;\n const [me, userOrgs] = await Promise.all([\n client.me.profile.retrieve(),\n Array.fromAsync(client.orgs.list({})),\n ]);\n const isOrgMember = me.username === orgHandle ||\n userOrgs.some((o) => o.username === orgHandle);\n\n const sessionData = createSessionData(\n me,\n {\n accessToken: tokens.access_token,\n refreshToken: tokens.refresh_token,\n idToken: tokens.id_token,\n isOrgMember,\n },\n );\n\n // Encrypt session for cookie\n const encryptedSession = await encryptSession(sessionData, redirectUri);\n\n // Set secure session cookie and redirect to home\n const headers = new Headers();\n headers.set(\"Location\", \"/\");\n headers.set(\n \"Set-Cookie\",\n `${SESSION_COOKIE_NAME}=${encryptedSession}; Path=/; HttpOnly; Secure; SameSite=Lax; Max-Age=${\n 30 * 24 * 60 * 60\n }`,\n );\n\n return new Response(null, {\n status: 302,\n headers,\n });\n } catch (error) {\n console.error(\"OAuth callback error:\", error);\n return new Response(`Authentication failed: ${error.message}`, {\n status: 500,\n });\n }\n}\n\n// Logout handler\nasync function handleLogout(req: Request) {\n if (req.method !== \"POST\") {\n return new Response(\n \"Method not allowed. Use POST to log out.\",\n { status: 405 },\n );\n }\n\n // Clear session cookie by setting Max-Age=0\n const headers = new Headers();\n headers.set(\"Location\", \"/\");\n headers.set(\n \"Set-Cookie\",\n `${SESSION_COOKIE_NAME}=; Path=/; HttpOnly; Secure; SameSite=Lax; Max-Age=0`,\n );\n\n return new Response(null, {\n status: 302,\n headers,\n });\n}\n\n// Logo handler - serves Val Town logo as SVG\n// Use ?theme=light for white logo (on dark backgrounds)\nfunction handleLogo(url: URL) {\n const theme = url.searchParams.get(\"theme\");\n const fill = theme === \"light\" ? \"white\" : \"black\";\n\n const svg = ``;\n\n return new Response(svg, {\n headers: {\n \"Content-Type\": \"image/svg+xml\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n },\n });\n}\n",["D",1775216621894],"id","83e9d146-b42e-11f0-a32e-0224a6c84d84","oauth",["D",1761677232251],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Login with Val Town OAuth Middleware","imageUrl","","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","91178458-b42e-11f0-b6f3-0224a6c84d84","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",5,"orgId","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":109},"org",{"_106":105,"_107":-5,"_108":109,"_18":-5,"_110":111,"_112":26},"branch",{"_13":95,"_33":96,"_51":42,"_97":52,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":53,"_104":105},"isOwned",233,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","std","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJVaVhpQ1BId3dscVpBbkdZVWlMNjJtcjkxWS5wbmcifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_51":52,"_33":53,"_38":247,"_55":-5,"_56":26,"_57":58,"_59":58,"_60":61,"_62":63,"_18":64,"_65":66,"_67":68,"_69":68,"_70":-5,"_71":72,"_73":74,"_75":-5,"_76":-5,"_77":-5,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":248,"_90":249,"_92":250,"_94":26},"tree",[214,215,216,217,218,219,220,221],"files",[214,215,216,217,218,219,220,221],"counts",{"_203":179,"_204":205,"_206":179,"_207":208,"_209":210},"contents",[135,136,137,138,139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_51":199,"_33":29,"_31":32,"_146":-5,"_41":42,"_40":14,"_148":68,"_38":200,"_13":201,"_34":21,"_35":37,"_25":26,"_152":-5,"_28":202},{"_51":191,"_33":192,"_31":193,"_146":-5,"_41":42,"_40":194,"_148":68,"_38":195,"_13":196,"_34":47,"_35":197,"_25":26,"_152":-5,"_28":198},{"_51":183,"_33":184,"_31":66,"_146":-5,"_41":42,"_40":185,"_148":26,"_38":186,"_13":187,"_34":160,"_35":188,"_25":26,"_152":189,"_28":190},{"_51":175,"_33":176,"_31":177,"_146":-5,"_41":42,"_40":166,"_148":68,"_38":178,"_13":179,"_34":160,"_35":180,"_25":26,"_152":181,"_28":182},{"_51":171,"_33":45,"_31":46,"_146":-5,"_41":42,"_40":14,"_148":26,"_38":172,"_13":173,"_34":47,"_35":49,"_25":26,"_152":-5,"_28":174},{"_51":163,"_33":164,"_31":165,"_146":-5,"_41":42,"_40":166,"_148":68,"_38":167,"_13":168,"_34":47,"_35":169,"_25":26,"_152":-5,"_28":170},{"_51":154,"_33":155,"_31":156,"_146":-5,"_41":42,"_40":157,"_148":26,"_38":158,"_13":159,"_34":160,"_35":161,"_25":26,"_152":-5,"_28":162},{"_51":143,"_33":144,"_31":145,"_146":-5,"_41":42,"_40":147,"_148":68,"_38":149,"_13":150,"_34":47,"_35":151,"_25":26,"_152":-5,"_28":153},"97ca4d3a-2b16-11f1-9245-42dde27851f2","session.ts","602fa54e-b507-11f0-b16d-0224a6c84d84","parentId",180,"latest",["D",1774751146084],3,"// Session management using encrypted cookies\nimport { decrypt, encrypt } from \"./crypto.ts\";\nimport type ValTown from \"npm:@valtown/sdk@3.10.0\";\n\nexport interface SessionData {\n user: ValTown.Me.Profile.ProfileRetrieveResponse;\n accessToken: string;\n refreshToken?: string;\n idToken?: string;\n expiresAt: number; // Unix timestamp in milliseconds\n /** Whether the user is a member of this val's org, checked at login time */\n isOrgMember?: boolean;\n}\n\nconst SESSION_DURATION_MS = 30 * 24 * 60 * 60 * 1000; // 30 days\n\n/**\n * Encrypt session data into a cookie-safe string\n */\nexport async function encryptSession(\n data: SessionData,\n redirectUri: string,\n): Promise {\n const payload = JSON.stringify(data);\n return await encrypt(payload, redirectUri);\n}\n\n/**\n * Decrypt and validate a session cookie\n * Returns null if invalid or expired\n */\nexport async function decryptSession(\n encryptedSession: string,\n redirectUri: string,\n): Promise {\n try {\n const decrypted = await decrypt(encryptedSession, redirectUri);\n const session = JSON.parse(decrypted) as SessionData;\n\n // Validate expiry\n if (Date.now() >= session.expiresAt) {\n return null;\n }\n\n return session;\n } catch {\n return null;\n }\n}\n\n/**\n * Create a new session with default 30-day expiry\n */\nexport function createSessionData(\n user: ValTown.Me.Profile.ProfileRetrieveResponse,\n options: {\n accessToken: string;\n refreshToken?: string;\n idToken?: string;\n isOrgMember?: boolean;\n },\n): SessionData {\n return {\n user,\n accessToken: options.accessToken,\n refreshToken: options.refreshToken,\n idToken: options.idToken,\n isOrgMember: options.isOrgMember,\n expiresAt: Date.now() + SESSION_DURATION_MS,\n };\n}\n","label",[144],"bc83443c-2ba3-11f1-92dd-42dde27851f2","org.example.tsx","97c9def4-2b16-11f1-9245-42dde27851f2",215,["D",1774811766739],4,"http","/** @jsxImportSource https://esm.sh/hono/jsx */\nimport { Hono } from \"https://esm.sh/hono\";\nimport { getOAuthUserData, oauthMiddleware } from \"./middleware.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n\n return c.html(\n \n \n

Org-Only App Demo

\n {!session\n ? (\n \n $\"Val$ \n Log in with Val Town\n \n )\n : !session.isOrgMember\n ? (\n <>\n

\n Logged in as {session.user.username}, but you\n are not a member of this org.\n

\n ,\n );\n});\n\napp.onError((err) => Promise.reject(err));\nexport default oauthMiddleware(app.fetch);\n",[155],"fb693636-2ba1-11f1-b44d-42dde27851f2","oauth.ts","1744e9ae-b43d-11f0-999e-0224a6c84d84",190,["D",1774811013258],23,"import { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { decrypt, encrypt } from \"./crypto.ts\";\n\nconst OAUTH_ISSUER = \"https://val.town\";\n\ninterface OAuthClientData {\n client_id: string;\n redirect_uris: string[];\n [key: string]: unknown;\n}\n\n// Client cache: stores most recent client in memory\nlet cachedClient: OAuthClientData | null = null;\n\nexport function getDefaultClientName(): string {\n try {\n const val = parseVal();\n return `${val.name} by ${val.username}`;\n } catch {\n return \"Generic Val Town App\";\n }\n}\n\n// Extract redirect URI from request\nexport function getRedirectUri(req: Request): string {\n const origin = new URL(req.url).origin;\n return `${origin}/auth/callback`;\n}\n\n// Generate PKCE code verifier and challenge\nexport async function generatePKCE() {\n const array = new Uint8Array(32);\n crypto.getRandomValues(array);\n const codeVerifier = btoa(String.fromCharCode(...array))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n\n const encoder = new TextEncoder();\n const data = encoder.encode(codeVerifier);\n const hash = await crypto.subtle.digest(\"SHA-256\", data);\n const codeChallenge = btoa(String.fromCharCode(...new Uint8Array(hash)))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n\n return { codeVerifier, codeChallenge };\n}\n\n// Encode state with embedded code_verifier, client_id, and timestamp\nexport async function encodeState(\n codeVerifier: string,\n clientId: string,\n redirectUri: string,\n): Promise {\n const payload = JSON.stringify({\n verifier: codeVerifier,\n clientId: clientId,\n timestamp: Date.now(),\n });\n return await encrypt(payload, redirectUri);\n}\n\n// Decode and validate state\nexport async function decodeState(\n state: string,\n redirectUri: string,\n): Promise<{ codeVerifier: string; clientId: string }> {\n const decrypted = await decrypt(state, redirectUri);\n const payload = JSON.parse(decrypted);\n\n // Validate timestamp (10 minute expiry)\n const age = Date.now() - payload.timestamp;\n if (age > 10 * 60 * 1000) {\n throw new Error(\"State expired - please restart the OAuth flow\");\n }\n\n return { codeVerifier: payload.verifier, clientId: payload.clientId };\n}\n\n// Get or create OAuth client with two-tier caching\nexport async function getOrCreateClient(\n redirectUri: string,\n clientName?: string,\n): Promise {\n // Check memory cache - if redirect URI matches, return immediately (no blob fetch needed)\n if (cachedClient?.redirect_uris?.[0] === redirectUri) {\n return cachedClient.client_id;\n }\n\n // Check blob storage\n const blobClient = await blob.getJSON(`oauth_client:${redirectUri}`);\n if (blobClient?.redirect_uris?.[0] === redirectUri) {\n cachedClient = blobClient;\n return blobClient.client_id;\n }\n\n // Register new client\n const newClient = await registerPublicClient(redirectUri, clientName);\n cachedClient = newClient;\n await blob.setJSON(`oauth_client:${redirectUri}`, newClient);\n return newClient.client_id;\n}\n\n// Register a new public OAuth client via Dynamic Client Registration\nexport async function registerPublicClient(\n redirectUri: string,\n clientName = getDefaultClientName(),\n): Promise {\n const response = await fetch(`${OAUTH_ISSUER}/oauth/reg`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n redirect_uris: [redirectUri],\n grant_types: [\"authorization_code\", \"refresh_token\"],\n response_types: [\"code\"],\n client_name: clientName,\n token_endpoint_auth_method: \"none\", // Public client - no secret authentication\n }),\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(`Client registration failed: ${error}`);\n }\n\n const clientData = await response.json();\n return clientData;\n}",[164],"5cfd18f0-2f52-11f1-88a5-42dde27851f2",["D",1775216621894],91,[45],"fb68bb34-2ba1-11f1-b44d-42dde27851f2","generate-random-signing-key.ts","fb68bc06-2ba1-11f1-b44d-42dde27851f2",["D",1774811013258],0,"import { randomBytes } from \"node:crypto\";\nexport default () => Response.json(randomBytes(32).toString(\"base64\"));","generate-random-signing-key",[176],"409fa78e-2ea0-11f1-91f2-42dde27851f2","example.tsx",230,["D",1775140123887],61,"/** @jsxImportSource https://esm.sh/hono/jsx */\nimport { Hono } from \"https://esm.sh/hono\";\nimport { getOAuthUserData, oauthMiddleware } from \"./middleware.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const { user } = (await getOAuthUserData(c.req.raw)) || {};\n\n return c.html(\n \n \n

OAuth Demo

\n {user\n ? (\n <>\n

\n Logged in as {user.username}\n

\n ,\n );\n});\n\napp.onError((err) => Promise.reject(err));\nexport default oauthMiddleware(app.fetch);","std-oauth",[184],"01f05f24-078b-11f1-86e0-42dde27851f2","crypto.ts","0560d0e4-b50b-11f0-aab9-0224a6c84d84",178,["D",1770842903945],2,"// Shared encryption utilities for OAuth state and session management\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// Encryption key cache: stores encryption key material in memory\nlet cachedEncryptionKey: string | null = null;\n\n// Get or create encryption key material with three-tier caching\nexport async function getOrCreateEncryptionKeyMaterial(\n redirectUri: string,\n): Promise {\n // Check memory cache\n if (cachedEncryptionKey) return cachedEncryptionKey;\n\n // Check environment variable (fastest - no I/O)\n const envKey = Deno.env.get(\"OAUTH_STATE_ENCRYPTION_KEY\");\n if (envKey) {\n cachedEncryptionKey = envKey;\n return envKey;\n }\n\n // Check blob storage (scoped to redirect URI)\n const blobKey = `oauth_encryption_key:${redirectUri}`;\n try {\n const storedKey = await blob.getJSON(blobKey) as string | null;\n if (storedKey) {\n cachedEncryptionKey = storedKey;\n return storedKey;\n }\n } catch (_error) {\n // Blob doesn't exist or is in old format, will create new one below\n }\n // Generate new random key (32 bytes = 256 bits)\n const randomBytes = new Uint8Array(32);\n crypto.getRandomValues(randomBytes);\n const newKey = btoa(String.fromCharCode(...randomBytes));\n // Store in blob for persistence\n await blob.setJSON(blobKey, newKey);\n cachedEncryptionKey = newKey;\n\n return newKey;\n}\n\n// Derive encryption key from key material\nexport async function getEncryptionKey(\n redirectUri: string,\n): Promise {\n const keyMaterialString = await getOrCreateEncryptionKeyMaterial(redirectUri);\n const encoder = new TextEncoder();\n const keyMaterial = encoder.encode(keyMaterialString);\n const keyHash = await crypto.subtle.digest(\"SHA-256\", keyMaterial);\n\n return await crypto.subtle.importKey(\n \"raw\",\n keyHash,\n { name: \"AES-GCM\" },\n false,\n [\"encrypt\", \"decrypt\"],\n );\n}\n\n// Encrypt data into a URL-safe string\nexport async function encrypt(\n data: string,\n redirectUri: string,\n): Promise {\n const key = await getEncryptionKey(redirectUri);\n const encoder = new TextEncoder();\n const iv = crypto.getRandomValues(new Uint8Array(12)); // 96-bit IV for GCM\n\n const encrypted = await crypto.subtle.encrypt(\n { name: \"AES-GCM\", iv },\n key,\n encoder.encode(data),\n );\n\n // Combine IV + encrypted data\n const combined = new Uint8Array(iv.length + encrypted.byteLength);\n combined.set(iv, 0);\n combined.set(new Uint8Array(encrypted), iv.length);\n\n // Base64url encode\n return btoa(String.fromCharCode(...combined))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n}\n\n// Decrypt URL-safe string back to data\nexport async function decrypt(\n encryptedData: string,\n redirectUri: string,\n): Promise {\n try {\n const key = await getEncryptionKey(redirectUri);\n\n // Base64url decode\n const combined = Uint8Array.from(\n atob(encryptedData.replace(/-/g, \"+\").replace(/_/g, \"/\")),\n (c) => c.charCodeAt(0),\n );\n\n // Extract IV and encrypted data\n const iv = combined.slice(0, 12);\n const encrypted = combined.slice(12);\n\n const decrypted = await crypto.subtle.decrypt(\n { name: \"AES-GCM\", iv },\n key,\n encrypted,\n );\n\n const decoder = new TextDecoder();\n return decoder.decode(decrypted);\n } catch {\n throw new Error(\"Failed to decrypt data - invalid or tampered\");\n }\n}",[192],"5cfcd520-2f52-11f1-88a5-42dde27851f2",["D",1775216621894],41,[29],"pulls","branches",1,"forks","envVars",{"_211":179,"_213":179},"connections",{"_211":179,"_212":179},"count","unfilledCount","emptyCount",{"_51":199,"_33":29,"_31":32,"_146":-5,"_41":42,"_40":14,"_148":68,"_38":244,"_13":201,"_34":21,"_35":37,"_25":26,"_152":-5,"_223":245,"_28":246},{"_51":191,"_33":192,"_31":193,"_146":-5,"_41":42,"_40":194,"_148":68,"_38":241,"_13":196,"_34":47,"_35":197,"_25":26,"_152":-5,"_223":242,"_28":243},{"_51":183,"_33":184,"_31":66,"_146":-5,"_41":42,"_40":185,"_148":26,"_38":238,"_13":187,"_34":160,"_35":188,"_25":26,"_152":189,"_223":239,"_28":240},{"_51":175,"_33":176,"_31":177,"_146":-5,"_41":42,"_40":166,"_148":68,"_38":235,"_13":179,"_34":160,"_35":180,"_25":26,"_152":181,"_223":236,"_28":237},{"_51":171,"_33":45,"_31":46,"_146":-5,"_41":42,"_40":14,"_148":26,"_38":232,"_13":173,"_34":47,"_35":49,"_25":26,"_152":-5,"_223":233,"_28":234},{"_51":163,"_33":164,"_31":165,"_146":-5,"_41":42,"_40":166,"_148":68,"_38":229,"_13":168,"_34":47,"_35":169,"_25":26,"_152":-5,"_223":230,"_28":231},{"_51":154,"_33":155,"_31":156,"_146":-5,"_41":42,"_40":157,"_148":26,"_38":226,"_13":159,"_34":160,"_35":161,"_25":26,"_152":-5,"_223":227,"_28":228},{"_51":143,"_33":144,"_31":145,"_146":-5,"_41":42,"_40":147,"_148":68,"_38":222,"_13":150,"_34":47,"_35":151,"_25":26,"_152":-5,"_223":224,"_28":225},["D",1774751146084],"children",[],[144],["D",1774811766739],[],[155],["D",1774811013258],[],[164],["D",1775216621894],[],[45],["D",1774811013258],[],[176],["D",1775140123887],[],[184],["D",1770842903945],[],[192],["D",1775216621894],[],[29],["D",1761677232251],{"_106":105,"_113":109},{"_106":105,"_107":-5,"_108":109,"_18":-5,"_110":111,"_112":26},{"_13":95,"_33":96,"_51":42,"_97":52,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":53,"_104":105},"ctx",{"_88":-5,"_132":284,"_285":286,"_287":288,"_289":26,"_290":26,"_291":26,"_292":68,"_293":-5,"_294":-7,"_295":-7,"_296":179,"_297":26,"_298":26,"_299":-5,"_300":26,"_301":26,"_302":26,"_303":-5},"ENV",{"_255":256,"_257":258,"_259":96,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v232