2016-10-30 3 views
0

Ich versuche, einen E-Mail-Server für meine Domains zu erstellen ... Was ich jetzt mache, empfängt E-Mails über SES und speichert sie in einem S3-Bucket. Wenn ein Benutzer dann auf den Posteingang zugreift, werden die neuen E-Mails abgerufen und gespeichert in meiner EC2 Instanz Datenbank.HOWTO: E-Mail-Server Amazon?

Obwohl es funktioniert Ich bin nicht vollständig mit dieser Lösung zufrieden, weiß jemand andere/bessere Möglichkeiten, dieses empfangende-speichern-zugreifende Problem zu arbeiten?

Vielen Dank im Voraus.

+0

eine Art ‚Webmail“ mit ses? – nogad

+0

@nogad Ich habe über Workmail gelesen (das ist, was ich denke du meinst), aber es funktioniert nicht zugänglich zu sein scheinen, sind programmatisch –

+0

Benutzer Zugang E-Mail über Web-Schnittstelle nicht Mail-Anwendung? – nogad

Antwort

0

Ich habe dies gelöst und die Antwort auf eine andere Frage geschrieben, die ich here gemacht hatte.

Aber ich werde es hier umbuchen sowieso:

Also, was ich tat, war die E-Mail in einem S3 Eimer empfangen zu speichern, als meine api darüber informiert, dass eine neue E-Mail (Senden der Dateiname) angekommen ist. Endlich gelesen von S3, geparst, gespeichert und gelöscht von S3, in meiner API.

SES Regeln: SES rules

Lambda anmelde Funktion:

Beachten Sie, dass der Name der von der ersten Regel erstellt S3-Datei die gleiche wie die Nachrichten-ID, daher 'fileName': event.Records[0].ses.mail.messageId .

'use strict'; 

exports.handler = (event, context, callback) => { 

    var http = require('http'); 
    var data = JSON.stringify({ 
     'fileName': event.Records[0].ses.mail.messageId, 
    }); 

    var options = { 
     host: 'my.host', 
     port: '80', 
     path: '/my/path', 
     method: 'POST', 
     headers: { 
      'Content-Type': 'application/json; charset=utf-8', 
      'Content-Length': data.length 
     } 
    }; 

    var req = http.request(options, function(res) { 
     var msg = ''; 

     res.setEncoding('utf8'); 
     res.on('data', function(chunk) { 
      msg += chunk; 
     }); 
     res.on('end', function() { 
      console.log(JSON.parse(msg)); 
      context.succeed(); 
     }); 
    }); 

    req.write(data); 
    req.end(); 
}; 

Api-Funktion (PHP - Laravel):

Beachten Sie, dass ich eine E-Mail-Parser bin mit, die auf Plancake Email Parser (Link here) mit einigen Änderungen meiner eigenen basiert und wenn nötig, werde ich bearbeiten, um die Quelle anzuzeigen.

public function process_incoming_email(Request $request) 
{ 
    $current_time = Carbon::now()->setTimezone('Brazil/East'); // ALL TIMEZONES: http://us.php.net/manual/en/timezones.others.php 

    try 
    { 
     if ($request->has('fileName') 
     { 
      $file_name = $request->input('fileName'); 

      // GET CREDENTIALS AND AUTHENTICATE 
      $credentials = CredentialProvider::env(); 
      $s3 = new S3Client([ 
       'version' => 'latest', 
       'region' => 'my-region', 
       'credentials' => $credentials 
      ]); 

      // FECTH S3 OBJECT 
      $object = $s3->GetObject(['Bucket' => 'my-bucket', 'Key' => $file_name]); 
      $body = $object['Body']->getContents(); 

      // PARSE S3 OBJECT 
      $parser = new EmailParser($body); 
      $receivers = ['to' => $parser->getTo(), 'cc' => $parser->getCc()]; 
      $from = $parser->getFrom(); 
      $body_plain = $parser->getPlainBody(); 
      $body_html = $parser->getHTMLBody(); 
      $subject = $parser->getSubject(); 

      $error_message; 

      // PROCESS EACH RECEIVER 
      foreach ($receivers as $type => $type_receivers) 
      { 
       foreach ($type_receivers as $receiver) 
       { 
        // PROCESS DOMAIN-MATCHING RECEIVERS 
        if(preg_match("/@(.*)/", $receiver['email'], $matches) && $matches[1] == self::HOST) 
        { 
         // INSERT NEW EMAIL 
         $inserted = DB::table('my-emails')->insert([ 
          // ... 
         ]); 
        } 
       } 
      } 

      // ADD ERROR LOG IF PARSER COULD NOT FIND EMAILS 
      if($email_count == 0) 
      { 
       DB::table('my-logs')->insert(
        ['sender' => $request->ip(), 'type' => 'error', 'content' => ($error_message = 'Could not parse received email or find a suitable user receiving email.') . ' File: ' . $file_name] 
       ); 
      } 
      // DELETE OBJECT FROM S3 IF INSERTED 
      else if(count($emails) == $email_count) 
      { 
       $s3->deleteObject(['Bucket' => 'my-bucket', 'Key' => $file_name]); 

       // RETURN SUCCESSFUL JSON RESPONSE 
       return Response::json(['success' => true, 'receivedAt' => $current_time, 'message' => 'Email successfully received and processed.']); 
      } 
      // ADD ERROR LOG IF NOT INSERTED 
      else 
      { 
       DB::table('my-logs')->insert(
        ['sender' => $request->ip(), 'type' => 'error', 'content' => ($error_message = 'Inserted ' . count($emails) . ' out of ' . $email_count . ' parsed records.') . ' File: ' . $file_name] 
       ); 
      } 
     } 
     else 
     { 
      // ERROR: NO fileName FIELD IN RESPONSE 
      DB::table('my-logs')->insert(
       ['sender' => $request->ip(), 'type' => 'error', 'content' => ($error_message = 'Incorrect request input format.') . ' Input: ' . json_encode($request->all())] 
      ); 
     } 
    } 
    // ERROR TREATMENT 
    catch(Exception $ex) 
    { 
     DB::table('my-logs')->insert(
      ['sender' => $request->ip(), 'type' => 'error', 'content' => ($error_message = 'An exception occurred while processing an incoming email.') . ' Details: ' . $ex->getMessage()] 
     ); 
    } 

    // RETURN FAILURE JSON RESPONSE 
    return Response::json(['success' => false, 'receivedAt' => $current_time, 'message' => $error_message]); 
}