<?php
/**
 *	프로그램명	: 갈쿠리
 *	버젼				: 1.0.0.2
 *	변경일			: 2006-09-10
 *	작성자			: 강용석
 *	메일				: wyseburn(at)gmail.com
 *	용도				: 텍스트 파싱
 */

class GalKuRi {
	// public
	var $response_header		= '';				// 응답헤더 저장
	var $contents					= '';				// 페이지 전체 내용 저장
	var $parse_value				= array();		// 결과가 저장될 배열

	// private
	var $_goods_no				= 0;				// 결과배열에 저장할때 쓰일 상품 번호
	var $_offset						= 0;				// 검색 시작 번지
	var $_page_no					= 0;				// 페이지 별로 읽을 경우 페이지 번호 저장변수
	var $_page_var					= '';				// 페이지 별로 읽을 경우 페이지 변수명을 저장하는 변수
	var $_parse_pattern			= array();		// 읽어들일 문자 패턴 2차원배열
	var $_process_func			= '';				// 페이지 별로 처리할때 결과를 처리할 외부함수
	var $_roop						= 1;				// 페이지를 계속 파싱할지 여부
	var $_set_cookies			= '';				// 쿠키 저장
	var $_set_referer				= '';				// 레퍼러 저장
	var $_skip_offset				= array();		// 건너뛸 문장
	var $_wait							= 0;				// 한페이지 처리후 멈춤시간(단위 초)

	/**
	 * public
	 * 쿠키를 설정합니다.
	 * ex) $buf->voidSetCookie(쿠키명,쿠키값);
	 */
	function voidSetCookie($var,$value) {
		$this->_set_cookies .= $var.'='.urlencode($value).';';
	}

	/**
	 * public
	 * 레퍼러를 설정합니다.
	 * ex) $buf->voidSetReferer(레퍼러);
	 */
	function voidSetReferer($ref) {
		$this->_set_referer = $ref;
	}

	/**
	 * public
	 * 페이지 처리를 원할경우 설정
	 * ex) $buf->voidSetPage(페이지변수명,[외부처리함수],[시작페이지]);
	 * 하나의 주소에 연속된 페이지가 존재할경우 계속 읽어들일수 있습니다.
	 *
	 * 페이지변수 pagenum=1,2,3,4,5 식으로 페이지가 존재하는 경우
	 * ex) $buf->voidSetPage('pagenum','func',1);
	 *
	 * 주의) 페이지가 많을경우 배열에 결과값이 계속 쌓이므로 리소스가 커질수 있으니
	 * 생성자에 설정할수 있는 외부 함수를 이용하여 페이지 마다 바로 처리하시기 바라며
	 * 역시나 시간이 오래 걸릴수 있으니 쉘모드에서 실행하시기 바랍니다.
	 */
	function voidSetPage($var,$func='',$page=1) {
		$this->_page_var = $var;
		$this->_page_no = $page;
		$this->_process_func = $func;
	}

	/**
	 * public
	 * 페이지 처리시 완료후 잠시 멈춰있을 시간입니다.
	 * ex) $buf->voidSetSleep(초);
	 */
	function voidSetSleep($sec) {
		$this->_wait = $sec;
	}

	/**
	 * public
	 * 파싱할 패턴문자 설정
	 * ex) $buf->voidSetPattern(필드명,시작문자,끝문자,[지울문자]);
	 *
	 * 텍스트 내용중 < 와 > 사이에 있는 문자열을 name 이라는 이름으로 빼내고
	 * 결과문자열중 \ 를 지우고자 하는경우
	 * ex) $buf->voidSetPattern('name','<','>','\');
	 */
	function voidSetPattern($field,$token_start,$token_end,$del_str='') {
		if($field == '_default_')
			$this->voidError('_default_ 는 사용할수 없는 단어입니다.' );

		$this->_parse_pattern[$field] = array($token_start,$token_end,$del_str);
	}

