Autoload yay

lib/core/services/specialized_services/logs_service.dart

@@ -16,6 +16,7 @@ class LogsService extends AbstractService<LogsResult> {
       if (p == "start" || p == "end") { continue; }
       v.add("$p=\"${params[p]}\"");
     } 
+    print("${subPath}query_range?query={${v.join(", ")}}&start=${params["start"].toString().substring(0, 10)}&end=${params["end"].toString().substring(0, 10)}");
     return service.get("${subPath}query_range?query={${v.join(", ")}}&start=${params["start"].toString().substring(0, 10)}&end=${params["end"].toString().substring(0, 10)}", false, context);
   }
 

lib/core/services/specialized_services/workflow_execution_service.dart

@@ -11,6 +11,7 @@ class WorkflowExecutionService extends AbstractService<WorkflowExecutions> {
   @override String subPath = "/";
 
   @override Future<APIResponse<WorkflowExecutions>> search(BuildContext? context, List<String> words, Map<String, dynamic> params) {  
+    print("${subPath}search/${words.join("/")}");
     return service.get("${subPath}search/${words.join("/")}", false, context);
   }
 

lib/pages/datacenter.dart

@@ -32,49 +32,7 @@ class ComputePageWidgetState extends State<ComputePageWidget> {
   List<String> titles = ["SCHEDULED", "RUNNING", "FAILURE", "SUCCESS", "MISSED"];
   
   @override Widget build(BuildContext context) {
-    return FutureBuilder(
-      future: widget._service.search(context, [ 
-        "${widget.start.year}-${widget.start.month > 9 ? widget.start.month : "0${widget.start.month}"}-${widget.start.day > 9 ? widget.start.day : "0${widget.start.day}"}", 
-        "${widget.end.year}-${widget.end.month > 9 ? widget.end.month : "0${widget.end.month}"}-${widget.end.day > 9 ? widget.end.day : "0${widget.end.day}"}"], {}),
-      builder: (ctx, as) { 
-        Map<String, List<WorkflowExecution>> data = {};
-        if (as.hasData && as.data!.data != null) {
-          for (var element in as.data!.data!.executions) {
-            if (element.executionData == null) { continue; }
-            DateTime dateTime = DateTime.parse(element.executionData!);
-            DateTime date = DateTime(dateTime.year, dateTime.month, dateTime.day);
-            var str = "${date.toIso8601String()}Z";
-            if (data[str] == null) { data[str] = []; }
-            data[str]!.add(element);
-            data[str]!.sort((a, b) => DateTime.parse(a.executionData!).compareTo(DateTime.parse(b.executionData!)));
-          }
-        }
         GlobalKey<ScheduleWidgetState> k = GlobalKey<ScheduleWidgetState>();
-        for (var da in data.keys) {
-          for (var exec in data[da]!) {
-            String start = "";
-            String end = "";
-            try {
-              if (exec.endDate != null && exec.endDate != "") {
-                var startD = DateTime.parse(exec.executionData!);
-                var endD = DateTime.parse(exec.endDate!);
-                var diff = endD.difference(startD);
-                if (diff.inDays < 30) {
-                  var rest = ((30 - diff.inDays) ~/ 2) - 1;
-                  start = (startD.subtract(Duration(days: rest)).microsecondsSinceEpoch).toString();
-                  end = (endD.add(Duration(days: rest)).microsecondsSinceEpoch).toString();
-                } else {
-                  start = (startD.microsecondsSinceEpoch).toString();
-                  end = (startD.add( const Duration(days: 29)).microsecondsSinceEpoch).toString();
-                }
-              } else {
-                start = (DateTime.parse(exec.executionData!).subtract( const Duration(days: 14)).microsecondsSinceEpoch).toString();
-                end = (DateTime.parse(exec.executionData!).add( const Duration(days: 14)).microsecondsSinceEpoch).toString();
-              }
-            } catch(e) { /* */ }
-            k.currentState?.setState(() { k.currentState?.widget.loading = true; });
-          }          
-        }
         return Column( children: [
           Container( color: lightColor,
             height: 50, width: getMainWidth(context),
@@ -211,8 +169,7 @@ class ComputePageWidgetState extends State<ComputePageWidget> {
                 )
               ]))
           ),
-          ScheduleWidget( key: k, data: data, start: widget.start, end : widget.end, isList: widget.isList, isBox: false)
+          ScheduleWidget( service: widget._service, key: k, start: widget.start, end : widget.end, isList: widget.isList, isBox: false)
         ]);
-    });
   }
 }

