Python-Projekte/planner/webservice/file_io.py

import os
from pathlib import Path
from flask import request, Flask
from flask_cors import CORS
from datetime import datetime
import json
import hashlib
import time
from auth import Auth
from planner_load import PlannerLoad
from config_load import ConfigLoad


app = Flask(__name__)
# cors = CORS(app, resources={r"/*": {"origins": "http://localhost:4200/"}})
CORS(app)

script_dir = os.path.dirname(__file__)
save_dir = script_dir.parent.joinpath('save')
planner_dir = script_dir.parent.joinpath('export')
config_dir = script_dir.parent.joinpath('config')
user_info = None


@app.route('/login/', methods=['POST'])
def login():
    user = request.get_json()['data']['user']
    password = request.get_json()['data']['password']
    user_info = Auth().get_user(user, password)

    return app.response_class(
        response=json.dumps(user_info),
        mimetype='application/json'
    )


@app.route('/list/', methods=['GET'])
def list_json():
    return json.dumps(list_dict(), indent=2)


def list_dict():
    result = {'list': [], 'tree': {}}
    for currentFile in save_dir.iterdir():
        if currentFile.is_file() and currentFile.name[-5:] == '.json':
            year, version, timestamp = currentFile.name[:-5].split("_")
            if year not in result['tree']:
                result['tree'][year] = {}
            if version not in result['tree'][year]:
                result['tree'][year][version] = []
            result['tree'][year][version].append(timestamp)
            result['list'].append({'year': year, 'version': version, 'timestamp': timestamp})
            result['list'].sort(key=lambda x: x['timestamp'])
    return result


@app.route('/load/<year>/<version>/<timestamp>', methods=['GET'])
def load(year, version, timestamp):
    file = full_filename(year, version, timestamp)

    if timestamp == 'new':
        return app.response_class(
            response=new_file(year),
            mimetype='application/json'
        )

    if timestamp == 'current' or not Path(file).exists():
        file_list = list_dict()
        timestamp = file_list['tree'][year][version][-1]
        file = full_filename(year, version, timestamp)

    print(file)
    time.sleep(2)
    with open(file, 'r') as frh:
        p_load = PlannerLoad(planner_dir)
        structure = p_load.convert_file(json.loads(frh.read()))

        return app.response_class(
            response=json.dumps(structure),
            mimetype='application/json'
        )


def full_filename(year, version, timestamp):
    return f'{str(save_dir)}/{year}_{version}_{timestamp}.json'


@app.route('/new/<year>', methods=['GET'])
def new_file(year):
    p_load = PlannerLoad(planner_dir)
    structure = p_load.new_file(year)
    return json.dumps(structure)


@app.route('/load/<filename>', methods=['GET'])
def load_file(filename):
    full_filename = f'{str(save_dir)}/{filename}.json'
    if not Path(full_filename).exists():
        file_list = list_dict()
        timestamp = file_list[filename][-1]
        full_filename = f'{full_filename[:-5]}_{timestamp}.json'

    print(full_filename)
    return open(full_filename, 'r').read()


@app.route('/save/<filename>', methods=['POST'])
def save(filename):
    if request.method != 'POST':
        return 'File is missing!'

    new_filename = str(save_dir) + '/' + filename + '_' + datetime.now().strftime('%Y%m%d%H%M%S') + '.json'
    data = request.get_json()['data']
    json.dump(data, open(new_filename, 'w'), indent=2)
    print(new_filename)

    try:
        file_list = list_dict()
        timestamp = file_list[filename][-2]
        old_filename = str(save_dir) + '/' + filename + "_" + timestamp + '.json'

        if old_filename != new_filename and hash(old_filename) == hash(new_filename):
            Path(old_filename).unlink()
            return 'File saved with no changes!'
    except KeyError:
        pass
    return 'File saved with new data!'


@app.route('/config', methods=['GET'])
def config():
    cfg = ConfigLoad(str(config_dir))
    return app.response_class(
        response=json.dumps(cfg.load_file('reisacher', '2022')),
        mimetype='application/json'
    )


@app.route('/accounts/<period>', methods=['GET'])
def accounts(period):
    return open(planner_dir.joinpath(f'accounts_{period}.json'), 'r').read()


def hash(filename):
    BUF_SIZE = 65536
    sha1 = hashlib.sha1()
    with open(filename, 'rb') as g:
        while True:
            hashdata = g.read(BUF_SIZE)
            if not hashdata:
                break
            sha1.update(hashdata)
    return sha1.hexdigest()


if __name__ == '__main__':
    app.secret_key = os.urandom(24)
    app.run(host='0.0.0.0', port='8082', debug=True)