import time
import thread
import os
import sys
from socket import *
from relocator import relocate # this function changes the cwd to the program's physical location
 
def handleClient(connection):                    # in spawned thread: reply
    print connection, time.ctime()        # show this client's address                  
    data = connection.recv(1024)      # read client socket
    try:
        response = 'Server got: ' + data
    except:
        sys.stderr.write('\n\nerror in function! ')
        sys.stderr.write("%s, %s\n," % tuple(sys.exc_info()[:2]))
        response = 'There was an error with the server.'
    connection.send(response)  # send a response
    connection.close()
 
 
class service_test:
    def __init__(self):
        thread.start_new(self.do_something, tuple()) # this is run in a thread so that the service can respond to stop requests
        while True:
                if getattr(sys,'stopservice', False):
                        sys.exit()
                time.sleep(0.3)
 
    def do_something(self):
        '''
        Do something
        '''
        myHost = ''                              # server machine, '' means local host
        myPort = 50007                           # listen on a non-reserved port number
 
        sockobj = socket(AF_INET, SOCK_STREAM)           # make a TCP socket object
        sockobj.bind((myHost, myPort))                   # bind it to server port number
        sockobj.listen(5)                                # allow up to 5 pending connects
        st = '\nIm starting... ' + time.ctime() + '\n'
        print st
        print str(os.getcwd())
        print str(os.path.dirname(sys.argv[0]))
        relocate()          # this just changes the cwd to the program's physical location
        print '\ncwd: '
        print str(os.getcwd())
        print '\n'
 
 
        while True:
            connection, address = sockobj.accept()   # pass to thread for service
            print 'Server connected by', address,
            print 'at', time.ctime(), '\n'
            thread.start_new(handleClient, (connection,))
 
 
 
if __name__ == "__main__":
        tst = service_test()

import win32serviceutil
import win32service
import win32event
import os
import sys
import time, redirect
 
sys.stopdriver = "false"
 
def main():
    '''
    Modulo principal para windows
    '''
    sys.path.insert(0,os.getcwd())
    import service_module
    a = service_module.service_test() # this is the funciton from the service_module.py
 
class ServiceLauncher(win32serviceutil.ServiceFramework):
    _svc_name_ = 'ServiceTest'
    _scv_display_name_ ='ServiceTest'
 
    def __init__(self, args):
        win32serviceutil.ServiceFramework.__init__(self, args)
        self.hWaitStop = win32event.CreateEvent(None, 0, 0, None)
 
    def SvcStop(self):
        self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
        sys.stopservice = "true"
        win32event.SetEvent(self.hWaitStop)
 
    def SvcDoRun(self):
        redirect.redirect(main, '')  # this is a stream redirection function...
        # it is run like this for debugging purposes
        # this should not affect anything... I can supply this code too if I need to

import sys, os, time
from socket import *              # portable socket interface plus constants
serverHost = 'localhost'          # replaced with the IP address of server prog
serverPort = 50007                # non-reserved port used by the server
 
 
 
message = raw_input('Enter message: ')           # default text to send to server
 
sockobj = socket(AF_INET, SOCK_STREAM)      # make a TCP/IP socket object
sockobj.connect((serverHost, serverPort))   # connect to server machine and port
 
sockobj.send(message)# send message to server over socket
data = sockobj.recv(1024)               # receive line from server: up to 1k
print 'Client received:', repr(data)    # make sure it is quoted, was `x`
print 'Client recieved data at',  time.ctime(time.time())
 
sockobj.close()                             # close socket to send eof to server
 
raw_input('Press enter when done')