root/python/ml/ml.php

#!/usr/bin/php
<?

  # ml.py -- simple mailing list to just distribute messages in a group.
  # Copyright (c) 2007 Shigeru KANEMOTO
  # All rights reserved.

  define('ML_LIST_ADDRESS', 'list@example.com');
  $ML_LIST_SUBSCRIBERS = array(
    # 'email address (lower case)' => 'real name'
    "somebody@example.com" => "�ʤޤ�"
  );

  define('ML_EMAIL_MAX_SIZE', 100000);
  define('ML_CHARSET', 'iso-2022-jp');
  define('ML_CODE_CHARSET', 'euc-jp');  // encoding of this source code.

////////////////////////////////////////////////////////////////////////////////

  // �饤�֥�
  require_once('PEAR.php');
  require_once('Mail.php');
  require_once('Mail/mime.php');
  require_once('Mail/mimeDecode.php');
  require_once('Mail/RFC822.php');

  function decodeSingleAddress($s) {
    $a = Mail_RFC822::parseAddressList($s);
    if (PEAR::isError($a) || count($a) != 1)
      return '';
    $a = $a[0];
    if ($a->mailbox == '')
      return '';
    return strtolower($a->mailbox . '@' . $a->host);
  }

  function decodeSomeAddresses($s) {
    $a = Mail_RFC822::parseAddressList($s);
    if (PEAR::isError($a))
      return array();
    $aa = array();
    foreach ($a as $v) {
      if ($v->mailbox != '')
        $aa[] = strtolower($v->mailbox . '@' . $v->host);
    }
    return $aa;
  }

////////////////////////////////////////////////////////////////////////////////


  //
  // �᡼���ǡ�����߹��ࡣ
  //
  $input = '';
  $len = ML_EMAIL_MAX_SIZE;
  while (!feof(STDIN) && $len > 0) {
    $s = fread(STDIN, $len);
    $input .= $s;
    $len -= strlen($s);
    unset($s);
  }
  if (!feof(STDIN)) {
    // �᡼���ǡ�������������롣
    fputs(STDERR, "Mail data size too large.\n");
//    exit(65); // EX_DATAERR
    exit(0);    // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
  }


  //
  // MIME�ǥ�����  //
  $decoder = new Mail_mimeDecode($input);
  if (PEAR::isError($decoder)) {
    // MIME�ǥ����ɼ����
    fputs(STDERR, "Could not decode MIME.\n");
//    exit(65); // EX_DATAERR
    exit(0);    // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
  }
  unset($input);
  $given = $decoder->decode(
    array(
      'include_bodies' => true,
      'decode_bodies' => true,
      'decode_headers' => true
    )
  );
  unset($decoder);


  //
  // ���Ԥθ���  //

  // ����Ԥ򸡾�  if (!isset($given->headers['from'])) {
    fputs(STDERR, "No 'from' header found.\n");
//    exit(65); // EX_DATAERR
    exit(0);    // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
  }
  $from = decodeSingleAddress($given->headers['from']);
  if ($from == '' || !isset($ML_LIST_SUBSCRIBERS[$from])) {
    // ����Ԥ��桼���ǤϤʤ���
    fputs(STDERR, "Sender not allowed.\n");
//    exit(65); // EX_DATAERR
    exit(0);    // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
  }

  // ����򸡾�XXX isset?
  if (array_search(ML_LIST_ADDRESS, decodeSomeAddresses($given->headers['to'])) === false
   && array_search(ML_LIST_ADDRESS, decodeSomeAddresses($given->headers['cc'])) === false) {
    // �����ML�ǤϤʤ���
    fputs(STDERR, "Recipient not allowed.\n");
//    exit(65); // EX_DATAERR
    exit(0);    // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
  }


  //
  // �������������
  //
  $subject = $given->headers['subject'];
  $subject = preg_replace('!^(re(\d+|\[\d+\])?[:>]\s*)+!i', 'Re:', $subject);


  //
  // �ʸ�ν�
  //
  class ProcessMimeParts {
    var $mime_;
    var $charset_;
    var $text_;
    var $i_;

    function ProcessMimeParts($s) {
      $this->mime_ = new Mail_mime();
      $this->charset_ = '';
      $this->text_ = $s;
      $this->i_ = 0;
    }

    function doit($o) {
      if ($o->ctype_primary == 'multipart') {
        foreach ($o->parts as $oo)
          $this->doit($oo);
      } else
      if ($o->ctype_primary == 'text') {
        if ($o->ctype_secondary == 'plain') {
          if ($this->charset_ != '')
            return;
          if (!isset($o->ctype_parameters['charset']))
            return;
          $this->charset_ = strtolower($o->ctype_parameters['charset']);
          $this->text_ .=
            mb_convert_encoding($o->body, ML_CHARSET, $this->charset_);
        }
      } else
      if ($o->ctype_primary == 'image') {
        $fn = '';
        if (isset($o->d_parameters['name']))
          $fn = $o->d_parameters['name'];
        else
        if (isset($o->d_parameters['filename']))
          $fn = $o->d_parameters['filename'];
        else
          $fn = sprintf("%d.jpg", $this->i_++);
        $this->mime_->addAttachment(
          $o->body, $o->ctype_primary . '/' . $o->ctype_secondary,
          $fn, false); 
      }
    }

    function done($subject) {
      if ($this->charset_ == '') {
        fputs(STDERR, "No charset found.\n");
//      exit(65);       // EX_DATAERR
        exit(0);        // XXX Courier�����顼�򥭥����夷�Ƥ��ޤ���
      }

      $this->mime_->setTXTBody($this->text_);
      $body = $this->mime_->get(
        array(
          'text_charset' => $charset
        )
      );

      // PEAR�Х���      // Mail_mime::get()�����Ԥ�;�פˤĤ��롣
      // SMTP::send()�����Ԥ�;�פ���
      $body = preg_replace("!\r?\n!", "\r\n", $body);   // \r\n���      $body = preg_replace("!\r\n\r\n$!", "", $body);

      $headers = $this->mime_->headers(
        array(
          'From' => ML_LIST_ADDRESS,
          'To' => ML_LIST_ADDRESS,
          'Subject' => '=?'.ML_CHARSET.'?B?'.base64_encode($subject).'?='
        )
      );

      return array($body, $headers);
    }
  }

  $pm = new ProcessMimeParts(
    "[".mb_convert_encoding($ML_LIST_SUBSCRIBERS[$from], ML_CHARSET, ML_CODE_CHARSET)."]\n"
  );

  $pm->doit($given);
  list($body, $headers) = $pm->done($subject);
  unset($pm);


  //
  // ���������������Ԥ����
  //
  unset($ML_LIST_SUBSCRIBERS[$from]);
  $dest = array_keys($ML_LIST_SUBSCRIBERS);


  //
  // �᡼�������
  //
  $mail = Mail::factory('smtp');        // 'mail'���o:�إå������������
  $o = $mail->send($dest, $headers, $body);
  if ($o !== True)
    fputs(STDERR, $o->toString());

?>