<?php

class Airpress {

	private $virtualPosts;
	private $virtualFields;
	public $debug_output;
	private $loopScope;
	public $debug_stats;

	private $deferred_queries;

	function init(){

		airpress_debug(0,"\n\nAIRPRESS LOADED");

		$this->deferredQueries = array();

		$this->virtualFields = new AirpressVirtualFields();
		$this->virtualFields->init();

		$this->virtualPosts = new AirpressVirtualPosts();
		$this->virtualPosts->init();

		// Populate related field with related records from another table
		add_shortcode( 'apr_populate', array($this,'shortcode_populate') );

		// Display contents of field
		add_shortcode( 'apr', array($this,'shortcode_display') );

		// Include PHP file
		add_shortcode( 'apr_include', array($this, 'shortcode_include'));

		// Loop through collection or array
		add_shortcode( 'apr_loop', array($this,'shortcode_loop') );
		for($i=0;$i<=10;$i++){
			add_shortcode( 'apr_loop'.$i, array($this,'shortcode_loop') );
		}

		// add_action( 'the_content', array($this,"apr_do_shortcodes"), 7);

		add_action( 'wp_footer', array($this,'renderDebugOutput') );
		add_action( 'admin_footer', array($this,'renderDebugOutput') );
		add_action( 'admin_bar_menu', array($this,'renderDebugToggle'), 999 );
		add_action( 'shutdown', array($this,'stash_and_trigger_deferred_queries'));

		$this->loopScope = array();
	}

	public function check_for_update(){
		global $airpress_version;
	    if ( get_option( 'airpress_version' ) != $airpress_version) {
	        
	    	// truncate log files
	    	if ( $airpress_version == "1.1.55" ){
	    		$this->truncate_log_files();
	    	}

	    	update_option("airpress_version", $airpress_version, false);

	    }
	}

	public function simulateVirtualPost($request,$query = null){
		airpress_debug(0,"Simulating Virtual Post",$request);
		if ( is_null($query) ){
			$query = new AirpressQuery();
		}
		$this->virtualPosts->check_for_actual_page( $request, true, $query);
		airpress_debug(0,"Simulated Virtual Post Collection",$this->virtualPosts->AirpressCollection);
		return $this->virtualPosts->AirpressCollection;
	}

	public function apr_do_shortcodes($content = ''){
		global $shortcode_tags;

		$early_run_shortcodes = ["apr","apr_loop","apr_populate"];
		$saved_shortcode_tags = [];

		foreach($shortcode_tags as $tag => $executable){

			if ( ! in_array($tag,$early_run_shortcodes) ){
				$saved_shortcode_tags[$tag] = $executable;
				unset($shortcode_tags[$tag]);
			}

		}

		// only running the early_run_shortcodes
		$content = do_shortcode($content);

		$shortcode_tags = $saved_shortcode_tags;

		return $content;

	}

/* CONFIGURATION FUNCTIONS */

	
	public function shortcode_loop($atts,$content=null,$tag){
		global $post,$airpress;		

	    $a = shortcode_atts( array(
	        'field'				=> null,
	        'default'			=> ""
	    ), $atts );

		if ( is_airpress_empty($post->AirpressCollection) ){
			return "no data found";
		}

	    if ($a["field"] === null){
	    	$records_to_loop = (array)$post->AirpressCollection;
	    } else if ( ! empty($this->loopScope) ){
	    	// This is a nested loop!
	    	$keys = explode("|",$a["field"]);
	    	$field = array_shift($keys);
	    	if (empty($keys)){
	    		$records_to_loop = $this->loopScope[0][$field];
	    	} else {
	    		$records_to_loop = $this->loopScope[0][$field]->getFieldValues($keys);
	    	}
	    } else {
			$keys = explode("|", $a["field"]);
		    $records_to_loop = $post->AirpressCollection->getFieldValues($keys);
	    }

	    preg_match_all("/{{([^}]*)}}/", $content, $matches);

	    $replacementFields = array_unique($matches[1]);

	    if ( empty($records_to_loop) ){

	    	$output = $a["default"];

	    } else {

		    $output = "";

		    foreach($records_to_loop as $record){

		    	// place current record at ZERO
		    	array_unshift($this->loopScope, $record);

		    	// Reset the template for each record
		    	// By doing the shortcodes BEFORE any processing, we're ensuring that
		    	// any nested loops ... or innermost loops are processed prior to outter most loops.
		    	// if we don't do this all {{variables}} will be replaced by outter most loops.
		    	$template = do_shortcode($content);

		    	$output .= airpress_parse_template($template, $record, $replacementFields);

		    	// Take current record back off scope stack
		    	array_shift($this->loopScope);
		    }
		    
	    }

	    return preg_replace("`(<br />\n)+`","<br />\n",$output);
	}

