First commit

Author: rmcdaniel

.editorconfig

@@ -0,0 +1,18 @@
+root = true
+
+[*]
+charset = utf-8
+end_of_line = lf
+indent_size = 4
+indent_style = space
+insert_final_newline = true
+trim_trailing_whitespace = true
+
+[*.md]
+trim_trailing_whitespace = false
+
+[*.{yml,yaml}]
+indent_size = 2
+
+[docker-compose.yml]
+indent_size = 4

.gitattributes

@@ -0,0 +1,11 @@
+* text=auto
+
+*.blade.php diff=html
+*.css diff=css
+*.html diff=html
+*.md diff=markdown
+*.php diff=php
+
+/.github export-ignore
+CHANGELOG.md export-ignore
+.styleci.yml export-ignore

.gitignore

@@ -0,0 +1,19 @@
+/node_modules
+/public/build
+/public/hot
+/public/storage
+/storage/*.key
+/vendor
+.env
+.env.backup
+.env.production
+.phpunit.result.cache
+Homestead.json
+Homestead.yaml
+auth.json
+npm-debug.log
+yarn-error.log
+/.fleet
+/.idea
+/.vscode
+.DS_Store

README.md

@@ -0,0 +1,54 @@
+<?php
+
+namespace Waterline\Console;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Str;
+
+class InstallCommand extends Command
+{
+    protected $signature = 'waterline:install';
+
+    protected $description = 'Install all of Waterline\'s resources';
+
+    public function handle()
+    {
+        $this->comment('Publishing Waterline Service Provider...');
+        $this->callSilent('vendor:publish', ['--tag' => 'waterline-provider']);
+
+        $this->comment('Publishing Waterline Assets...');
+        $this->callSilent('vendor:publish', ['--tag' => 'waterline-assets']);
+
+        $this->registerWaterlineServiceProvider();
+
+        $this->info('Waterline installed successfully.');
+    }
+
+    /**
+     * Register the Waterline service provider in the application configuration file.
+     *
+     * @return void
+     */
+    protected function registerWaterlineServiceProvider()
+    {
+        $namespace = Str::replaceLast('\\', '', $this->laravel->getNamespace());
+
+        $appConfig = file_get_contents(config_path('app.php'));
+
+        if (Str::contains($appConfig, $namespace.'\\Providers\\WaterlineServiceProvider::class')) {
+            return;
+        }
+
+        file_put_contents(config_path('app.php'), str_replace(
+            "{$namespace}\\Providers\EventServiceProvider::class,".PHP_EOL,
+            "{$namespace}\\Providers\EventServiceProvider::class,".PHP_EOL."        {$namespace}\Providers\WaterlineServiceProvider::class,".PHP_EOL,
+            $appConfig
+        ));
+
+        file_put_contents(app_path('Providers/WaterlineServiceProvider.php'), str_replace(
+            "namespace App\Providers;",
+            "namespace {$namespace}\Providers;",
+            file_get_contents(app_path('Providers/.php'))
+        ));
+    }
+}

app/Console/InstallCommand.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Waterline\Console;
+
+use Illuminate\Console\Command;
+
+class PublishCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'waterline:publish';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Publish all of Waterline\'s resources';
+
+    /**
+     * Execute the console command.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $this->call('vendor:publish', [
+            '--tag' => 'waterline-assets',
+            '--force' => true,
+        ]);
+    }
+}

app/Console/PublishCommand.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace App\Exceptions;
+
+use Illuminate\Foundation\Exceptions\Handler as ExceptionHandler;
+use Throwable;
+
+class Handler extends ExceptionHandler
+{
+    /**
+     * A list of exception types with their corresponding custom log levels.
+     *
+     * @var array<class-string<\Throwable>, \Psr\Log\LogLevel::*>
+     */
+    protected $levels = [
+        //
+    ];
+
+    /**
+     * A list of the exception types that are not reported.
+     *
+     * @var array<int, class-string<\Throwable>>
+     */
+    protected $dontReport = [
+        //
+    ];
+
+    /**
+     * A list of the inputs that are never flashed to the session on validation exceptions.
+     *
+     * @var array<int, string>
+     */
+    protected $dontFlash = [
+        'current_password',
+        'password',
+        'password_confirmation',
+    ];
+
+    /**
+     * Register the exception handling callbacks for the application.
+     *
+     * @return void
+     */
+    public function register()
+    {
+        $this->reportable(function (Throwable $e) {
+            //
+        });
+    }
+}

