<?php
/**
 * Open Source Social Network
 *
 * @package   (openteknik.com).ossn
 * @author    OSSN Core Team <info@openteknik.com>
 * @copyright (C) OpenTeknik LLC
 * @license   Open Source Social Network License (OSSN LICENSE)  http://www.opensource-socialnetwork.org/licence
 * @link      https://www.opensource-socialnetwork.org/
 */
class OssnComponents extends OssnDatabase {
		/**
		 * Get components from compnents directory
		 *
		 * @return array
		 */
		public function getComponentsDir() {
				$dir     = ossn_route()->com;
				$com_ids = array();
				$handle  = opendir($dir);

				if($handle) {
						while($com_id = readdir($handle)) {
								if(substr($com_id, 0, 1) !== '.' && is_dir($dir . $com_id) && !preg_match('/\s/', $com_id) && is_file("{$dir}{$com_id}/ossn_com.php") && is_file("{$dir}{$com_id}/ossn_com.xml")) {
										$com_ids[] = $com_id;
								}
						}
				}

				sort($com_ids);
				return $com_ids;
		}

		/**
		 * Count total components
		 *
		 * @return integer
		 */
		public function total() {
				return count($this->getComponents());
		}

		/**
		 * Get components list
		 *
		 * @return array
		 */
		public function getComponents() {
				$params['from'] = 'ossn_components as c';
				//[E] Show components in admin panel in ASC order of their installation #2155
				$params['order_by'] = 'c.id ASC';
				$this->coms         = $this->select($params, true);
				if(!$this->coms) {
						return false;
				}
				foreach($this->coms as $com_id) {
						$com_ids[] = $com_id->com_id;
				}
				return $com_ids;
		}

