Parking.class.php

<?php
// vim: set ai ts=4 sw=4 ft=php:
class Parking implements BMO {
	protected $FreePBX;
	protected $db;
	protected $astman;
	protected $id;
	protected $parkedCalls;
	public function __construct($freepbx = null) {
		if ($freepbx == null){
			throw new Exception("Not given a FreePBX Object");
		}

		$this->FreePBX = $freepbx;
		$this->db = $freepbx->Database;
		$this->astman = $freepbx->astman;
	}

	public function install() {
		//Remove duplication etc. Moved from install.php
		$this->initializeParkingLot();
	}
	public function uninstall() {

	}
	public function setDatabase($pdo){
	$this->db = $pdo;
	return $this;
	}
	
	public function resetDatabase(){
		$this->db = $this->FreePBX->Database;
	return $this;
	}
	public function doConfigPageInit($page){
		$id = $_REQUEST['id'] ?? '';
		$parking_defaults = ["name" => "Lot Name", "type" => "public", "parkext" => "", "parkpos" => "", "numslots" => 4, "parkingtime" => 45, "parkedmusicclass" => "default", "generatehints" => "yes", "generatefc" => "yes", "findslot" => "first", "parkedplay" => "both", "parkedcalltransfers" => "caller", "parkedcallreparking" => "caller", "alertinfo" => "", "cidpp" => "", "autocidpp" => "", "announcement_id" => null, "comebacktoorigin" => "yes", "dest" => "", "rvolume" => ""];

		switch ($_REQUEST['action'] ?? "") {
			case 'add':
			case 'update':
				$vars = [];
				foreach(array_keys($parking_defaults) as $k) {
					if(isset($_REQUEST[$k]))
						$vars[$k] = $_REQUEST[$k];
				}
				if(!empty($vars)) {
					$vars['dest'] = (isset($_REQUEST['goto0']) && isset($_REQUEST[$_REQUEST['goto0'].'0'])) ? $_REQUEST[$_REQUEST['goto0'].'0'] : '';
					if($_REQUEST['action'] == 'update') {
						$vars['id'] = $_REQUEST['id'];
					}
					$id = $this->save($vars);
					if($id !== false){
						$_REQUEST['action'] = 'modify';
						$_REQUEST['id'] = $id;
					}
					if($this->FreePBX->Modules->checkStatus('parkpro')) {
						unset($_REQUEST['action']);
					}
				}
			break;
			case 'delete':
				if(function_exists('parkpro_del')) {
					if(parkpro_del($id)) {
						$_REQUEST['action'] = '';
						$_REQUEST['id'] = '';
					}
				}
			break;
			default:
			break;
		}
	}
	public function search($query, &$results) {
		if(!ctype_digit((string) $query)) {
			$sql = "SELECT * FROM parkplus WHERE parkext LIKE ?";
			$sth = $this->db->prepare($sql);
			$sth->execute(["%".$query."%"]);
			$rows = $sth->fetchAll(PDO::FETCH_ASSOC);
			foreach($rows as $row) {
				$results[] = ["text" => _("ParkingLot")." ".$row['parkext'], "type" => "get", "dest" => "?display=parking&action=modify&id=".$row['id']];
			}
		} else {
			$sql = "SELECT * FROM parkplus WHERE name LIKE ?";
			$sth = $this->db->prepare($sql);
			$sth->execute(["%".$query."%"]);
			$rows = $sth->fetchAll(PDO::FETCH_ASSOC);
			foreach($rows as $row) {
				$results[] = ["text" => $row['name'] . " (".$row['parkext'].")", "type" => "get", "dest" => "?display=parking&action=modify&id=".$row['id']];
			}
		}
	}

	public function getAllParkingLots() {
		$sql = "SELECT * FROM parkplus";
		$sth = $this->db->prepare($sql);
		$sth->execute();
		return $sth->fetchAll(PDO::FETCH_ASSOC);
	}

	public function getParkingLotByID($id='default') {
		$sql = "SELECT * FROM parkplus WHERE id = ?";
		$sth = $this->db->prepare($sql);
		$sth->execute([$id]);
		return $sth->fetch(PDO::FETCH_ASSOC);
	}

	static function getDefaults(){
		return [
			'name' => 'Parking Lot',
			'type' => 'public',
			'parkext' => '',
			'parkpos' => '',
			'numslots' => 4,
			'parkingtime' => 45,
			'parkedmusicclass' => 'default',
			'generatefc' => 'yes',
			'findslot' => 'first',
			'parkedplay' => 'both',
			'parkedcalltransfers' => 'caller',
			'parkedcallreparking' => 'caller',
			'alertinfo' => '',
			'cidpp' => '',
			'autocidpp' => 'none',
			'announcement_id' => null,
			'comebacktoorigin' => 'yes',
			'dest' => '',
			'defaultlot' => 'yes',
			'rvolume' => '',
		];
	}
	
	public function save($params = []){
		$var = [];
		if(isset($params['id'])){
			$var['id'] = $params['id'];
		}

		if (!function_exists('parkpro_get')) {
			$var['id'] = 1;
		}

		foreach (static::getDefaults() as $k => $v) {
			if (!empty($params[$k])) {
				$var[$k] = $params[$k];
			} else {
			$var[$k] = $v;
		}
		}
		$var['defaultlot'] = isset($var['id']) && $var['id'] == 1 ? 'yes' : 'no';
		$var['type'] = isset($var['id']) && $var['id'] == 1 ? 'public' : $var['type'];
		$fields = "name, type, parkext, parkpos, numslots, parkingtime, parkedmusicclass, generatefc, findslot, parkedplay,
		parkedcalltransfers, parkedcallreparking, alertinfo, cidpp, autocidpp, announcement_id, comebacktoorigin, dest, defaultlot, rvolume";
		$holders = ':name,  :type,  :parkext,  :parkpos,  :numslots,  :parkingtime,  :parkedmusicclass,  :generatefc,  :findslot,  :parkedplay, 
		:parkedcalltransfers,  :parkedcallreparking,  :alertinfo,  :cidpp,  :autocidpp,  :announcement_id,  :comebacktoorigin,  :dest,  :defaultlot,  :rvolume';

		if (!empty($var['id'])) {
			$fields = 'id, '.$fields;
			$holders = ':id, '.$holders;
		}
		$sql = "REPLACE INTO parkplus ($fields) VALUES ($holders)";
		$this->FreePBX->Database->prepare($sql)->execute($var);
		$id = $this->FreePBX->Database->lastInsertId('id');
		needreload();
		return $id;
	}

	public function genConfig() {
		$conf = [];
		global $version;

		if (function_exists('parkpro_get_config')) {
			return null;
		}

		if(version_compare($version, '12', 'ge')) {
			$lot = parking_get();
			$parkpos1	= $lot['parkpos'];
			$parkpos2	= $parkpos1 + $lot['numslots'] - 1;
			$park_context = 'default';
			$hint_context = 'parkedcalls';
			$conf['res_parking.conf'][] = "#include res_parking_additional.conf\n#include res_parking_custom.conf";
			$conf['res_parking_additional.conf'][$park_context] = ['parkext' => $lot['parkext'], 'parkpos' => $parkpos1."-".$parkpos2, 'context' => $hint_context, 'parkingtime' => $lot['parkingtime'], 'comebacktoorigin' => 'no', 'parkedplay' => $lot['parkedplay'], 'courtesytone' => 'beep', 'parkedcalltransfers' => $lot['parkedcalltransfers'], 'parkedcallreparking' => $lot['parkedcallreparking'], 'parkedmusicclass' => $lot['parkedmusicclass'], 'findslot' => $lot['findslot']];
			return $conf;
		}
	}
	public function writeConfig($conf){
		$this->FreePBX->WriteConfig($conf);
	}
	public function getActionBar($request) {
		$buttons = [];
		switch($request['display']) {
			case 'parking':
				$buttons = ['delete' => ['name' => 'delete', 'id' => 'delete', 'value' => _("Delete")], 'reset' => ['name' => 'reset', 'id' => 'reset', 'value' => _('Reset')], 'submit' => ['name' => 'submit', 'id' => 'submit', 'value' => _('Submit')]];
				if (empty($request['id']) || !function_exists('parkpro_view')) {
					unset($buttons['delete']);
				}
				if(!isset($request['action']) && function_exists('parkpro_view')){
					$buttons = [];
				}
			break;
		}
		return $buttons;
	}
	public function getRightNav($request) {
		if(function_exists('parkpro_view')){
			return $this->FreePBX->Parkpro->getRightNav($request);
		}
	}

