Adds support for "Deployments" and add penant

.github/workflows/php-unit.yml

@@ -19,10 +19,10 @@ jobs:
           touch storage/logs/crontab.log
           touch storage/logs/horizon.log
           touch database/database.sqlite
-          npm install
+          ./bin/sail npm install
           cp .env.ci .env
           ./bin/sail up -d
-          npm run build
+          ./bin/sail npm run build
       - name: Run tests
         run: |
           ./bin/sail art key:generate

README.md

@@ -1,5 +1,5 @@
 # What is spork?
-Spork is a personal multi-tool, a place to let my creativity run while and automate random tasks.
+Spork is a personal multi-tool, a place to let my creativity run wild and automate random tasks.
 
 # How do I run it?
 If you'd like to get this project up and running, it's pretty straight forward using docker and Laravel sail. Other deployment methods are not supported officially, but will likely work with little issue. I deploy this personally using Laravel Forge.

app/Actions/Spork/Servers/Manage/RestartAction.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Spork\Servers\Manage;
+
+use App\Actions\Spork\CustomAction;
+use App\Contracts\ActionInterface;
+use App\Models\Server;
+use App\Services\SshService;
+use Illuminate\Http\Request;
+
+class RestartAction extends CustomAction implements ActionInterface
+{
+    public function __construct(
+        $name = 'Restart server',
+        $slug = 'restart-servers'
+    ) {
+        parent::__construct($name, $slug, models: [Server::class]);
+    }
+
+    /**
+     * @throws \Exception
+     */
+    public function __invoke(Request $request)
+    {
+        $request->validate([
+            'items' => 'required|array',
+        ]);
+
+        $servers = Server::query()
+            ->whereIn('id', $request->input('items'))
+            ->get();
+
+        foreach ($servers as $server) {
+            $sshService = new SshService(
+                $server->ip,
+                $server->username,
+                $server->credential->public_key,
+                $server->credential->private_key,
+                $server->port,
+                decrypt($server->credential->pass_key)
+            );
+            $sshService->execute('reboot');
+        }
+    }
+}

app/Actions/Spork/Servers/Manage/StartAction.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Spork\Servers\Manage;
+
+use App\Actions\Spork\CustomAction;
+use App\Contracts\ActionInterface;
+use App\Models\Server;
+use Illuminate\Http\Request;
+
+class StartAction extends CustomAction implements ActionInterface
+{
+    public function __construct(
+        $name = 'Start a server',
+        $slug = 'start-servers'
+    ) {
+        parent::__construct($name, $slug, models: [Server::class]);
+    }
+
+    /**
+     * @throws \Exception
+     */
+    public function __invoke(Request $request)
+    {
+        $request->validate([
+            'items' => 'required|array',
+        ]);
+
+        $servers = Server::query()
+            ->whereIn('id', $request->input('items'))
+            ->get();
+
+        /// Hmm can't exactly ssh to turn these things on...
+    }
+}

app/Actions/Spork/Servers/Manage/StopAction.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Spork\Servers\Manage;
+
+use App\Actions\Spork\CustomAction;
+use App\Contracts\ActionInterface;
+use App\Models\Server;
+use App\Services\SshService;
+use Illuminate\Http\Request;
+
+class StopAction extends CustomAction implements ActionInterface
+{
+    public function __construct(
+        $name = 'Stop a server',
+        $slug = 'stop-servers'
+    ) {
+        parent::__construct($name, $slug, models: [Server::class]);
+    }
+
+    /**
+     * @throws \Exception
+     */
+    public function __invoke(Request $request)
+    {
+        $request->validate([
+            'items' => 'required|array',
+        ]);
+
+        $servers = Server::query()
+            ->whereIn('id', $request->input('items'))
+            ->get();
+
+        foreach ($servers as $server) {
+            $sshService = new SshService(
+                $server->ip,
+                $server->username,
+                $server->credential->public_key,
+                $server->credential->private_key,
+                $server->port,
+                decrypt($server->credential->pass_key)
+            );
+            $sshService->execute('shutdown -h');
+        }
+    }
+}

app/Actions/Spork/SyncDataFromCredential.php

