added google xoauth2 support + fixed a journaling issue

2025-06-13 01:37:02 +02:00 · 2012-09-28 10:34:04 +02:00
parent f930aacc84
commit 55de53bb26
111 changed files with 38812 additions and 4 deletions
--- a/webui/model/google/google.php
+++ b/webui/model/google/google.php
@ -0,0 +1,133 @@
+<?php
+
+class ModelGoogleGoogle extends Model {
+
+   private function constructAuthString($email, $accessToken) {
+      return base64_encode("user=$email\1auth=Bearer $accessToken\1\1");
+   }
+
+
+   public function oauth2Authenticate($imap, $email, $accessToken) {
+      $authenticateParams = array('XOAUTH2', $this->constructAuthString($email, $accessToken));
+
+      $imap->sendRequest('AUTHENTICATE', $authenticateParams);
+      while (true) {
+         $response = "";
+         $is_plus = $imap->readLine($response, '+', true);
+         if($is_plus) {
+            error_log("got an extra server challenge: $response");
+            // Send empty client response.
+            $imap->sendRequest('');
+         } else {
+            if(preg_match('/^NO /i', $response) ||
+               preg_match('/^BAD /i', $response)) {
+               error_log("got failure response: $response");
+               return false;
+            } else if (preg_match("/^OK /i", $response)) {
+               return true;
+            } else {
+               // Some untagged response, such as CAPABILITY
+            }
+         }
+      }
+   }
+
+
+   public function try_imap_login($email, $accessToken) {
+      $imap = new Zend_Mail_Protocol_Imap('imap.gmail.com', '993', true);
+
+      if($this->oauth2Authenticate($imap, $email, $accessToken)) {
+         return $imap;
+      } else {
+         return '';
+      }
+   }
+
+
+
+   public function download_users_emails($email, $accessToken) {
+      $last_msg_id = -1;
+      $from = 1;
+
+      if(!$email || !$accessToken) { return 0; }
+
+      $imap = $this->try_imap_login($email, $accessToken);
+
+      if($imap) {
+
+         $storage = new Zend_Mail_Storage_Imap($imap);
+         $storage->selectFolder('[Gmail]/All Mail');
+
+         $from = $this->get_last_message_id_by_unique_id($email, $storage) + 1;
+
+         //print "will download messages from: $from\n";
+
+
+         $num = $storage->countMessages();
+
+         $to = $from;
+
+         while($from <= $num) {
+            if($num - $from > 9) { $delta = 9; }
+            else { $delta = $num-$from; }
+
+            $to = $from + $delta;
+
+            //print "downloading $from, $to\n";
+
+            $unique_msg_id = $storage->getUniqueId($to);
+
+            $messages = $storage->piler_batch_fetch($from, $to);
+
+            while(list($k, $v) = each($messages)) {
+               $uuid = $storage->getUniqueId($k);
+
+               $tmpname = DIR_TMP . "piler-" . $email . "-" . $k . "-" . $uuid . ".eml";
+               $f = fopen($tmpname, "w+");
+               if($f){
+                  fwrite($f, $v['RFC822.HEADER'] . $v['RFC822.TEXT']);
+                  fclose($f);
+               }
+               //print "k: $k\n";
+            }
+
+            $this->update_imap_table($email, $unique_msg_id, $to);
+
+            $from += $delta + 1;
+         }
+
+
+
+     }
+
+   }
+
+
+   private function get_last_message_id_by_unique_id($email = '', $storage) {
+      if($email == '') { return 0; }
+
+      $query = $this->db->query("SELECT last_msg_id FROM " . TABLE_GOOGLE_IMAP . " WHERE email=? ORDER BY last_msg_id DESC", array($email));
+      if(isset($query->rows)) {
+         foreach ($query->rows as $q) {
+            try {
+               $num = $storage->getNumberByUniqueId($q['last_msg_id']);
+               return $num;
+            }
+            catch(Exception $exception) {}
+         }
+      }
+
+      return 0;
+   }
+
+
+   private function update_imap_table($email, $unique_msg_id, $id) {
+      $query = $this->db->query("INSERT INTO " . TABLE_GOOGLE_IMAP . " (id, email, last_msg_id) VALUES(?,?,?)", array($id, $email, $unique_msg_id));
+
+      return $this->db->countAffected();
+   }
+
+
+}
+
+?>