<?php

namespace ProcessMaker\Models;

use Illuminate\Database\Eloquent\ModelNotFoundException;

use Illuminate\Validation\Rule;

use ProcessMaker\Exception\ScriptLanguageNotSupported;

use ProcessMaker\Facades\Docker;

use ProcessMaker\Traits\Exportable;

use ProcessMaker\Traits\HasVersioning;

use ProcessMaker\Traits\HideSystemResources;

/**

* Represents an Eloquent model of a Script Executor

*

*

* @property int id

* @property string title

* @property text description

* @property string language

* @property text config

* @property string value

* @property text initDockerFile

*

* @OA\Schema(

* schema="scriptExecutorsEditable",

* @OA\Property(property="title", type="string"),

* @OA\Property(property="description", type="string"),

* @OA\Property(property="language", type="string"),

* @OA\Property(property="config", type="string"),

* @OA\Property(property="is_system", type="boolean"),

* ),

* @OA\Schema(

* schema="scriptExecutors",

* allOf={

* @OA\Schema(ref="#/components/schemas/scriptExecutorsEditable"),

* @OA\Schema(

* @OA\Property(property="id", type="integer", format="id"),

* @OA\Property(property="created_at", type="string", format="date-time"),

* @OA\Property(property="updated_at", type="string", format="date-time"),

* )

* },

* ),

*

* @OA\Schema(

* schema="availableLanguages",

* @OA\Property(property="text", type="string"),

* @OA\Property(property="value", type="string"),

* @OA\Property(property="initDockerFile", type="string"),

* ),

*/

class ScriptExecutor extends ProcessMakerModel

{

use HasVersioning;

use Exportable;

use HideSystemResources;

protected $fillable = [

'title', 'description', 'language', 'config', 'is_system',

];

public static function install($params)

{

$language = $params['language'];

try {

$initialExecutor = self::initialExecutor($language);

} catch (ScriptLanguageNotSupported $e) {

$initialExecutor = null;

}

if ($initialExecutor) {

$initialExecutor->update($params);

} else {

$initialExecutor = self::create($params);

Script::where('language', $language)->update(['script_executor_id' => $initialExecutor->id]);

ScriptVersion::where('language', $language)->update(['script_executor_id' => $initialExecutor->id]);

}

return $initialExecutor;

}

public static function initialExecutor($language)

{

$initialExecutor = self::where('language', $language)

->orderBy('created_at', 'asc')

->first();

if (!$initialExecutor) {

throw new ScriptLanguageNotSupported($language);

}

return $initialExecutor;

}

public function versions()

{

return $this->hasMany(ScriptExecutorVersion::class);

}

public static function initDockerfile($language)

{

// remove try/catch block after lang packages updated

try {

$dockerfile = file_get_contents(self::packagePath($language) . '/Dockerfile');

} catch (\ErrorException $e) {

$dockerfile = '';

}

$initDockerfile = self::config($language)['init_dockerfile'];

// remove check after lang packages updated

if (!is_array($initDockerfile)) {

$initDockerfile = explode("\n", $initDockerfile);

}

$dockerfile .= "\n" . implode("\n", $initDockerfile);

return $dockerfile;

}

public static function packagePath($language)

{

return self::config($language)['package_path'];

}

public static function config($language)

{

$config = config('script-runners');

$language = strtolower($language);

if (!isset($config[$language])) {

throw new \ErrorException('Language not in config: ' . $language);

}

return $config[$language];

}

public static function rules($existing = null)

{

return [

'title' => 'required',

'language' => [

'required',

Rule::in(Script::scriptFormatValues()),

],

];

}

public static function list($language = null)

{

$list = [];

$executors =

self::where('is_system', false)->orderBy('language', 'asc')

->orderBy('created_at', 'asc');

if ($language) {

$executors->where('language', $language);

}

foreach ($executors->get() as $executor) {

$list[$executor->id] = [

'language' => $executor->language,

'title' => $executor->title,

];

}

return $list;

}

public function dockerImageName()

{

$lang = strtolower($this->language);

$id = $this->id;

$tag = $this->imageTag();

$instance = config('app.instance');

return "processmaker4/executor-{$instance}-{$lang}-{$id}:{$tag}";

}

public function imageTag()

{

$config = self::config($this->language);

$tag = 'v';

if (isset($config['package_version'])) {

$tag .= $config['package_version'];

}

return $tag;

}

public function scripts()

{

return $this->hasMany(Script::class);

}

public function getScriptsCountAttribute()

{

return $this->scripts()->count();

}

public function dockerImageExists()

{

$images = self::listOfExecutorImages();

return in_array($this->dockerImageName(), $images);

}

public static function listOfExecutorImages($filterByLanguage = null)

{

exec(Docker::command() . ' images | awk \'{r=$1":"$2; print r}\'', $result);

$instance = config('app.instance');

return array_values(array_filter($result, function ($image) use ($filterByLanguage, $instance) {

$filter = "processmaker4/executor-{$instance}-";

if ($filterByLanguage) {

$filter .= $filterByLanguage . '-';

}

return strpos($image, $filter) !== false;

}));

}

}