	/**
	 * public
	 * 파싱후 패턴과 동일한 문자가 중간에 존재하여 그부분의 뒷부분 부터 파싱을 원할경우
	 * ex) $buf->voidSetSkipOffset(필드명,찾을문자);
	 *
	 * name 필드 파싱후 다음 파싱 패턴과 동일한 문자가 있을경우 건너뜀
	 * ex) $buf->voidSetSkipOffset('name','<');
	 *
	 * 필드명을 _default_ 라고 설정할경우 파싱전 해당 문자로 이동을 한후에
	 * 파싱을 시작함. default 시작위치를 설정
	 * ex) $buf->voidSetSkipOffset('_default_','<');
	 */
	function voidSetSkipOffset($field,$token) {
		$this->_skip_offset[$field] = $token;
	}

	/**
	 * public
	 * 전체 페이지 내용을 긁어오는 부분입니다.
	 * ex) $buf->voidGetAllContents(주소,[메소드],[포트]);
	 *
	 * 결과 값은 
	 * $buf->response_header; 응답헤더만 별도 저장
	 * $buf->contents; 전체페이지 내용저장
	 */
	function voidGetAllContents($url,$method = 'get',$port = '80') {
		if($method != 'get' && $method != 'post')
			$this->voidError('method 값이 다릅니다. '.$method);

		$url_info = parse_url($url);
		$fp = fsockopen($url_info['host'], $port, $errno, $errstr);
		if(!$fp) {
			$this->voidError($errstr.' ('.$errno.')');
		}
		
		if($method == 'post')	{
			fputs($fp,"POST ".$url_info['path']." HTTP/1.0\r\n");
			fputs($fp,"Host: ".$url_info['host']."\r\n");
			fputs($fp,"User-Agent: PHP Script\r\n");

			if($this->_set_referer) 
				fputs($fp,"Referer: ".$this->_set_referer."\r\n");

			if($this->_set_cookies)
				fputs($fp,"Cookie: ".$this->_set_cookies."\r\n");

			fputs($fp,"Content-Type: application/x-www-form-urlencoded\r\n");
			fputs($fp,"Content-Length: ".strlen($url_info['query'])."\r\n");
			fputs($fp,"Connection: close\r\n\r\n");
			fputs($fp,$url_info['query']);
		}
		else {
			fputs($fp,"GET ".$url_info['path'].($url_info['query'] ? '?'.$url_info['query'] : '')." HTTP/1.0\r\n");
			fputs($fp,"Host: ".$url_info['host']."\r\n");
			fputs($fp,"User-Agent: PHP Script\r\n");

			if($this->_set_referer) 
				fputs($fp,"Referer: ".$this->_set_referer."\r\n");

			if($this->_set_cookies)
				fputs($fp,"Cookie: ".$this->_set_cookies."\r\n");

			fputs($fp,"Connection: close\r\n\r\n");
		}

		$this->contents = '';
		$this->response_header = '';

		while(trim($buf = fgets($fp,1024)) != "") { //응답헤더를 읽어옵니다.
			$this->response_header .= $buf;
		}

		while(!feof($fp)) { //내용을 읽어옵니다.
			$this->contents .=  fgets($fp,1024);
		}
		fclose($fp);
	}

