oc-front/lib/pages/workflow.dart

import 'package:flutter/material.dart';
import 'package:flutter_flow_chart/flutter_flow_chart.dart';
import 'package:go_router/go_router.dart';
import 'package:oc_front/core/models/shared_workspace_local.dart';
import 'package:oc_front/core/models/workspace_local.dart';
import 'package:oc_front/core/sections/header/header.dart';
import 'package:oc_front/core/services/specialized_services/shared_service.dart';
import 'package:oc_front/core/services/specialized_services/workflow_service.dart';
import 'package:oc_front/models/response.dart';
import 'package:oc_front/models/search.dart';
import 'package:oc_front/models/workflow.dart';
import 'package:oc_front/pages/abstract_page.dart';
import 'package:oc_front/pages/shared.dart';
import 'package:oc_front/widgets/dialog/shallow_creation.dart';
import 'package:oc_front/widgets/forms/processing_forms.dart';
import 'package:oc_front/widgets/forms/scheduler_forms.dart';
import 'package:oc_front/widgets/items/item_row.dart';
import 'package:oc_front/widgets/inputs/shallow_dropdown_input.dart';

Dashboard dash = Dashboard(
  name: "workflow_${DateTime.now().toString().replaceAll(" ", "_").substring(0, DateTime.now().toString().length - 7)}");
class WorkflowFactory implements AbstractFactory {
  static GlobalKey<WorkflowPageWidgetState> key = GlobalKey<WorkflowPageWidgetState>();
  @override bool searchFill() { return false; }
  @override Widget factory(GoRouterState state, List<String> args) { 
    String? id;
    try { id = state.pathParameters[args.first];
    } catch (e) { }
    return WorkflowPageWidget(id: id); 
  }
  @override void search(BuildContext context) { }
}
bool getAll = true;

class WorkflowPageWidget extends StatefulWidget {
  String? id;
  WorkflowPageWidget ({ this.id }) : super(key: WorkflowFactory.key);
  @override WorkflowPageWidgetState createState() => WorkflowPageWidgetState();
  static void search(BuildContext context) { }
  static Widget factory() { return WorkflowPageWidget(); }
}
class WorkflowPageWidgetState extends State<WorkflowPageWidget> {
final WorflowService _service = WorflowService();
  Widget itemBuild(Object item) {
    var e = item as AbstractItem;
    return Tooltip( message: item.name ?? "",
      child:  e.logo != null ? Image.network(e.logo ?? "", fit: BoxFit.fill) 
        : Image.network('https://get-picto.com/wp-content/uploads/2024/01/logo-instagram-png.webp', 
      fit: BoxFit.fill));
  }
  Widget itemTooltipBuild(Object item) {
    var e = item as AbstractItem;
    return Container(color: Colors.white, child: ItemRowWidget(low: true, contextWidth: 290, item: e));
  }
  List<Widget> getForms(FlowData? obj) {
    return obj == null ? [] : [
      ProcessingFormsWidget(item: obj as AbstractItem, dash: dash),
    ];
  }

  List<Widget> getDashInfoForms() {
    return [
      SchedulerFormsWidget(item: dash),
    ];
  }

  Future<void> loadDash(String selected) async {
    dash.shouldSave = false;
    if (selected.split("~").length > 1) {
      dash.name = selected.split("~")[1];
      dash.id = selected.split("~")[0];
    } else {
      dash.name = selected;
    }
    await _service.get(context, dash.id ?? "").then((value) {
      if (value.data != null) {
        dash.clear();
        dash.deserialize(value.data!.toDashboard());
        Future.delayed(const Duration(seconds: 1), () => dash.shouldSave = true);
      }
    });
  }

