Skip to content

Commit

Permalink
make Sree a new look for ceph nano
Browse files Browse the repository at this point in the history 
Signed-off-by: Sébastien Han <seb@redhat.com>
  • Loading branch information
@leseb
leseb committed May 8, 2018
1 parent c161d29 commit 4ab9969
Show file tree
Hide file tree
Showing 21 changed files with 17,040 additions and 2,657 deletions.
3 changes: 2 additions & 1 deletion .gitignore
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
.idea/
sree.cfg
*.pyc
static/js/config.json
196 changes: 109 additions & 87 deletions app.py
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#! /usr/bin/python
#encoding=utf-8
# encoding=utf-8

import json
from StringIO import StringIO
Expand All @@ -17,11 +17,23 @@

app = Flask(__name__, static_url_path='')

import urlparse


def get_url_from_req(request):
url = from_request(request, 'url')
parsed = urlparse.urlparse(url)
rgw_civetweb_port = app.config['RGW_CIVETWEB_PORT']
rgw_address = "127.0.0.1:" + rgw_civetweb_port
return urlparse.urlunparse((parsed[0], rgw_address, parsed[2], parsed[3], parsed[4], parsed[5]))


def from_request(request, k):
if not request.json:
raise Exception("Invalid Request")
return str(request.json[k])


def req(url, method):
c = pycurl.Curl()
c.setopt(pycurl.URL, url)
Expand All @@ -31,50 +43,53 @@ def req(url, method):
c.close()
return statuscode

@app.route("/createbucket", methods = ['POST'])

@app.route("/createbucket", methods=['POST'])
def create():
url = from_request(request, 'url')
statuscode = req(url, 'PUT')

if statuscode == 200:
resp = Response(response='Success', status=statuscode)
elif statuscode == 400:
resp = Response(response='Invalid Bucket Name', status=statuscode)
elif statuscode == 409:
resp = Response(response='Conflict: Bucket already Exists',
status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp


@app.route("/deletebucket", methods = ['DELETE'])
url = get_url_from_req(request)
statuscode = req(url, 'PUT')

if statuscode == 200:
resp = Response(response='Success', status=statuscode)
elif statuscode == 400:
resp = Response(
response='Invalid Bucket Name (minimum is 3 characters)', status=statuscode)
elif statuscode == 409:
resp = Response(response='Conflict: Bucket already Exists',
status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp


@app.route("/deletebucket", methods=['DELETE'])
def delete():
url = from_request(request, 'url')
statuscode = req(url, 'DELETE')

if statuscode == 204:
resp = Response(status=200)
elif statuscode == 404:
resp = Response(response='Bucket Not Exist', status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
elif statuscode == 409:
resp = Response(response='Confilct: Object Still Exists',
status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp

@app.route("/putcors", methods = ['PUT'])
url = get_url_from_req(request)
statuscode = req(url, 'DELETE')

if statuscode == 204:
resp = Response(status=200)
elif statuscode == 404:
resp = Response(response='Bucket does not exist', status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
elif statuscode == 409:
resp = Response(response='Conflict: Object still exists',
status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp


@app.route("/putcors", methods=['PUT'])
def putcors():
corsurl = from_request(request, 'url')
s3auth = from_request(request, 's3auth')
date = from_request(request, 'date')
corsurl = get_url_from_req(request)
s3auth = from_request(request, 's3auth')
date = from_request(request, 'date')

cors = '''
cors = '''
<CORSConfiguration>
<CORSRule>
<AllowedMethod>PUT</AllowedMethod>
Expand All @@ -87,62 +102,69 @@ def putcors():
<ExposeHeader>ETag</ExposeHeader>
</CORSRule>
</CORSConfiguration>'''
content_md5 = base64.b64encode(hashlib.md5(cors).digest())
c = pycurl.Curl()
c.setopt(pycurl.URL, corsurl)
c.setopt(pycurl.HTTPHEADER, ['Content-type: text/xml',
'Content-MD5: ' + content_md5,
'Authorization: ' + s3auth,
'Date: ' + date])
c.setopt(pycurl.CUSTOMREQUEST, 'PUT')
c.setopt(pycurl.POSTFIELDS, cors)
c.perform()
statuscode = c.getinfo(c.HTTP_CODE)
c.close()
if statuscode == 200:
resp = Response(status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp

@app.route("/getservice", methods = ['POST'])
def listbucketsurl():
url = from_request(request, 'url')
s3auth = from_request(request, 's3auth')
date = from_request(request, 'date')

storage = StringIO()
c = pycurl.Curl()
c.setopt(pycurl.URL, url)
c.setopt(c.WRITEFUNCTION, storage.write)
c.setopt(pycurl.HTTPHEADER, ['Authorization: ' + s3auth,
'x-amz-date: ' + date])
c.perform()
statuscode = c.getinfo(c.HTTP_CODE)
c.close()

if statuscode != 200:
if statuscode == 403:
content_md5 = base64.b64encode(hashlib.md5(cors).digest())
c = pycurl.Curl()
c.setopt(pycurl.URL, corsurl)
c.setopt(pycurl.HTTPHEADER, ['Content-type: text/xml',
'Content-MD5: ' + content_md5,
'Authorization: ' + s3auth,
'Date: ' + date])
c.setopt(pycurl.CUSTOMREQUEST, 'PUT')
c.setopt(pycurl.POSTFIELDS, cors)
c.perform()
statuscode = c.getinfo(c.HTTP_CODE)
c.close()
if statuscode == 200:
resp = Response(status=statuscode)
elif statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
else:
else:
resp = Response(response='Unknown Error', status=500)
return resp
return resp


@app.route("/getservice", methods=['POST'])
def listbucketsurl():
url = get_url_from_req(request)
s3auth = from_request(request, 's3auth')
date = from_request(request, 'date')

storage = StringIO()
c = pycurl.Curl()
c.setopt(pycurl.URL, url)
c.setopt(c.WRITEFUNCTION, storage.write)
c.setopt(pycurl.HTTPHEADER, ['Authorization: ' + s3auth,
'x-amz-date: ' + date])
c.perform()
statuscode = c.getinfo(c.HTTP_CODE)
c.close()

if statuscode != 200:
if statuscode == 403:
resp = Response(response='Access Denied', status=statuscode)
else:
resp = Response(response='Unknown Error', status=500)
return resp

content = storage.getvalue()
buckets = xmlparser.getListFromXml(content, 'Bucket')
resp = Response(response=json.dumps(buckets), status=statuscode)
resp.headers['Content-type'] = 'application/json; charset=UTF-8'
return resp

content = storage.getvalue()
buckets = xmlparser.getListFromXml(content, 'Bucket')
resp = Response(response=json.dumps(buckets), status=statuscode)
resp.headers['Content-type'] = 'application/json; charset=UTF-8'
return resp

@app.route("/")
def root():
return app.send_static_file('buckets.html')


@app.route("/<path:path>")
def static_files(path):
return send_from_directory('static', path)


if __name__ == '__main__':
app.run(host='0.0.0.0', port=5000, threaded=True)
app.config.from_pyfile('sree.cfg')
flask_port = app.config['SREE_PORT']
flask_debug = app.config['FLASK_DEBUG']
app.run(host='0.0.0.0', port=flask_port, threaded=True, debug=flask_debug)
3 changes: 3 additions & 0 deletions sree.cfg.sample
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
RGW_CIVETWEB_PORT="RGW_CIVETWEB_PORT_VALUE"
SREE_PORT=SREE_PORT_VALUE
FLASK_DEBUG=False

0 comments on commit 4ab9969

Please sign in to comment.