|
|
"""
|
|
|
This script should run in the abs module embedded system
|
|
|
It creates a Web Application with API Restful Bottle to connect to SIR server.
|
|
|
It needs the following scripts: abs_gpio.py and bottle.py
|
|
|
"""
|
|
|
from bottle import route, run, request
|
|
|
from bottle import error
|
|
|
from abs_gpio import abs_read
|
|
|
|
|
|
#Sockets
|
|
|
import socket
|
|
|
import sys
|
|
|
|
|
|
import json
|
|
|
|
|
|
module_ip = '192.168.1.xx'
|
|
|
module_num = 'xx'
|
|
|
module_port = 5500
|
|
|
module = (module_ip,5500)
|
|
|
|
|
|
#This function decode sent characters
|
|
|
def fromChar2Binary(char):
|
|
|
#To get the real value (-33)
|
|
|
number = ord(char) - 33
|
|
|
bits = bin(number)[2:]
|
|
|
#To ensure we have a string with 6bits
|
|
|
if len(bits) < 6:
|
|
|
bits = bits.zfill(6)
|
|
|
return bits
|
|
|
|
|
|
@route('/')
|
|
|
@route('/hello')
|
|
|
def hello():
|
|
|
return "Hello World!"
|
|
|
|
|
|
"""
|
|
|
#---- Send Bits Function ----
|
|
|
@route('/write', method='POST')
|
|
|
def writebits():
|
|
|
|
|
|
#This funcion configure ABS sending bits.
|
|
|
|
|
|
try:
|
|
|
#------------Get Values-----------
|
|
|
#----------------UP---------------
|
|
|
ub2 = request.forms.get('ub2')
|
|
|
ub1 = request.forms.get('ub1')
|
|
|
ub0 = request.forms.get('ub0')
|
|
|
#--------------DOWN---------------
|
|
|
db2 = request.forms.get('db2')
|
|
|
db1 = request.forms.get('db1')
|
|
|
db0 = request.forms.get('db0')
|
|
|
|
|
|
#-----------Send Values-----------
|
|
|
#----------------UP---------------
|
|
|
ub2 = abs_write(126,ub2)
|
|
|
ub1 = abs_write(124,ub1)
|
|
|
ub0 = abs_write(122,ub0)
|
|
|
#--------------DOWN---------------
|
|
|
db2 = abs_write(120,db2)
|
|
|
db1 = abs_write(118,db1)
|
|
|
db0 = abs_write(116,db0)
|
|
|
|
|
|
if (ub2+ub1+ub0+db2+db1+db0) == 6:
|
|
|
return {"status": 1, "message": "Bits were successfully adjusted"}
|
|
|
else:
|
|
|
return {"status": 0, "message": "Couldn't configure ABS"}
|
|
|
|
|
|
except:
|
|
|
return {"status": 0, "message": "Couldn't configure ABS"}
|
|
|
"""
|
|
|
|
|
|
#------ Get Status -------
|
|
|
@route('/status', method='GET')
|
|
|
def module_status():
|
|
|
"""
|
|
|
This function returns:
|
|
|
0 : No Connected
|
|
|
1 : Connected
|
|
|
|
|
|
"""
|
|
|
message_tx = 'JROABSClnt_01CeCnMod000001MNTR10'
|
|
|
#Create the datagram socket
|
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
|
try:
|
|
|
sock.connect(module)
|
|
|
sock.send(message_tx)
|
|
|
sock.close()
|
|
|
except:
|
|
|
sock = None
|
|
|
return {"status":0, "message": "TCP Control Module not detected."}
|
|
|
return {"status": 1, "message": "Module "+module_num+" is running"}
|
|
|
|
|
|
|
|
|
#---- Get Bits Function ----
|
|
|
@route('/read', method='GET')
|
|
|
def readbits():
|
|
|
|
|
|
"""
|
|
|
This function reads the real values from the embedded system pins
|
|
|
with gpio class
|
|
|
"""
|
|
|
|
|
|
#This function reads sent bits.
|
|
|
|
|
|
#------Get Monitoring Values------
|
|
|
#----------------UP---------------
|
|
|
um2_value = abs_read(80) #(++)
|
|
|
um1_value = abs_read(82)
|
|
|
um0_value = abs_read(84) #(--)
|
|
|
#--------------DOWN---------------
|
|
|
dm2_value = abs_read(94) #(++)
|
|
|
dm1_value = abs_read(88)
|
|
|
dm0_value = abs_read(86) #(--)
|
|
|
|
|
|
allbits = [um2_value, um1_value, um0_value, dm2_value, dm1_value, dm0_value]
|
|
|
if "" not in allbits:
|
|
|
allbits = {"um2":int(um2_value), "um1": int(um1_value), "um0": int(um0_value), "dm2": int(dm2_value), "dm1": int(dm1_value), "dm0": int(dm0_value)}
|
|
|
#allbits = {"ub0":0, "ub1":0, "ub2":0, "db0":0, "db1":0, "db2":0}
|
|
|
return {"status": 1, "message": "Bits were successfully read", "allbits" : allbits}
|
|
|
else:
|
|
|
return {"status": 0, "message": "There's a problem reading bits", "allbits" : ""}
|
|
|
|
|
|
@route('/write', method='POST')
|
|
|
def writebits():
|
|
|
"""
|
|
|
This function sends configurations to the module tcp_
|
|
|
"""
|
|
|
header_rx = 'JROABSCeCnModCnMod01000108SNDFexperimento1.ab1'
|
|
|
module_rx = 'ABS_'+module_num
|
|
|
try:
|
|
|
#header_rx = request.forms.get('header')
|
|
|
#module_rx = request.forms.get('module')
|
|
|
#beams_rx = request.forms.get('beams')
|
|
|
#beams_rx = json.loads(beams_rx)
|
|
|
beams_rx = json.loads(request.body.readline())
|
|
|
beams_rx = beams_rx['beams']
|
|
|
except:
|
|
|
return {"status":0, "message": "Could not accept configuration"}
|
|
|
#print beams_rx
|
|
|
message_tx = header_rx+"\n"+module_rx+"\n"
|
|
|
for i in range(0,len(beams_rx)): #(1,len(beams_rx)+1)
|
|
|
try:
|
|
|
message_tx = message_tx+fromChar2Binary(beams_rx[i])+"\n"
|
|
|
except:
|
|
|
return {"status":0, "message": "Error in parameters from Beams List"}
|
|
|
message_tx = message_tx+"0"
|
|
|
|
|
|
|
|
|
# Create the datagram socket
|
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
|
print >>sys.stderr, 'sending "%s"' % message_tx
|
|
|
sock.connect(module)
|
|
|
sock.send(message_tx)
|
|
|
sock.close()
|
|
|
|
|
|
return {"status":1, "message": "Configuration has been successfully sent"}
|
|
|
|
|
|
@error(404)
|
|
|
def error404(error):
|
|
|
return "^^' Nothing here, try again."
|
|
|
|
|
|
run(host=module_ip, port=8080, debug=True)
|
|
|
|