	/**
	 * public
	 * 파싱하는 부분 main 이 되겠습니다.
	 * 페이징 처리와 계속 파싱할것인지 결정을 하고
	 * 외부함수 처리 역시 여기서 합니다.
	 * ex) $buf->voidParsePage(주소,[메소드],[포트]);
	 *
	 * _default_ 오프셋이 있으면 그쪽으로 이동시키고 패턴에 등록된 것만큼 반복을 합니다.
	 * name,img,price 패턴이 등록되 있다면
	 * name파싱,img파싱,price파싱을 계속 반복합니다.
	 * 더이상 내용이 없다면 종료시키거나 페이지설정이 되있다면
	 * 다음페이지를 읽어들여서 다시 파싱을 반복하고 페이지가 없을때까지 반복 파싱.
	 */
	function voidParsePage($url,$method = 'get',$port = '80') {
		$this->_roop = 1;
		$page_now = $this->_page_no;
		$page = '';
		$key = array_keys($this->_parse_pattern);
		$cnt=count($key);

		while($this->_roop) {
			$this->_goods_no = 0;
			$this->_offset = 0;
			$parse_count = 0;
			$this->voidGetAllContents($url.$page,$method,$port);
		
			if($this->_skip_offset['_default_'])
				$this->voidGetOffset($this->_skip_offset['_default_']);

			if($this->_roop) {
				while($this->_roop) {
					for($i=0;$i<$cnt;$i++) {
						$this->voidGetText($key[$i]);
						if(!$this->_roop) {
							unset($this->parse_value[$this->_goods_no]);
							break;
						}
						$parse_count++;
					}
					$this->_goods_no++;
				}
			}

			if($this->_page_var) {
				if($parse_count >= $cnt) {
					$page = '&'.$this->_page_var.'='.(++$page_now);
					$this->_roop = 1;
					if($this->_wait)
						sleep($this->_wait);
				}
				else {
					$this->_roop = 0;
					break;
				}
			}
			
			if($this->_process_func) {
				call_user_func($this->_process_func,$this->parse_value);
				$this->parse_value = array();
			}
		}
	}

	/**
	 * private
	 * 검색위치를 건너뛰는 부분입니다.
	 * ex) $buf->voidGetOffset(문자);
	 * 해당문자가 없으면 종료합니다.
	 */
	function voidGetOffset($str) {
		$tmp_offset = strpos($this->contents,$str,$this->_offset);
		if($tmp_offset)
			$this->_offset = $tmp_offset + strlen($str);
		else
			$this->_roop = 0;
	}

	/**
	 * private
	 * 패턴 사이의 문자열을 추출하는 부분입니다.
	 * ex) $buf->voidGetText(필드);
	 * 역시나 해당문자가 없으면 종료합니다.
	 */
	function voidGetText($field) {
		$spos = strpos($this->contents,$this->_parse_pattern[$field][0],$this->_offset);
		if(!$spos) {
			$this->_roop = 0;
			return;
		}
		$spos += strlen($this->_parse_pattern[$field][0]);

		$epos = strpos($this->contents,$this->_parse_pattern[$field][1],$spos);
		if(!$epos) {
			$this->_roop = 0;
			return;
		}
		$this->_offset = $epos + strlen($this->_parse_pattern[$field][1]);

		$str = substr($this->contents,$spos,$epos-$spos);

		if($this->_parse_pattern[$field][2])
			$this->parse_value[$this->_goods_no][$field] = str_replace("\r\n",'',str_replace($this->_parse_pattern[$field][2],'',trim($str)));
		else
			$this->parse_value[$this->_goods_no][$field] = str_replace("\r\n",'',trim($str));

		if($this->_skip_offset[$field])
			voidGetOffset($this->_skip_offset[$field]);
	}

	function voidError($msg) {
		exit($msg);
	}
	
	function voidReset() {
		// public
		$this->response_header		= '';				// 응답헤더 저장
		$this->contents				= '';				// 페이지 전체 내용 저장
		$this->parse_value				= array();		// 결과가 저장될 배열
	
		// private
		$this->_goods_no				= 0;				// 결과배열에 저장할때 쓰일 상품 번호
		$this->_offset					= 0;				// 검색 시작 번지
		$this->_page_no				= 0;				// 페이지 별로 읽을 경우 페이지 번호 저장변수
		$this->_page_var				= '';				// 페이지 별로 읽을 경우 페이지 변수명을 저장하는 변수
		$this->_parse_pattern			= array();		// 읽어들일 문자 패턴 2차원배열
		$this->_process_func			= '';				// 페이지 별로 처리할때 결과를 처리할 외부함수
		$this->_roop					= 1;				// 페이지를 계속 파싱할지 여부
		$this->_set_cookies			= '';				// 쿠키 저장
		$this->_set_referer				= '';				// 레퍼러 저장
		$this->_skip_offset				= array();		// 건너뛸 문장
		$this->_wait					= 0;				// 한페이지 처리후 멈춤시간(단위 초)
	}
}
?>