Merge pull request #17 from laravel-workflow/mongodb

MongoDB

Author: rmcdaniel

app/Http/Controllers/DashboardStatsController.php

@@ -24,21 +24,74 @@ public function index() {
             ->orderBy('updated_at')
             ->first();
 
-        $maxDurationWorkflow = config('workflows.stored_workflow_model', StoredWorkflow::class)::select('*')
-            ->when(config('database.default') === 'mysql', function ($q) {
-                return $q->addSelect(DB::raw('TIMEDIFF(created_at, updated_at) as duration'));
-            })
-            ->when(config('database.default') === 'pgsql', function ($q) {
-                return $q->addSelect(DB::raw('(EXTRACT(EPOCH FROM created_at - updated_at)) as duration'));
-            })
-            ->where('status', '!=', 'pending')
-            ->orderBy('duration')
-            ->first();
+        if (config('database.default') === 'mongodb' && $maxWaitTimeWorkflow && $maxWaitTimeWorkflow->_id) {
+            $maxWaitTimeWorkflow->id = $maxWaitTimeWorkflow->_id;
+        }
 
-        $maxExceptionsWorkflow = config('workflows.stored_workflow_model', StoredWorkflow::class)::withCount('exceptions')
-            ->orderByDesc('exceptions_count')
-            ->orderByDesc('updated_at')
-            ->first();
+        if (config('database.default') === 'mongodb') {
+            $maxDurationWorkflow = config('workflows.stored_workflow_model', StoredWorkflow::class)::select('*')
+                ->raw(function ($collection) {
+                    return $collection->aggregate([
+                        [
+                            '$match' => [
+                                'status' => [ '$ne' => 'pending' ]
+                            ]
+                        ],
+                        [
+                            '$addFields' => [
+                                'duration' => [
+                                    '$subtract' => [
+                                        ['$toDate' => '$updated_at'],
+                                        ['$toDate' => '$created_at']
+                                    ]
+                                ]
+                            ]
+                        ],
+                        [
+                            '$sort' => ['duration' => -1]
+                        ],
+                        [
+                            '$limit' => 1
+                        ]
+                    ]);
+                })
+                ->first();
+                $maxDurationWorkflow->id = $maxDurationWorkflow->_id;
+        } else {
+            $maxDurationWorkflow = config('workflows.stored_workflow_model', StoredWorkflow::class)::select('*')
+                ->when(config('database.default') === 'mysql', function ($q) {
+                    return $q->addSelect(DB::raw('TIMEDIFF(created_at, updated_at) as duration'));
+                })
+                ->when(config('database.default') === 'pgsql', function ($q) {
+                    return $q->addSelect(DB::raw('(EXTRACT(EPOCH FROM created_at - updated_at)) as duration'));
+                })
+                ->where('status', '!=', 'pending')
+                ->orderBy('duration')
+                ->first();
+        }
+
+        if (config('database.default') === 'mongodb') {
+            $maxExceptionsWorkflow = null;
+
+            $mostExceptionWorkflowId = StoredWorkflowException::raw(function ($collection) {
+                return $collection->aggregate([
+                    ['$group' => ['_id' => '$stored_workflow_id', 'count' => ['$sum' => 1]]],
+                    ['$sort' => ['count' => -1]],
+                    ['$limit' => 1]
+                ]);
+            })->first()['_id'];
+
+            $maxExceptionsWorkflow = StoredWorkflow::where('_id', $mostExceptionWorkflowId)->first();
+
+            $maxExceptionsWorkflow->exceptions_count = StoredWorkflowException::where('stored_workflow_id', $mostExceptionWorkflowId)->count();
+
+            $maxExceptionsWorkflow->id = $maxExceptionsWorkflow->_id;
+        } else {
+            $maxExceptionsWorkflow = config('workflows.stored_workflow_model', StoredWorkflow::class)::withCount('exceptions')
+                ->orderByDesc('exceptions_count')
+                ->orderByDesc('updated_at')
+                ->first();
+        }
 
         return response()->json([
             'flows' => config('workflows.stored_workflow_model', StoredWorkflow::class)::count(),

app/Http/Controllers/WorkflowsController.php

@@ -32,7 +32,7 @@ public function running() {
     }
 
     public function show($id) {
-        $flow = config('workflows.stored_workflow_model', StoredWorkflow::class)::whereId($id)->with(['exceptions', 'logs'])->first();
+        $flow = config('workflows.stored_workflow_model', StoredWorkflow::class)::find($id)->with(['exceptions', 'logs'])->first();
 
         $flow->arguments = serialize(Y::unserialize($flow->arguments));