run_backend.py

# Copyright 2022 Cisco Systems, Inc. and its affiliates
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# SPDX-License-Identifier: Apache-2.0


import argparse
from multiprocessing import Process
import yaml
from tinydb import TinyDB, Query
from backend.server import create_app, run_app_server, create_server_config
from frontend.app import run_client

if __name__ == "__main__":
    # es = Elasticsearch(['http://localhost:9200/'], verify_certs=True)
    # if not es.ping():
    #     run_elastic_search_service = subprocess.Popen(
    #         ["./elasticsearch"], cwd="../elasticsearch/bin")

    db = TinyDB('config.json')
    db.drop_tables()
    Config = Query()
    parser = argparse.ArgumentParser()
    parser.add_argument('yaml_file',
                        help='YAML file that describes the NLP pipeline',
                        )
    parser.add_argument('-p', type=int, default=5001,
                        required=False, help="defines port ot be used")

    args = parser.parse_args()

    with open(args.yaml_file, mode="rt", encoding="utf-8") as file:
        data = yaml.safe_load(file)

    db.insert({
        "type":"yaml_config",
        "config":data
    })
    config = create_server_config(data)
    app,sockio = create_app(data)
    port = args.p

    run_app_server(app,sockio,3000,'0.0.0.0')

    # p_dash = Process(target=run_client, args=(data, port, '0.0.0.0'))
    # p_serv = Process(target=run_app_server, args=(app,sockio, 3000, '0.0.0.0'))

    # p_dash.start()

    # try:
    #     p_serv.start()
    #     p_serv.join()
    # except:
    #     print("Flask server may already be running!")

    # p_dash.join()