import os import json from flask import Flask, render_template, send_from_directory, request, \ url_for, abort, g, redirect, jsonify, session, flash, Response from flask_login import login_required from fatcat_client import Editgroup from fatcat_client.rest import ApiException from fatcat_tools.transforms import * from fatcat_web import app, api, auth_api, priv_api from fatcat_web.auth import handle_token_login, handle_logout, load_user, handle_ia_xauth from fatcat_web.cors import crossdomain from fatcat_web.search import * from fatcat_web.forms import * ### Helper Methods ########################################################## def form_editgroup_get_or_create(api, edit_form): """ This function expects a submitted, validated """ if edit_form.editgroup_id.data: try: eg = api.get_editgroup(edit_form.editgroup_id.data) except ApiException as ae: if ae.status == 404: edit_form.editgroup_id.errors.append("Editgroup does not exist") return None app.log.warning(ae) abort(ae.status) if eg.changelog_index: edit_form.editgroup_id.errors.append("Editgroup has already been accepted") return None else: # if no editgroup, create one from description try: eg = api.create_editgroup( Editgroup(description=edit_form.editgroup_description.data or None)) except ApiException as ae: app.log.warning(ae) abort(ae.status) # set this session editgroup_id session['active_editgroup_id'] = eg.editgroup_id flash('Started new editgroup {}' \ .format(eg.editgroup_id, eg.editgroup_id)) return eg ### Views ################################################################### @app.route('/container/create', methods=['GET', 'POST']) @login_required def container_create(): form = ContainerEntityForm() status = 200 if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # no merge or anything hard to do; just create the entity entity = form.to_entity() try: edit = user_api.create_container(entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to new entity return redirect('/container/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id return render_template('container_create.html', form=form), status @app.route('/container//edit', methods=['GET', 'POST']) @login_required def container_edit(ident): # TODO: prev_rev interlock try: entity = api.get_container(ident) except ApiException as ae: abort(ae.status) status = 200 form = ContainerEntityForm() if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # all the tricky logic is in the update method form.update_entity(entity) try: edit = user_api.update_container(entity.ident, entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to entity revision # TODO: container_rev_view return redirect('/container/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: form = ContainerEntityForm.from_entity(entity) if not form.is_submitted(): editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id return render_template('container_edit.html', form=form, entity=entity), status @app.route('/creator//edit', methods=['GET']) def creator_edit(ident): try: entity = api.get_creator(ident) except ApiException as ae: abort(ae.status) return render_template('entity_edit.html'), 404 @app.route('/creator/create', methods=['GET']) def creator_create_view(): return abort(404) @app.route('/file/create', methods=['GET', 'POST']) @login_required def file_create(): form = FileEntityForm() status = 200 if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # no merge or anything hard to do; just create the entity entity = form.to_entity() try: edit = user_api.create_file(entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to new entity return redirect('/file/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id form.urls.append_entry() form.release_ids.append_entry() return render_template('file_create.html', form=form), status @app.route('/file//edit', methods=['GET', 'POST']) @login_required def file_edit(ident): # TODO: prev_rev interlock try: entity = api.get_file(ident) except ApiException as ae: abort(ae.status) status = 200 form = FileEntityForm() if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # all the tricky logic is in the update method form.update_entity(entity) try: edit = user_api.update_file(entity.ident, entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to entity revision # TODO: file_rev_view return redirect('/file/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: # not submitted form = FileEntityForm.from_entity(entity) editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id return render_template('file_edit.html', form=form, entity=entity), status @app.route('/fileset//edit', methods=['GET']) def fileset_edit(ident): try: entity = api.get_fileset(ident) except ApiException as ae: abort(ae.status) return render_template('entity_edit.html'), 404 @app.route('/fileset/create', methods=['GET']) def fileset_create_view(): return abort(404) @app.route('/webcapture//edit', methods=['GET']) def webcapture_edit(ident): try: entity = api.get_webcapture(ident) except ApiException as ae: abort(ae.status) return render_template('entity_edit.html'), 404 @app.route('/webcapture/create', methods=['GET']) def webcapture_create_view(): return abort(404) @app.route('/release/create', methods=['GET', 'POST']) @login_required def release_create(): form = ReleaseEntityForm() status = 200 if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # no merge or anything hard to do; just create the entity entity = form.to_entity() try: edit = user_api.create_release(entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to new release return redirect('/release/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: # not submitted form.contribs.append_entry() editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id return render_template('release_create.html', form=form), status @app.route('/release//edit', methods=['GET', 'POST']) @login_required def release_edit(ident): # TODO: prev_rev interlock try: entity = api.get_release(ident) except ApiException as ae: abort(ae.status) status = 200 form = ReleaseEntityForm() if form.is_submitted(): if form.validate_on_submit(): # API on behalf of user user_api = auth_api(session['api_token']) eg = form_editgroup_get_or_create(user_api, form) if eg: # all the tricky logic is in the update method form.update_entity(entity) try: edit = user_api.update_release(entity.ident, entity, editgroup_id=eg.editgroup_id) except ApiException as ae: app.log.warning(ae) abort(ae.status) # redirect to entity revision # TODO: release_rev_view return redirect('/release/{}'.format(edit.ident)) elif form.errors: status = 400 app.log.info("form errors (did not validate): {}".format(form.errors)) else: # not submitted form = ReleaseEntityForm.from_entity(entity) editgroup_id = session.get('active_editgroup_id', None) form.editgroup_id.data = editgroup_id return render_template('release_edit.html', form=form, entity=entity), status @app.route('/work/create', methods=['GET']) def work_create_view(): return abort(404) @app.route('/work//edit', methods=['GET']) def work_edit_view(ident): try: entity = api.get_work(ident) except ApiException as ae: abort(ae.status) return render_template('entity_edit.html'), 404