app/Exceptions/Handler.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Waterline\Http\Controllers;
+
+use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
+use Illuminate\Foundation\Bus\DispatchesJobs;
+use Illuminate\Foundation\Validation\ValidatesRequests;
+use Illuminate\Routing\Controller as BaseController;
+use Waterline\Http\Middleware\Authenticate;
+
+class Controller extends BaseController
+{
+    use AuthorizesRequests, DispatchesJobs, ValidatesRequests;
+
+    public function __construct()
+    {
+        $this->middleware(Authenticate::class);
+    }
+}

app/Http/Controllers/Controller.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Waterline\Http\Controllers;
+
+use Illuminate\Support\Facades\App;
+
+class DashboardController extends Controller
+{
+    public function index() {
+        return view('waterline::layout', [
+            'assetsAreCurrent' => true,
+            'cssFile' => true ? 'app-dark.css' : 'app.css',
+            'waterlineScriptVariables' => [
+                'path' => config('waterline.path', 'waterline'),
+            ],
+            'isDownForMaintenance' => App::isDownForMaintenance(),
+        ]);       
+    }
+}

app/Http/Controllers/DashboardController.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Waterline\Http\Controllers;
+
+use Illuminate\Support\Facades\DB;
+use Workflow\Models\StoredWorkflow;
+use Workflow\Models\StoredWorkflowException;
+
+class DashboardStatsController extends Controller
+{
+    public function index() {
+
+        $flowsPastHour = StoredWorkflow::where('updated_at', '>=', now()->subHour())
+            ->count();
+
+        $exceptionsPastHour = StoredWorkflowException::where('created_at', '>=', now()->subHour())
+            ->count();
+
+        $failedFlowsPastWeek = StoredWorkflow::where('status', 'failed')
+            ->where('updated_at', '>=', now()->subDays(7))
+            ->count();
+
+        $maxWaitTimeWorkflow = StoredWorkflow::where('status', 'pending')
+            ->orderBy('updated_at')
+            ->first();
+
+        $maxDurationWorkflow = StoredWorkflow::select('*')
+            ->addSelect(DB::raw('TIMEDIFF(created_at, updated_at) as duration'))
+            ->where('status', '!=', 'pending')
+            ->orderBy('duration')
+            ->first();
+
+        $maxExceptionsWorkflow = StoredWorkflow::withCount('exceptions')
+            ->orderByDesc('exceptions_count')
+            ->orderByDesc('updated_at')
+            ->first();
+
+        return response()->json([
+            'flows' => StoredWorkflow::count(),
+            'flows_per_minute' => $flowsPastHour / 60,
+            'flows_past_hour' => $flowsPastHour,
+            'exceptions_past_hour' => $exceptionsPastHour,
+            'failed_flows_past_week' => $failedFlowsPastWeek,
+            'max_wait_time_workflow' => $maxWaitTimeWorkflow,
+            'max_duration_workflow' => $maxDurationWorkflow,
+            'max_exceptions_workflow' => $maxExceptionsWorkflow,
+        ]);
+    }
+}

app/Http/Controllers/DashboardStatsController.php

