Loki

\n \n

${listings.length} New Listing${listings.length > 1 ? \"s\" : \"\"}

For ${groupName}

\n \n \n \n \n \n \n \n \n \n \n ${listingRows}\n \n

Address	Price	Details

\n \n

\n \n View All Listings\n \n

\n \n

\n You're receiving this because you're a member of ${groupName} on Loki.\n Manage notification preferences\n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Generate comment request email\n */\nfunction generateCommentRequest(\n groupName: string,\n listing: Listing,\n requestingUser: string,\n baseUrl: string\n): EmailTemplate {\n return {\n subject: `[Loki] ${requestingUser} wants your feedback on a listing`,\n text: `\n${requestingUser} from ${groupName} is requesting your feedback on:\n\n${listing.address_original}\n${listing.price ? `Price: $${listing.price}` : \"\"}\n${listing.beds ? `Beds: ${listing.beds}` : \"\"} / ${listing.baths ? `Baths: ${listing.baths}` : \"\"}\n\nView listing: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n\n\n

Loki

\n \n

Feedback Requested

\n ${requestingUser} from ${groupName} wants your feedback on this listing:\n

\n \n

${listing.address_original}

\n ${listing.price ? `$${listing.price.toLocaleString()}/mo • ` : \"\"}\n ${listing.beds ?? \"?\"} bed • ${listing.baths ?? \"?\"} bath\n

\n \n \n View & Comment\n \n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Generate apply reminder email\n */\nfunction generateApplyReminder(\n groupName: string,\n listing: Listing,\n message: string | null,\n baseUrl: string\n): EmailTemplate {\n return {\n subject: `[Loki] Reminder: Apply for listing at ${listing.address_original}`,\n text: `\nDon't forget to apply!\n\n${listing.address_original}\n${listing.price ? `Price: $${listing.price}` : \"\"}\n${message ? `\\nNote: ${message}` : \"\"}\n\nView listing: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n\n\n

Reminder

\n \n

Time to Apply!

\n You set a reminder to apply for this listing:\n

\n \n

${listing.address_original}

\n ${listing.price ? `$${listing.price.toLocaleString()}/mo` : \"\"}\n

\n ${message ? `

\"${message}\"

` : \"\"}\n

\n \n \n View Listing\n \n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Send new listings notification to a group\n */\nexport async function sendNewListingsNotification(\n groupId: string,\n listings: Listing[],\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n if (listings.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const group = await getGroup(groupId);\n if (!group) {\n console.error(\"Group not found:\", groupId);\n return { sent: 0, errors: 1 };\n }\n\n const recipients = await getNotificationRecipients(groupId, \"notify_new_listing\");\n if (recipients.length === 0) {\n console.log(\"No recipients for new listings notification\");\n return { sent: 0, errors: 0 };\n }\n\n const template = generateNewListingsDigest(group.name, listings, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n/**\n * Send comment request notification\n */\nexport async function sendCommentRequestNotification(\n groupId: string,\n listing: Listing,\n requestingUserId: string,\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n const group = await getGroup(groupId);\n if (!group) {\n return { sent: 0, errors: 1 };\n }\n\n // Get requesting user's name\n const userResult = await sqlite.execute({\n sql: `SELECT name, email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [requestingUserId],\n });\n const requestingUser = userResult.rows[0]?.name || userResult.rows[0]?.email || \"A group member\";\n\n // Get recipients (excluding the requesting user)\n const recipients = (await getNotificationRecipients(groupId, \"notify_comment_request\"))\n .filter(r => r.userId !== requestingUserId);\n\n if (recipients.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const template = generateCommentRequest(group.name, listing, requestingUser as string, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n// Type for reminder row with joins\ntype ReminderJoinRow = {\n id: string;\n listing_id: string;\n group_id: string;\n created_by: string;\n message: string | null;\n remind_at: number;\n is_sent: number;\n created_at: number;\n address_original: string;\n price: number | null;\n beds: number | null;\n baths: number | null;\n group_name: string;\n};\n\n/**\n * Process and send due reminders\n */\nexport async function processDueReminders(): Promise<{ processed: number; sent: number; errors: number }> {\n const now = Math.floor(Date.now() / 1000);\n\n // Get due reminders\n const remindersResult = await sqlite.execute({\n sql: `\n SELECT r.id, r.listing_id, r.group_id, r.created_by, r.message, r.remind_at, r.is_sent, r.created_at, l.address_original, l.price, l.beds, l.baths, g.name as group_name\n FROM ${TABLE_PREFIX}reminders r\n JOIN ${TABLE_PREFIX}listings l ON r.listing_id = l.id\n JOIN ${TABLE_PREFIX}groups g ON r.group_id = g.id\n WHERE r.is_sent = 0 AND r.remind_at <= ?\n `,\n args: [now],\n });\n\n const reminderRows = rowsToObjects(remindersResult.rows as (unknown[] | Record)[], remindersResult.columns);\n\n let processed = 0;\n let sent = 0;\n let errors = 0;\n\n for (const row of reminderRows) {\n processed++;\n\n // Get user email\n const userResult = await sqlite.execute({\n sql: `SELECT email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [row.created_by],\n });\n\n if (userResult.rows.length === 0) continue;\n\n type EmailRow = { email: string };\n const userRow = rowToObject(userResult.rows[0] as unknown[] | Record, userResult.columns);\n\n const listing: Listing = {\n id: row.listing_id,\n address_original: row.address_original,\n address_normalized: \"\",\n unit_number: null,\n lat: null,\n lng: null,\n beds: row.beds,\n baths: row.baths,\n price: row.price,\n availability: null,\n neighborhood: null,\n first_seen_at: 0,\n last_updated_at: 0,\n is_active: true,\n };\n\n const template = generateApplyReminder(\n row.group_name,\n listing,\n row.message,\n \"https://your-app.val.run\"\n );\n\n try {\n await email({\n to: [userRow.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n\n // Mark as sent\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}reminders SET is_sent = 1 WHERE id = ?`,\n args: [row.id],\n });\n\n sent++;\n } catch (err) {\n console.error(\"Failed to send reminder:\", err);\n errors++;\n }\n }\n\n return { processed, sent, errors };\n}\n\n/**\n * Create a reminder for a listing\n */\nexport async function createReminder(\n listingId: string,\n groupId: string,\n userId: string,\n remindAt: number,\n message?: string\n): Promise {\n const id = `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n const now = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}reminders \n (id, listing_id, group_id, created_by, remind_at, message, is_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, ?)\n `,\n args: [id, listingId, groupId, userId, remindAt, message || null, now],\n });\n\n return id;\n}\n\nexport { getNotificationRecipients, getGroup };\n","deleted","label",[176,158],"backend","permalink","https://www.val.town/x/shapedlines/loki/code/backend/notifications.ts","extension","actionData","errors"]