[{"_1":2,"_171":-5,"_172":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","ENV",{"_36":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e0e89c7153bd059eb1080bc940c618bdf9a95d64","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_168":169,"_170":-5},"handle","Venny","name","Chatbrain","path","backend/scheduler.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","603f6164-3942-11f0-9efb-9e149126039e","createdAt",["D",1748161769385],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","c85aa4a0-2ce2-11f0-b24f-c19e9e5d59f9","pinnedFileId","pinPreview","screenshotVersion","likeCount","e6bfacf1-dff1-46eb-81c1-70adc05fbd3f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ3cllnS2RUMGV4Z2pMRHQ1bEs4MVYwYW5sVyJ9","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",18,"603fa124-3942-11f0-9efb-9e149126039e","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":32,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"f6d55302-3944-11f0-a8fc-9e149126039e","scheduler.ts","fileId","f6d553b6-3944-11f0-a8fc-9e149126039e","parentId","725d83d2-4fe8-4087-9378-ddcc192d84ba","branchId","branchVersion",14,"latest",true,["D",1748162881018],"fileType","script","content","// Content scheduling and queue management\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { ContentPost, SocialPlatform } from \"../shared/types.ts\";\n\nconst SCHEDULED_POSTS_TABLE = 'scheduled_posts_v1';\n\nexport class ContentScheduler {\n constructor() {\n this.initDatabase();\n }\n\n private async initDatabase() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${SCHEDULED_POSTS_TABLE} (\n id TEXT PRIMARY KEY,\n content TEXT NOT NULL,\n hashtags TEXT NOT NULL,\n platforms TEXT NOT NULL,\n scheduled_for TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'scheduled',\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n posted_at TEXT,\n error_message TEXT,\n retry_count INTEGER DEFAULT 0,\n max_retries INTEGER DEFAULT 3\n )`);\n }\n\n async schedulePost(\n content: string,\n hashtags: string[],\n platforms: SocialPlatform[],\n scheduledFor: Date\n ): Promise<{ success: boolean; scheduleId?: string; error?: string }> {\n try {\n const scheduleId = `sched_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`;\n \n await sqlite.execute(\n `INSERT INTO ${SCHEDULED_POSTS_TABLE} \n (id, content, hashtags, platforms, scheduled_for) \n VALUES (?, ?, ?, ?, ?)`,\n [\n scheduleId,\n content,\n JSON.stringify(hashtags),\n JSON.stringify(platforms),\n scheduledFor.toISOString()\n ]\n );\n\n return { success: true, scheduleId };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async getScheduledPosts(limit: number = 50): Promise<{\n success: boolean;\n posts?: Array<{\n id: string;\n content: string;\n hashtags: string[];\n platforms: SocialPlatform[];\n scheduledFor: string;\n status: string;\n createdAt: string;\n }>;\n error?: string;\n }> {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM ${SCHEDULED_POSTS_TABLE} \n ORDER BY scheduled_for ASC \n LIMIT ?`,\n [limit]\n );\n\n const posts = result.rows?.map(row => ({\n id: row.id,\n content: row.content,\n hashtags: JSON.parse(row.hashtags),\n platforms: JSON.parse(row.platforms),\n scheduledFor: row.scheduled_for,\n status: row.status,\n createdAt: row.created_at,\n })) || [];\n\n return { success: true, posts };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async getPendingPosts(): Promise<{\n success: boolean;\n posts?: Array<{\n id: string;\n content: string;\n hashtags: string[];\n platforms: SocialPlatform[];\n scheduledFor: string;\n }>;\n error?: string;\n }> {\n try {\n const now = new Date().toISOString();\n \n const result = await sqlite.execute(\n `SELECT * FROM ${SCHEDULED_POSTS_TABLE} \n WHERE status = 'scheduled' \n AND scheduled_for <= ? \n AND retry_count < max_retries\n ORDER BY scheduled_for ASC`,\n [now]\n );\n\n const posts = result.rows?.map(row => ({\n id: row.id,\n content: row.content,\n hashtags: JSON.parse(row.hashtags),\n platforms: JSON.parse(row.platforms),\n scheduledFor: row.scheduled_for,\n })) || [];\n\n return { success: true, posts };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async markPostAsPosted(scheduleId: string, postResults: Array<{\n platform: SocialPlatform;\n success: boolean;\n postId?: string;\n error?: string;\n }>): Promise<{ success: boolean; error?: string }> {\n try {\n const allSuccessful = postResults.every(r => r.success);\n const status = allSuccessful ? 'posted' : 'failed';\n const errorMessage = allSuccessful ? null : \n postResults.filter(r => !r.success).map(r => `${r.platform}: ${r.error}`).join('; ');\n\n await sqlite.execute(\n `UPDATE ${SCHEDULED_POSTS_TABLE} \n SET status = ?, posted_at = ?, error_message = ?\n WHERE id = ?`,\n [status, new Date().toISOString(), errorMessage, scheduleId]\n );\n\n return { success: true };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async markPostAsFailed(scheduleId: string, error: string): Promise<{ success: boolean; error?: string }> {\n try {\n await sqlite.execute(\n `UPDATE ${SCHEDULED_POSTS_TABLE} \n SET retry_count = retry_count + 1, error_message = ?\n WHERE id = ?`,\n [error, scheduleId]\n );\n\n // Check if we've exceeded max retries\n const result = await sqlite.execute(\n `SELECT retry_count, max_retries FROM ${SCHEDULED_POSTS_TABLE} WHERE id = ?`,\n [scheduleId]\n );\n\n const row = result.rows?.[0];\n if (row && row.retry_count >= row.max_retries) {\n await sqlite.execute(\n `UPDATE ${SCHEDULED_POSTS_TABLE} SET status = 'failed' WHERE id = ?`,\n [scheduleId]\n );\n }\n\n return { success: true };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async deleteScheduledPost(scheduleId: string): Promise<{ success: boolean; error?: string }> {\n try {\n await sqlite.execute(\n `DELETE FROM ${SCHEDULED_POSTS_TABLE} WHERE id = ?`,\n [scheduleId]\n );\n\n return { success: true };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n async updateScheduledPost(\n scheduleId: string,\n updates: {\n content?: string;\n hashtags?: string[];\n platforms?: SocialPlatform[];\n scheduledFor?: Date;\n }\n ): Promise<{ success: boolean; error?: string }> {\n try {\n const setParts = [];\n const values = [];\n\n if (updates.content !== undefined) {\n setParts.push('content = ?');\n values.push(updates.content);\n }\n if (updates.hashtags !== undefined) {\n setParts.push('hashtags = ?');\n values.push(JSON.stringify(updates.hashtags));\n }\n if (updates.platforms !== undefined) {\n setParts.push('platforms = ?');\n values.push(JSON.stringify(updates.platforms));\n }\n if (updates.scheduledFor !== undefined) {\n setParts.push('scheduled_for = ?');\n values.push(updates.scheduledFor.toISOString());\n }\n\n if (setParts.length === 0) {\n return { success: false, error: 'No updates provided' };\n }\n\n values.push(scheduleId);\n\n await sqlite.execute(\n `UPDATE ${SCHEDULED_POSTS_TABLE} SET ${setParts.join(', ')} WHERE id = ?`,\n values\n );\n\n return { success: true };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n // Generate optimal posting times based on historical engagement\n async getOptimalPostingTimes(): Promise<{\n success: boolean;\n times?: Array<{ hour: number; dayOfWeek: number; score: number }>;\n error?: string;\n }> {\n try {\n // This would analyze historical engagement data\n // For now, return some sensible defaults\n const optimalTimes = [\n { hour: 9, dayOfWeek: 1, score: 0.85 }, // Monday 9 AM\n { hour: 12, dayOfWeek: 2, score: 0.82 }, // Tuesday 12 PM\n { hour: 15, dayOfWeek: 3, score: 0.88 }, // Wednesday 3 PM\n { hour: 10, dayOfWeek: 4, score: 0.84 }, // Thursday 10 AM\n { hour: 14, dayOfWeek: 5, score: 0.79 }, // Friday 2 PM\n ];\n\n return { success: true, times: optimalTimes };\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n\n // Schedule posts at optimal times\n async scheduleAtOptimalTime(\n content: string,\n hashtags: string[],\n platforms: SocialPlatform[],\n daysAhead: number = 1\n ): Promise<{ success: boolean; scheduleId?: string; scheduledFor?: Date; error?: string }> {\n try {\n const optimalTimes = await this.getOptimalPostingTimes();\n if (!optimalTimes.success || !optimalTimes.times) {\n return { success: false, error: 'Could not get optimal times' };\n }\n\n // Find the next optimal time\n const now = new Date();\n const targetDate = new Date(now.getTime() + (daysAhead * 24 * 60 * 60 * 1000));\n \n // Use the best scoring time for the target day\n const bestTime = optimalTimes.times[0]; // Highest scoring time\n targetDate.setHours(bestTime.hour, 0, 0, 0);\n\n const result = await this.schedulePost(content, hashtags, platforms, targetDate);\n \n if (result.success) {\n return {\n success: true,\n scheduleId: result.scheduleId,\n scheduledFor: targetDate\n };\n } else {\n return result;\n }\n } catch (error) {\n return { success: false, error: error.message };\n }\n }\n}","deleted","label",[167,149],"backend","permalink","https://www.val.town/x/Venny/Chatbrain/code/backend/scheduler.ts","extension","actionData","errors"]