\n \n \n \n \n ,\n );\n\n return new Response(stream, {\n status,\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n ...extraHeaders,\n },\n });\n}",[],[151,192],[151],{"_103":202,"_95":203,"_152":204,"_154":-5,"_155":137,"_156":205,"_158":159,"_105":206,"_100":207,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":208,"_98":244},"f7df46f4-5361-11f0-9396-f69ea79377d9","frontend","f4cc2108-5361-11f0-8b33-f69ea79377d9",22,["D",1751034068394],2,[209,217],{"_103":210,"_95":211,"_152":212,"_154":204,"_155":137,"_156":213,"_158":159,"_105":214,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":215,"_98":216},"0b6c0cac-5362-11f0-9683-f69ea79377d9","components","087fec7a-5362-11f0-b326-f69ea79377d9",29,["D",1751034101192],[],[203,211],{"_103":218,"_95":219,"_152":220,"_154":204,"_155":137,"_156":221,"_158":159,"_105":222,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":223,"_98":243},"06ee88bc-5362-11f0-abe4-f69ea79377d9","pages","05c090de-5362-11f0-acb3-f69ea79377d9",27,["D",1751034093657],[224,233],{"_103":225,"_95":226,"_152":227,"_154":220,"_155":137,"_156":228,"_158":159,"_105":229,"_100":157,"_162":176,"_164":230,"_165":22,"_166":-5,"_167":231,"_98":232},"a4b75d84-5386-11f0-8c5a-f69ea79377d9","HomePage.tsx","0479554c-5382-11f0-a6ce-f69ea79377d9",76,["D",1751049820256],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport { ExperimentalWarning } from \"../components/ExperimentalWarning.tsx\";\n\nexport default function({ onLogin }) {\n const [apiKey, setApiKey] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, onError] = useState(\"\");\n\n return (\n

Val Town Oauth Connect

\n Connect to Slack\n

\n );\n}",[],[203,219,226],{"_103":234,"_95":235,"_152":236,"_154":220,"_155":137,"_156":237,"_158":159,"_105":238,"_100":239,"_162":176,"_164":240,"_165":22,"_166":-5,"_167":241,"_98":242},"4d9777b4-5381-11f0-b57c-f69ea79377d9","LoginPage.tsx","ffb2d7f6-5361-11f0-afdc-f69ea79377d9",35,["D",1751047526602],8,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport { ExperimentalWarning } from \"../components/ExperimentalWarning.tsx\";\n\nexport default function ({ onLogin }) {\n const [apiKey, setApiKey] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, onError] = useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n setIsLoading(true);\n onError(\"\");\n try {\n const response = await fetch(\"/auth/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ apiKey }),\n });\n if (response.ok) window.location.href = \"/\";\n } catch (err) {\n console.error(err);\n onError(err.message);\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

\n Val Town OAuth Connect\n

\n \n View source\n \n

\n OAuth everywhere!\n

\n\n {error && (\n

\n {error}\n

\n )}\n\n

To login:

