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,
+        ]);
+    }
+}