[{"_1":2,"_540":-5,"_541":-5},"loaderData",{"_3":4,"_91":92,"_271":272,"_539":-5},"root",{"_5":6,"_32":33,"_60":61},"ctx",{"_7":8,"_19":20,"_21":-5,"_22":23,"_24":25,"_26":27,"_28":27,"_29":27,"_30":31},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers",false,"preferencesCopilot","preferencesSelectionAi","notificationCount",0,"ENV",{"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","d61e6fca584575ce46a18e0c1db610039aa1035f","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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/","API_URL","https://api.val.town","WORKER_FINGERPRINT","fd7e47ba602df66e0f857b45e802b861","clerkState",{"_62":63},"__internal_clerk_state",{"_64":65,"_66":43,"_67":68,"_69":68,"_70":27,"_71":68,"_72":68,"_73":68,"_74":68,"_75":68,"_76":68,"_77":68,"_78":68,"_79":80,"_89":27,"_90":27},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_81":27,"_82":68,"_83":84,"_85":68,"_86":43,"_87":27,"_88":68},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":41,"_98":68,"_99":-7,"_100":101,"_141":142,"_246":247,"_248":249,"_254":255,"_232":-5,"_268":-5,"_269":27,"_270":27},"handle","stevekrouse","name","social_data","branchName","path","version","project",{"_102":103,"_95":96,"_104":105,"_106":-5,"_107":27,"_108":109,"_110":111,"_112":-5,"_12":113,"_114":115,"_116":117,"_118":-5,"_119":31,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":27,"_21":129,"_132":133},"id","28681a86-fb96-11ef-8251-569c3dd06744","createdAt",["D",1741380781333],"deletedAt","legacyEnvVars","privacy","public","description","Service for getting Twitter 𝕏 data without Twitter's API","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","955cf21a-fb96-11ef-9eab-569c3dd06744","pinPreview",true,"screenshotVersion","likeCount","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","isOwned",{"_93":94,"_130":131},"profileImageUrl","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","branch",{"_99":134,"_95":41,"_102":135,"_136":103,"_137":-5,"_138":-5,"_139":-5,"_140":-5},105,"2868708a-fb96-11ef-8251-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectUserId","tree",[143,209,225,236],{"_102":144,"_95":145,"_146":147,"_148":-5,"_149":135,"_150":151,"_152":117,"_104":153,"_99":31,"_154":155,"_156":-5,"_157":27,"_158":-5,"_159":160,"_98":208},"ab14009e-fb96-11ef-be2b-569c3dd06744","proxy","fileId","ab140184-fb96-11ef-be2b-569c3dd06744","parentId","branchId","branchVersion",5,"latest",["D",1741381000562],"fileType","directory","content","deleted","label","children",[161,180,188,198],{"_102":162,"_95":163,"_146":164,"_148":147,"_149":135,"_150":165,"_152":117,"_104":166,"_99":31,"_154":155,"_156":-5,"_157":27,"_158":-5,"_159":167,"_98":179},"e0fca6fc-fb9b-11ef-97f0-569c3dd06744","routes","e0fca7ce-fb9b-11ef-97f0-569c3dd06744",46,["D",1741383238489],[168],{"_102":169,"_95":170,"_146":171,"_148":164,"_149":135,"_150":172,"_152":117,"_104":173,"_99":174,"_154":175,"_156":176,"_157":27,"_158":-5,"_159":177,"_98":178},"e8328bf2-fdf4-11ef-8a3c-569c3dd06744","search.ts","e4e638dc-fb9b-11ef-9837-569c3dd06744",103,["D",1741641378110],10,"script","import { createRoute, z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { SearchResponseSchema } from \"../../schemas.ts\";\nimport { authMiddleware } from \"../auth.ts\";\n\n// Define the request/response schema for a route to list users\nexport const searchTwitterRoute = createRoute({\n method: \"get\",\n path: \"/twitter/search\",\n summary: \"Search twitter\",\n tags: [\"Search\"],\n security: [\n {\n Bearer: [],\n },\n ],\n // NOTE: You can add middleware here or when the route is mounted,\n // here we just need to use `as const` to ensure TypeScript infers the middleware's Context.\n // see: https://github.com/honojs/middleware/tree/main/packages/zod-openapi#configure-middleware-for-each-endpoint\n middleware: [authMiddleware] as const,\n request: {\n query: z.object({\n query: z.string().openapi({ example: \"valtown\" }),\n }),\n },\n responses: {\n 200: {\n content: {\n \"application/json\": {\n schema: SearchResponseSchema,\n },\n },\n description: \"Twitter search results\",\n },\n 401: {\n content: {\n \"application/json\": {\n // TODO: explicitly type what a 401 looks like\n // schema: ErrorSchema,\n schema: z.string().openapi({ example: \"Unauthorized - Missing or invalid Bearer token\" }),\n },\n },\n description: \"Unauthorized\",\n },\n 429: {\n content: {\n \"application/json\": {\n // TODO: explicitly type what a 429 looks like\n // schema: ErrorSchema,\n schema: z.string().openapi({ example: \"Rate limit exceeded\" }),\n },\n },\n description: \"Rate limit exceeded\",\n },\n },\n});",[],[145,163,170],[145,163],{"_102":181,"_95":182,"_146":183,"_148":147,"_149":135,"_150":172,"_152":117,"_104":184,"_99":31,"_154":175,"_156":185,"_157":27,"_158":-5,"_159":186,"_98":187},"e8326528-fdf4-11ef-8a3c-569c3dd06744","auth.ts","e83265d2-fdf4-11ef-8a3c-569c3dd06744",["D",1741641378110],"import { createMiddleware } from \"npm:hono@4.7.0/factory\";\n\n/**\n * Authentication middleware that validates the valtown api key as a bearer token,\n * while maintaining backwards compatibility with old proxy\n *\n * If missing or invalid, returns a 401\n * Otherwise, sets `bearerToken` on the Hono context\n */\nexport const authMiddleware = createMiddleware<{\n Variables: {\n bearerToken: string;\n };\n}>(async (c, next) => {\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n\n if (!Authorization) {\n return c.json(\"Missing Authorization header\", 401);\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n if (!bearerToken) {\n return c.json(\"Missing bearer token\", 401);\n }\n\n // Put the valid token in context\n c.set(\"token\", bearerToken);\n\n // Don't forget to await. It's not necessary\n // until it is, and then it's a pain to retrofit\n await next();\n});",[],[145,182],{"_102":189,"_95":190,"_146":191,"_148":147,"_149":135,"_150":192,"_152":117,"_104":193,"_99":194,"_154":175,"_156":195,"_157":27,"_158":-5,"_159":196,"_98":197},"ee938934-fb96-11ef-8440-569c3dd06744","database.ts","b5f7191a-fb96-11ef-aac5-569c3dd06744",11,["D",1741381113797],3,"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport const USAGE_TABLE = \"socialDataProxy_usage_2\";\n\nexport async function setupDatabase() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${USAGE_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n username TEXT NOT NULL,\n query TEXT NOT NULL,\n returned_tweets_count INTEGER NOT NULL,\n cost REAL NOT NULL,\n timestamp DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n}",[],[145,190],{"_102":199,"_95":200,"_146":115,"_148":147,"_149":135,"_150":172,"_152":117,"_104":201,"_99":202,"_154":203,"_156":204,"_157":27,"_158":205,"_159":206,"_98":207},"e83285a8-fdf4-11ef-8a3c-569c3dd06744","index.ts",["D",1741641378110],38,"http","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\n// TODO - put this back to 0.10\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n const bearerToken = c.get(\"bearerToken\");\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults, 200);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/*\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;","socialdata",[],[145,200],[145],{"_102":210,"_95":211,"_146":212,"_148":-5,"_149":135,"_150":213,"_152":117,"_104":214,"_99":31,"_154":155,"_156":-5,"_157":27,"_158":-5,"_159":215,"_98":224},"75d9e828-fb99-11ef-999c-569c3dd06744","sdk","75d9e8dc-fb99-11ef-999c-569c3dd06744",21,["D",1741382199752],[216],{"_102":217,"_95":200,"_146":218,"_148":212,"_149":135,"_150":134,"_152":117,"_104":219,"_99":220,"_154":175,"_156":221,"_157":27,"_158":-5,"_159":222,"_98":223},"316efee8-31d2-11f0-aac1-569c3dd06744","b9cdd972-fb99-11ef-b61d-569c3dd06744",["D",1747343929063],20,"import { type SearchResponse } from \"../schemas.ts\";\n\nexport default class SocialData {\n bearerToken: string;\n baseURL: string;\n\n constructor({\n baseURL = \"https://api.socialdata.tools\",\n bearerToken = Deno.env.get(\"SOCIAL_DATA_API_KEY\"),\n } = {}) {\n if (bearerToken === undefined) {\n throw new Error(\n \"The SOCIAL_DATA_API_KEY environment variable is missing or empty; either provide it, or instantiate the SocialData client with an bearerToken option, like new SocialData({ bearerToken: 'My Bearer Token' }).\",\n );\n }\n this.bearerToken = bearerToken;\n this.baseURL = baseURL;\n }\n\n async search(query: string) {\n const url = new URL(`${this.baseURL}/twitter/search`);\n url.searchParams.set(\"query\", query);\n const resp = await fetch(url, {\n headers: {\n Authorization: `Bearer ${this.bearerToken}`,\n },\n });\n const json = await resp.json();\n return json as SearchResponse;\n }\n}\n\nexport class ValTownSocialData extends SocialData {\n constructor({\n baseURL = \"https://socialdata.val.run\",\n bearerToken = Deno.env.get(\"valtown\"),\n } = {}) {\n super({ baseURL, bearerToken });\n }\n}",[],[211,200],[211],{"_102":226,"_95":227,"_146":228,"_148":-5,"_149":135,"_150":229,"_152":117,"_104":230,"_99":231,"_154":232,"_156":233,"_157":27,"_158":-5,"_159":234,"_98":235},"9198a9bc-fb96-11ef-853c-569c3dd06744","README.md","3529497a-fb96-11ef-9fb9-569c3dd06744",2,["D",1741380957804],1,"file","# Social Data\n\n[Social Data](https://socialdata.tools/) is an API for getting Twitter 𝕏 data without Twitter's API.",[],[227],{"_102":237,"_95":238,"_146":239,"_148":-5,"_149":135,"_150":240,"_152":117,"_104":241,"_99":242,"_154":175,"_156":243,"_157":27,"_158":-5,"_159":244,"_98":245},"eea0907a-fba0-11ef-a6c1-569c3dd06744","schemas.ts","da7888e0-fb97-11ef-9a3e-569c3dd06744",91,["D",1741385408854],14,"import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n quoted_status: z.record(z.any()).nullable(), // TweetSchema.nullable(),\n retweeted_status: z.record(z.any()).nullable(), // TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",[],[238],"files",[143,161,168,180,188,198,209,216,225,236],"counts",{"_250":31,"_251":231,"_252":194,"_253":231},"pulls","branches","forks","envVars","contents",[256,259,262,265],{"_102":144,"_95":145,"_146":147,"_148":-5,"_149":135,"_150":151,"_152":117,"_104":257,"_99":31,"_154":155,"_156":-5,"_157":27,"_158":-5,"_98":258},["D",1741381000562],[145],{"_102":210,"_95":211,"_146":212,"_148":-5,"_149":135,"_150":213,"_152":117,"_104":260,"_99":31,"_154":155,"_156":-5,"_157":27,"_158":-5,"_98":261},["D",1741382199752],[211],{"_102":226,"_95":227,"_146":228,"_148":-5,"_149":135,"_150":229,"_152":117,"_104":263,"_99":231,"_154":232,"_156":233,"_157":27,"_158":-5,"_98":264},["D",1741380957804],[227],{"_102":237,"_95":238,"_146":239,"_148":-5,"_149":135,"_150":240,"_152":117,"_104":266,"_99":242,"_154":175,"_156":243,"_157":27,"_158":-5,"_98":267},["D",1741385408854],[238],"upstream","emptyEnvVars","isNew","routes/_app.x.$handle.$name.branch.$branch.history",{"_93":94,"_95":96,"_97":41,"_100":273,"_277":278,"_537":31,"_538":117},{"_102":103,"_95":96,"_104":274,"_106":-5,"_107":27,"_108":109,"_110":111,"_112":-5,"_12":113,"_114":115,"_116":117,"_118":-5,"_119":31,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":27,"_21":275,"_132":276},["D",1741380781333],{"_93":94,"_130":131},{"_99":134,"_95":41,"_102":135,"_136":103,"_137":-5,"_138":-5,"_139":-5,"_140":-5},"history",[279,284,293,304,313,322,331,340,349,357,366,375,383,392,401,406,415,424,431,439,448,457,466,475,484,493,501,510,519,528],{"_146":218,"_99":134,"_104":280,"_149":135,"_246":281},["D",1747343929063],[282],{"_102":217,"_149":135,"_146":218,"_95":200,"_156":221,"_154":175,"_99":220,"_148":212,"_104":280,"_150":134,"_158":-5,"_152":117,"_157":27,"_98":283},[211,200],{"_146":218,"_99":285,"_104":286,"_149":135,"_246":287},104,["D",1747343927174],[288],{"_102":289,"_149":135,"_146":218,"_95":200,"_156":290,"_154":175,"_99":291,"_148":212,"_104":286,"_150":285,"_158":-5,"_152":27,"_157":27,"_98":292},"304f1106-31d2-11f0-a44d-569c3dd06744","import { type SearchResponse } from \"../schemas.ts\";\n\nexport default class SocialData {\n bearerToken: string;\n baseURL: string;\n\n constructor({\n baseURL = \"https://api.socialdata.tools\",\n bearerToken = Deno.env.get(\"SOCIAL_DATA_API_KEY\"),\n } = {}) {\n if (bearerToken === undefined) {\n throw new Error(\n \"The SOCIAL_DATA_API_KEY environment variable is missing or empty; either provide it, or instantiate the SocialData client with an bearerToken option, like new SocialData({ bearerToken: 'My Bearer Token' }).\",\n );\n }\n this.bearerToken = bearerToken;\n this.baseURL = baseURL;\n }\n\n async search(query: string) {\n const url = new URL(`${this.baseURL}/twitter/search`);\n url.searchParams.set(\"query\", query);\n const resp = await fetch(url, {\n headers: {\n Authorization: `Bearer ${this.bearerToken}`,\n },\n });\n const json = await resp.json();\n return json as SearchResponse;\n }\n}\n\nexport class ValTownSocialData extends SocialData {\n constructor({\n baseURL = \"https://socialdata.val.run\", // TODO - make this pretty somehow\n bearerToken = Deno.env.get(\"valtown\"),\n } = {}) {\n super({ baseURL, bearerToken });\n }\n}",19,[211,200],{"_146":115,"_99":172,"_104":294,"_149":135,"_246":295},["D",1741641378110],[296,298,301],{"_102":199,"_149":135,"_146":115,"_95":200,"_156":204,"_154":203,"_99":202,"_148":147,"_104":294,"_150":172,"_158":205,"_152":117,"_157":27,"_98":297},[145,200],{"_102":169,"_149":135,"_146":171,"_95":170,"_156":176,"_154":175,"_99":174,"_148":164,"_104":299,"_150":172,"_158":-5,"_152":117,"_157":27,"_98":300},["D",1741641378110],[145,163,170],{"_102":181,"_149":135,"_146":183,"_95":182,"_156":185,"_154":175,"_99":31,"_148":147,"_104":302,"_150":172,"_158":-5,"_152":117,"_157":27,"_98":303},["D",1741641378110],[145,182],{"_146":115,"_99":305,"_104":306,"_149":135,"_246":307},102,["D",1741386932515],[308],{"_102":309,"_149":135,"_146":115,"_95":200,"_156":310,"_154":203,"_99":311,"_148":147,"_104":306,"_150":305,"_158":205,"_152":27,"_157":27,"_98":312},"7accd45c-fba4-11ef-a334-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\n// TODO - put this back to 0.10\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",37,[145,200],{"_146":218,"_99":314,"_104":315,"_149":135,"_246":316},101,["D",1741386901464],[317],{"_102":318,"_149":135,"_146":218,"_95":200,"_156":319,"_154":175,"_99":320,"_148":212,"_104":315,"_150":314,"_158":-5,"_152":27,"_157":27,"_98":321},"684ad662-fba4-11ef-baa5-569c3dd06744","import { type SearchResponse } from \"../schemas.ts\";\n\nexport default class SocialData {\n bearerToken: string;\n baseURL: string;\n\n constructor({\n baseURL = \"https://api.socialdata.tools\",\n bearerToken = Deno.env.get(\"SOCIAL_DATA_API_KEY\"),\n } = {}) {\n if (bearerToken === undefined) {\n throw new Error(\n \"The SOCIAL_DATA_API_KEY environment variable is missing or empty; either provide it, or instantiate the SocialData client with an bearerToken option, like new SocialData({ bearerToken: 'My Bearer Token' }).\",\n );\n }\n this.bearerToken = bearerToken;\n this.baseURL = baseURL;\n }\n\n async search(query: string) {\n const url = new URL(`${this.baseURL}/twitter/search`);\n url.searchParams.set(\"query\", query);\n const resp = await fetch(url, {\n headers: {\n Authorization: `Bearer ${this.bearerToken}`,\n },\n });\n const json = await resp.json();\n return json as SearchResponse;\n }\n}\n\nexport class ValTownSocialData extends SocialData {\n constructor({\n baseURL = \"https://stevekrouse--955cf21afb9611ef9eab569c3dd06744.web.val.run\", // TODO - make this pretty somehow\n bearerToken = Deno.env.get(\"valtown\"),\n } = {}) {\n super({ baseURL, bearerToken });\n }\n}",18,[211,200],{"_146":115,"_99":323,"_104":324,"_149":135,"_246":325},100,["D",1741386889006],[326],{"_102":327,"_149":135,"_146":115,"_95":200,"_156":328,"_154":203,"_99":329,"_148":147,"_104":324,"_150":323,"_158":205,"_152":27,"_157":27,"_98":330},"60ddee3c-fba4-11ef-ac61-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\n// TODO - put this back to 0.10\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n console.log(bearerToken);\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",36,[145,200],{"_146":115,"_99":332,"_104":333,"_149":135,"_246":334},99,["D",1741386878267],[335],{"_102":336,"_149":135,"_146":115,"_95":200,"_156":337,"_154":203,"_99":338,"_148":147,"_104":333,"_150":332,"_158":205,"_152":27,"_157":27,"_98":339},"5a771942-fba4-11ef-b780-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\n// TODO - put this back to 0.10\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer: \") ? Authorization.slice(\"Bearer: \".length) : Authorization;\n console.log(bearerToken);\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",35,[145,200],{"_146":115,"_99":341,"_104":342,"_149":135,"_246":343},98,["D",1741386876829],[344],{"_102":345,"_149":135,"_146":115,"_95":200,"_156":346,"_154":203,"_99":347,"_148":147,"_104":342,"_150":341,"_158":205,"_152":27,"_157":27,"_98":348},"599bc78e-fba4-11ef-ac61-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\n// TODO - put this back to 0.10\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer: \") ? Authorization.slice(\"Beare:r \".length) : Authorization;\n console.log(bearerToken);\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",34,[145,200],{"_146":115,"_99":350,"_104":351,"_149":135,"_246":352},97,["D",1741386785452],[353],{"_102":354,"_149":135,"_146":115,"_95":200,"_156":328,"_154":203,"_99":355,"_148":147,"_104":351,"_150":350,"_158":205,"_152":27,"_157":27,"_98":356},"232501fc-fba4-11ef-86e9-569c3dd06744",33,[145,200],{"_146":218,"_99":358,"_104":359,"_149":135,"_246":360},96,["D",1741386613740],[361],{"_102":362,"_149":135,"_146":218,"_95":200,"_156":363,"_154":175,"_99":364,"_148":212,"_104":359,"_150":358,"_158":-5,"_152":27,"_157":27,"_98":365},"bccbd9bc-fba3-11ef-b7a4-569c3dd06744","import { type SearchResponse } from \"../schemas.ts\";\n\nexport default class SocialData {\n bearerToken: string;\n baseURL: string;\n\n constructor({\n baseURL = \"https://api.socialdata.tools\",\n bearerToken = Deno.env.get(\"SOCIAL_DATA_API_KEY\"),\n } = {}) {\n if (bearerToken === undefined) {\n throw new Error(\n \"The SOCIAL_DATA_API_KEY environment variable is missing or empty; either provide it, or instantiate the SocialData client with an bearerToken option, like new SocialData({ bearerToken: 'My Bearer Token' }).\",\n );\n }\n this.bearerToken = bearerToken;\n this.baseURL = baseURL;\n }\n\n async search(query: string) {\n const url = new URL(`${this.baseURL}/twitter/search`);\n url.searchParams.set(\"query\", query);\n const resp = await fetch(url, {\n headers: {\n Authorization: `Bearer: ${this.bearerToken}`,\n },\n });\n const json = await resp.json();\n return json as SearchResponse;\n }\n}\n\nexport class ValTownSocialData extends SocialData {\n constructor({\n baseURL = \"https://stevekrouse--955cf21afb9611ef9eab569c3dd06744.web.val.run\", // TODO - make this pretty somehow\n bearerToken = Deno.env.get(\"valtown\"),\n } = {}) {\n super({ baseURL, bearerToken });\n }\n}",17,[211,200],{"_146":218,"_99":367,"_104":368,"_149":135,"_246":369},95,["D",1741386579905],[370],{"_102":371,"_149":135,"_146":218,"_95":200,"_156":372,"_154":175,"_99":373,"_148":212,"_104":368,"_150":367,"_158":-5,"_152":27,"_157":27,"_98":374},"a8a111dc-fba3-11ef-9fab-569c3dd06744","import { type SearchResponse } from \"../schemas.ts\";\n\nexport default class SocialData {\n bearerToken: string;\n baseURL: string;\n\n constructor({\n baseURL = \"https://api.socialdata.tools\",\n bearerToken = Deno.env.get(\"SOCIAL_DATA_API_KEY\"),\n } = {}) {\n if (bearerToken === undefined) {\n throw new Error(\n \"The SOCIAL_DATA_API_KEY environment variable is missing or empty; either provide it, or instantiate the SocialData client with an bearerToken option, like new SocialData({ bearerToken: 'My Bearer Token' }).\",\n );\n }\n this.bearerToken = bearerToken;\n this.baseURL = baseURL;\n }\n\n async search(query: string) {\n const url = new URL(`${this.bearerToken}/twitter/search`);\n url.searchParams.set(\"query\", query);\n const resp = await fetch(url, {\n headers: {\n Authorization: `Bearer: ${this.bearerToken}`,\n },\n });\n const json = await resp.json();\n return json as SearchResponse;\n }\n}\n\nexport class ValTownSocialData extends SocialData {\n constructor({\n baseURL = \"https://stevekrouse--955cf21afb9611ef9eab569c3dd06744.web.val.run\", // TODO - make this pretty somehow\n bearerToken = Deno.env.get(\"valtown\"),\n } = {}) {\n super({ baseURL, bearerToken });\n }\n}",16,[211,200],{"_146":115,"_99":376,"_104":377,"_149":135,"_246":378},94,["D",1741386513449],[379],{"_102":380,"_149":135,"_146":115,"_95":200,"_156":310,"_154":203,"_99":381,"_148":147,"_104":377,"_150":376,"_158":205,"_152":27,"_157":27,"_98":382},"810498c4-fba3-11ef-9498-569c3dd06744",32,[145,200],{"_146":115,"_99":384,"_104":385,"_149":135,"_246":386},93,["D",1741386502151],[387],{"_102":388,"_149":135,"_146":115,"_95":200,"_156":389,"_154":203,"_99":390,"_148":147,"_104":385,"_150":384,"_158":205,"_152":27,"_157":27,"_98":391},"7a488554-fba3-11ef-b0e2-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.20;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",31,[145,200],{"_146":115,"_99":393,"_104":394,"_149":135,"_246":395},92,["D",1741385636822],[396],{"_102":397,"_149":135,"_146":115,"_95":200,"_156":398,"_154":203,"_99":399,"_148":147,"_104":394,"_150":393,"_158":205,"_152":27,"_157":27,"_98":400},"7682238c-fba1-11ef-b3a5-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // Really, the middleware should validate this, right?\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",30,[145,200],{"_146":239,"_99":240,"_104":402,"_149":135,"_246":403},["D",1741385408854],[404],{"_102":237,"_149":135,"_146":239,"_95":238,"_156":243,"_154":175,"_99":242,"_148":-5,"_104":402,"_150":240,"_158":-5,"_152":117,"_157":27,"_98":405},[238],{"_146":239,"_99":407,"_104":408,"_149":135,"_246":409},90,["D",1741385367746],[410],{"_102":411,"_149":135,"_146":239,"_95":238,"_156":412,"_154":175,"_99":413,"_148":-5,"_104":408,"_150":407,"_158":-5,"_152":27,"_157":27,"_98":414},"d620a6de-fba0-11ef-9040-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n quoted_status: z.object({}).nullable(), // TweetSchema.nullable(),\n retweeted_status: z.object({}).nullable(), // TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",13,[238],{"_146":239,"_99":416,"_104":417,"_149":135,"_246":418},89,["D",1741385364199],[419],{"_102":420,"_149":135,"_146":239,"_95":238,"_156":421,"_154":175,"_99":422,"_148":-5,"_104":417,"_150":416,"_158":-5,"_152":27,"_157":27,"_98":423},"d4027d96-fba0-11ef-8143-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n quoted_status: z.object().nullable(), // TweetSchema.nullable(),\n retweeted_status: z.object({}).nullable(), // TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",12,[238],{"_146":239,"_99":425,"_104":426,"_149":135,"_246":427},88,["D",1741385361632],[428],{"_102":429,"_149":135,"_146":239,"_95":238,"_156":412,"_154":175,"_99":192,"_148":-5,"_104":426,"_150":425,"_158":-5,"_152":27,"_157":27,"_98":430},"d27af386-fba0-11ef-8143-569c3dd06744",[238],{"_146":239,"_99":432,"_104":433,"_149":135,"_246":434},87,["D",1741385355835],[435],{"_102":436,"_149":135,"_146":239,"_95":238,"_156":437,"_154":175,"_99":174,"_148":-5,"_104":433,"_150":432,"_158":-5,"_152":27,"_157":27,"_98":438},"cf06eea8-fba0-11ef-b99f-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n quoted_status: z.object({}), // TweetSchema.nullable(),\n retweeted_status: z.object({}), // TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",[238],{"_146":239,"_99":440,"_104":441,"_149":135,"_246":442},86,["D",1741385351663],[443],{"_102":444,"_149":135,"_146":239,"_95":238,"_156":445,"_154":175,"_99":446,"_148":-5,"_104":441,"_150":440,"_158":-5,"_152":27,"_157":27,"_98":447},"cc8a6380-fba0-11ef-81a7-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n quoted_status: z.object({}), TweetSchema.nullable(),\n retweeted_status: z.object({}), TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",9,[238],{"_146":239,"_99":449,"_104":450,"_149":135,"_246":451},85,["D",1741385330043],[452],{"_102":453,"_149":135,"_146":239,"_95":238,"_156":454,"_154":175,"_99":455,"_148":-5,"_104":450,"_150":449,"_158":-5,"_152":27,"_157":27,"_98":456},"bfa739fe-fba0-11ef-a365-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // Recursive zod types are hard!\n // quoted_status: TweetSchema.nullable(),\n // retweeted_status: TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",8,[238],{"_146":239,"_99":458,"_104":459,"_149":135,"_246":460},84,["D",1741385322239],[461],{"_102":462,"_149":135,"_146":239,"_95":238,"_156":463,"_154":175,"_99":464,"_148":-5,"_104":459,"_150":458,"_158":-5,"_152":27,"_157":27,"_98":465},"bb002e9c-fba0-11ef-b868-569c3dd06744","import { z } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\n\nexport const UserMentionSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n indices: z.array(z.number()),\n});\n\nexport const EntitiesSchema = z.object({\n user_mentions: z.array(UserMentionSchema),\n urls: z.array(z.any()),\n hashtags: z.array(z.any()),\n symbols: z.array(z.any()),\n});\n\nexport const UserSchema = z.object({\n id_str: z.string(),\n name: z.string(),\n screen_name: z.string(),\n location: z.string(),\n url: z.string().nullable(),\n description: z.string(),\n protected: z.boolean(),\n verified: z.boolean(),\n followers_count: z.number(),\n friends_count: z.number(),\n listed_count: z.number(),\n favourites_count: z.number(),\n statuses_count: z.number(),\n created_at: z.string(),\n profile_banner_url: z.string(),\n profile_image_url_https: z.string(),\n can_dm: z.boolean(),\n});\n\n// Recursive zod types are hard!\nexport const TweetSchema = z.object({\n tweet_created_at: z.string(),\n id_str: z.string(),\n text: z.string().nullable(),\n full_text: z.string(),\n source: z.string(),\n truncated: z.boolean(),\n in_reply_to_status_id_str: z.string().nullable(),\n in_reply_to_user_id_str: z.string().nullable(),\n in_reply_to_screen_name: z.string().nullable(),\n user: UserSchema,\n quoted_status_id_str: z.string().nullable(),\n is_quote_status: z.boolean(),\n // quoted_status: TweetSchema.nullable(),\n // retweeted_status: TweetSchema.nullable(),\n quote_count: z.number(),\n reply_count: z.number(),\n retweet_count: z.number(),\n favorite_count: z.number(),\n lang: z.string(),\n entities: EntitiesSchema,\n views_count: z.number(),\n bookmark_count: z.number(),\n});\n\nexport const TwitterResponseSchema = z.object({\n next_cursor: z.string(),\n tweets: z.array(TweetSchema),\n});\n\nexport const ErrorResponseSchema = z.object({\n status: z.literal(\"error\"),\n message: z.string(),\n});\n\nexport const SearchResponseSchema = z.union([TwitterResponseSchema, ErrorResponseSchema]);\n\nexport type SearchResponse = z.infer;\nexport type TwitterResponse = z.infer;\nexport type Tweet = z.infer;\nexport type User = z.infer;\nexport type Entities = z.infer;\nexport type UserMention = z.infer;\nexport type ErrorResponse = z.infer;",7,[238],{"_146":115,"_99":467,"_104":468,"_149":135,"_246":469},83,["D",1741385110882],[470],{"_102":471,"_149":135,"_146":115,"_95":200,"_156":472,"_154":203,"_99":473,"_148":147,"_104":468,"_150":467,"_158":205,"_152":27,"_157":27,"_98":474},"3d06124a-fba0-11ef-8dd5-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return c.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return c.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return c.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return c.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",29,[145,200],{"_146":115,"_99":476,"_104":477,"_149":135,"_246":478},82,["D",1741385087818],[479],{"_102":480,"_149":135,"_146":115,"_95":200,"_156":481,"_154":203,"_99":482,"_148":147,"_104":477,"_150":476,"_158":205,"_152":27,"_157":27,"_98":483},"2f46517e-fba0-11ef-8824-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",28,[145,200],{"_146":115,"_99":485,"_104":486,"_149":135,"_246":487},81,["D",1741385084757],[488],{"_102":489,"_149":135,"_146":115,"_95":200,"_156":490,"_154":203,"_99":491,"_148":147,"_104":486,"_150":485,"_158":205,"_152":27,"_157":27,"_98":492},"2d73c318-fba0-11ef-aced-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\n});\n\n// Create OpenAPI documentation\napp.doc(\"/openapi.json\", {\n openapi: \"3.0.0\",\n info: {\n title: \"User Management API\",\n version: \"v1.0.0\",\n },\n});\n\n// Mount the Fiberplane UI at the root to be able to test api endpoints\napp.use(\n \"/*\",\n createFiberplane({\n openapi: { url: \"/openapi.json\" },\n }),\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",27,[145,200],{"_146":115,"_99":494,"_104":495,"_149":135,"_246":496},80,["D",1741385069980],[497],{"_102":498,"_149":135,"_146":115,"_95":200,"_156":490,"_154":203,"_99":499,"_148":147,"_104":495,"_150":494,"_158":205,"_152":27,"_157":27,"_98":500},"24a47174-fba0-11ef-9e6f-569c3dd06744",26,[145,200],{"_146":115,"_99":502,"_104":503,"_149":135,"_246":504},79,["D",1741384949887],[505],{"_102":506,"_149":135,"_146":115,"_95":200,"_156":507,"_154":203,"_99":508,"_148":147,"_104":503,"_150":502,"_158":205,"_152":27,"_157":27,"_98":509},"dd0fa8e2-fb9f-11ef-92a5-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",25,[145,200],{"_146":115,"_99":511,"_104":512,"_149":135,"_246":513},78,["D",1741384941353],[514],{"_102":515,"_149":135,"_146":115,"_95":200,"_156":516,"_154":203,"_99":517,"_148":147,"_104":512,"_150":511,"_158":205,"_152":27,"_157":27,"_98":518},"d7f98ada-fb9f-11ef-ab54-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\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: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\nexport default app.fetch;",24,[145,200],{"_146":115,"_99":520,"_104":521,"_149":135,"_246":522},77,["D",1741384926972],[523],{"_102":524,"_149":135,"_146":115,"_95":200,"_156":525,"_154":203,"_99":526,"_148":147,"_104":521,"_150":520,"_158":205,"_152":27,"_157":27,"_98":527},"cf672a94-fb9f-11ef-b447-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, async c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\n});\n\nexport default app.fetch;",23,[145,200],{"_146":115,"_99":529,"_104":530,"_149":135,"_246":531},76,["D",1741384918888],[532],{"_102":533,"_149":135,"_146":115,"_95":200,"_156":534,"_154":203,"_99":535,"_148":147,"_104":530,"_150":529,"_158":205,"_152":27,"_157":27,"_98":536},"ca95e5fa-fb9f-11ef-ad50-569c3dd06744","import { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\nimport { OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.18.4\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport SocialData from \"../sdk/index.ts\";\nimport { setupDatabase, USAGE_TABLE } from \"./database.ts\";\nimport { searchTwitterRoute } from \"./routes/search.ts\";\n\nexport const LIMIT_ERROR = \"You have exceeded the limit of 10 cents per day.\";\n\nconst MAX_DAILY_SPEND = 0.10;\n\n// Uncomment this if you're forking this project:\n// await setupDatabase()\n\n// https://socialdata.gitbook.io/docs/pricing\nconst SOCIAL_DATA_COST_PER_TWEET = 0.0002;\n\nconst app = new OpenAPIHono();\n\napp.openAPIRegistry.registerComponent(\"securitySchemes\", \"Bearer\", {\n type: \"http\",\n scheme: \"bearer\",\n});\n\napp.openapi(searchTwitterRoute, c => {\n const { query } = c.req.valid(\"query\");\n\n // authenticate val town user\n const Authorization = c.req.header(\"Authorization\");\n if (!Authorization) {\n // TODO check if our hono middleware garuntees this or not or if I have to do this\n return Response.json(\"Missing Authorization header\", { status: 401 });\n }\n // For backwards compatibility with old proxy\n const bearerToken = Authorization.startsWith(\"Bearer \") ? Authorization.slice(\"Bearer \".length) : Authorization;\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n if (user.tier === \"free\") {\n return Response.json(\"This SocialData Proxy requires Val Town Pro: https://www.val.town/pricing\", { status: 401 });\n }\n\n // Check usage limit\n const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const usageCount = await sqlite.execute(\n `\n SELECT sum(cost) as cost\n FROM ${USAGE_TABLE}\n WHERE user_id = ? AND timestamp > ?`,\n [user.id, twentyFourHoursAgo],\n );\n\n const day_cost = usageCount.rows[0].cost as number;\n if (day_cost >= MAX_DAILY_SPEND) {\n return Response.json(LIMIT_ERROR, { status: 429 });\n }\n\n const socialData = new SocialData();\n const socialDataResults = await socialData.search(query);\n\n const returned_tweets_count = \"tweets\" in socialDataResults ? socialDataResults.tweets.length : 0;\n const cost = returned_tweets_count * SOCIAL_DATA_COST_PER_TWEET;\n\n // Insert usage data\n await sqlite.execute(\n `INSERT INTO ${USAGE_TABLE} (user_id, username, query, returned_tweets_count, cost) VALUES (?, ?, ?, ?, ?)`,\n [user.id, user.username, query, returned_tweets_count, cost],\n );\n\n return Response.json(socialDataResults);\n});\n\nexport default app.fetch;",22,[145,200],"page","hasNext","routes/_app","actionData","errors"]

History