<?php
namespace SamApiLib;

class HcpApi
{
	
	private $base_url;
	private $auth_token;
	
	const cookie_name = "hcp-ns-auth";
	
	
	function __construct($base_url, $login, $password)
	{
		$this->base_url = $base_url;
		$this->auth_token = base64_encode($login) . ":" . md5($password);
	}
	
	public static function create($protocol, $repository_url, $tenant, $namespace, $login, $password)
	{
		$base_url = "$protocol://$namespace.$tenant.$repository_url";
		return new self($base_url, $login, $password);
	}
	
	
	/**
	 * REST API query helper
	 * @param $ws_route
	 * @param $url_params
	 * @param $query_params
	 * @param $body_params
	 * @return array
	 */
	protected function query($ws_method, $ws_url, $url_params, $query_params, $body_params)
	{
		$query_string = http_build_query($query_params);
		foreach ($url_params as $url_param => $value)
		{
			$ws_url = str_replace('{'.$url_param.'}', $value, $ws_url);
		}
		$url = $this->base_url . $ws_url . "?" . $query_string;
		
		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, $url);
		curl_setopt($ch, CURLOPT_HEADER, true);
		
		$ws_method = strtoupper($ws_method);
		if($ws_method !== "GET")
		{
			if($ws_method === "POST")
			{
				curl_setopt($ch, CURLOPT_POST, true);
				curl_setopt($ch, CURLOPT_POSTFIELDS, (json_encode($body_params)));
			}
			elseif ($ws_method === "PUT")
			{
				curl_setopt($ch, CURLOPT_PUT, true);
				if(file_exists($body_params) && is_readable($body_params))
				{
					curl_setopt($ch, CURLOPT_INFILE, fopen($body_params, "r"));
					curl_setopt($ch, CURLOPT_INFILESIZE, filesize($body_params));
				}
				else
				{
					die("file open error");
				}
			}
			elseif ($ws_method === "HEAD")
			{
				curl_setopt($ch, CURLOPT_NOBODY, true);
			}
			else
			{
				curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $ws_method);
			}
		}
		
		curl_setopt($ch, CURLOPT_COOKIE, self::cookie_name . "=" . $this->auth_token);
		
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$res = curl_exec($ch);
		if ($res === false)
		{
			echo "curl error #" . curl_errno($ch) . " : " . curl_error($ch); die;
		}
		curl_close($ch);
		
// 		var_dump($res); die;
		list($headers, $body) = explode("\r\n\r\n", $res); // PHP_EOL.PHP_EOL
		$headers = explode("\r\n", $headers);
		
		// sometimes headers are in the body
		if(count($headers) === 1 && !empty($body))
		{
			$headers = explode("\r\n", $body);
			$body = "";
		}
		else
		{
			$body2 = json_decode($body, true);
			if(json_last_error() === JSON_ERROR_NONE)
			{ // content was really json
				$body = $body2; // use decoded content
			}
		}
		
		$status_row = array_shift($headers);
		preg_match("|HTTP/1.1 (\d+) (.+)|", $status_row, $matches);
		$status = $matches[1];
		
		$headers2 = [];
		foreach ($headers as $header)
		{
			list($key, $value) = \explode(": ", $header);
			$headers2 [$key] = $value;
		}
		
		return [$status, $headers2, $body];
	}
	
	
	public function put_file ($filename, $directory)
	{
		$basename = basename($filename);
		list($status, $headers, $body) = $this->query("put", "/rest/$directory/$basename", [], [], $filename);
		
		if($status === "201")
		{
			// check the hash
			$keyword = "X-HCP-Hash";
			$algo = "";
			$hash = "";
			$test = array_filter($headers, function($header) use ($keyword, &$algo, &$hash)
			{
				if(preg_match("|$keyword: (.+) (.+)|", $header, $matches) === 1)
				{
					list(,$algo, $hash) = $matches;
					return true;
				}
				else
				{
					return false;
				}
			});
			if($algo === "SHA-256")
			{
				$hash_calculated = strtoupper(hash("sha256", file_get_contents($filename)));
				if($hash !== $hash_calculated)
				{
					die("hash mismatch");
				}
			}
		}
		
		//TODO handle 409 ...
		return $status;
	}
	
	
	public function get_file ($filename)
	{
		list($status, $headers, $body) = $this->query("get", "/rest/$filename", [], [], []);
		
		//TODO handle 404 ...
		if($status == 200)
		{
			return $body;
		}
		else
		{
			return false;
		}
	}
	
	
	public function delete_file ($filename)
	{
		list($status, $headers, $body) = $this->query("delete", "/rest/$filename", [], [], []);
		
		//TODO handle 403 404 ...
		return $status;
	}
	
	
	public function head_file ($filename)
	{
		list($status, $headers, $body) = $this->query("head", "/rest/$filename", [], [], []);
		
		if($status == 200)
		{
			return $headers;
		}
		elseif($status == 404)
		{
			return false;
		}
	}
	
	
	public function list_files ($directory)
	{
		list($status, $headers, $body) = $this->query("get", "/rest/$directory", [], [/*"type" => "directory"*/], []);
		
		//TODO handle 404 ...
		if($status == 200)
		{
// 			echo $body . PHP_EOL;
			$res = [];
			$xml = \simplexml_load_string($body);
			foreach ($xml->entry as $entry)
			{
				$elem = ((array)$entry->attributes())['@attributes'];
				$res [$elem["urlName"]] = $elem;
			}
			
			return $res;
		}
		else
		{
			return false;
		}
	}
	
}