<?php

namespace Zotlabs\Module;

use App;
use Zotlabs\Web\Controller;
use Zotlabs\Lib\Libzotdir;
use Zotlabs\Lib\Libsync;
use Zotlabs\Lib\LibBlock;

require_once('include/socgraph.php');
require_once('include/bbcode.php');
require_once('include/html2plain.php');

define( 'DIRECTORY_PAGESIZE', 60);

class Directory extends Controller {

	function init() {
		App::set_pager_itemspage(DIRECTORY_PAGESIZE);
	
		if (x($_GET,'ignore') && local_channel()) {
			q("insert into xign ( uid, xchan ) values ( %d, '%s' ) ",
				intval(local_channel()),
				dbesc($_GET['ignore'])
			);
			
			Libsync::build_sync_packet(local_channel(), [ 'xign' => [ [ 'uid' => local_channel(), 'xchan' => $_GET['ignore'] ]]] );	
			if ($_REQUEST['return']) {
				goaway(z_root() . '/' . base64_decode($_REQUEST['return']));
			}
			goaway(z_root() . '/directory?f=&suggest=1');
		}
	
		$observer = get_observer_hash();
		$global_changed = false;
		$safe_changed = false;
		$type_changed = false;
	
		if (array_key_exists('global',$_REQUEST)) {
			$globaldir = intval($_REQUEST['global']);
			if (get_config('system','localdir_hide')) {
				$globaldir = 1;
			}
			$global_changed = true;
		}
		if ($global_changed) {
			$_SESSION['globaldir'] = $globaldir;
			if ($observer) {
				set_xconfig($observer,'directory','globaldir',$globaldir);
			}
		}
	
		if (array_key_exists('safe',$_REQUEST)) {
			$safemode = intval($_REQUEST['safe']);
			$safe_changed = true;
		}
		if ($safe_changed) {
			$_SESSION['safemode'] = $safemode;
			if ($observer) {
				set_xconfig($observer,'directory','safemode',$safemode);
			}
		}
	
		if (array_key_exists('type',$_REQUEST)) {
			$type = intval($_REQUEST['type']);
			$type_changed = true;
		}
		if ($type_changed) {
			$_SESSION['chantype'] = $type;
			if ($observer) {
				set_xconfig($observer,'directory','chantype',$type);
			}
		}
	}
	
