sartography
/
spiff-arena
mirror of https://github.com/sartography/spiff-arena.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

lint

This commit is contained in:
burnettk 2023-04-13 12:38:31 -04:00
parent 8129fd4a59
commit a6ce8bfdc7
1 changed files with 43 additions and 100 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

115
spiffworkflow-backend/src/spiffworkflow_backend/routes/process_instances_controller.py
View File

@ -90,9 +90,7 @@ def process_instance_create(
modified_process_model_identifier: str, modified_process_model_identifier: str,
) -> flask.wrappers.Response: ) -> flask.wrappers.Response:
"""Create_process_instance.""" """Create_process_instance."""
process_model_identifier = _un_modify_modified_process_model_id( process_model_identifier = _un_modify_modified_process_model_id(modified_process_model_identifier)
modified_process_model_identifier
)
process_model = _get_process_model(process_model_identifier) process_model = _get_process_model(process_model_identifier)
if process_model.primary_file_name is None: if process_model.primary_file_name is None:
@ -105,11 +103,9 @@ def process_instance_create(
status_code=400, status_code=400,
) )
process_instance = ( process_instance = ProcessInstanceService.create_process_instance_from_process_model_identifier(
ProcessInstanceService.create_process_instance_from_process_model_identifier(
process_model_identifier, g.user process_model_identifier, g.user
) )
)
return Response( return Response(
json.dumps(ProcessInstanceModelSchema().dump(process_instance)), json.dumps(ProcessInstanceModelSchema().dump(process_instance)),
status=201, status=201,
@ -158,15 +154,11 @@ def process_instance_run(
if not current_app.config["SPIFFWORKFLOW_BACKEND_RUN_BACKGROUND_SCHEDULER"]: if not current_app.config["SPIFFWORKFLOW_BACKEND_RUN_BACKGROUND_SCHEDULER"]:
MessageService.correlate_all_message_instances() MessageService.correlate_all_message_instances()
process_instance_api = ProcessInstanceService.processor_to_process_instance_api( process_instance_api = ProcessInstanceService.processor_to_process_instance_api(processor)
processor
)
process_instance_data = processor.get_data() process_instance_data = processor.get_data()
process_instance_metadata = ProcessInstanceApiSchema().dump(process_instance_api) process_instance_metadata = ProcessInstanceApiSchema().dump(process_instance_api)
process_instance_metadata["data"] = process_instance_data process_instance_metadata["data"] = process_instance_data
return Response( return Response(json.dumps(process_instance_metadata), status=200, mimetype="application/json")
json.dumps(process_instance_metadata), status=200, mimetype="application/json"
)
def process_instance_terminate( def process_instance_terminate(
@ -244,17 +236,12 @@ def process_instance_log_list(
process_instance = _find_process_instance_by_id_or_raise(process_instance_id) process_instance = _find_process_instance_by_id_or_raise(process_instance_id)
log_query = ( log_query = (
ProcessInstanceEventModel.query.filter_by( ProcessInstanceEventModel.query.filter_by(process_instance_id=process_instance.id)
process_instance_id=process_instance.id
)
.outerjoin(TaskModel, TaskModel.guid == ProcessInstanceEventModel.task_guid) .outerjoin(TaskModel, TaskModel.guid == ProcessInstanceEventModel.task_guid)
.outerjoin( .outerjoin(TaskDefinitionModel, TaskDefinitionModel.id == TaskModel.task_definition_id)
TaskDefinitionModel, TaskDefinitionModel.id == TaskModel.task_definition_id
)
.outerjoin( .outerjoin(
BpmnProcessDefinitionModel, BpmnProcessDefinitionModel,
BpmnProcessDefinitionModel.id BpmnProcessDefinitionModel.id == TaskDefinitionModel.bpmn_process_definition_id,
== TaskDefinitionModel.bpmn_process_definition_id,
) )
) )
if not detailed: if not detailed:
@ -351,9 +338,7 @@ def process_instance_list(
report_filter_by: Optional[str] = None, report_filter_by: Optional[str] = None,
) -> flask.wrappers.Response: ) -> flask.wrappers.Response:
"""Process_instance_list.""" """Process_instance_list."""
process_instance_report = ProcessInstanceReportService.report_with_identifier( process_instance_report = ProcessInstanceReportService.report_with_identifier(g.user, report_id, report_identifier)
g.user, report_id, report_identifier
)
report_column_list = None report_column_list = None
if report_columns: if report_columns:
@ -377,8 +362,7 @@ def process_instance_list(
report_filter_by_list=report_filter_by_list, report_filter_by_list=report_filter_by_list,
) )
else: else:
report_filter = ( report_filter = ProcessInstanceReportService.filter_from_metadata_with_overrides(
ProcessInstanceReportService.filter_from_metadata_with_overrides(
process_instance_report=process_instance_report, process_instance_report=process_instance_report,
process_model_identifier=process_model_identifier, process_model_identifier=process_model_identifier,
user_group_identifier=user_group_identifier, user_group_identifier=user_group_identifier,
@ -392,7 +376,6 @@ def process_instance_list(
report_column_list=report_column_list, report_column_list=report_column_list,
report_filter_by_list=report_filter_by_list, report_filter_by_list=report_filter_by_list,
) )
)
response_json = ProcessInstanceReportService.run_process_instance_report( response_json = ProcessInstanceReportService.run_process_instance_report(
report_filter=report_filter, report_filter=report_filter,
@ -416,17 +399,14 @@ def process_instance_report_column_list(
.distinct() # type: ignore .distinct() # type: ignore
) )
if process_model_identifier: if process_model_identifier:
columns_for_metadata_query = columns_for_metadata_query.join( columns_for_metadata_query = columns_for_metadata_query.join(ProcessInstanceModel)
ProcessInstanceModel
)
columns_for_metadata_query = columns_for_metadata_query.filter( columns_for_metadata_query = columns_for_metadata_query.filter(
ProcessInstanceModel.process_model_identifier == process_model_identifier ProcessInstanceModel.process_model_identifier == process_model_identifier
) )
columns_for_metadata = columns_for_metadata_query.all() columns_for_metadata = columns_for_metadata_query.all()
columns_for_metadata_strings = [ columns_for_metadata_strings = [
{"Header": i[0], "accessor": i[0], "filterable": True} {"Header": i[0], "accessor": i[0], "filterable": True} for i in columns_for_metadata
for i in columns_for_metadata
] ]
return make_response(jsonify(table_columns + columns_for_metadata_strings), 200) return make_response(jsonify(table_columns + columns_for_metadata_strings), 200)
@ -473,17 +453,13 @@ def process_instance_delete(
# (Pdb) db.session.delete # (Pdb) db.session.delete
# <bound method delete of <sqlalchemy.orm.scoping.scoped_session object at 0x103eaab30>> # <bound method delete of <sqlalchemy.orm.scoping.scoped_session object at 0x103eaab30>>
db.session.query(ProcessInstanceQueueModel).filter_by( db.session.query(ProcessInstanceQueueModel).filter_by(process_instance_id=process_instance.id).delete()
process_instance_id=process_instance.id
).delete()
db.session.delete(process_instance) db.session.delete(process_instance)
db.session.commit() db.session.commit()
return Response(json.dumps({"ok": True}), status=200, mimetype="application/json") return Response(json.dumps({"ok": True}), status=200, mimetype="application/json")
def process_instance_report_list( def process_instance_report_list(page: int = 1, per_page: int = 100) -> flask.wrappers.Response:
page: int = 1, per_page: int = 100
) -> flask.wrappers.Response:
"""Process_instance_report_list.""" """Process_instance_report_list."""
process_instance_reports = ProcessInstanceReportModel.query.filter_by( process_instance_reports = ProcessInstanceReportModel.query.filter_by(
created_by_id=g.user.id, created_by_id=g.user.id,
@ -568,9 +544,7 @@ def process_instance_report_show(
) )
substitution_variables = request.args.to_dict() substitution_variables = request.args.to_dict()
result_dict = process_instance_report.generate_report( result_dict = process_instance_report.generate_report(process_instances.items, substitution_variables)
process_instances.items, substitution_variables
)
# update this if we go back to a database query instead of filtering in memory # update this if we go back to a database query instead of filtering in memory
result_dict["pagination"] = { result_dict["pagination"] = {
@ -639,9 +613,7 @@ def process_instance_task_list(
to_task_model: Optional[TaskModel] = None to_task_model: Optional[TaskModel] = None
task_models_of_parent_bpmn_processes_guids: list[str] = [] task_models_of_parent_bpmn_processes_guids: list[str] = []
if to_task_guid is not None: if to_task_guid is not None:
to_task_model = TaskModel.query.filter_by( to_task_model = TaskModel.query.filter_by(guid=to_task_guid, process_instance_id=process_instance.id).first()
guid=to_task_guid, process_instance_id=process_instance.id
).first()
if to_task_model is None: if to_task_model is None:
raise ApiError( raise ApiError(
error_code="task_not_found", error_code="task_not_found",
@ -664,9 +636,7 @@ def process_instance_task_list(
_parent_bpmn_processes, _parent_bpmn_processes,
task_models_of_parent_bpmn_processes, task_models_of_parent_bpmn_processes,
) = TaskService.task_models_of_parent_bpmn_processes(to_task_model) ) = TaskService.task_models_of_parent_bpmn_processes(to_task_model)
task_models_of_parent_bpmn_processes_guids = [ task_models_of_parent_bpmn_processes_guids = [p.guid for p in task_models_of_parent_bpmn_processes if p.guid]
p.guid for p in task_models_of_parent_bpmn_processes if p.guid
]
task_model_query = task_model_query.filter( task_model_query = task_model_query.filter(
or_( or_(
TaskModel.end_in_seconds <= to_task_model.end_in_seconds, # type: ignore TaskModel.end_in_seconds <= to_task_model.end_in_seconds, # type: ignore
@ -680,14 +650,11 @@ def process_instance_task_list(
task_model_query = ( task_model_query = (
task_model_query.order_by(TaskModel.id.desc()) # type: ignore task_model_query.order_by(TaskModel.id.desc()) # type: ignore
.join( .join(TaskDefinitionModel, TaskDefinitionModel.id == TaskModel.task_definition_id)
TaskDefinitionModel, TaskDefinitionModel.id == TaskModel.task_definition_id
)
.join(bpmn_process_alias, bpmn_process_alias.id == TaskModel.bpmn_process_id) .join(bpmn_process_alias, bpmn_process_alias.id == TaskModel.bpmn_process_id)
.outerjoin( .outerjoin(
direct_parent_bpmn_process_alias, direct_parent_bpmn_process_alias,
direct_parent_bpmn_process_alias.id direct_parent_bpmn_process_alias.id == bpmn_process_alias.direct_parent_process_id,
== bpmn_process_alias.direct_parent_process_id,
) )
.outerjoin( .outerjoin(
direct_parent_bpmn_process_definition_alias, direct_parent_bpmn_process_definition_alias,
@ -696,8 +663,7 @@ def process_instance_task_list(
) )
.join( .join(
BpmnProcessDefinitionModel, BpmnProcessDefinitionModel,
BpmnProcessDefinitionModel.id BpmnProcessDefinitionModel.id == TaskDefinitionModel.bpmn_process_definition_id,
== TaskDefinitionModel.bpmn_process_definition_id,
) )
.add_columns( .add_columns(
BpmnProcessDefinitionModel.bpmn_identifier.label("bpmn_process_definition_identifier"), # type: ignore BpmnProcessDefinitionModel.bpmn_identifier.label("bpmn_process_definition_identifier"), # type: ignore
@ -720,9 +686,7 @@ def process_instance_task_list(
) )
if len(bpmn_process_ids) > 0: if len(bpmn_process_ids) > 0:
task_model_query = task_model_query.filter( task_model_query = task_model_query.filter(bpmn_process_alias.id.in_(bpmn_process_ids))
bpmn_process_alias.id.in_(bpmn_process_ids)
)
task_models = task_model_query.all() task_models = task_model_query.all()
if most_recent_tasks_only: if most_recent_tasks_only:
@ -739,22 +703,14 @@ def process_instance_task_list(
task_models = [ task_models = [
task_model task_model
for task_model in most_recent_tasks.values() for task_model in most_recent_tasks.values()
if task_model.bpmn_process_guid in most_recent_subprocesses if task_model.bpmn_process_guid in most_recent_subprocesses or task_model.bpmn_process_guid is None
or task_model.bpmn_process_guid is None
] ]
if to_task_model is not None: if to_task_model is not None:
task_models_dict = json.loads(current_app.json.dumps(task_models)) task_models_dict = json.loads(current_app.json.dumps(task_models))
for task_model in task_models_dict: for task_model in task_models_dict:
end_in_seconds = ( end_in_seconds = float(task_model["end_in_seconds"]) if task_model["end_in_seconds"] is not None else None
float(task_model["end_in_seconds"]) if to_task_model.guid == task_model["guid"] and task_model["state"] == "COMPLETED":
if task_model["end_in_seconds"] is not None
else None
)
if (
to_task_model.guid == task_model["guid"]
and task_model["state"] == "COMPLETED"
):
TaskService.reset_task_model_dict(task_model, state="READY") TaskService.reset_task_model_dict(task_model, state="READY")
elif ( elif (
end_in_seconds is None end_in_seconds is None
@ -783,14 +739,10 @@ def process_instance_find_by_id(
) -> flask.wrappers.Response: ) -> flask.wrappers.Response:
"""Process_instance_find_by_id.""" """Process_instance_find_by_id."""
process_instance = _find_process_instance_by_id_or_raise(process_instance_id) process_instance = _find_process_instance_by_id_or_raise(process_instance_id)
modified_process_model_identifier = ( modified_process_model_identifier = ProcessModelInfo.modify_process_identifier_for_path_param(
ProcessModelInfo.modify_process_identifier_for_path_param(
process_instance.process_model_identifier process_instance.process_model_identifier
) )
) process_instance_uri = f"/process-instances/{modified_process_model_identifier}/{process_instance.id}"
process_instance_uri = (
f"/process-instances/{modified_process_model_identifier}/{process_instance.id}"
)
has_permission = AuthorizationService.user_has_permission( has_permission = AuthorizationService.user_has_permission(
user=g.user, user=g.user,
permission="read", permission="read",
@ -824,31 +776,22 @@ def _get_process_instance(
process_model_with_diagram = None process_model_with_diagram = None
name_of_file_with_diagram = None name_of_file_with_diagram = None
if process_identifier: if process_identifier:
spec_reference = SpecReferenceCache.query.filter_by( spec_reference = SpecReferenceCache.query.filter_by(identifier=process_identifier, type="process").first()
identifier=process_identifier, type="process"
).first()
if spec_reference is None: if spec_reference is None:
raise SpecReferenceNotFoundError( raise SpecReferenceNotFoundError(
f"Could not find given process identifier in the cache: {process_identifier}" f"Could not find given process identifier in the cache: {process_identifier}"
) )
process_model_with_diagram = ProcessModelService.get_process_model( process_model_with_diagram = ProcessModelService.get_process_model(spec_reference.process_model_id)
spec_reference.process_model_id
)
name_of_file_with_diagram = spec_reference.file_name name_of_file_with_diagram = spec_reference.file_name
process_instance.process_model_with_diagram_identifier = ( process_instance.process_model_with_diagram_identifier = process_model_with_diagram.id
process_model_with_diagram.id
)
else: else:
process_model_with_diagram = _get_process_model(process_model_identifier) process_model_with_diagram = _get_process_model(process_model_identifier)
if process_model_with_diagram.primary_file_name: if process_model_with_diagram.primary_file_name:
name_of_file_with_diagram = process_model_with_diagram.primary_file_name name_of_file_with_diagram = process_model_with_diagram.primary_file_name
if process_model_with_diagram and name_of_file_with_diagram: if process_model_with_diagram and name_of_file_with_diagram:
if ( if process_instance.bpmn_version_control_identifier == current_version_control_revision:
process_instance.bpmn_version_control_identifier
== current_version_control_revision
):
bpmn_xml_file_contents = SpecFileService.get_data( bpmn_xml_file_contents = SpecFileService.get_data(
process_model_with_diagram, name_of_file_with_diagram process_model_with_diagram, name_of_file_with_diagram
).decode("utf-8") ).decode("utf-8")