import nodemailer from 'nodemailer'; const FRONTEND_URL = process.env.FRONTEND_URL || 'https://rainmakersports.app'; const FORECASTS_WELCOME_URL = `${FRONTEND_URL}/forecasts?welcome=true`; const FORECASTS_SURVEY_URL = `${FRONTEND_URL}/forecasts?welcome=true&survey=1`; const transporter = nodemailer.createTransport({ sendmail: true, newline: 'unix', path: '/usr/sbin/sendmail', }); function escapeHtml(str: string): string { return str .replace(/&/g, '&') .replace(//g, '>') .replace(/"/g, '"') .replace(/'/g, '''); } /** Colorize O/U tokens and winner names in display_text for HTML email */ function colorizeClipHtml(text: string, clipData?: any): string { let html = escapeHtml(text); // Colorize | O | and | U | tokens html = html.replace(/\|\s*O\s*\|/g, '| O |'); html = html.replace(/\|\s*U\s*\|/g, '| U |'); // Colorize winner name in green if present in clip_data if (clipData?.winner) { const winner = escapeHtml(clipData.winner); html = html.replace(`Winner: ${winner}`, `Winner: ${winner}`); } return html; } export async function sendClipperEmail( email: string, clips: Array<{ clip_type: string; display_text: string; clipped_at: string; clip_data?: any }> ): Promise { const now = new Date(); const etTime = now.toLocaleString('en-US', { timeZone: 'America/New_York', dateStyle: 'medium', timeStyle: 'short' }); const clipItems = clips .map( (c) => `
  • ${escapeHtml(c.clip_type.replace(/_/g, ' '))}
    ${colorizeClipHtml(c.display_text, c.clip_data)}
    • ` ) .join(''); const html = `

    Your Clipper List

    ${clips.length} item${clips.length !== 1 ? 's' : ''} clipped

      ${clipItems}

    Sent ${etTime} ET — Rainmaker Sports

    `; await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: 'Your Clipper List', html, }); } export async function sendVerificationEmail(email: string, token: string): Promise { const API_URL = process.env.API_URL || FRONTEND_URL.replace(/\/$/, '') + '/api'; const verifyUrl = `${API_URL}/auth/verify-email?token=${token}`; const html = `

    Verify Your Email

    Welcome to Rainmaker

    Click below to verify your email and unlock your free daily forecasts.

    Verify Email

    This link expires in 24 hours. If you didn't create a Rainmaker account, ignore this email.

    Rainmaker Sports — AI Sports Forecasting

    `; const text = `Verify Your Email\n\nWelcome to Rainmaker! Click the link below to verify your email and unlock your free daily forecasts.\n\n${verifyUrl}\n\nThis link expires in 24 hours. If you didn't create a Rainmaker account, ignore this email.\n\nRainmaker Sports — AI Sports Forecasting`; await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: 'Verify your Rainmaker email', text, html, }); } export async function sendPasswordResetEmail(email: string, token: string): Promise { // Fragments are not sent in Referer headers, unlike query strings. const resetUrl = `${FRONTEND_URL}/reset-password#token=${encodeURIComponent(token)}`; const html = `

    Reset Your Password

    Rainmaker account recovery

    Click below to set a new password for your Rainmaker account.

    Reset Password

    This link expires in 1 hour. If you didn't request a reset, ignore this email.

    Rainmaker Sports — Account Security

    `; const text = `Reset Your Password\n\nSet a new password for your Rainmaker account:\n\n${resetUrl}\n\nThis link expires in 1 hour. If you didn't request a reset, ignore this email.\n\nRainmaker Sports`; await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: 'Reset your Rainmaker password', text, html, }); } export async function sendWelcomeEmail(email: string): Promise { const html = `
    Rainmaker

    Welcome to Rainmaker

    Your AI Sports Forecast Edge

    Your email is verified and your free daily forecasts are live. Do these two things first so you actually get value out of the account:

    1. Claim your bonus forecasts

    Complete the quick survey to unlock your daily free board plus the survey bonus.

    2. Open your first forecast

    Jump straight into today's board and tap any matchup for the full AI read.

    Free forecasts reset daily

    If you want the full board every day, upgrade later. Don’t worry about that now.

    Rainmaker Sports — We collect the data. You enjoy the games.

    `; const text = `Welcome to Rainmaker!\n\nYour email is verified and your free daily forecasts are live.\n\n1. Claim your bonus forecasts: ${FORECASTS_SURVEY_URL}\n2. Open your first forecast: ${FORECASTS_WELCOME_URL}\n\nFree forecasts reset daily. Upgrade later if you want the full board every day.\n\nRainmaker Sports — We collect the data. You enjoy the games.`; await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: 'Welcome to Rainmaker — Your forecasts are live', text, html, }); } export async function sendPurchaseConfirmationEmail( email: string, params: { productName: string; picksGranted: number; totalBalance: number } ): Promise { const html = `

    Purchase Confirmed

    ${escapeHtml(params.productName)}

    +${params.picksGranted}

    forecasts added to your account

    Current Balance: ${params.totalBalance} forecasts

    Use Your Forecasts

    Rainmaker Sports — We collect the data. You enjoy the games.

    `; const text = `Purchase Confirmed\n\n${params.productName}\n+${params.picksGranted} forecasts added\nCurrent balance: ${params.totalBalance} forecasts\n\nUse your forecasts: ${FRONTEND_URL}/forecasts\n\nRainmaker Sports`; await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: `Purchase confirmed — +${params.picksGranted} forecasts added`, text, html, }); } export async function sendMonthlyPassExpiryEmail( email: string, params: { expiresAt: string } ): Promise { const expiresLabel = new Date(params.expiresAt).toLocaleString('en-US', { timeZone: 'America/New_York', weekday: 'short', month: 'short', day: 'numeric', hour: 'numeric', minute: '2-digit', timeZoneName: 'short', }); const renewUrl = `${FRONTEND_URL}/pricing`; const html = `
    Rainmaker

    Your Rain Man access is ending soon

    This plan does not auto-renew.

    Your unlimited Rain Man access expires on ${escapeHtml(expiresLabel)}.

    If you want to keep unlimited forecasts and premium insights, renew manually before it ends. We do not rebill this pass automatically.

    Renew Rain Man

    Rainmaker Sports — No silent rebills. No fake subscription language.

    `; const text = [ 'Your Rain Man access is ending soon.', '', `Expires: ${expiresLabel}`, 'This plan does not auto-renew.', `Renew here: ${renewUrl}`, '', 'Rainmaker Sports', ].join('\n'); await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: 'Rain Man access expires soon', text, html, }); } export async function sendMlbAlertDigestEmail( email: string, params: { dateET: string; summary: { total_assets: number; critical_assets: number; warning_assets: number; by_code: Record }; issueSummary?: { total_games: number; by_issue_type: Record }; issues?: Array<{ event_id: string; starts_at: string; matchup: string; home_team: string; away_team: string; home_feed_rows: number; away_feed_rows: number; home_candidate_count: number; away_candidate_count: number; zero_candidate_teams: string[]; issue_type: string; }>; assets: Array<{ event_id: string; forecast_type: string; team_side: string | null; team_id: string | null; status: string; starts_at: string | null; home_team: string | null; away_team: string | null; alerts: any[]; }>; }, ): Promise { const summaryItems = Object.entries(params.summary.by_code) .sort((a, b) => b[1] - a[1]) .map(([code, count]) => `
  • ${escapeHtml(code)}: ${count}
    • `) .join(''); const issueSummaryItems = Object.entries(params.issueSummary?.by_issue_type || {}) .sort((a, b) => b[1] - a[1]) .map(([code, count]) => `
  • ${escapeHtml(code)}: ${count}
    • `) .join(''); const assetItems = params.assets .slice(0, 20) .map((asset) => { const matchup = `${asset.away_team || '?'} @ ${asset.home_team || '?'}`; const alerts = asset.alerts .map((alert) => `
  • ${escapeHtml(String(alert?.severity || 'info').toUpperCase())} — ${escapeHtml(alert?.message || alert?.code || 'Alert')}
    • `) .join(''); return `
  • ${escapeHtml(matchup)}
    ${escapeHtml(asset.forecast_type)}${asset.team_side ? ` | ${escapeHtml(asset.team_side)}` : ''} | status=${escapeHtml(asset.status)}
      ${alerts}
    • `; }) .join(''); const issueItems = (params.issues || []) .slice(0, 20) .map((issue) => `
  • ${escapeHtml(issue.matchup)}
    ${escapeHtml(issue.issue_type)} | feed ${issue.home_team}:${issue.home_feed_rows} ${issue.away_team}:${issue.away_feed_rows} | candidates ${issue.home_team}:${issue.home_candidate_count} ${issue.away_team}:${issue.away_candidate_count}
    • `) .join(''); const html = `

    MLB Operational Alerts

    ${escapeHtml(params.dateET)} ET

    Summary
    Total assets: ${params.summary.total_assets}
    Critical assets: ${params.summary.critical_assets}
    Warning assets: ${params.summary.warning_assets}
      ${summaryItems}
    Zero-Candidate Issues
    Affected games: ${params.issueSummary?.total_games || 0}
      ${issueSummaryItems || '
    • None
      • '}
      ${issueItems || '
    • No issue rows.
      • '}
    Affected Assets
      ${assetItems || '
    • No assets.
      • '}
    `; const text = [ `MLB Operational Alerts — ${params.dateET} ET`, `Total assets: ${params.summary.total_assets}`, `Critical assets: ${params.summary.critical_assets}`, `Warning assets: ${params.summary.warning_assets}`, '', ...Object.entries(params.summary.by_code).map(([code, count]) => `${code}: ${count}`), '', `Zero-candidate issue games: ${params.issueSummary?.total_games || 0}`, ...Object.entries(params.issueSummary?.by_issue_type || {}).map(([code, count]) => `${code}: ${count}`), '', ...(params.issues || []).slice(0, 20).map((issue) => `${issue.matchup} | ${issue.issue_type} | feed ${issue.home_team}:${issue.home_feed_rows} ${issue.away_team}:${issue.away_feed_rows} | candidates ${issue.home_team}:${issue.home_candidate_count} ${issue.away_team}:${issue.away_candidate_count}` ), '', ...params.assets.slice(0, 20).map((asset) => `${asset.away_team || '?'} @ ${asset.home_team || '?'} | ${asset.forecast_type}${asset.team_side ? ` | ${asset.team_side}` : ''} | ${asset.status}\n` + asset.alerts.map((alert) => `- ${String(alert?.severity || 'info').toUpperCase()}: ${alert?.message || alert?.code || 'Alert'}`).join('\n') ), ].join('\n'); await transporter.sendMail({ from: 'Rainmaker ', to: email, subject: `MLB operational alerts (${params.summary.critical_assets} critical, ${params.summary.warning_assets} warning)`, text, html, }); }