lib/pages/scheduler.dart

@@ -2,10 +2,8 @@ import 'package:datetime_picker_formfield/datetime_picker_formfield.dart';
 import 'package:flutter/material.dart';
 import 'package:intl/intl.dart' as intl;
 import 'package:go_router/go_router.dart';
-import 'package:oc_front/core/services/specialized_services/logs_service.dart';
 import 'package:oc_front/core/services/specialized_services/workflow_execution_service.dart';
 import 'package:oc_front/main.dart';
-import 'package:oc_front/models/workflow.dart';
 import 'package:oc_front/pages/abstract_page.dart';
 import 'package:oc_front/widgets/sheduler_items/schedule.dart';
 
@@ -29,70 +27,10 @@ class SchedulerPageWidget extends StatefulWidget {
 }
 class SchedulerPageWidgetState extends State<SchedulerPageWidget> {
   List<Color> colors = [Colors.blue, Colors.orange, redColor, Colors.green, redColor];
-  List<String> titles = ["SCHEDULED", "RUNNING", "FAILURE", "SUCCESS", "MISSED"];
+  List<String> titles = ["SCHEDULED", "RUNNING", "FAILURE", "SUCCESS", "FORGOTTEN"];
   
   @override Widget build(BuildContext context) {
-    return FutureBuilder(
-      future: widget._service.search(context, [ 
-        "${widget.start.year}-${widget.start.month > 9 ? widget.start.month : "0${widget.start.month}"}-${widget.start.day > 9 ? widget.start.day : "0${widget.start.day}"}", 
-        "${widget.end.year}-${widget.end.month > 9 ? widget.end.month : "0${widget.end.month}"}-${widget.end.day > 9 ? widget.end.day : "0${widget.end.day}"}"], {}),
-      builder: (ctx, as) { 
-        Map<String, List<WorkflowExecution>> data = {};
-        if (as.hasData && as.data!.data != null) {
-          for (var element in as.data!.data!.executions) {
-            if (element.executionData == null) { continue; }
-            DateTime dateTime = DateTime.parse(element.executionData!);
-            DateTime date = DateTime(dateTime.year, dateTime.month, dateTime.day);
-            var str = "${date.toIso8601String()}Z";
-            if (data[str] == null) { data[str] = []; }
-            data[str]!.add(element);
-            data[str]!.sort((a, b) => DateTime.parse(a.executionData!).compareTo(DateTime.parse(b.executionData!)));
-          }
-        }
         GlobalKey<ScheduleWidgetState> k = GlobalKey<ScheduleWidgetState>();
-        for (var da in data.keys) {
-          for (var exec in data[da]!) {
-            String start = "";
-            String end = "";
-            try {
-              if (exec.endDate != null && exec.endDate != "") {
-                var startD = DateTime.parse(exec.executionData!);
-                var endD = DateTime.parse(exec.endDate!);
-                var diff = endD.difference(startD);
-                if (diff.inDays < 30) {
-                  var rest = ((30 - diff.inDays) ~/ 2) - 1;
-                  start = (startD.subtract(Duration(days: rest)).microsecondsSinceEpoch).toString();
-                  end = (endD.add(Duration(days: rest)).microsecondsSinceEpoch).toString();
-                } else {
-                  start = (startD.microsecondsSinceEpoch).toString();
-                  end = (startD.add( const Duration(days: 29)).microsecondsSinceEpoch).toString();
-                }
-              } else {
-                start = (DateTime.parse(exec.executionData!).subtract( const Duration(days: 14)).microsecondsSinceEpoch).toString();
-                end = (DateTime.parse(exec.executionData!).add( const Duration(days: 14)).microsecondsSinceEpoch).toString();
-              }
-            } catch(e) { /* */ }
-            k.currentState?.setState(() { k.currentState?.widget.loading = true; });
-            LogsService().search(context, [], {
-              "workflow_execution_id": exec.id,
-              "start": start,
-              "end": end
-            }).then((value) {
-              if (value.data != null) {
-                var d = value.data!;
-                for( var r in d.result) {
-                  for (var element in r.logs) {
-                    element.level = r.level;
-                    exec.logs ??= [];
-                    exec.logs!.add(element);
-                  }
-                  exec.logs?.sort((a, b) => a.timestamp!.compareTo(b.timestamp!));
-                }
-              }  
-              k.currentState?.setState(() { k.currentState?.widget.loading = false; });      
-            });
-          }          
-        }
         return Column( children: [
           Container( color: lightColor,
             height: 50, width: getMainWidth(context),
@@ -229,8 +167,7 @@ class SchedulerPageWidgetState extends State<SchedulerPageWidget> {
                 )
               ]))
           ),
-          ScheduleWidget( key: k, data: data, start: widget.start, end : widget.end, isList: widget.isList, )
+          ScheduleWidget( service: widget._service, key: k, start: widget.start, end : widget.end, isList: widget.isList, )
         ]);
-    });
   }
 }

