mirror of
https://github.com/sartography/cr-connect-workflow.git
synced 2025-02-23 13:18:35 +00:00
3b57adb84c
* TaskEvents now contain the data for each event as it was when the task was completed. * When loading a task for the front end, if the task was completed previously, we take that data, and overwrite it with the lastest data, allowing users to see previously entered values. * Pulling in the Admin branch, as there are changes in that branch that are critical to seeing what is happening when we do this thing. * Moved code for converting a workflow to an API ready data stricture into the Workflow service where it belongs, and out of the API. * Hard resets just convert to using the latest spec, they don't try to keep the data from the last task. There is a better way. * Moving to a previous task does not attept to keep the data from the last completed task. * Added a function that will fix all the existing RRT data by adding critical data into the TaskEvent model. This can be called with from the flask command line tool.
103 lines
3.1 KiB
Python
103 lines
3.1 KiB
Python
import logging
|
|
import os
|
|
import sentry_sdk
|
|
|
|
import connexion
|
|
from jinja2 import Environment, FileSystemLoader
|
|
from flask_admin import Admin
|
|
from flask_admin.contrib.sqla import ModelView
|
|
from flask_cors import CORS
|
|
from flask_marshmallow import Marshmallow
|
|
from flask_mail import Mail
|
|
from flask_migrate import Migrate
|
|
from flask_sqlalchemy import SQLAlchemy
|
|
from sentry_sdk.integrations.flask import FlaskIntegration
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
|
|
connexion_app = connexion.FlaskApp(__name__)
|
|
|
|
app = connexion_app.app
|
|
app.config.from_object('config.default')
|
|
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
|
|
|
|
if "TESTING" in os.environ and os.environ["TESTING"] == "true":
|
|
app.config.from_object('config.testing')
|
|
app.config.from_pyfile('../config/testing.py')
|
|
else:
|
|
app.config.root_path = app.instance_path
|
|
app.config.from_pyfile('config.py', silent=True)
|
|
|
|
db = SQLAlchemy(app)
|
|
""":type: sqlalchemy.orm.SQLAlchemy"""
|
|
|
|
session = db.session
|
|
""":type: sqlalchemy.orm.Session"""
|
|
|
|
migrate = Migrate(app, db)
|
|
ma = Marshmallow(app)
|
|
|
|
from crc import models
|
|
from crc import api
|
|
from crc.api import admin
|
|
|
|
connexion_app.add_api('api.yml', base_path='/v1.0')
|
|
|
|
|
|
# Convert list of allowed origins to list of regexes
|
|
origins_re = [r"^https?:\/\/%s(.*)" % o.replace('.', '\.') for o in app.config['CORS_ALLOW_ORIGINS']]
|
|
cors = CORS(connexion_app.app, origins=origins_re)
|
|
|
|
# Sentry error handling
|
|
if app.config['ENABLE_SENTRY']:
|
|
sentry_sdk.init(
|
|
dsn="https://25342ca4e2d443c6a5c49707d68e9f40@o401361.ingest.sentry.io/5260915",
|
|
integrations=[FlaskIntegration()]
|
|
)
|
|
|
|
# Jinja environment definition, used to render mail templates
|
|
template_dir = os.getcwd() + '/crc/static/templates/mails'
|
|
env = Environment(loader=FileSystemLoader(template_dir))
|
|
# Mail settings
|
|
mail = Mail(app)
|
|
|
|
print('=== USING THESE CONFIG SETTINGS: ===')
|
|
print('APPLICATION_ROOT = ', app.config['APPLICATION_ROOT'])
|
|
print('CORS_ALLOW_ORIGINS = ', app.config['CORS_ALLOW_ORIGINS'])
|
|
print('DB_HOST = ', app.config['DB_HOST'])
|
|
print('LDAP_URL = ', app.config['LDAP_URL'])
|
|
print('PB_BASE_URL = ', app.config['PB_BASE_URL'])
|
|
print('PB_ENABLED = ', app.config['PB_ENABLED'])
|
|
print('PRODUCTION = ', app.config['PRODUCTION'])
|
|
print('TESTING = ', app.config['TESTING'])
|
|
print('TEST_UID = ', app.config['TEST_UID'])
|
|
print('ADMIN_UIDS = ', app.config['ADMIN_UIDS'])
|
|
|
|
@app.cli.command()
|
|
def load_example_data():
|
|
"""Load example data into the database."""
|
|
from example_data import ExampleDataLoader
|
|
ExampleDataLoader.clean_db()
|
|
ExampleDataLoader().load_all()
|
|
|
|
|
|
@app.cli.command()
|
|
def load_example_rrt_data():
|
|
"""Load example data into the database."""
|
|
from example_data import ExampleDataLoader
|
|
ExampleDataLoader.clean_db()
|
|
ExampleDataLoader().load_rrt()
|
|
|
|
@app.cli.command()
|
|
def clear_db():
|
|
"""Load example data into the database."""
|
|
from example_data import ExampleDataLoader
|
|
ExampleDataLoader.clean_db()
|
|
|
|
@app.cli.command()
|
|
def rrt_data_fix():
|
|
"""Finds all the empty task event logs, and populates
|
|
them with good wholesome data."""
|
|
from crc.services.workflow_service import WorkflowService
|
|
WorkflowService.fix_legacy_data_model_for_rrt()
|