<?php

namespace Arlo\Importer;

use Arlo\Logger;
use Arlo\Utilities;

class ImportRequest extends BaseImporter  {
	const schema_level = 100;
	const FRAGMENT_MAX_BYTE_SIZE = 10485760;
	const FRAGMENT_DEFAULT_BYTE_SIZE = 524288;	

	private $nonce;

	private $callback_action = 'arlo_import_callback';
	
	private $snapshot_type = "Full";
	private $fields = [
		'Regions' => [
			'RegionID', 'Name',
		],
		'TimeZones' => [
			'TimeZoneID', 'Name', 'WindowsTzID'
		],
		'Events' => [
			'EventID', 'EventTemplateID', 'Name', 'Code', 'Description', 'Summary', 'StartDateTime', 'EndDateTime', 'TimeZoneID', 'TimeZone', 'Location', 'IsFull', 'PlacesRemaining', 'AdvertisedOffers', 'SessionsDescription', 'Presenters', 'Notice', 'ViewUri', 'RegistrationInfo', 'Provider', 'TemplateCode', 'Tags', 'Credits', 'Sessions.EventID', 'Sessions.Name', 'Sessions.Code', 'Sessions.Summary', 'Sessions.StartDateTime', 'Sessions.EndDateTime', 'Sessions.TimeZoneID', 'Sessions.TimeZone', 'Sessions.Location', 'Sessions.IsFull', 'Sessions.PlacesRemaining','Sessions.AdvertisedOffers', 'Sessions.Presenters', 'Sessions.Tags'
		],
		'Templates' => [
			'TemplateID', 'Code', 'Name', 'Description', 'AdvertisedPresenters', 'AdvertisedDuration', 'BestAdvertisedOffers', 'ViewUri', 'RegisterInterestUri', 'RegisterPrivateInterestUri', 'Categories', 'Tags', 'Credits', 'Media',
		],	
		'Presenters' => [
			'PresenterID', 'FirstName', 'LastName', 'ViewUri', 'Profile', 'SocialNetworkInfo',
		],
		'OnlineActivities' => [
			'OnlineActivityID', 'TemplateID', 'Name', 'Code', 'DeliveryDescription', 'ViewUri', 'ReferenceTerms', 'Credits', 'RegistrationInfo', 'AdvertisedOffers', 'Tags',
		],
		'Venues' => [
			'VenueID', 'Name', 'GeoData', 'PhysicalAddress', 'FacilityInfo', 'ViewUri',
		],
		'Categories' => [
			'CategoryID', 'ParentCategoryID', 'Name', 'SequenceIndex', 'Description', 'Footer',
		],
		'CategoryItems' => [
			'CategoryID', 'EventTemplateID', 'SequenceIndex',
		],
	];
	private $encription_type = 'A256CBC-HS512';

	private $fragmentation = true;
	public $fragment_size;

	protected function save_entity($item) {}

	public function run() {
		$this->nonce = \Arlo\Utilities::GUIDv4(true, true);

		$this->importer->set_import_entry($this->nonce);

		$this->check_fragment_byte_size();

		$retval = $this->api_client->Snapshots()->request_import($this->generate_post_data($this->fragmentation));

		if (!empty($retval->RequestID)) {
			$data = [
					'request_id' => $retval->RequestID,
					'response_json' => json_encode($retval),
				];
 
			$this->importer->update_import_entry($data);
		}

		$this->is_finished = true;
	}

	private function check_fragment_byte_size() {
		if (empty($this->fragment_size) || !is_numeric($this->fragment_size) ) {
			$this->fragment_size = self::FRAGMENT_DEFAULT_BYTE_SIZE;
		} else if ($this->fragment_size > self::FRAGMENT_MAX_BYTE_SIZE) {
			$this->fragment_size = self::FRAGMENT_MAX_BYTE_SIZE;
		}
	}

	private function generate_post_data($fragmentation = false) {
		$data_obj = new \stdClass();

		$data_obj->SchemaLevel = self::schema_level;
		$data_obj->SnapshotType = $this->snapshot_type;
		$data_obj->Query = $this->generate_query_object();
		$data_obj->Result = $this->generate_result_object($fragmentation);
		$data_obj->Callback = $this->generate_callback_object();

		return $data_obj;
	}

	private function generate_query_object() {
		$data_obj = new \stdClass();

		foreach ($this->fields as $group => $field) {
			$obj_key = $group . ".Fields";
			$data_obj->$obj_key = implode(",", $field);
		}

		return $data_obj;
	}

	private function generate_result_object($fragmentation = false) {
		$data_obj = new \stdClass();
		$data_obj->EncryptedResponse = $this->generate_encryptedresponse_object();

		if ($fragmentation) {
			$data_obj->Disposition = "Fragmented";
			$data_obj->Fragmentation = new \stdClass(); 
			$data_obj->Fragmentation->FragmentMaxSizeBytes = $this->fragment_size;
		}

		return $data_obj;
	}

	private function generate_callback_object() {
		$data_obj = new \stdClass();

		$data_obj->Uri = admin_url('admin-ajax.php') . '?action=' . $this->callback_action;
		$data_obj->Nonce = $this->nonce;
		$data_obj->EncryptedResponse = $this->generate_encryptedresponse_object();

		$settings = get_option('arlo_settings');
		if (!empty($settings['import_callback_host'])) {
			$site_url = parse_url(get_option( 'siteurl' ));
			$callback_url = parse_url($settings['import_callback_host']);
			
			$search_url = $site_url["host"] . (!empty($site_url['port']) ? ':' . $site_url['port'] : '');
			$replace_url = $callback_url["host"] . (!empty($callback_url['port']) ? ':' . $callback_url['port'] : '');

			$data_obj->Uri = str_replace($search_url, $replace_url, $data_obj->Uri);
		}

		return $data_obj;
	}
	

	private function generate_encryptedresponse_object() {
		$data_obj = new \stdClass();

		$data_obj->alg = "dir";
		$data_obj->enc = $this->encription_type;

		return $data_obj;
	}
}