	public function shortcode_populate($atts, $content=null, $tag){
		global $post,$airpress;

		// Check for non-value "flag" attributes. Set to true
		$flags = array("single");
		foreach($atts as $k => $v){
			foreach($flags as $flag){
				if (strtolower($v) == $flag ){
					$atts[$flag] = true;
				}
			}
		}

	    $a = shortcode_atts( array(
	        'field'				=> null,
			'relatedto'			=> null,
			'filterbyformula'	=> null,
			'view'				=> null,
			'sort'				=> null,
			'maxrecords'		=> null,
	    ), $atts );

	    if (isset($post->AirpressCollection)){
	    	$collection = $post->AirpressCollection;
	    } else {
	    	airpress_debug(0,"NO AIRPRESS COLLECTION with which to populate ".$a["field"]);
	    	return null;
	    }

		if ( ! empty($this->loopScope) ){
			airpress_debug(0,"CANNOT POPULATE inside of apr_loop. Move all apr_populate shortcodes to the top of your content.");
			return "apr_populate must be called inside apr_loop, as apr_populate recursively populates records.";
		}

	    $keys = explode("|", $a["field"]);

		// Gather IDs
		$record_ids = $collection->getFieldValues($keys);

		if ( isset($record_ids[0]) && is_airpress_record($record_ids[0]) ){
			// This has ALREADY been populated fool! Move along.
			return;
		}

		$query = new AirpressQuery();
		$query->setConfig($collection->query->getConfig());
	    $query->table($a["relatedto"]);
	    //$query->filterByRelated($record_ids);

	    if (isset($a["filterbyformula"]))
	    	$query->filterByFormula($a["filterbyformula"]);

	    if (isset($a["view"]))
	    	$query->view($a["view"]);

	    if (isset($a["sort"]))
	    	$query->sort($a["sort"]);

	    if (isset($a["maxrecords"]))
	    	$query->maxRecords($a["maxrecords"]);

	    $collection->populateRelatedField($keys,$query);
		// $subCollection = new AirpressCollection($query);
		// $collection->setFieldValues($keys,$subCollection,$query);

	}

	public function shortcode_include($atts, $content=null, $tag){
		global $post,$model;

	    $a = shortcode_atts( array(
	        'path' => null,
	        'value' => null,
			'title' => null
	    ), $atts );

	    $a["path"] = ltrim($a["path"], '/');

	    $filepath = apply_filters("airpress_include_path_pre",$a["path"]);

	    if ( substr(strtolower($filepath), -4) != ".php" ){
	    	$filepath .= ".php";
	    }

	    $filepath = get_stylesheet_directory()."/".$filepath;

	    $filepath = apply_filters("airpress_include_path",$filepath);

	    if (is_file($filepath)){
	    	ob_start();
	    	include($filepath);
	    	$html = ob_get_clean();
	    	return do_shortcode($html);
	    } else {
	    	return $filepath." not found.";
	    }
	}