lib/pages/shared.dart

@@ -339,7 +339,7 @@ class WorkspaceSharedPageWidgetState extends State<WorkspaceSharedPageWidget> {
     List<Widget> items = [];
     for (var w in data) {
       List<Widget> badges = [];
-      if (widget.type == CollaborativeAreaType.peer && w.getID(
+      if (w is Peer && w.getID(
       ) == CollaborativeAreaLocal.workspaces[CollaborativeAreaLocal.current ?? ""]?.rule?.creator) {
         badges.add(Padding( padding: const EdgeInsets.only(left: 5), child: Icon(Icons.star, color: Colors.orange.shade300 )));
       } else if (widget.type == CollaborativeAreaType.workspace) {

lib/widgets/logs.dart

@@ -2,21 +2,66 @@ import 'package:alert_banner/exports.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
 import 'package:json_string/json_string.dart';
-import 'package:oc_front/core/sections/header/header.dart';
+import 'package:oc_front/core/services/specialized_services/logs_service.dart';
 import 'package:oc_front/main.dart';
 import 'package:oc_front/models/logs.dart';
+import 'package:oc_front/models/workflow.dart';
 import 'package:oc_front/widgets/dialog/alert.dart';
 
 class LogsWidget extends StatefulWidget {
-  final List<Log> items;
   String? level;
   String search = "";
-  LogsWidget ({ Key? key, this.search = "", required this.items, this.level }): super(key: key);
+
+  WorkflowExecution? exec;
+  LogsWidget ({ Key? key, this.search = "", this.level, this.exec }): super(key: key);
   @override LogsWidgetState createState() => LogsWidgetState();
 }
+
 class LogsWidgetState extends State<LogsWidget> {
   @override Widget build(BuildContext context) {
-    List<LogWidget> itemRows = widget.items.where((element) => (element.message?.toLowerCase().contains(widget.search.toLowerCase()) ?? true)
+    if (widget.exec == null) {
+      return Container();
+    } else {
+      String start = "";
+      String end = "";
+      try {
+        if (widget.exec!.endDate != null && widget.exec!.endDate != "") {
+          var startD = DateTime.parse(widget.exec!.executionData!);
+          var endD = DateTime.parse(widget.exec!.endDate!);
+          var diff = endD.difference(startD);
+          if (diff.inDays < 30) {
+            var rest = ((30 - diff.inDays) ~/ 2) - 1;
+            start = (startD.subtract(Duration(days: rest)).microsecondsSinceEpoch).toString();
+            end = (endD.add(Duration(days: rest)).microsecondsSinceEpoch).toString();
+          } else {
+            start = (startD.microsecondsSinceEpoch).toString();
+            end = (startD.add( const Duration(days: 29)).microsecondsSinceEpoch).toString();
+          }
+        } else {
+          start = (DateTime.parse(widget.exec!.executionData!).subtract( const Duration(days: 14)).microsecondsSinceEpoch).toString();
+          end = (DateTime.parse(widget.exec!.executionData!).add( const Duration(days: 14)).microsecondsSinceEpoch).toString();
+        }
+      } catch(e) { /* */ }
+      return FutureBuilder(future: LogsService().search(context, [], {
+              "workflow_execution_id":  widget.exec!.id,
+              "start": start,
+              "end":  end
+            }), builder: (a, b) {
+              Future.delayed(const Duration(minutes: 1), () {
+                setState(() {});
+              });
+              List<Log> logs = [];
+              if (b.data != null && b.data!.data != null) {
+                var d = b.data!.data!;
+                for( var r in d.result) {
+                  for (var element in r.logs) {
+                    element.level = r.level;
+                    logs.add(element);
+                  }
+                  logs.sort((a, b) => a.timestamp!.compareTo(b.timestamp!));
+                }
+              }  
+              List<LogWidget> itemRows = logs.where((element) => (element.message?.toLowerCase().contains(widget.search.toLowerCase()) ?? true)
                 && (widget.level?.contains(element.level ?? "") ?? true) ).map((e) => LogWidget(item: e)).toList();
               return Stack( children: [ 
                   SingleChildScrollView( child: itemRows.isEmpty ? 
@@ -24,6 +69,9 @@ class LogsWidgetState extends State<LogsWidget> {
                     child: const Center( child: Text("no log registered", style: TextStyle(color: Colors.grey, fontSize: 25 ),)))
                   :  Column(  children:  [...itemRows, Container(height: 50,) ] ) ),
                 ]);
+      });
+    }
+    
   }
 }
 

lib/widgets/sheduler_items/schedule.dart

@@ -1,7 +1,8 @@
 import 'package:flutter/material.dart';
 import 'package:flutter_box_transform/flutter_box_transform.dart';
+import 'package:oc_front/core/services/specialized_services/abstract_service.dart';
+import 'package:oc_front/core/services/specialized_services/booking_service.dart';
 import 'package:oc_front/main.dart';
-import 'package:oc_front/models/logs.dart';
 import 'package:oc_front/models/workflow.dart';
 import 'package:oc_front/widgets/logs.dart';
 import 'package:flutter_spinkit/flutter_spinkit.dart';
@@ -16,13 +17,14 @@ class ScheduleWidget extends StatefulWidget {
   DateTime end;
   bool isDayPlanner = true;
   bool loading = true;
-  Map<String, List<WorkflowExecution>> data;
   bool isList = true;
   bool isBox = true;
-  ScheduleWidget ({ super.key, required this.data, required this.start, required this.end, 
+  AbstractService<WorkflowExecutions> service;
+  ScheduleWidget ({ super.key, required this.start, required this.end, required this.service,
     this.isBox =true, this.isList = true, this.loading = false});
   @override ScheduleWidgetState createState() => ScheduleWidgetState();
 }
+
 String? selected;
 String? selectedReal;
 class ScheduleWidgetState extends State<ScheduleWidget> {
@@ -37,11 +39,31 @@ class ScheduleWidgetState extends State<ScheduleWidget> {
   }
 
   @override Widget build(BuildContext context) {
+    return FutureBuilder(
+      future: widget.service.search(context, [ 
+        "${widget.start.year}-${widget.start.month > 9 ? widget.start.month : "0${widget.start.month}"}-${widget.start.day > 9 ? widget.start.day : "0${widget.start.day}"}", 
+        "${widget.end.year}-${widget.end.month > 9 ? widget.end.month : "0${widget.end.month}"}-${widget.end.day > 9 ? widget.end.day : "0${widget.end.day}"}"], {}),
+      builder: (ctx, as) { 
+        Future.delayed(const Duration(minutes: 1), () {
+          setState(() {});
+        });
+        Map<String, List<WorkflowExecution>> data = {};
+        if (as.hasData && as.data!.data != null) {
+          for (var element in as.data!.data!.executions) {
+            if (element.executionData == null) { continue; }
+            DateTime dateTime = DateTime.parse(element.executionData!);
+            DateTime date = DateTime(dateTime.year, dateTime.month, dateTime.day);
+            var str = "${date.toIso8601String()}Z";
+            if (data[str] == null) { data[str] = []; }
+            data[str]!.add(element);
+            data[str]!.sort((a, b) => DateTime.parse(a.executionData!).compareTo(DateTime.parse(b.executionData!)));
+          }
+        }
         bool isInfo = getMainWidth(context) <= 600 && selected != null && widget.isBox;
         double w = selected != null && widget.isBox ? getMainWidth(context) - menuSize : getMainWidth(context);
         List<Widget> children = [];
         if (selected != null) {
-      for (var wf in widget.data[selected!] ?? (<WorkflowExecution>[])) {
+          for (var wf in data[selected!] ?? (<WorkflowExecution>[])) {
             DateTime d2 = DateTime.parse(wf.executionData!).toLocal();
             children.add( InkWell(
               onTap: () => setState(() { selectedReal = wf.executionData; }),
@@ -77,13 +99,12 @@ class ScheduleWidgetState extends State<ScheduleWidget> {
           }
           
         }
-    List<Log> logs = [];
         String? selectedID;
+        WorkflowExecution? sel;
         if (selectedReal != null) {
           try {
-        var sel = widget.data[selected!]!.firstWhere((element) => element.executionData == selectedReal);
+            sel = data[selected!]!.firstWhere((element) => element.executionData == selectedReal);
             selectedID = sel.id;
-        logs = sel.logs ?? [];
           } catch(e) { /* */ }
         }
         menuSize = isInfo ? getMainWidth(context) : (menuSize > getMainWidth(context) / 2 ? getMainWidth(context) / 2 : menuSize);
@@ -91,8 +112,8 @@ class ScheduleWidgetState extends State<ScheduleWidget> {
                   width: selected != null ? menuSize : 0, height: (getMainHeight(context) - 50) > 0 ? (getMainHeight(context) - 50) : 0);
         return Row( children: [
           isInfo ? Container() : SizedBox( width: w, 
-        child: widget.isList ? SchedulerItemWidget(data: widget.data, parent: this, focusedDay: getFocusedDay(), width: w) 
+            child: widget.isList ? SchedulerItemWidget(data: data, parent: this, focusedDay: getFocusedDay(), width: w) 
-        : SchedulerCalendarWidget(data: widget.data, start: widget.start, 
+            : SchedulerCalendarWidget(data: data, start: widget.start, 
               end: widget.end, parent: this, focusedDay: getFocusedDay(),)
           ),
           !widget.isBox  ? Container() : fork.TransformableBox(
@@ -143,7 +164,7 @@ class ScheduleWidgetState extends State<ScheduleWidget> {
                       mainAxisAlignment: children.isEmpty || widget.loading ? MainAxisAlignment.center : MainAxisAlignment.start,
                       children: [ 
                       ...( widget.isDayPlanner ? children : ( selectedID != null ? [
-                    widget.loading ?  const SpinKitCircle(color: Colors.white,) : LogsWidget(items: logs, search: search, level: level)
+                        widget.loading ?  const SpinKitCircle(color: Colors.white,) : LogsWidget(exec: sel, search: search, level: level)
                       ] : [])),
                       children.isEmpty ? Container( height: 100, alignment: Alignment.center, child: const Text("No event found", style: TextStyle(color: Colors.grey, fontSize: 20))) : Container()
                     ]), 
@@ -216,5 +237,6 @@ class ScheduleWidgetState extends State<ScheduleWidget> {
             ),
           ); })
         ]);
+      });
   } 
 }