php-mpos/include/classes/pushnotification.class.php

<?php
	class PushNotification extends Base {
		var $tableSettings = 'push_notification_settings';
		
		private static function getClassesInFile($file){
			$classes = array();
			$tokens = token_get_all(file_get_contents($file));
			$count = count($tokens);
			for ($i = 2; $i < $count; $i++) {
				if ($tokens[$i - 2][0] == T_CLASS && $tokens[$i - 1][0] == T_WHITESPACE && $tokens[$i][0] == T_STRING) {
					$class_name = $tokens[$i][1];
					$classes[] = $class_name;
				}
			}
			return $classes;
		}
		
		private static $classes = null;
		public function getClasses(){
			if (self::$classes === null){
				$directory = new DirectoryIterator(__DIR__.'/push_notification');
				foreach ($directory as $fileInfo) {
					if (($fileInfo->getExtension() != 'php') || $fileInfo->isDot()) {
						continue;
					}
					foreach (self::getClassesInFile($fileInfo->getRealPath()) as $class){
						if (!class_exists($class)){
							include $fileInfo->getRealPath();
						}
						$cr = new ReflectionClass($class);
						if ($cr->isSubclassOf('IPushNotification')){
							self::$classes[$class] = array($fileInfo->getFilename(), $cr->getMethod('getName')->invoke(null), $cr->getMethod('getParameters')->invoke(null));
						}
					}
				}
			}
			return self::$classes;
		}
		
		public function getClassesForSmarty(){
			$c = $this->getClasses();
			return array_map(function($a, $b){
				return array(
					'class' => $b,
					'file' => $a[0],
					'name' => $a[1],
					'parameters' => $a[2],
				);
			}, $c, array_keys($c));
		}
		
		/**
		 * @param string|array $notificator
		 * @param array $data
		 * @return IPushNotification|bool
		 */
		public function getNotificatorInstance($notificator, $data){
			$class = null;
			$file = null;
			
			if (is_array($notificator)){
				if (count($notificator) == 2){
					list($class, $file) = $notificator;
				} else {
					$class = reset($notificator);
				}
			} else {
				$class = $notificator;
			}
			
			if (!class_exists($class)){
				if ($file === null){
					foreach (self::getClasses() as $_class => $_info){
						if ($_class == $class){
							$file = $_info[0];
							break;
						}
					}
				} else {
					include __DIR__.'/push_notification/'.$file;
				}
				if (!class_exists($class)){
					return false;
				}
			}
			$cr = new ReflectionClass($class);
			$constructor = $cr->getConstructor();
			$constructorParameters = array();
			foreach (array_map(function($a){ return $a->getName();}, $constructor->getParameters()) as $param){
				$constructorParameters[] = array_key_exists($param, $data)?$data[$param]:null;
			}
			$instance = $cr->newInstanceArgs($constructorParameters);
			return $instance;
		}
		
		/**
		 * Update accounts push notification settings
		 * @param account_id int Account ID
		 * @param data array Data array
		 * @return bool
		 **/
		public function updateSettings($account_id, $data) {
			$this->debug->append("STA " . __METHOD__, 4);
			
			$stmt = $this->mysqli->prepare("INSERT INTO $this->tableSettings (value, account_id) VALUES (?, ?) ON DUPLICATE KEY UPDATE value = VALUES(value)");
			if (!($stmt && $stmt->bind_param('si', json_encode($data), $account_id) && $stmt->execute())) {
				$this->setErrorMessage($this->getErrorMsg('E0047', __CLASS__));
				return $this->sqlError();
			}
			$this->log->log("info", "User $account_id updated notification settings");
			return true;
		}
		
		/**
		 * Fetch notification settings for user account
		 * @param id int Account ID
		 * @return array Notification settings
		 **/
		public function getNotificationSettings($account_id) {
			$this->debug->append("STA " . __METHOD__, 4);
			$stmt = $this->mysqli->prepare("SELECT value FROM $this->tableSettings WHERE account_id = ?");
			if ($stmt && $stmt->bind_param('i', $account_id) && $stmt->execute() && $result = $stmt->get_result()) {
				if ($result->num_rows) {
					/* @var $result mysqli_result */
					$aData = json_decode(current($result->fetch_row()), true);
					return $aData;
				} else {
					return array(
						'class' => false,
						'params' => null,
						'file' => null,
					);
				}
			}
			return $this->sqlError('E0045');
		}
		
		private static $instance = null;
		/**
		 * @param PushNotification $instance
		 */
		public static function Instance($instance = null){
			if (func_num_args() == 0){
				return self::$instance;
			}
			return self::$instance = $instance;
		}
		
		public function sendNotification($account_id, $template, $aData){
			$settings = $this->getNotificationSettings($account_id);
			if ($settings['class']){
				$instance = $this->getNotificatorInstance(array($settings['class'], $settings['file']), $settings['params']);
				if ($instance){
					$this->smarty->assign('WEBSITENAME', $this->setting->getValue('website_name'));
					$this->smarty->assign('SUBJECT', $aData['subject']);
					$this->smarty->assign('DATA', $aData);
						
					$message = false;
					foreach (array('/mail/push_notifications/', '/mail/notifications/') as $dir){
							$this->smarty->clearCache($templateFile = TEMPLATE_DIR.$dir.$template.'.tpl');
						try {
							$message = $this->smarty->fetch($templateFile);
						} catch (SmartyException $e){
							
						}
					}
					if ($message){
						$instance->notify($message, 'info', $aData['subject']);
					}
				}
			}
			return true;
		}
	}
	
	$pushnotification = PushNotification::Instance(new PushNotification());
	$pushnotification->setDebug($debug);
	$pushnotification->setLog($log);
	$pushnotification->setMysql($mysqli);
	$pushnotification->setSmarty($smarty);
	$pushnotification->setConfig($config);
	$pushnotification->setSetting($setting);
	$pushnotification->setErrorCodes($aErrorCodes);