	public function shortcode_display($atts, $content=null, $tag){
		global $post;

		// Check for non-value "flag" attributes. Set to true
		$flags = array("single");
		foreach($atts as $k => $v){
			foreach($flags as $flag){
				if (strtolower($v) == $flag ){
					$atts[$flag] = true;
				}
			}
		}

	    $a = shortcode_atts( array(
	        'field'				=> null,
			'relatedto'			=> null,
			'recordtemplate'	=> null,
			'relatedtemplate'	=> null,
			'wrapper'			=> null,
			'single'			=> null,
			'rollup'			=> null,
			'condition'			=> null,
			'default'			=> "",
			'format'			=> null,
			'loopscope'			=> null,
			'glue'				=> "\n",
	    ), $atts );

	    $field_name = $a["field"];

	    $single = (!isset($a["single"]) || strtolower($a["single"]) == "false")? false : true;

	    $condition = ( isset($a["condition"]) )? $a["condition"] : false;

		$recordTemplate = (isset($a["recordtemplate"]))? $a["recordtemplate"] : "%s\n";
		$relatedTemplate = (isset($a["relatedtemplate"]))? $a["relatedtemplate"] : "%s\n";

   		$keys = explode("|", $a["field"]);
   		$values = array();

   		$condition_match = true;

   		if ( ! empty($this->loopScope) ){

   			$scope = ( is_null($a["loopscope"]) ) ? 0 : count($this->loopScope) - $a["loopscope"] - 1;

   			airpress_debug(0,"asking for $field_name: ".$scope." of ".count($this->loopScope));

   			$field = array_shift($keys);
   			
   			if ( $condition && ( empty($keys) || is_airpress_attachment($this->loopScope[$scope][$field]) ) ){

				list($condition_field,$condition_value) = explode("|",$condition);
				if ( $this->loopScope[$scope][$condition_field] != $condition_value){
					$condition_match = false;
				}
			}

			if ( $condition_match ):

				if ( $field == "record_id" ){
					$values = array($this->loopScope[$scope]->record_id());
				} else if ( is_string($this->loopScope[$scope][$field]) ){

					if ( $condition ){
						list($condition_field,$condition_value) = explode("|",$condition);
						if ( $this->loopScope[$scope][$condition_field] == $condition_value){
							$values = array($this->loopScope[$scope][$field]);
						}
					} else {
	   					$values = array($this->loopScope[$scope][$field]);
					}

	   			} else if ( is_array($this->loopScope[$scope][$field]) ){

		   			// If the intended field is an attachment, then can't treat as collection
		   			if ( is_airpress_attachment($this->loopScope[$scope][$field]) ){

						$values = array();
						foreach( $this->loopScope[$scope][$field] as $attachment ){
							$values[] = airpress_getArrayValues($attachment,$keys);
						}

					} else {
						$values = airpress_getArrayValues($this->loopScope[$scope][$field],$keys);
					}

	   			} else if ( is_airpress_collection($this->loopScope[$scope][$field]) ){
	   				
	   				$collection = $this->loopScope[$scope][$field];

	   				if ( ! is_airpress_empty($collection) ){
						$values = $collection->getFieldValues($keys,$condition);
	   				}

	   			}

	   		endif;

   		} else {
   			$collection = $post->AirpressCollection;

   			if ( is_airpress_collection($collection) ){
				$values = $collection->getFieldValues($keys,$condition);
   			} else {
   				airpress_debug(0,"[apr field='".$field_name."'] attempting to be used on a page where there is no collection.",$collection);
   				return "[apr field='".$field_name."'] attempting to be used on a page where there is no collection.";
   			}
			
   		}

   		// when a condition is set, we don't want to show a bunch of empty rows output
   		// for all the unmet conditions.
		if ( $condition ){

			$values = array_filter($values, create_function('$value', 'return $value !== "";'));
			if ( empty($values)){
				$values = null;
			}

		}

		$output = sprintf($a["wrapper"],$a["default"]);

		if ( ! is_null($values) && ! empty($values) ){

			if (isset($a["format"])){

				// a typical filter would be: date|Y-m-d
				// resulting in a hookable filter of: airfield_filter_date

				$f = explode("|", $a["format"]);
				foreach($values as &$value):
					if ( has_filter("airpress_shortcode_filter_".$f[0])){
						$value = apply_filters("airpress_shortcode_filter_".$f[0],$value,$f[1]);
					} else {
						switch ($f[0]){
							case "date":
								$value = date($f[1],strtotime($value));
							break;
						}
					}

				endforeach;
				unset($value);
			}

			if ( is_airpress_record($values[0]) ){
				$keys = $values[0]->array_keys();
				$output = "{$keys[0]} is a related record. You must specify a field for that record. Perhaps [apr field='$field_name|{$keys[0]}']";
			} else if ( is_array($values[0]) && isset($values[0]["url"])){
				$output = "{$field_name} is an image field. You must specify a format for that field. Perhaps [apr field='$field_name|url' single]";
			} else {

				if ($single){
					$values = array($values[0]);
				}

				if ( isset($a["wrapper"]) ){
					$output_values = array();
					foreach($values as $value){
						$output_values[] = sprintf($a["wrapper"],$value);
					}
					$values = $output_values;
				}

				$output = implode($a["glue"], $values);

			}

		}

		// $output = "";
		// foreach($collection as $record){
		// 	foreach($record[$field_name] as $value){
		// 		if (isset($keys)){
		// 			$output .= sprintf($relatedTemplate,$this->array_traverse($value,$keys));
		// 		} else {
		// 			$output .= sprintf($relatedTemplate,$value);
		// 		}
		// 	}

		return apply_filters( 'airpress_shortcode_filter', $output, $atts, $content, $tag );

	}

