root/lang/php/Scraper/library/Diggin/Scraper/Strategy/Xpath.php @ 16913

<?php
/**
 * Diggin - Simplicity PHP Library
 * 
 * LICENSE
 *
 * This source file is subject to the new BSD license.
 * It is also available through the world-wide-web at this URL:
 * http://framework.zend.com/license/new-bsd
 * 
 * @category   Diggin
 * @package    Diggin_Scraper
 * @copyright  2006-2008 sasezaki (http://diggin.musicrider.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 */

require_once 'Diggin/Scraper/Strategy/Abstract.php';

class Diggin_Scraper_Strategy_Xpath extends Diggin_Scraper_Strategy_Abstract 
{
    protected static $_adapter = null;
    protected static $_adapterconfig = null;

    public function __destruct()
    {
       self::$_adapter = null;
       self::$_adapterconfig = null;
       parent::$_adapter = null;
    }
    
    public function setAdapter(Diggin_Scraper_Adapter_Interface $adapter)
    {
        self::$_adapter = $adapter;
    }

    public function setAdapterConfig($config)
    {
        self::$_adapterconfig = $config;
    }
    
    public function getAdapter()
    {
        if (isset(self::$_adapter)) {
            if(self::$_adapterconfig) self::$_adapter->setConfig(self::$_adapterconfig);
            return self::$_adapter;
        }
        
        //コンストラクタで設定されてた時用
        if (parent::$_adapter instanceof Diggin_Scraper_Adapter_Interface) {
            if (self::$_adapterconfig) self::$_adapter->setConfig(self::$_adapterconfig);
            return parent::$_adapter;
        } else { 
            /**
             * @see Diggin_Scraper_Adapter
             */
            require_once 'Diggin/Scraper/Adapter/Htmlscraping.php';
            self::$_adapter = new Diggin_Scraper_Adapter_Htmlscraping();
            if(self::$_adapterconfig) self::$_adapter->setConfig(self::$_adapterconfig);
        }

        return self::$_adapter;
    }

    /**
     * scraping with Xpath
     * 
     * @param Zend_Http_Response $respose
     * @param string $process
     * @return array $results
     */
    public function scrape($respose, $process)
    {
        $simplexml = $this->getAdapter()->readData($respose);
        
        return self::extract($simplexml, $process);
    }
    
    public static function extract($values, $process)
    {
        //↓このハンドリングはxpathの記述自体が間違ってたとき（いらないかな？）
        set_error_handler(
            create_function('$errno, $errstr',
            'if($errno) require_once "Diggin/Scraper/Strategy/Xpath/Exception.php"; 
                throw new Diggin_Scraper_Strategy_Xpath_Exception($errstr, $errno);'
            )
        );
        $results = (array) $values->xpath($process->expression);
        restore_error_handler();

        //        if (count($results) === 0) {
        //        //@todo notice error
        //            require_once 'Diggin/Scraper/Strategy/Exception.php';
        //            throw new Diggin_Scraper_Strategy_Exception("couldn't find By Xpath, Process : $process");            
        //        }
//        if ((isset($results[0])) && ($results[0] === false)) {//これはxpath記述自体が間違ってたとき
//            require_once 'Diggin/Scraper/Strategy/Exception.php';
//            throw new Diggin_Scraper_Strategy_Exception("Couldn't find By Xpath, Process : $process");
//        }
        
        return $results;
    }

    /**
     * get value with DSL
     * 
     * @param Diggin_Scraper_Context
     * @param Diggin_Scraper_Process
     * @return mixed
     */
    public function getValue($values, $process)
    {
        //type
        if (strtoupper(($process->type)) === 'RAW') {
            $strings = $values;
        } elseif (strtoupper(($process->type)) === 'TEXT') {
            $strings = array();
            foreach ($values as $value) {
                $value = strip_tags((string) str_replace('&amp;', '&', $value->asXML()));
                $value = str_replace(array(chr(10), chr(13)), '', $value);
                array_push($strings, $value);
            }
        } elseif (strtoupper(($process->type)) === 'PLAIN') {
            $strings = array();
            foreach ($values as $value) {
                array_push($strings, (string) str_replace('&amp;', '&', $value->asXML()));
            }
                
        } elseif (strpos($process->type, '@') === 0) {
            $strings = array();
            require_once 'Diggin/Scraper/Adapter/Htmlscraping.php';
            foreach ($values as $value) {
                if (($process->type == '@href' OR $process->type == '@src')) {
                    array_push($strings, Diggin_Scraper_Adapter_Htmlscraping::getAbsoluteUrl((string)$value[substr($process->type, 1)], self::$_adapterconfig['url']));

                    //require_once 'Diggin/Uri/Http.php';
                    //array_push($strings, Diggin_Uri_Http::getAbsoluteUrl((string)$value[substr($process->type, 1)], self::$_adapterconfig['url']));
                } else {
                    array_push($strings, (string) $value[substr($process->type, 1)]);
                }
            }
            
        } else {
            require_once 'Diggin/Scraper/Strategy/Exception.php';
            throw new Diggin_Scraper_Strategy_Exception("Unknown value type :".$process->type);
        }
        
        return $strings;
    }

}