[{"_1":2,"_176":-5,"_177":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8a08d4a46a197c541e82d5fac862bafdcf40c111","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",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_151":152,"_173":174,"_175":-5},"handle","drewmcdonald","name","flipdot","path","backend/content/router.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":111,"_112":-5,"_12":113,"_114":115,"_116":117,"_118":117,"_119":-5,"_120":32,"_14":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_150":20},"id","c3bdecb0-ba4d-11f0-aa28-0224a6c84d84","createdAt",["D",1762350360767],"deletedAt","legacyEnvVars","privacy","public","description","server for flipdot display content","imageUrl","b8db9d60-1994-11f0-a97f-49be2029e0a3","pinnedFileId","036ffad0-bcd1-11f0-a8c9-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","5affebf8-2371-44b9-a6da-146d4a0e1f13","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_132":133},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ydmtBUlRqVEEwb1lKTWo3UHNHN25IZlo0UFYifQ","org",{"_94":95,"_136":133,"_12":113},"avatar","branch",{"_139":140,"_96":44,"_102":141,"_142":103,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":97,"_149":95},"version",112,"c3be6604-ba4d-11f0-aa28-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":153,"_96":154,"_155":156,"_157":158,"_159":141,"_160":161,"_162":117,"_104":163,"_139":164,"_165":166,"_167":168,"_169":20,"_170":-5,"_98":171},"682fa2c6-c948-11f0-b579-42dde27851f2","router.ts","fileId","cca006a8-bcd0-11f0-a677-42dde27851f2","parentId","cc5447a4-bcd0-11f0-a582-42dde27851f2","branchId","branchVersion",111,"latest",["D",1763997327084],4,"fileType","script","content","/**\n * Content router with priority queue\n * Manages content sources and selects highest priority content\n */\n\nimport { storage } from \"../storage.ts\";\nimport type { Content } from \"../../shared/types.ts\";\nimport type { CachedContent, ContentSource } from \"./types.ts\";\nimport { isCacheValid } from \"./types.ts\";\n\n/**\n * Content router class\n */\nexport class ContentRouter {\n private sources: Map = new Map();\n private lastContentId: string | null = null;\n\n /**\n * Register a content source\n */\n registerSource(source: ContentSource): void {\n this.sources.set(source.id, source);\n }\n\n /**\n * Unregister a content source\n */\n unregisterSource(sourceId: string): void {\n this.sources.delete(sourceId);\n }\n\n /**\n * Get all registered sources\n */\n getSources(): ContentSource[] {\n return Array.from(this.sources.values());\n }\n\n /**\n * Get cached content from blob storage\n */\n private async getCachedContent(\n cacheKey: string,\n ): Promise {\n try {\n const cached = await storage.getJSON(cacheKey) as CachedContent | null;\n if (!cached) {\n return null;\n }\n\n const now = Date.now();\n if (isCacheValid(cached, now)) {\n return cached.content;\n }\n\n // Cache expired, delete it\n await storage.delete(cacheKey);\n return null;\n } catch (error) {\n console.error(`Error reading cache key ${cacheKey}:`, error);\n return null;\n }\n }\n\n /**\n * Set cached content in blob storage\n */\n private async setCachedContent(\n cacheKey: string,\n content: Content,\n ttl_ms: number,\n next_update_ms?: number,\n ): Promise {\n try {\n const cached: CachedContent = {\n content,\n cached_at: Date.now(),\n ttl_ms,\n next_update_ms,\n };\n await storage.setJSON(cacheKey, cached);\n } catch (error) {\n console.error(`Error writing cache key ${cacheKey}:`, error);\n }\n }\n\n /**\n * Get content from a source (with caching)\n */\n private async getSourceContent(\n source: ContentSource,\n ): Promise {\n // Build cache key from source ID\n const cacheKey = `flipdot:source:${source.id}`;\n\n // Try to get from cache\n let content = await this.getCachedContent(cacheKey);\n\n // If cache miss, generate new content\n if (!content) {\n try {\n content = await source.generate();\n\n // Calculate next update time if source provides it\n const next_update_ms = source.getNextUpdateTime?.();\n\n await this.setCachedContent(\n cacheKey,\n content,\n source.ttl_ms,\n next_update_ms,\n );\n } catch (error) {\n console.error(\n `Error generating content from source ${source.id}:`,\n error,\n );\n return null;\n }\n }\n\n return content;\n }\n\n /**\n * Generate complete playlist from all sources ordered by priority\n * Automatically removes expired sources\n */\n async generatePlaylist(): Promise {\n const now = Date.now();\n const sources = this.getSources();\n\n // Remove expired sources\n const expiredSources = sources.filter(\n (s) => s.expires_at !== undefined && s.expires_at < now,\n );\n for (const source of expiredSources) {\n console.log(\n `Removing expired source: ${source.id} (expired at ${\n new Date(source.expires_at!).toISOString()\n })`,\n );\n this.unregisterSource(source.id);\n }\n\n // Get remaining sources\n const activeSources = this.getSources();\n\n if (activeSources.length === 0) {\n console.warn(\"No content sources registered\");\n return [];\n }\n\n // Get content from all active sources\n const contentPromises = activeSources.map(async (source) => {\n const content = await this.getSourceContent(source);\n return { source, content };\n });\n\n const results = await Promise.all(contentPromises);\n\n // Filter out null content\n const available = results.filter((r) => r.content !== null) as Array<{\n source: ContentSource;\n content: Content;\n }>;\n\n if (available.length === 0) {\n console.warn(\"No content available from any source\");\n return [];\n }\n\n // Sort by priority (descending - highest first)\n available.sort((a, b) => b.source.priority - a.source.priority);\n\n // Return all content as ordered playlist\n return available.map((r) => r.content);\n }\n\n /**\n * Select highest priority content from all sources\n * @deprecated Use generatePlaylist() instead\n */\n async selectContent(): Promise {\n const playlist = await this.generatePlaylist();\n return playlist.length > 0 ? playlist[0] : null;\n }\n\n /**\n * Check if content has changed since last selection\n */\n hasContentChanged(content: Content | null): boolean {\n if (!content) {\n return this.lastContentId !== null;\n }\n return content.content_id !== this.lastContentId;\n }\n\n /**\n * Get last sent content ID\n */\n getLastContentId(): string | null {\n return this.lastContentId;\n }\n\n /**\n * Update last content ID (call after sending content)\n */\n updateLastContentId(contentId: string): void {\n this.lastContentId = contentId;\n }\n\n /**\n * Load last content ID from persistent storage\n */\n async loadLastContentId(): Promise {\n try {\n const lastId = await storage.getJSON(\"flipdot:last_content_id\") as\n | string\n | null;\n this.lastContentId = lastId;\n } catch (error) {\n console.error(\"Error loading last content ID:\", error);\n }\n }\n\n /**\n * Save last content ID to persistent storage\n */\n async saveLastContentId(): Promise {\n try {\n if (this.lastContentId) {\n await storage.setJSON(\"flipdot:last_content_id\", this.lastContentId);\n }\n } catch (error) {\n console.error(\"Error saving last content ID:\", error);\n }\n }\n\n /**\n * Calculate optimal poll interval based on next content update and source expiration\n * Returns milliseconds until the next update is needed, or default interval\n */\n async getOptimalPollInterval(\n defaultInterval: number = 30000,\n ): Promise {\n const now = Date.now();\n const sources = this.getSources();\n\n // Find the soonest expiration time among all sources\n const expiringTimes = sources\n .filter((s) => s.expires_at !== undefined)\n .map((s) => s.expires_at!);\n\n let minInterval = defaultInterval;\n\n if (expiringTimes.length > 0) {\n const nextExpiration = Math.min(...expiringTimes);\n const timeUntilExpiration = nextExpiration - now;\n\n // If expiration is in the past or very soon, poll again quickly\n if (timeUntilExpiration <= 0) {\n return 1000; // 1 second (minimum)\n }\n\n // Add a small buffer (1 second) to ensure we poll after expiration\n minInterval = Math.min(minInterval, timeUntilExpiration + 1000);\n }\n\n // Check all cached content for next_update_ms\n for (const source of sources) {\n const cacheKey = `flipdot:source:${source.id}`;\n try {\n const cached = await storage.getJSON(cacheKey) as CachedContent | null;\n if (cached?.next_update_ms) {\n const timeUntilUpdate = cached.next_update_ms - now;\n if (timeUntilUpdate > 0) {\n // Add buffer to ensure we poll after the update time\n minInterval = Math.min(minInterval, timeUntilUpdate + 1000);\n } else {\n // Content needs immediate update\n return 1000;\n }\n }\n } catch (_error) {\n // Ignore cache read errors\n }\n }\n\n return minInterval;\n }\n}\n","deleted","label",[172,167,154],"backend","permalink","https://www.val.town/x/drewmcdonald/flipdot/code/backend/content/router.ts","extension","actionData","errors"]