	####################################
	## DEFERRED
	####################################

	function stash_and_trigger_deferred_queries(){

		if (!empty($this->deferredQueries)){

			$stash_key = "airpress_stash_".microtime(true);
			set_transient($stash_key,$this->deferredQueries,60);
			//trigger async request to process stashed queries
			$start = microtime(true);
			airpress_debug(0,__FUNCTION__."|"."Sending ASYNC request to process ".count($this->deferredQueries)." deferred queries.");
			wp_remote_post(
				admin_url( 'admin-ajax.php' )."?action=airpress_deferred&stash_key=".urlencode($stash_key),
				array(
						"blocking"  => false,
						"timeout"   => 0.01 ,
						'sslverify' => apply_filters( 'https_local_ssl_verify', false )
					)
			);
			airpress_debug(0,__FUNCTION__."|"."DONE in ".(microtime(true) - $start)." seconds");
		}
	}

	function defer_query($query){
		$hash = $query->hash();
		$this->deferredQueries[$hash] = clone $query;
	}

	function run_deferred_queries($stash_key){

		if (has_action("airpress_run_deferred_queries")){
			do_action("airpress_run_deferred_queries",$stash_key);
		} else {
			$deferred_queries = get_transient($stash_key);
			delete_transient($stash_key);
			airpress_debug(0,__FUNCTION__."|"."Processing ".count($deferred_queries)." queries");
			foreach($deferred_queries as $hash => $query){
				$results = AirpressConnect::_get($query);
				airpress_debug(0,__FUNCTION__."|"."Query ".$query->toString()." had ".count($results)." records returned. Que Bella!");
			}
		}

	}

	public function truncate_log_files(){
		$connections = get_airpress_configs("airpress_cx");

		foreach($connections as $config){

			if ( ! empty($config["log"]) && file_exists($config["log"]) && is_writable($config["log"]) ){

				$parts = pathinfo($config["log"]);

				if ( $parts["basename"] == "airpress.log" && $h = @fopen($config["log"], "w") ){
					fclose($h);
				}

			}

		}
	}

	function debug(){

		$args = func_get_args();

		$message = array_shift($args);
		if (!is_string($message)){
			ob_start();
			var_dump($message);
			$message = ob_get_clean();
		}

		if (!empty($args)){
			$expanded = "";
			foreach($args as $input){
				if (!is_string($input)){
					ob_start();
					var_dump($input);
					$expanded .= ob_get_clean()."<Br><Br>";
				}
			}

			$this->debug_output .= "<a class='expander' href='#'>$message</a>";
			$this->debug_output .= "<div class='expandable'>$expanded</div>";
		} else {
			$this->debug_output .= $message;
		}

		$this->debug_output .= "<br><br>";
	
	}

	public function renderDebugOutput(){

		?>
		<style type="text/css">
			#airpress_debugger {
				width:100%;
				font-family: monospace;
				padding:50px;
				font-size: 12px;
				padding-top:100px;
				display:none;
				position: absolute;
				top: 0px;
				left: 0px;
				color:#000000;
				background-color: #f7f7f7;
				z-index:99998;
			}

			#airpress_debugger .expander {
				color: blue !important;
			}
			#airpress_debugger .expandable {
				padding: 20px;
				border: 1px dashed #cccccc;
				display: none;
				white-space: pre-wrap;
			}
		</style>
		<script type="text/javascript">
		jQuery(document).ready(function(){
			jQuery("#wp-admin-bar-airpress_debugger_toggle").click(function(e){
				e.preventDefault();
				jQuery("#airpress_debugger").toggle();
				jQuery('html, body').animate({ scrollTop: 0 }, 'fast');
			});

			jQuery(".expander").click(function(e){
				e.preventDefault();
				jQuery(this).next().fadeToggle();
			});
		});
		</script>
		<div id="airpress_debugger">
		<?php
		// foreach($this->debug_stats as $name => $value){
		// 	echo $name.": ".$value."<br>";
		// }
		?>
		<!-- <hr> -->
		<?php echo $this->debug_output; ?>
		</div>
		<?php
	}

	function renderDebugToggle( $wp_admin_bar ) {
		$args = array(
			'id'    => 'airpress_debugger_toggle',
			'title' => 'Toggle Airpress Debugger',
			'href'  => '#',
			'meta'  => array( 'class' => 'my-toolbar-page' )
		);
		$wp_admin_bar->add_node( $args );
	}


}
?>