Last commit: Mon Nov 12 20:57:02 2018 +0100	dankert	Ganz einfache Implementierung einer Queue.


      <?php
      
      require('./Queue.class.php');
      
      class MailboxQueue extends Queue
      {
      	public $debug = false;
      	public $hostname = 'localhost';
      	public $username = 'user';
     	public $password = '';
     	
     	private $text;
     	private $html;
     	
     	public function pull()
     	{
     		/* Verbindung zu Server */
     		$inbox = imap_open($this->hostname,$this->username,$this->password) or die('Cannot connect to IMAP server: ' . imap_last_error());
     		
     		/* grab emails */
     		$emails = imap_search($inbox,'ALL UNDELETED UNSEEN');
     		
     		if	($emails)
     		{
     			/* put the newest emails on top */
     			rsort($emails);
     			
     			$email_number = $email[0];
     		
     			/* get information specific to this email */
     			// 		$overview  = imap_fetch_overview($inbox,$email_number,0);
     			$headers = imap_headerinfo($inbox,$email_number);
     			$structure = imap_fetchstructure($inbox,$email_number);
     			// 		$message = imap_fetchbody($inbox,$email_number);
     	
     			// 		echo "\nOverview:";
     			//  		print_r($overview);
     			if	( $this->debug ) { echo '<pre>'; print_r($headers); echo '</pre>'; }
     	
     			// Initalize
     			$this->filenames = array();
     			$this->text      = '';
     			$this->html      = '';
     			$subject   = iconv_mime_decode($headers->subject,0,'UTF-8');
     	
     			$s = imap_fetchstructure($inbox,$email_number);
     	
     			if (!$s->parts)  // simple
     				$this->getpart($inbox,$email_number,$s,0);  // pass 0 as part-number
     			else {  // multipart: cycle through each part
     				foreach ($s->parts as $partno0=>$p)
     					$this->getpart($inbox,$email_number,$p,$partno0+1);
     			}
     	
     			// 		print_r($message);
     			/* output the email header information */
     			// 		$output.= '<div class="toggler '.($overview[0]->seen ? 'read' : 'unread').'">';
     			// 		$output.= '<span class="subject">'.$overview[0]->subject.'</span> ';
     			// 		$output.= '<span class="from">'.$overview[0]->from.'</span>';
     			// 		$output.= '<span class="date">on '.$overview[0]->date.'</span>';
     			// 		$output.= '</div>';
     	
     			/* output the email body */
     			// 		$output.= '<div class="body">'.$message.'</div>';
     	
     			if	( $this->debug ) echo "\n\nBetreff: ".$subject;
     			if	( $this->debug ) echo "\n\nText: ";
     			if	( $this->debug ) print_r($this->text);
     			if	( $this->debug ) echo "\n\nAnlagen: ";
     			if	( $this->debug ) print_r($this->filenames);
     	
     			$entrys[] = array(
     				'filenames'=> $this->filenames,
     				'keywords' => array(),
     				'timestamp' => strtotime($headers->date),
     				'subject'  => $subject,
     				'text'     => $this->text
     			);
     	
     			// Aufräumen:
     			// - Mail als gelesen markieren und in das Archiv verschieben.
     			if	( $this->config['dry'] )
     				;
     			else
     			{
     				imap_setflag_full($inbox,$email_number,'\\SEEN',0);
     				
     				if	(isset($this->config['archive_folder']))
     				{
     					imap_mail_move($inbox,$email_number,$this->config['archive_folder']) or die("IMAP: Move did not suceed: "+imap_last_error() );
     			
     					imap_expunge($inbox);
     				}
     			}
     		}
     		
     		/* close the connection */
     		imap_close($inbox);
     		
    		return $entrys;
    	}
    	
    	
    	
    	private function getpart($mbox,$mid,$p,$partno)
    	{
    		// $partno = '1', '2', '2.1', '2.1.3', etc for multipart, 0 if simple
    		
    		// DECODE DATA
    		$data = ($partno) ?
    		imap_fetchbody($mbox,$mid,$partno):  // multipart
    		imap_body($mbox,$mid);  // simple
    	
    		// Any part may be encoded, even plain text messages, so check everything.
    		if	($p->encoding==4)
    			$data = quoted_printable_decode($data);
    		elseif ($p->encoding==3)
    		$data = base64_decode($data);
    	
    		// PARAMETERS
    		// get all parameters, like charset, filenames of attachments, etc.
    		$params = array();
    		if (@$p->parameters)
    			foreach ($p->parameters as $x)
    			$params[strtolower($x->attribute)] = $x->value;
    		if (@$p->dparameters)
    			foreach ($p->dparameters as $x)
    			$params[strtolower($x->attribute)] = $x->value;
    	
    		// ATTACHMENT
    		// Any part with a filename is an attachment,
    		// so an attached text file (type 0) is not mistaken as the message.
    		if (@$params['filename'] || @$params['name']) {
    			// filename may be given as 'Filename' or 'Name' or both
    			$filename = ($params['filename'])? $params['filename'] : $params['name'];
    			// filename may be encoded, so see imap_mime_header_decode()
    			$fname = tempnam(null,'blog-file-');
    			$file = fopen($fname,'w');
    			fwrite($file,$data);
    			fclose($file);
    			chmod($fname,0644);
    	
    			$this->filenames[] = array('filename'=>$fname,'name'=>$filename);
    		}
    	
    		// TEXT
    		if ($p->type==0 && $data) {
    			$charset = $params['charset'];  // assume all parts are same charset
    			$data = iconv($charset,'UTF-8//TRANSLIT',$data);
    			
    			// Messages may be split in different parts because of inline attachments,
    			// so append parts together with blank row.
    			if (strtolower($p->subtype)=='plain')
    				$this->text.= trim($data) ."\n\n";
    			else
    				$this->html.= $data ."<br><br>";
    		}
    	
    		// EMBEDDED MESSAGE
    		// Many bounce notifications embed the original message as type 2,
    		// but AOL uses type 1 (multipart), which is not handled here.
    		// There are no PHP functions to parse embedded messages,
    		// so this just appends the raw source to the main message.
    		elseif ($p->type==2 && $data) {
    			$this->text.= $data."\n\n";
    		}
    	
    		// SUBPART RECURSION
    		if (@$p->parts) {
    			foreach ($p->parts as $partno0=>$p2)
    				$this->getpart($mbox,$mid,$p2,$partno.'.'.($partno0+1));  // 1.2, 1.2.1, etc.
    		}
    	}
    	
    	
    	public function push( $entry )
    	{
    		$headers = '';
    		$headers .= 'Queue-Time: '.time()."\r\n";
    		$headers .= 'Queue-User: '.get_current_user()."\r\n";
    		$headers .= 'From: '.$this->from. "\r\n";
    		$headers .= 'X-Mailer: MailboxQueue/PHP/' . phpversion();
    		
    		mail($this->receiver, $this->subject, json_encode($entry->value), $headers);		
    	}
    	
    }
    	
    
    ?>


Download util/MailboxQueue.class.php

History
Mon, 12 Nov 2018 20:57:02 +0100	dankert	Ganz einfache Implementierung einer Queue.