		/**
		 * Upload component
		 *
		 * Requires component package file,
		 *
		 * @return boolean
		 */
		public function upload() {
				$upload_error_messages = array(
						UPLOAD_ERR_OK         => 'php:upload_err_ok',
						UPLOAD_ERR_INI_SIZE   => 'php:upload_err_ini_size',
						UPLOAD_ERR_FORM_SIZE  => 'php:upload_err_form_size',
						UPLOAD_ERR_PARTIAL    => 'php:upload_err_partial',
						UPLOAD_ERR_NO_FILE    => 'php:upload_err_no_file',
						UPLOAD_ERR_NO_TMP_DIR => 'php:upload_err_no_tmp_dir',
						UPLOAD_ERR_CANT_WRITE => 'php:upload_err_cant_write',
						UPLOAD_ERR_EXTENSION  => 'php:upload_err_extension',
				);
				$archive  = new ZipArchive();
				$data_dir = ossn_get_userdata('tmp/components');
				if(!is_dir($data_dir)) {
						mkdir($data_dir, 0755, true);
				}
				if(!is_dir($data_dir)) {
						ossn_trigger_message(ossn_print('ossn:com:installer:create:tmpdir:error'), 'error');
						error_log('Com Installer Error: Cannot create temporary data directory');
						return;
				}
				// return upload error messages
				if($_FILES['com_file']['error'] != UPLOAD_ERR_OK) {
						ossn_trigger_message(
								ossn_print('ossn:com:installer:upload:error', array(
										ossn_print($upload_error_messages[$_FILES['com_file']['error']]),
								)),
								'error',
						);
						error_log('Com Installer Error: ' . $upload_error_messages[$_FILES['com_file']['error']]);
						return;
				}

				$zip     = $_FILES['com_file'];
				$newfile = "{$data_dir}/{$zip['name']}";

				if(move_uploaded_file($zip['tmp_name'], $newfile)) {
						if($archive->open($newfile) === true) {
								$translit = OssnTranslit::urlize($zip['name']);

								//make community components works on installer #394
								//Component installer problems with certain zip - archives #420

								$archive->extractTo($data_dir . '/' . $translit);
								$dirctory = scandir($data_dir . '/' . $translit, 1);
								$dirctory = $dirctory[0];

								$files = $data_dir . '/' . $translit . '/' . $dirctory . '/';
								$archive->close();

								if(is_dir($files) && is_file("{$files}ossn_com.php") && is_file("{$files}ossn_com.xml")) {
										$ossn_com_xml = simplexml_load_file("{$files}ossn_com.xml");
										//need to check id , since ossn v3.x
										if(isset($ossn_com_xml->id) && !empty($ossn_com_xml->id)) {
												// asure Ossn compatibility before overwriting an older component release
												$required_version  = $ossn_com_xml->requires->version;
												$installed_version = ossn_site_settings('site_version');
												if($installed_version < $required_version) {
														OssnFile::DeleteDir($data_dir);
														ossn_trigger_message(
																ossn_print('ossn:com:installer:version:error', array(
																		$required_version,
																)),
																'error',
														);
														error_log('Com Installer Error: Ossn version ' . $required_version . ' requirement not met');
														return;
												}
												// if the component is already installed
												// warn the admin to remove it first
												if(is_dir(ossn_route()->com . $ossn_com_xml->id . '/')) {
														OssnFile::DeleteDir($data_dir);
														ossn_trigger_message(ossn_print('ossn:com:installer:remove:comdir:error'), 'error');
														error_log('Com Installer Error: Former component is still in place');
														return;
												}

												//move to components directory
												if(OssnFile::moveFiles($files, ossn_route()->com . $ossn_com_xml->id . '/')) {
														//add new component to system
														$this->newCom($ossn_com_xml->id);

														//restore prefs
														$this->restorePref($ossn_com_xml->id);

														//why it shows success even if the component is not updated #510
														OssnFile::DeleteDir($data_dir);
														//Trigger callback upon component deletion, enable, installation #1111
														ossn_trigger_callback('component', 'installed', array(
																'component' => $ossn_com_xml->id,
														));
														ossn_trigger_message(ossn_print('ossn:com:installer:com:installation:success'), 'success');
														return;
												}
												OssnFile::DeleteDir($data_dir);
												ossn_trigger_message(ossn_print('ossn:com:installer:create:comdir:error'), 'error');
												error_log('Com Installer Error: Cannot copy files to component directory');
												return;
										}
										OssnFile::DeleteDir($data_dir);
										ossn_trigger_message(ossn_print('ossn:com:installer:xml:incomplete:error'), 'error');
										error_log('Com Installer Error: XML file missing or incomplete');
										return;
								}
								OssnFile::DeleteDir($data_dir);
								ossn_trigger_message(ossn_print('ossn:com:installer:zip:incomplete:error'), 'error');
								error_log('Com Installer Error: Zip-archive incomplete');
								return;
						}
						OssnFile::DeleteDir($data_dir);
						ossn_trigger_message(ossn_print('ossn:com:installer:open:zip:error'), 'error');
						error_log('Com Installer Error: Cannot open zip-archive');
						return;
				}
				OssnFile::DeleteDir($data_dir);
				ossn_trigger_message(ossn_print('ossn:com:installer:move:uploaded:file:error'), 'error');
				error_log('Com Installer Error: Cannot open zip-archive');
				return;
		}

