source: trunk/prototype/services/ImapServiceAdapter.php @ 5188

<?php

include_once "../header.session.inc.php";

include_once "../expressoMail1_2/inc/class.imap_functions.inc.php";

class ImapServiceAdapter extends imap_functions/* implements Service*/
{
    public function open( $config )
    {
        $this->init();
    }

    public function connect( $config )
    {
        $this->init();
    }

    public function find( $URI, $context, $justthese = false, $criteria = false )
    {
        
        if( is_array($URI) )
        { 
            $criteria = $justthese;
            $justthese = $context;
            $context = $URI['context'];
            $URI = $URI['concept'];
        }

        switch( $URI )
        {
            case 'folder':
            {
                $result = $this->get_folders_list();

                foreach ($result as $res) {

                    $response[] = array(
                                    'id' => $res['folder_id'],
                                    'commonName' => $res['folder_name'],
                                    'parentFolder' => $res['folder_parent'],
                                    'messageCount' => array('unseen' => isset($res['folder_unseen']) ? $res['folder_unseen'] : null, 'total' => null)
                            );
                }

                break;
            }
            case 'message':
            {
                //begin: for grid       
                $page  = $criteria['page']; //{1}    get the requested page
                $limit = $criteria['rows']; //{10}   get how many rows we want to have into the grid
                $sidx  = $criteria['sidx']; //{id}   get index row - i.e. user click to sort
                $sord  = $criteria['sord']; //{desc} get the direction

                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'];

                $total_pages = $count > 0 ? ceil( $count/$limit ) : 0;

                if( $page > $total_pages )
                    $page = $total_pages;

                $start = $limit * $page - $limit; // do not put $limit*($page - 1)
                //end: for grid

                $service_params = 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));
                //return var_export($result);

                $response = array( "page" => $page, "total" => $total_pages, "records" => $result['num_msgs'] );
                
                for ($i=0; $i<count($result); $i++)
                {
                    $flags_enum = array('Recent', 'Unseen',  'Answered',  'Draft',  'Deleted', 'Flagged');

                    foreach ($flags_enum as $key => $flag)
                    {
                        if ( !isset($result[$i][$flag]) || !trim($result[$i][$flag]) || trim($result[$i][$flag]) == '') 
                                unset($flags_enum[$key]);
                        unset($result[$i][$flag]);
                    }

                    if (array_key_exists($i, $result))
                    {
                                $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]['flags'] = implode(',', $flags_enum);
                                $response["rows"][$i]['size'] = $response["rows"][$i]['Size'];
                                $response["rows"][$i]['udate'] = ( $result[$i]['udate'] + $this->functions->CalculateDateOffset()  * 1000 );
                                unset($response["rows"][$i]['Size']);
                    }
                 }

                break;
            }
        }
        return $response;
    }

    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 );
    }

    public function create( $URI, $data )
    {}

    public function delete( $URI, $justthese = false, $criteria = false )
    {}

    public function deleteAll( $URI, $justthese = false, $criteria = false ) // avaliar
    {}

    public function update( $URI, $data, $criteria = false )
    {}

    public function replace( $URI, $data, $criteria = false )
    {}

    public function close()
    {}

    public function setup()
    {}

    public function teardown()
    {}

    function to_utf8($in) 
    { 
        if (is_array($in)) { 
                foreach ($in as $key => $value) { 
                        $out[$this->to_utf8($key)] = $this->to_utf8($value); 
                } 
        } elseif(is_string($in)) { 
                //if(mb_detect_encoding($in) != "UTF-8") 
                        return utf8_encode($in); 
                //else 
                //      return $in; 
        } else { 
                return $in; 
        } 
        return $out; 
    } 
}