  Future<void> saveDash(String? id) async {
    if (id == null || !dash.isOpened || !dash.shouldSave) { return; }
    var datas = WorkspaceLocal.byTopic("data", true).where(
        (element) => dash.elements.map( (e) => e.element?.getID()).contains(element.id) );
    var dataCenter = WorkspaceLocal.byTopic("datacenter", true).where(
        (element) => dash.elements.map( (e) => e.element?.getID()).contains(element.id) );
    var storage = WorkspaceLocal.byTopic("storage", true).where(
        (element) => dash.elements.map( (e) => e.element?.getID()).contains(element.id) );
    var computing = WorkspaceLocal.byTopic("processing", true).where(
        (element) => dash.elements.map( (e) => e.element?.getID()).contains(element.id) );
    var workflows = WorkspaceLocal.byTopic("workflows", true).where(
        (element) => dash.elements.map( (e) => e.element?.getID()).contains(element.id) );
    var updateW = Workflow(
      name: dash.name,
      graph: Graph(),
      data: datas.map((e) => e.id).toSet().toList(),
      datacenter: dataCenter.map((e) => e.id).toSet().toList(),
      storage: storage.map((e) => e.id).toSet().toList(),
      processing: computing.map((e) => e.id).toSet().toList(),
      workflows: workflows.map((e) => e.id).toSet().toList(),
    );
    updateW.fromDashboard(dash.serialize());
    for (var item in (updateW.graph?.items.values ?? [] as List<GraphItem>)) {
      if (item.position == null) { continue; }
      item.position?.x = (item.position?.x ?? 0) + (item.width! / 2) + 7.5;
      item.position?.y = (item.position?.y ?? 0) + (item.height! / 2) + 7.5;
      for (var i in (updateW.graph?.links ?? [] as List<GraphLink>).where((element) => id == element.source?.id)) {
        i.source?.x = (i.source?.x ?? 0) + (item.width! / 2) + 7;
        i.source?.y = (i.source?.y ?? 0) + (item.width! / 2) + 7;
      }
      for (var i in (updateW.graph?.links ?? [] as List<GraphLink>).where((element) => id == element.destination?.id)) {
        i.destination?.x = (i.destination?.x ?? 0) + (item.width! / 2) + 7.5;
        i.destination?.y = (i.destination?.y ?? 0) + (item.width! / 2) + 7.5;
      }
    }
    updateW.graph?.zoom = dash.getZoomFactor();
    print("SAVE DASH");
    dash.addToHistory();
    await _service.put(context, id, updateW.serialize(), {}).then( (e) {
      if (dash.addChange) {
        dash.addChange = false;
        WorkspaceLocal.init(context, false);
        dash.selectedLeftMenuKey.currentState?.setState(() { });
      }
    });  
  }

  FlowData? transformToData(Map<String, dynamic> data) {
    var d = WorkspaceLocal.getItem(data["id"] ?? "", true);
    if (d == null) { return null; }
    d.model = ResourceModel().deserialize(data["resource_model"]);
    if (d.topic == "data") { return d as DataItem; }
    if (d.topic == "datacenter") { return d as DataCenterItem; }
    if (d.topic == "storage") { return d as StorageItem; }
    if (d.topic == "processing") { return d as ProcessingItem; }
    if (d.topic == "workflows") { return d as WorkflowItem; }
    return null;
  }

