Changeset 5341 for trunk/prototype/services/ImapServiceAdapter.php

Timestamp:

01/10/12 11:25:51 (12 years ago)

Author:

wmerlotto

Message:

Ticket #2434 - Commit inicial do novo módulo de agenda do Expresso - expressoCalendar

File:

• trunk/prototype/services/ImapServiceAdapter.php (modified) (8 diffs)

trunk/prototype/services/ImapServiceAdapter.php

@@ -1 +1 @@
 <?php
 
-include_once "../header.session.inc.php";
-
-include_once "../expressoMail1_2/inc/class.imap_functions.inc.php";
+include_once ROOTPATH."/../header.session.inc.php";
+
+include_once ROOTPATH."/../expressoMail1_2/inc/class.imap_functions.inc.php";
 
 class ImapServiceAdapter extends imap_functions/* implements Service*/
@@ -12 +12 @@
     }
 
-    public function connect( $config )
-    {
-        $this->init();
-    }
-
-    public function find( $URI, $context, $justthese = false, $criteria = false )
-    {
+//     public function connect( $config )
+//     {
+//      $this->init();
+//     }
         
-        if( is_array($URI) )
+    public function find( $URI, $justthese = false, $criteria = false )
         { 
-            $criteria = $justthese;
-            $justthese = $context;
-            $context = $URI['context'];
+        $context = $justthese['context'];
             $URI = $URI['concept'];
-        }
 
         switch( $URI )
@@ -54 +48 @@
                 $sord  = $criteria['sord']; //{desc} get the direction
 
+                $filter = $criteria['filter'];
+
                 if( !$sidx ) $sidx = 1;
 
                 $folder_name = str_replace( '.', $this->imap_delimiter, $context['folder'] );
                 
-                $folder = $this->get_range_msgs2(array('folder'=>$folder_name));
-
-                $count = $folder['num_msgs'];
+                $count = imap_num_msg( $this->open_mbox( $folder_name ) );
 
                 $total_pages = $count > 0 ? ceil( $count/$limit ) : 0;
@@ -67 +61 @@
                     $page = $total_pages;
 
-                $start = $limit * $page - $limit; // do not put $limit*($page - 1)
+                $start = $limit * $page - $limit;
+
+                // do not put $limit*($page - 1)
                 //end: for grid
 
-                $service_params = array( 'folder' => $folder_name, //INBOX
+                if( $filter )
+                {
+                    if( $filter[0] !== 'msgNumber' )
+                    {
+                        for( $i = 0; $i < count($filter); $i++ )
+                        {
+                            if( count( $filter[$i] ) === 4 )
+                                $criteria['isExact'] = ( array_shift( $filter[$i] ) === 'AND' );
+
+                            $criteria[ $filter[$i][0] ] = array( 'criteria' => $filter[$i][2], 'filter' => $filter[$i][1] );
+                        }
+
+                        return $this->searchSieveRule($criteria);
+                    }
+
+                    $msgNumber = array();
+
+                    for( $i = $start; $i < $start + $limit && isset( $filter[2][$i] ); $i++ )
+                          $msgNumber[] = $filter[2][$i];
+
+                    if( empty( $msgNumber ) )
+                        return( false );
+
+                    $result = $this->get_info_msgs( array( 'folder' => $folder_name, 
+                                                           'msgs_number' => implode( ',', $msgNumber ) ) );
+
+                    foreach( $result as $i => $val )
+                        $result[$i] = unserialize( $val );
+
+                }
+                else
+                {
+                    $result = $this->get_range_msgs2( array( 'folder' => $folder_name, //INBOX
                                          'msg_range_begin' => $start + 1, //??
                                          'msg_range_end' => $start + $limit, //$limit = $_GET['rows']; // get how many rows we want to have into the grid
                                          'sort_box_type' => 'SORTARRIVAL', 
                                          'search_box_type' => 'ALL',
-                                         'sort_box_reverse' => 1 );
-
-                $result = $this->to_utf8($this->get_range_msgs2($service_params));
+                                                             'sort_box_reverse' => 1 ) );
+                }
                 //return var_export($result);
 
-                $response = array( "page" => $page, "total" => $total_pages, "records" => $result['num_msgs'] );
+                $response = array( "page" => $page, "total" => $total_pages, "records" => $count );
                 
                 for ($i=0; $i<count($result); $i++)
@@ -96 +123 @@
                     {
                                 $response["rows"][$i] = $result[$i];
-                                $response["rows"][$i]['body'] = $this->to_utf8($result[$i]['body']);
-                                $response["rows"][$i]['timestamp'] = ( ( $result[$i]['udate']) * 1000 );
-                                //USA OS TIME ZONES
-                                //$response["rows"][$i]['timestamp'] = ( ( $result[$i]['udate'] + $this->functions->CalculateDateOffset()) * 1000 );
+                        $response["rows"][$i]['timestamp'] = ( ( $result[$i]['udate'] + $this->functions->CalculateDateOffset() ) * 1000 );
                                 $response["rows"][$i]['flags'] = implode(',', $flags_enum);
                                 $response["rows"][$i]['size'] = $response["rows"][$i]['Size'];
-                                $response["rows"][$i]['udate'] = ( $result[$i]['udate'] + $this->functions->CalculateDateOffset()  * 1000 );
+//                      $response["rows"][$i]['udate'] = ( $result[$i]['udate'] + $this->functions->CalculateDateOffset()  * 1000 );
                                 unset($response["rows"][$i]['Size']);
                     }
                  }
+
+                $response = $this->to_utf8($response);
 
                 break;
@@ -113 +139 @@
     }
 
-    public function retrieve( $concept, $id, $parents, $justthese = false, $criteria = false )
-    {
-        return $this->read( array( 'id' => $id, 
-                            'concept' => $concept, 
-                            'context' => $parents ), $justthese );
-    }
+//     public function retrieve( $concept, $id, $parents, $justthese = false, $criteria = false )
+//     {
+//      return $this->read( array( 'id' => $id, 
+//                          'concept' => $concept, 
+//                          'context' => $parents ), $justthese );
+//     }
 
     public function read( $URI, $justthese = false )
     {
-        $folder_name = str_replace( '.', $this->imap_delimiter, $URI['context']['folder'] );
-
-        $response = $this->get_info_msg( array('msg_number'=>$URI['id'],'msg_folder'=>$folder_name) );
-
-        return $this->to_utf8( $response );
+
+        return $this->to_utf8( $this->get_info_msg( array('msg_number'=>$URI['id'],
+                                                                                                          'msg_folder'=>str_replace( '.', $this->imap_delimiter, $justthese['context']['folder'] )) ) );
     }
 
@@ -149 +173 @@
     public function setup()
     {}
+
+    public function commit( $uri )
+    { return( true ); }
+
+    public function rollback( $uri )
+    {}
+
+    public function begin( $uri )
+    {}
+
 
     public function teardown()
@@ -160 +194 @@
                 } 
         } elseif(is_string($in)) { 
-                //if(mb_detect_encoding($in) != "UTF-8") 
                         return mb_convert_encoding( $in , 'UTF-8' , 'UTF-8 , ISO-8859-1' ); 
-                //else 
-                //      return $in; 
         } else { 
                 return $in;