GraphictoriaWeb/web/app/Grid/SoapService.php

<?php

/*
	Graphictoria 2022
	This file handles communications between the arbiter and the website.
*/

// TODO: Comment the return values and descriptions of the soap service functions.
// TODO: Make new classes in App\Grid to automate the generation of thumbnails and game servers.

namespace App\Grid;

use Illuminate\Support\Facades\Storage;
use SoapClient;

class SoapService
{
	/**
     * SoapClient used by the functions in this class.
     *
     * @var SoapClient
     */
	public $Client;
	
	/**
     * Constructs the SoapClient.
	 *
	 * Arbiter address should be formatted like "http://127.0.0.1:64989"
     *
     * @param  string  $arbiterAddr
     * @return null
     */
	public function __construct($arbiterAddr) {
		$this->Client = new SoapClient(
			Storage::path('grid/RCCService.wsdl'),
			[
				'location' => $arbiterAddr,
				'uri' => 'http://roblox.com/',
				'exceptions' => false
			]
		);
	}
	
	/**
     * Calls on the soap service.
     *
     * @param  string  $name
	 * @param  array $args
     * @return null
     */
	public function CallService($name, $args = []) {
		$soapResult = $this->Client->{$name}($args);
		
		if(is_soap_fault($soapResult)) {
			// TODO: log faults
		}
		
		return $soapResult;
	}
	
	/* Job constructors */
	
	public static function LuaValue($value)
	{
		switch ($value) {
			case is_bool(json_encode($value)) || $value == 1:
				return json_encode($value);
			default:
				return $value;
		}
	}
	
	public static function CastType($value)
	{
		$luaTypeConversions = [
			'NULL' 		=> 'LUA_TNIL',
			'boolean'	=> 'LUA_TBOOLEAN',
			'integer'	=> 'LUA_TNUMBER',
			'double'	=> 'LUA_TNUMBER',
			'string'	=> 'LUA_TSTRING',
			'array'		=> 'LUA_TTABLE',
			'object'	=> 'LUA_TNIL'
		];
		return $luaTypeConversions[gettype($value)];
	}
	
	public static function ToLuaArguments($luaArguments = [])
    {
		$luaValue = ['LuaValue' => []];
		
		foreach ($luaArguments as $argument) {
			array_push(
				$luaValue['LuaValue'],
				[
					'type' => SoapService::CastType($argument),
					'value' => SoapService::LuaValue($argument)
				]
			);
		}
		
		return $luaValue;
    }
	
	public static function MakeJobJSON($jobID, $expiration, $category, $cores, $scriptName, $script, $scriptArgs = [])
	{
		return [
				'job' => [
					'id' => $jobID,
					'expirationInSeconds' => $expiration,
					'category' => $category,
					'cores' => $cores
				],
				'script' => [
					'name' => $scriptName,
					'script' => $script,
					'arguments' => SoapService::ToLuaArguments($scriptArgs)
				]
			];
	}
	
	/* Service functions */
	
	public function HelloWorld()
    {
		return $this->CallService('HelloWorld');
    }
	
	public function GetVersion()
    {
		return $this->CallService('GetVersion');
    }
	
	public function GetStatus()
    {
		return $this->CallService('GetStatus');
    }
	
	/* Job specific functions */
	
	public function BatchJobEx($args)
    {
		return $this->CallService('BatchJobEx', $args);
    }
	
	public function OpenJobEx($args)
    {
		return $this->CallService('OpenJobEx', $args);
    }
	
	public function ExecuteEx($args)
    {
		return $this->CallService('ExecuteEx', $args);
    }
	
	public function GetAllJobsEx()
    {
		return $this->CallService('GetAllJobsEx');
    }
	
	public function CloseExpiredJobs()
    {
		return $this->CallService('CloseExpiredJobs');
    }
	
	public function CloseAllJobs()
    {
		return $this->CallService('CloseAllJobs');
    }
	
	/* Job management */
	
	public function DiagEx($jobID, $type)
    {
		return $this->CallService(
			'DiagEx',
			[
				'type' => $type,
				'jobID' => $jobID
			]
		);
    }
	
	public function CloseJob($jobID)
    {
		return $this->CallService(
			'CloseJob',
			[
				'jobID' => $jobID
			]
		);
    }
	
	public function GetExpiration($jobID)
    {
		return $this->CallService(
			'GetExpiration',
			[
				'jobID' => $jobID
			]
		);
    }
	
	public function RenewLease($jobID, $expiration)
    {
		return $this->CallService(
			'RenewLease',
			[
				'jobID' => $jobID,
				'expirationInSeconds' => $expiration
			]
		);
    }
	
	/* dep */
	
	public function BatchJob($args)
    {
		return $this->BatchJobEx($args);
    }
	
	public function OpenJob($args)
    {
		return $this->OpenJobEx($args);
    }
	
	public function Execute($args)
    {
		return $this->ExecuteEx($args);
    }
	
	public function GetAllJobs()
    {
		return $this->GetAllJobsEx();
    }
	
	public function Diag($jobID, $type)
    {
		return $this->DiagEx($jobID, $type);
	}
}