\n \n \n \n\n",[123,127],"87e464bd52714526a07792a2c7f1642e90081f818e1cc2f1ae5d88bc6e63e165",{"_32":135,"_13":123,"_87":116,"_89":-5,"_91":57,"_92":129,"_94":26,"_34":136,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":-7,"_80":137,"_103":-5},"30aff2b4-3f3d-11f0-a186-76b3cceeab13",["D",1748819249077],[123],"backend/services/code-parser.ts",{"_32":140,"_13":141,"_87":142,"_89":143,"_91":57,"_92":144,"_94":26,"_34":145,"_40":22,"_96":97,"_98":146,"_64":48,"_100":-5,"_101":-7,"_80":147,"_103":148},"f1400768-3f3c-11f0-b687-76b3cceeab13","code-parser.ts","f1400830-3f3c-11f0-b687-76b3cceeab13","5adcad47-5c8b-4e1e-8483-8f11a976530a",4,["D",1748819142651],"import { SUPPORTED_LANGUAGES } from \"../../shared/codesentinel-types.ts\";\n\nexport class CodeParser {\n /**\n * Detect programming language from code content\n */\n static detectLanguage(code: string, filename?: string): string {\n // First try to detect by filename extension\n if (filename) {\n const extension = this.getFileExtension(filename);\n const langByExtension = SUPPORTED_LANGUAGES.find(lang => \n lang.extensions.includes(extension)\n );\n if (langByExtension) {\n return langByExtension.id;\n }\n }\n\n // Fallback to content-based detection\n return this.detectLanguageByContent(code);\n }\n\n /**\n * Extract file extension from filename\n */\n private static getFileExtension(filename: string): string {\n const lastDot = filename.lastIndexOf('.');\n return lastDot !== -1 ? filename.substring(lastDot) : '';\n }\n\n /**\n * Detect language by analyzing code content\n */\n private static detectLanguageByContent(code: string): string {\n const patterns = [\n { lang: 'javascript', patterns: [/\\bfunction\\b/, /\\bconst\\b/, /\\blet\\b/, /\\bvar\\b/, /=>/] },\n { lang: 'typescript', patterns: [/\\binterface\\b/, /\\btype\\b/, /:\\s*\\w+/, /\\bas\\b/] },\n { lang: 'python', patterns: [/\\bdef\\b/, /\\bimport\\b/, /\\bfrom\\b.*\\bimport\\b/, /\\bclass\\b.*:/] },\n { lang: 'java', patterns: [/\\bpublic\\s+class\\b/, /\\bprivate\\b/, /\\bprotected\\b/, /\\bstatic\\b/] },\n { lang: 'go', patterns: [/\\bfunc\\b/, /\\bpackage\\b/, /\\bimport\\b/, /\\bvar\\b/] },\n { lang: 'rust', patterns: [/\\bfn\\b/, /\\blet\\b/, /\\bmut\\b/, /\\buse\\b/] },\n { lang: 'cpp', patterns: [/\\b#include\\b/, /\\bstd::\\b/, /\\bnamespace\\b/, /\\bclass\\b/] }\n ];\n\n for (const { lang, patterns } of patterns) {\n const matches = patterns.filter(pattern => pattern.test(code)).length;\n if (matches >= 2) {\n return lang;\n }\n }\n\n // Default to JavaScript if no clear match\n return 'javascript';\n }\n\n /**\n * Validate code syntax (basic validation)\n */\n static validateCode(code: string, language: string): { isValid: boolean; errors: string[] } {\n const errors: string[] = [];\n\n // Basic validation checks\n if (!code.trim()) {\n errors.push(\"Code cannot be empty\");\n return { isValid: false, errors };\n }\n\n if (code.length > 50000) {\n errors.push(\"Code is too long (max 50,000 characters)\");\n }\n\n // Language-specific basic checks\n switch (language) {\n case 'javascript':\n case 'typescript':\n this.validateJavaScript(code, errors);\n break;\n case 'python':\n this.validatePython(code, errors);\n break;\n case 'java':\n this.validateJava(code, errors);\n break;\n }\n\n return { isValid: errors.length === 0, errors };\n }\n\n private static validateJavaScript(code: string, errors: string[]): void {\n // Check for basic syntax issues\n const openBraces = (code.match(/\\{/g) || []).length;\n const closeBraces = (code.match(/\\}/g) || []).length;\n if (openBraces !== closeBraces) {\n errors.push(\"Mismatched curly braces\");\n }\n\n const openParens = (code.match(/\$/g) || []).length;\n const closeParens = (code.match(/\$/g) || []).length;\n if (openParens !== closeParens) {\n errors.push(\"Mismatched parentheses\");\n }\n }\n\n private static validatePython(code: string, errors: string[]): void {\n // Check for basic Python syntax\n const lines = code.split('\\n');\n let indentLevel = 0;\n \n for (let i = 0; i < lines.length; i++) {\n const line = lines[i];\n if (line.trim() === '') continue;\n \n const leadingSpaces = line.length - line.trimStart().length;\n if (leadingSpaces % 4 !== 0 && leadingSpaces > 0) {\n errors.push(`Line ${i + 1}: Inconsistent indentation (should be multiples of 4 spaces)`);\n break;\n }\n }\n }\n\n private static validateJava(code: string, errors: string[]): void {\n // Check for basic Java syntax\n if (!code.includes('class') && !code.includes('interface')) {\n errors.push(\"Java code should contain at least one class or interface\");\n }\n\n const openBraces = (code.match(/\\{/g) || []).length;\n const closeBraces = (code.match(/\\}/g) || []).length;\n if (openBraces !== closeBraces) {\n errors.push(\"Mismatched curly braces\");\n }\n }\n\n /**\n * Extract metadata from code\n */\n static extractMetadata(code: string, language: string) {\n const lines = code.split('\\n');\n const nonEmptyLines = lines.filter(line => line.trim() !== '');\n \n return {\n totalLines: lines.length,\n codeLines: nonEmptyLines.length,\n blankLines: lines.length - nonEmptyLines.length,\n language,\n estimatedComplexity: this.estimateComplexity(code, language),\n hasComments: this.hasComments(code, language)\n };\n }\n\n private static estimateComplexity(code: string, language: string): 'low' | 'medium' | 'high' {\n const complexityIndicators = [\n /\\bif\\b/g, /\\belse\\b/g, /\\bfor\\b/g, /\\bwhile\\b/g, \n /\\bswitch\\b/g, /\\btry\\b/g, /\\bcatch\\b/g, /\\bfunction\\b/g,\n /\\bclass\\b/g, /\\binterface\\b/g\n ];\n\n const totalMatches = complexityIndicators.reduce((sum, pattern) => {\n return sum + (code.match(pattern) || []).length;\n }, 0);\n\n const codeLines = code.split('\\n').filter(line => line.trim() !== '').length;\n const complexityRatio = totalMatches / Math.max(codeLines, 1);\n\n if (complexityRatio > 0.3) return 'high';\n if (complexityRatio > 0.15) return 'medium';\n return 'low';\n }\n\n private static hasComments(code: string, language: string): boolean {\n const commentPatterns = {\n javascript: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//],\n typescript: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//],\n python: [/#/],\n java: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//],\n go: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//],\n rust: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//],\n cpp: [/\\/\\//, /\\/\\*[\\s\\S]*?\\*\\//]\n };\n\n const patterns = commentPatterns[language as keyof typeof commentPatterns] || [];\n return patterns.some(pattern => pattern.test(code));\n }\n}",[149,150,141],"dea0bf78e5fba7b9a22970f85d27d27e192e42969c8b743bcc62984f57debac4","backend","services","backend/services/ai-engine.ts",{"_32":153,"_13":154,"_87":155,"_89":143,"_91":57,"_92":156,"_94":26,"_34":157,"_40":22,"_96":97,"_98":158,"_64":48,"_100":-5,"_101":-7,"_80":159,"_103":160},"deb4fd56-3f3c-11f0-89b8-76b3cceeab13","ai-engine.ts","deb4fe28-3f3c-11f0-89b8-76b3cceeab13",3,["D",1748819111538],"import { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { \n CodeReviewRequest, \n CodeReviewResult, \n CodeIssue, \n IssueType, \n Severity,\n SUPPORTED_LANGUAGES \n} from \"../../shared/codesentinel-types.ts\";\n\nexport class AIReviewEngine {\n private openai: OpenAI;\n\n constructor() {\n this.openai = new OpenAI();\n }\n\n async analyzeCode(request: CodeReviewRequest): Promise {\n const language = SUPPORTED_LANGUAGES.find(lang => lang.id === request.language);\n if (!language) {\n throw new Error(`Unsupported language: ${request.language}`);\n }\n\n const prompt = this.buildAnalysisPrompt(request.code, language.ai_context);\n \n try {\n const completion = await this.openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"system\",\n content: \"You are an expert code reviewer. Analyze the provided code and return a JSON response with issues, suggestions, and risk assessment.\"\n },\n {\n role: \"user\",\n content: prompt\n }\n ],\n max_tokens: 2000,\n temperature: 0.1\n });\n\n const response = completion.choices[0]?.message?.content;\n if (!response) {\n throw new Error(\"No response from AI model\");\n }\n\n return this.parseAIResponse(response, request);\n } catch (error) {\n console.error(\"AI analysis failed:\", error);\n throw new Error(\"Failed to analyze code with AI\");\n }\n }\n\n private buildAnalysisPrompt(code: string, languageContext: string): string {\n return `\nAnalyze the following ${languageContext} code for issues and provide suggestions for improvement.\n\nCode to analyze:\n\\`\\`\\`\n${code}\n\\`\\`\\`\n\nPlease provide your analysis in the following JSON format:\n{\n \"issues\": [\n {\n \"line_number\": number,\n \"issue_type\": \"bug|code_smell|security|performance|maintainability|style|complexity|documentation\",\n \"severity\": \"critical|high|medium|low|info\",\n \"message\": \"Description of the issue\",\n \"suggestion\": \"How to fix or improve this\"\n }\n ],\n \"suggestions\": [\n \"General suggestion 1\",\n \"General suggestion 2\"\n ],\n \"summary\": \"Overall assessment of the code quality\",\n \"risk_factors\": [\n \"Risk factor 1\",\n \"Risk factor 2\"\n ]\n}\n\nFocus on:\n1. Potential bugs and logical errors\n2. Security vulnerabilities\n3. Performance issues\n4. Code maintainability and readability\n5. Best practices for the language\n6. Code complexity and structure\n7. Documentation and naming conventions\n\nBe specific about line numbers where issues occur. Provide constructive suggestions for improvement.\n`;\n }\n\n private parseAIResponse(response: string, request: CodeReviewRequest): CodeReviewResult {\n try {\n // Extract JSON from the response (in case there's extra text)\n const jsonMatch = response.match(/\\{[\\s\\S]*\\}/);\n if (!jsonMatch) {\n throw new Error(\"No JSON found in AI response\");\n }\n\n const parsed = JSON.parse(jsonMatch[0]);\n const issues: CodeIssue[] = (parsed.issues || []).map((issue: any, index: number) => ({\n id: `issue_${index + 1}`,\n file_path: request.filename || \"code.txt\",\n line_number: issue.line_number || 1,\n issue_type: this.mapIssueType(issue.issue_type),\n severity: this.mapSeverity(issue.severity),\n message: issue.message || \"No description provided\",\n suggestion: issue.suggestion\n }));\n\n const riskScore = this.calculateRiskScore(issues);\n const codeLines = request.code.split('\\n').length;\n\n return {\n issues,\n suggestions: parsed.suggestions || [],\n risk_score: riskScore,\n summary: parsed.summary || \"Code analysis completed\",\n timestamp: new Date().toISOString(),\n language: request.language,\n lines_analyzed: codeLines\n };\n } catch (error) {\n console.error(\"Failed to parse AI response:\", error);\n // Return a fallback result\n return {\n issues: [],\n suggestions: [\"Unable to parse AI analysis. Please try again.\"],\n risk_score: 0,\n summary: \"Analysis failed - please try again\",\n timestamp: new Date().toISOString(),\n language: request.language,\n lines_analyzed: request.code.split('\\n').length\n };\n }\n }\n\n private mapIssueType(type: string): IssueType {\n const typeMap: Record = {\n 'bug': IssueType.BUG,\n 'code_smell': IssueType.CODE_SMELL,\n 'security': IssueType.SECURITY,\n 'performance': IssueType.PERFORMANCE,\n 'maintainability': IssueType.MAINTAINABILITY,\n 'style': IssueType.STYLE,\n 'complexity': IssueType.COMPLEXITY,\n 'documentation': IssueType.DOCUMENTATION\n };\n return typeMap[type] || IssueType.CODE_SMELL;\n }\n\n private mapSeverity(severity: string): Severity {\n const severityMap: Record = {\n 'critical': Severity.CRITICAL,\n 'high': Severity.HIGH,\n 'medium': Severity.MEDIUM,\n 'low': Severity.LOW,\n 'info': Severity.INFO\n };\n return severityMap[severity] || Severity.MEDIUM;\n }\n\n private calculateRiskScore(issues: CodeIssue[]): number {\n if (issues.length === 0) return 0;\n\n const severityWeights = {\n [Severity.CRITICAL]: 10,\n [Severity.HIGH]: 7,\n [Severity.MEDIUM]: 4,\n [Severity.LOW]: 2,\n [Severity.INFO]: 1\n };\n\n const totalWeight = issues.reduce((sum, issue) => {\n return sum + severityWeights[issue.severity];\n }, 0);\n\n // Normalize to 0-100 scale\n const maxPossibleWeight = issues.length * 10; // All critical\n return Math.min(100, Math.round((totalWeight / maxPossibleWeight) * 100));\n }\n}",[149,150,154],"59294bc9bdc29dd3ea710c2e8310aa6979de461ce5ea81b945bf05840f9c6fc8","backend/services",{"_32":163,"_13":150,"_87":143,"_89":164,"_91":57,"_92":156,"_94":26,"_34":165,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":-7,"_80":166,"_103":-5},"deb5161a-3f3c-11f0-89b8-76b3cceeab13","3d87b255-31fe-4d2e-a73d-5f4fd9756bba",["D",1748819111538],[149,150],"backend/routes/review.ts",{"_32":169,"_13":170,"_87":171,"_89":172,"_91":57,"_92":173,"_94":26,"_34":174,"_40":22,"_96":97,"_98":175,"_64":48,"_100":-5,"_101":-7,"_80":176,"_103":177},"ffbd04da-3f3c-11f0-8781-76b3cceeab13","review.ts","ffbd0584-3f3c-11f0-8781-76b3cceeab13","a9630fec-a6e5-48a2-8b9b-5509bfe0e8bf",5,["D",1748819166952],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { AIReviewEngine } from \"../services/ai-engine.ts\";\nimport { CodeParser } from \"../services/code-parser.ts\";\nimport { CodeReviewRequest, SUPPORTED_LANGUAGES } from \"../../shared/codesentinel-types.ts\";\n\nconst app = new Hono();\n\n// Initialize AI engine\nconst aiEngine = new AIReviewEngine();\n\n// Health check endpoint\napp.get(\"/health\", (c) => {\n return c.json({ \n status: \"healthy\", \n timestamp: new Date().toISOString(),\n service: \"CodeSentinel Review API\"\n });\n});\n\n// Get supported languages\napp.get(\"/languages\", (c) => {\n return c.json({ \n languages: SUPPORTED_LANGUAGES,\n total: SUPPORTED_LANGUAGES.length\n });\n});\n\n// Code review endpoint\napp.post(\"/review\", async (c) => {\n try {\n const body = await c.req.json();\n \n // Validate request\n if (!body.code || typeof body.code !== 'string') {\n return c.json({ \n error: \"Code is required and must be a string\" \n }, 400);\n }\n\n // Auto-detect language if not provided\n let language = body.language;\n if (!language) {\n language = CodeParser.detectLanguage(body.code, body.filename);\n }\n\n // Validate language is supported\n const supportedLanguage = SUPPORTED_LANGUAGES.find(lang => lang.id === language);\n if (!supportedLanguage) {\n return c.json({ \n error: `Unsupported language: ${language}. Supported languages: ${SUPPORTED_LANGUAGES.map(l => l.id).join(', ')}` \n }, 400);\n }\n\n // Validate code\n const validation = CodeParser.validateCode(body.code, language);\n if (!validation.isValid) {\n return c.json({ \n error: \"Code validation failed\", \n details: validation.errors \n }, 400);\n }\n\n // Extract metadata\n const metadata = CodeParser.extractMetadata(body.code, language);\n\n // Create review request\n const request: CodeReviewRequest = {\n code: body.code,\n language: language,\n filename: body.filename || `code.${supportedLanguage.extensions[0].substring(1)}`\n };\n\n // Perform AI analysis\n const result = await aiEngine.analyzeCode(request);\n\n // Add metadata to result\n const enrichedResult = {\n ...result,\n metadata: {\n ...metadata,\n detected_language: language,\n auto_detected: !body.language\n }\n };\n\n return c.json(enrichedResult);\n\n } catch (error) {\n console.error(\"Review endpoint error:\", error);\n \n // Return appropriate error response\n if (error instanceof Error) {\n if (error.message.includes(\"Unsupported language\")) {\n return c.json({ error: error.message }, 400);\n }\n if (error.message.includes(\"Failed to analyze\")) {\n return c.json({ error: \"AI analysis service temporarily unavailable\" }, 503);\n }\n }\n\n return c.json({ \n error: \"Internal server error occurred during code analysis\" \n }, 500);\n }\n});\n\n// Batch review endpoint (for multiple files)\napp.post(\"/review/batch\", async (c) => {\n try {\n const body = await c.req.json();\n \n if (!Array.isArray(body.files) || body.files.length === 0) {\n return c.json({ \n error: \"Files array is required and must not be empty\" \n }, 400);\n }\n\n if (body.files.length > 10) {\n return c.json({ \n error: \"Maximum 10 files allowed per batch request\" \n }, 400);\n }\n\n const results = [];\n \n for (const file of body.files) {\n try {\n const language = file.language || CodeParser.detectLanguage(file.code, file.filename);\n const request: CodeReviewRequest = {\n code: file.code,\n language: language,\n filename: file.filename\n };\n \n const result = await aiEngine.analyzeCode(request);\n results.push({\n filename: file.filename,\n success: true,\n result\n });\n } catch (error) {\n results.push({\n filename: file.filename,\n success: false,\n error: error instanceof Error ? error.message : \"Unknown error\"\n });\n }\n }\n\n return c.json({\n batch_id: `batch_${Date.now()}`,\n total_files: body.files.length,\n successful: results.filter(r => r.success).length,\n failed: results.filter(r => !r.success).length,\n results\n });\n\n } catch (error) {\n console.error(\"Batch review endpoint error:\", error);\n return c.json({ \n error: \"Internal server error occurred during batch analysis\" \n }, 500);\n }\n});\n\nexport default app;",[149,178,170],"e89970900b28aed2c12c2044c2bd716b7f41b82c718616130e293a33f8fd6d5b","routes","backend/routes",{"_32":181,"_13":178,"_87":172,"_89":164,"_91":57,"_92":173,"_94":26,"_34":182,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":-7,"_80":183,"_103":-5},"ffbd2c8a-3f3c-11f0-8781-76b3cceeab13",["D",1748819166952],[149,178],"backend/index.ts",{"_32":186,"_13":187,"_87":188,"_89":164,"_91":57,"_92":56,"_94":26,"_34":189,"_40":93,"_96":190,"_98":191,"_64":48,"_100":-5,"_101":-7,"_80":192,"_103":193},"4a2b2eb6-3f3d-11f0-9027-76b3cceeab13","index.ts","0e02df56-3f3d-11f0-b8f6-76b3cceeab13",["D",1748819291829],"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport reviewRoutes from \"./routes/review.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// API routes\napp.route(\"/api\", reviewRoutes);\n\n// Serve static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Serve main application\napp.get(\"/\", async c => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject initial data to avoid extra round-trips\n const initialData = {\n supportedLanguages: [\n { id: \"javascript\", name: \"JavaScript\", extensions: [\".js\", \".mjs\"] },\n { id: \"typescript\", name: \"TypeScript\", extensions: [\".ts\", \".tsx\"] },\n { id: \"python\", name: \"Python\", extensions: [\".py\"] },\n { id: \"java\", name: \"Java\", extensions: [\".java\"] },\n { id: \"go\", name: \"Go\", extensions: [\".go\"] },\n { id: \"rust\", name: \"Rust\", extensions: [\".rs\"] },\n { id: \"cpp\", name: \"C++\", extensions: [\".cpp\", \".cc\", \".cxx\"] }\n ],\n appName: \"CodeSentinel\",\n version: \"1.0.0\"\n };\n \n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error serving main page:\", error);\n return c.html(`\n \n \n \n CodeSentinel - Error\n \n \n \n

🚨 Application Error

Failed to load the CodeSentinel application.

Please try refreshing the page.

\n \n \n `, 500);\n }\n});\n\n// 404 handler\napp.notFound((c) => {\n return c.html(`\n \n \n \n CodeSentinel - Not Found\n \n \n \n

🔍 Page Not Found

The page you're looking for doesn't exist.

\n \n Go Home\n \n

\n \n \n `, 404);\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;",[149,187],"9dbbe1605628b7640d553a858a5c46b3f8c319387b9bf2f1a47ee04a4d053e15",{"_32":195,"_13":149,"_87":164,"_89":-5,"_91":57,"_92":156,"_94":26,"_34":196,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":-7,"_80":197,"_103":-5},"deb51462-3f3c-11f0-89b8-76b3cceeab13",["D",1748819111538],[149],["D",1748561592095],"legacyEnvVars","httpPrivacy","description","imageUrl","userId","6ba47c70-3ce3-11f0-8a84-ab0596bba6f5","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","a956f3ab-c5b6-4f16-a22e-9bcb0079d529","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_235":231},"org",{"_11":12,"_229":-5,"_230":231,"_203":204,"_232":233,"_234":48},"branch","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ5dncxVUwwR0NJUlhncHZ1a2NHMXZxS1g5ZSJ9","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":58,"_13":14,"_34":477,"_46":-5,"_199":48,"_49":50,"_200":50,"_201":-5,"_202":-5,"_203":204,"_205":188,"_206":26,"_207":26,"_208":-5,"_209":22,"_53":210,"_211":-5,"_212":-5,"_213":-5,"_214":-5,"_215":216,"_217":216,"_218":219,"_220":219,"_221":219,"_222":216,"_223":216,"_224":478,"_226":479,"_228":480,"_47":48},"tree",[318,325,328,340,342,345,346,347],"files",[318,319,320,321,322,323,324,325,326,327,328,329,330,331,332,333,334,335,336,337,338,339,340,341,342,343,344,345,346,347],"counts",{"_308":22,"_309":276,"_310":22,"_311":312,"_313":314},"contents",[265,266,267,268,269,270,271,272],"upstreamProject",{"_32":39,"_13":14,"_201":261,"_202":262,"_49":50,"_224":263},"upstreamBranch",{"_32":33,"_34":259,"_36":260,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1744293493384],["D",1745504421946],"Augmenting Notion with webhooks and val.town.","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f25cb5fe-2b5b-4f08-5492-f088b3195400/square512?exp=1789606840&sig=a6432ce61fdc3d624104aa082cb3e3a6f02244c5a514c8560cbd2b64589c70e8",{"_11":52,"_235":264},"https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4YUNlWnM0S3Z6OWxiOUlLS25sWjNJWFhzSSJ9",{"_32":195,"_13":149,"_87":164,"_89":-5,"_91":57,"_92":156,"_94":26,"_34":306,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_80":307},{"_32":135,"_13":123,"_87":116,"_89":-5,"_91":57,"_92":129,"_94":26,"_34":304,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_80":305},{"_32":300,"_13":178,"_87":301,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":302,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_80":303},{"_32":107,"_13":105,"_87":90,"_89":-5,"_91":57,"_92":93,"_94":26,"_34":298,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_80":299},{"_32":293,"_13":294,"_87":295,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":296,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_80":297},{"_32":287,"_13":288,"_87":289,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":290,"_40":22,"_96":119,"_98":291,"_64":48,"_100":-5,"_80":292},{"_32":280,"_13":281,"_87":282,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":283,"_40":22,"_96":284,"_98":285,"_64":48,"_100":-5,"_80":286},{"_32":273,"_13":274,"_87":275,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":277,"_40":22,"_96":190,"_98":278,"_64":48,"_100":-5,"_80":279},"4930bc9c-3ce5-11f0-9afd-9e149126039e","webhookAPI","b65ca42b-ca53-4167-be6a-9bc636ae48c0",1,["D",1748561592095],"import { Hono } from \"npm:hono@3\";\n// import { cors } from \"npm:hono@3/cors\";\n\n// Import route modules\nimport auth from \"./routes/auth.ts\";\nimport countExamples from \"./routes/count-examples.ts\";\nimport exampleCallout from \"./routes/example-callout.ts\";\nimport exampleChildPages from \"./routes/example-child-pages.ts\";\nimport exampleDatabasePage from \"./routes/example-database-page.ts\";\nimport exampleDatabasePages from \"./routes/example-database-pages.ts\";\nimport exampleGuestWelcome from \"./routes/example-guest-welcome.ts\";\nimport propertyInjections from \"./routes/property-injections.ts\";\nimport root from \"./routes/root.ts\";\nimport testRoutes from \"./routes/test-routes.ts\";\n\n// Create main app\nconst app = new Hono();\n\n// Mount root route\napp.route(\"/\", root);\n\n// Apply authentication middleware to all routes\napp.use(\"*\", auth);\n\n// Mount route modules\napp.route(\"/example/database/pages\", exampleDatabasePages);\napp.route(\"/example/database/page\", exampleDatabasePage);\napp.route(\"/example/child_pages\", exampleChildPages);\napp.route(\"/example/callout\", exampleCallout);\napp.route(\"/example/guest/welcome\", exampleGuestWelcome);\napp.route(\"/countExamples\", countExamples);\napp.route(\"/property/injections\", propertyInjections);\n\n// Mount test routes - these include /asdf, /qwer/:id, and /test/:id\napp.route(\"/\", testRoutes);\n\n/* this should go up just after initializing hono, if enabling cors\napp.use(\n \"/*\",\n cors({\n origin: [\"https://notion.so\", \"https://notion.com\"],\n }),\n);\napp.post(\"/test/button\", async (c) => {\n // console.log(await c);\n // console.log(await c.req.json());\n console.log(await c.res);\n console.log(await c.res.headers);\n return c.json({ ok: true });\n});\n*/\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\nexport default app.fetch;",[274],"4930b9cc-3ce5-11f0-9afd-9e149126039e","resets","a0749164-f788-437a-8321-597c9e8b8356",["D",1748561592095],"interval","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // reset via the API\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API resets the blocks on notion pages, and also knows what to do with the blob\n // (note the x-blob-key header)\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.id, block.type, \" is gone!\", \"archived:\" + block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",[281],"4930b846-3ce5-11f0-9afd-9e149126039e","README.md","9748b028-36ea-481d-8a4d-d47865cfbd5f",["D",1748561592095],"# ValTownForNotion\n\nThis val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\n\nHere's one of the examples, which uses val.town to update database pages with favicons from the web:\n\n![valtown-for-notion-example.gif](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a050f132-f6da-4af8-d0b3-ae8c60783900/public)\n\nRead up on it and try the examples:\n[https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4](https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4)\n\n## Handling Notion Webhooks\n\nThis is done in the webhookAPI file.\n\n## Resetting state\n\nEvery minute, this project has a cron that resets all the state, so that the next visitor to the Notion page has a clean experience. That cron uses the subdomain as the prefix for all the blob storage.\n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a8afa60b-7ff7-4707-b07b-6011b8e2b700/public)",[288],"4930b670-3ce5-11f0-9afd-9e149126039e","utils","4c024767-c08d-4eb0-a672-152662eb8afa",["D",1748561592095],[294],["D",1748819083979],[105],"4930a4b4-3ce5-11f0-9afd-9e149126039e","15f005c9-001c-46fd-a4a9-3ea07c556393",["D",1748561592095],[178],["D",1748819249077],[123],["D",1748819111538],[149],"pulls","branches","forks","envVars",{"_315":156,"_317":156},"connections",{"_315":22,"_316":22},"count","unfilledCount","emptyCount",{"_32":195,"_13":149,"_87":164,"_89":-5,"_91":57,"_92":156,"_94":26,"_34":196,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":475,"_80":476},{"_32":181,"_13":178,"_87":172,"_89":164,"_91":57,"_92":173,"_94":26,"_34":182,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":473,"_80":474},{"_32":169,"_13":170,"_87":171,"_89":172,"_91":57,"_92":173,"_94":26,"_34":174,"_40":22,"_96":97,"_98":175,"_64":48,"_100":-5,"_101":471,"_80":472},{"_32":163,"_13":150,"_87":143,"_89":164,"_91":57,"_92":156,"_94":26,"_34":165,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":469,"_80":470},{"_32":153,"_13":154,"_87":155,"_89":143,"_91":57,"_92":156,"_94":26,"_34":157,"_40":22,"_96":97,"_98":158,"_64":48,"_100":-5,"_101":467,"_80":468},{"_32":140,"_13":141,"_87":142,"_89":143,"_91":57,"_92":144,"_94":26,"_34":145,"_40":22,"_96":97,"_98":146,"_64":48,"_100":-5,"_101":465,"_80":466},{"_32":186,"_13":187,"_87":188,"_89":164,"_91":57,"_92":56,"_94":26,"_34":189,"_40":93,"_96":190,"_98":191,"_64":48,"_100":-5,"_101":463,"_80":464},{"_32":135,"_13":123,"_87":116,"_89":-5,"_91":57,"_92":129,"_94":26,"_34":136,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":461,"_80":462},{"_32":126,"_13":127,"_87":128,"_89":116,"_91":57,"_92":129,"_94":26,"_34":130,"_40":22,"_96":119,"_98":131,"_64":48,"_100":-5,"_101":459,"_80":460},{"_32":113,"_13":114,"_87":115,"_89":116,"_91":57,"_92":117,"_94":26,"_34":118,"_40":22,"_96":119,"_98":120,"_64":48,"_100":-5,"_101":457,"_80":458},{"_32":300,"_13":178,"_87":301,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":454,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":455,"_80":456},{"_32":448,"_13":288,"_87":449,"_89":301,"_91":57,"_92":276,"_94":26,"_34":450,"_40":22,"_96":119,"_98":451,"_64":48,"_100":-5,"_101":452,"_80":453},{"_32":441,"_13":442,"_87":443,"_89":301,"_91":57,"_92":276,"_94":26,"_34":444,"_40":22,"_96":97,"_98":445,"_64":48,"_100":-5,"_101":446,"_80":447},{"_32":434,"_13":435,"_87":436,"_89":301,"_91":57,"_92":276,"_94":26,"_34":437,"_40":22,"_96":97,"_98":438,"_64":48,"_100":-5,"_101":439,"_80":440},{"_32":427,"_13":428,"_87":429,"_89":301,"_91":57,"_92":276,"_94":26,"_34":430,"_40":22,"_96":97,"_98":431,"_64":48,"_100":-5,"_101":432,"_80":433},{"_32":420,"_13":421,"_87":422,"_89":301,"_91":57,"_92":276,"_94":26,"_34":423,"_40":22,"_96":97,"_98":424,"_64":48,"_100":-5,"_101":425,"_80":426},{"_32":413,"_13":414,"_87":415,"_89":301,"_91":57,"_92":276,"_94":26,"_34":416,"_40":22,"_96":97,"_98":417,"_64":48,"_100":-5,"_101":418,"_80":419},{"_32":406,"_13":407,"_87":408,"_89":301,"_91":57,"_92":276,"_94":26,"_34":409,"_40":22,"_96":97,"_98":410,"_64":48,"_100":-5,"_101":411,"_80":412},{"_32":399,"_13":400,"_87":401,"_89":301,"_91":57,"_92":276,"_94":26,"_34":402,"_40":22,"_96":97,"_98":403,"_64":48,"_100":-5,"_101":404,"_80":405},{"_32":392,"_13":393,"_87":394,"_89":301,"_91":57,"_92":276,"_94":26,"_34":395,"_40":22,"_96":97,"_98":396,"_64":48,"_100":-5,"_101":397,"_80":398},{"_32":385,"_13":386,"_87":387,"_89":301,"_91":57,"_92":276,"_94":26,"_34":388,"_40":22,"_96":97,"_98":389,"_64":48,"_100":-5,"_101":390,"_80":391},{"_32":378,"_13":379,"_87":380,"_89":301,"_91":57,"_92":276,"_94":26,"_34":381,"_40":22,"_96":97,"_98":382,"_64":48,"_100":-5,"_101":383,"_80":384},{"_32":107,"_13":105,"_87":90,"_89":-5,"_91":57,"_92":93,"_94":26,"_34":108,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":376,"_80":377},{"_32":85,"_13":86,"_87":88,"_89":90,"_91":57,"_92":93,"_94":26,"_34":95,"_40":22,"_96":97,"_98":99,"_64":48,"_100":-5,"_101":374,"_80":375},{"_32":293,"_13":294,"_87":295,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":371,"_40":22,"_96":109,"_98":-5,"_64":48,"_100":-5,"_101":372,"_80":373},{"_32":364,"_13":365,"_87":366,"_89":295,"_91":57,"_92":276,"_94":26,"_34":367,"_40":22,"_96":97,"_98":368,"_64":48,"_100":-5,"_101":369,"_80":370},{"_32":357,"_13":358,"_87":359,"_89":295,"_91":57,"_92":276,"_94":26,"_34":360,"_40":22,"_96":97,"_98":361,"_64":48,"_100":-5,"_101":362,"_80":363},{"_32":287,"_13":288,"_87":289,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":354,"_40":22,"_96":119,"_98":291,"_64":48,"_100":-5,"_101":355,"_80":356},{"_32":280,"_13":281,"_87":282,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":351,"_40":22,"_96":284,"_98":285,"_64":48,"_100":-5,"_101":352,"_80":353},{"_32":273,"_13":274,"_87":275,"_89":-5,"_91":57,"_92":276,"_94":26,"_34":348,"_40":22,"_96":190,"_98":278,"_64":48,"_100":-5,"_101":349,"_80":350},["D",1748561592095],[],[274],["D",1748561592095],[],[281],["D",1748561592095],[],[288],"4930acf2-3ce5-11f0-9afd-9e149126039e","notionHelpers.ts","a43c2ac8-c4e7-4006-a4a3-21b4fc193bf8",["D",1748561592095],"import { Client } from \"npm:@notionhq/client\";\nimport * as helpers from \"./helpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport async function createDatabasePagesParallel(databaseId: string, pages: []) {\n const creations = pages.map((page) =>\n notion.pages.create({\n parent: { database_id: databaseId },\n properties: {\n \"Website\": {\n \"title\": [\n {\n \"text\": {\n \"content\": page.domain,\n },\n },\n ],\n },\n \"Description\": {\n \"rich_text\": [\n {\n \"text\": {\n \"content\": page.description,\n },\n },\n ],\n },\n Status: {\n \"select\": {\n \"name\": page.status,\n },\n },\n },\n })\n );\n const results = await Promise.allSettled(creations);\n return results;\n}\n\n// delete all database rows\nexport async function deleteAllDatabasePagesParallel(databaseId: string) {\n const pageIds = await notion.databases.query({\n database_id: databaseId,\n });\n // Step 2: Delete all pages in parallel\n const deletions = pageIds.results.map((page) =>\n notion.pages.update({\n page_id: page.id,\n archived: true,\n })\n );\n // Wait for all deletions to complete (even if some fail)\n const results = await Promise.allSettled(deletions);\n return results;\n}\n\nexport async function getDatabaseId(databaseTitle: string) {\n // getDatabaseId(databaseTitle)\n const database = await notion.databases\n .query({ filter: { property: \"title\", title: { equals: databaseTitle } } });\n return database.results[0].id;\n}\n\nexport async function getDatabaseTitle(databaseId: string) {\n // getDatabaseTitle(databaseId)\n const database = await notion.databases.retrieve({ database_id: databaseId });\n // console.log(database.title[0].plain_text);\n return database.title[0].plain_text;\n}\n\nexport async function getDatabaseParentPageId(databaseId: string) {\n let currentBlockId = databaseId;\n\n while (true) {\n const block = await notion.blocks.retrieve({ block_id: currentBlockId });\n\n if (!block.parent) {\n throw new Error(`No parent found for block ${currentBlockId}`);\n }\n\n const parent = block.parent;\n\n if (parent.type === \"page_id\") {\n return parent.page_id;\n }\n\n if (parent.type === \"block_id\") {\n // Climb to the next parent block\n currentBlockId = parent.block_id;\n } else {\n throw new Error(`Unsupported parent type: ${parent.type}`);\n }\n }\n}\n\nexport async function getCalloutProperties(askingFor: string) {\n const blockProperties = (askingFor != \"val.town\")\n ? {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://www.notion.so/icons/notion_blue.svg\",\n },\n },\n \"color\": \"default_background\",\n }\n : {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://static.esm.town/build/_assets/vt-whiteOnBlack-VOLODW64.svg\",\n },\n },\n \"color\": \"yellow_background\",\n };\n return blockProperties;\n}\n\nexport async function findChildDatabaseBlocks(rootBlockId: string, blockIdentifier: string) {\n const matchingBlocks = [];\n\n async function searchBlock(blockId) {\n const res = await notion.blocks.children.list({ block_id: blockId });\n\n for (const block of res.results) {\n // if (\n // block.type === \"callout\" && block.callout?.rich_text?.[0]?.plain_text && (!block.archived || !block.in_trash)\n // ) {\n // const calloutText = await helpers.slugify(block.callout?.rich_text?.[0]?.plain_text.toLowerCase()) || \"\";\n // const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n // if (calloutText === identifier) {\n // console.log(calloutText, identifier);\n // matchingBlocks.push(block);\n // }\n // }\n if (\n block.type === \"child_database\" && block.child_database?.title && (!block.archived || !block.in_trash)\n ) {\n const databaseTitle = await helpers.slugify(block.child_database?.title.toLowerCase()) || \"\";\n const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n if (databaseTitle === identifier) {\n console.log(databaseTitle, identifier);\n matchingBlocks.push(block);\n }\n // console.log(block);\n // matchingBlocks.push(block);\n }\n\n // If the block has children, recurse\n if (block.has_children && matchingBlocks.length === 0) {\n await searchBlock(block.id);\n }\n }\n }\n\n await searchBlock(rootBlockId);\n\n return matchingBlocks;\n}\n\nexport async function findCalloutBlocks(rootBlockId: string, blockIdentifier: string) {\n const matchingBlocks = [];\n\n async function searchBlock(blockId) {\n const res = await notion.blocks.children.list({ block_id: blockId });\n\n for (const block of res.results) {\n // get callouts that are flagged with the val.town icon in this workspace\n // archived: false,\n // in_trash: false,\n if (\n block.type === \"callout\" && block.callout?.rich_text?.[0]?.plain_text && (!block.archived || !block.in_trash)\n ) {\n const calloutText = await helpers.slugify(block.callout?.rich_text?.[0]?.plain_text.toLowerCase()) || \"\";\n const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n if (calloutText === identifier) {\n console.log(calloutText, identifier);\n matchingBlocks.push(block);\n }\n }\n\n // If the block has children, recurse\n // limit return to one item\n if (block.has_children && matchingBlocks.length === 0) {\n await searchBlock(block.id);\n }\n }\n }\n\n await searchBlock(rootBlockId);\n\n return matchingBlocks;\n}\n\nexport async function getBostonTime() {\n const now = new Date();\n\n const formattedDate = now.toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n hour: \"numeric\",\n minute: \"numeric\",\n second: \"numeric\",\n });\n\n return `val.town says, \"It's ${formattedDate} in Boston.\"`;\n}\n\nexport async function listChildrenChildPages(blockId: string) {\n try {\n const response = await notion.blocks.children.list({\n block_id: blockId,\n });\n\n if (!response) {\n throw new Error(\"Failed to retrieve pages from Notion\");\n }\n const pages = response.results.filter((page) => page.type === \"child_page\");\n return pages;\n } catch (error) {\n console.error(`Error getting Notion pages that are children of ${blockId}:`, error);\n }\n}\n\nexport async function addFavicon(data?: any) {\n const pageId = data?.id;\n // use notion if nothing if the URL property is empty\n const url = await getWebhookPropertyValue(data, \"Website\") || \"notion.com\";\n // send the URL value to the function that will get the site's favicon location\n const faviconURL = await helpers.scrapeFaviconUrl(url);\n console.log({ \"Verified favicon URL\": faviconURL });\n // update the page icon\n await updatePageIcon(pageId, faviconURL);\n\n return pageId;\n}\n\nexport async function setPageStatus(object: any) {\n const { data, section, step } = object;\n const pageId = data?.id;\n // statuses are passed to val.town from Notion in the payload\n const statuses = await getWebhookPropertyValue(data, \"Statuses\");\n // loop through statuses to find items that have the section in their value\n const sectionStatuses = await statuses.split(\",\").filter(status => status.toLowerCase().includes(section));\n // console.log(sectionStatuses);\n const status = (() => {\n switch (step) {\n case \"first\":\n return sectionStatuses[0];\n case \"last\":\n return sectionStatuses[sectionStatuses.length - 1];\n default:\n return sectionStatuses[0];\n }\n })();\n console.log(status);\n\n try {\n const response = await notion.pages.update({\n page_id: pageId,\n properties: {\n Status: {\n select: {\n name: status,\n },\n },\n },\n });\n if (!response) {\n throw new Error(\"Failed to update page in Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error updating Notion page ${pageId}:`, error);\n }\n}\n\nexport async function updatePageIcon(pageId: string, faviconURL?: string) {\n try {\n const response = await notion.pages.update({\n page_id: pageId,\n icon: {\n type: \"external\",\n external: {\n url: faviconURL,\n },\n },\n });\n if (!response) {\n throw new Error(\"Failed to update page in Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error updating Notion page ${pageId}:`, error);\n }\n}\n\nexport async function listChildren(pageId: string) {\n // get page properties\n try {\n const response = await notion.blocks.children.list({\n block_id: pageId,\n });\n\n if (!response) {\n throw new Error(\"Failed to retrieve pages from Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error getting Notion pages that are children of ${pageId}:`, error);\n }\n}\n\n// Helper function to get property value from webhook payload\nexport async function getWebhookPropertyValue(payload: any, propertyName: any) {\n let result = null;\n // check to see if the whole payload was sent, or just the data object\n const properties = payload.data?.properties || payload.properties;\n\n if (properties) {\n const property = properties[propertyName];\n\n if (property) {\n // Different property types have different value structures\n switch (property.type) {\n case \"select\":\n result = property.select?.name;\n break;\n case \"formula\":\n result = property.formula?.string;\n break;\n case \"rich_text\":\n result = property.rich_text?.[0]?.plain_text;\n break;\n case \"title\":\n result = property.title?.[0]?.plain_text;\n break;\n case \"url\":\n result = property.url;\n break;\n case \"text\":\n result = property.text?.content;\n break;\n default:\n result = property.value;\n }\n }\n }\n\n return result;\n}\n\nexport async function getNotionPage(pageId: string) {\n // get page properties\n try {\n const response = await notion.pages.retrieve({\n page_id: pageId,\n });\n if (!response) {\n throw new Error(\"Failed to retrieve page from Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error getting Notion page ${pageId}:`, error);\n }\n}",[],[294,358],"4930a6ee-3ce5-11f0-9afd-9e149126039e","helpers.ts","c1beb930-25f6-47ec-8d0d-00ab0a632827",["D",1748561592095],"export async function setBlobKey(object: any) {\n const { slug, clientPageId, containerId } = object;\n const blobKey = [ // key_legend: \"[subdomain]--[id of guest page]--[id of container to be reset]\",\n slug.split(\".\")[0], // subdomain name minus .val.run\n clientPageId.replaceAll(\"-\", \"\"), // remove hyphens from ids\n containerId,\n ].join(\"--\");\n\n // console.log(blobKey);\n return blobKey;\n}\n\nexport async function slugify(str: string) {\n // const containerTitleSlug = (await helpers.setContainerTitle(c.req.headers.get(\"x-container-title\"))).split(\" \").join(\"-\");\n return (str.replace(/[^\\w\\s]|_/g, \"\").replace(/\\s+/g, \" \").trim().toLowerCase()).split(\" \").join(\"-\");\n}\n\n// Function to scrape favicon URL from a website\nexport async function scrapeFaviconUrl(url: string) {\n try {\n // Ensure URL has protocol\n if (!url.startsWith(\"http://\") && !url.startsWith(\"https://\")) {\n url = \"https://\" + url;\n }\n\n // Parse the URL to get the origin\n const parsedUrl = new URL(url);\n const origin = parsedUrl.origin;\n\n // Fetch the HTML from the URL\n const response = await fetch(url);\n const html = await response.text();\n\n // Find favicon links in the HTML\n // Using regex patterns to find icon link tags\n let faviconUrl = null;\n\n // Look for link tags with rel=\"icon\" or similar\n const iconRegex = /]*rel=[\"'](?:icon|shortcut icon|apple-touch-icon)[^>]*href=[\"']([^\"']+)[\"'][^>]*>/gi;\n const matches = html.matchAll(iconRegex);\n\n for (const match of matches) {\n if (match && match[1]) {\n faviconUrl = match[1];\n break;\n }\n }\n\n // If we didn't find an icon in link tags, try the default location\n if (!faviconUrl) {\n faviconUrl = \"/favicon.ico\";\n }\n\n // Make sure the URL is absolute\n if (!faviconUrl.startsWith(\"http://\") && !faviconUrl.startsWith(\"https://\")) {\n if (faviconUrl.startsWith(\"/\")) {\n faviconUrl = origin + faviconUrl;\n } else {\n faviconUrl = origin + \"/\" + faviconUrl;\n }\n }\n\n // Verify the favicon exists\n const faviconResponse = await fetch(faviconUrl, { method: \"HEAD\" });\n\n if (!faviconResponse.ok) {\n return null; // Favicon not found\n }\n\n return faviconUrl;\n } catch (error) {\n console.error(\"Error scraping favicon:\", error);\n return null;\n }\n}\n\nexport async function extractCamelCaseWords(str: string) {\n if (!str) return [];\n\n // This regex looks for word boundaries:\n // - Start of string\n // - Transitions from lowercase to uppercase\n const words = str.split(/(?=[A-Z])/).map(word => word.toLowerCase());\n const watchWords = [\"favicon\", \"team\", \"invoice\", \"estimate\"];\n\n // Remove words that are not in the watchWords array\n words.forEach((word, index) => {\n if (!watchWords.includes(word)) {\n words.splice(index, 1);\n }\n });\n return words;\n}",[],[294,365],["D",1748561592095],[343,344],[294],[],[105,86],[341],[105],"4930a32e-3ce5-11f0-9afd-9e149126039e","test-routes.ts","aa165d25-8e98-4bf1-a73d-e0bd66e734fd",["D",1748561592095],"import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.post(\"/asdf\", async (c) => {\n const requestData = await c.req.json();\n console.log(requestData);\n return c.json({ ok: true });\n});\n\napp.post(\"/qwer/:id\", async (c) => {\n const action = c.req.param(\"id\");\n console.log({ action });\n return c.json({ action });\n});\n\napp.post(\"/test/:id\", async (c) => {\n const requestData = await c.req.json();\n const id = c.req.param(\"id\");\n\n // Make internal requests to other routes\n await app.request(\"/asdf\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestData),\n });\n\n await app.request(\"/qwer/\" + id, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestData),\n });\n \n return c.json({ ok: true, id });\n});\n\nexport default app;",[],[178,379],"4930a194-3ce5-11f0-9afd-9e149126039e","root.ts","cabbe967-e909-46fd-95f9-953b9517523e",["D",1748561592095],"import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n url: notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",[],[178,386],"4930a018-3ce5-11f0-9afd-9e149126039e","property-injections.ts","c7e109c1-49ee-40b8-b8cc-d840fa43ab0f",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n // THIS MAY BE DEPRECATED IN V3\n\n // Extract data from request\n const slug = await c.req.url.replace(\"https://\", \"\");\n const copyLink = c.req.headers.get(\"x-copy-link\") || \"\"; // the URL of the block to update on the page\n const payload = await c.req.json();\n const pageId = payload?.data?.id;\n\n // extract the id of the block from the x-copy-link header\n const blockId = copyLink?.split(\"#\").pop();\n // console.log(\"blockId: \", blockId);\n\n // update Notion page block with JSON formatted as javascript\n const block = await notion.blocks.update({\n block_id: blockId,\n code: {\n rich_text: [\n {\n text: {\n content: JSON.stringify(payload?.data?.properties, null, 2),\n },\n },\n ],\n language: \"javascript\",\n },\n });\n console.log(block);\n\n return c.json({ ok: true });\n});\n\nexport default app;",[],[178,393],"49309d52-3ce5-11f0-9afd-9e149126039e","example-guest-welcome.ts","553a60a7-1028-49c0-a77b-6401a7fa407e",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n try {\n // Extract data from request\n const payload = await c.req.json();\n const pageId = await payload.data?.id;\n const guest = payload?.data?.properties?.Guest || \"\";\n\n // to package this project we may need to call Notion to get the full page object\n // rather than rely on what's sent by the webhook and arrives in the payload\n // for now, we can assume that the webhook will sent what this endpoint needs\n // const page = await notion.pages.retrieve({ page_id: pageId });\n // console.log(page);\n // console.log(guest);\n\n // find the \"welcome\" callout in the page\n // it's the callout with the \"wave\" emoji in the icon property\n const children = await notion.blocks.children.list({\n block_id: pageId,\n });\n const welcomeCallout = await children.results.filter((child) => {\n return (child.type === \"callout\" && child.callout?.icon?.type == \"emoji\")\n && (child.callout?.icon?.emoji.includes(\"👋\"));\n });\n // console.log(welcomeCallout);\n // update the block with the id of welcomeCallout[0].id\n await notion.blocks.update({\n block_id: welcomeCallout[0].id,\n \"callout\": {\n \"rich_text\": [\n {\n \"type\": \"text\",\n \"text\": {\n \"content\": \"Hi, \" + guest.people[0]?.person?.email + \"!\",\n },\n annotations: {\n bold: true,\n italic: false,\n strikethrough: false,\n underline: true,\n code: false,\n color: \"default\",\n },\n },\n ],\n },\n });\n\n return c.json({\n ok: true,\n });\n } catch (error) {\n console.error(\"Error in guest welcome endpoint:\", error);\n return c.json({\n ok: false,\n error: \"Failed to process welcome request\",\n details: error.message,\n }, 500);\n }\n});\n\nexport default app;",[],[178,400],"49309870-3ce5-11f0-9afd-9e149126039e","example-database-pages.ts","b7bff902-b27e-4837-a1fe-b21ae102e527",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n // webhook\n const slug = await c.req.url.replace(\"https://\", \"\");\n const askingFor = c.req.headers.get(\"x-asking-for\") || \"default\"; // val.town or default\n const containerTitle = c.req.headers.get(\"x-container-title\") || \"good web sites\"; // should map to the database title\n const payload = await c.req.json();\n const pageId = payload?.data?.id;\n\n const defaults = [\n { \"domain\": \"val.town\", \"description\": \"val.town is awesome.\", \"status\": \"No favicon\" },\n { \"domain\": \"notion.com\", \"description\": \"Notion is awesome.\", \"status\": \"No favicon\" },\n { \"domain\": \"hono.dev\", \"description\": \"Hono is awesome.\", \"status\": \"No favicon\" },\n ].reverse();\n\n // this endpoint handles two types of resets:\n // 1) cron reets\n // 2) button resets\n\n // reset crons send x-blob-key as a custom header\n // if we have that header, use it to find the blob\n // (note that notion button calls will _not_ have the x-blob-key custom header)\n\n // otherwise, if this is a call from a notion reset button, we should have the block id to modify cached\n // we just need to build the key to find the blob with that block id\n\n // when the reset button is clicked, it sends the x-container-title header\n // we use this header to a) find a blob or b) if no blob, find a database with a title that matches it\n // a) find a blob\n // b) find a database with a title that matches it\n\n // blob\n const blobKey = (c.req.headers.get(\"x-blob-key\")) // this header is only sent by reset cron\n ? c.req.headers.get(\"x-blob-key\") // if this is a reset cron, use the blob key sent by the reset cron\n : await helpers.setBlobKey({ // otherwise, build a blob key from the custom headers sent by the button\n \"slug\": slug,\n \"clientPageId\": pageId,\n \"containerId\": await helpers.slugify(c.req.headers.get(\"x-container-title\")),\n });\n console.log(\"blobKey:\", blobKey);\n\n // use the key we just built to find a blob, if there is one\n // we'll use the block id in this blob as the callout to modify\n const blobject = await blob.getJSON(blobKey) || null; // get the blob if there is one\n console.log(\"blobject:\", blobject);\n\n // if the blob exists that maps to this callout for this user, use the id property inside it\n // otherwise call the function to find the id of the callout for this user\n // const blockId = blobject // if therre's a blob, then this isn't the first call\n // ? blobject.id // use the id in the blob to speed up subsequent calls\n // : (await notionHelpers.findCalloutBlocks(pageId, containerTitle))[0].id; // otherwise, find the callout id in the page\n // console.log(\"blockId:\", blockId);\n\n const databaseId = blobject?.id || (await notionHelpers.findChildDatabaseBlocks(pageId, containerTitle))[0].id;\n // console.log(\"databaseId:\", databaseId);\n\n // actions\n await notionHelpers.deleteAllDatabasePagesParallel(databaseId);\n // add back pages; fresh start for the next person to add favicons\n // create new database pages from default object\n await notionHelpers.createDatabasePagesParallel(databaseId, defaults);\n // store webhook data in blob storage for resets\n await blob.setJSON(blobKey, {\n path: c.req.path,\n user: {\n page_id: pageId,\n },\n id: databaseId,\n date: new Date(),\n content: askingFor,\n });\n\n return c.json({ ok: true });\n});\n\nexport default app;",[],[178,407],"49308b14-3ce5-11f0-9afd-9e149126039e","example-database-page.ts","8d6fa446-459b-4644-b45a-702768a992d5",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\nconst app = new Hono();\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\napp.post(\"/\", async (c) => {\n // webhook\n const slug = await c.req.url.replace(\"https://\", \"\");\n const askingFor = await c.req.headers.get(\"x-asking-for\") || \"default\"; // val.town or default\n // payload\n const payload = await c.req.json();\n const data = payload?.data;\n const pageId = data?.id;\n const databaseId = data?.parent?.database_id;\n\n // this endpoint is for a specific database page and is triggered by a button in that database page\n\n // the button that calls this endpoint sends a payload with the id of the database page, and the id of the parent database\n // (e.g., pageId and databaseId from the payload)\n\n // different than other endpoints, this one does not get called by a reset button or the cron reset\n // instead, the reset button and the reset cron target the database, not the page\n // so, we don't have a reset call coming in with the x-blob-key custom header to this enpoint\n // nor do we have a x-container-title header that holds the title of the target object coming from the button payload\n\n // both the reset button and the reset cron delete all database pages, and then add back fresh pages\n // the endpoint for that is /example-database-pages (note the \"s\" at the end)\n\n // different than other endpoints, we get the id of the block to modify (ie, the database page) from the button payload\n // so, we don't need to do the things we do at other endpoints to get the id of target block\n // (e.g., search the blob cache, or traverse notion page objects)\n\n // but, we do need to set the blob for the resets\n // and for that we'll need the id of the page in which this database lives\n // and an identifier for the database\n\n // can that idenfifier be the databaseId rather than the database title?\n // the reset button sends the database title to the .../pages endpoint in order to find the id of the database\n // but the matching there will traverse the notion page database objects looking for a title match\n // which has nothing to do with the database title in the blob\n\n // note: if you're wondering why none of the notion buttons have hard-coded ids for the targeting\n // we can't hard-code ids into the buttons because the guest or I will have to update the custom headers\n // for every button that gets cloned for every user\n // as is, i can clone a page with examples for a guest and everything will work without anyone needing to edit button settings\n\n // when a user adds a favicon to a database page, we need to capture in the blob cache that a page in this database has been updated\n // so that resets know which database to reset\n // but the payload of the favicon button in this page does _not_ send the id of the page in which the database lives\n // nor does it send the database title\n // so we'll need to get those to make the blob key\n\n // unless there's already a blob key that matches\n // to see if there's a match, loop through blobs rather than traversing the notion page\n // though not ideal, it's faster than doing the API calls necessary to traverse the Notion page\n const checkForBlob = async () => {\n const items = await blob.list(slug.split(\".\")[0]);\n // console.log(stub, hits, hits.length);\n for (const item of items) {\n const blobData = await blob.getJSON(item.key);\n if (blobData?.id === databaseId) {\n // console.log(item.key, blobData);\n blobData.key = item.key;\n return blobData;\n }\n }\n return null;\n };\n const blobject = await checkForBlob();\n console.log(\"blobject:\", blobject);\n\n // actions\n const favicons = await notionHelpers.addFavicon(data);\n\n // blob for cache\n // get the parent page id of this child_database\n // this is the user's page and we need it for the blob key\n const parentPageId = blobject?.user\n ? blobject?.user?.page_id\n : await notionHelpers.getDatabaseParentPageId(databaseId);\n\n // we also need the database title\n // even though we have the database id and it's tempting to use it here\n // we need the title in the blob key so that the reset button can work\n // b/c the reset button can only send the title in the x-container-title header\n // with no other way to tie the button to the database\n\n // const databaseTitle = blobject?.key\n // ? (blobject?.key).split(\"--\").pop()\n // : await notionHelpers.getDatabaseTitle(databaseId);\n const databaseTitle = await notionHelpers.getDatabaseTitle(databaseId);\n\n console.log(\"databaseTitle:\", databaseTitle);\n\n // store webhook data in blob storage for resets\n const blobKey = await helpers.setBlobKey({\n \"slug\": slug,\n \"clientPageId\": parentPageId,\n // \"containerId\": databaseId, // slugify databaseTitle here?\n \"containerId\": await helpers.slugify(databaseTitle),\n });\n await blob.setJSON(blobKey, {\n path: c.req.path + \"s\", // need the \"s\" for cron resets; we do not need to call the endpoint for individual pages b/c the reset blows all db pages away\n user: {\n page_id: parentPageId,\n },\n id: databaseId,\n date: new Date(),\n content: askingFor,\n });\n console.log(\"blob just saved:\", await blob.getJSON(blobKey));\n\n // await notionHelpers.setPageStatus({ data: data, section: \"setup\", step: \"last\" });\n\n return c.json({ ok: true });\n});\n\nexport default app;",[],[178,414],"493084a2-3ce5-11f0-9afd-9e149126039e","example-child-pages.ts","cf4c6e88-6ebc-43e3-b9b2-3c179e5a6987",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n // webhook\n const slug = await c.req.url.replace(\"https://\", \"\");\n const askingFor = c.req.headers.get(\"x-asking-for\") || \"default\"; // val.town or default\n const containerTitle = c.req.headers.get(\"x-container-title\") || \"child pages\"; // title of callout in page, and value of x-callout-title header\n const payload = await c.req.json();\n const pageId = payload?.data?.id;\n\n const emojis = [\"👍\", \"🚀\", \"😀\", \"❤️\"];\n // blob\n // for the first call from a button in a notion callout:\n // we expect the x-container-title custom header sent by that button to match the text of a callout heading in the page\n // so we need to match the value of that custom header to the value of that heading\n // when they match, we create a blob key with the slug, the page id, and the slugified value of the container title\n // we do this only if this is the first call to modify this callout\n\n // we will know that a call is the first call if there is no blob\n // (ie, this call is not cached, and the id of the callout to change is not saved anywhere yet)\n\n // reset crons send x-blob-key as a custom header, so if we have that, use it to find the blob\n // (note that notion button calls will not have the x-blob-key custom header)\n // otherwise, if this is a subsequent call from a notion button, we should have the block id to modify cached\n // we just need to build the key to find the blob with that block id\n\n const blobKey = (c.req.headers.get(\"x-blob-key\")) // this header is only sent by reset cron\n ? c.req.headers.get(\"x-blob-key\") // if this is a reset cron, use the blob key sent by the reset cron\n : await helpers.setBlobKey({ // otherwise, build a blob key from the custom headers sent by the button\n \"slug\": slug,\n \"clientPageId\": pageId,\n \"containerId\": await helpers.slugify(c.req.headers.get(\"x-container-title\")),\n });\n console.log(\"blobKey:\", blobKey);\n\n // use the key we just built to find a blob, if there is one\n // we'll use the block id in this blob as the callout to modify\n const blobject = await blob.getJSON(blobKey) || null; // get the blob if there is one\n console.log(\"blobject:\", blobject);\n\n // after the first call, we should always use the block id from the blob (i.e., the cache)\n // to target the callout (b/c we don't need to find the id of the block in the page anymore)\n // however, if we don't have the block id in a corresponding blob, we'll need to find it in the notion page\n // by traversing the notion page callouts for a heading that matches the x-container-title custom header\n const blockId = blobject // if therre's a blob, then this isn't the first call\n ? blobject.id // use the id in the blob to speed up subsequent calls\n : (await notionHelpers.findCalloutBlocks(pageId, containerTitle))[0].id; // otherwise, find the callout id in the page\n console.log(\"blockId:\", blockId);\n\n const children = await notionHelpers.listChildrenChildPages(blockId) || [];\n\n // update the page icon for each page in children\n for (const [key, child] of children.entries()) {\n // default icon is notion's page icon, which comes when icon is null\n const icon = (askingFor != \"val.town\") ? null : {\n type: \"emoji\",\n emoji: emojis[key],\n };\n // update the page icon\n const page = await notion.pages.update({\n page_id: child.id,\n icon: icon,\n });\n }\n\n // update the callout icon and background\n await notion.blocks.update({\n \"block_id\": blockId,\n \"callout\": await notionHelpers.getCalloutProperties(askingFor),\n });\n\n // store webhook data for resets\n await blob.setJSON(blobKey, {\n path: c.req.path,\n user: {\n page_id: pageId,\n },\n container_title: containerTitle,\n id: blockId,\n date: new Date(),\n content: askingFor,\n });\n\n // wrap it up\n return c.json({ ok: true });\n});\n\nexport default app;",[],[178,421],"49307cf0-3ce5-11f0-9afd-9e149126039e","example-callout.ts","0023d6b5-ef08-4c47-a5ec-04148dc24b9f",["D",1748561592095],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\nimport * as helpers from \"../utils/helpers.ts\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n // webhook data\n const slug = await c.req.url.replace(\"https://\", \"\"); // this will prepend blob key, which we use for cache\n const askingFor = c.req.headers.get(\"x-asking-for\") || \"default\"; // val.town or default\n const containerTitle = c.req.headers.get(\"x-container-title\") || \"testing\"; // title of callout in page\n const payload = await c.req.json();\n const pageId = payload?.data?.id; // this will also be in the blob key\n\n // for the first call from a button in a notion callout:\n // we expect the x-container-title custom header sent by that button to match the text of a callout heading in the page\n // so we need to match the value of that custom header to the value of that heading\n // when they match, we create a blob key with the slug, the page id, and the slugified value of the container title\n // we do this only if this is the first call to modify this callout\n\n // we will know that a call is the first call if there is no blob\n // (ie, this call is not cached, and the id of the callout to change is not saved anywhere yet)\n\n // reset crons send x-blob-key as a custom header, so if we have that, use it to find the blob\n // (note that notion button calls will not have the x-blob-key custom header)\n // otherwise, if this is a subsequent call from a notion button, we should have the block id to modify cached\n // we just need to build the key to find the blob with that block id\n\n const blobKey = (c.req.headers.get(\"x-blob-key\")) // this header is only sent by reset cron\n ? c.req.headers.get(\"x-blob-key\") // if this is a reset cron, use the blob key sent by the reset cron\n : await helpers.setBlobKey({ // otherwise, build a blob key from the custom headers sent by the button\n \"slug\": slug,\n \"clientPageId\": pageId,\n \"containerId\": await helpers.slugify(c.req.headers.get(\"x-container-title\")),\n });\n console.log(\"blobKey:\", blobKey);\n\n // use the key we just built to find a blob, if there is one\n // we'll use the block id in this blob as the callout to modify\n const blobject = await blob.getJSON(blobKey) || null; // get the blob if there is one\n console.log(\"blobject:\", blobject);\n\n // after the first call, we should always use the block id from the blob (i.e., the cache) to target the callout\n // (we don't need to find the id of the block in the page if the block id is in the blob)\n // however, if we don't have the block id in a corresponding blob, we'll need to find it in the notion page\n // by traversing the notion page callouts for a heading that matches the x-container-title custom header\n const blockId = blobject // if therre's a blob, then this isn't the first call\n ? blobject.id // use the id in the blob to speed up subsequent calls\n : (await notionHelpers.findCalloutBlocks(pageId, containerTitle))[0].id; // otherwise, find the callout id in the page\n console.log(\"blockId:\", blockId);\n\n // this may mean that we do away with reset buttons, and to leave resets to the cron\n // to keep reset buttons, we would need to instruct people to paste the callout heading in the x-container-title field\n // for both the main button AND the reset button, which could lead to usability issues\n // alternatively, we can just message that the reset cron will clean up the page later\n // it may be the case that reset buttons aren't that important in a per user sandbox world, anyway\n\n const blockProperties = (askingFor != \"val.town\")\n ? {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://www.notion.so/icons/notion_blue.svg\",\n },\n },\n \"color\": \"default_background\",\n rich_text: [\n {\n type: \"text\",\n text: {\n content: \"Notion says, \\\"I wish I could tell the reader what time it is in Boston.\\\"\",\n },\n },\n ],\n }\n : {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://static.esm.town/build/_assets/vt-whiteOnBlack-VOLODW64.svg\",\n },\n },\n \"color\": \"yellow_background\",\n rich_text: [\n {\n type: \"text\",\n text: {\n content: await notionHelpers.getBostonTime(),\n },\n },\n ],\n };\n const page = await notion.blocks.update({\n \"block_id\": blockId,\n \"callout\": await blockProperties,\n });\n // console.log(await page);\n\n // store webhook data for resets\n await blob.setJSON(blobKey, {\n path: c.req.path,\n user: {\n page_id: pageId,\n },\n id: blockId,\n container_title: containerTitle,\n date: new Date(),\n content: askingFor,\n });\n // console.log(await blob.getJSON(blobKey));\n\n // wrap it up\n return c.json({ ok: true });\n});\n\nexport default app;",[],[178,428],"49307b56-3ce5-11f0-9afd-9e149126039e","count-examples.ts","3792f072-a4bb-434f-86b9-af69f37fc9f0",["D",1748561592095],"import { Hono } from \"npm:hono@3\";\nimport * as notionHelpers from \"../utils/notionHelpers.ts\";\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n const payload = await c.req.json();\n let data = await payload?.data;\n const pageId = await data?.id;\n const logs = [];\n\n const exampleFlag = \"https://www.notion.so/icons/cursor-click_blue.svg\";\n const children = await notionHelpers.listChildren(pageId);\n const callouts = await children?.results.filter((child) => child?.callout?.icon?.external?.url === exampleFlag) || [];\n logs.push(callouts.length, { callouts });\n logs.push(callouts[0].callout.icon.external);\n\n console.log(logs);\n return c.json(logs);\n});\n\nexport default app;",[],[178,435],"49307854-3ce5-11f0-9afd-9e149126039e","auth.ts","bfb0fc04-3733-457a-bc71-7cc56966ed80",["D",1748561592095],"export default async (c, next) => {\n const secret = c.req.header(\"x-api-key\");\n if (secret !== Deno.env.get(\"X_API_KEY\")) {\n return c.text(\"Unauthorized\", 401);\n }\n await next();\n};",[],[178,442],"49307084-3ce5-11f0-9afd-9e149126039e","df2a36ab-b249-48c0-bfeb-c6610addd022",["D",1748561592095],"# Routes Directory\n\nThis directory contains all the route handlers for the webhookAPI application. Each file exports a Hono app that handles a specific route or group of related routes.\n\n## Structure\n\n- `auth.ts` - Authentication middleware\n- `example-database-pages.ts` - Handles `/example/database/pages` endpoint\n- `example-database-page.ts` - Handles `/example/database/page` endpoint\n- `example-child-pages.ts` - Handles `/example/child_pages` endpoint\n- `example-callout.ts` - Handles `/example/callout` endpoint\n- `example-guest-welcome.ts` - Handles `/example/guest/welcome` endpoint\n- `count-examples.ts` - Handles `/countExamples` endpoint\n- `property-injections.ts` - Handles `/property/injections` endpoint\n- `test-routes.ts` - Handles `/asdf`, `/qwer/:id`, and `/test/:id` endpoints\n- `root.ts` - Handles the root `/` endpoint",[],[178,288],["D",1748561592095],[329,330,331,332,333,334,335,336,337,338,339],[178],[],[123,114],[],[123,127],[326,327],[123],[],[149,187],[],[149,150,141],[],[149,150,154],[322,323],[149,150],[],[149,178,170],[320],[149,178],[319,321,324],[149],["D",1748561592095],{"_11":12,"_235":231},{"_11":12,"_229":-5,"_230":231,"_203":204,"_232":233,"_234":48},{"_40":56,"_13":16,"_32":57,"_38":58,"_42":33,"_43":41,"_59":50,"_60":39,"_61":54,"_55":14,"_51":12},"ctx",{"_224":-5,"_256":514,"_515":516,"_517":518,"_519":48,"_520":48,"_521":48,"_522":26,"_523":-5,"_524":-7,"_525":-7,"_526":22,"_527":48,"_528":48,"_529":-5,"_530":48,"_531":48,"_532":48,"_533":-5},"ENV",{"_485":486,"_487":488,"_489":16,"_490":491,"_492":493,"_494":495,"_496":497,"_498":499,"_500":501,"_502":503,"_504":505,"_506":507,"_508":509,"_510":511,"_512":513},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Compare

Mergecanstralian/mainintobradnoble/main

backend

Hbackend/index.ts+89-0

backend/routes

backend/routes/review.ts+166-0

backend/services

backend/services/ai-engine.ts+189-0

backend/services/code-parser.ts+184-0

frontend

frontend/index.html+321-0

frontend/style.css+110-0

shared

shared/codesentinel-types.ts+110-0