Geliştiriciler

IMAP'ten Otomasyon Kurmak: Maili Çekmek Kolay, İki Kez İşlememek Zor

IMAP kutusundan mail çekmek üç satır kod. Onu gece 03:00'te kimse uyanmadan çalışan, aynı maili iki kez işlemeyen bir servise çevirmek asıl mühendislik. UIDVALIDITY, idempotent tüketim, MIME ağacı ve IDLE + reconnect döngüsünü Node.js ve Python'da yan yana kuruyoruz.

EvilMail Team2 Ağustos 202614 dk okuma

IMAP'ten Otomasyon Kurmak: Maili Çekmek Kolay, İki Kez İşlememek Zor

Bir kutuya düşen mailleri otomatik işleyen bir servis kuruyorsun: gelen faturaları muhasebeye, başvuru maillerini bir kuyruğa, sipariş bildirimlerini bir webhook'a çeviriyorsun. En saf hali üç satır:

text

1. UNSEEN olanları çek
2. Ayrıştır (parse)
3. İşi yap, \Seen'e işaretle

Bu üç satır demoda kusursuz çalışır. Üretimde tam olarak üç yerden patlar: \Seen bayrağına güvenmek, UIDVALIDITY'yi yok saymak ve MIME gövdesini string olarak kesmeye çalışmak. Bağlanmak zaten kolay — asıl mühendislik durum takibi ve ayrıştırma. Bu yazı o üç patlamayı sırayla kapatıp, gece 03:00'te kimse uyanmadan çalışan idempotent bir tüketici kuruyor. Node.js (imapflow + mailparser) ve Python (IMAPClient + email) tarafını yan yana veriyorum.

IMAP gerçekte nasıl bir veri modeli

Bir mailbox'ı SELECT

IMAP ile E-posta Otomasyonu: Node.js ve Python'da İdempotent Parsing — EvilMail Blog

UIDVALIDITY

UIDNEXT

EXISTS

bash

openssl s_client -connect imap.gmail.com:993 -crlf
# bağlantı açılınca:
a LOGIN kullanici parola
a SELECT INBOX
# → * OK [UIDVALIDITY 1712345678] ...
# → * OK [UIDNEXT 5001] ...
a UID SEARCH UID 5000:*
# → * SEARCH 5000 5001 5002
a UID FETCH 5001 (BODY.PEEK[] FLAGS)

javascript

import { ImapFlow } from 'imapflow';

const client = new ImapFlow({
  host: 'mail.evilmail.pro',
  port: 993,
  secure: true,
  auth: { user: '[email protected]', pass: process.env.IMAP_PASS },
  logger: false,
});

await client.connect();
const box = await client.mailboxOpen('INBOX');
// box.uidValidity (BigInt), box.uidNext, box.exists

python

from imapclient import IMAPClient

with IMAPClient('mail.evilmail.pro', port=993, ssl=True) as server:
    server.login('[email protected]', os.environ['IMAP_PASS'])
    status = server.folder_status('INBOX', ['UIDVALIDITY', 'UIDNEXT'])
    server.select_folder('INBOX')
    # status[b'UIDVALIDITY'], status[b'UIDNEXT']

javascript

import { simpleParser } from 'mailparser';

const lock = await client.getMailboxLock('INBOX');
try {
  for await (const msg of client.fetch(`${lastUid + 1}:*`,
      { uid: true, source: true, flags: true })) {
    const mail = await simpleParser(msg.source);
    // mail.subject, mail.text, mail.html, mail.messageId
    // mail.attachments: [{ filename, contentType, content: Buffer, size }]
    await handle(mail, msg.uid);
  }
} finally {
  lock.release();
}

python

import email
from email.header import decode_header, make_header

raw = server.fetch(uids, ['BODY.PEEK[]'])
for uid, data in raw.items():
    m = email.message_from_bytes(data[b'BODY[]'])
    subject = str(make_header(decode_header(m['Subject'])))
    message_id = m['Message-ID']

    for part in m.walk():
        ctype = part.get_content_type()
        if ctype == 'text/plain' and not part.get_filename():
            cs = part.get_content_charset() or 'utf-8'
            body = part.get_payload(decode=True).decode(cs, errors='replace')
        elif part.get_filename():
            save_attachment(part)  # aşağıda

python

import os

def save_attachment(part, out_dir='/var/spool/robot', max_bytes=25 * 1024 * 1024):
    name = str(make_header(decode_header(part.get_filename())))
    name = os.path.basename(name)          # path traversal kes
    payload = part.get_payload(decode=True)
    if payload is None or len(payload) > max_bytes:
        return
    path = os.path.join(out_dir, name)
    with open(path, 'wb') as f:
        f.write(payload)

javascript

async function run() {
  for (;;) {
    try {
      await client.connect();
      const box = await client.mailboxOpen('INBOX');
      await resyncIfNeeded(box.uidValidity);   // UIDVALIDITY kontrolü
      await drainNewMessages();                // last_uid+1:*
      client.on('exists', () => drainNewMessages());
      await client.idle();                     // ~28dk'da otomatik yenilenir
    } catch (err) {
      await sleep(backoff() + jitter());       // exp backoff + jitter
    } finally {
      backoffReset();
    }
  }
}

IMAP'ten Otomasyon Kurmak: Maili Çekmek Kolay, İki Kez İşlememek Zor

IMAP gerçekte nasıl bir veri modeli

Bağlantı ve kimlik doğrulama

Yeni mesajları güvenilir yakalama

MIME'ı doğru ayrıştırma — asıl acı burada

Dedup: neden hem bayrak hem tablo

Gerçek zamanlı: IDLE ve reconnect döngüsü

Üretim sertleştirme ve sınırlar

Üretime çıkmadan hızlı kontrol listesi

İlgili Yazılar

ManageSieve ile Sieve Script'lerini Uzaktan Yönetmek: Merkezi Dağıtım ve Sürümleme

SMTP DSN ile Teslim ve Gecikme Bildirimlerini Programatik İşlemek

CI/CD Hattında E-postaları Mailpit ile Yakalayıp Otomatik Test Etmek