# vim: tabstop=4 shiftwidth=4 softtabstop=4
# HTTP 2 COM Service
# Copyright 2013 IGpython UK
# All Rights Reserved.
# Developer: Dairon Medina
from win32api import CloseHandle, GetLastError, SetConsoleCtrlHandler
import win32serviceutil
import win32service
import win32event
import servicemanager
import traceback
import logging
import time
import os, sys
import inspect
import ConfigParser, codecs
import serial
import socket
import eventlet
import eventlet.wsgi
import json
import httplib
import ftplib
import urllib
import SocketServer
import BaseHTTPServer
ROOT = os.path.dirname(sys.executable)
path = lambda *a: os.path.join(ROOT, *a)
settings = ConfigParser.ConfigParser()
settings.read(path('config/settings.conf'))
def bridge(env, start_response):
"""
The main SERVER
"""
port = settings.get('SERIAL', 'PORT')
ser = serial.Serial(port=port, baudrate=settings.getint('SERIAL', 'BAUDRATE'), parity=settings.get('SERIAL', 'PARITY'), stopbits=settings.getint('SERIAL', 'STOPBITS'),bytesize=settings.getint('SERIAL', 'BYTESIZE'), timeout=30)
headers = [('Content-Type', 'application/json'), ('Access-Control-Allow-Origin', '*'), ('Access-Control-Allow-Methods', '*'), ('Access-Control-Max-Age', '3628800')]
if ser is not None:
data = env['PATH_INFO'][1:]
if settings.getboolean('SERIAL', 'ADDENDLINE'):
data = str(data) + '\n\r'
#print data
ser.write(data)
raw = ser.readline()
start_response('200 OK', headers)
response = {'status': 'ok', 'content': str(raw)}
return json.dumps(response)
else:
start_response('200 OK', headers)
response = {'status': 'error', 'content': 'Serial port dont return any response or there is no device connected to it.'}
return json.dumps(response)
class IGPythonService(win32serviceutil.ServiceFramework):
_svc_name_ = 'IGpython HTTP2CCOM Service'
_svc_description_ = 'IGpython HTTP2COM Service. Takes requests on HTTP port and relays to COM serial.'
_scv_display_name_ ='TCP to COM - WSGI Server'
def __init__(self, args):
win32serviceutil.ServiceFramework.__init__(self, args)
# create an event that SvcDoRun can wait on and SvcStop
# can set.
# self.stop_event = win32event.CreateEvent(None, 0, 0, None)
self._server = None
self._protocol = eventlet.wsgi.HttpProtocol
bind_addr = ('', settings.getint('WEBSERVER', 'PORT'))
self._socket = eventlet.listen(bind_addr)
SetConsoleCtrlHandler(lambda x: True, True)
self.hWaitStop = win32event.CreateEvent(None,0,0,None)
def SvcStop(self):
self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
if self._server is not None:
self._socket.close()
self._server = None
win32event.SetEvent(self.hWaitStop)
self.ReportServiceStatus(win32service.SERVICE_STOPPED)
self.run = False
def SvcDoRun(self):
servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE,
servicemanager.PYS_SERVICE_STARTED,
(self._svc_name_,''))
self.run = True
try:
self._server = eventlet.wsgi.server(self._socket, bridge, keepalive=False, debug=False, log_output=False)
except:
servicemanager.LogErrorMsg(traceback.format_exc()) # if error print it to event log
os._exit(-1)#return some value other than 0 to os so that service knows to restart
if __name__ == '__main__':
win32serviceutil.HandleCommandLine(IGPythonService)