upload_status.php

<?php
require __DIR__ . '/vendor/autoload.php';
require_once "../config.php";

use \Tsugi\Util\U;
use \Tsugi\Util\Net;
use \Tsugi\Core\LTIX;
use \Tsugi\Core\Settings;
use \Tsugi\UI\SettingsForm;
use \Tsugi\Blob\BlobUtil;

use \CloudConvert\CloudConvert;
use \CloudConvert\Models\Job;
use \CloudConvert\Models\Task;

// No parameter means we require CONTEXT, USER, and LINK
$LAUNCH = LTIX::requireData();

$job_id = U::get($_SESSION, 'job_id');
$job_start = U::get($_SESSION, 'job_start');
$retval = array();
header('Content-Type: application/json');

if ( ! $job_id ) {
    $retval['status'] = 'There is no active conversion';
    echo(json_encode($retval, JSON_PRETTY_PRINT));
    return;
}
$retval['job_id'] = $job_id;
if ( $job_start ) {
    $retval['ellapsed'] = time() - $job_start;
}

$context_settings = $LAUNCH->context->settingsGetAll();

// https://github.com/cloudconvert/cloudconvert-php
$api_key = U::get($context_settings, 'api_key');
$sandbox = U::get($context_settings, 'sandbox');

if ( ! $api_key ) {
    $retval['status'] = 'API Key not configured.';
    echo(json_encode($retval, JSON_PRETTY_PRINT));
    return;
}

$cloudconvert = new CloudConvert([
    'api_key' => $api_key,
    'sandbox' => $sandbox == 'true'
]);

$tag = "context_". $LAUNCH->context->id . '::result_' . $LAUNCH->result->id;


$job = $cloudconvert->jobs()->get($job_id);

/* 
    public const STATUS_WATING = 'waiting';
    public const STATUS_PROCESSING = 'processing';
    public const STATUS_ERROR = 'error';
    public const STATUS_FINISHED = 'finished';
*/
$status = $job->getStatus();
$retval['status'] = $status;

// Grab extra bits.
$debug = array();
$debug['tag'] = $job->getTag();
$debug['created_at'] = $job->getCreatedAt();
$debug['ended_at'] = $job->getEndedAt();
$retval['job'] = $debug;

if ( $status == Job::STATUS_ERROR ) {
	$all_tasks = $job->getTasks();
	$tasks = array();
    $code = false;
	foreach($all_tasks as $one_task) {
		// It seems like the last one is the best one...
		$code = $one_task->getCode();
		$task = array();
		$task['code'] = $one_task->getCode();
		$task['message'] = $one_task->getMessage();
		$tasks[] = $task;
	}
	if ( $code) $retval['code'] = $code;
	$retval['tasks'] = $tasks;
    echo(json_encode($retval, JSON_PRETTY_PRINT));
    return;
}

$previous_status = U::get($_SESSION, 'previous_status');

if ( $status != Job::STATUS_FINISHED ) {
    echo(json_encode($retval, JSON_PRETTY_PRINT));
    return;
}

if ( $status == Job::STATUS_FINISHED && ! $previous_status ) {
    $_SESSION['previous_status'] = $status;
    $retval['status'] = 'downloading';
    echo(json_encode($retval, JSON_PRETTY_PRINT));
    return;
}

unset($_SESSION['previous_status']);

// TODO: Try / except here
$results = array();
foreach ($job->getExportUrls() as $file) {

    error_log('Started download '.$file->url);
    $source = $cloudconvert->getHttpTransport()->download($file->url)->detach();
    error_log('Download complete '.$file->url);

    $temp_file = tempnam(sys_get_temp_dir(), $job->getTag());
    $dest = fopen($temp_file, 'w');

    $results[] = $temp_file;
    stream_copy_to_stream($source, $dest);
    error_log('Inserting Blob '.$temp_file);
    $blob_id = BlobUtil::uploadPathToBlob($temp_file, 'text/html');
    error_log('Inserted Blob '.$temp_file.' '.$blob_id);
    $LAUNCH->result->setJsonKey('blob_id', $blob_id);

    // TODO: unlink($temp_file);

}
$retval['results'] = $results;

echo(json_encode($retval, JSON_PRETTY_PRINT));