blob: 1b7aec36bfe9d3c8041bdf5e56de57ada40ac342 [file] [log] [blame]
#!/usr/bin/python
import copy
import json
from flask import Flask, make_response, request
from flask.ext.cors import CORS
from subprocess import call
app = Flask(__name__)
app.debug = True
CORS(app)
e_lines = {}
@app.route('/SCA_ETH_FDFr_EC/findByState', methods=['GET'])
def get_elines_by_state():
resp = make_response(json.dumps(e_lines.values()))
resp.mimetype = 'application/json'
resp.headers['Access-Control-Allow-Origin'] = '*'
return resp
@app.route('/SCA_ETH_FDFr_EC', methods=['GET'])
def get_elines():
resp = make_response(json.dumps(e_lines.values()))
resp.mimetype = 'application/json'
resp.headers['Access-Control-Allow-Origin'] = '*'
return resp
@app.route('/SCA_ETH_FDFr_EC/<name>/', methods=['GET'])
def get_eline(name):
resp = make_response(json.dumps(e_lines[int(name)]))
resp.mimetype = 'application/json'
resp.headers['Access-Control-Allow-Origin'] = '*'
return resp
# Convert long value to dotted hex value with specified length in bytes
def longToHex(l, length=6):
h = ("%x" % l)
if len(h) % 2 != 0:
h = '0' + h
result = ':'.join([h[i:i+2] for i in range(0, len(h), 2)])
prefix = '00:' * (length - (len(h) / 2) - (len(h) % 2))
return prefix + result
@app.route('/SCA_ETH_FDFr_EC', methods=['POST'])
def create_eline():
# Store E-Line
e_line = json.loads(request.data)
e_line['id'] = len(e_lines) + 1
e_lines[e_line['id']] = e_line
# Create E-Line in ONOS
flow_points = e_line['SCA_ETH_Flow_Points']
# src_host = flow_points[0]['scaEthFppUniN']['transportPort']['Hostname'] + '/-' + flow_points[0]['scaEthFppUniN']['transportPort']['Port']
# dst_host = flow_points[1]['scaEthFppUniN']['transportPort']['Hostname'] + '/-' + flow_points[1]['scaEthFppUniN']['transportPort']['Port']
src_index = int(flow_points[0]['scaEthFppUniN']['transportPort']['Hostname'][-2:])
dst_index = int(flow_points[1]['scaEthFppUniN']['transportPort']['Hostname'][-2:])
src_host = str(longToHex(src_index, 6)) + '/-1'
dst_host = str(longToHex(dst_index, 6)) + '/-1'
print 'Creating E-Line between %s (%s) and %s (%s)' % (src_index, src_host, dst_index, dst_host)
call(['onos', 'localhost', 'add-host-intent', src_host, dst_host])
# Return response
resp = make_response(json.dumps(e_line))
resp.mimetype = 'application/json'
resp.headers['Access-Control-Allow-Origin'] = '*'
return resp
if __name__ == '__main__':
app.run(host='0.0.0.0', port=6000)