"""Transactional email service.
Priority:
1. If SMTP settings are configured in the admin Settings panel → use SMTP (hosting email).
2. Else if RESEND_API_KEY env var is set → use Resend.
3. Else → log + skip (no error raised).
All sends are logged to `email_logs` collection regardless of provider.
"""
import os
import asyncio
import logging
import uuid
import smtplib
import ssl
from email.message import EmailMessage
from datetime import datetime, timezone
from typing import Optional
import resend
from db import get_db
from bd_time import now_bd_str, fmt_bd_long
logger = logging.getLogger(__name__)
RESEND_API_KEY = os.environ.get("RESEND_API_KEY", "")
DEFAULT_SENDER = os.environ.get("SENDER_EMAIL", "onboarding@resend.dev")
if RESEND_API_KEY:
resend.api_key = RESEND_API_KEY
async def _get_email_settings() -> dict:
"""Read live SMTP + Resend settings.
Priority for each SMTP field:
1. DB `settings` document (admin panel controlled)
2. Environment variable fallback (for cPanel / fresh-deploy scenarios
where DB may not be seeded yet)
Falls back to empty values if neither is set.
"""
db = get_db()
doc = await db.settings.find_one({"id": "global"}, {"_id": 0}) or {}
def pick(db_key: str, env_key: str, default=None):
v = doc.get(db_key)
if v not in (None, ""):
return v
return os.environ.get(env_key, default)
return {
**doc,
"smtp_host": pick("smtp_host", "SMTP_HOST", ""),
"smtp_port": int(pick("smtp_port", "SMTP_PORT", 465) or 465),
"smtp_user": pick("smtp_user", "SMTP_USER", ""),
"smtp_password": pick("smtp_password", "SMTP_PASSWORD", ""),
"smtp_from_name": pick("smtp_from_name", "SMTP_FROM_NAME", "Maxlife88 Agent Portal"),
"smtp_use_ssl": doc.get("smtp_use_ssl") if doc.get("smtp_use_ssl") is not None
else (os.environ.get("SMTP_USE_SSL", "true").lower() != "false"),
"sender_email": pick("sender_email", "SENDER_EMAIL", DEFAULT_SENDER),
"notification_email": pick("notification_email", "ADMIN_EMAIL", ""),
}
async def _log_email(
to: str,
subject: str,
email_type: str,
status: str,
provider: str = "skipped",
resend_id: Optional[str] = None,
error: Optional[str] = None,
application_id: Optional[str] = None,
sender: Optional[str] = None,
):
try:
db = get_db()
await db.email_logs.insert_one({
"id": str(uuid.uuid4()),
"to": to,
"subject": subject,
"email_type": email_type,
"status": status,
"provider": provider,
"resend_id": resend_id,
"error": error,
"application_id": application_id,
"sender": sender or DEFAULT_SENDER,
"sent_at": datetime.now(timezone.utc).isoformat(),
})
except Exception as e:
logger.error("Could not write email log: %s", e)
def _wrap_html(title: str, body_html: str, accent: str = "#10B981", preheader: str = "") -> str:
"""Premium email wrapper — gradient header, hero badge, polished footer.
`preheader` shows as the email preview text in inboxes (hidden in body).
"""
return f"""\
{title}
{preheader or title}
|
● Maxlife88 Agent Portal
|
{now_bd_str("%d %b %Y · %I:%M %p")} BDT
|
|
{title}
|
|
{body_html}
|
Automated message from Maxlife88 Agent Portal ·
Please do not reply.
এটি একটি স্বয়ংক্রিয় বার্তা — অনুগ্রহ করে এই ইমেইলে রিপ্লাই করবেন না।
|
|
|
© Maxlife88 · Bangladesh's most trusted agent network
|
|
"""
def _send_smtp_sync(
smtp_host: str,
smtp_port: int,
smtp_user: str,
smtp_password: str,
smtp_use_ssl: bool,
from_addr: str,
from_name: str,
to: str,
subject: str,
html: str,
attachments: Optional[list] = None,
) -> None:
"""Blocking SMTP send. Should be called via asyncio.to_thread.
attachments: list of dicts: {"filename": str, "content": bytes, "mime_type": "application/pdf"}
"""
msg = EmailMessage()
msg["Subject"] = subject
msg["From"] = f"{from_name} <{from_addr}>" if from_name else from_addr
msg["To"] = to
# Plain-text fallback then HTML alternative
msg.set_content("This email requires an HTML-capable client.")
msg.add_alternative(html, subtype="html")
if attachments:
for att in attachments:
mime = att.get("mime_type", "application/octet-stream")
maintype, _, subtype = mime.partition("/")
msg.add_attachment(
att["content"],
maintype=maintype or "application",
subtype=subtype or "octet-stream",
filename=att.get("filename", "attachment"),
)
if smtp_use_ssl:
context = ssl.create_default_context()
with smtplib.SMTP_SSL(smtp_host, smtp_port, context=context, timeout=20) as s:
s.login(smtp_user, smtp_password)
s.send_message(msg)
else:
with smtplib.SMTP(smtp_host, smtp_port, timeout=20) as s:
s.ehlo()
s.starttls(context=ssl.create_default_context())
s.ehlo()
s.login(smtp_user, smtp_password)
s.send_message(msg)
async def send_email(
to: str,
subject: str,
html: str,
sender: Optional[str] = None,
email_type: str = "generic",
application_id: Optional[str] = None,
attachments: Optional[list] = None,
) -> dict:
"""Send email via SMTP (preferred) or Resend (fallback). Logs every attempt.
attachments: optional list of {"filename","content"(bytes),"mime_type"}.
"""
settings = await _get_email_settings()
smtp_host = (settings.get("smtp_host") or "").strip()
smtp_user = (settings.get("smtp_user") or "").strip()
smtp_password = settings.get("smtp_password") or ""
# ---- SMTP path (preferred) ----
if smtp_host and smtp_user and smtp_password:
smtp_port = int(settings.get("smtp_port") or 465)
smtp_use_ssl = bool(settings.get("smtp_use_ssl", True))
configured_sender = (sender or settings.get("sender_email") or "").strip()
# If no sender, or default resend address, OR sender domain doesn't match smtp_user domain,
# fall back to smtp_user to avoid "Sender address rejected" errors.
smtp_user_domain = smtp_user.split("@")[-1].lower() if "@" in smtp_user else ""
sender_domain = configured_sender.split("@")[-1].lower() if "@" in configured_sender else ""
if (
not configured_sender
or "resend.dev" in configured_sender.lower()
or (smtp_user_domain and sender_domain and smtp_user_domain != sender_domain)
):
from_addr = smtp_user
else:
from_addr = configured_sender
from_name = settings.get("smtp_from_name") or "Maxlife88 Agent Portal"
try:
await asyncio.to_thread(
_send_smtp_sync,
smtp_host,
smtp_port,
smtp_user,
smtp_password,
smtp_use_ssl,
from_addr,
from_name,
to,
subject,
html,
attachments,
)
logger.info("SMTP email sent to %s via %s:%s (attachments=%d)", to, smtp_host, smtp_port, len(attachments or []))
await _log_email(to, subject, email_type, "sent", provider="smtp", application_id=application_id, sender=from_addr)
return {"success": True, "provider": "smtp"}
except Exception as e:
err = str(e)[:500]
logger.error("SMTP send failed to %s: %s", to, err)
await _log_email(to, subject, email_type, "failed", provider="smtp", error=err, application_id=application_id, sender=from_addr)
return {"success": False, "provider": "smtp", "error": err}
# ---- Resend fallback ----
if RESEND_API_KEY:
from_addr = sender or settings.get("sender_email") or DEFAULT_SENDER
params = {"from": from_addr, "to": [to], "subject": subject, "html": html}
if attachments:
# Resend accepts base64-encoded content
import base64
params["attachments"] = [
{
"filename": a.get("filename", "attachment"),
"content": base64.b64encode(a["content"]).decode("ascii"),
}
for a in attachments
]
try:
result = await asyncio.to_thread(resend.Emails.send, params)
rid = result.get("id")
logger.info("Resend email sent to %s id=%s", to, rid)
await _log_email(to, subject, email_type, "sent", provider="resend", resend_id=rid, application_id=application_id, sender=from_addr)
return {"success": True, "provider": "resend", "id": rid}
except Exception as e:
err = str(e)[:500]
logger.error("Resend send failed to %s: %s", to, err)
await _log_email(to, subject, email_type, "failed", provider="resend", error=err, application_id=application_id, sender=from_addr)
return {"success": False, "provider": "resend", "error": err}
# ---- Nothing configured ----
logger.warning("No email provider configured. Skipping email to %s", to)
await _log_email(to, subject, email_type, "skipped", provider="none", error="no_provider_configured", application_id=application_id, sender=sender)
return {"skipped": True, "reason": "no_provider"}
async def send_test_email(to: str) -> dict:
"""Admin → Settings → Test SMTP button calls this."""
body = f"""
Hello 👋
This is a test email from your Maxlife88 Agent Portal SMTP setup.
If you received this, your hosting SMTP is configured correctly and ready to send transactional emails.
আপনি যদি এই ইমেইলটি পেয়ে থাকেন, তাহলে আপনার SMTP setup সফলভাবে কাজ করছে।
{_info_card([
("Sent at", now_bd_str("%d %b %Y · %I:%M:%S %p")),
("Recipient", to),
("Test type", "SMTP connectivity"),
])}
"""
return await send_email(
to=to,
subject="✅ SMTP Test — Maxlife88 Agent Portal",
html=_wrap_html("SMTP Test Successful", body,
preheader=f"Your SMTP setup is working — test received at {now_bd_str('%I:%M %p')}."),
email_type="test",
)
# ============ Email helpers ============
def _info_card(rows: list, accent: str = "#10B981") -> str:
"""Render a dark info-card with rows of [label, value]."""
inner = ""
for label, value in rows:
inner += (
f''
f'| {label} | '
f'{value} | '
f'
'
)
return (
f''
)
def _cta_button(label: str, url: str, accent: str = "#10B981") -> str:
return (
f''
)
def _note_box(text_en: str, text_bn: str, color: str = "#10B981", icon: str = "📎") -> str:
return (
f''
f'{icon} {text_en}
'
f'{icon} {text_bn}'
f'
'
)
# ============ Email templates ============
async def send_payment_received_email(to: str, full_name: str, amount: float, payment_id: str, application_id: Optional[str] = None, pdf_bytes: Optional[bytes] = None):
body = f"""
Hello {full_name},
হ্যালো {full_name},
We've received your USDT payment of ${amount:.2f}.
Your agent application is now queued for KYC review by our team.
আপনার ${amount:.2f} USDT পেমেন্ট
সফলভাবে গ্রহণ করা হয়েছে। আপনার এজেন্ট আবেদন এখন আমাদের রিভিউ টিমের কাছে পাঠানো হয়েছে।
{_info_card([
("Application ID", f'{application_id or "—"}'),
("Payment ID", f'{payment_id}'),
("Amount", f'${amount:.2f} USDT'),
("Status", 'UNDER REVIEW'),
])}
You'll receive another email within ~24 hours once an admin approves or rejects your application.
২৪ ঘন্টার মধ্যে অনুমোদন বা প্রত্যাখ্যান সংক্রান্ত আরেকটি ইমেইল পাঠানো হবে।
{_note_box("Your payment receipt is attached as a PDF — keep it for your records.", "আপনার পেমেন্ট রিসিপ্ট PDF আকারে সংযুক্ত করা হয়েছে।") if pdf_bytes else ""}
"""
attachments = [{"filename": f"payment-receipt-{application_id or ''}.pdf", "content": pdf_bytes, "mime_type": "application/pdf"}] if pdf_bytes else None
return await send_email(
to,
"✓ Payment Received — Maxlife88 Agent Application",
_wrap_html("Payment received & queued for review", body,
preheader=f"Your ${amount:.2f} USDT payment is confirmed. Review starts within 24h."),
email_type="payment_received",
application_id=application_id,
attachments=attachments,
)
async def send_application_approved_email(to: str, full_name: str, telegram_url: str, application_id: Optional[str] = None, pdf_bytes: Optional[bytes] = None):
body = f"""
Congratulations, {full_name} 🎉
অভিনন্দন, {full_name} — আপনার আবেদন অনুমোদিত হয়েছে।
Your Maxlife88 Agent application has been approved.
Welcome to our agent network — your account is now active.
আপনার Maxlife88 এজেন্ট আবেদন অনুমোদিত হয়েছে। আমাদের এজেন্ট নেটওয়ার্কে আপনাকে স্বাগতম।
{_info_card([
("Application ID", f'{application_id or "—"}'),
("Status", 'VERIFIED AGENT'),
("Approved On", now_bd_str("%d %b %Y · %I:%M %p")),
])}
Our team will message you on Telegram shortly with your agent credentials and onboarding details.
Please be ready to receive the call within the next few hours.
আমাদের টিম শীঘ্রই Telegram-এ যোগাযোগ করে আপনার এজেন্ট লগইন ক্রেডেনশিয়াল ও পরবর্তী ধাপ জানাবে।
{_cta_button("Contact Manager on Telegram", telegram_url)}
{_note_box("Your official approval certificate is attached as a PDF.", "আপনার অনুমোদন সার্টিফিকেট PDF আকারে সংযুক্ত।", icon="🎖️") if pdf_bytes else ""}
"""
attachments = [{"filename": f"approval-certificate-{application_id or ''}.pdf", "content": pdf_bytes, "mime_type": "application/pdf"}] if pdf_bytes else None
return await send_email(
to,
"🎉 Approved — Welcome to Maxlife88 Agent Network",
_wrap_html("Welcome to the agent network", body,
preheader="Your KYC has been verified and your agent account is now active."),
email_type="approved",
application_id=application_id,
attachments=attachments,
)
async def send_application_rejected_email(to: str, full_name: str, reason: str, telegram_url: str, application_id: Optional[str] = None, pdf_bytes: Optional[bytes] = None, reupload_url: Optional[str] = None):
reupload_cta = ""
if reupload_url:
reupload_cta = f"""
✨ Free Resubmission · ফ্রি পুনরায় আবেদন
Re-upload clearer NID photos using the button below — no additional payment required.
Your previous payment is carried forward automatically.
নিচের বাটনে ক্লিক করে স্পষ্ট NID ছবি আপলোড করুন — পুনরায় পেমেন্ট লাগবে না। আপনার পূর্ববর্তী পেমেন্ট স্বয়ংক্রিয়ভাবে carry-forward হবে।
{_cta_button("Re-upload NID & Resubmit (No Payment)", reupload_url, accent="#10B981")}
"""
else:
reupload_cta = _cta_button("Contact Support on Telegram", telegram_url, accent="#10B981")
body = f"""
Hello {full_name},
হ্যালো {full_name},
After careful review of your documents, we're unable to approve your Maxlife88 Agent application at this time.
সতর্কতার সাথে রিভিউ করার পর দুঃখের সাথে জানানো হচ্ছে যে এই মুহূর্তে আপনার আবেদনটি অনুমোদন করা সম্ভব হয়নি।
Reason for Rejection · কারণ
{reason}
{_info_card([
("Application ID", f'{application_id or "—"}'),
("Status", 'NOT APPROVED'),
("Decision Date", now_bd_str("%d %b %Y · %I:%M %p")),
], accent="#EF4444")}
{reupload_cta}
{_note_box("The full application report (with the rejection reason) is attached as a PDF.", "আবেদন রিপোর্ট PDF আকারে সংযুক্ত।") if pdf_bytes else ""}
"""
attachments = [{"filename": f"application-report-{application_id or ''}.pdf", "content": pdf_bytes, "mime_type": "application/pdf"}] if pdf_bytes else None
return await send_email(
to,
"Application Update — Resubmit Without Re-payment | Maxlife88",
_wrap_html("Application status update", body, accent="#EF4444",
preheader="Your application needs clearer NID photos — resubmit for free using the link inside."),
email_type="rejected",
application_id=application_id,
attachments=attachments,
)
async def send_admin_new_application_email(to: str, application: dict):
info_rows = [
("Application ID", f'{application.get("id", "")}'),
("Name", application.get("full_name", "—")),
("Email", application.get("email", "—")),
("Phone", application.get("phone", "—")),
("Username", application.get("username", "—")),
("Telegram", f'@{application.get("telegram_username", "—")}'),
("Location", f'{application.get("city","—")}, {application.get("state","—")}'),
("Amount Paid", f'${application.get("price_amount", 0):.2f} USDT'),
("Submitted", fmt_bd_long(application.get("created_at"))),
]
body = f"""
A new paid agent application has just landed in your queue and is ready for KYC review.
নতুন একটি paid এজেন্ট আবেদন এসেছে — রিভিউয়ের অপেক্ষায়।
{_info_card(info_rows)}
Log in to the admin panel to verify the NID documents and approve / reject this application.
"""
return await send_email(
to,
f"🔔 New Paid Application — {application.get('full_name', '')}",
_wrap_html("New paid application in queue", body,
preheader=f"{application.get('full_name','Agent')} just paid ${application.get('price_amount',0):.2f} — ready for review."),
email_type="admin_alert",
application_id=application.get("id"),
)