123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139 |
- <?php
- if (!defined('STATUSNET')) {
- exit(1);
- }
- class ImapManager extends IoManager
- {
- protected $conn = null;
- function __construct($plugin)
- {
- $this->plugin = $plugin;
- }
-
- public static function get()
- {
-
- throw new Exception(_m('ImapManager should be created using its constructor, not using the static "get()" method.'));
- }
-
- public function getSockets()
- {
- return array();
- }
-
- public static function multiSite()
- {
- return IoManager::GLOBAL_SINGLE_ONLY;
- }
-
- public function start($master)
- {
- if(parent::start($master))
- {
- $this->conn = $this->connect();
- return true;
- }else{
- return false;
- }
- }
- public function handleInput($socket)
- {
- $this->check_mailbox();
- return true;
- }
- public function poll()
- {
- return $this->check_mailbox() > 0;
- }
- function pollInterval()
- {
- return $this->plugin->poll_frequency;
- }
- protected function connect()
- {
- $this->conn = imap_open($this->plugin->mailbox, $this->plugin->user, $this->plugin->password);
- if($this->conn){
- common_log(LOG_INFO, "Connected");
- return $this->conn;
- }else{
- common_log(LOG_INFO, "Failed to connect: " . imap_last_error());
- return $this->conn;
- }
- }
- protected function check_mailbox()
- {
- imap_ping($this->conn);
- $count = imap_num_msg($this->conn);
- common_log(LOG_INFO, "Found $count messages");
- if($count > 0){
- $handler = new IMAPMailHandler();
- for($i=1; $i <= $count; $i++)
- {
- $rawmessage = imap_fetchheader($this->conn, $count, FT_PREFETCHTEXT) . imap_body($this->conn, $i);
- $handler->handle_message($rawmessage);
- imap_delete($this->conn, $i);
- }
- imap_expunge($this->conn);
- common_log(LOG_INFO, "Finished processing messages");
- }
- return $count;
- }
- }
|