ecc2xmpp.py

import settings
import argparse
import pathlib
import logging
import socket
import signal
import sys

from datetime import datetime

################################################################################

class xmppServer:

	BUFFER_SIZE = 4096

	def __init__(self, bind_addr, bind_port):

		self.bind_addr = bind_addr
		self.bind_port = bind_port

	############################################################################

	def handler(self, client_conn, client_addr):

		logging.info('Connection from %s', client_addr)

		data = client_conn.recv(self.BUFFER_SIZE)

		logging.info(data)

		data = client_conn.recv(self.BUFFER_SIZE)

		logging.info(data)

	############################################################################

	def run(self):

		s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

		s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # Avoids bind failures caused by old sockets in TIMED_WAIT state

		try:

			s.bind((self.bind_addr, self.bind_port))

		except Exception as msg:

			logging.info('Bind failed : %s', msg)

			sys.exit()

		logging.info('Server bound to %s:%d', self.bind_addr, self.bind_port)

		s.listen(0) # 0 -> don't allow unaccepted connections to be queued by the OS

		while True:

			(client_conn, client_addr) = s.accept()

			self.handler(client_conn, client_addr)

			#thread.start_new_thread(xmppHandler, (conn, addr))

################################################################################

def terminate(signalNumber, frame):

	logging.info('%s received - terminating' % signal.Signals(signalNumber).name)

	sys.exit()

################################################################################
### Main program ###############################################################
################################################################################

def main():

	pathlib.Path('log').mkdir(parents=True, exist_ok=True)

	logging.basicConfig(filename = 'log/{:%Y-%m-%d}.log'.format(datetime.now()),
						filemode = 'a',
						level    = logging.INFO,
						format   = '%(asctime)s - %(levelname)s : %(message)s',
						datefmt  = '%d/%m/%Y %H:%M:%S')

	logging.info('STARTUP')

	signal.signal(signal.SIGINT,  terminate)  # keyboard interrupt ^C
	signal.signal(signal.SIGTERM, terminate)  # kill [default -15]

	argparser = argparse.ArgumentParser(description='XMPP Client Bridge for ECC Messaging')

	argparser.add_argument('-a', '--addr', action='store', help='address to accept connections', type=str, default = '127.0.0.1')
	argparser.add_argument('-p', '--port', action='store', help='port for client connections'  , type=int, default = 5222)

	command_line_args = argparser.parse_args()

	logging.info('Arguments %s', vars(command_line_args))

	server = xmppServer(command_line_args.addr, command_line_args.port)

	server.run()

	logging.info('SHUTDOWN')

################################################################################

if __name__ == "__main__":

	main()

################################################################################