feat: getting executor name

.env

@@ -4,10 +4,11 @@ OPR_EXECUTOR_CONNECTION_STORAGE=file://localhost
 OPR_EXECUTOR_INACTIVE_TRESHOLD=60
 OPR_EXECUTOR_MAINTENANCE_INTERVAL=60
 OPR_EXECUTOR_NETWORK=runtimes-1,runtimes-2
-OPR_EXECUTOR_NAME=executor
+OPR_EXECUTOR_IMAGE=ldoes-not-exist
 OPR_EXECUTOR_SECRET=executor-secret-key
+OPR_EXECUTOR_NAME=executor
 OPR_EXECUTOR_LOGGING_PROVIDER=
 OPR_EXECUTOR_LOGGING_CONFIG=
 OPR_EXECUTOR_DOCKER_HUB_USERNAME=
 OPR_EXECUTOR_DOCKER_HUB_PASSWORD=
-OPR_EXECUTOR_RUNTIME_VERSIONS=v3
+OPR_EXECUTOR_RUNTIME_VERSIONS=v3

app/http.php

@@ -49,7 +49,7 @@
 
 Runtime::enableCoroutine(true, SWOOLE_HOOK_ALL);
 
-Http::setMode((string) Http::getEnv('OPR_EXECUTOR_ENV', Http::MODE_TYPE_PRODUCTION));
+Http::setMode((string)Http::getEnv('OPR_EXECUTOR_ENV', Http::MODE_TYPE_PRODUCTION));
 
 // Setup Registry
 $register = new Registry();
@@ -81,8 +81,8 @@
  * Create orchestration
  */
 $register->set('orchestration', function () {
-    $dockerUser = (string) Http::getEnv('OPR_EXECUTOR_DOCKER_HUB_USERNAME', '');
-    $dockerPass = (string) Http::getEnv('OPR_EXECUTOR_DOCKER_HUB_PASSWORD', '');
+    $dockerUser = (string)Http::getEnv('OPR_EXECUTOR_DOCKER_HUB_USERNAME', '');
+    $dockerPass = (string)Http::getEnv('OPR_EXECUTOR_DOCKER_HUB_PASSWORD', '');
     $orchestration = new Orchestration(new DockerCLI($dockerUser, $dockerPass));
 
     return $orchestration;
@@ -145,7 +145,7 @@ function logError(Log $log, Throwable $error, string $action, Logger $logger = n
     Console::error('[Error] Line: ' . $error->getLine());
 
     if ($logger && ($error->getCode() === 500 || $error->getCode() === 0)) {
-        $version = (string) Http::getEnv('OPR_EXECUTOR_VERSION', '');
+        $version = (string)Http::getEnv('OPR_EXECUTOR_VERSION', '');
         if (empty($version)) {
             $version = 'UNKNOWN';
         }
@@ -261,14 +261,25 @@ function getStorageDevice(string $root): Device
     }
 }
 
+
 /**
  * @param array<string> $networks
  *
  * @return array<string>
  */
 function createNetworks(Orchestration $orchestration, array $networks): array
 {
-    $containerName = Http::getEnv('OPR_EXECUTOR_NAME') ?? 'executor';
+    $imageName = Http::getEnv('OPR_EXECUTOR_IMAGE') ;
+    if (empty($imageName)) {
+        throw new \Exception('Executor image name is not set');
+    }
+    $containers = $orchestration->list(['ancestor' => $imageName, 'status' => 'running']);
+
+    if (count($containers) < 1) {
+        throw new \Exception('No running executor found');
+    }
+
+    $containerName = $containers[0]->getName();
     $createdNetworks = [];
     $jobs = [];
 
@@ -502,18 +513,21 @@ function cleanUp(Orchestration $orchestration, Table $activeRuntimes, array $net
             /**
              * Create container
              */
-            $variables = \array_merge($variables, match ($version) {
-                'v2' => [
-                    'INTERNAL_RUNTIME_KEY' => $secret,
-                    'INTERNAL_RUNTIME_ENTRYPOINT' => $entrypoint,
-                    'INERNAL_EXECUTOR_HOSTNAME' => System::getHostname()
-                ],
-                'v3' => [
-                    'OPEN_RUNTIMES_SECRET' => $secret,
-                    'OPEN_RUNTIMES_ENTRYPOINT' => $entrypoint,
-                    'OPEN_RUNTIMES_HOSTNAME' => System::getHostname()
-                ]
-            });
+            $variables = \array_merge(
+                $variables,
+                match ($version) {
+                    'v2' => [
+                        'INTERNAL_RUNTIME_KEY' => $secret,
+                        'INTERNAL_RUNTIME_ENTRYPOINT' => $entrypoint,
+                        'INERNAL_EXECUTOR_HOSTNAME' => System::getHostname()
+                    ],
+                    'v3' => [
+                        'OPEN_RUNTIMES_SECRET' => $secret,
+                        'OPEN_RUNTIMES_ENTRYPOINT' => $entrypoint,
+                        'OPEN_RUNTIMES_HOSTNAME' => System::getHostname()
+                    ]
+                }
+            );
 
             $variables = array_map(fn ($v) => strval($v), $variables);
             $orchestration
@@ -1155,7 +1169,7 @@ function (string $runtimeId, ?string $payload, string $path, string $method, arr
             $response
                 ->setStatusCode(Response::STATUS_CODE_OK)
                 ->setContentType(Response::CONTENT_TYPE_JSON, Response::CHARSET_UTF8)
-                ->send((string) $executionString);
+                ->send((string)$executionString);
         }
     );
 
@@ -1296,7 +1310,7 @@ function (string $runtimeId, ?string $payload, string $path, string $method, arr
      * Run a maintenance worker every X seconds to remove inactive runtimes
      */
     Console::info('Starting maintenance interval...');
-    $interval = (int) Http::getEnv('OPR_EXECUTOR_MAINTENANCE_INTERVAL', '3600'); // In seconds
+    $interval = (int)Http::getEnv('OPR_EXECUTOR_MAINTENANCE_INTERVAL', '3600'); // In seconds
     Timer::tick($interval * 1000, function () use ($orchestration, $activeRuntimes) {
         Console::info("Running maintenance task ...");
         // Stop idling runtimes

docker-compose.yml

@@ -14,8 +14,8 @@ version: '3'
 
 services:
   openruntimes-executor:
-    container_name: $OPR_EXECUTOR_NAME
     hostname: $OPR_EXECUTOR_NAME
+    image: $OPR_EXECUTOR_IMAGE
     <<: *x-logging
     stop_signal: SIGINT
     build:
@@ -42,7 +42,7 @@ services:
       - OPR_EXECUTOR_MAINTENANCE_INTERVAL
       - OPR_EXECUTOR_NETWORK
       - OPR_EXECUTOR_SECRET
-      - OPR_EXECUTOR_NAME
+      - OPR_EXECUTOR_IMAGE
       - OPR_EXECUTOR_LOGGING_PROVIDER
       - OPR_EXECUTOR_LOGGING_CONFIG
       - OPR_EXECUTOR_DOCKER_HUB_USERNAME
@@ -55,4 +55,4 @@ services:
 
 volumes:
   openruntimes-builds:
-  openruntimes-functions:
+  openruntimes-functions: