Synnefo

from astakos.im.api import get_services_dict

from astakos.im import settings as astakos_settings

from astakos.im.api.callpoint import AstakosCallpoint

from astakos.im.project_xctx import project_transaction_context

from astakos.im.retry_xctx import RetryException

    def decorator(func, *args, **kwargs):

        @wraps(func)

        def wrapper(request, *args, **kwargs):

            if not provider or not provider.is_active():

                raise PermissionDenied

            return func(request, *args)

        return wrapper

    return decorator

    return wrapper

    """

    Decorator that checks whether the request.user has all required auth providers

    assigned.

    """

    def decorator(func):

        @wraps(func)

        def wrapper(request, *args, **kwargs):

            if request.user.is_authenticated():

            return func(request, *args, **kwargs)

        return wrapper

    return decorator

@require_http_methods(["GET", "POST"])

@login_required

@signed_terms_required

def edit_profile(request, template_name='im/profile.html', extra_context=None):

        request.user.save()

    # existing providers

    # providers that user can add

    user_available_providers = request.user.get_available_auth_providers()

    return render_response(template_name,

                           profile_form = form,

                           user_providers = user_providers,

                           user_available_providers = user_available_providers,

                           context_instance = get_context(request,

                                                          extra_context))

        return HttpResponseRedirect(reverse('edit_profile'))

    provider = get_query(request).get('provider', 'local')

        raise PermissionDenied

    id = get_query(request).get('id')

    except AstakosUser.DoesNotExist:

        instance = None

    third_party_token = request.REQUEST.get('third_party_token', None)

    if third_party_token:

        pending = get_object_or_404(PendingThirdPartyUser,

                                    token=third_party_token)

        provider = pending.provider

        instance = pending.get_user_instance()

    try:

        if not backend:

    except Exception, e:

        form = SimpleBackend(request).get_signup_form(provider)

        messages.error(request, e)

    if request.method == 'POST':

        if form.is_valid():

            user = form.save(commit=False)

                AstakosUser.objects.get_by_identifier(user.email).delete()

            try:

                result = backend.handle_activation(user)

                status = messages.SUCCESS

                message = result.message

                if 'additional_email' in form.cleaned_data:

                    additional_email = form.cleaned_data['additional_email']

                    if additional_email != user.email:

@require_http_methods(["GET", "POST"])

@login_required

@signed_terms_required

def feedback(request, template_name='im/feedback.html', email_template_name='im/feedback_mail.txt', extra_context=None):

        response['Location'] = LOGOUT_NEXT

        response.status_code = 301

    else:

        messages.success(request, message)

        response['Location'] = reverse('index')

        response.status_code = 301

    form = EmailChangeForm(request.POST or None)

    if request.method == 'POST' and form.is_valid():

        try:

        except SendMailError, e:

            msg = e

            messages.error(request, msg)

    if request.user.is_authenticated():

        return HttpResponseRedirect(reverse('edit_profile'))

    extra_context = extra_context or {}

    try:

        u = AstakosUser.objects.get(id=user_id)

    except AstakosUser.DoesNotExist:

        messages.error(request, _(astakos_messages.ACCOUNT_UNKNOWN))

    else:

        try:

            send_activation_func(u)

            msg = _(astakos_messages.ACTIVATION_SENT)

# TODO: action only on POST and user should confirm the removal

@require_http_methods(["GET", "POST"])

def remove_auth_provider(request, pk):

    try:

    except AstakosUserAuthProvider.DoesNotExist:

        raise Http404

        return HttpResponseRedirect(reverse('edit_profile'))

    else:

        raise PermissionDenied

        return response

@require_http_methods(["GET", "POST"])

def project_add(request):

    user = request.user

@require_http_methods(["GET"])

def project_list(request):

    projects = ProjectApplication.objects.user_accessible_projects(request.user).select_related()

    table = tables.UserProjectApplicationsTable(projects, user=request.user,

@require_http_methods(["GET", "POST"])

@project_transaction_context()

def project_app_cancel(request, application_id, ctx=None):

    chain_id = None

@require_http_methods(["GET", "POST"])

def project_modify(request, application_id):

    try:

@require_http_methods(["GET", "POST"])

def project_app(request, application_id):

    return common_detail(request, application_id, project_view=False)

@require_http_methods(["GET", "POST"])

def project_detail(request, chain_id):

    return common_detail(request, chain_id)

            })

@require_http_methods(["GET", "POST"])

def project_search(request):

    q = request.GET.get('q', '')

    form = ProjectSearchForm()

        })

@require_http_methods(["POST", "GET"])

@project_transaction_context(sync=True)

def project_join(request, chain_id, ctx=None):

    next = request.GET.get('next')

    return redirect(next)

@require_http_methods(["POST", "GET"])

@project_transaction_context(sync=True)

def project_leave(request, chain_id, ctx=None):

    next = request.GET.get('next')

    return redirect(next)

@require_http_methods(["POST"])

@project_transaction_context()

def project_cancel(request, chain_id, ctx=None):

    next = request.GET.get('next')

    return redirect(next)

@require_http_methods(["POST"])

@project_transaction_context(sync=True)

def project_accept_member(request, chain_id, user_id, ctx=None):

    try:

    return redirect(reverse('project_detail', args=(chain_id,)))

@require_http_methods(["POST"])

@project_transaction_context(sync=True)

def project_remove_member(request, chain_id, user_id, ctx=None):

    try:

    return redirect(reverse('project_detail', args=(chain_id,)))

@require_http_methods(["POST"])

@project_transaction_context()

def project_reject_member(request, chain_id, user_id, ctx=None):

    try:

        next = reverse('project_list')

    return redirect(next)

def landing(request):

    return render_response(

        'im/landing.html',