Auteur: saerts

Combinatie API zowel RESTful als SOAP, in php met een WSDL

/**
	 *  AOZ Soap Class
	 */
	class soapServiceFunctions { 
		public $authorized 	= false;
		public $testmode	= false;

		/**
		 *  Check auhtorization
		 */
		function authorization($header) {
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			global $_SERVER;
			if ( isset($header->username) && isset($header->hash) ) 
			{ 
				if ( $header->username == "testuser" && $header->hash == "7f3be433c9bab15315e23fbb4664d33c6074211b" ) {
					$this->authorized 			= true;
					$this->testmode				= true;
					$this->userData["userid"] 	= 1;
				} else {
					$this->userData	= $this->auth->checkWSDLAccess($header->username, $header->hash, $_SERVER["REMOTE_ADDR"]);
					if ( $this->userData ) $this->authorized 	= true;
					$this->userData["userid"] 	= $this->userData["id"];
				}
			} 
		} 

		/**
		 *  Exception handler
		 */
		function serviceAPIException($errNr, $msg, $call)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			switch ( $this->serviceType ) {
				case "SOAP":
					$this->soap->fault($errNr, $msg, $call, "Contact the AOZ support department on 076 - 74 10 100.");
				break;;
				default:
					throw new Exception($errNr . "::" . $msg . "::" . $call . "]->" . "Contact the AOZ support department on 076 - 74 10 100.");
				break;;
			}
		}
		
		/**
		 *  Request for bag (basisregistratie adressen information ...
		 */
		function someFunction(
					$firstName,
					$lastName,
		) {	
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			
			return(
				array(
					"processData"				=> $this->serviceConversion($this->procData),
					"aozBagRequest"				=> $this->serviceConversion($rs),
					"dataResources"				=> null	
				)
			);
		}

		/**
		 *  Convert to API 
		 */
		function serviceConversion($dataSet)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			switch ( $this->serviceType ) {
				case "SOAP":
					return(new SoapVar($dataSet, SOAP_ENC_OBJECT));
				break;;
				default:
					return($dataSet);
				break;;
			}
		}
		
		/**
		 *  API Constructor ...
		 */
		function __construct($soapService, $sql, $auth, $crypt, $conversionTbl, $serviceType = "SOAP")
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			global $logData;
			$this->logData			= &$logData;
			$this->soap 			= $soapService;
			$this->sql 				= $sql;
			$this->auth 			= $auth;
			$this->crypt			= $crypt;
			$this->conversionTbl	= $conversionTbl;
			$this->serviceType		= $serviceType;
			$this->logData["API"]	= $serviceType;
			$this->locationImages	= true;
			$this->imageHashes		= array();
			$this->procData			= array(
											"calls"		=> 0,
											"resources"	=> 0,
											"runtime"	=> microtime(true),
											"date"		=> time(),
											"errors"	=> 0,
											"warnings"	=> 0,
											"images"	=> 0,
											"timezone"	=> date_default_timezone_get()
										);
		}
	} 
	
	/**
	 *  RESTful API class
	 */
	abstract class RESTFullAPI extends soapServiceFunctions { 
		/**
		 *  Request vars
		 */
		protected $method		= "";
		protected $endpoint		= "";
		protected $verb			= "";
		protected $args			= Array();
		protected $file			= null;
		protected $username		= "";
		protected $hash			= "";
		
		/**
		 *  API Entrypoint
		 */
		
		/**
		 *  Response function
		 */
		function __response($data, $statusCode = 200)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			header("HTTP/1.1 " . $statusCode . " " . $this->__requestStatus($statusCode));
			return json_encode($data);
		}
		
		/**
		 *  Cleanup input data
		 */
		function __cleanInput($data)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			$clean_input = Array();
			if (is_array($data)) {
				foreach ($data as $k => $v) {
					$clean_input[$k] = $this->__cleanInput($v);
				}
			} else {
				$clean_input = trim(strip_tags($data));
			}
			return $clean_input;
		}
		
		/**
		 *  Check request status
		 */
		function __requestStatus($statusCode)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			$statusCodes = array(
								200 => "OK",
								404 => "Not Found",
								405 => "Method Not Allowed",
								500 => "Internal Server Error"
							);
			return($statusCodes[$statusCode] ? $statusCodes[$statusCode] : $statusCodes[500]);
		}
		
		/**
		 *  RESTful API constructor
		 */
		function __construct($requestInput)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			global $server, $sql, $auth, $crypt, $conversionTbl, $apiClass;
			$apiClass = $this;
			
			/**
			 * Response headers 
			 */
			header("Access-Control-Allow-Orgin: *");
			header("Access-Control-Allow-Methods: *");
			header("Content-Type: application/json");
			
			/**
			 *  Parse arguments
			 */
			$this->args 	= explode("/", rtrim($requestInput));
			$this->endpoint	= array_shift($this->args);
			$this->method	= $_SERVER["REQUEST_METHOD"];
			
			/**
			 *  Check request method
			 */
			if ( $this->method == "POST" && array_key_exists("HTTP_X_HTTP_METHOD", $_SERVER) )
			{
				switch ( $_SERVER["HTTP_X_HTTP_METHOD"] ) {
					case "DELETE":
					case "PUT":
						$this->method = $_SERVER["HTTP_X_HTTP_METHOD"];
					break;;
					default:
						$this->serviceAPIException("400", "Unexpected headers found ...", __CLASS__ . "::" . __FUNCTION__);
					break;;
				}
			}
			
			/**
			 *  Parse data for correct REQUEST method
			 */
			switch ( $this->method ) {
				case "DELETE":
				case "POST":
					$this->request 	= $this->__cleanInput($_POST);
				break;;
				case "GET":
					$this->request 	= $this->__cleanInput($_GET);
				break;;
				case "PUT":
					$this->request 	= $this->__cleanInput($_GET);
					$this->file		= file_get_contents("php://input");
				break;;
				default:
					$this->__response("Invalid method", 405);
				break;;
			}
			
			parent::__construct($server, $sql, $auth, $crypt, $conversionTbl, "RESTFUL");
		}
		
		/**
		 *  Get Arguments from class
		 */
		function getArgs()
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			return($this->args);
		}
		
		function processAPI() {
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			if (method_exists($this, $this->endpoint)) {
				$cc 		= 0;
				$arguments 	= "";
				foreach ($this->args as $var ) {
					$varList[$cc] = $var;
					$arguments .= "\$varList[$cc], ";
					$cc++;
				}
				
				$reflection = new ReflectionMethod('soapServiceClass', $this->endpoint);
				if ( $reflection->getNumberOfRequiredParameters() > $cc ) {
					$this->serviceAPIException("428", "Required arguments missing ...", __CLASS__ . "::" . __FUNCTION__);
				} else {
					$arguments  = substr($arguments, 0, strlen($arguments) - 2);
					$call 		= "\$result = \$this->{\$this->endpoint}(" . $arguments . ");";
					eval($call);
					return $this->__response($result);
				}
			}
			return $this->__response("No Endpoint: $this->endpoint", 404);
		}
		
		/**
		 *  RESTful API deconstructor
		 */
		function __deconstruct()
		{
			
		}
	}
	
	/**
	 *  This RESTful API entrypoint
	 */
	class RESTApi extends RESTFullAPI {		
		/**
		 *  API Constructor
		 */
		function __construct($request, $origin, $start)
		{
			logSysCall(( __CLASS__ == "" ? __FUNCTION__ : __METHOD__), __LINE__, __FILE__);
			$request = strstr($request, $start);
			parent::__construct($request);
			
			if ( isset($this->request["username"]) && isset($this->request["hash"]) ) 
			{ 
				/**
				 *  Are we a test user?
				 */
				if ( $this->request["username"] == "testuser" && $this->request["hash"] == "7f3be433c9bab15315e23fbb4664d33c6074211b" ) {
					$this->authorized 			= true;
					$this->testmode				= true;
					$this->userData["userid"] 	= 1;
				} else {
					/**
					 *  Check user WSDL access
					 */
					$this->userData	= $this->auth->checkWSDLAccess($this->request["username"], $this->request["hash"], $_SERVER["REMOTE_ADDR"]);
					if ( $this->userData ) $this->authorized 	= true;
					$this->userData["userid"] 	= $this->userData["id"];
				}
			} else {
				$this->serviceAPIException("400", "Missing authorization parameters ...", __CLASS__ . "::" . __FUNCTION__);
			}

		}
	}
	
	/**
	 *  Check API request type, RESTful / SOAP
	 */
	$requestHeaders 		= getallheaders();
	$logData["headers"]		= json_encode($requestHeaders);
	$logData["url"]			= $_SERVER["REQUEST_URI"];
	$logData["rawRequest"]	= file_get_contents("php://input");
	$logData["ip"]			= $_SERVER["REMOTE_ADDR"];
	
	/**
	 *  API Processing
	 */
	if ( array_key_exists("SOAPAction", $requestHeaders) || isset($_GET["wsdl"]) ) {	
		/**
		 *  SOAP/API Service Entrypoint
		 */
		if ( isset($_GET["wsdl"]) ) {
			header("Content-type: text/xml");
			/**
			 *  AOZ_WSE_ENDPOINT_PEOPLE_SEARCH Set service endpoint
			 */
			echo str_replace("%%AOZ_WSE_ENDPOINT_PEOPLE_SEARCH%%", AOZ_WSE_ENDPOINT_PEOPLE_SEARCH, file_get_contents("aozWse.wsdl"));
		} else {
			$soapServiceOptions = array(
									"soap_version"	=> SOAP_1_2,
									"cache_wsdl"	=> WSDL_CACHE_NONE,
									"send_errors"	=> true
									);
			$server = new SoapServer("aozWse.wsdl", $soapServiceOptions);
			$server->setClass("soapServiceClass", $server, $sql, $auth, $crypt, $conversionTbl);
			$server->handle();
		}
		$logData["vars"]		= "";
	} else {
		/**
		 *  RESTful API Service Entrypoint
		 */
		if ( array_key_exists("request", $_REQUEST) ) {
			if (!array_key_exists('HTTP_ORIGIN', $_SERVER)) {
				$_SERVER['HTTP_ORIGIN'] = $_SERVER['SERVER_NAME'];
			}

			try {
				$API = new RESTApi($_REQUEST['request'], $_SERVER['HTTP_ORIGIN'], $_REQUEST['start']);
				echo $API->processAPI();
				$logData["vars"] = json_encode($API->getArgs());
			} catch (Exception $e) {
				echo json_encode(Array('error' => $e->getMessage()));
			}
		} else {
			echo "RESTful API Endpoint";
		}
	}