	function get() {
	
		if (observer_prohibited()) {
			notice( t('Public access denied.') . EOL);
			return;
		}

		$observer = get_observer_hash();

		if (get_config('system','block_public_directory',true) && (! $observer)) {
			notice( t('Public access denied.') . EOL);
			return login(false);
		}
			
		$globaldir = Libzotdir::get_directory_setting($observer, 'globaldir');

		// override your personal global search pref if we're doing a navbar search of the directory
		if (intval($_REQUEST['navsearch'])) {
			$globaldir = 1;
		}
	
		$safe_mode = Libzotdir::get_directory_setting($observer, 'safemode');
	
		$type = Libzotdir::get_directory_setting($observer, 'chantype');
	
		$o = '';
		nav_set_selected('Directory');
	
		if (x($_POST,'search')) {
			$search = notags(trim($_POST['search']));
		}
		else {
			$search = ((x($_GET,'search')) ? notags(trim(rawurldecode($_GET['search']))) : '');
		}
	
		if (strpos($search,'=')) {
			$advanced = $search;
		}
	
		$keywords = (($_GET['keywords']) ? $_GET['keywords'] : '');
	
		// Suggest channels if no search terms or keywords are given
		$suggest = (local_channel() && x($_REQUEST,'suggest')) ? $_REQUEST['suggest'] : '';
	
		if ($suggest) {

			// the directory options have no effect in suggestion mode
			
			$globaldir = 1;
			$safe_mode = 1;
			$type = 0;

			// only return DIRECTORY_PAGESIZE suggestions as the suggestion sorting
			// only works if the suggestion query and the directory query have the
			// same number of results

			App::set_pager_itemspage(60);
			$r = suggestion_query(local_channel(),get_observer_hash(),App::$pager['start'],DIRECTORY_PAGESIZE);

			if (! $r) {
				notice( t('No default suggestions were found.') . EOL);
				return;
			}
	
			// Remember in which order the suggestions were
			$addresses = array();
			$common = array();
			$index = 0;
			foreach ($r as $rr) {
				$common[$rr['xchan_hash']] = ((intval($rr['total']) > 0) ? intval($rr['total']) - 1 : 0);
				$addresses[$rr['xchan_hash']] = $index++;
			}
	
			// Build query to get info about suggested people
			$advanced = '';
			foreach (array_keys($addresses) as $address) {
				$advanced .= "xhash=\"$address\" ";
			}
			// Remove last space in the advanced query
			$advanced = rtrim($advanced);
	
		}
	
		$tpl = get_markup_template('directory_header.tpl');
	
		$dirmode = intval(get_config('system','directory_mode'));

		$directory_admin = false;

		$url = z_root() . '/dirsearch';
		if (is_site_admin()) {
			$directory_admin = true;
		}
	
		$contacts = array();
	
		if (local_channel()) {
			$x = q("select abook_xchan from abook where abook_channel = %d",
				intval(local_channel())
			);
			if ($x) {
				foreach ($x as $xx) {
					$contacts[] = $xx['abook_xchan'];
				}
			}
		}
	
		if ($url) {
	
			$numtags = get_config('system','directorytags');
	
			$kw = ((intval($numtags) > 0) ? intval($numtags) : 50);
	
			if (get_config('system','disable_directory_keywords')) {
				$kw = 0;
			}
	
			$query = $url . '?f=&kw=' . $kw . (($safe_mode != 1) ? '&safe=' . $safe_mode : '');
	
			if ($token) {
				$query .= '&t=' . $token;
			}
			
			if (! $globaldir) {
				$query .= '&hub=' . App::get_hostname();
			}
			if ($search) {
				$query .= '&name=' . urlencode($search) . '&keywords=' . urlencode($search);
			}
			if (strpos($search,'@')) {
				$query .= '&address=' . urlencode($search);
			}
			if ($keywords) {
				$query .= '&keywords=' . urlencode($keywords);
			}
			if ($advanced) {
				$query .= '&query=' . urlencode($advanced);
			}
			if (! is_null($type)) {
				$query .= '&type=' . intval($type);
			}
			$directory_sort_order = get_config('system','directory_sort_order');
			if (! $directory_sort_order) {
				$directory_sort_order = 'date';
			}
	
			$sort_order  = ((x($_REQUEST,'order')) ? $_REQUEST['order'] : $directory_sort_order);
	
			if ($sort_order) {
				$query .= '&order=' . urlencode($sort_order);
			}
				
			if (App::$pager['page'] != 1) {
				$query .= '&p=' . App::$pager['page'];
			}
	
			logger('mod_directory: query: ' . $query);
	
			$x = z_fetch_url($query);
			// logger('directory: return from upstream: ' . print_r($x,true), LOGGER_DATA);
	
			if ($x['success']) {
				$t = 0;
				$j = json_decode($x['body'],true);
				if ($j) {
	
					if ($j['results']) {

						$results = $j['results'];
						if ($suggest) {
							// change order to "number of common friends descending"
							$results = self::reorder_results($results,$addresses);
						}

						$entries = array();
	
						$photo = 'thumb';
	
						foreach ($results as $rr) {
	
							$profile_link = chanlink_url($rr['url']);
			
							$pdesc = (($rr['description']) ? $rr['description'] . '<br>' : '');
							$connect_link = ((local_channel()) ? z_root() . '/follow?f=&url=' . urlencode($rr['address']) : ''); 		
	
							// Checking status is disabled ATM until someone checks the performance impact more carefully
							//$online = remote_online_status($rr['address']);
							$online = '';
	
							if (in_array($rr['hash'],$contacts)) {
								$connect_link = '';
							}
	
							$location = '';
							if (strlen($rr['locale'])) {
								$location .= $rr['locale'];
							}
							if (strlen($rr['region'])) {
								if (strlen($rr['locale'])) {
									$location .= ', ';
								}
								$location .= $rr['region'];
							}
							if (strlen($rr['country'])) {
								if (strlen($location)) {
									$location .= ', ';
								}
								$location .= $rr['country'];
							}
	
							$age = '';
							if (strlen($rr['birthday'])) {
								if (($years = age($rr['birthday'],'UTC','')) > 0) {
									$age = $years;
								}
							}
	
							$page_type = '';
	
							$total_ratings = '';
	
							$profile = $rr;
	
							$gender = ((x($profile,'gender') == 1) ? t('Gender: ') . $profile['gender']: False);
							$marital = ((x($profile,'marital') == 1) ?  t('Status: ') . $profile['marital']: False);	
							$homepage = ((x($profile,'homepage') == 1) ?  t('Homepage: ') : False);
							$homepageurl = ((x($profile,'homepage') == 1) ?  html2plain($profile['homepage']) : '');
							$hometown = ((x($profile,'hometown') == 1) ? html2plain($profile['hometown'])  : False);
							$about = ((x($profile,'about') == 1) ? zidify_links(bbcode($profile['about'])) : False);
							
							$keywords = ((x($profile,'keywords')) ? $profile['keywords'] : '');
	
							$out = '';
	
							if ($keywords) {
								$keywords = str_replace(',',' ', $keywords);
								$keywords = str_replace('  ',' ', $keywords);
								$karr = explode(' ', $keywords);
	
								if ($karr) {
									if (local_channel()) {
										$pk = q("select keywords from profile where uid = %d and is_default = 1 limit 1",
											intval(local_channel())
										);
										if ($pk) {
											$keywords = str_replace(',',' ', $pk[0]['keywords']);
											$keywords = str_replace('  ',' ', $keywords);
											$marr = explode(' ', $keywords);
										}
									}
									foreach ($karr as $k) {
										if (strlen($out)) {
											$out .= ', ';
										}
										if ($marr && in_arrayi($k,$marr)) {
											$out .= '<a href="' . z_root() . '/directory/f=&keywords=' . urlencode($k)  .'"><strong>' . $k . '</strong></a>';
										}
										else {
											$out .= '<a href="' . z_root() . '/directory/f=&keywords=' . urlencode($k)  .'">' . $k . '</a>';
										}
									}
								}
							}
	
							$entry = [ 
								'id'                => ++ $t,
								'profile_link'      => $profile_link,
								'type'              => $rr['type'],
								'photo'             => $rr['photo'],
								'hash'              => $rr['hash'],
								'alttext'           => $rr['name'] . ((local_channel() || remote_channel()) ? ' ' . $rr['address'] : ''),
								'name'              => $rr['name'],
								'age'               => $age,
								'age_label'         => t('Age:'),
								'profile'           => $profile,
								'address'           => $rr['address'],
								'nickname'          => substr($rr['address'],0,strpos($rr['address'],'@')),
								'location'          => $location,
								'location_label'    => t('Location:'),
								'gender'            => $gender,
								'total_ratings'     => $total_ratings,
								'viewrate'          => true,
								'canrate'           => (($rating_enabled && local_channel()) ? true : false),
								// 'network'           => network_to_name($rr['network']),
								// 'network_label'     => t('Network:'),
								'pdesc'	            => $pdesc,
								'pdesc_label'       => t('Description:'),
								'censor'            => (($directory_admin) ? 'dircensor/' . $rr['hash'] : ''),
								'censor_label'      => (($rr['censored']) ? t('Uncensor') : t('Censor')),
								'marital'           => $marital,
								'homepage'          => $homepage,
								'homepageurl'       => (($safe_mode) ? $homepageurl : linkify($homepageurl)),
								'hometown'          => $hometown,
								'hometown_label'    => t('Hometown:'),
								'about'             => $about,
								'about_label'       => t('About:'),
								'conn_label'        => t('Connect'),
								'forum_label'       => t('Group'), 
								'collections_label' => t('Collection'), 
								'connect'           => $connect_link,
								'online'            => $online,
								'kw'                => (($out) ? t('Keywords: ') : ''),
								'keywords'          => $out,
								'ignlink'           => $suggest ? z_root() . '/directory?ignore=' . $rr['hash'] : '',
								'ignore_label'      => t('Don\'t suggest'),
								'common_friends'    => (($common[$rr['address']]) ? intval($common[$rr['address']]) : ''),
								'common_label'      => t('Common connections (at least):'),
								'common_count'      => intval($common[$rr['address']]),
								'safe'              => $safe_mode
							];
	
							if (LibBlock::fetch_by_entity(local_channel(), $entry['hash'])) {
								continue;
							}
							
							$arr = array('contact' => $rr, 'entry' => $entry);
	
							call_hooks('directory_item', $arr);
	
							unset($profile);
							unset($location);
	
							if (! $arr['entry']) {
								continue;
							}			
							
							if ($sort_order == '' && $suggest) {
								$entries[$addresses[$rr['address']]] = $arr['entry']; // Use the same indexes as originally to get the best suggestion first
							}
							else {
								$entries[] = $arr['entry'];
							}
						}
	
						ksort($entries); // Sort array by key so that foreach-constructs work as expected
	
						if ($j['keywords']) {
							App::$data['directory_keywords'] = $j['keywords'];
						}
	
						// logger('mod_directory: entries: ' . print_r($entries,true), LOGGER_DATA);
	
	
						if ($_REQUEST['aj']) {
							if ($entries) {
								$o = replace_macros(get_markup_template('directajax.tpl'), [ '$entries' => $entries ] );
							}
							else {
								$o = '<div id="content-complete"></div>';
							}
							echo $o;
							killme();
						}
						else {
							$maxheight = 94;
	
							$dirtitle = (($globaldir) ? t('Network Directory (channels known to this site)') : t('Local Directory'));
	
							$o .= "<script> var page_query = '" . escape_tags(urlencode($_GET['req'])) . "'; var extra_args = '" . extra_query_args() . "' ; divmore_height = " . intval($maxheight) . ";  </script>";
							$o .= replace_macros($tpl, [
								'$search'      => $search,
								'$desc'        => t('Find'),
								'$finddsc'     => t('Finding:'),
								'$safetxt'     => htmlspecialchars($search,ENT_QUOTES,'UTF-8'),
								'$entries'     => $entries,
								'$dirlbl'      => $suggest ? t('Channel Suggestions') : $dirtitle,
								'$submit'      => t('Find'),
								'$next'        => alt_pager($j['records'], t('next page'), t('previous page')),
								'$sort'        => t('Sort options'),
								'$normal'      => t('Alphabetic'),
								'$reverse'     => t('Reverse Alphabetic'),
								'$date'        => t('Newest to Oldest'),
								'$reversedate' => t('Oldest to Newest'),
								'$suggest'     => $suggest ? '&suggest=1' : ''
							]);
						}
					}
					else {
						if ($_REQUEST['aj']) {
							$o = '<div id="content-complete"></div>';
							echo $o;
							killme();
						}
						if (App::$pager['page'] == 1 && $j['records'] == 0) {
							if (strpos($search,'@')) {
								goaway(z_root() . '/chanview/?f=&address=' . $search);
							}
							else {
								$r = q("select xchan_hash from xchan where xchan_name = '%s' limit 1",
									dbesc($search)
								);
								if ($r) {
									goaway(z_root() . '/chanview/?f=&hash=' . urlencode($r[0]['xchan_hash']));
								}
							}
						}
						info( t("No entries (some entries may be hidden).") . EOL);
					}
				}
			}
		}
		return $o;
	}


	static public function reorder_results($results,$suggests) {
		if (! $suggests) {
			return $results;
		}

		$out = [];
		foreach ($suggests as $k => $v) {
			foreach ($results as $rv) {
				if ($k == $rv['hash']) {
					$out[intval($v)] = $rv;
					break;
				}
			}
		}
		return $out;
	}
	
}