feat: #14 allow to configure services

Author: bohdan-shulha

api-nodes/Http/Controllers/NextTaskController.php

@@ -3,7 +3,7 @@
 namespace ApiNodes\Http\Controllers;
 
 use App\Models\Node;
-use App\Models\NodeTask\TaskStatus;
+use App\Models\NodeTasks\TaskStatus;
 use App\Models\NodeTaskGroup;
 use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Http\Response;

api-nodes/Http/Controllers/TaskController.php

@@ -2,9 +2,8 @@
 
 namespace ApiNodes\Http\Controllers;
 
-use App\Casts\TaskResultCast;
 use App\Models\NodeTask;
-use App\Models\NodeTask\ErrorResult;
+use App\Models\NodeTasks\ErrorResult;
 use Illuminate\Http\Request;
 use Illuminate\Http\Response;
 
@@ -20,7 +19,9 @@ public function complete(NodeTask $task, Request $request)
             return new Response(['error' => "Task didn't start yet."], 409);
         }
 
-        $result = TaskResultCast::RESULT_BY_TYPE[$task->type]::validateAndCreate($request->all());
+        $resultClass = $task->type->result();
+
+        $result = $resultClass::validateAndCreate($request->all());
 
         $task->complete($result);
 

api-nodes/Http/Middleware/AgentTokenAuth.php

@@ -3,7 +3,7 @@
 namespace ApiNodes\Http\Middleware;
 
 use App\Models\Node;
-use App\Models\NodeTask;
+use App\Models\NodeTasks;
 use App\Models\Scopes\TeamScope;
 use App\Models\Team;
 use Closure;

app/Casts/TaskMetaCast.php

@@ -0,0 +1,77 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Str;
+
+class MakeNodeTask extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'make:node-task [taskName]';
+
+    /**
+     * The console command description.
+     *34
+     * @var string
+     */
+    protected $description = 'Create a new node task';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle(): void
+    {
+        $this->promptForMissingArguments($this->input, $this->output);
+
+        $taskName = $this->hasArgument('taskName')
+            ? $this->argument('taskName')
+            : $this->ask('Enter task name');
+
+        $taskName = Str::camel($taskName);
+        $taskName = Str::ucfirst($taskName);
+
+        $this->info("Normalized Task Name: {$taskName}");
+
+        $taskDataFiles = [
+            "Models/NodeTasks/{$taskName}/{$taskName}Meta.php" => $this->readStub('NodeTaskMeta', $taskName),
+            "Models/NodeTasks/{$taskName}/{$taskName}Result.php" => $this->readStub('NodeTaskResult', $taskName),
+            "Events/NodeTasks/{$taskName}/{$taskName}Completed.php" => $this->readStub('NodeTaskCompleted', $taskName),
+            "Events/NodeTasks/{$taskName}/{$taskName}Failed.php" => $this->readStub('NodeTaskFailed', $taskName),
+        ];
+
+        $dirs = [
+            "Events/NodeTasks/{$taskName}",
+            "Models/NodeTasks/{$taskName}",
+        ];
+
+        foreach ($dirs as $dir) {
+            $path = app_path($dir);
+
+            $this->info('Creating directory ' . $dir);
+
+            mkdir($path);
+        }
+
+        foreach ($taskDataFiles as $abstractPath => $template) {
+            $path = app_path($abstractPath);
+
+            $this->info('Writing ' . $abstractPath);
+
+            file_put_contents($path, $template);
+        }
+
+        $this->info('Done!');
+    }
+
+    protected function readStub($type, $taskName): string
+    {
+        $template = file_get_contents(__DIR__ . "/stubs/MakeNodeTask/$type.stub");
+
+        return str_replace('$taskName', $taskName, $template);
+    }
+}

app/Casts/TaskPayloadCast.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace App\Events\NodeTasks\$taskName;
+
+use App\Events\NodeTasks\BaseTaskEvent;
+
+class $taskNameCompleted extends BaseTaskEvent
+{
+}

app/Casts/TaskResultCast.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace App\Events\NodeTasks\$taskName;
+
+use App\Events\NodeTasks\BaseTaskEvent;
+
+class $taskNameFailed extends BaseTaskEvent
+{
+}

app/Console/Commands/MakeNodeTask.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Models\NodeTasks\$taskName;
+
+use App\Models\NodeTasks\AbstractTaskMeta;
+
+class $taskNameMeta extends AbstractTaskMeta
+{
+    public function __construct(
+    )
+    {
+        //
+    }
+
+    public function formattedHtml(): string
+    {
+        return "$taskName - Task Payload";
+    }
+}

app/Console/Commands/stubs/MakeNodeTask/NodeTaskCompleted.stub

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Models\NodeTasks\$taskName;
+
+use App\Models\NodeTasks\AbstractTaskResult;
+
+class $taskNameResult extends AbstractTaskResult
+{
+    public function __construct(
+    )
+    {
+        //
+    }
+
+    public function formattedHtml(): string
+    {
+        return "$taskName - Task Result";
+    }
+}

app/Console/Commands/stubs/MakeNodeTask/NodeTaskFailed.stub

@@ -1,6 +1,6 @@
 <?php
 
-namespace App\Events\Tasks;
+namespace App\Events\NodeTasks;
 
 use App\Models\NodeTask;
 use Illuminate\Broadcasting\InteractsWithSockets;

app/Console/Commands/stubs/MakeNodeTask/NodeTaskMeta.stub

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Events\NodeTasks\CreateConfig;
+
+use App\Events\NodeTasks\BaseTaskEvent;
+
+class CreateConfigCompleted extends BaseTaskEvent
+{
+
+}

app/Console/Commands/stubs/MakeNodeTask/NodeTaskResult.stub

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Events\NodeTasks\CreateConfig;
+
+use App\Events\NodeTasks\BaseTaskEvent;
+
+class CreateConfigFailed extends BaseTaskEvent
+{
+
+}