Revision 11bb4341

b/snf-cyclades-app/conf/20-snf-cyclades-app-api.conf
124 124
## using a user uuid)
125 125
#CYCLADES_ASTAKOS_SERVICE_TOKEN = ''
126 126
#
127
## Astakos user_catalogs endpoint
128
#CYCLADES_USER_CATALOG_URL = 'https://<astakos domain>/user_catalogs'
b/snf-cyclades-app/synnefo/api/delegate.py
1
# Copyright 2011-2012 GRNET S.A. All rights reserved.
2
#
3
# Redistribution and use in source and binary forms, with or
4
# without modification, are permitted provided that the following
5
# conditions are met:
6
#
7
#   1. Redistributions of source code must retain the above
8
#      copyright notice, this list of conditions and the following
9
#      disclaimer.
10
#
11
#   2. Redistributions in binary form must reproduce the above
12
#      copyright notice, this list of conditions and the following
13
#      disclaimer in the documentation and/or other materials
14
#      provided with the distribution.
15
#
16
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27
# POSSIBILITY OF SUCH DAMAGE.
28
#
29
# The views and conclusions contained in the software and
30
# documentation are those of the authors and should not be
31
# interpreted as representing official policies, either expressed
32
# or implied, of GRNET S.A.
33

  
34
import logging
35

  
36
from urlparse import urlparse
37
import urllib
38
import urllib2
39

  
40
from django.http import (
41
    HttpResponseNotFound, HttpResponseRedirect, HttpResponseBadRequest,
42
    HttpResponse)
43
from django.utils.http import urlencode
44
from django.views.decorators.csrf import csrf_exempt
45

  
46
from django.conf import settings
47

  
48
USER_CATALOG_URL = getattr(settings, 'CYCLADES_USER_CATALOG_URL', None)
49
USER_FEEDBACK_URL = getattr(settings, 'CYCLADES_USER_FEEDBACK_URL', None)
50

  
51
from synnefo.lib.pool.http import get_http_connection
52

  
53
logger = logging.getLogger(__name__)
54

  
55

  
56
def delegate_to_login_service(request):
57
    url = USER_LOGIN_URL
58
    if not url:
59
        return HttpResponseNotFound()
60

  
61
    p = urlparse(url)
62
    if request.is_secure():
63
        proto = 'https://'
64
    else:
65
        proto = 'http://'
66
    params = dict([(k, v) for k, v in request.GET.items()])
67
    uri = proto + p.netloc + p.path + '?' + urlencode(params)
68
    return HttpResponseRedirect(uri)
69

  
70

  
71
def proxy(request, url, headers={}, body=None):
72
    p = urlparse(url)
73

  
74
    kwargs = {}
75
    kwargs['headers'] = headers
76
    kwargs['headers'].update(request.META)
77
    kwargs['body'] = body
78
    kwargs['headers'].setdefault('content-type', 'application/json')
79
    kwargs['headers'].setdefault('content-length', len(body) if body else 0)
80

  
81
    conn = get_http_connection(p.netloc, p.scheme)
82
    try:
83
        conn.request(request.method, p.path + '?' + p.query, **kwargs)
84
        response = conn.getresponse()
85
        length = response.getheader('content-length', None)
86
        data = response.read(length)
87
        status = int(response.status)
88
        return HttpResponse(data, status=status)
89
    finally:
90
        conn.close()
91

  
92
@csrf_exempt
93
def delegate_to_feedback_service(request):
94
    token = request.META.get('HTTP_X_AUTH_TOKEN')
95
    headers = {'X-Auth-Token': token}
96
    return proxy(
97
        request, USER_FEEDBACK_URL, headers=headers, body=request.raw_post_data)
98

  
99
@csrf_exempt
100
def delegate_to_user_catalogs_service(request):
101
    token = request.META.get('HTTP_X_AUTH_TOKEN')
102
    headers = {'X-Auth-Token': token, 'content-type': 'application/json'}
103
    return proxy(
104
        request, USER_CATALOG_URL, headers=headers, body=request.raw_post_data)
105

  
b/snf-cyclades-app/synnefo/app_settings/default/api.py
124 124
# using a user uuid)
125 125
CYCLADES_ASTAKOS_SERVICE_TOKEN = ''
126 126

  
127
# Astakos user_catalogs endpoint
128
CYCLADES_USER_CATALOG_URL = 'https://<astakos domain>/user_catalogs'
b/snf-cyclades-app/synnefo/app_settings/urls.py
32 32
# or implied, of GRNET S.A.
33 33

  
34 34
from django.conf.urls.defaults import *
35
from django.conf import settings
35 36

  
36 37
urlpatterns = patterns('',
37 38
    (r'^ui/', include('synnefo.ui.urls')),
......
45 46
    (r'^helpdesk/', include('synnefo.helpdesk.urls')),
46 47
)
47 48

  
49
PROXY_USER_SERVICES = getattr(settings, 'CYCLADES_PROXY_USER_SERVICES', True)
50
if PROXY_USER_SERVICES:
51
    urlpatterns += patterns(
52
        '',
53
        (r'^feedback/?$', 'synnefo.api.delegate.delegate_to_feedback_service'),
54
        (r'^user_catalogs/?$', 'synnefo.api.delegate.delegate_to_user_catalogs_service'))
55

  

Also available in: Unified diff