	/**
	 * Retrieve a parking lot or all parking lots from the database.
	 *
	 * @param string $id The ID of the parking lot to retrieve. If 'all' or empty, return all parking lots.
	 * @return array An associative array where the key is the parking lot ID and the value is an associative array with the parking lot's properties.
	 *               If the parking lot ID is specified and it does not exist, an empty array is returned.
	 */
	public function parkingGet($id = 'default'){
		if (function_exists('parkpro_get')) {
			return parkpro_get($id);
		}

		try {
			$sql = "SELECT * FROM parkplus WHERE defaultlot = 'yes' LIMIT 1";
			$stmt = $this->db->prepare($sql);

			if ($id === 'all' || $id === '') {
				$stmt->execute();
				$results = [];
				$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
				
				foreach ($rows as $row) {
					$results[$row['id']] = $row;
				}
				return $results;
			}

			$stmt->execute();
			$result = $stmt->fetch(PDO::FETCH_ASSOC);
			return $result ?: [];
		} catch (PDOException $e) {
			dbug(sprintf("Database error in parkingGet: %s", $e->getMessage()));
			return [];
		}
	}


	/**
	 * Initialize default parking lot if it does not exist.
	 *
	 * If there are multiple default parking lots, delete all of them and reinitialize
	 * the default lot. If there is a single default lot, check if it has an empty
	 * destination and update it if necessary. If there are no default parking lots,
	 * initialize a new one with the default settings.
	 *
	 * @throws PDOException if there is a database error
	 */
	public function initializeParkingLot()
	{
		try {
			// Get default lots
			$stmt = $this->db->query("SELECT * FROM parkplus WHERE defaultlot = 'yes'");
			$defaultLots = $stmt->fetchAll(PDO::FETCH_ASSOC);
			$defaultLotCount = count($defaultLots);

			// Handle multiple default lots
			if ($defaultLotCount > 1) {
				out(_("ERROR: too many default lots detected, deleting and reinitializing"));
				$this->db->exec("DELETE FROM parkplus WHERE defaultlot = 'yes'");
				$defaultLotCount = 0;
				$defaultLots = [];
			}

			// Check and update empty destination
			if ($defaultLotCount === 1 && empty($defaultLots[0]['dest'])) {
				$stmt = $this->db->prepare("UPDATE parkplus SET dest = ? WHERE defaultlot = 'yes'");
				$stmt->execute(['app-blackhole,hangup,1']);
			}

			// Initialize default parking lot if none exists
			if ($defaultLotCount === 0) {
				outn(_("Initializing default parkinglot.."));
				
				$stmt = $this->db->prepare(
					"INSERT INTO parkplus (id, defaultlot, name, parkext, parkpos, numslots) 
					VALUES (?, ?, ?, ?, ?, ?)"
				);
				$stmt->execute([1, 'yes', _('Default Lot'), '70', '71', 8]);
				out(_("done"));
			}
		} catch (PDOException $e) {
			// Log error appropriately in production
			out(sprintf(_("Database error: %s"), $e->getMessage()));
		}
	}

	/**
	 * Retrieves a list of currently parked calls.
	 *
	 * @param string $id The ID of the parking lot to retrieve.
	 * @return array List of parked calls.
	 */
	public function getParkedCalls($id = '') {
		// the $id param can be the desired lot's id number, but for the default
		// lot, an id of 'default' must be used
		$this->id = strval($id);
		$actionId = 'getParkedCalls' . str_shuffle(strval(time()));
		$this->parkedCalls = [];
		$this->astman->events("on");
		$this->astman->add_event_handler(
			"parkedcall",
			function ($event, $data, $server, $port) {
				$lotId = str_replace('parkinglot_', '', (string) $data['Parkinglot']);
				if (empty($this->id) || $this->id === $lotId) {
					unset($data['Event']);
					unset($data['ActionID']);
					array_push($this->parkedCalls, $data);
				}
			}
		);

		$this->astman->add_event_handler(
			"parkedcallscomplete",
			function ($event, $data, $server, $port) {
				stream_set_timeout($this->astman->socket, 0, 1);
			}
		);

		$response = $this->astman->ParkedCalls($actionId);
		if ($response["Response"] == "Success") {
			$this->astman->wait_response(true);
			stream_set_timeout($this->astman->socket, 30);
		}

		return $this->parkedCalls;
	}
}