/ - Diff - Synnefo - Greek Research and Technology Network's projects

Revision 6335ad6f

       * A Project entry is created when submitting an application for a new
         project, rather than on approval. Its state is dependent on the state
         of its `reference' application (current definition).
         of its `reference' application (current definition). Lock Project rather
         than Chain (the latter is semantically obsolete).
       * Improve recording of membership actions.

     from synnefo.lib import join_urls
     from astakos.im.models import AstakosUser, Invitation, ProjectMembership, \
         ProjectApplication, Project, Chain, new_chain
         ProjectApplication, Project, new_chain
     from astakos.im.quotas import qh_sync_user, get_pending_app_quota, \
         register_pending_apps, qh_sync_project, qh_sync_locked_users, \
         get_users_for_update, members_to_sync
-...
             raise IOError(m)
     def get_chain_for_update(chain_id):
     def get_project_for_update(project_id):
         try:
             return Chain.objects.get_for_update(chain=chain_id)
         except Chain.DoesNotExist:
             m = _(astakos_messages.UNKNOWN_PROJECT_ID) % chain_id
             return Project.objects.get_for_update(id=project_id)
         except Project.DoesNotExist:
             m = _(astakos_messages.UNKNOWN_PROJECT_ID) % project_id
             raise IOError(m)
     def get_chain_of_application_for_update(app_id):
     def get_project_of_application_for_update(app_id):
         app = get_application(app_id)
         return Chain.objects.get_for_update(chain=app.chain_id)
         return get_project_for_update(app.chain_id)
     def get_application(application_id):
-...
             raise IOError(m)
     def get_chain_of_membership_for_update(memb_id):
     def get_project_of_membership_for_update(memb_id):
         m = get_membership_by_id(memb_id)
         return get_chain_for_update(m.project_id)
         return get_project_for_update(m.project_id)
     def get_user_by_id(user_id):
-...
     def accept_membership(memb_id, request_user=None):
         get_chain_of_membership_for_update(memb_id)
         project = get_project_of_membership_for_update(memb_id)
         membership = get_membership_by_id(memb_id)
         if not membership.can_accept():
             m = _(astakos_messages.NOT_MEMBERSHIP_REQUEST)
             raise PermissionDenied(m)
         project = membership.project
         accept_membership_checks(project, request_user)
         user = membership.person
         membership.accept()
-...
     def reject_membership(memb_id, request_user=None):
         get_chain_of_membership_for_update(memb_id)
         project = get_project_of_membership_for_update(memb_id)
         membership = get_membership_by_id(memb_id)
         if not membership.can_reject():
             m = _(astakos_messages.NOT_MEMBERSHIP_REQUEST)
             raise PermissionDenied(m)
         project = membership.project
         reject_membership_checks(project, request_user)
         user = membership.person
         membership.reject()
-...
     def cancel_membership(memb_id, request_user):
         get_chain_of_membership_for_update(memb_id)
         project = get_project_of_membership_for_update(memb_id)
         membership = get_membership_by_id(memb_id)
         if not membership.can_cancel():
-...
     def remove_membership(memb_id, request_user=None):
         get_chain_of_membership_for_update(memb_id)
         project = get_project_of_membership_for_update(memb_id)
         membership = get_membership_by_id(memb_id)
         if not membership.can_remove():
             m = _(astakos_messages.NOT_ACCEPTED_MEMBERSHIP)
             raise PermissionDenied(m)
         project = membership.project
         remove_membership_checks(project, request_user)
         user = membership.person
         membership.remove()
-...
     def enroll_member(project_id, user, request_user=None):
         get_chain_for_update(project_id)
         project = get_project_by_id(project_id)
         project = get_project_for_update(project_id)
         accept_membership_checks(project, request_user)
         try:
-...
     def leave_project(memb_id, request_user):
         get_chain_of_membership_for_update(memb_id)
         project = get_project_of_membership_for_update(memb_id)
         membership = get_membership_by_id(memb_id)
         if not membership.can_leave():
-...
     def join_project(project_id, request_user):
         get_chain_for_update(project_id)
         project = get_project_by_id(project_id)
         project = get_project_for_update(project_id)
         join_project_checks(project)
         try:
-...
         project = None
         if project_id is not None:
             get_chain_for_update(project_id)
             project = Project.objects.get(id=project_id)
             project = get_project_for_update(project_id)
             if (request_user and
                 (not project.application.owner == request_user and
-...
     def cancel_application(application_id, request_user=None, reason=""):
         get_chain_of_application_for_update(application_id)
         get_project_of_application_for_update(application_id)
         application = get_application(application_id)
         checkAllowed(application, request_user)
-...
     def dismiss_application(application_id, request_user=None, reason=""):
         get_chain_of_application_for_update(application_id)
         get_project_of_application_for_update(application_id)
         application = get_application(application_id)
         checkAllowed(application, request_user)
-...
     def deny_application(application_id, request_user=None, reason=""):
         get_chain_of_application_for_update(application_id)
         get_project_of_application_for_update(application_id)
         application = get_application(application_id)
         checkAllowed(application, request_user, admin_only=True)
-...
     def approve_application(app_id, request_user=None, reason=""):
         get_chain_of_application_for_update(app_id)
         project = get_project_of_application_for_update(app_id)
         application = get_application(app_id)
         project = application.chain
         checkAllowed(application, request_user, admin_only=True)
-...
     def terminate(project_id, request_user=None):
         get_chain_for_update(project_id)
         project = get_project_by_id(project_id)
         project = get_project_for_update(project_id)
         checkAllowed(project, request_user, admin_only=True)
         checkAlive(project)
-...
     def suspend(project_id, request_user=None):
         get_chain_for_update(project_id)
         project = get_project_by_id(project_id)
         project = get_project_for_update(project_id)
         checkAllowed(project, request_user, admin_only=True)
         checkAlive(project)
-...
     def resume(project_id, request_user=None):
         get_chain_for_update(project_id)
         project = get_project_by_id(project_id)
         project = get_project_for_update(project_id)
         checkAllowed(project, request_user, admin_only=True)
         if not project.is_suspended:

Also available in: Unified diff