[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","08df2158b567c8dc30dd332965dd8203fb644318","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/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_155":156,"_177":178,"_179":-5},"handle","kamenxrider","name","readwise-mastra","path","lib/readwise.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":121,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_154":20},"id","cbd319ae-ffd3-11f0-bcd8-42dde27851f2","createdAt",["D",1769994557115],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","d4de366f-8281-484e-8856-3824b6bdfb0b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","9bb2e2b6-8aa1-4b6a-b4ef-ad7adab2b868","tursoName","cbd319aeffd311f0bcd842dde27851f2","tursoHostname","cbd319aeffd311f0bcd842dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ybFJkNm8zSzFzbGE5RzhsTUt3OGJMZFdGZFkifQ","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","pro","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},"version",51,"cbd4b750-ffd3-11f0-bcd8-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":157,"_97":158,"_159":160,"_161":162,"_163":145,"_164":165,"_166":167,"_105":168,"_143":33,"_169":170,"_171":172,"_173":20,"_174":-5,"_99":175},"c3584816-ffd4-11f0-9f7d-42dde27851f2","readwise.ts","fileId","c35848c0-ffd4-11f0-9f7d-42dde27851f2","parentId","99160818-ffd4-11f0-97f3-42dde27851f2","branchId","branchVersion",13,"latest",true,["D",1769994972388],"fileType","script","content","/**\n * Readwise Reader API client\n * Docs: https://readwise.io/reader_api\n */\n\nimport { loadEnv } from \"./env.ts\";\n\nconst READER_API_BASE = \"https://readwise.io/api/v3\";\n\nexport interface ReadwiseDoc {\n id: string;\n url: string;\n source_url: string | null;\n title: string | null;\n author: string | null;\n source: string | null;\n category: string;\n location: string;\n tags: Record; // { tag_key: tag_name }\n site_name: string | null;\n word_count: number | null;\n created_at: string;\n updated_at: string;\n published_date: string | null;\n summary: string | null;\n image_url: string | null;\n content: string | null;\n html_content?: string | null;\n notes: string | null;\n parent_id: string | null;\n reading_progress: number;\n first_opened_at: string | null;\n last_opened_at: string | null;\n saved_at: string;\n last_moved_at: string;\n}\n\nexport interface ListDocsParams {\n id?: string;\n updatedAfter?: string;\n location?: string;\n category?: string;\n pageCursor?: string;\n}\n\nexport interface ListDocsResponse {\n count: number;\n nextPageCursor: string | null;\n results: ReadwiseDoc[];\n}\n\nexport interface UpdateDocParams {\n title?: string;\n author?: string;\n summary?: string;\n published_date?: string;\n image_url?: string;\n location?: \"new\" | \"later\" | \"shortlist\" | \"archive\" | \"feed\";\n category?: \"article\" | \"email\" | \"rss\" | \"highlight\" | \"note\" | \"pdf\" | \"epub\" | \"tweet\" | \"video\";\n tags?: string[]; // Array of tag names to set (replaces existing)\n notes?: string;\n}\n\n/**\n * Get authorization headers for Readwise API\n */\nfunction getHeaders(): HeadersInit {\n const { READWISE_TOKEN } = loadEnv();\n return {\n \"Authorization\": `Token ${READWISE_TOKEN}`,\n \"Content-Type\": \"application/json\",\n };\n}\n\n/**\n * Check if the Readwise token is valid\n */\nexport async function checkAuth(): Promise<{ valid: boolean; error?: string }> {\n try {\n const response = await fetch(`${READER_API_BASE}/list/`, {\n method: \"GET\",\n headers: getHeaders(),\n });\n\n if (response.ok) {\n return { valid: true };\n }\n\n if (response.status === 401) {\n return { valid: false, error: \"Invalid Readwise token\" };\n }\n\n return { valid: false, error: `Unexpected status: ${response.status}` };\n } catch (err) {\n return { valid: false, error: String(err) };\n }\n}\n\n/**\n * List documents with pagination support\n */\nexport async function listDocs(params: ListDocsParams = {}): Promise {\n const url = new URL(`${READER_API_BASE}/list/`);\n\n if (params.id) url.searchParams.set(\"id\", params.id);\n if (params.updatedAfter) url.searchParams.set(\"updatedAfter\", params.updatedAfter);\n if (params.location) url.searchParams.set(\"location\", params.location);\n if (params.category) url.searchParams.set(\"category\", params.category);\n if (params.pageCursor) url.searchParams.set(\"pageCursor\", params.pageCursor);\n\n const response = await fetch(url.toString(), {\n method: \"GET\",\n headers: getHeaders(),\n });\n\n if (!response.ok) {\n if (response.status === 429) {\n const retryAfter = response.headers.get(\"Retry-After\");\n throw new RateLimitError(retryAfter ? parseInt(retryAfter) : 60);\n }\n throw new Error(`Readwise API error: ${response.status} ${response.statusText}`);\n }\n\n const data = await response.json();\n return {\n count: data.count,\n nextPageCursor: data.nextPageCursor || null,\n results: data.results || [],\n };\n}\n\n/**\n * Get a single document by ID\n */\nexport async function getDoc(id: string): Promise {\n const response = await listDocs({ id });\n return response.results[0] || null;\n}\n\n/**\n * Update a document\n */\nexport async function updateDoc(id: string, params: UpdateDocParams): Promise {\n const response = await fetch(`${READER_API_BASE}/update/${id}/`, {\n method: \"PATCH\",\n headers: getHeaders(),\n body: JSON.stringify(params),\n });\n\n if (!response.ok) {\n if (response.status === 429) {\n const retryAfter = response.headers.get(\"Retry-After\");\n throw new RateLimitError(retryAfter ? parseInt(retryAfter) : 60);\n }\n const errorText = await response.text();\n throw new Error(`Readwise update error: ${response.status} - ${errorText}`);\n }\n\n return response.json();\n}\n\n/**\n * Delete a document\n */\nexport async function deleteDoc(id: string): Promise {\n const response = await fetch(`${READER_API_BASE}/delete/${id}/`, {\n method: \"DELETE\",\n headers: getHeaders(),\n });\n\n if (!response.ok && response.status !== 404) {\n if (response.status === 429) {\n const retryAfter = response.headers.get(\"Retry-After\");\n throw new RateLimitError(retryAfter ? parseInt(retryAfter) : 60);\n }\n throw new Error(`Readwise delete error: ${response.status}`);\n }\n}\n\n/**\n * Fetch all pages of documents (with rate limit handling)\n */\nexport async function fetchAllDocs(\n params: Omit = {},\n onPage?: (docs: ReadwiseDoc[], pageNum: number) => Promise\n): Promise {\n const allDocs: ReadwiseDoc[] = [];\n let pageCursor: string | null = null;\n let pageNum = 0;\n\n do {\n try {\n const response = await listDocs({ ...params, pageCursor: pageCursor || undefined });\n allDocs.push(...response.results);\n pageNum++;\n\n if (onPage) {\n await onPage(response.results, pageNum);\n }\n\n pageCursor = response.nextPageCursor;\n\n // Small delay between pages to be nice to the API\n if (pageCursor) {\n await sleep(200);\n }\n } catch (err) {\n if (err instanceof RateLimitError) {\n console.log(`Rate limited, waiting ${err.retryAfter} seconds...`);\n await sleep(err.retryAfter * 1000);\n // Retry the same page\n continue;\n }\n throw err;\n }\n } while (pageCursor);\n\n return allDocs;\n}\n\n// ============ Error Classes ============\n\nexport class RateLimitError extends Error {\n retryAfter: number;\n\n constructor(retryAfter: number) {\n super(`Rate limited. Retry after ${retryAfter} seconds.`);\n this.name = \"RateLimitError\";\n this.retryAfter = retryAfter;\n }\n}\n\n// ============ Helpers ============\n\nfunction sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\n/**\n * Convert Readwise tags object to array of tag keys\n */\nexport function tagsObjectToKeys(tags: Record): string[] {\n return Object.keys(tags);\n}\n\n/**\n * Convert Readwise tags object to array of tag names\n */\nexport function tagsObjectToNames(tags: Record): string[] {\n return Object.values(tags);\n}\n","deleted","label",[176,158],"lib","permalink","https://www.val.town/x/kamenxrider/readwise-mastra/code/lib/readwise.ts","extension","actionData","errors"]