@@ -0,0 +1,48 @@
+<?php
+
+namespace Waterline\Http\Controllers;
+
+use SplFileObject;
+use Workflow\Models\StoredWorkflow;
+
+class WorkflowsController extends Controller
+{
+    public function completed() {
+        return StoredWorkflow::whereStatus('completed')
+            ->paginate(50);
+    }
+
+    public function failed() {
+        return StoredWorkflow::whereStatus('failed')
+            ->paginate(50);
+    }
+
+    public function running() {
+        return StoredWorkflow::whereIn('status', [
+                'created',
+                'pending',
+                'running',
+                'waiting',
+            ])
+            ->paginate(50);
+    }
+
+    public function show($id) {
+        $flow = StoredWorkflow::whereId($id)->with(['exceptions', 'logs'])->first();
+
+        $flow->exceptions = $flow->exceptions->map(function ($exception) {
+            $unserialized = unserialize($exception->exception);
+            $file = new SplFileObject($unserialized->getFile());
+            $file->seek($unserialized->getLine() - 4);
+            for ($line = 0; $line < 7; ++$line) {
+                $exception->code .= $file->current();
+                $file->next();
+                if ($file->eof()) break;
+            }
+            $exception->code = rtrim($exception->code);
+            return $exception;
+        });
+
+        return $flow;
+    }
+}

app/Http/Controllers/WorkflowsController.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace Waterline\Http;
+
+use Illuminate\Foundation\Http\Kernel as HttpKernel;
+
+class Kernel extends HttpKernel
+{
+    /**
+     * The application's global HTTP middleware stack.
+     *
+     * These middleware are run during every request to your application.
+     *
+     * @var array<int, class-string|string>
+     */
+    protected $middleware = [
+        // \App\Http\Middleware\TrustHosts::class,
+        \App\Http\Middleware\TrustProxies::class,
+        \Illuminate\Http\Middleware\HandleCors::class,
+        \App\Http\Middleware\PreventRequestsDuringMaintenance::class,
+        \Illuminate\Foundation\Http\Middleware\ValidatePostSize::class,
+        \App\Http\Middleware\TrimStrings::class,
+        \Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull::class,
+    ];
+
+    /**
+     * The application's route middleware groups.
+     *
+     * @var array<string, array<int, class-string|string>>
+     */
+    protected $middlewareGroups = [
+        'web' => [
+            \App\Http\Middleware\EncryptCookies::class,
+            \Illuminate\Cookie\Middleware\AddQueuedCookiesToResponse::class,
+            \Illuminate\Session\Middleware\StartSession::class,
+            \Illuminate\View\Middleware\ShareErrorsFromSession::class,
+            \App\Http\Middleware\VerifyCsrfToken::class,
+            \Illuminate\Routing\Middleware\SubstituteBindings::class,
+        ],
+
+        'api' => [
+            // \Laravel\Sanctum\Http\Middleware\EnsureFrontendRequestsAreStateful::class,
+            'throttle:api',
+            \Illuminate\Routing\Middleware\SubstituteBindings::class,
+        ],
+    ];
+
+    /**
+     * The application's route middleware.
+     *
+     * These middleware may be assigned to groups or used individually.
+     *
+     * @var array<string, class-string|string>
+     */
+    protected $routeMiddleware = [
+        'auth' => \App\Http\Middleware\Authenticate::class,
+        'auth.basic' => \Illuminate\Auth\Middleware\AuthenticateWithBasicAuth::class,
+        'auth.session' => \Illuminate\Session\Middleware\AuthenticateSession::class,
+        'cache.headers' => \Illuminate\Http\Middleware\SetCacheHeaders::class,
+        'can' => \Illuminate\Auth\Middleware\Authorize::class,
+        'guest' => \App\Http\Middleware\RedirectIfAuthenticated::class,
+        'password.confirm' => \Illuminate\Auth\Middleware\RequirePassword::class,
+        'signed' => \App\Http\Middleware\ValidateSignature::class,
+        'throttle' => \Illuminate\Routing\Middleware\ThrottleRequests::class,
+        'verified' => \Illuminate\Auth\Middleware\EnsureEmailIsVerified::class,
+    ];
+}