\n 1. Create an API key:{\" \"}\n \n https://www.val.town/settings/api\n \n

2. Give it the \"Users: read-only\" scope.

\n\n

\n );\n}",[],[203,219,235],[203,219],[203],{"_103":246,"_95":247,"_152":248,"_154":-5,"_155":137,"_156":136,"_158":159,"_105":249,"_100":250,"_162":251,"_164":252,"_165":22,"_166":96,"_167":253,"_98":254},"4a44e35c-53a0-11f0-83a9-f69ea79377d9","main.tsx","968c56f2-5358-11f0-ab25-f69ea79377d9",["D",1751060835425],48,"http","import { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport * as arctic from \"npm:arctic\";\nimport { Hono } from \"npm:hono\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\nimport { auth, getCurrentUser } from \"./backend/auth.ts\";\nimport { getTokensByUserId, insertToken } from \"./backend/database.ts\";\nimport { renderPage } from \"./backend/render-react-page.tsx\";\n\nconst app = new Hono();\n\n// Serve all /frontend files\napp.get(\"/frontend/**/*\", (c) => serveFile(c.req.path, import.meta.url));\n\napp.route(\"/auth\", auth);\n\nconst title = \"Val Town OAuth Connect\";\n\napp.use(\"*\", async (c, next) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return renderPage({\n pageModuleURL: \"/frontend/pages/LoginPage.tsx\",\n title,\n });\n } else {\n c.set(\"user\", user);\n await next();\n }\n});\n\napp.get(\"/\", async (c) => {\n return renderPage({\n pageModuleURL: \"/frontend/pages/HomePage.tsx\",\n title,\n props: {\n user: c.get(\"user\"),\n },\n });\n});\n\napp.get(\"/api/tokens\", async (c) => {\n const user = c.get(\"user\");\n return c.json(await getTokensByUserId(user.id));\n});\n\nconst slack = new arctic.Slack(\n Deno.env.get(\"SLACK_CLIENT_ID\"),\n Deno.env.get(\"SLACK_CLIENT_SECRET\"),\n \"https://oauth-connect.val.run/api/callback/slack\",\n);\napp.get(\"/api/start-connection/:service\", (c) => {\n const state = arctic.generateState();\n\n // store state as cookie\n setCookie(c, \"state\", state, {\n secure: true, // set to false in localhost\n path: \"/\",\n httpOnly: true,\n maxAge: 60 * 10, // 10 min\n });\n\n const scopes = [\n \"openid\",\n \"profile\",\n \"channels:read\",\n // \"channels:read\",\n // \"incoming-webhook\",.public\",\n ];\n const url = slack.createAuthorizationURL(state, scopes);\n return c.redirect(url);\n});\n\napp.get(\"/api/callback/:service\", async (c) => {\n const service = c.req.param(\"service\");\n\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n\n const storedState = getCookie(c, \"state\");\n\n if (code === null || storedState === null || state !== storedState) {\n // 400\n throw new Error(\"Invalid request\");\n }\n\n try {\n console.log(code);\n const tokens = await slack.validateAuthorizationCode(code);\n const accessToken = tokens.accessToken();\n const user = c.get(\"user\");\n const token = {\n userId: user.id,\n service,\n accessToken,\n state,\n createdAt: new Date(),\n };\n insertToken(token);\n return c.json(\"OK\");\n } catch (e) {\n if (e instanceof arctic.OAuth2RequestError) {\n // Invalid authorization code, credentials, or redirect URI\n const code = e.code;\n console.error(e);\n }\n if (e instanceof arctic.ArcticFetchError) {\n // Failed to call `fetch()`\n const cause = e.cause;\n console.error(e);\n }\n console.error(e);\n }\n\n return c.redirect(\"/\");\n});\n\n// Unwrap and rethrow Hono errors as the original error\n// If you delete this, all errors will be \"Internal Server Error\"\napp.onError((err, c) => Promise.reject(err));\nexport default app.fetch;",[],[247],"files",[149,169,180,190,201,209,217,224,233,245],"counts",{"_259":32,"_260":161,"_261":32,"_262":207},"pulls","branches","forks","envVars","contents",[],"file",{"_103":181,"_95":182,"_152":183,"_154":153,"_155":137,"_156":184,"_158":159,"_105":267,"_100":186,"_162":176,"_164":187,"_165":22,"_166":-5,"_98":268},["D",1751048581247],[151,182],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_93":94,"_95":96,"_97":43,"_98":99,"_101":277,"_265":282,"_285":286,"_335":336,"_348":-7,"_349":32,"_350":22},{"_103":104,"_95":96,"_105":278,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":279,"_131":280,"_134":281,"_146":22},["D",1751030039581],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},{"_103":181,"_95":182,"_152":183,"_154":153,"_155":137,"_156":184,"_158":159,"_105":283,"_100":186,"_162":176,"_164":187,"_165":22,"_166":-5,"_98":284},["D",1751048581247],[151,182],"history",[287,289,294,300,306,311,317,321,326,330],{"_103":181,"_155":137,"_152":183,"_95":182,"_164":187,"_162":176,"_100":186,"_154":153,"_105":288,"_156":184,"_166":-5},["D",1751048581247],{"_103":290,"_155":137,"_152":183,"_95":182,"_164":291,"_162":176,"_100":239,"_154":153,"_105":292,"_156":293,"_166":-5},"b996cab2-5383-11f0-972c-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);\n\nexport async function getTokensByUserId(userId: string) {\n const data = await sqlite.execute(\n `SELECT service, access_token, created_at, access_token_expires_at FROM connection_oauth_tokens WHERE user_id = ?`,\n [userId],\n );\n return data.rows;\n}\n\nexport function insertToken(token: any) {\n return sqlite.execute(\n `INSERT INTO connection_oauth_tokens (service, user_id, access_token, refresh_token, state, created_at, access_token_expires_at) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n token.service,\n token.userId,\n token.accessToken,\n token.refreshToken,\n token.state,\n token.createdAt,\n token.accessTokenExpiresAt,\n ],\n );\n}",["D",1751048566786],54,{"_103":295,"_155":137,"_152":183,"_95":182,"_164":296,"_162":176,"_100":297,"_154":153,"_105":298,"_156":299,"_166":-5},"b5cd7372-5383-11f0-a7ed-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);\n\nexport function getTokensByUserId(userId: string) {\n const data = await sqlite.execute(\n `SELECT service, access_token, created_at, access_token_expires_at FROM connection_oauth_tokens WHERE user_id = ?`,\n [userId],\n );\n return data.rows;\n}\n\nexport function insertToken(token: any) {\n return sqlite.execute(\n `INSERT INTO connection_oauth_tokens (service, user_id, access_token, refresh_token, state, created_at, access_token_expires_at) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n token.service,\n token.userId,\n token.accessToken,\n token.refreshToken,\n token.state,\n token.createdAt,\n token.accessTokenExpiresAt,\n ],\n );\n}",7,["D",1751048560434],53,{"_103":301,"_155":137,"_152":183,"_95":182,"_164":302,"_162":176,"_100":303,"_154":153,"_105":304,"_156":305,"_166":-5},"37d92b1e-5383-11f0-8dfb-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);\n\nexport function getTokensByUserId(userId: string) {\n return sqlite.execute(\n `SELECT service, access_token, created_at, access_token_expires_at FROM connection_oauth_tokens WHERE user_id = ?`,\n [userId],\n );\n}\n\nexport function insertToken(token: any) {\n return sqlite.execute(\n `INSERT INTO connection_oauth_tokens (service, user_id, access_token, refresh_token, state, created_at, access_token_expires_at) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n token.service,\n token.userId,\n token.accessToken,\n token.refreshToken,\n token.state,\n token.createdAt,\n token.accessTokenExpiresAt,\n ],\n );\n}",6,["D",1751048349117],51,{"_103":307,"_155":137,"_152":183,"_95":182,"_164":308,"_162":176,"_100":175,"_154":153,"_105":309,"_156":310,"_166":-5},"251b9066-5383-11f0-a327-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);\n\nexport function getTokensByUserId(userId: string) {\n return sqlite.execute(\n `SELECT service, access_token, created_at, access_token_expires_at FROM connection_oauth_tokens WHERE user_id = ?`,\n [userId],\n );\n}",["D",1751048317670],50,{"_103":312,"_155":137,"_152":183,"_95":182,"_164":313,"_162":176,"_100":314,"_154":153,"_105":315,"_156":316,"_166":-5},"23d2f44c-5383-11f0-b1f8-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);\n\nfunction getTokensByUserId(userId: string) {\n return sqlite.execute(\n `SELECT service, access_token, created_at, access_token_expires_at FROM connection_oauth_tokens WHERE user_id = ?`,\n [userId],\n );\n}",4,["D",1751048315522],49,{"_103":318,"_155":137,"_152":183,"_95":182,"_164":319,"_162":176,"_100":196,"_154":153,"_105":320,"_156":250,"_166":-5},"f59c3b24-5382-11f0-a327-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);",["D",1751048237988],{"_103":322,"_155":137,"_152":183,"_95":182,"_164":323,"_162":176,"_100":207,"_154":153,"_105":324,"_156":325,"_166":-5},"edb67f6e-5382-11f0-acf2-f69ea79377d9","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n// export const connectionOAuthTokens = pgTable(\n// \"connection_oauth_tokens\",\n// {\n// service: serviceEnum(),\n// userId: uuid()\n// .notNull()\n// .references(() => users.id, {\n// onUpdate: \"cascade\",\n// onDelete: \"cascade\",\n// }),\n// accessToken: text(),\n// refreshToken: text(),\n// state: text(),\n// createdAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// })\n// .notNull()\n// .defaultNow(),\n// /**\n// * Many of these values expire quite quickly.\n// */\n// accessTokenExpiresAt: timestamp({\n// withTimezone: true,\n// mode: \"date\",\n// }),\n// },\n// (table) => [\n// primaryKey({\n// columns: [table.service, table.userId],\n// }),\n// ]\n// );\n\nawait sqlite.batch([\n `CREATE TABLE connection_oauth_tokens (\n service text NOT NULL,\n user_id uuid NOT NULL,\n access_token text NOT NULL,\n refresh_token text NOT NULL,\n state text NOT NULL,\n created_at timestamp with time zone NOT NULL,\n access_token_expires_at timestamp with time zone NOT NULL\n )`,\n]);",["D",1751048224738],47,{"_103":327,"_155":137,"_152":183,"_95":182,"_164":72,"_162":176,"_100":161,"_154":153,"_105":328,"_156":329,"_166":-5},"9bd58ffa-5382-11f0-9ce3-f69ea79377d9",["D",1751048087371],46,{"_103":331,"_155":137,"_152":183,"_95":332,"_164":72,"_162":176,"_100":32,"_154":153,"_105":333,"_156":334,"_166":-5},"9a66d7a0-5382-11f0-aea0-f69ea79377d9","new-file-858.tsx",["D",1751048084971],45,"versions",[337,339,340,341,342,343,344,345,346,347],{"_265":287,"_338":289},"previous",{"_265":289,"_338":294},{"_265":294,"_338":300},{"_265":300,"_338":306},{"_265":306,"_338":311},{"_265":311,"_338":317},{"_265":317,"_338":321},{"_265":321,"_338":326},{"_265":326,"_338":330},{"_265":330,"_338":-5},"versionNumber","page","hasNext","actionData","errors"]

History for database.ts