  Widget onDashboardMenu(Dashboard dash) {
    return ShallowDropdownInputWidget(
            iconLoad: Icons.share,
            tooltipLoad: 'share',
            tooltipRemove: 'unshare',
            filled: const Color.fromRGBO(38,166, 154, 1),
            color: Colors.white,
            hintColor: Colors.grey.shade300,
            type: SharedWorkspaceType.workflow,
            all: () async => SharedWorkspaceLocal.workspaces.values.map( 
              (e) => Shallow(id: e.id ?? "", name: e.name ?? "") ).toList(),
            current: WorkspaceLocal.workspaces[WorkspaceLocal.current]?.shared,
            width: (MediaQuery.of(context).size.width / 3),
            canLoad: (String? change) {
              return SharedWorkspaceLocal.workspaces[change] == null 
              || !SharedWorkspaceLocal.workspaces[change]!.workflows.map( (e) => e.id 
                ).contains(dash.id);
            },
            canRemove: (String? change) => SharedWorkspaceLocal.workspaces[change] == null 
              || SharedWorkspaceLocal.workspaces[change]!.workflows.map( (e) => e.id 
                ).contains(dash.id), 
            load: (String val) async {
              await SharedService().addWorkflow(context, val, dash.id ?? "");
              SharedWorkspaceLocal.init(context, false);
              dash.selectedMenuKey.currentState?.setState(() { });
            },
            remove: (String val) async {
              await SharedService().removeWorkflow(context, val, dash.id ?? "");
              SharedWorkspaceLocal.init(context, false);
              dash.selectedMenuKey.currentState?.setState(() { });
            });
  }
  Widget menuExtension() {
    var quart = MediaQuery.of(context).size.width / 6;
    return ShallowDropdownInputWidget(
                current: WorkspaceLocal.current,
                width: quart > 80 ? quart : 80,
                all: () async => WorkspaceLocal.getWorkspacesShallow(),
                type: SharedWorkspaceType.workspace,
                change: (String? change) {
                  WorkspaceLocal.changeWorkspace(change.toString());
                }
            );
  }
  Widget onDashboardAlertOpened(BuildContext context, Dashboard dash) {
    return ShallowCreationDialogWidget(
      canClose: () => dash.isOpened,
      context: context,
      load: (p0) async {
        dash.isOpened = true;
        if (dash.load != null) {
          WorkspaceLocal.changeWorkspaceByName(p0.split("~")[1]);  
            await dash.load!(p0);         
          } 
          dash.notifyListeners();
      },
      create: (p0) async => await _service.post(context, p0, {}).then( (value) {
          dash.clear();
          dash.id = value.data?.getID() ?? "";
          dash.name = value.data?.getName() ?? "";
          dash.notifyListeners();
          WorkspaceLocal.init(context, true);
          dash.isOpened = true;
        }
      ),
      maptoDropdown: (e) => DropdownMenuItem<String>(
                              value: "${e.id}~${e.name}",
                              child: Text(e.name),
                            ),
      type: SharedWorkspaceType.workflow,
      all: () async {
        List<Shallow> res = [];
        await _service.all(context).then(
          (e) {
            if (e.data != null) {
              res = e.data!.values.map((e) => Shallow(id: e["id"] ?? "", name: e["name"] ?? "")).toList();
            }
          }
        );
        return res;
      }
    );
  }
  @override Widget build(BuildContext context) {
    dash.load = loadDash;
    dash.save = saveDash;
    dash.transformToData = transformToData;
    dash.infoItemWidget = getForms;
    dash.infoWidget = getDashInfoForms;
    var quart = MediaQuery.of(context).size.width / 6;
    dash.defaultName = "workflow_${DateTime.now().toString().replaceAll(" ", "_"
      ).substring(0, DateTime.now().toString().length - 7)}";
    return FlowChart<AbstractItem>(
                onDashboardAlertOpened: onDashboardAlertOpened,
                dashboard: dash,
                current: widget.id,
                itemWidget: itemBuild,
                menuWidget: onDashboardMenu,
                categories: const ["processing", "data", "datacenter", "storage", "workflows"],
                draggableItemBuilder: (cat) => WorkspaceLocal.byTopic(cat, false),
                itemWidgetTooltip: itemTooltipBuild,
                innerMenuWidth: quart > 80 ? quart : 80,
                width: MediaQuery.of(context).size.width,
                height: MediaQuery.of(context).size.height - HeaderConstants.height,
                onNewConnection: (p1, p2) { },
                menuExtension: menuExtension,
                onDashboardTapped: (context, position) { },
                onScaleUpdate: (newScale) { },
                onDashboardSecondaryTapped: (context, position) { },
                onDashboardLongTapped: (context, position) { },
                onDashboardSecondaryLongTapped: (context, position) { },
                onElementLongPressed: (context, position, element) { },
                onElementSecondaryLongTapped: (context, position, element) { },
                onElementPressed: (context, position, element) {  },
                onElementSecondaryTapped: (context, position, element) { },
                onHandlerPressed: (context, position, handler, element) { },
                onHandlerLongPressed: (context, position, handler, element) { },
                onPivotSecondaryPressed: (context, pivot) { },
      );
  }
}