@@ -9,6 +9,7 @@
 use App\Models\Credential;
 use Illuminate\Contracts\Bus\Dispatcher;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Bus;
 
 class SyncDataFromCredential extends CustomAction implements ActionInterface
 {
@@ -19,10 +20,19 @@ public function __construct($name = 'Sync Data From Credential', $slug = 'sync-d
 
     public function __invoke(Dispatcher $dispatcher, Request $request)
     {
-        $credentials = Credential::where('user_id', $request->user()->id)->whereIn('id', $request->get('items'))->get();
+        $credentials = Credential::query()
+            ->where('user_id', $request->user()->id)
+            ->whereIn('id', $request->get('items'))
+            ->whereNotIn('type', [
+                // These aren't managed by a syncing php process.
+                'matrix',
+                'ssh',
+            ])
+            ->get();
 
         foreach ($credentials as $credential) {
-            $dispatcher->dispatch(new FetchResourcesFromCredential($credential));
+            Bus::batch([new FetchResourcesFromCredential($credential)])
+                ->dispatch();
         }
     }
 }

app/Console/Commands/BulkScoutImport.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Services\Code;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Artisan;
+use Laravel\Scout\Searchable;
+
+class BulkScoutImport extends Command
+{
+    protected $signature = 'scout:bulk-import';
+
+    protected $description = 'Command description';
+
+    public function handle()
+    {
+        $searchableModels = Code::instancesOf(Searchable::class)
+            ->getClasses();
+
+        foreach ($searchableModels as $model) {
+            Artisan::call('scout:import', [
+                'model' => $model,
+            ], $this->output);
+        }
+    }
+}

app/Console/Commands/Initialize.php

@@ -0,0 +1,59 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Models\Credential;
+use App\Models\User;
+use App\Services\SshKeyGeneratorService;
+use Illuminate\Console\Command;
+use Illuminate\Support\Str;
+
+class Initialize extends Command
+{
+    protected $signature = 'app:initialize';
+
+    protected $description = 'Initialize the application';
+
+    public function handle()
+    {
+        if (Credential::where('type', Credential::TYPE_SSH)->exists()) {
+            $this->info('SSH key already exists');
+
+            return;
+        }
+
+        if (! User::exists()) {
+            $this->call('make:user');
+        }
+
+        $randomName = Str::random(16);
+        $passKey = Str::random(16);
+
+        [$privateKey, $publicKey] = SshKeyGeneratorService::generate($passKey);
+
+        $publicKeyFile = storage_path('app/keys/'.$randomName.'.pub');
+        $privateKeyFile = storage_path('app/keys/'.$randomName);
+
+        file_put_contents($publicKeyFile, $publicKey);
+        chmod($publicKeyFile, 0600);
+        file_put_contents($privateKeyFile, $privateKey);
+        chmod($privateKeyFile, 0600);
+
+        Credential::create([
+            'service' => Credential::TYPE_SSH,
+            'type' => Credential::TYPE_SSH,
+            'name' => 'SSH',
+            'user_id' => User::first()->id,
+            'api_key' => Str::random(32),
+            'settings' => [
+                'pub_key' => $publicKey,
+                'pub_key_file' => $publicKeyFile,
+                'private_key' => encrypt($privateKey),
+                'private_key_file' => $privateKeyFile,
+                'pass_key' => ! empty($passKey) ? encrypt($passKey) : '',
+            ],
+        ]);
+    }
+}

app/Contracts/Services/Documents/PdfParserServiceContract.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Contracts\Services\Documents;
+
+interface PdfParserServiceContract
+{
+    public function getPdfTextFromFile(string $filename): string;
+
+    public function getPdfTextFromRawContent(string $contents): string;
+}

app/Events/AbstractLogicalEvent.php

@@ -13,9 +13,4 @@
 abstract class AbstractLogicalEvent implements LogicalEvent
 {
     use Dispatchable, InteractsWithQueue,  InteractsWithSockets, SerializesModels;
-
-    public function broadcastConnections(): array
-    {
-        return ['pusher'];
-    }
 }

app/Events/Models/Article/ArticleCreated.php

@@ -14,3 +14,5 @@ public function __construct(
     ) {
     }
 }
+
+

app/Events/Models/Server/ServerCreated.php

@@ -6,11 +6,22 @@
 
 use App\Events\AbstractLogicalEvent;
 use App\Models\Server;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
 
-class ServerCreated extends AbstractLogicalEvent
+class ServerCreated extends AbstractLogicalEvent implements ShouldBroadcastNow
 {
     public function __construct(
         public Server $model,
     ) {
     }
+
+    public function broadcastOn()
+    {
+        $this->model->load('credential');
+
+        return [
+            new PrivateChannel('App.Models.User.'.$this->model->credential->user_id),
+        ];
+    }
 }

app/Events/Models/Server/ServerCreating.php

@@ -6,11 +6,22 @@
 
 use App\Events\AbstractLogicalEvent;
 use App\Models\Server;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
 
-class ServerCreating extends AbstractLogicalEvent
+class ServerCreating extends AbstractLogicalEvent implements ShouldBroadcastNow
 {
     public function __construct(
         public Server $model,
     ) {
     }
+
+    public function broadcastOn()
+    {
+        $this->model->load('credential');
+
+        return [
+            new PrivateChannel('App.Models.User.'.$this->model->credential->user_id),
+        ];
+    }
 }