		/**
		 * Insert a new component to system
		 *
		 * @return boolean
		 */
		public function newCom($com) {
				if(!empty($com) && is_dir(ossn_route()->com . $com)) {
						/*
														             * Get a com;
														             * @last edit: $arsalanshah
														             * @Reason: Initial;
												*/
						$this->statement("SELECT * FROM ossn_components
			    						  WHERE (com_id='$com');");
						$this->execute();
						$CHECK = $this->fetch();
						if(!isset($CHECK->active)) {
								/*
																		                 * Update com  status;
																		                 * @last edit: $arsalanshah
																		                 * @Reason: Initial;
																*/
								$this->statement("INSERT INTO `ossn_components`
			 									 (`com_id`, `active`)
		         								  VALUES ('$com', '0')");
								$this->execute();
								return true;
						}
				}
				return false;
		}

		/**
		 * Load all active components
		 *
		 * @return false|null startup files;
		 */
		public function loadComs() {
				$coms = $this->getActive();
				$lang = ossn_site_settings('language');

				$vars['activated'] = $coms;
				ossn_trigger_callback('components', 'before:load', $vars);
				if(!$coms) {
						return false;
				}
				foreach($coms as $com) {
						$dir  = ossn_route()->com;
						$name = $this->getCom($com->com_id);
						if(!empty($name->name)) {
								ossn_register_plugins_by_path("{$dir}{$com->com_id}/plugins/");
								//Include only when cache is not enabled, cache the locale files #1321
								if(ossn_site_settings('cache') == 0 && is_file("{$dir}{$com->com_id}/locale/ossn.{$lang}.php")) {
										include "{$dir}{$com->com_id}/locale/ossn.{$lang}.php";
								}
								include_once "{$dir}{$com->com_id}/ossn_com.php";
						}
				}
				ossn_trigger_callback('components', 'after:load', $vars);
		}

		/**
		 * Get active components
		 *
		 * @return active components;
		 */
		public function getActive($ids_only = false) {
				$params['from']   = 'ossn_components';
				$params['wheres'] = array(
						"active='1'",
				);
				//components are not loading in the correct order #1328
				$params['order_by'] = 'id ASC';
				$list               = $this->select($params, true);
				if($ids_only) {
						if($list) {
								$lists = array();
								foreach($list as $item) {
										$lists[] = $item->com_id;
								}
								return $lists;
						}
				}
				return $list;
		}

		/**
		 * Get component details
		 *
		 * @params string $name Component id;
		 *
		 * @return false|object
		 */
		public static function getCom($name) {
				$name = trim($name);
				if(!preg_match('/\s/', $name)) {
						$dir       = ossn_route()->com;
						$component = $dir . $name;
						if(is_file("{$component}/ossn_com.xml")) {
								$component = simplexml_load_file("{$component}/ossn_com.xml");
								return $component;
						}
				}
				return false;
		}
		/**
		 * Check if component is older than 3.x
		 *
		 * @param string $element Component xml string.
		 *
		 * @return boolean
		 */
		public function isOld($element) {
				if(empty($element)) {
						return false;
				}
				$version = current($element->getNamespaces());
				if(substr($version, -3) == '1.0') {
						return true;
				}
				return false;
		}
		/**
		 * Check if $comId is defined as required in XML of other active component
		 *
		 * @params string $comId Component id;
		 *
		 * @return array
		 */
		public function inUseBy($comId) {
				$list   = $this->getActive();
				$result = array();
				if($list) {
						foreach($list as $component) {
								$element = $this->getCom($component->com_id);
								if($element->name == 'OssnProfile' && $comId == 'OssnProfile') {
										// special case: not defined in xml, but used and needed by Ossn
										$result[] = 'Ossn';
										break;
								}
								if(isset($element->requires)) {
										$requires = $element->requires;
										foreach($requires as $item) {
												if($item->type != 'ossn_component') {
														continue;
												}
												if($item->name == $comId) {
														$result[] = $element->name;
												}
										}
								}
						}
				}
				return $result;
		}
		/**
		 * Check component requirments
		 *
		 * @param string $element A valid component xml file
		 *
		 * @return false|array
		 */
		public static function checkRequirments($element) {
				if(empty($element)) {
						return false;
				}
				$types = array(
						'ossn_version',
						'php_extension',
						'php_version',
						'php_function',
						'ossn_component',
				);
				if(isset($element->name)) {
						if(isset($element->requires)) {
								$result   = array();
								$requires = $element->requires;
								foreach($requires as $item) {
										if(!in_array($item->type, $types)) {
												continue;
										}
										$requirments = array();
										//version checks
										if($item->type == 'ossn_version') {
												//Ossn Version checking not strict enough when installing components #1000
												$comparator = '>=';
												if(isset($item->comparator) && !empty($item->comparator)) {
														$comparator = $item->comparator;
												}

												$requirments['type']         = ossn_print('ossn:version');
												$requirments['value']        = $comparator . ' ' . (string) $item->version;
												$requirments['availability'] = 0;
												$site_version                = ossn_site_settings('site_version');

												if(version_compare($site_version, (string) $item->version, $comparator)) {
														$requirments['availability'] = 1;
												}
										}
										//check php extension
										if($item->type == 'php_extension') {
												$requirments['type']         = ossn_print('php:extension');
												$requirments['value']        = (string) $item->name;
												$requirments['availability'] = 0;

												if(extension_loaded($item->name)) {
														$requirments['availability'] = 1;
												}
										}
										//check php version
										if($item->type == 'php_version') {
												$comparator = '>=';
												if(isset($item->comparator) && !empty($item->comparator)) {
														$comparator = $item->comparator;
												}
												$requirments['type']         = ossn_print('php:version');
												$requirments['value']        = $comparator . ' ' . (string) $item->version;
												$requirments['availability'] = 0;

												$phpversion = substr(PHP_VERSION, 0, 6);
												if(version_compare($phpversion, (string) $item->version, $comparator)) {
														$requirments['availability'] = 1;
												}
										}
										//check php function
										if($item->type == 'php_function') {
												$comparator = 'available';
												if(isset($item->comparator) && !empty($item->comparator)) {
														$comparator = $item->comparator;
												}

												$requirments['type']         = ossn_print('php:function') . ' ' . (string) $item->name;
												$requirments['value']        = $comparator;
												$requirments['availability'] = 0;

												if((function_exists($item->name) && $comparator == 'available') || (!function_exists($item->name) && $comparator == 'not available')) {
														$requirments['availability'] = 1;
												}
										}
										if($item->type == 'ossn_component') {
												$comparator = '>=';
												if(isset($item->comparator) && !empty($item->comparator)) {
														$comparator = $item->comparator;
												}
												$requirments['type']         = (string) $item->name . ' ' . ossn_print('component');
												$requirments['value']        = $comparator . ' ' . (string) $item->version;
												$requirments['availability'] = 0;

												$OssnComponent = new OssnComponents();
												if($OssnComponent->isActive($item->name)) {
														$requirments['availability'] = 1;

														if(isset($item->version)) {
																$com_load = $OssnComponent->getCom($item->name);
																if($com_load && version_compare($com_load->version, (string) $item->version, $comparator)) {
																		$requirments['availability'] = 1;
																} else {
																		$requirments['availability'] = 0;
																}
														}
														if($comparator == 'disabled') {
																$requirments['availability'] = 0;
														}
												} else {
														if($comparator == 'disabled') {
																$requirments['availability'] = 1;
														}
												}
										}
										$result[] = $requirments;
								} //loop
								return $result;
						}
				}
				return false;
		} //func
		/**
		 * Check if component is active or not
		 *
		 * @return boolean
		 */
		public function isActive($id = '') {
				if(empty($id)) {
						return false;
				}
				$params['from']   = 'ossn_components';
				$params['wheres'] = array(
						"com_id='{$id}'",
				);

				$this->settings = $this->select($params);
				if($this->settings && $this->settings->active == 1) {
						return true;
				}
				return false;
		}

		/**
		 * Enable Component
		 *
		 * @return boolean
		 */
		public function enable($com) {
				ossn_trigger_callback('component', 'before:enable', array(
						'component' => $com,
				));
				if(!empty($com) && is_dir(ossn_route()->com . $com)) {
						//file is called before component is enabled
						if(file_exists(ossn_route()->com . $com . '/enable.php')) {
								include_once ossn_route()->com . $com . '/enable.php';
						}
						/*
														             * Get a com;
														             * @last edit: $arsalanshah
														             * @Reason: Initial;
												*/
						$this->statement("SELECT * FROM ossn_components WHERE (com_id='$com');");
						$this->execute();
						$CHECK = $this->fetch();
						/*
														             * Update com status;
														             * @last edit: $arsalanshah
														             * @Reason: Initial;
												*/
						if(isset($CHECK->active) && $CHECK->active == 0) {
								$this->statement("UPDATE ossn_components SET active='1' WHERE (com_id='$com');");
								$this->execute();
								//Trigger callback upon component deletion, enable, installation #1111
								ossn_trigger_callback('component', 'enabled', array(
										'component' => $com,
								));
								//file is called before component is already enabled
								if(file_exists(ossn_route()->com . $com . '/enabled.php')) {
										include_once ossn_route()->com . $com . '/enabled.php';
								}
								return true;
						} elseif(!isset($CHECK->active)) {
								/*
																		                 * Update com  status;
																		                 * @last edit: $arsalanshah
																		                 * @Reason: Initial;
																*/
								$this->statement("INSERT INTO `ossn_components` (`com_id`, `active`) VALUES ('$com', '1')");
								$this->execute();
								//Trigger callback upon component deletion, enable, installation #1111
								ossn_trigger_callback('component', 'enabled', array(
										'component' => $com,
								));
								//file is called after component is enabled
								if(file_exists(ossn_route()->com . $com . '/enabled.php')) {
										include_once ossn_route()->com . $com . '/enabled.php';
								}
								return true;
						}
				}
				return false;
		}

		/**
		 * Delete component
		 *
		 * @return boolean
		 */
		public function delete($com) {
				ossn_trigger_callback('component', 'before:delete', array(
						'component' => $com,
				));
				if(in_array($com, $this->requiredComponents())) {
						return false;
				}
				//file is called before component deleted
				if(file_exists(ossn_route()->com . $com . '/delete.php')) {
						include_once ossn_route()->com . $com . '/delete.php';
				}
				$component = $this->getbyName($com);
				if(!$component) {
						return false;
				}
				$params           = array();
				$params['from']   = 'ossn_components';
				$params['wheres'] = array(
						"com_id='{$com}'",
				);
				if(parent::delete($params)) {
						//Delete component settings upon its deletion #538
						$entities = new OssnEntities();
						$entities->deleteByOwnerGuid($component->id, 'component');

						//delete component directory
						OssnFile::DeleteDir(ossn_route()->com . "{$com}/");

						//Trigger callback upon component deletion, enable, installation #1111
						$vars['component'] = $component;
						ossn_trigger_callback('component', 'deleted', $vars);
						//file is called after component is already deleted
						if(file_exists(ossn_route()->com . $com . '/deleted.php')) {
								include_once ossn_route()->com . $com . '/deleted.php';
						}
						return true;
				}
				return false;
		}

		/**
		 * Required Components
		 *
		 * Admin can't disable required components;
		 *
		 * @return array
		 */
		public function requiredComponents() {
				$default = array(
						'OssnProfile',
				);
				return ossn_call_hook('required', 'components', false, $default);
		}

		/**
		 * Disable component
		 *
		 * @return boolean
		 */
		public function DISABLE($com = null) {
				ossn_trigger_callback('component', 'before:disable', array(
						'component' => $com,
				));
				//file is called before component is disabled
				if(file_exists(ossn_route()->com . $com . '/disable.php')) {
						include_once ossn_route()->com . $com . '/disable.php';
				}
				if(in_array($com, $this->requiredComponents())) {
						return false;
				}
				if(!empty($com)) {
						$this->statement("UPDATE ossn_components SET active='0' WHERE (com_id='$com')");
						$this->execute();
						ossn_trigger_callback('component', 'disabled', array(
								'component' => $com,
						));
						//file is called after component is disabled
						if(file_exists(ossn_route()->com . $com . '/disabled.php')) {
								include_once ossn_route()->com . $com . '/disabled.php';
						}
						return true;
				}
				return false;
		}

		/**
		 * Bundled components
		 *
		 * @return array
		 */
		public function bundledComponents() {
				return array_merge(
						array(
								'OssnGroups',
								'OssnSitePages',
								'OssnChat',
								'OssnPoke',
								'OssnBlock',
								'OssnSmilies',
								'OssnInvite',
								'OssnEmbed',
								'OssnAds',
								'OssnComments',
								'OssnLikes',
								'OssnMessages',
								'OssnNotifications',
								'OssnPhotos',
								'OssnSearch',
								'OssnWall',
						),
						$this->requiredComponents(),
				);
		}
		/**
		 * Set component settings
		 *
		 * setSettings should have array() to accept values #434
		 *
		 * @param  string $component Component id
		 * @param  array vars Setting (two-dem array)
		 *
		 * @return boolean
		 */
		public function setSettings($component, array $vars = array()) {
				$settings = self::getComSettings($component);
				$guid     = $this->getbyName($component)->getID();
				$entity   = new OssnEntities();
				if(empty($guid)) {
						return false;
				}
				foreach($vars as $name => $value) {
						if($settings && !$settings->isParam($name)) {
								$entity->owner_guid = $guid;
								$entity->type       = 'component';
								$entity->subtype    = $name;
								$entity->value      = $value;
								$entity->add();
						} else {
								$entity->data        = new stdClass();
								$entity->owner_guid  = $guid;
								$entity->type        = 'component';
								$entity->data->$name = $value;
								$entity->save();
						}
				}
				return true;
		}
		/**
		 * Get Component Settings
		 *
		 * @param string $component Component id
		 *
		 * @return false|array;
		 */
		public function getSettings($component) {
				$object = $this->getbyName($component);
				if(!$object) {
						return false;
				}
				$entity             = new OssnEntities();
				$entity->type       = 'component';
				$entity->owner_guid = $object->getID();
				$settings           = $entity->get_entities();
				if(is_array($settings) && !empty($settings)) {
						foreach($settings as $setting) {
								$comsettings[$setting->subtype] = $setting->value;
						}
						return arrayObject($comsettings, 'OssnComponents');
				}
				return false;
		}
		/**
		 * Get Component Settings
		 *
		 * @params string $component Component id
		 *
		 * @note This method is deprecated and will be removed in Ossn v4.0
		 *
		 * @return false|array;
		 */
		public function getComSettings($component) {
				return $this->getSettings($component);
		}
		/**
		 * Get component
		 *
		 * @note This id is not a package id
		 *
		 * @return integer|false;
		 */
		public function getbyName($name) {
				$params           = array();
				$params['from']   = 'ossn_components';
				$params['wheres'] = array(
						"com_id='{$name}'",
				);
				if($data = $this->select($params)) {
						return arrayObject($data, get_class($this));
				}
				return false;
		}
		/**
		 * Keep preference on next upload
		 *
		 * @param string $com_id Component ID
		 *
		 * @return boolean
		 */
		public function savePref(string $com_id): bool {
				if(!empty($com_id)) {
						$data_dir = ossn_get_userdata("components/preferences/{$com_id}/");
						$settings = $this->getSettings($com_id);
						if($settings) {
								if(!is_dir($data_dir)) {
										mkdir($data_dir, 0755, true);
								}
								$toArray = (array) $settings;
								$toJson  = json_encode($toArray);
								$file    = $data_dir . 'pref.json';
								return file_put_contents($file, $toJson);
						}
						return true;
				}
				return false;
		}
		/**
		 * Restore preference
		 *
		 * @param string $com_id Component ID
		 *
		 * @return boolean
		 */
		public function restorePref(string $com_id): bool {
				if(!empty($com_id)) {
						$data_dir = ossn_get_userdata("components/preferences/{$com_id}/");
						$filePath = $data_dir . 'pref.json';
						if(is_file($filePath)) {
								$file    = file_get_contents($filePath);
								$toArray = json_decode($file, true);
								if($this->setSettings($com_id, $toArray)) {
										//remove old pref
										OssnFile::DeleteDir($data_dir);
										return true;
								}
						}
				}
				return false;
		}
} //class