Homec4science
Diffusion invenio-infoscience (maint-2.1) Browse

R3600/modules/webdeposit/lib/webdeposit_workflow_utils.py
d068293b9798maint-2.1

Last Change
Raw File

webdeposit_workflow_utils.py
View Options

# -*- coding: utf-8 -*-
##
## This file is part of Invenio.
## Copyright (C) 2012, 2013 CERN.
##
## Invenio is free software; you can redistribute it and/or
## modify it under the terms of the GNU General Public License as
## published by the Free Software Foundation; either version 2 of the
## License, or (at your option) any later version.
##
## Invenio is distributed in the hope that it will be useful, but
## WITHOUT ANY WARRANTY; without even the implied warranty of
## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
## General Public License for more details.
##
## You should have received a copy of the GNU General Public License
## along with Invenio; if not, write to the Free Software Foundation, Inc.,
## 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
from sqlalchemy import func
from invenio.sqlalchemyutils import db
from invenio.webdeposit_model import WebDepositDraft, \
WebDepositWorkflow
class JsonCookerMixin(object):
def cook_json(self, json_reader):
"""
This is a stub implementation.
"""
return json_reader
def JsonCookerMixinBuilder(key):
class CustomJsonCookerMixin(JsonCookerMixin):
def cook_json(self, json_reader):
value = self.data
json_reader[key] = value
return json_reader
return CustomJsonCookerMixin
def create_deposition_document(deposition_type):
def create_dep_doc(obj, eng):
obj['deposition_type'] = deposition_type
uuid = obj['uuid']
temp_obj = dict(obj)
temp_obj.pop('uuid')
temp_obj.pop('step')
temp_obj.pop('deposition_type')
webdeposit_workflow = WebDepositWorkflow(uuid=uuid,
deposition_type=deposition_type,
obj_json=temp_obj,
current_step=0,
status=0)
db.session.add(webdeposit_workflow)
db.session.commit()
return create_dep_doc
def authorize_user(user_id=None):
def user_auth(obj, eng):
if user_id is not None:
obj['user_id'] = user_id
else:
from invenio.webuser_flask import current_user
obj['user_id'] = current_user.get_id()
return user_auth
def render_form(form):
def render(obj, eng):
uuid = obj['uuid']
if 'user_id' in obj:
user_id = obj['user_id']
else:
from invenio.webuser_flask import current_user
user_id = current_user.get_id()
deposition_type = obj['deposition_type']
step = obj['step']
form_type = form.__name__
webdeposit_draft = WebDepositDraft(uuid=uuid,
user_id=user_id,
deposition_type=deposition_type,
form_type=form_type,
form_values={},
step=step,
timestamp=func.current_timestamp())
db.session.add(webdeposit_draft)
db.session.commit()
return render
def wait_for_submission():
def wait(obj, eng):
obj['break'] = True
eng.current_step -= 1
return wait
c4science · Help