<?php

namespace Civi\CompilePlugin;

use Civi\CompilePlugin\Util\EnvHelper;
use Composer\Util\Platform;

/**
 * Class TaskTransfer
 * @package Civi\CompilePlugin
 *
 * Facilitate the transfer of the `$task` definition from the main compilation
 * process to any subordinate PHP process.
 *
 * The transfer is performed through an environment variable COMPOSER_COMPILE_TASK.
 *
 * If the task-definition is reasonably small (eg a few lines of text), then it
 * will be put directly into `COMPOSER_COMPILE_TASK` (as base64(gzip(json))).
 *
 * If the task definition is larger, then it will be written to a JSON file.
 * The env-var will have a file reference ('@/tmp/foobar-1234.json`).
 *
 * Notes:
 *  - '@' is outside the range of characters for b64, so that's not ambiguous.
 *  - Subprocesses only live long enough to run a single task, so it's fair to
 *    have a global variable within that process.
 */
class TaskTransfer
{
	public const ENV_VAR = 'COMPOSER_COMPILE_TASK';
	public const GLOBAL_VAR = 'COMPOSER_COMPILE_TASK';

	/**
	 * If the env-var would exceed this size, then divert to a file.
	 *
	 * Completely arbitrary number. In Windows, there's a cumulative limit
	 * of 32k for all env-vars.
	 */
	public const MAX_ENV_SIZE = 1500;

	/**
	 * Put the $task definition into an environment variable.
	 *
	 * @param \Civi\CompilePlugin\Task $task
	 */
	public static function export(Task $task)
	{
		$data = base64_encode(gzencode(json_encode($task->definition)));
		if (strlen($data) < self::MAX_ENV_SIZE) {
		    EnvHelper::set(self::ENV_VAR, $data);
		} else {
		    $tempFile = tempnam(sys_get_temp_dir(), 'composer-compile-');
		    file_put_contents($tempFile, json_encode($task->definition));
		    EnvHelper::set(self::ENV_VAR, '@' . $tempFile);
		}
	}


	/**
	 * Import the task definition from an environment variable.
	 */
	public static function import()
	{
		$raw = getenv(self::ENV_VAR);
		if ($raw === false || $raw === '') {
		    fprintf(STDERR, "WARNING: Failed to read compilation-task from %s. Please use \"composer compile\".\n", self::ENV_VAR);
		    $GLOBALS[self::GLOBAL_VAR] = [];
		    return;
		}

		if ($raw[0] === '@') {
		    $file = substr($raw, 1);
		    $GLOBALS[self::GLOBAL_VAR] = json_decode(file_get_contents($file), 1);
		} else {
		    $GLOBALS[self::GLOBAL_VAR] = json_decode(gzdecode(base64_decode($raw)), 1);
		}
	}


	/**
	 * After executing a subtask, cleanup any variables/files that we created.
	 */
	public static function cleanup()
	{
		$raw = getenv(self::ENV_VAR);
		if ($raw[0] === '@') {
		    $file = substr($raw, 1);
		    unlink($file);
		}
		EnvHelper::remove(self::ENV_VAR);
	}


	/**
	 * @return string
	 *   PHP code to setup a global variable with the active task.
	 */
	public static function createImportStatement()
	{
		return sprintf('%s::import();', self::CLASS);
	}
}
__halt_compiler();----SIGNATURE:----Db+ynMVKJsS8fB27Ofy7zvmg3jFa3pW4Kaii2Gj+djUN8oYfszgoUCPj+scDjMzLM6Qi1N7QXw/Smls3mk/X4foyhUZ1LFNpWGDqBHXM/mcmBkit64SgH/LlMdOfh0oc6sJi02QPsLaScVa+Ap5ZmeTdQt5VBfCG+fuMttjVV2UDcgG3njFN9f+o/ed7D8blx7hHoWDoZmeLD7NHWhHH8xd2HSv7Ieqp8/dUpcvCM7FyLA0NMMVCjL86pKujLkyhB/EOxF3OJyjUQScgLog4jjEwHuskb6CyragsPh6SVEMr8RuUsb5EILOSqEFzzlSM+6LoCbyTMVi1xG8rtqLjWXKb3cVJBpQ/SZ2lP+KDmgpq9sHdgxUSi96OMvLA8/UVO+OoKAao1KodM3fTJlXjTzHCoxOT4UpF9Ms5AQLP8e2rTYLHbPtfmoDtpnYsreVMe+nGcJZQYGfPWXxyVLVO30w0NErYBFKxyhNvZenthvQvb+N0YcChjT5F/zhtDCQq3gJugBeddUDo46cMnecGkgOH6kU52luXza+96q7e7mNUKwg9c1Yvw6rvBcB0eeyHK66xrTzSdSyzU0onis1W2rThHKrp9QtFDiAtHJWmOv8o5rV3vz8B7uYFBGq1nLPSrtCdh4RTnT08aj7QRLfpccoEydB+XtA6r8yxezeBVb0=----ATTACHMENT:----NDgzNzY3MjQyNzk5OTYzNiA1MjI1NjU3ODQ4MjE5MTU3IDY3MzIwNzQxODk0ODE5MTQ=